feat(db): add migration logic

Signed-off-by: brookjeynes <[e-mail]>

internal/db/db.go

···
 	"strings"
 
 	_ "github.com/mattn/go-sqlite3"
+	"yoten.app/internal/server/log"
 )
 
 type DB struct {
···
 	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
 }
 
-func Make(ctx context.Context, dbPath string, logger *slog.Logger) (*DB, error) {
+func Make(ctx context.Context, dbPath string) (*DB, error) {
 	opts := []string{
 		"_foreign_keys=1",
 		"_journal_mode=WAL",
 		"_synchronous=NORMAL",
 		"_auto_vacuum=incremental",
 	}
+
+	logger := log.FromContext(ctx)
+	logger = log.SubLogger(logger, "db")
 
 	db, err := sql.Open("sqlite3", dbPath+"?"+strings.Join(opts, "&"))
 	if err != nil {
···
 		logger,
 	}, nil
 }
+
+type migrationFn = func(*sql.Tx) error
+
+func runMigration(c *sql.Conn, logger *slog.Logger, name string, migrationFn migrationFn) error {
+	logger = logger.With("migration", name)
+
+	tx, err := c.BeginTx(context.Background(), nil)
+	if err != nil {
+		return err
+	}
+	defer tx.Rollback()
+
+	var exists bool
+	err = tx.QueryRow("select exists (select 1 from migrations where name = ?)", name).Scan(&exists)
+	if err != nil {
+		return err
+	}
+
+	if !exists {
+		err = migrationFn(tx)
+		if err != nil {
+			logger.Error("failed to run migration", "err", err)
+			return err
+		}
+
+		_, err = tx.Exec("insert into migrations (name) values (?)", name)
+		if err != nil {
+			logger.Error("failed to mark migration as complete", "err", err)
+			return err
+		}
+
+		if err := tx.Commit(); err != nil {
+			return err
+		}
+
+		logger.Info("migration applied successfully")
+	} else {
+		logger.Warn("skipped migration, already applied")
+	}
+
+	return nil
+}

internal/server/app.go

···
 func Make(ctx context.Context, config *config.Config) (*Server, error) {
 	logger := log.FromContext(ctx)
 
-	d, err := db.Make(ctx, config.Core.DbPath, log.SubLogger(logger, "db"))
+	d, err := db.Make(ctx, config.Core.DbPath)
 	if err != nil {
 		return nil, err
 	}