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

Create channel information when creating channel

Browse Source
This commit is contained in:
Peter Stuifzand 2018-07-03 22:44:53 +02:00
parent 71a9040eba
commit 209e7510c1
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/eksterd/memory.go
View File

@ -162,6 +162,10 @@ func (b *memoryBackend) ChannelsGetList() []microsub.Channel {
// ChannelsCreate creates a channels // ChannelsCreate creates a channels
func (b *memoryBackend) ChannelsCreate(name string) microsub.Channel { func (b *memoryBackend) ChannelsCreate(name string) microsub.Channel {
defer b.save() defer b.save()
conn := pool.Get()
defer conn.Close()
uid := fmt.Sprintf("%04d", b.NextUid) uid := fmt.Sprintf("%04d", b.NextUid)
channel := microsub.Channel{ channel := microsub.Channel{
UID: uid, UID: uid,
@ -171,6 +175,9 @@ func (b *memoryBackend) ChannelsCreate(name string) microsub.Channel {
b.Channels[channel.UID] = channel b.Channels[channel.UID] = channel
b.Feeds[channel.UID] = []microsub.Feed{} b.Feeds[channel.UID] = []microsub.Feed{}
b.NextUid++ b.NextUid++
conn.Do("SADD", "channels", uid)
conn.Do("SETNX", "channel_sortorder_"+uid, 99999)
return channel return channel
} }