sqlstore

type Config struct {
	Driver     string       // "sqlite" | "postgres"
	DataDir    string       // SQLite file lives at DataDir/liturgist.db
	URL        string       // PostgreSQL
	MaxConns   int          // PostgreSQL pool; 0 = 10
	MaxReaders int          // SQLite readers; 0 = 4
	Logger     *slog.Logger // warnings about unknown stored scopes; nil = discard
}

type DB struct {
	// contains filtered or unexported fields
}

type Dialect interface {
	Name() string // "sqlite" | "postgres"
	Rebind(query string) string
	// MapError turns driver errors into app errors (02 §8); nil and unknown errors pass through.
	MapError(err error) error
	// Retryable reports busy, serialisation and deadlock errors (02 §2).
	Retryable(err error) bool
	LockInstall(ctx context.Context, tx *sqlx.Tx) error
	LockUser(ctx context.Context, tx *sqlx.Tx, id string) error
	LockChurch(ctx context.Context, tx *sqlx.Tx, id string) error
	SetTenant(ctx context.Context, tx *sqlx.Tx, churchID string) error // RLS hook (02 §7)
	TimeArg(t time.Time) any                                           // value to bind for a timestamp

	// Song search (06 §5): the only place the two databases differ in how
	// text is matched. Folded text contains only letters, digits and single
	// spaces, so every tokenizer splits at the same places.
	WriteSongIndex(ctx context.Context, tx *sqlx.Tx, churchID, songID, language, head, lyrics string) error // replaces the song's rows
	DeleteSongIndex(ctx context.Context, tx *sqlx.Tx, churchID, songID string) error
	DeleteChurchIndex(ctx context.Context, tx *sqlx.Tx, churchID string) error
	// TermMatch is the predicate "some token of the head (headOnly) or of head or
	// lyrics starts with term" for the song_search row aliased ss.
	TermMatch(term string, headOnly bool) (sql string, args []any)
	// Contains is the predicate "col contains the bound value" (Chinese substring search).
	Contains(col string) string
	// OrderBytes orders a text column bytewise, so both databases sort alike.
	OrderBytes(col string) string
}

type MigrateOptions struct {
	FS               fs.FS // migrations for this dialect
	AllowNewerSchema bool  // only skips the refusal to start (02 §5.1)
	RequireCopy      bool  // LITURGIST_REQUIRE_PREUPGRADE_COPY
	Logger           *slog.Logger
	Now              func() time.Time
}

type MigrateResult struct {
	From, To int64
	CopyPath string // "" when no copy was made
}

type NullTime struct {
	Time  time.Time
	Valid bool
}

type SchemaNewerError struct{ DB, Program int64 }

type Time struct{ time.Time }