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

Extract function to remove channel from Redis

Browse Source
This commit is contained in:
Peter Stuifzand 2018-10-03 19:09:56 +02:00
parent 7252675aba
commit 7f4eb2e7e3
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/eksterd/memory.go
View File

@ -267,6 +267,11 @@ func (b *memoryBackend) ChannelsUpdate(uid, name string) (microsub.Channel, erro
return microsub.Channel{}, fmt.Errorf("Channel %s does not exist", uid) return microsub.Channel{}, fmt.Errorf("Channel %s does not exist", uid)
} }
func removeChannelFromRedis(conn redis.Conn, uid string) {
conn.Do("SREM", "channels", uid)
conn.Do("DEL", "channel_sortorder_"+uid)
}
// ChannelsDelete deletes a channel // ChannelsDelete deletes a channel
func (b *memoryBackend) ChannelsDelete(uid string) error { func (b *memoryBackend) ChannelsDelete(uid string) error {
defer b.save() defer b.save()
@ -274,8 +279,7 @@ func (b *memoryBackend) ChannelsDelete(uid string) error {
conn := pool.Get() conn := pool.Get()
defer conn.Close() defer conn.Close()
conn.Do("SREM", "channels", uid) removeChannelFromRedis(conn, uid)
conn.Do("DEL", "channel_sortorder_"+uid)
b.lock.Lock() b.lock.Lock()
delete(b.Channels, uid) delete(b.Channels, uid)