Restructure repo: move Go server into player-server/

1 files changed, 0 insertions, 122 deletions

diff --git a/internal/repository/playback_progress.go b/internal/repository/playback_progress.go
deleted file mode 100644
index d044f92..0000000
--- a/internal/repository/playback_progress.go
+++ /dev/null
@@ -1,122 +0,0 @@
-package repository
-
-import (
-	"context"
-	"database/sql"
-	"fmt"
-	"strings"
-
-	"codeberg.org/snonux/player/internal/model"
-)
-
-// UpsertProgress inserts or replaces playback progress.
-func (s *SQLite) UpsertProgress(ctx context.Context, progress *model.PlaybackProgress) error {
-	_, err := s.db.ExecContext(ctx,
-		`INSERT OR REPLACE INTO playback_progress (user_id, media_id, position_seconds, finished, updated_at) VALUES (?, ?, ?, ?, ?)`,
-		progress.UserID, progress.MediaID, progress.PositionSeconds, progress.Finished, progress.UpdatedAt,
-	)
-	if err != nil {
-		return fmt.Errorf("upsert progress: %w", err)
-	}
-	return nil
-}
-
-// GetProgress retrieves playback progress for a user and media.
-func (s *SQLite) GetProgress(ctx context.Context, userID, mediaID int64) (*model.PlaybackProgress, error) {
-	row := s.db.QueryRowContext(ctx,
-		`SELECT user_id, media_id, position_seconds, finished, updated_at FROM playback_progress WHERE user_id = ? AND media_id = ?`,
-		userID, mediaID,
-	)
-	var p model.PlaybackProgress
-	if err := row.Scan(&p.UserID, &p.MediaID, &p.PositionSeconds, &p.Finished, &p.UpdatedAt); err == sql.ErrNoRows {
-		return nil, nil
-	} else if err != nil {
-		return nil, err
-	}
-	return &p, nil
-}
-
-// DeleteProgress removes playback progress for a user and media.
-func (s *SQLite) DeleteProgress(ctx context.Context, userID, mediaID int64) error {
-	_, err := s.db.ExecContext(ctx, `DELETE FROM playback_progress WHERE user_id = ? AND media_id = ?`, userID, mediaID)
-	if err != nil {
-		return fmt.Errorf("delete progress: %w", err)
-	}
-	return nil
-}
-
-// MarkFinished marks playback progress finished for a user and media.
-func (s *SQLite) MarkFinished(ctx context.Context, userID, mediaID int64) error {
-	_, err := s.db.ExecContext(ctx,
-		`UPDATE playback_progress SET finished = 1, updated_at = CURRENT_TIMESTAMP WHERE user_id = ? AND media_id = ?`,
-		userID, mediaID,
-	)
-	if err != nil {
-		return fmt.Errorf("mark finished: %w", err)
-	}
-	return nil
-}
-
-// ListProgressByUser returns all progress records for a user.
-func (s *SQLite) ListProgressByUser(ctx context.Context, userID int64) ([]model.PlaybackProgress, error) {
-	rows, err := s.db.QueryContext(ctx,
-		`SELECT user_id, media_id, position_seconds, finished, updated_at FROM playback_progress WHERE user_id = ? ORDER BY updated_at DESC`, userID)
-	if err != nil {
-		return nil, fmt.Errorf("list progress: %w", err)
-	}
-	defer rows.Close()
-	var pp []model.PlaybackProgress
-	for rows.Next() {
-		var p model.PlaybackProgress
-		if err := rows.Scan(&p.UserID, &p.MediaID, &p.PositionSeconds, &p.Finished, &p.UpdatedAt); err != nil {
-			return nil, err
-		}
-		pp = append(pp, p)
-	}
-	return pp, rows.Err()
-}
-
-// ListInProgressMedia returns unfinished, non-deleted media with at least 60s accumulated playback.
-func (s *SQLite) ListInProgressMedia(ctx context.Context, userID int64, filter MediaFilter) ([]model.Media, error) {
-	args := []any{userID}
-	conds := []string{
-		`pp.user_id = ?`,
-		`pp.finished = 0`,
-		`media.deleted_at IS NULL`,
-		`EXISTS (
-			SELECT 1
-			FROM playback_accumulator pa
-			INNER JOIN sessions s ON s.id = pa.session_id
-			WHERE pa.media_id = media.id
-				AND s.user_id = pp.user_id
-				AND pa.accumulated_seconds >= 60
-		)`,
-	}
-	query := `SELECT media.id, media.set_id, media.rel_path, media.file_name, media.abs_path, media.type, media.duration, media.codec, media.resolution, media.bitrate, media.file_size_bytes, media.width, media.height, media.exif_camera, media.exif_lens, media.exif_date, media.exif_iso, media.exif_f_number, media.exif_exposure, media.exif_focal_length, media.thumbnail_path, media.play_count, media.deleted_at, media.created_at FROM playback_progress pp INNER JOIN media ON media.id = pp.media_id`
-
-	if len(filter.AllowedSetIDs) > 0 {
-		conds = append(conds, "media.set_id IN ("+placeholders(len(filter.AllowedSetIDs))+")")
-		for _, id := range filter.AllowedSetIDs {
-			args = append(args, id)
-		}
-	}
-
-	query += " WHERE " + strings.Join(conds, " AND ")
-	query += " ORDER BY pp.updated_at DESC"
-
-	rows, err := s.db.QueryContext(ctx, query, args...)
-	if err != nil {
-		return nil, fmt.Errorf("list in-progress media: %w", err)
-	}
-	defer rows.Close()
-
-	var media []model.Media
-	for rows.Next() {
-		m, err := scanMedia(rows)
-		if err != nil {
-			return nil, err
-		}
-		media = append(media, *m)
-	}
-	return media, rows.Err()
-}