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 }