From 13484d1834de352164b42c00168e1bf54763c8e7 Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Sat, 16 Apr 2022 23:55:10 +0200 Subject: [PATCH] Problem: no events is sent when a channel is created Solution: fix bug when checking if channel was created --- cmd/eksterd/memory.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/eksterd/memory.go b/cmd/eksterd/memory.go index 5f0283d..981051e 100644 --- a/cmd/eksterd/memory.go +++ b/cmd/eksterd/memory.go @@ -186,7 +186,7 @@ func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) { for { varMicrosub.Add("ChannelsCreate.RandStringBytes", 1) 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 { log.Println("channels insert", err) if !shouldRetryWithNewUID(err, try) { @@ -195,7 +195,7 @@ func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) { try++ continue } - if n, err := result.RowsAffected(); err != nil { + if n, err := result.RowsAffected(); err == nil { if n > 0 { b.broker.Notifier <- sse.Message{Event: "new channel", Object: channelMessage{1, channel}} }