From e582fa42bb1718b522b4d9639a19ac19f8fadb21 Mon Sep 17 00:00:00 2001
From: Peter Stuifzand <peter@stuifzand.eu>
Date: Wed, 19 Aug 2020 16:58:33 +0200
Subject: [PATCH] Add tests for not creating duplicate channels

---
 cmd/eksterd/memory_test.go | 114 +++++++++++++++++++++++++++++++++++++
 1 file changed, 114 insertions(+)
 create mode 100644 cmd/eksterd/memory_test.go

diff --git a/cmd/eksterd/memory_test.go b/cmd/eksterd/memory_test.go
new file mode 100644
index 0000000..eb0321a
--- /dev/null
+++ b/cmd/eksterd/memory_test.go
@@ -0,0 +1,114 @@
+package main
+
+import (
+	"reflect"
+	"sync"
+	"testing"
+	"time"
+
+	"github.com/gomodule/redigo/redis"
+	"p83.nl/go/ekster/pkg/microsub"
+	"p83.nl/go/ekster/pkg/sse"
+)
+
+func Test_memoryBackend_ChannelsCreate(t *testing.T) {
+	type fields struct {
+		hubIncomingBackend hubIncomingBackend
+		lock               sync.RWMutex
+		Channels           map[string]microsub.Channel
+		Feeds              map[string][]microsub.Feed
+		Settings           map[string]channelSetting
+		NextUID            int
+		Me                 string
+		TokenEndpoint      string
+		AuthEnabled        bool
+		ticker             *time.Ticker
+		quit               chan struct{}
+		broker             *sse.Broker
+		pool               *redis.Pool
+	}
+	type args struct {
+		name string
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		args    args
+		want    microsub.Channel
+		wantErr bool
+	}{
+		{
+			name: "Duplicate channel",
+			fields: fields{
+				hubIncomingBackend: hubIncomingBackend{},
+				lock:               sync.RWMutex{},
+				Channels: func() map[string]microsub.Channel {
+					channels := make(map[string]microsub.Channel)
+					channels["1234"] = microsub.Channel{
+						UID:  "1234",
+						Name: "Test",
+						Unread: microsub.Unread{
+							Type:        microsub.UnreadCount,
+							Unread:      false,
+							UnreadCount: 0,
+						},
+					}
+					return channels
+				}(),
+				Feeds: func() map[string][]microsub.Feed {
+					feeds := make(map[string][]microsub.Feed)
+					return feeds
+				}(),
+				Settings:      nil,
+				NextUID:       1,
+				Me:            "",
+				TokenEndpoint: "",
+				AuthEnabled:   false,
+				ticker:        nil,
+				quit:          nil,
+				broker:        nil,
+				pool:          nil,
+			},
+			args: args{
+				name: "Test",
+			},
+			want: microsub.Channel{
+				UID:  "1234",
+				Name: "Test",
+				Unread: microsub.Unread{
+					Type:        microsub.UnreadCount,
+					Unread:      false,
+					UnreadCount: 0,
+				},
+			},
+			wantErr: false,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			b := &memoryBackend{
+				hubIncomingBackend: tt.fields.hubIncomingBackend,
+				lock:               tt.fields.lock,
+				Channels:           tt.fields.Channels,
+				Feeds:              tt.fields.Feeds,
+				Settings:           tt.fields.Settings,
+				NextUID:            tt.fields.NextUID,
+				Me:                 tt.fields.Me,
+				TokenEndpoint:      tt.fields.TokenEndpoint,
+				AuthEnabled:        tt.fields.AuthEnabled,
+				ticker:             tt.fields.ticker,
+				quit:               tt.fields.quit,
+				broker:             tt.fields.broker,
+				pool:               tt.fields.pool,
+			}
+			got, err := b.ChannelsCreate(tt.args.name)
+			if (err != nil) != tt.wantErr {
+				t.Errorf("ChannelsCreate() error = %v, wantErr %v", err, tt.wantErr)
+				return
+			}
+			if !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("ChannelsCreate() got = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}