package seeder

import (
	"context"
	"os"

	"github.com/jackc/tern/v2/migrate"
	"gitlab.com/alexkavon/newsstand/src/db"
)

func MigrateDatabase(dbpool *db.Db, migrationspath string) error {
	conn, err := dbpool.Conn().Acquire(context.Background())
	if err != nil {
		return err
	}
	m, err := migrate.NewMigrator(context.Background(), conn.Conn(), "public.schema_version")
	if err != nil {
		return err
	}
	// load migration files
	err = m.LoadMigrations(os.DirFS(migrationspath))
	if err != nil {
		return err
	}

	// migrate!
	return m.Migrate(context.Background())
}