Method runMigrations

internal/metadata/store.go:420–446

runMigrations applies idempotent data migrations after the schema exists.

(ctx context.Context, db *sql.DB)

// runMigrations applies idempotent data migrations after the schema exists.
func (s *Store) runMigrations(ctx context.Context, db *sql.DB) error {
	if _, err := db.ExecContext(ctx, migrationMetaSQL); err != nil {
		return fmt.Errorf("migration meta: %w", err)
	}
	migrations := []struct {
		id  string
		run func(context.Context, *sql.DB) error
	}{
		{id: "prompt_to_instruction", run: s.migratePromptToInstruction},
	}
	for _, migration := range migrations {
		var applied int
		if err := db.QueryRowContext(ctx, `SELECT COUNT(*) FROM migration_meta WHERE id = ?`, migration.id).Scan(&applied); err != nil {
			return fmt.Errorf("migration check %s: %w", migration.id, err)
		}
		if applied > 0 {
			continue
		}
		if err := migration.run(ctx, db); err != nil {
			return fmt.Errorf("migration %s: %w", migration.id, err)
		}
		if _, err := db.ExecContext(ctx, `INSERT INTO migration_meta(id, applied_at) VALUES(?, ?)`, migration.id, timeNow()); err != nil {
			return fmt.Errorf("migration record %s: %w", migration.id, err)
		}
	}
	return nil
}

func (s *Store) migratePromptToInstruction(ctx context.Context, db *sql.DB) error {
	for _, table := range []string{"metadata_items", "metadata_sources"} {