peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Add 'new channel' and 'update channel' events
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2020-08-09 09:50:23 +02:00
parent 199514857a
commit 1144c615da
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
cmd/eksterd/memory.go
View File

@ -58,6 +58,16 @@ type channelSetting struct {
ChannelType string ChannelType string
} }
type channelMessage struct {
Version int `json:"version"`
Channel microsub.Channel `json:"channel"`
}
type newItemMessage struct {
Item microsub.Item `json:"item"`
Channel string `json:"channel"`
}
// Debug interface for easy of use in other packages // Debug interface for easy of use in other packages
type Debug interface { type Debug interface {
Debug() Debug()
@ -210,6 +220,8 @@ func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) {
updateChannelInRedis(conn, channel.UID, DefaultPrio) updateChannelInRedis(conn, channel.UID, DefaultPrio)
b.broker.Notifier <- sse.Message{Event: "new channel", Object: channelMessage{1, channel}}
return channel, nil return channel, nil
} }
@ -228,6 +240,8 @@ func (b *memoryBackend) ChannelsUpdate(uid, name string) (microsub.Channel, erro
b.Channels[uid] = c b.Channels[uid] = c
b.lock.Unlock() b.lock.Unlock()
b.broker.Notifier <- sse.Message{Event: "update channel", Object: channelMessage{1, c}}
return c, nil return c, nil
} }
@ -673,11 +687,6 @@ func (b *memoryBackend) channelAddItem(channel string, item microsub.Item) error
timelineBackend := b.getTimeline(channel) timelineBackend := b.getTimeline(channel)
added, err := timelineBackend.AddItem(item) added, err := timelineBackend.AddItem(item)
type newItemMessage struct {
Item microsub.Item `json:"item"`
Channel string `json:"channel"`
}
// Sent message to Server-Sent-Events // Sent message to Server-Sent-Events
if added { if added {
b.broker.Notifier <- sse.Message{Event: "new item", Object: newItemMessage{item, channel}} b.broker.Notifier <- sse.Message{Event: "new item", Object: newItemMessage{item, channel}}