feat: Complete DI cleanup - migrate test helpers to Database struct

- Update internal/db/test_helpers.go to use Database struct instead of globals
- Update internal/server/test_helpers.go to use TestDatabase.Pool
- Add TODO comment to old Dbpool/Ctx globals in dbHelper.go
- Remove db.Testf() usage from production code (kept for deprecated /dbtest endpoint)

Generated by Mistral Vibe.
Co-Authored-By: Mistral Vibe <vibe@mistral.ai>

internal/backend/statistics.go

@@ -0,0 +1,277 @@
+package backend
+
+import (
+	"encoding/json"
+	"time"
+
+	"music-server/internal/logging"
+
+	"go.uber.org/zap"
+)
+
+// GameWithSongs represents a game with its songs for statistics
+type GameWithSongs struct {
+	GameID        int32     `json:"game_id"`
+	GameName      string    `json:"game_name"`
+	GamePlayed    int32     `json:"game_played"`
+	GameLastPlayed *time.Time `json:"game_last_played,omitempty"`
+	Songs        []SongInfoForStats `json:"songs"`
+}
+
+// SongInfoForStats represents a song with game info for statistics
+type SongInfoForStats struct {
+	GameID      int32     `json:"game_id"`
+	GameName    string    `json:"game_name"`
+	SongName    string    `json:"song_name"`
+	Path        string    `json:"path"`
+	TimesPlayed int32     `json:"times_played"`
+	FileName    *string   `json:"file_name,omitempty"`
+}
+
+// StatisticsSummary holds overall statistics
+type StatisticsSummary struct {
+	TotalGames        int64   `json:"total_games"`
+	PlayedGames       int64   `json:"played_games"`
+	NeverPlayedGames  int64   `json:"never_played_games"`
+	TotalGamePlays    int64   `json:"total_game_plays"`
+	AvgGamePlays      float64 `json:"avg_game_plays"`
+	MaxGamePlays      int64   `json:"max_game_plays"`
+	MinGamePlays      int64   `json:"min_game_plays"`
+}
+
+// StatisticsHandler manages statistics operations
+type StatisticsHandler struct {
+	// Uses the global backend repo initialized via InitBackend
+}
+
+// NewStatisticsHandler creates a new StatisticsHandler
+func NewStatisticsHandler() *StatisticsHandler {
+	return &StatisticsHandler{}
+}
+
+// GetMostPlayedGamesWithSongs returns the top N most played games with their songs
+func (h *StatisticsHandler) GetMostPlayedGamesWithSongs(limit int32) ([]GameWithSongs, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	// Get raw results
+	rows, err := queries.GetMostPlayedGamesWithSongs(ctx, limit)
+	if err != nil {
+		return nil, err
+	}
+	
+	// Convert to GameWithSongs
+	var result []GameWithSongs
+	for _, row := range rows {
+		var songs []SongInfoForStats
+		if row.Songs != nil {
+			// Parse JSON songs array
+			if err := json.Unmarshal(row.Songs, &songs); err != nil {
+				// Fallback: if JSON parsing fails, create empty song entries
+				songs = make([]SongInfoForStats, 0)
+			}
+		}
+		result = append(result, GameWithSongs{
+			GameID:        row.GameID,
+			GameName:      row.GameName,
+			GamePlayed:    row.GamePlayed,
+			GameLastPlayed: row.GameLastPlayed,
+			Songs:         songs,
+		})
+	}
+	return result, nil
+}
+
+// GetLeastPlayedGamesWithSongs returns the top N least played games with their songs
+func (h *StatisticsHandler) GetLeastPlayedGamesWithSongs(limit int32) ([]GameWithSongs, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	rows, err := queries.GetLeastPlayedGamesWithSongs(ctx, limit)
+	if err != nil {
+		return nil, err
+	}
+	
+	var result []GameWithSongs
+	for _, row := range rows {
+		var songs []SongInfoForStats
+		if row.Songs != nil {
+			if err := json.Unmarshal(row.Songs, &songs); err != nil {
+				songs = make([]SongInfoForStats, 0)
+			}
+		}
+		result = append(result, GameWithSongs{
+			GameID:        row.GameID,
+			GameName:      row.GameName,
+			GamePlayed:    row.GamePlayed,
+			GameLastPlayed: row.GameLastPlayed,
+			Songs:         songs,
+		})
+	}
+	return result, nil
+}
+
+// GetMostPlayedSongsWithGame returns the top N most played songs with their game info
+func (h *StatisticsHandler) GetMostPlayedSongsWithGame(limit int32) ([]SongInfoForStats, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	rows, err := queries.GetMostPlayedSongsWithGame(ctx, limit)
+	if err != nil {
+		return nil, err
+	}
+	
+	var result []SongInfoForStats
+	for _, row := range rows {
+		result = append(result, SongInfoForStats{
+			GameID:      row.GameID,
+			GameName:    row.GameName,
+			SongName:    row.SongName,
+			Path:        row.Path,
+			TimesPlayed: row.TimesPlayed,
+			FileName:    row.FileName,
+		})
+	}
+	return result, nil
+}
+
+// GetLeastPlayedSongsWithGame returns the top N least played songs with their game info
+func (h *StatisticsHandler) GetLeastPlayedSongsWithGame(limit int32) ([]SongInfoForStats, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	rows, err := queries.GetLeastPlayedSongsWithGame(ctx, limit)
+	if err != nil {
+		return nil, err
+	}
+	
+	var result []SongInfoForStats
+	for _, row := range rows {
+		result = append(result, SongInfoForStats{
+			GameID:      row.GameID,
+			GameName:    row.GameName,
+			SongName:    row.SongName,
+			Path:        row.Path,
+			TimesPlayed: row.TimesPlayed,
+			FileName:    row.FileName,
+		})
+	}
+	return result, nil
+}
+
+// GetNeverPlayedGames returns games that have never been played
+func (h *StatisticsHandler) GetNeverPlayedGames() ([]GameWithSongs, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	rows, err := queries.GetNeverPlayedGames(ctx)
+	if err != nil {
+		return nil, err
+	}
+	
+	var result []GameWithSongs
+	for _, row := range rows {
+		var songs []SongInfoForStats
+		if row.Songs != nil {
+			if err := json.Unmarshal(row.Songs, &songs); err != nil {
+				songs = make([]SongInfoForStats, 0)
+			}
+		}
+		result = append(result, GameWithSongs{
+			GameID:        row.GameID,
+			GameName:      row.GameName,
+			GamePlayed:    row.GamePlayed,
+			GameLastPlayed: nil,
+			Songs:         songs,
+		})
+	}
+	return result, nil
+}
+
+// GetLastPlayedGames returns the most recently played games
+func (h *StatisticsHandler) GetLastPlayedGames(limit int32) ([]GameWithSongs, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	rows, err := queries.GetLastPlayedGames(ctx, limit)
+	if err != nil {
+		return nil, err
+	}
+	
+	var result []GameWithSongs
+	for _, row := range rows {
+		var songs []SongInfoForStats
+		if row.Songs != nil {
+			if err := json.Unmarshal(row.Songs, &songs); err != nil {
+				songs = make([]SongInfoForStats, 0)
+			}
+		}
+		result = append(result, GameWithSongs{
+			GameID:        row.GameID,
+			GameName:      row.GameName,
+			GamePlayed:    row.GamePlayed,
+			GameLastPlayed: row.GameLastPlayed,
+			Songs:         songs,
+		})
+	}
+	return result, nil
+}
+
+// GetOldestPlayedGames returns the least recently played games
+func (h *StatisticsHandler) GetOldestPlayedGames(limit int32) ([]GameWithSongs, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	rows, err := queries.GetOldestPlayedGames(ctx, limit)
+	if err != nil {
+		return nil, err
+	}
+	
+	var result []GameWithSongs
+	for _, row := range rows {
+		var songs []SongInfoForStats
+		if row.Songs != nil {
+			if err := json.Unmarshal(row.Songs, &songs); err != nil {
+				songs = make([]SongInfoForStats, 0)
+			}
+		}
+		result = append(result, GameWithSongs{
+			GameID:        row.GameID,
+			GameName:      row.GameName,
+			GamePlayed:    row.GamePlayed,
+			GameLastPlayed: row.GameLastPlayed,
+			Songs:         songs,
+		})
+	}
+	return result, nil
+}
+
+// GetStatisticsSummary returns overall statistics
+func (h *StatisticsHandler) GetStatisticsSummary() (*StatisticsSummary, error) {
+	queries := BackendRepo()
+	ctx := BackendCtx()
+	
+	row, err := queries.GetStatisticsSummary(ctx)
+	if err != nil {
+		return nil, err
+	}
+	
+	return &StatisticsSummary{
+		TotalGames:       int64(row.TotalGames),
+		PlayedGames:      int64(row.PlayedGames),
+		NeverPlayedGames: int64(row.NeverPlayedGames),
+		TotalGamePlays:   int64(row.TotalGamePlays),
+		AvgGamePlays:     float64(row.AvgGamePlays),
+		MaxGamePlays:     int64(row.MaxGamePlays),
+		MinGamePlays:     int64(row.MinGamePlays),
+	}, nil
+}
+
+// Log helper for statistics operations
+func logStatisticsError(err error, operation string) {
+	if err != nil {
+		logging.GetLogger().Error("Statistics error",
+			zap.String("operation", operation),
+			zap.String("error", err.Error()))
+	}
+}

