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

Problem: no events is sent when a channel is created

Browse Source 
Solution: fix bug when checking if channel was created
This commit is contained in:
Peter Stuifzand 2022-04-16 23:55:10 +02:00
parent 6bf8417451
commit 13484d1834
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/eksterd/memory.go
View File

@ -186,7 +186,7 @@ func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) {
for { for {
varMicrosub.Add("ChannelsCreate.RandStringBytes", 1) varMicrosub.Add("ChannelsCreate.RandStringBytes", 1)
channel.UID = util.RandStringBytes(24) channel.UID = util.RandStringBytes(24)
result, err := b.database.Exec(`insert into "channels" ("uid", "name", "created_at") values($1, $2, DEFAULT)`, channel.UID, channel.Name) result, err := b.database.Exec(`insert into "channels" ("uid", "name", "created_at") values ($1, $2, DEFAULT)`, channel.UID, channel.Name)
if err != nil { if err != nil {
log.Println("channels insert", err) log.Println("channels insert", err)
if !shouldRetryWithNewUID(err, try) { if !shouldRetryWithNewUID(err, try) {
@ -195,7 +195,7 @@ func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) {
try++ try++
continue continue
} }
if n, err := result.RowsAffected(); err != nil { if n, err := result.RowsAffected(); err == nil {
if n > 0 { if n > 0 {
b.broker.Notifier <- sse.Message{Event: "new channel", Object: channelMessage{1, channel}} b.broker.Notifier <- sse.Message{Event: "new channel", Object: channelMessage{1, channel}}
} }