db

type DB interface {
	Connect() error
	Close() error
	Connection() *sqlx.DB
	Migrate(ctx context.Context, options *MigrationOptions) (*MigrationResult, error)
	Tx(ctx context.Context, tx TxFn) error
	EventTx(ctx context.Context, etx EventTxFn) (*events.EventID, error)
	EventsTx(ctx context.Context, etx EventsTxFn) ([]events.EventID, error)
}

type EventTxFn func(ctx context.Context, tx *sqlx.Tx) (*events.EventSpec, error)

type EventsTxFn func(ctx context.Context, tx *sqlx.Tx) ([]*events.EventSpec, error)

type MigrationOptions struct {
	DropTablesBeforeMigrating bool
}

type MigrationResult struct {
	AppliedMigrations []string
}

type Migrator interface {
	Migrate(ctx context.Context, dsn string) (*MigrationResult, error)
}

type TxFn func(ctx context.Context, tx *sqlx.Tx) error