add(sam): example usage of an events broadcast

2018-09-11 20:47:07 +02:00
parent 48d47b95e8
commit d31d0595da
1 changed files with 5 additions and 1 deletions
@@ -125,7 +125,11 @@ func (svc message) Create(ctx context.Context, mod *types.Message) (*types.Messa

 	mod.UserID = currentUserID

-	return svc.rpo.CreateMessage(mod)
+	message, err := svc.rpo.CreateMessage(mod)
+	if err == nil {
+		PubSub().Event(ctx, "new message added")
+	}
+	return message, err
 }

 func (svc message) Update(ctx context.Context, mod *types.Message) (*types.Message, error) {