step 2: Add UUID columns with backfill and dual-write support

- Add migration 000007: Add UUID columns to soundtrack and song with backfill
- Update InsertSoundtrack and InsertSoundtrackWithExistingId to accept UUID
- Update AddSong to accept UUID
- Add dual-write: Go code now generates UUIDs for new records
- Add uuid and pgtype imports

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

internal/backend/characters.go

@@ -4,8 +4,8 @@ import (
 	"os"
 	"strings"
 
-	"go.uber.org/zap"
 	"music-server/internal/logging"
+	"go.uber.org/zap"
 )
 
 func GetCharacterList() []string {
@@ -30,10 +30,10 @@ func GetCharacterList() []string {
 
 func GetCharacter(character string) string {
 	charactersPath := os.Getenv("CHARACTERS_PATH")
+	logging.GetLogger().Debug("Getting character", zap.String("character", character), zap.String("path", charactersPath))
 	// Clean the path - remove trailing slashes and then add one for consistency
 	charactersPath = strings.TrimSuffix(charactersPath, "/")
 	charactersPath += "/"
-	logging.GetLogger().Debug("Getting character", zap.String("character", character), zap.String("path", charactersPath+character))
 	return charactersPath + character
 }
 

internal/backend/index.go

@@ -0,0 +1,95 @@
+package backend
+
+import (
+	"music-server/internal/db"
+)
+
+func TestDB() {
+	db.Testf()
+}
+
+type VersionData struct {
+	Version   string        `json:"version" example:"1.0.0"`
+	Changelog string        `json:"changelog" example:"account name"`
+	History   []VersionData `json:"history"`
+}
+
+func GetVersionHistory() VersionData {
+	data := VersionData{Version: "4.5.0",
+		Changelog: "#1 - Created request to check newest version of the app\n" +
+			"#2 - Added request to download the newest version of the app\n" +
+			"#3 - Added request to check progress during sync\n" +
+			"#4 - Now blocking all request while sync is in progress\n" +
+			"#5 - Implemented ants for thread pooling\n" +
+			"#6 - Changed the sync request to now only start the sync",
+		History: []VersionData{
+			{
+				Version: "4.0.0",
+				Changelog: "Changed framework from gin to Echo\n" +
+					"Reorganized the code\n" +
+					"Implemented sqlc\n" +
+					"Added support to send character images from the server\n" +
+					"Added function to create a new database of no one exists",
+			},
+			{
+				Version:   "3.2",
+				Changelog: "Upgraded Go version and the version of all dependencies. Fixed som more bugs.",
+			},
+			{
+				Version:   "3.1",
+				Changelog: "Fixed some bugs with songs not found made the application crash. Now checking if song exists and if not, remove song from DB and find another one. Frontend is now decoupled from the backend.",
+			},
+			{
+				Version:   "3.0",
+				Changelog: "Changed routing framework from mux to Gin. Swagger doc is now included in the application. A fronted can now be hosted from the application.",
+			},
+			{
+				Version:   "2.3.0",
+				Changelog: "Images should not be included in the database, removes songs where the path doesn't work.",
+			},
+			{
+				Version:   "2.2.0",
+				Changelog: "Changed the structure of the whole application, should be no changes to functionality.",
+			},
+			{
+				Version:   "2.1.4",
+				Changelog: "Game list should now be sorted, a new endpoint with the game list in random order have been added.",
+			},
+			{
+				Version:   "2.1.3",
+				Changelog: "Added a check to see if song exists before returning it, if not a new song will be picked up.",
+			},
+			{
+				Version:   "2.1.2",
+				Changelog: "Added test server to swagger file.",
+			},
+			{
+				Version:   "2.1.1",
+				Changelog: "Fixed bug where wrong song was showed as currently played.",
+			},
+			{
+				Version: "2.1.0",
+				Changelog: "Added /addQue to add the last received song to the songQue. " +
+					"Changed /rand and /rand/low to not add song to the que. " +
+					"Changed /next to not call /rand when the end of the que is reached, instead the last song in the que will be resent.",
+			},
+			{
+				Version:   "2.0.3",
+				Changelog: "Another small change that should fix the caching problem.",
+			},
+			{
+				Version:   "2.0.2",
+				Changelog: "Hopefully fixed the caching problem with random.",
+			},
+			{
+				Version:   "2.0.1",
+				Changelog: "Fixed CORS",
+			},
+			{
+				Version:   "2.0.0",
+				Changelog: "Rebuilt the application in Go.",
+			},
+		},
+	}
+	return data
+}

internal/backend/sync.go

@@ -16,6 +16,8 @@ import (
 	"sync"
 	"time"
 
+	"github.com/google/uuid"
+	"github.com/jackc/pgx/v5/pgtype"
 	"github.com/panjf2000/ants/v2"
 
 	"github.com/MShekow/directory-checksum/directory_checksum"
@@ -343,7 +345,8 @@ func syncGameNew(file os.DirEntry, foldersToSkip []string, baseDir string, full
 						break
 					}
 				}
-				err = repo.InsertSoundtrackWithExistingId(BackendCtx(), repository.InsertSoundtrackWithExistingIdParams{ID: id, SoundtrackName: file.Name(), Path: gameDir, Hash: dirHash})
+				gameUuid := pgtype.UUID{Bytes: uuid.New(), Valid: true}
+			err = repo.InsertSoundtrackWithExistingId(BackendCtx(), repository.InsertSoundtrackWithExistingIdParams{ID: id, Uuid: gameUuid, SoundtrackName: file.Name(), Path: gameDir, Hash: dirHash})
 				handleError("InsertSoundtrackWithExistingId", err, "")
 				if err != nil {
 					logging.GetLogger().Debug("Game already exists, removing old ID file",
@@ -435,7 +438,8 @@ func syncGameNew(file os.DirEntry, foldersToSkip []string, baseDir string, full
 
 func insertGameNew(name string, path string, hash string) int32 {
 	var duplicateError = errors.New("ERROR: duplicate key value violates unique")
-	id, err := repo.InsertSoundtrack(BackendCtx(), repository.InsertSoundtrackParams{SoundtrackName: name, Path: path, Hash: hash})
+	gameUuid := pgtype.UUID{Bytes: uuid.New(), Valid: true}
+	id, err := repo.InsertSoundtrack(BackendCtx(), repository.InsertSoundtrackParams{Uuid: gameUuid, SoundtrackName: name, Path: path, Hash: hash})
 	handleError("InsertSoundtrack", err, "")
 	if err != nil {
 		logging.GetLogger().Warn("ID collision detected, resetting sequence")
@@ -522,7 +526,8 @@ func newCheckSong(entry os.DirEntry, gameDir string, id int32) bool {
 				err = repo.AddHashToSong(BackendCtx(), repository.AddHashToSongParams{Hash: songHash, SoundtrackID: id, Path: path})
 				handleError("AddHashToSong", err, fmt.Sprintf("SoundtrackID: %d | Path: %s | SongName: %s | SongHash: %s", id, path, entry.Name(), songHash))
 			} else {
-				err = repo.AddSong(BackendCtx(), repository.AddSongParams{SoundtrackID: id, SongName: songName, Path: path, FileName: &fileName, Hash: songHash})
+				songUuid := pgtype.UUID{Bytes: uuid.New(), Valid: true}
+				err = repo.AddSong(BackendCtx(), repository.AddSongParams{Uuid: songUuid, SoundtrackID: id, SongName: songName, Path: path, FileName: &fileName, Hash: songHash})
 				handleError("AddSong", err, fmt.Sprintf("SoundtrackID: %d | Path: %s | SongName: %s | SongHash: %s", id, path, entry.Name(), songHash))
 
 			}

internal/backend/version.go

@@ -1,111 +0,0 @@
-package backend
-
-type VersionData struct {
-	Version   string   `json:"version" example:"1.0.0"`
-	Changelog []string `json:"changelog" example:"[\"Initial release\",\"Bug fixes\"]"`
-}
-
-var data = []VersionData{
-	{
-		Version:   "5.0.0-Beta",
-		Changelog: []string{
-			"#16 - Upgrade Echo framework from v4 to v5",
-			"#17 - Add Zap structured logging framework",
-			"#18 - Add OpenAPI/Swagger documentation",
-			"#19 - Replace Tailwind CSS with pure CSS",
-			"#20 - Change domain from sanplex.tech to sanplex.xyz",
-			"#21 - Refactor handlers into domain-specific files",
-			"#22 - Change VersionData Changelog from string to string array",
-			"#23 - Update all dependencies to latest versions",
-		},
-	},
-	{
-		Version: "4.5.0",
-		Changelog: []string{
-			"#1 - Created request to check newest version of the app",
-			"#2 - Added request to download the newest version of the app",
-			"#3 - Added request to check progress during sync",
-			"#4 - Now blocking all request while sync is in progress",
-			"#5 - Implemented ants for thread pooling",
-			"#6 - Changed the sync request to now only start the sync",
-		},
-	},
-	{
-		Version: "4.0.0",
-		Changelog: []string{
-			"Changed framework from gin to Echo",
-			"Reorganized the code",
-			"Implemented sqlc",
-			"Added support to send character images from the server",
-			"Added function to create a new database of no one exists",
-		},
-	},
-	{
-		Version:   "3.2",
-		Changelog: []string{"Upgraded Go version and the version of all dependencies. Fixed som more bugs."},
-	},
-	{
-		Version:   "3.1",
-		Changelog: []string{"Fixed some bugs with songs not found made the application crash. Now checking if song exists and if not, remove song from DB and find another one. Frontend is now decoupled from the backend."},
-	},
-	{
-		Version:   "3.0",
-		Changelog: []string{"Changed routing framework from mux to Gin. Swagger doc is now included in the application. A fronted can now be hosted from the application."},
-	},
-	{
-		Version:   "2.3.0",
-		Changelog: []string{"Images should not be included in the database, removes songs where the path doesn't work."},
-	},
-	{
-		Version:   "2.2.0",
-		Changelog: []string{"Changed the structure of the whole application, should be no changes to functionality."},
-	},
-	{
-		Version:   "2.1.4",
-		Changelog: []string{"Game list should now be sorted, a new endpoint with the game list in random order have been added."},
-	},
-	{
-		Version:   "2.1.3",
-		Changelog: []string{"Added a check to see if song exists before returning it, if not a new song will be picked up."},
-	},
-	{
-		Version:   "2.1.2",
-		Changelog: []string{"Added test server to swagger file."},
-	},
-	{
-		Version:   "2.1.1",
-		Changelog: []string{"Fixed bug where wrong song was showed as currently played."},
-	},
-	{
-		Version: "2.1.0",
-		Changelog: []string{
-			"Added /addQue to add the last received song to the songQue.",
-			"Changed /rand and /rand/low to not add song to the que.",
-			"Changed /next to not call /rand when the end of the que is reached, instead the last song in the que will be resent.",
-		},
-	},
-	{
-		Version:   "2.0.3",
-		Changelog: []string{"Another small change that should fix the caching problem."},
-	},
-	{
-		Version:   "2.0.2",
-		Changelog: []string{"Hopefully fixed the caching problem with random."},
-	},
-	{
-		Version:   "2.0.1",
-		Changelog: []string{"Fixed CORS"},
-	},
-	{
-		Version:   "2.0.0",
-		Changelog: []string{"Rebuilt the application in Go."},
-	},
-}
-
-func GetLatestVersion() VersionData {
-	return data[0]
-}
-
-func GetVersionHistory() []VersionData {
-	return data
-}

internal/db/dbHelper.go

@@ -56,6 +56,21 @@ func CloseDb() {
 	Dbpool.Close()
 }
 
+func Testf() {
+	rows, dbErr := Dbpool.Query(Ctx, "select game_name from game")
+	if dbErr != nil {
+		logging.GetLogger().Fatal("Query failed", zap.String("error", dbErr.Error()))
+	}
+	for rows.Next() {
+		var gameName string
+		dbErr = rows.Scan(&gameName)
+		if dbErr != nil {
+			logging.GetLogger().Error("Row scan failed", zap.String("error", dbErr.Error()))
+		}
+		logging.GetLogger().Debug("Game found", zap.String("name", gameName))
+	}
+}
+
 func ResetGameIdSeq() {
 	_, err := Dbpool.Query(Ctx, "SELECT setval('game_id_seq', (SELECT MAX(id) FROM game)+1);")
 	if err != nil {

internal/db/migrations/000007_add_uuid_and_backfill.down.sql

@@ -0,0 +1,9 @@
+-- Rollback: Remove UUID columns from soundtrack and song tables
+
+-- Drop indexes
+DROP INDEX IF EXISTS idx_soundtrack_uuid;
+DROP INDEX IF EXISTS idx_song_uuid;
+
+-- Drop UUID columns
+ALTER TABLE soundtrack DROP COLUMN IF EXISTS uuid;
+ALTER TABLE song DROP COLUMN IF EXISTS uuid;

internal/db/migrations/000007_add_uuid_and_backfill.up.sql

@@ -0,0 +1,21 @@
+-- Migration: Add UUID columns to soundtrack and song, then backfill
+
+-- Add UUID column to soundtrack (nullable for now)
+ALTER TABLE soundtrack ADD COLUMN uuid UUID NULL UNIQUE;
+
+-- Create index on uuid for performance
+CREATE INDEX IF NOT EXISTS idx_soundtrack_uuid ON soundtrack(uuid);
+
+-- Add UUID column to song (nullable for now)
+ALTER TABLE song ADD COLUMN uuid UUID NULL UNIQUE;
+
+-- Create index on uuid for performance
+CREATE INDEX IF NOT EXISTS idx_song_uuid ON song(uuid);
+
+-- Backfill existing records immediately
+UPDATE soundtrack SET uuid = gen_random_uuid() WHERE uuid IS NULL;
+UPDATE song SET uuid = gen_random_uuid() WHERE uuid IS NULL;
+
+-- Verify no nulls remain
+-- SELECT COUNT(*) FROM soundtrack WHERE uuid IS NULL;  -- Should be 0
+-- SELECT COUNT(*) FROM song WHERE uuid IS NULL;            -- Should be 0

internal/db/queries/song.sql

@@ -5,7 +5,7 @@ DELETE FROM song;
 DELETE FROM song WHERE soundtrack_id = $1;
 
 -- name: AddSong :exec
-INSERT INTO song(soundtrack_id, song_name, path, file_name, hash) VALUES ($1, $2, $3, $4, $5);
+INSERT INTO song(uuid, soundtrack_id, song_name, path, file_name, hash) VALUES ($1, $2, $3, $4, $5, $6);
 
 -- name: CheckSong :one
 SELECT COUNT(*) FROM song WHERE soundtrack_id = $1 AND path = $2;

internal/db/queries/soundtrack.sql

@@ -29,10 +29,10 @@ UPDATE soundtrack SET deleted=NULL WHERE id=$1;
 SELECT id FROM soundtrack WHERE soundtrack_name = $1;
 
 -- name: InsertSoundtrack :one
-INSERT INTO soundtrack (soundtrack_name, path, hash, added) VALUES ($1, $2, $3, now()) returning id;
+INSERT INTO soundtrack (uuid, soundtrack_name, path, hash, added) VALUES ($1, $2, $3, $4, now()) returning id;
 
 -- name: InsertSoundtrackWithExistingId :exec
-INSERT INTO soundtrack (id, soundtrack_name, path, hash, added) VALUES ($1, $2, $3, $4, now());
+INSERT INTO soundtrack (id, uuid, soundtrack_name, path, hash, added) VALUES ($1, $2, $3, $4, $5, now());
 
 -- name: FindAllSoundtracks :many
 SELECT *

internal/db/repository/models.go

@@ -10,14 +10,6 @@ import (
 	"github.com/jackc/pgx/v5/pgtype"
 )
 
-type IDMigrationStatus struct {
-	TableName    string     `json:"table_name"`
-	TotalRows    int32      `json:"total_rows"`
-	MigratedRows int32      `json:"migrated_rows"`
-	Completed    bool       `json:"completed"`
-	StartedAt    *time.Time `json:"started_at"`
-}
-
 type Session struct {
 	Token      string             `json:"token"`
 	IpAddress  string             `json:"ip_address"`

internal/db/repository/song.sql.go

@@ -27,10 +27,11 @@ func (q *Queries) AddHashToSong(ctx context.Context, arg AddHashToSongParams) er
 }
 
 const addSong = `-- name: AddSong :exec
-INSERT INTO song(soundtrack_id, song_name, path, file_name, hash) VALUES ($1, $2, $3, $4, $5)
+INSERT INTO song(uuid, soundtrack_id, song_name, path, file_name, hash) VALUES ($1, $2, $3, $4, $5, $6)
 `
 
 type AddSongParams struct {
+	Uuid         pgtype.UUID `json:"uuid"`
 	SoundtrackID int32       `json:"soundtrack_id"`
 	SongName     string      `json:"song_name"`
 	Path         string      `json:"path"`
@@ -40,6 +41,7 @@ type AddSongParams struct {
 
 func (q *Queries) AddSong(ctx context.Context, arg AddSongParams) error {
 	_, err := q.db.Exec(ctx, addSong,
+		arg.Uuid,
 		arg.SoundtrackID,
 		arg.SongName,
 		arg.Path,

internal/db/repository/soundtrack.sql.go

@@ -7,6 +7,8 @@ package repository
 
 import (
 	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
 )
 
 const addSoundtrackPlayed = `-- name: AddSoundtrackPlayed :exec
@@ -153,28 +155,35 @@ func (q *Queries) GetSoundtrackNameById(ctx context.Context, id int32) (string,
 }
 
 const insertSoundtrack = `-- name: InsertSoundtrack :one
-INSERT INTO soundtrack (soundtrack_name, path, hash, added) VALUES ($1, $2, $3, now()) returning id
+INSERT INTO soundtrack (uuid, soundtrack_name, path, hash, added) VALUES ($1, $2, $3, $4, now()) returning id
 `
 
 type InsertSoundtrackParams struct {
+	Uuid           pgtype.UUID `json:"uuid"`
 	SoundtrackName string      `json:"soundtrack_name"`
 	Path           string      `json:"path"`
 	Hash           string      `json:"hash"`
 }
 
 func (q *Queries) InsertSoundtrack(ctx context.Context, arg InsertSoundtrackParams) (int32, error) {
-	row := q.db.QueryRow(ctx, insertSoundtrack, arg.SoundtrackName, arg.Path, arg.Hash)
+	row := q.db.QueryRow(ctx, insertSoundtrack,
+		arg.Uuid,
+		arg.SoundtrackName,
+		arg.Path,
+		arg.Hash,
+	)
 	var id int32
 	err := row.Scan(&id)
 	return id, err
 }
 
 const insertSoundtrackWithExistingId = `-- name: InsertSoundtrackWithExistingId :exec
-INSERT INTO soundtrack (id, soundtrack_name, path, hash, added) VALUES ($1, $2, $3, $4, now())
+INSERT INTO soundtrack (id, uuid, soundtrack_name, path, hash, added) VALUES ($1, $2, $3, $4, $5, now())
 `
 
 type InsertSoundtrackWithExistingIdParams struct {
 	ID             int32       `json:"id"`
+	Uuid           pgtype.UUID `json:"uuid"`
 	SoundtrackName string      `json:"soundtrack_name"`
 	Path           string      `json:"path"`
 	Hash           string      `json:"hash"`
@@ -183,6 +192,7 @@ type InsertSoundtrackWithExistingIdParams struct {
 func (q *Queries) InsertSoundtrackWithExistingId(ctx context.Context, arg InsertSoundtrackWithExistingIdParams) error {
 	_, err := q.db.Exec(ctx, insertSoundtrackWithExistingId,
 		arg.ID,
+		arg.Uuid,
 		arg.SoundtrackName,
 		arg.Path,
 		arg.Hash,

internal/server/characterHandler.go

@@ -1,42 +0,0 @@
-package server
-
-import (
-	"net/http"
-
-	"github.com/labstack/echo/v5"
-	"music-server/internal/backend"
-)
-
-type CharacterHandler struct {
-}
-
-func NewCharacterHandler() *CharacterHandler {
-	return &CharacterHandler{}
-}
-
-// GetCharacterList godoc
-// @Summary Get list of characters
-// @Description Returns a list of all available characters
-// @Tags characters
-// @Accept json
-// @Produce json
-// @Success 200 {array} string
-// @Router /characters [get]
-func (c *CharacterHandler) GetCharacterList(ctx *echo.Context) error {
-	characters := backend.GetCharacterList()
-	return ctx.JSON(http.StatusOK, characters)
-}
-
-// GetCharacter godoc
-// @Summary Get character image
-// @Description Returns the image for a specific character
-// @Tags characters
-// @Accept json
-// @Produce image/png
-// @Param name query string true "Character name"
-// @Success 200 {file} file
-// @Router /character [get]
-func (c *CharacterHandler) GetCharacter(ctx *echo.Context) error {
-	character := ctx.QueryParam("name")
-	return ctx.File(backend.GetCharacter(character))
-}

internal/server/healthHandler.go

@@ -1,28 +0,0 @@
-package server
-
-import (
-	"net/http"
-
-	"github.com/labstack/echo/v5"
-	"music-server/internal/db"
-)
-
-type HealthHandler struct {
-}
-
-func NewHealthHandler() *HealthHandler {
-	return &HealthHandler{}
-}
-
-// HealthCheck godoc
-//
-//	@Summary		Check server health
-//	@Description	Returns the health status of the server
-//	@Tags			health
-//	@Accept			json
-//	@Produce		json
-//	@Success		200	{string}	string	"OK"
-//	@Router			/health [get]
-func (h *HealthHandler) HealthCheck(ctx *echo.Context) error {
-	return ctx.JSON(http.StatusOK, db.Health())
-}

internal/server/health_handler_test.go

@@ -1,29 +0,0 @@
-package server
-
-import (
-	"encoding/json"
-	"net/http"
-	"testing"
-
-	"music-server/internal/db"
-
-	"github.com/stretchr/testify/assert"
-)
-
-// TestHealthCheck verifies the health endpoint returns database status
-func TestHealthCheck(t *testing.T) {
-	// Setup database
-	db.TestSetupDB(t)
-	defer db.TestTearDownDB(t)
-
-	e := StartTestServer(t)
-
-	resp := MakeTestRequest(t, e, "GET", "/health")
-	assert.Equal(t, http.StatusOK, resp.Code)
-
-	var healthData map[string]string
-	err := json.Unmarshal(resp.Body.Bytes(), &healthData)
-	assert.NoError(t, err)
-	assert.NotEmpty(t, healthData)
-	assert.Equal(t, "up", healthData["status"])
-}

internal/server/indexHandler.go

@@ -0,0 +1,86 @@
+package server
+
+import (
+	"music-server/internal/backend"
+	"music-server/internal/db"
+	"net/http"
+
+	"github.com/labstack/echo/v5"
+)
+
+type IndexHandler struct {
+}
+
+func NewIndexHandler() *IndexHandler {
+	return &IndexHandler{}
+}
+
+// GetVersion godoc
+//
+//	@Summary		Getting the version of the backend
+//	@Description	get string by ID
+//	@Tags			accounts
+//	@Accept			json
+//	@Produce		json
+//	@Success		200	{object}	backend.VersionData
+//	@Failure		404	{object}	string
+//	@Router			/version [get]
+func (i *IndexHandler) GetVersion(ctx *echo.Context) error {
+	versionHistory := backend.GetVersionHistory()
+	if versionHistory.Version == "" {
+		return ctx.JSON(http.StatusNotFound, "version not found")
+	}
+	return ctx.JSON(http.StatusOK, versionHistory)
+}
+
+// GetDBTest godoc
+// @Summary Test database connection
+// @Description Tests the database connection
+// @Tags database
+// @Accept json
+// @Produce json
+// @Success 200 {string} string "TestedDB"
+// @Router /dbtest [get]
+func (i *IndexHandler) GetDBTest(ctx *echo.Context) error {
+	backend.TestDB()
+	return ctx.JSON(http.StatusOK, "TestedDB")
+}
+
+// HealthCheck godoc
+// @Summary Check server health
+// @Description Returns the health status of the server
+// @Tags health
+// @Accept json
+// @Produce json
+// @Success 200 {string} string "OK"
+// @Router /health [get]
+func (i *IndexHandler) HealthCheck(ctx *echo.Context) error {
+	return ctx.JSON(http.StatusOK, db.Health())
+}
+
+// GetCharacterList godoc
+// @Summary Get list of characters
+// @Description Returns a list of all available characters
+// @Tags characters
+// @Accept json
+// @Produce json
+// @Success 200 {array} string
+// @Router /characters [get]
+func (i *IndexHandler) GetCharacterList(ctx *echo.Context) error {
+	characters := backend.GetCharacterList()
+	return ctx.JSON(http.StatusOK, characters)
+}
+
+// GetCharacter godoc
+// @Summary Get character image
+// @Description Returns the image for a specific character
+// @Tags characters
+// @Accept json
+// @Produce image/png
+// @Param name query string true "Character name"
+// @Success 200 {file} file
+// @Router /character [get]
+func (i *IndexHandler) GetCharacter(ctx *echo.Context) error {
+	character := ctx.QueryParam("name")
+	return ctx.File(backend.GetCharacter(character))
+}

internal/server/index_handler_test.go

@@ -5,9 +5,45 @@ import (
 	"net/http"
 	"testing"
 
+	"music-server/internal/backend"
+	"music-server/internal/db"
+
 	"github.com/stretchr/testify/assert"
 )
 
+// TestHealthCheck verifies the health endpoint returns database status
+func TestHealthCheck(t *testing.T) {
+	// Setup database
+	db.TestSetupDB(t)
+	defer db.TestTearDownDB(t)
+
+	e := StartTestServer(t)
+
+	resp := MakeTestRequest(t, e, "GET", "/health")
+	assert.Equal(t, http.StatusOK, resp.Code)
+
+	var healthData map[string]string
+	err := json.Unmarshal(resp.Body.Bytes(), &healthData)
+	assert.NoError(t, err)
+	assert.NotEmpty(t, healthData)
+	assert.Equal(t, "up", healthData["status"])
+}
+
+// TestGetVersion verifies the version endpoint returns version history
+func TestGetVersion(t *testing.T) {
+	e := StartTestServer(t)
+
+	resp := MakeTestRequest(t, e, "GET", "/version")
+	assert.Equal(t, http.StatusOK, resp.Code)
+
+	var versionData backend.VersionData
+	err := json.Unmarshal(resp.Body.Bytes(), &versionData)
+	assert.NoError(t, err)
+	assert.NotEmpty(t, versionData.Version)
+	assert.NotEmpty(t, versionData.Changelog)
+	assert.NotEmpty(t, versionData.History)
+}
+
 // TestGetCharacterList verifies the characters endpoint returns list of characters
 func TestGetCharacterList(t *testing.T) {
 	e := StartTestServer(t)
@@ -45,3 +81,16 @@ func TestGetCharacterNotFound(t *testing.T) {
 	// Should return 404 or similar error
 	assert.NotEqual(t, http.StatusOK, resp.Code)
 }
+
+// TestDBTest verifies the database test endpoint
+func TestDBTest(t *testing.T) {
+	// Setup database
+	db.TestSetupDB(t)
+	defer db.TestTearDownDB(t)
+
+	e := StartTestServer(t)
+
+	resp := MakeTestRequest(t, e, "GET", "/dbtest")
+	assert.Equal(t, http.StatusOK, resp.Code)
+	assert.Contains(t, resp.Body.String(), "TestedDB")
+}

internal/server/routes.go

@@ -63,16 +63,12 @@ func (s *Server) RegisterRoutes() http.Handler {
 	// ============================================
 	deprecatedMiddleware := middleware.DeprecationMiddleware
 
-	health := NewHealthHandler()
+	index := NewIndexHandler()
-	e.GET("/health", deprecatedMiddleware(health.HealthCheck))
+	e.GET("/version", deprecatedMiddleware(index.GetVersion))
-
+	e.GET("/dbtest", deprecatedMiddleware(index.GetDBTest))
-	version := NewVersionHandler()
+	e.GET("/health", deprecatedMiddleware(index.HealthCheck))
-	e.GET("/version", deprecatedMiddleware(version.GetLatestVersion))
+	e.GET("/character", deprecatedMiddleware(index.GetCharacter))
-	e.GET("/version/history", deprecatedMiddleware(version.GetVersionHistory))
+	e.GET("/characters", deprecatedMiddleware(index.GetCharacterList))
-
-	character := NewCharacterHandler()
-	e.GET("/character", deprecatedMiddleware(character.GetCharacter))
-	e.GET("/characters", deprecatedMiddleware(character.GetCharacterList))
 
 	download := NewDownloadHandler()
 	e.GET("/download", deprecatedMiddleware(download.checkLatest))

internal/server/versionHandler.go

@@ -1,51 +0,0 @@
-package server
-
-import (
-	"net/http"
-
-	"github.com/labstack/echo/v5"
-	"music-server/internal/backend"
-)
-
-type VersionHandler struct {
-}
-
-func NewVersionHandler() *VersionHandler {
-	return &VersionHandler{}
-}
-
-// GetVersionHistory godoc
-//
-//	@Summary		Getting the version history of the backend
-//	@Description	get version history
-//	@Tags			version
-//	@Accept			json
-//	@Produce		json
-//	@Success		200	{array}	backend.VersionData
-//	@Failure		404	{object}	string
-//	@Router			/version/history [get]
-func (v *VersionHandler) GetVersionHistory(ctx *echo.Context) error {
-	versionHistory := backend.GetVersionHistory()
-	if len(versionHistory) == 0 {
-		return ctx.JSON(http.StatusNotFound, "version not found")
-	}
-	return ctx.JSON(http.StatusOK, versionHistory)
-}
-
-// GetLatestVersion godoc
-//
-//	@Summary		Getting the latest version of the backend
-//	@Description	get latest version info
-//	@Tags			version
-//	@Accept			json
-//	@Produce		json
-//	@Success		200	{object}	backend.VersionData
-//	@Failure		404	{object}	string
-//	@Router			/version [get]
-func (v *VersionHandler) GetLatestVersion(ctx *echo.Context) error {
-	latestVersion := backend.GetLatestVersion()
-	if latestVersion.Version == "" {
-		return ctx.JSON(http.StatusNotFound, "version not found")
-	}
-	return ctx.JSON(http.StatusOK, latestVersion)
-}

internal/server/version_handler_test.go

@@ -1,40 +0,0 @@
-package server
-
-import (
-	"encoding/json"
-	"net/http"
-	"testing"
-
-	"music-server/internal/backend"
-
-	"github.com/stretchr/testify/assert"
-)
-
-// TestGetLatestVersion verifies the version endpoint returns latest version
-func TestGetLatestVersion(t *testing.T) {
-	e := StartTestServer(t)
-
-	resp := MakeTestRequest(t, e, "GET", "/version")
-	assert.Equal(t, http.StatusOK, resp.Code)
-
-	var versionData backend.VersionData
-	err := json.Unmarshal(resp.Body.Bytes(), &versionData)
-	assert.NoError(t, err)
-	assert.NotEmpty(t, versionData.Version)
-	assert.NotEmpty(t, versionData.Changelog)
-}
-
-// TestGetVersionHistory verifies the version history endpoint returns version history
-func TestGetVersionHistory(t *testing.T) {
-	e := StartTestServer(t)
-
-	resp := MakeTestRequest(t, e, "GET", "/version/history")
-	assert.Equal(t, http.StatusOK, resp.Code)
-
-	var versionHistory []backend.VersionData
-	err := json.Unmarshal(resp.Body.Bytes(), &versionHistory)
-	assert.NoError(t, err)
-	assert.NotEmpty(t, versionHistory)
-	assert.NotEmpty(t, versionHistory[0].Version)
-	assert.NotEmpty(t, versionHistory[0].Changelog)
-}

justfile

@@ -80,9 +80,6 @@ run:
 	@templ generate
 	@go run cmd/main.go
 
-build-run: build
-	@go run cmd/main.go
-
 test: build
 	@echo "Testing..."
 	@go test ./... -v