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

Add channel to new item message
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2019-08-18 13:15:03 +02:00
parent 449e6321c6
commit b3ecad3c92
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/eksterd/memory.go
View File

@ -641,9 +641,14 @@ 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
Channel string
}
// 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: item} b.broker.Notifier <- sse.Message{Event: "new item", Object: newItemMessage{item, channel}}
} }
return err return err