From 330931742b252ee95e4c5ca8b2007b854a9fc8c9 Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Sun, 9 Aug 2020 09:59:11 +0200 Subject: [PATCH] Add event 'delete channel' --- cmd/eksterd/memory.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/cmd/eksterd/memory.go b/cmd/eksterd/memory.go index 2130cd1..b9b5d2c 100644 --- a/cmd/eksterd/memory.go +++ b/cmd/eksterd/memory.go @@ -63,6 +63,11 @@ type channelMessage struct { Channel microsub.Channel `json:"channel"` } +type channelDeletedMessage struct { + Version int `json:"version"` + UID string `json:"uid"` +} + type newItemMessage struct { Item microsub.Item `json:"item"` Channel string `json:"channel"` @@ -262,6 +267,8 @@ func (b *memoryBackend) ChannelsDelete(uid string) error { delete(b.Feeds, uid) b.lock.Unlock() + b.broker.Notifier <- sse.Message{Event: "delete channel", Object: channelDeletedMessage{1, uid}} + return nil }