From 1b02a8181a8b2f089287d3f93373793228c588a6 Mon Sep 17 00:00:00 2001
From: Peter Stuifzand <peter@stuifzand.eu>
Date: Wed, 19 Aug 2020 16:06:55 +0200
Subject: [PATCH] Fetch the channel when it doesn't exist

---
 cmd/eksterd/memory.go | 21 ++++++++++++++++++++-
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/cmd/eksterd/memory.go b/cmd/eksterd/memory.go
index cfdcf7a..12c9caa 100644
--- a/cmd/eksterd/memory.go
+++ b/cmd/eksterd/memory.go
@@ -215,10 +215,15 @@ func (b *memoryBackend) ChannelsGetList() ([]microsub.Channel, error) {
 
 // ChannelsCreate creates a channels
 func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) {
-	defer b.save()
+	// Try to fetch the channel, if it exists, we don't create it
+	if channel, e := b.fetchChannel(name); e {
+		return channel, nil
+	}
 
+	// Otherwise create the channel
 	channel := b.createChannel(name)
 	b.setChannel(channel)
+	b.save()
 
 	conn := b.pool.Get()
 	defer conn.Close()
@@ -834,9 +839,23 @@ func (b *memoryBackend) createChannel(name string) microsub.Channel {
 	return channel
 }
 
+func (b *memoryBackend) fetchChannel(name string) (microsub.Channel, bool) {
+	b.lock.RLock()
+	defer b.lock.RUnlock()
+
+	for _, c := range b.Channels {
+		if c.Name == name {
+			return c, true
+		}
+	}
+
+	return microsub.Channel{}, false
+}
+
 func (b *memoryBackend) setChannel(channel microsub.Channel) {
 	b.lock.Lock()
 	defer b.lock.Unlock()
+
 	b.Channels[channel.UID] = channel
 	b.Feeds[channel.UID] = []microsub.Feed{}
 	b.NextUID++