// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.27.0
// source: clean.sql

package repository

import (
	"context"

	"github.com/jackc/pgx/v5/pgtype"
)

const addDocumentClean = `-- name: AddDocumentClean :one
INSERT INTO documentCleans (documentId, bucket, key, mimetype, fail) VALUES ($1, $2, $3, $4, $5) returning id
`

type AddDocumentCleanParams struct {
	Documentid pgtype.UUID       `db:"documentid"`
	Bucket     *string           `db:"bucket"`
	Key        *string           `db:"key"`
	Mimetype   NullCleanmimetype `db:"mimetype"`
	Fail       NullCleanfailtype `db:"fail"`
}

// AddDocumentClean
//
//	INSERT INTO documentCleans (documentId, bucket, key, mimetype, fail) VALUES ($1, $2, $3, $4, $5) returning id
func (q *Queries) AddDocumentClean(ctx context.Context, arg *AddDocumentCleanParams) (pgtype.UUID, error) {
	row := q.db.QueryRow(ctx, addDocumentClean,
		arg.Documentid,
		arg.Bucket,
		arg.Key,
		arg.Mimetype,
		arg.Fail,
	)
	var id pgtype.UUID
	err := row.Scan(&id)
	return id, err
}

const addDocumentCleanEntry = `-- name: AddDocumentCleanEntry :exec
INSERT INTO documentCleanEntries (cleanId, version) VALUES ($1, $2)
`

type AddDocumentCleanEntryParams struct {
	Cleanid pgtype.UUID `db:"cleanid"`
	Version int32       `db:"version"`
}

// AddDocumentCleanEntry
//
//	INSERT INTO documentCleanEntries (cleanId, version) VALUES ($1, $2)
func (q *Queries) AddDocumentCleanEntry(ctx context.Context, arg *AddDocumentCleanEntryParams) error {
	_, err := q.db.Exec(ctx, addDocumentCleanEntry, arg.Cleanid, arg.Version)
	return err
}

const getDocumentCleanEntry = `-- name: GetDocumentCleanEntry :one
SELECT id, documentId, bucket, key, version, mimetype, fail
    FROM currentCleanEntries
    WHERE documentId = $1
`

// GetDocumentCleanEntry
//
//	SELECT id, documentId, bucket, key, version, mimetype, fail
//	    FROM currentCleanEntries
//	    WHERE documentId = $1
func (q *Queries) GetDocumentCleanEntry(ctx context.Context, documentid pgtype.UUID) (*Currentcleanentry, error) {
	row := q.db.QueryRow(ctx, getDocumentCleanEntry, documentid)
	var i Currentcleanentry
	err := row.Scan(
		&i.ID,
		&i.Documentid,
		&i.Bucket,
		&i.Key,
		&i.Version,
		&i.Mimetype,
		&i.Fail,
	)
	return &i, err
}

const getMostRecentDocumentCleanEntry = `-- name: GetMostRecentDocumentCleanEntry :one
WITH cleans as (
    SELECT id, documentId, bucket, key, mimetype, fail
    FROM documentCleans dc
    WHERE documentId = $1 ORDER BY id DESC
)
SELECT
    dc.id,
    dc.documentId,
    dc.bucket,
    dc.key,
    dce.version,
    dc.mimetype,
    dc.fail
FROM cleans dc
JOIN documentCleanEntries dce ON dc.id = dce.cleanId
ORDER BY dc.id DESC, dce.id DESC
LIMIT 1
`

type GetMostRecentDocumentCleanEntryRow struct {
	ID         pgtype.UUID       `db:"id"`
	Documentid pgtype.UUID       `db:"documentid"`
	Bucket     *string           `db:"bucket"`
	Key        *string           `db:"key"`
	Version    int32             `db:"version"`
	Mimetype   NullCleanmimetype `db:"mimetype"`
	Fail       NullCleanfailtype `db:"fail"`
}

// GetMostRecentDocumentCleanEntry
//
//	WITH cleans as (
//	    SELECT id, documentId, bucket, key, mimetype, fail
//	    FROM documentCleans dc
//	    WHERE documentId = $1 ORDER BY id DESC
//	)
//	SELECT
//	    dc.id,
//	    dc.documentId,
//	    dc.bucket,
//	    dc.key,
//	    dce.version,
//	    dc.mimetype,
//	    dc.fail
//	FROM cleans dc
//	JOIN documentCleanEntries dce ON dc.id = dce.cleanId
//	ORDER BY dc.id DESC, dce.id DESC
//	LIMIT 1
func (q *Queries) GetMostRecentDocumentCleanEntry(ctx context.Context, documentid pgtype.UUID) (*GetMostRecentDocumentCleanEntryRow, error) {
	row := q.db.QueryRow(ctx, getMostRecentDocumentCleanEntry, documentid)
	var i GetMostRecentDocumentCleanEntryRow
	err := row.Scan(
		&i.ID,
		&i.Documentid,
		&i.Bucket,
		&i.Key,
		&i.Version,
		&i.Mimetype,
		&i.Fail,
	)
	return &i, err
}

const hasDocumentCleanEntry = `-- name: HasDocumentCleanEntry :one
SELECT EXISTS(
    SELECT 1 FROM currentCleanEntries WHERE documentId = $1
)
`

// HasDocumentCleanEntry
//
//	SELECT EXISTS(
//	    SELECT 1 FROM currentCleanEntries WHERE documentId = $1
//	)
func (q *Queries) HasDocumentCleanEntry(ctx context.Context, documentid pgtype.UUID) (bool, error) {
	row := q.db.QueryRow(ctx, hasDocumentCleanEntry, documentid)
	var exists bool
	err := row.Scan(&exists)
	return exists, err
}