From 99401065a72da58711b67d732c5af7a7057b8263 Mon Sep 17 00:00:00 2001 From: Denis Arh Date: Sat, 28 Jul 2018 11:20:44 +0200 Subject: [PATCH] Add channel to delete message --- sam/websocket/incoming/messages.go | 3 ++- sam/websocket/incoming_message.go | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/sam/websocket/incoming/messages.go b/sam/websocket/incoming/messages.go index 8fb6acccb..85a94ad82 100644 --- a/sam/websocket/incoming/messages.go +++ b/sam/websocket/incoming/messages.go @@ -12,6 +12,7 @@ type ( } MessageDelete struct { - ID string `json:"id"` + ChannelID string `json:"cid"` + ID string `json:"id"` } ) diff --git a/sam/websocket/incoming_message.go b/sam/websocket/incoming_message.go index 9d4bf85a1..d70820be7 100644 --- a/sam/websocket/incoming_message.go +++ b/sam/websocket/incoming_message.go @@ -48,6 +48,6 @@ func (s *Session) messageDelete(ctx context.Context, payload *incoming.Payload) if err := service.Message().Delete(ctx, id); err != nil { return err } - // @todo: delete broadcast to channel - return s.sendMessageChannel("TODO", &outgoing.MessageDelete{request.ID}) + + return s.sendMessageChannel(request.ChannelID, &outgoing.MessageDelete{request.ID}) }