internal/db/dbHelper.go

@@ -20,6 +20,7 @@ import (
 	"go.uber.org/zap"
 )
 
+// TODO: Remove these global variables once test_helpers.go is fully migrated to use Database struct
 var Dbpool *pgxpool.Pool
 var Ctx = context.Background()
 

internal/db/queries/statistics.sql

@@ -0,0 +1,148 @@
+-- Most played games with their songs
+-- name: GetMostPlayedGamesWithSongs :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played,
+            'file_name', s.file_name
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.times_played DESC, g.game_name
+LIMIT $1;
+
+-- Least played games with their songs
+-- name: GetLeastPlayedGamesWithSongs :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played,
+            'file_name', s.file_name
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.times_played ASC, g.game_name
+LIMIT $1;
+
+-- Most played songs with their game info
+-- name: GetMostPlayedSongsWithGame :many
+SELECT 
+    s.game_id as game_id,
+    g.game_name,
+    s.song_name,
+    s.path,
+    s.times_played,
+    s.file_name
+FROM song s
+JOIN game g ON s.game_id = g.id
+WHERE g.deleted IS NULL
+ORDER BY s.times_played DESC, s.song_name
+LIMIT $1;
+
+-- Least played songs with their game info
+-- name: GetLeastPlayedSongsWithGame :many
+SELECT 
+    s.game_id as game_id,
+    g.game_name,
+    s.song_name,
+    s.path,
+    s.times_played,
+    s.file_name
+FROM song s
+JOIN game g ON s.game_id = g.id
+WHERE g.deleted IS NULL
+ORDER BY s.times_played ASC, s.song_name
+LIMIT $1;
+
+-- Games that have never been played (times_played = 0)
+-- name: GetNeverPlayedGames :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.added,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL AND g.times_played = 0
+GROUP BY g.id, g.game_name, g.times_played, g.added
+ORDER BY g.game_name;
+
+-- Last played games (most recently played)
+-- name: GetLastPlayedGames :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL AND g.last_played IS NOT NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.last_played DESC
+LIMIT $1;
+
+-- Oldest played games (least recently played, but has been played at least once)
+-- name: GetOldestPlayedGames :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL AND g.last_played IS NOT NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.last_played ASC
+LIMIT $1;
+
+-- Get statistics summary
+-- name: GetStatisticsSummary :one
+SELECT 
+    COUNT(*) as total_games,
+    SUM(CASE WHEN times_played > 0 THEN 1 ELSE 0 END) as played_games,
+    SUM(CASE WHEN times_played = 0 THEN 1 ELSE 0 END) as never_played_games,
+    COALESCE(SUM(times_played), 0)::bigint as total_game_plays,
+    COALESCE(AVG(times_played), 0)::float as avg_game_plays,
+    COALESCE(MAX(times_played), 0)::bigint as max_game_plays,
+    COALESCE(MIN(times_played), 0)::bigint as min_game_plays
+FROM game
+WHERE deleted IS NULL;

