// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.29.0
// source: queries.sql

package db

import (
	"context"
)

const addStaticRecord = `-- name: AddStaticRecord :exec
INSERT OR REPLACE INTO static_records (record_id, record_name)
VALUES (?, ?)
`

type AddStaticRecordParams struct {
	RecordID   string `json:"record_id"`
	RecordName string `json:"record_name"`
}

func (q *Queries) AddStaticRecord(ctx context.Context, arg AddStaticRecordParams) error {
	_, err := q.db.ExecContext(ctx, addStaticRecord, arg.RecordID, arg.RecordName)
	return err
}

const deleteAllConfig = `-- name: DeleteAllConfig :exec
DELETE FROM config
`

func (q *Queries) DeleteAllConfig(ctx context.Context) error {
	_, err := q.db.ExecContext(ctx, deleteAllConfig)
	return err
}

const getConfig = `-- name: GetConfig :one
SELECT api_token, zone_id, domain, update_period FROM config LIMIT 1
`

// db/queries.sql
func (q *Queries) GetConfig(ctx context.Context) (Config, error) {
	row := q.db.QueryRowContext(ctx, getConfig)
	var i Config
	err := row.Scan(
		&i.ApiToken,
		&i.ZoneID,
		&i.Domain,
		&i.UpdatePeriod,
	)
	return i, err
}

const getStaticRecords = `-- name: GetStaticRecords :many
SELECT record_id, record_name FROM static_records
`

type GetStaticRecordsRow struct {
	RecordID   string `json:"record_id"`
	RecordName string `json:"record_name"`
}

func (q *Queries) GetStaticRecords(ctx context.Context) ([]GetStaticRecordsRow, error) {
	rows, err := q.db.QueryContext(ctx, getStaticRecords)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	var items []GetStaticRecordsRow
	for rows.Next() {
		var i GetStaticRecordsRow
		if err := rows.Scan(&i.RecordID, &i.RecordName); 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 initSchema = `-- name: InitSchema :exec
CREATE TABLE IF NOT EXISTS config (
    api_token TEXT NOT NULL DEFAULT '',
    zone_id TEXT NOT NULL DEFAULT '',
    domain TEXT NOT NULL DEFAULT 'mz.uy',
    update_period TEXT NOT NULL DEFAULT '0 */6 * * *'
)
`

func (q *Queries) InitSchema(ctx context.Context) error {
	_, err := q.db.ExecContext(ctx, initSchema)
	return err
}

const insertConfig = `-- name: InsertConfig :exec
INSERT INTO config (api_token, zone_id, domain, update_period)
VALUES (?, ?, ?, ?)
`

type InsertConfigParams struct {
	ApiToken     string `json:"api_token"`
	ZoneID       string `json:"zone_id"`
	Domain       string `json:"domain"`
	UpdatePeriod string `json:"update_period"`
}

func (q *Queries) InsertConfig(ctx context.Context, arg InsertConfigParams) error {
	_, err := q.db.ExecContext(ctx, insertConfig,
		arg.ApiToken,
		arg.ZoneID,
		arg.Domain,
		arg.UpdatePeriod,
	)
	return err
}

const isStaticRecord = `-- name: IsStaticRecord :one
SELECT CAST(EXISTS(SELECT 1 FROM static_records WHERE record_id = ?) AS BOOLEAN) AS is_static
`

func (q *Queries) IsStaticRecord(ctx context.Context, recordID string) (bool, error) {
	row := q.db.QueryRowContext(ctx, isStaticRecord, recordID)
	var is_static bool
	err := row.Scan(&is_static)
	return is_static, err
}

const removeStaticRecord = `-- name: RemoveStaticRecord :exec
DELETE FROM static_records WHERE record_id = ?
`

func (q *Queries) RemoveStaticRecord(ctx context.Context, recordID string) error {
	_, err := q.db.ExecContext(ctx, removeStaticRecord, recordID)
	return err
}

const upsertConfig = `-- name: UpsertConfig :exec
INSERT INTO config (api_token, zone_id, domain, update_period)
VALUES (?, ?, ?, ?)
ON CONFLICT DO UPDATE SET
    api_token = excluded.api_token,
    zone_id = excluded.zone_id,
    domain = excluded.domain,
    update_period = excluded.update_period
`

type UpsertConfigParams struct {
	ApiToken     string `json:"api_token"`
	ZoneID       string `json:"zone_id"`
	Domain       string `json:"domain"`
	UpdatePeriod string `json:"update_period"`
}

func (q *Queries) UpsertConfig(ctx context.Context, arg UpsertConfigParams) error {
	_, err := q.db.ExecContext(ctx, upsertConfig,
		arg.ApiToken,
		arg.ZoneID,
		arg.Domain,
		arg.UpdatePeriod,
	)
	return err
}