totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-17 05:14:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix notes

Browse Source
This commit is contained in:
Asim Aslam
2021-11-01 15:33:59 +00:00
parent ad3674a4de
commit 7eb9bdca87
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
notes/handler/notes.go
View File

@@ -69,7 +69,7 @@ func (h *Notes) Create(ctx context.Context, req *pb.CreateRequest, rsp *pb.Creat
// return the note in the response // return the note in the response
rsp.Note = note rsp.Note = note
go h.Stream.Publish(ctx, &streamPb.PublishRequest{ h.Stream.Publish(ctx, &streamPb.PublishRequest{
Topic: "notes", Topic: "notes",
Message: newMessage(map[string]interface{}{ Message: newMessage(map[string]interface{}{
"type": "create", "type": "create",
@@ -155,7 +155,7 @@ func (h *Notes) Update(ctx context.Context, req *pb.UpdateRequest, rsp *pb.Updat
return errors.InternalServerError("notes.update", "Error writing to store: %v", err.Error()) return errors.InternalServerError("notes.update", "Error writing to store: %v", err.Error())
} }
go h.Stream.Publish(ctx, &streamPb.PublishRequest{ h.Stream.Publish(ctx, &streamPb.PublishRequest{
Topic: "notes", Topic: "notes",
Message: newMessage(map[string]interface{}{ Message: newMessage(map[string]interface{}{
"type": "update", "type": "update",
@@ -242,7 +242,7 @@ func (h *Notes) Delete(ctx context.Context, req *pb.DeleteRequest, rsp *pb.Delet
return errors.InternalServerError("notes.delete", "Failed to delete note") return errors.InternalServerError("notes.delete", "Failed to delete note")
} }
go h.Stream.Publish(ctx, &streamPb.PublishRequest{ h.Stream.Publish(ctx, &streamPb.PublishRequest{
Topic: "notes", Topic: "notes",
Message: newMessage(map[string]interface{}{ Message: newMessage(map[string]interface{}{
"type": "delete", "type": "delete",