From 1f1fbad2019055c9d01e921630d9c6229220f535 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Mon, 1 Nov 2021 17:04:38 +0000 Subject: [PATCH] fix missing event --- notes/handler/notes.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/notes/handler/notes.go b/notes/handler/notes.go index 5c8b41f..795c92d 100644 --- a/notes/handler/notes.go +++ b/notes/handler/notes.go @@ -75,7 +75,7 @@ func (h *Notes) Create(ctx context.Context, req *pb.CreateRequest, rsp *pb.Creat h.Stream.Publish(ctx, &streamPb.PublishRequest{ Topic: "notes", Message: newMessage(map[string]interface{}{ - "type": "create", + "event": "create", "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{ Topic: "notes", Message: newMessage(map[string]interface{}{ - "type": "update", + "event": "update", "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{ Topic: "notes", Message: newMessage(map[string]interface{}{ - "type": "delete", + "event": "delete", "note": note, }), })