gabehf/Koito
1
0
Fork 0
mirror of https://github.com/gabehf/Koito.git synced 2026-04-22 20:11:50 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: embed db migrations

Browse source
This commit is contained in:
potatoattack 2025-06-28 17:17:32 +10:00
parent 5537b6fb89
commit 4a0519f01b
2 changed files with 9 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

6
db/migrations/migrations.go Normal file
View file

@ -0,0 +1,6 @@
package migrations
import "embed"
//go:embed *.sql
var Files embed.FS

11
internal/db/psql/psql.go
View file

@ -5,10 +5,9 @@ import (
"context" "context"
"database/sql" "database/sql"
"fmt" "fmt"
"path/filepath"
"runtime"
"time" "time"
"github.com/gabehf/koito/db/migrations"
"github.com/gabehf/koito/internal/cfg" "github.com/gabehf/koito/internal/cfg"
"github.com/gabehf/koito/internal/db" "github.com/gabehf/koito/internal/db"
"github.com/gabehf/koito/internal/repository" "github.com/gabehf/koito/internal/repository"
@ -54,13 +53,9 @@ func New() (*Psql, error) {
return nil, fmt.Errorf("psql.New: failed to open db for migrations: %w", err) return nil, fmt.Errorf("psql.New: failed to open db for migrations: %w", err)
} }
_, filename, _, ok := runtime.Caller(0) goose.SetBaseFS(migrations.Files)
if !ok {
return nil, fmt.Errorf("psql.New: unable to get caller info")
}
migrationsPath := filepath.Join(filepath.Dir(filename), "..", "..", "..", "db", "migrations")
if err := goose.Up(sqlDB, migrationsPath); err != nil { if err := goose.Up(sqlDB, "."); err != nil {
return nil, fmt.Errorf("psql.New: goose failed: %w", err) return nil, fmt.Errorf("psql.New: goose failed: %w", err)
} }
_ = sqlDB.Close() _ = sqlDB.Close()