Restructure repo: move Go server into player-server/

1 files changed, 190 insertions, 0 deletions

diff --git a/player-server/internal/service/no_rows_test.go b/player-server/internal/service/no_rows_test.go
new file mode 100644
index 0000000..e8186f2
--- /dev/null
+++ b/player-server/internal/service/no_rows_test.go
@@ -0,0 +1,190 @@
+package service
+
+import (
+	"context"
+	"errors"
+	"testing"
+
+	"codeberg.org/snonux/player/internal/model"
+	"codeberg.org/snonux/player/internal/repository"
+)
+
+func TestService_NoRows_ReturnsNil(t *testing.T) {
+	ctx := context.Background()
+
+	t.Run("GetMediaDetail nil media", func(t *testing.T) {
+		store := &repository.MockStore{
+			MediaRepo: repository.MockMediaRepo{
+				GetMediaByIDFunc: func(ctx context.Context, id int64) (*model.Media, error) {
+					return nil, nil
+				},
+			},
+		}
+		svc := NewMediaService(store, newMockClock(), "/tmp/media", nil, nil)
+		detail, err := svc.GetMediaDetail(ctx, 99, 1)
+		if !errors.Is(err, ErrNotFound) {
+			t.Fatalf("expected ErrNotFound, got %v", err)
+		}
+		if detail != nil {
+			t.Fatalf("expected nil detail, got %+v", detail)
+		}
+	})
+
+	t.Run("GetNote nil", func(t *testing.T) {
+		store := &repository.MockStore{
+			MediaRepo: repository.MockMediaRepo{
+				GetMediaByIDFunc: func(ctx context.Context, id int64) (*model.Media, error) {
+					return &model.Media{ID: 1, SetID: 1}, nil
+				},
+			},
+			UserRepo: repository.MockUserRepo{
+				GetUserByIDFunc: func(ctx context.Context, id int64) (*model.User, error) {
+					return &model.User{ID: id, IsAdmin: true}, nil
+				},
+			},
+			SetRepo: repository.MockSetRepo{
+				GetSetByIDFunc: func(ctx context.Context, id int64) (*model.Set, error) {
+					return &model.Set{ID: id}, nil
+				},
+			},
+			NoteRepo: repository.MockNoteRepo{
+				GetNoteFunc: func(ctx context.Context, mediaID, userID int64) (*model.Note, error) {
+					return nil, nil
+				},
+			},
+		}
+		svc := NewMediaService(store, newMockClock(), "/tmp/media", nil, nil)
+		note, err := svc.GetNote(ctx, 1, 1)
+		if err != nil {
+			t.Fatalf("expected no error, got %v", err)
+		}
+		if note != nil {
+			t.Fatalf("expected nil note, got %+v", note)
+		}
+	})
+
+	t.Run("AssignTag creates missing tag", func(t *testing.T) {
+		store := &repository.MockStore{
+			MediaRepo: repository.MockMediaRepo{
+				GetMediaByIDFunc: func(ctx context.Context, id int64) (*model.Media, error) {
+					return &model.Media{ID: 1, SetID: 1}, nil
+				},
+			},
+			UserRepo: repository.MockUserRepo{
+				GetUserByIDFunc: func(ctx context.Context, id int64) (*model.User, error) {
+					return &model.User{ID: id, IsAdmin: true}, nil
+				},
+			},
+			SetRepo: repository.MockSetRepo{
+				GetSetByIDFunc: func(ctx context.Context, id int64) (*model.Set, error) {
+					return &model.Set{ID: id}, nil
+				},
+			},
+			TagRepo: repository.MockTagRepo{
+				GetTagByNameFunc: func(ctx context.Context, name string) (*model.Tag, error) {
+					return nil, nil
+				},
+				CreateTagFunc: func(ctx context.Context, name string) (int64, error) {
+					return 42, nil
+				},
+				AssignTagFunc: func(ctx context.Context, mediaID, tagID int64) error {
+					return nil
+				},
+			},
+		}
+		svc := NewMediaService(store, newMockClock(), "/tmp/media", nil, nil)
+		if err := svc.AssignTag(ctx, 1, 1, "newtag"); err != nil {
+			t.Fatalf("expected no error, got %v", err)
+		}
+	})
+
+	t.Run("UpdateProgress with nil accumulator", func(t *testing.T) {
+		store := &repository.MockStore{
+			PlaybackProgressRepo: repository.MockPlaybackProgressRepo{
+				UpsertProgressFunc: func(ctx context.Context, progress *model.PlaybackProgress) error {
+					return nil
+				},
+			},
+			PlaybackAccumulatorRepo: repository.MockPlaybackAccumulatorRepo{
+				GetAccumulatorFunc: func(ctx context.Context, sessionID string, mediaID int64) (*model.PlaybackAccumulator, error) {
+					return nil, nil
+				},
+				UpsertAccumulatorFunc: func(ctx context.Context, acc *model.PlaybackAccumulator) error {
+					return nil
+				},
+			},
+			MediaRepo: repository.MockMediaRepo{
+				IncrementPlayCountFunc: func(ctx context.Context, id int64) error {
+					return nil
+				},
+			},
+		}
+		svc := NewProgressService(store, newMockClock())
+		if err := svc.UpdateProgress(ctx, "sess", 1, 10, 5); err != nil {
+			t.Fatalf("expected no error, got %v", err)
+		}
+	})
+
+	t.Run("ValidateShareToken nil", func(t *testing.T) {
+		store := &repository.MockStore{
+			ShareRepo: repository.MockShareRepo{
+				GetShareByTokenFunc: func(ctx context.Context, token string) (*model.Share, error) {
+					return nil, nil
+				},
+			},
+		}
+		svc := NewMediaService(store, newMockClock(), "/tmp/media", nil, nil)
+		sh, err := svc.ValidateShareToken(ctx, "nope")
+		if !errors.Is(err, ErrShareNotFound) {
+			t.Fatalf("expected ErrShareNotFound, got %v", err)
+		}
+		if sh != nil {
+			t.Fatalf("expected nil share, got %+v", sh)
+		}
+	})
+
+	t.Run("StreamSharedMedia missing share", func(t *testing.T) {
+		store := &repository.MockStore{
+			ShareRepo: repository.MockShareRepo{
+				GetShareByTokenFunc: func(ctx context.Context, token string) (*model.Share, error) {
+					return nil, nil
+				},
+			},
+		}
+		svc := NewMediaService(store, newMockClock(), "/tmp/media", nil, nil)
+		_, err := svc.StreamSharedMedia(ctx, "nope")
+		if !errors.Is(err, ErrShareNotFound) {
+			t.Fatalf("expected ErrShareNotFound, got %v", err)
+		}
+	})
+
+	t.Run("verifyAccess missing permission", func(t *testing.T) {
+		store := &repository.MockStore{
+			MediaRepo: repository.MockMediaRepo{
+				GetMediaByIDFunc: func(ctx context.Context, id int64) (*model.Media, error) {
+					return &model.Media{ID: 1, SetID: 1}, nil
+				},
+			},
+			UserRepo: repository.MockUserRepo{
+				GetUserByIDFunc: func(ctx context.Context, id int64) (*model.User, error) {
+					return &model.User{ID: 1, IsAdmin: false}, nil
+				},
+			},
+			SetRepo: repository.MockSetRepo{
+				GetSetByIDFunc: func(ctx context.Context, id int64) (*model.Set, error) {
+					return &model.Set{ID: 1}, nil
+				},
+			},
+			SetPermissionRepo: repository.MockSetPermissionRepo{
+				GetPermissionFunc: func(ctx context.Context, setID, userID int64) (*model.SetPermission, error) {
+					return nil, nil
+				},
+			},
+		}
+		svc := NewMediaService(store, newMockClock(), "/tmp/media", nil, nil)
+		_, err := svc.StreamMedia(ctx, 1, 1)
+		if !errors.Is(err, ErrForbidden) {
+			t.Fatalf("expected ErrForbidden, got %v", err)
+		}
+	})
+}