cgalo5758
b0072d8971
Squash the pre-production migration history into fresh core, fedwiki, and stripe baselines and reduce the canonical source list to those three streams. Update sqlc configs, generated queries, raw SQL, tests, and docs while keeping provider tables schema-qualified. BREAKING: existing local database volumes must be wiped because goose version history restarts from the new baselines.
106 lines
2.6 KiB
Go
106 lines
2.6 KiB
Go
// Code generated by sqlc. DO NOT EDIT.
|
|
// versions:
|
|
// sqlc v1.29.0
|
|
// source: provider_states.sql
|
|
|
|
package integration
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/lib/pq"
|
|
)
|
|
|
|
const addProviderState = `-- name: AddProviderState :exec
|
|
INSERT INTO core.provider_states (provider, state)
|
|
VALUES ($1, $2)
|
|
ON CONFLICT (provider, state) DO NOTHING
|
|
`
|
|
|
|
type AddProviderStateParams struct {
|
|
Provider string `json:"provider"`
|
|
State string `json:"state"`
|
|
}
|
|
|
|
func (q *Queries) AddProviderState(ctx context.Context, arg AddProviderStateParams) error {
|
|
_, err := q.db.ExecContext(ctx, addProviderState, arg.Provider, arg.State)
|
|
return err
|
|
}
|
|
|
|
const deleteProviderStatesNotIn = `-- name: DeleteProviderStatesNotIn :exec
|
|
DELETE FROM core.provider_states
|
|
WHERE provider = $1 AND state <> ALL($2::text[])
|
|
`
|
|
|
|
type DeleteProviderStatesNotInParams struct {
|
|
Provider string `json:"provider"`
|
|
States []string `json:"states"`
|
|
}
|
|
|
|
// Boot reconciliation: drop states a provider no longer declares.
|
|
func (q *Queries) DeleteProviderStatesNotIn(ctx context.Context, arg DeleteProviderStatesNotInParams) error {
|
|
_, err := q.db.ExecContext(ctx, deleteProviderStatesNotIn, arg.Provider, pq.Array(arg.States))
|
|
return err
|
|
}
|
|
|
|
const listAllProviderStates = `-- name: ListAllProviderStates :many
|
|
SELECT provider, state FROM core.provider_states
|
|
ORDER BY provider, state
|
|
`
|
|
|
|
type ListAllProviderStatesRow struct {
|
|
Provider string `json:"provider"`
|
|
State string `json:"state"`
|
|
}
|
|
|
|
func (q *Queries) ListAllProviderStates(ctx context.Context) ([]ListAllProviderStatesRow, error) {
|
|
rows, err := q.db.QueryContext(ctx, listAllProviderStates)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
items := []ListAllProviderStatesRow{}
|
|
for rows.Next() {
|
|
var i ListAllProviderStatesRow
|
|
if err := rows.Scan(&i.Provider, &i.State); err != nil {
|
|
return nil, err
|
|
}
|
|
items = append(items, i)
|
|
}
|
|
if err := rows.Close(); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return nil, err
|
|
}
|
|
return items, nil
|
|
}
|
|
|
|
const listProviderStates = `-- name: ListProviderStates :many
|
|
SELECT state FROM core.provider_states
|
|
WHERE provider = $1 ORDER BY state
|
|
`
|
|
|
|
func (q *Queries) ListProviderStates(ctx context.Context, provider string) ([]string, error) {
|
|
rows, err := q.db.QueryContext(ctx, listProviderStates, provider)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
items := []string{}
|
|
for rows.Next() {
|
|
var state string
|
|
if err := rows.Scan(&state); err != nil {
|
|
return nil, err
|
|
}
|
|
items = append(items, state)
|
|
}
|
|
if err := rows.Close(); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return nil, err
|
|
}
|
|
return items, nil
|
|
}
|