Backend: Add unit tests for internal/workers

internal/session/data_test.go

@@ -0,0 +1,17 @@
+package session
+
+import (
+	"github.com/stretchr/testify/assert"
+	"testing"
+)
+
+func TestUIDs_String(t *testing.T) {
+	uid := UIDs{"dghjkfd", "dfgehrih"}
+	assert.Equal(t, "dghjkfd,dfgehrih", uid.String())
+}
+
+func TestData_HasShare(t *testing.T) {
+	data := Data{Shares: []string{"abc123", "def444"}}
+	assert.True(t, data.HasShare("def444"))
+	assert.False(t, data.HasShare("xxx"))
+}

internal/workers/meta_test.go

@@ -35,3 +35,12 @@ func TestPrism_Start(t *testing.T) {
 		t.Fatal(err)
 	}
 }
+
+func TestMeta_originalsPath(t *testing.T) {
+	conf := config.TestConfig()
+
+	worker := NewMeta(conf)
+
+	assert.IsType(t, &Meta{}, worker)
+	assert.Equal(t, "/go/src/github.com/photoprism/photoprism/storage/testdata/originals", worker.originalsPath())
+}

internal/workers/share_test.go

@@ -1,6 +1,7 @@
 package workers
 
 import (
+	"github.com/photoprism/photoprism/internal/mutex"
 	"testing"
 
 	"github.com/photoprism/photoprism/internal/config"
@@ -14,3 +15,29 @@ func TestNewShare(t *testing.T) {
 
 	assert.IsType(t, &Share{}, worker)
 }
+
+func TestShare_Start(t *testing.T) {
+	conf := config.TestConfig()
+
+	worker := NewShare(conf)
+
+	assert.IsType(t, &Share{}, worker)
+
+	if err := mutex.ShareWorker.Start(); err != nil {
+		t.Fatal(err)
+	}
+
+	if err := worker.Start(); err == nil {
+		t.Fatal("error expected")
+	}
+
+	mutex.ShareWorker.Stop()
+
+	if err := worker.Start(); err != nil {
+		t.Fatal(err)
+	}
+
+	if err := worker.Start(); err != nil {
+		t.Fatal(err)
+	}
+}

internal/workers/sync_test.go

@@ -1,6 +1,7 @@
 package workers
 
 import (
+	"github.com/photoprism/photoprism/internal/mutex"
 	"testing"
 
 	"github.com/photoprism/photoprism/internal/config"
@@ -14,3 +15,29 @@ func TestNewSync(t *testing.T) {
 
 	assert.IsType(t, &Sync{}, worker)
 }
+
+func TestSync_Start(t *testing.T) {
+	conf := config.TestConfig()
+
+	worker := NewSync(conf)
+
+	assert.IsType(t, &Sync{}, worker)
+
+	if err := mutex.SyncWorker.Start(); err != nil {
+		t.Fatal(err)
+	}
+
+	if err := worker.Start(); err == nil {
+		t.Fatal("error expected")
+	}
+
+	mutex.SyncWorker.Stop()
+
+	if err := worker.Start(); err != nil {
+		t.Fatal(err)
+	}
+
+	if err := worker.Start(); err != nil {
+		t.Fatal(err)
+	}
+}