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})
 }