// 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
}