Adding internal/redis/key.go

internal/redis/key.go

@@ -0,0 +1,17 @@
+package redis
+
+import (
+	"fmt"
+)
+
+// Key consists of a namespace and a channel.
+// And is encoded to a string in this format: `<namespace>::<channel>`
+
+type Key struct {
+	NS      Namespace
+	Channel ChannelInterface
+}
+
+func (k Key) String() string {
+	return fmt.Sprintf("%s::%s", k.NS, k.Channel)
+}

internal/redis/key_test.go

@@ -0,0 +1,31 @@
+package redis
+
+import "testing"
+
+func TestKey_String(t *testing.T) {
+	type fields struct {
+		NS      Namespace
+		Channel ChannelInterface
+	}
+	tests := []struct {
+		name   string
+		fields fields
+		want   string
+	}{
+		{"Empty", fields{NS: Namespace{}, Channel: Channel{}}, "ship.0000000000000000000000000000000000000000000000000000000000000000::"},
+		{"Transactions", fields{NS: Namespace{ChainID: "id"}, Channel: Channel{"transactions"}}, "ship.id::transactions"},
+		{"Nested", fields{NS: Namespace{ChainID: "id"}, Channel: Channel{"one.two"}}, "ship.id::one.two"},
+		{"Action", fields{NS: Namespace{ChainID: "id"}, Channel: ActionChannel{Contract: "mycontract"}}, "ship.id::actions.contract:mycontract"},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			k := Key{
+				NS:      tt.fields.NS,
+				Channel: tt.fields.Channel,
+			}
+			if got := k.String(); got != tt.want {
+				t.Errorf("Key.String() = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}