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

Only send 'delete channel' event when channel was removed
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2020-08-09 10:06:12 +02:00
parent 330931742b
commit 08ae30b305
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/eksterd/memory.go
View File

@ -260,6 +260,14 @@ func (b *memoryBackend) ChannelsDelete(uid string) error {
conn := b.pool.Get()
defer conn.Close()
removed := false
b.lock.RLock()
if _, e := b.Channels[uid]; e {
removed = true
}
b.lock.RUnlock()
removeChannelFromRedis(conn, uid)
b.lock.Lock()
@ -267,7 +275,9 @@ 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}}
if removed {
b.broker.Notifier <- sse.Message{Event: "delete channel", Object: channelDeletedMessage{1, uid}}
}
return nil
}