From d31d0595dab3de1ff5cb6e6fed0e8aec3a0e7711 Mon Sep 17 00:00:00 2001
From: Tit Petric <black@scene-si.org>
Date: Tue, 11 Sep 2018 20:47:07 +0200
Subject: [PATCH] add(sam): example usage of an events broadcast

---
 sam/service/message.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/sam/service/message.go b/sam/service/message.go
index 6b7b57b73..f89424cb7 100644
--- a/sam/service/message.go
+++ b/sam/service/message.go
@@ -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) {