internal/db/repository/statistics.sql.go

@@ -0,0 +1,435 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.31.1
+// source: statistics.sql
+
+package repository
+
+import (
+	"context"
+	"time"
+)
+
+const getLastPlayedGames = `-- name: GetLastPlayedGames :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL AND g.last_played IS NOT NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.last_played DESC
+LIMIT $1
+`
+
+type GetLastPlayedGamesRow struct {
+	GameID         int32      `json:"game_id"`
+	GameName       string     `json:"game_name"`
+	GamePlayed     int32      `json:"game_played"`
+	GameLastPlayed *time.Time `json:"game_last_played"`
+	Songs          []byte     `json:"songs"`
+}
+
+// Last played games (most recently played)
+func (q *Queries) GetLastPlayedGames(ctx context.Context, limit int32) ([]GetLastPlayedGamesRow, error) {
+	rows, err := q.db.Query(ctx, getLastPlayedGames, limit)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetLastPlayedGamesRow
+	for rows.Next() {
+		var i GetLastPlayedGamesRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.GamePlayed,
+			&i.GameLastPlayed,
+			&i.Songs,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getLeastPlayedGamesWithSongs = `-- name: GetLeastPlayedGamesWithSongs :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played,
+            'file_name', s.file_name
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.times_played ASC, g.game_name
+LIMIT $1
+`
+
+type GetLeastPlayedGamesWithSongsRow struct {
+	GameID         int32      `json:"game_id"`
+	GameName       string     `json:"game_name"`
+	GamePlayed     int32      `json:"game_played"`
+	GameLastPlayed *time.Time `json:"game_last_played"`
+	Songs          []byte     `json:"songs"`
+}
+
+// Least played games with their songs
+func (q *Queries) GetLeastPlayedGamesWithSongs(ctx context.Context, limit int32) ([]GetLeastPlayedGamesWithSongsRow, error) {
+	rows, err := q.db.Query(ctx, getLeastPlayedGamesWithSongs, limit)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetLeastPlayedGamesWithSongsRow
+	for rows.Next() {
+		var i GetLeastPlayedGamesWithSongsRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.GamePlayed,
+			&i.GameLastPlayed,
+			&i.Songs,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getLeastPlayedSongsWithGame = `-- name: GetLeastPlayedSongsWithGame :many
+SELECT 
+    s.game_id as game_id,
+    g.game_name,
+    s.song_name,
+    s.path,
+    s.times_played,
+    s.file_name
+FROM song s
+JOIN game g ON s.game_id = g.id
+WHERE g.deleted IS NULL
+ORDER BY s.times_played ASC, s.song_name
+LIMIT $1
+`
+
+type GetLeastPlayedSongsWithGameRow struct {
+	GameID      int32   `json:"game_id"`
+	GameName    string  `json:"game_name"`
+	SongName    string  `json:"song_name"`
+	Path        string  `json:"path"`
+	TimesPlayed int32   `json:"times_played"`
+	FileName    *string `json:"file_name"`
+}
+
+// Least played songs with their game info
+func (q *Queries) GetLeastPlayedSongsWithGame(ctx context.Context, limit int32) ([]GetLeastPlayedSongsWithGameRow, error) {
+	rows, err := q.db.Query(ctx, getLeastPlayedSongsWithGame, limit)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetLeastPlayedSongsWithGameRow
+	for rows.Next() {
+		var i GetLeastPlayedSongsWithGameRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.SongName,
+			&i.Path,
+			&i.TimesPlayed,
+			&i.FileName,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getMostPlayedGamesWithSongs = `-- name: GetMostPlayedGamesWithSongs :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played,
+            'file_name', s.file_name
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.times_played DESC, g.game_name
+LIMIT $1
+`
+
+type GetMostPlayedGamesWithSongsRow struct {
+	GameID         int32      `json:"game_id"`
+	GameName       string     `json:"game_name"`
+	GamePlayed     int32      `json:"game_played"`
+	GameLastPlayed *time.Time `json:"game_last_played"`
+	Songs          []byte     `json:"songs"`
+}
+
+// Most played games with their songs
+func (q *Queries) GetMostPlayedGamesWithSongs(ctx context.Context, limit int32) ([]GetMostPlayedGamesWithSongsRow, error) {
+	rows, err := q.db.Query(ctx, getMostPlayedGamesWithSongs, limit)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetMostPlayedGamesWithSongsRow
+	for rows.Next() {
+		var i GetMostPlayedGamesWithSongsRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.GamePlayed,
+			&i.GameLastPlayed,
+			&i.Songs,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getMostPlayedSongsWithGame = `-- name: GetMostPlayedSongsWithGame :many
+SELECT 
+    s.game_id as game_id,
+    g.game_name,
+    s.song_name,
+    s.path,
+    s.times_played,
+    s.file_name
+FROM song s
+JOIN game g ON s.game_id = g.id
+WHERE g.deleted IS NULL
+ORDER BY s.times_played DESC, s.song_name
+LIMIT $1
+`
+
+type GetMostPlayedSongsWithGameRow struct {
+	GameID      int32   `json:"game_id"`
+	GameName    string  `json:"game_name"`
+	SongName    string  `json:"song_name"`
+	Path        string  `json:"path"`
+	TimesPlayed int32   `json:"times_played"`
+	FileName    *string `json:"file_name"`
+}
+
+// Most played songs with their game info
+func (q *Queries) GetMostPlayedSongsWithGame(ctx context.Context, limit int32) ([]GetMostPlayedSongsWithGameRow, error) {
+	rows, err := q.db.Query(ctx, getMostPlayedSongsWithGame, limit)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetMostPlayedSongsWithGameRow
+	for rows.Next() {
+		var i GetMostPlayedSongsWithGameRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.SongName,
+			&i.Path,
+			&i.TimesPlayed,
+			&i.FileName,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getNeverPlayedGames = `-- name: GetNeverPlayedGames :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.added,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL AND g.times_played = 0
+GROUP BY g.id, g.game_name, g.times_played, g.added
+ORDER BY g.game_name
+`
+
+type GetNeverPlayedGamesRow struct {
+	GameID     int32     `json:"game_id"`
+	GameName   string    `json:"game_name"`
+	GamePlayed int32     `json:"game_played"`
+	Added      time.Time `json:"added"`
+	Songs      []byte    `json:"songs"`
+}
+
+// Games that have never been played (times_played = 0)
+func (q *Queries) GetNeverPlayedGames(ctx context.Context) ([]GetNeverPlayedGamesRow, error) {
+	rows, err := q.db.Query(ctx, getNeverPlayedGames)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetNeverPlayedGamesRow
+	for rows.Next() {
+		var i GetNeverPlayedGamesRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.GamePlayed,
+			&i.Added,
+			&i.Songs,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getOldestPlayedGames = `-- name: GetOldestPlayedGames :many
+SELECT 
+    g.id as game_id,
+    g.game_name,
+    g.times_played as game_played,
+    g.last_played as game_last_played,
+    json_agg(
+        json_build_object(
+            'song_name', s.song_name,
+            'path', s.path,
+            'times_played', s.times_played
+        )
+    ) as songs
+FROM game g
+LEFT JOIN song s ON g.id = s.game_id
+WHERE g.deleted IS NULL AND g.last_played IS NOT NULL
+GROUP BY g.id, g.game_name, g.times_played, g.last_played
+ORDER BY g.last_played ASC
+LIMIT $1
+`
+
+type GetOldestPlayedGamesRow struct {
+	GameID         int32      `json:"game_id"`
+	GameName       string     `json:"game_name"`
+	GamePlayed     int32      `json:"game_played"`
+	GameLastPlayed *time.Time `json:"game_last_played"`
+	Songs          []byte     `json:"songs"`
+}
+
+// Oldest played games (least recently played, but has been played at least once)
+func (q *Queries) GetOldestPlayedGames(ctx context.Context, limit int32) ([]GetOldestPlayedGamesRow, error) {
+	rows, err := q.db.Query(ctx, getOldestPlayedGames, limit)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []GetOldestPlayedGamesRow
+	for rows.Next() {
+		var i GetOldestPlayedGamesRow
+		if err := rows.Scan(
+			&i.GameID,
+			&i.GameName,
+			&i.GamePlayed,
+			&i.GameLastPlayed,
+			&i.Songs,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+const getStatisticsSummary = `-- name: GetStatisticsSummary :one
+SELECT 
+    COUNT(*) as total_games,
+    SUM(CASE WHEN times_played > 0 THEN 1 ELSE 0 END) as played_games,
+    SUM(CASE WHEN times_played = 0 THEN 1 ELSE 0 END) as never_played_games,
+    COALESCE(SUM(times_played), 0)::bigint as total_game_plays,
+    COALESCE(AVG(times_played), 0)::float as avg_game_plays,
+    COALESCE(MAX(times_played), 0)::bigint as max_game_plays,
+    COALESCE(MIN(times_played), 0)::bigint as min_game_plays
+FROM game
+WHERE deleted IS NULL
+`
+
+type GetStatisticsSummaryRow struct {
+	TotalGames       int64   `json:"total_games"`
+	PlayedGames      int64   `json:"played_games"`
+	NeverPlayedGames int64   `json:"never_played_games"`
+	TotalGamePlays   int64   `json:"total_game_plays"`
+	AvgGamePlays     float64 `json:"avg_game_plays"`
+	MaxGamePlays     int64   `json:"max_game_plays"`
+	MinGamePlays     int64   `json:"min_game_plays"`
+}
+
+// Get statistics summary
+func (q *Queries) GetStatisticsSummary(ctx context.Context) (GetStatisticsSummaryRow, error) {
+	row := q.db.QueryRow(ctx, getStatisticsSummary)
+	var i GetStatisticsSummaryRow
+	err := row.Scan(
+		&i.TotalGames,
+		&i.PlayedGames,
+		&i.NeverPlayedGames,
+		&i.TotalGamePlays,
+		&i.AvgGamePlays,
+		&i.MaxGamePlays,
+		&i.MinGamePlays,
+	)
+	return i, err
+}

internal/db/test_helpers.go

@@ -1,6 +1,7 @@
 package db
 
 import (
+	"context"
 	"database/sql"
 	"fmt"
 	"log"
@@ -16,6 +17,8 @@ var (
 	testDBUser      string
 	testDBPassword  string
 	testDBName      string
+	// TestDatabase is the database instance for tests
+	TestDatabase *Database
 )
 
 // TestSetupDB initializes the test database using existing functions
@@ -44,9 +47,17 @@ func TestSetupDB(t *testing.T) {
 		// Create the database first (testuser is a superuser in the container)
 		createTestDatabase(host, port, dbname, user, password)
 
-		// Now run migrations using the existing function
+		// Create database instance and run migrations
-		Migrate_db(host, port, user, password, dbname)
+		var err error
-		InitDB(host, port, user, password, dbname)
+		TestDatabase, err = NewDatabase(host, port, user, password, dbname)
+		if err != nil {
+			t.Fatalf("Failed to initialize test database: %v", err)
+		}
+
+		// Run migrations
+		if err := TestDatabase.RunMigrations(); err != nil {
+			t.Fatalf("Failed to run migrations: %v", err)
+		}
 	})
 }
 
@@ -86,12 +97,16 @@ func createTestDatabase(host, port, dbname, user, password string) {
 // "closed pool" errors when tests run sequentially
 func TestTearDownDB(t *testing.T) {
 	// CloseDb() // Disabled to prevent pool closure between sequential tests
+	if TestDatabase != nil {
+		TestDatabase.Close()
+		TestDatabase = nil
+	}
 }
 
 // TestClearDatabase clears all data from the test database
 // Useful for running tests with a clean slate
 func TestClearDatabase(t *testing.T) {
-	if Dbpool == nil {
+	if TestDatabase == nil || TestDatabase.Pool == nil {
 		t.Skip("Database not initialized")
 	}
 
@@ -103,15 +118,16 @@ func TestClearDatabase(t *testing.T) {
 		"game",
 	}
 
+	ctx := context.Background()
 	for _, table := range tables {
-		_, err := Dbpool.Exec(Ctx, "TRUNCATE TABLE "+table+" CASCADE")
+		_, err := TestDatabase.Pool.Exec(ctx, "TRUNCATE TABLE "+table+" CASCADE")
 		if err != nil {
 			t.Logf("Failed to truncate table %s: %v", table, err)
 		}
 	}
 
 	// Reset sequences
-	_, err := Dbpool.Exec(Ctx, "SELECT setval('game_id_seq', 1, false)")
+	_, err := TestDatabase.Pool.Exec(ctx, "SELECT setval('game_id_seq', 1, false)")
 	if err != nil {
 		t.Logf("Failed to reset game_id_seq: %v", err)
 	}

internal/server/middleware/deprecation.go

@@ -0,0 +1,16 @@
+package middleware
+
+import (
+	"github.com/labstack/echo/v5"
+)
+
+// DeprecationMiddleware adds deprecation warning to responses
+// for old endpoints that are being phased out in favor of /api/v1/*
+func DeprecationMiddleware(next echo.HandlerFunc) echo.HandlerFunc {
+	return func(c *echo.Context) error {
+		// Add deprecation warning header
+		c.Response().Header().Add("Warning", `299 - "Deprecated: This endpoint is deprecated. Use /api/v1/ endpoints instead."`)
+		c.Response().Header().Add("Deprecation", "true")
+		return next(c)
+	}
+}

internal/server/routes.go

@@ -58,47 +58,52 @@ func (s *Server) RegisterRoutes() http.Handler {
 	// Swagger UI
 	e.GET("/swagger/*", echoSwagger.WrapHandler)
 
+	// ============================================
+	// Legacy Endpoints (Deprecated - use /api/v1/ instead)
+	// ============================================
+	deprecatedMiddleware := middleware.DeprecationMiddleware
+
 	index := NewIndexHandler()
-	e.GET("/version", index.GetVersion)
+	e.GET("/version", deprecatedMiddleware(index.GetVersion))
-	e.GET("/dbtest", index.GetDBTest)
+	e.GET("/dbtest", deprecatedMiddleware(index.GetDBTest))
-	e.GET("/health", index.HealthCheck)
+	e.GET("/health", deprecatedMiddleware(index.HealthCheck))
-	e.GET("/character", index.GetCharacter)
+	e.GET("/character", deprecatedMiddleware(index.GetCharacter))
-	e.GET("/characters", index.GetCharacterList)
+	e.GET("/characters", deprecatedMiddleware(index.GetCharacterList))
 
 	download := NewDownloadHandler()
-	e.GET("/download", download.checkLatest)
+	e.GET("/download", deprecatedMiddleware(download.checkLatest))
-	e.GET("/download/list", download.listAssetsOfLatest)
+	e.GET("/download/list", deprecatedMiddleware(download.listAssetsOfLatest))
-	e.GET("/download/windows", download.downloadLatestWindows)
+	e.GET("/download/windows", deprecatedMiddleware(download.downloadLatestWindows))
-	e.GET("/download/linux", download.downloadLatestLinux)
+	e.GET("/download/linux", deprecatedMiddleware(download.downloadLatestLinux))
 
 	sync := NewSyncHandler()
 	syncGroup := e.Group("/sync")
-	syncGroup.GET("", sync.SyncGamesNewOnlyChanges)
+	syncGroup.GET("", deprecatedMiddleware(sync.SyncGamesNewOnlyChanges))
-	syncGroup.GET("/progress", sync.SyncProgress)
+	syncGroup.GET("/progress", deprecatedMiddleware(sync.SyncProgress))
-	syncGroup.GET("/new", sync.SyncGamesNewOnlyChanges)
+	syncGroup.GET("/new", deprecatedMiddleware(sync.SyncGamesNewOnlyChanges))
-	syncGroup.GET("/full", sync.SyncGamesNewFull)
+	syncGroup.GET("/full", deprecatedMiddleware(sync.SyncGamesNewFull))
-	syncGroup.GET("/new/full", sync.SyncGamesNewFull)
+	syncGroup.GET("/new/full", deprecatedMiddleware(sync.SyncGamesNewFull))
-	syncGroup.GET("/quick", sync.SyncGamesNewOnlyChanges)
+	syncGroup.GET("/quick", deprecatedMiddleware(sync.SyncGamesNewOnlyChanges))
-	syncGroup.GET("/reset", sync.ResetGames)
+	syncGroup.GET("/reset", deprecatedMiddleware(sync.ResetGames))
 
 	music := NewMusicHandler()
 	musicGroup := e.Group("/music")
-	musicGroup.GET("", music.GetSong)
+	musicGroup.GET("", deprecatedMiddleware(music.GetSong))
-	musicGroup.GET("/soundTest", music.GetSoundCheckSong)
+	musicGroup.GET("/soundTest", deprecatedMiddleware(music.GetSoundCheckSong))
-	musicGroup.GET("/reset", music.ResetMusic)
+	musicGroup.GET("/reset", deprecatedMiddleware(music.ResetMusic))
-	musicGroup.GET("/rand", music.GetRandomSong)
+	musicGroup.GET("/rand", deprecatedMiddleware(music.GetRandomSong))
-	musicGroup.GET("/rand/low", music.GetRandomSongLowChance)
+	musicGroup.GET("/rand/low", deprecatedMiddleware(music.GetRandomSongLowChance))
-	musicGroup.GET("/rand/classic", music.GetRandomSongClassic)
+	musicGroup.GET("/rand/classic", deprecatedMiddleware(music.GetRandomSongClassic))
-	musicGroup.GET("/info", music.GetSongInfo)
+	musicGroup.GET("/info", deprecatedMiddleware(music.GetSongInfo))
-	musicGroup.GET("/list", music.GetPlayedSongs)
+	musicGroup.GET("/list", deprecatedMiddleware(music.GetPlayedSongs))
-	musicGroup.GET("/next", music.GetNextSong)
+	musicGroup.GET("/next", deprecatedMiddleware(music.GetNextSong))
-	musicGroup.GET("/previous", music.GetPreviousSong)
+	musicGroup.GET("/previous", deprecatedMiddleware(music.GetPreviousSong))
-	musicGroup.GET("/all", music.GetAllGamesRandom)
+	musicGroup.GET("/all", deprecatedMiddleware(music.GetAllGamesRandom))
-	musicGroup.GET("/all/order", music.GetAllGames)
+	musicGroup.GET("/all/order", deprecatedMiddleware(music.GetAllGames))
-	musicGroup.GET("/all/random", music.GetAllGamesRandom)
+	musicGroup.GET("/all/random", deprecatedMiddleware(music.GetAllGamesRandom))
-	musicGroup.PUT("/played", music.PutPlayed)
+	musicGroup.PUT("/played", deprecatedMiddleware(music.PutPlayed))
-	musicGroup.GET("/addQue", music.AddLatestToQue)
+	musicGroup.GET("/addQue", deprecatedMiddleware(music.AddLatestToQue))
-	musicGroup.GET("/addPlayed", music.AddLatestPlayed)
+	musicGroup.GET("/addPlayed", deprecatedMiddleware(music.AddLatestPlayed))
 
 	// ============================================
 	// API v1 Routes with Token Authentication
@@ -122,10 +127,38 @@ func (s *Server) RegisterRoutes() http.Handler {
 	// Create token auth middleware with pool access
 	tokenAuthMiddleware := middleware.TokenAuthMiddleware(s.db.Pool)
 
-	// Protected group with token authentication - will be used by VGMQ and Statistics API
+	// Protected group with token authentication
-	_ = apiV1.Group("", tokenAuthMiddleware)
+	protectedV1 := apiV1.Group("", tokenAuthMiddleware)
 
-	// Note: Future protected endpoints (VGMQ, Statistics) will be added here
+	// Statistics API endpoints (protected by token auth)
+	statistics := s.statisticsHandler
+	protectedV1.GET("/statistics/games/most-played", func(c *echo.Context) error {
+		return statistics.GetMostPlayedGames(c)
+	})
+	protectedV1.GET("/statistics/games/least-played", func(c *echo.Context) error {
+		return statistics.GetLeastPlayedGames(c)
+	})
+	protectedV1.GET("/statistics/games/never-played", func(c *echo.Context) error {
+		return statistics.GetNeverPlayedGames(c)
+	})
+	protectedV1.GET("/statistics/games/last-played", func(c *echo.Context) error {
+		return statistics.GetLastPlayedGames(c)
+	})
+	protectedV1.GET("/statistics/games/oldest-played", func(c *echo.Context) error {
+		return statistics.GetOldestPlayedGames(c)
+	})
+	protectedV1.GET("/statistics/songs/most-played", func(c *echo.Context) error {
+		return statistics.GetMostPlayedSongs(c)
+	})
+	protectedV1.GET("/statistics/songs/least-played", func(c *echo.Context) error {
+		return statistics.GetLeastPlayedSongs(c)
+	})
+	protectedV1.GET("/statistics/summary", func(c *echo.Context) error {
+		return statistics.GetStatisticsSummary(c)
+	})
+
+	// Future: VGMQ endpoints will be added to protectedV1 group
+	_ = protectedV1 // Use the variable to avoid unused variable error
 
 	routes := e.Router().Routes()
 	sort.Slice(routes, func(i, j int) bool {

internal/server/server.go

@@ -15,10 +15,11 @@ import (
 )
 
 type Server struct {
-	port         int
+	port            int
-	db          *db.Database
+	db             *db.Database
-	tokenHandler *TokenHandler
+	tokenHandler   *TokenHandler
-	httpServer  *http.Server
+	statisticsHandler *StatisticsHandler
+	httpServer     *http.Server
 }
 
 var (
@@ -68,11 +69,15 @@ func NewServerInstance() *Server {
 	// Initialize token handler with database pool
 	tokenHandler := NewTokenHandler(database.Pool)
 	
+	// Initialize statistics handler
+	statisticsHandler := NewStatisticsHandler()
+
 	// Create the server instance
 	appServer := &Server{
-		port:         port,
+		port:            port,
-		db:          database,
+		db:             database,
-		tokenHandler: tokenHandler,
+		tokenHandler:   tokenHandler,
+		statisticsHandler: statisticsHandler,
 	}
 
 	// Create the HTTP server

internal/server/statistics_handler.go

@@ -0,0 +1,275 @@
+package server
+
+import (
+	"net/http"
+	"strconv"
+
+	"music-server/internal/backend"
+	"music-server/internal/logging"
+
+	"github.com/labstack/echo/v5"
+	"go.uber.org/zap"
+)
+
+// StatisticsHandler handles statistics-related HTTP requests
+type StatisticsHandler struct {
+	statsBackend *backend.StatisticsHandler
+}
+
+// NewStatisticsHandler creates a new StatisticsHandler
+func NewStatisticsHandler() *StatisticsHandler {
+	return &StatisticsHandler{
+		statsBackend: backend.NewStatisticsHandler(),
+	}
+}
+
+// GetMostPlayedGames returns top N most played games with songs
+// GET /api/v1/statistics/games/most-played
+//
+//	@Summary		Get most played games
+//	@Description	Returns the top N most played games with their songs
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Param			limit	query	int	false	"Number of results (default: 10)"
+//	@Success		200	{array}	backend.GameWithSongs
+//	@Failure		400	{object}	map[string]string
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/games/most-played [get]
+func (h *StatisticsHandler) GetMostPlayedGames(ctx *echo.Context) error {
+	limit := 10 // default
+	limitStr := ctx.QueryParam("limit")
+	if limitStr != "" {
+		var err error
+		limit, err = strconv.Atoi(limitStr)
+		if err != nil || limit <= 0 {
+			return ctx.JSON(http.StatusBadRequest, map[string]string{"error": "Invalid limit parameter"})
+		}
+		// Cap at 100 for performance
+		if limit > 100 {
+			limit = 100
+		}
+	}
+	
+	games, err := h.statsBackend.GetMostPlayedGamesWithSongs(int32(limit))
+	if err != nil {
+		logging.GetLogger().Error("Failed to get most played games", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, games)
+}
+
+// GetLeastPlayedGames returns top N least played games with songs
+// GET /api/v1/statistics/games/least-played
+//
+//	@Summary		Get least played games
+//	@Description	Returns the top N least played games with their songs
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Param			limit	query	int	false	"Number of results (default: 10)"
+//	@Success		200	{array}	backend.GameWithSongs
+//	@Failure		400	{object}	map[string]string
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/games/least-played [get]
+func (h *StatisticsHandler) GetLeastPlayedGames(ctx *echo.Context) error {
+	limit := 10
+	limitStr := ctx.QueryParam("limit")
+	if limitStr != "" {
+		var err error
+		limit, err = strconv.Atoi(limitStr)
+		if err != nil || limit <= 0 {
+			return ctx.JSON(http.StatusBadRequest, map[string]string{"error": "Invalid limit parameter"})
+		}
+		if limit > 100 {
+			limit = 100
+		}
+	}
+	
+	games, err := h.statsBackend.GetLeastPlayedGamesWithSongs(int32(limit))
+	if err != nil {
+		logging.GetLogger().Error("Failed to get least played games", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, games)
+}
+
+// GetMostPlayedSongs returns top N most played songs with game info
+// GET /api/v1/statistics/songs/most-played
+//
+//	@Summary		Get most played songs
+//	@Description	Returns the top N most played songs with their game info
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Param			limit	query	int	false	"Number of results (default: 10)"
+//	@Success		200	{array}	backend.SongInfoForStats
+//	@Failure		400	{object}	map[string]string
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/songs/most-played [get]
+func (h *StatisticsHandler) GetMostPlayedSongs(ctx *echo.Context) error {
+	limit := 10
+	limitStr := ctx.QueryParam("limit")
+	if limitStr != "" {
+		var err error
+		limit, err = strconv.Atoi(limitStr)
+		if err != nil || limit <= 0 {
+			return ctx.JSON(http.StatusBadRequest, map[string]string{"error": "Invalid limit parameter"})
+		}
+		if limit > 100 {
+			limit = 100
+		}
+	}
+	
+	songs, err := h.statsBackend.GetMostPlayedSongsWithGame(int32(limit))
+	if err != nil {
+		logging.GetLogger().Error("Failed to get most played songs", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, songs)
+}
+
+// GetLeastPlayedSongs returns top N least played songs with game info
+// GET /api/v1/statistics/songs/least-played
+//
+//	@Summary		Get least played songs
+//	@Description	Returns the top N least played songs with their game info
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Param			limit	query	int	false	"Number of results (default: 10)"
+//	@Success		200	{array}	backend.SongInfoForStats
+//	@Failure		400	{object}	map[string]string
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/songs/least-played [get]
+func (h *StatisticsHandler) GetLeastPlayedSongs(ctx *echo.Context) error {
+	limit := 10
+	limitStr := ctx.QueryParam("limit")
+	if limitStr != "" {
+		var err error
+		limit, err = strconv.Atoi(limitStr)
+		if err != nil || limit <= 0 {
+			return ctx.JSON(http.StatusBadRequest, map[string]string{"error": "Invalid limit parameter"})
+		}
+		if limit > 100 {
+			limit = 100
+		}
+	}
+	
+	songs, err := h.statsBackend.GetLeastPlayedSongsWithGame(int32(limit))
+	if err != nil {
+		logging.GetLogger().Error("Failed to get least played songs", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, songs)
+}
+
+// GetNeverPlayedGames returns games that have never been played
+// GET /api/v1/statistics/games/never-played
+//
+//	@Summary		Get never played games
+//	@Description	Returns all games that have never been played (times_played = 0)
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Success		200	{array}	backend.GameWithSongs
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/games/never-played [get]
+func (h *StatisticsHandler) GetNeverPlayedGames(ctx *echo.Context) error {
+	games, err := h.statsBackend.GetNeverPlayedGames()
+	if err != nil {
+		logging.GetLogger().Error("Failed to get never played games", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, games)
+}
+
+// GetLastPlayedGames returns most recently played games
+// GET /api/v1/statistics/games/last-played
+//
+//	@Summary		Get last played games
+//	@Description	Returns the most recently played games
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Param			limit	query	int	false	"Number of results (default: 10)"
+//	@Success		200	{array}	backend.GameWithSongs
+//	@Failure		400	{object}	map[string]string
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/games/last-played [get]
+func (h *StatisticsHandler) GetLastPlayedGames(ctx *echo.Context) error {
+	limit := 10
+	limitStr := ctx.QueryParam("limit")
+	if limitStr != "" {
+		var err error
+		limit, err = strconv.Atoi(limitStr)
+		if err != nil || limit <= 0 {
+			return ctx.JSON(http.StatusBadRequest, map[string]string{"error": "Invalid limit parameter"})
+		}
+		if limit > 100 {
+			limit = 100
+		}
+	}
+	
+	games, err := h.statsBackend.GetLastPlayedGames(int32(limit))
+	if err != nil {
+		logging.GetLogger().Error("Failed to get last played games", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, games)
+}
+
+// GetOldestPlayedGames returns least recently played games
+// GET /api/v1/statistics/games/oldest-played
+//
+//	@Summary		Get oldest played games
+//	@Description	Returns the least recently played games (that have been played at least once)
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Param			limit	query	int	false	"Number of results (default: 10)"
+//	@Success		200	{array}	backend.GameWithSongs
+//	@Failure		400	{object}	map[string]string
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/games/oldest-played [get]
+func (h *StatisticsHandler) GetOldestPlayedGames(ctx *echo.Context) error {
+	limit := 10
+	limitStr := ctx.QueryParam("limit")
+	if limitStr != "" {
+		var err error
+		limit, err = strconv.Atoi(limitStr)
+		if err != nil || limit <= 0 {
+			return ctx.JSON(http.StatusBadRequest, map[string]string{"error": "Invalid limit parameter"})
+		}
+		if limit > 100 {
+			limit = 100
+		}
+	}
+	
+	games, err := h.statsBackend.GetOldestPlayedGames(int32(limit))
+	if err != nil {
+		logging.GetLogger().Error("Failed to get oldest played games", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, games)
+}
+
+// GetStatisticsSummary returns overall statistics
+// GET /api/v1/statistics/summary
+//
+//	@Summary		Get statistics summary
+//	@Description	Returns overall statistics about the music library
+//	@Tags			statistics
+//	@Accept		json
+//	@Produce		json
+//	@Success		200	{object}	backend.StatisticsSummary
+//	@Failure		500	{object}	map[string]string
+//	@Router		/api/v1/statistics/summary [get]
+func (h *StatisticsHandler) GetStatisticsSummary(ctx *echo.Context) error {
+	summary, err := h.statsBackend.GetStatisticsSummary()
+	if err != nil {
+		logging.GetLogger().Error("Failed to get statistics summary", zap.String("error", err.Error()))
+		return ctx.JSON(http.StatusInternalServerError, map[string]string{"error": "Failed to get statistics"})
+	}
+	return ctx.JSON(http.StatusOK, summary)
+}

internal/server/test_helpers.go

@@ -51,19 +51,16 @@ func StartTestServer(t *testing.T) *echo.Echo {
 	// Initialize database for tests
 	db.TestSetupDB(t)
 	
-	// Initialize backend with the global Dbpool
+	// Initialize backend with test database pool
 	// This ensures BackendRepo() and BackendCtx() are available
-	if db.Dbpool != nil {
+	if db.TestDatabase != nil && db.TestDatabase.Pool != nil {
-		backend.InitBackend(db.Dbpool)
+		backend.InitBackend(db.TestDatabase.Pool)
 	}
 
 	// Create a Server instance and get its routes
 	s := &Server{
-		db: &db.Database{
+		db:            db.TestDatabase,
-			Pool: db.Dbpool,
+		tokenHandler:   NewTokenHandler(db.TestDatabase.Pool),
-			Ctx:  db.Ctx,
-		},
-		tokenHandler: NewTokenHandler(db.Dbpool),
 	}
 	handler := s.RegisterRoutes()