totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-23 15:51:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix missing event

Browse Source
This commit is contained in:
Asim Aslam
2021-11-01 17:04:38 +00:00
parent 828ca26225
commit 1f1fbad201
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

@@ -75,7 +75,7 @@ func (h *Notes) Create(ctx context.Context, req *pb.CreateRequest, rsp *pb.Creat
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", "event": "create",
"note": note, "note": note,
}), }),
}) })
@@ -161,7 +161,7 @@ func (h *Notes) Update(ctx context.Context, req *pb.UpdateRequest, rsp *pb.Updat
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", "event": "update",
"note": note, "note": note,
}), }),
}) })
@@ -255,7 +255,7 @@ func (h *Notes) Delete(ctx context.Context, req *pb.DeleteRequest, rsp *pb.Delet
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", "event": "delete",
"note": note, "note": note,
}), }),
}) })