created testfile

internal/db/inmemory/map.go

@@ -23,6 +23,13 @@ func (m *Map[K, V]) lazyInit() {
 	}
 }
 
+func NewMap[K comparable, V Value[K]]() *Map[K, V] {
+	return &Map[K, V]{
+		data: make(map[K]*list.Element),
+		l:    list.List{},
+	}
+}
+
 func (m *Map[K, V]) Add(k K, v V) {
 	m.mu.Lock()
 	defer m.mu.Unlock()

internal/db/inmemory/map_test.go

@@ -0,0 +1,32 @@
+package inmemory
+
+import (
+	"context"
+	"testing"
+
+	"github.com/lordvidex/gostream/internal/entity"
+	gostreamv1 "github.com/lordvidex/gostream/pkg/api/gostream/v1"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+func TestMap(t *testing.T) {
+	m := NewMap[uint64, *entity.User]()
+	ch, err := NewCache(context.Background(), m, nil)
+	m.AddAll([]*entity.User{
+		{User: &gostreamv1.User{Id: 2, Nationality: "RU", Age: 22, Name: "Evans"}},
+		{User: &gostreamv1.User{Id: 1, Nationality: "CA", Age: 4, Name: "Joe"}},
+		{User: &gostreamv1.User{Id: 3, Nationality: "RU", Age: 14, Name: "Evans Jones"}},
+	})
+	require.NoError(t, err)
+	ch.computeHash()
+	fromDB := "37a3282bedee25ce3ad52bc24e08c6de" // select md5_chain(id || name || age || nationality) FROM stream_users
+	assert.Equal(t, fromDB, ch.dataHash)
+}
+
+func TestMap_Get(t *testing.T) {
+	m := NewMap[uint64, *entity.User]()
+	_, ok := m.Get(0)
+	assert.Equal(t, false, ok)
+}
+