// Code generated by BobGen psql v0.41.1. DO NOT EDIT.
// This file is meant to be re-generated in place and/or deleted at any time.

package sql

import (
	"context"
	_ "embed"
	"io"
	"iter"
	"time"

	"github.com/aarondl/opt/null"
	"github.com/stephenafamo/bob"
	"github.com/stephenafamo/bob/dialect/psql"
	"github.com/stephenafamo/bob/dialect/psql/dialect"
	"github.com/stephenafamo/bob/orm"
	"github.com/stephenafamo/scan"
)

//go:embed oauth_by_user_id.bob.sql
var formattedQueries_oauth_by_user_id string

var oauthTokenByUserIdSQL = formattedQueries_oauth_by_user_id[156:694]

type OauthTokenByUserIdQuery = orm.ModQuery[*dialect.SelectQuery, oauthTokenByUserId, OauthTokenByUserIdRow, []OauthTokenByUserIdRow, oauthTokenByUserIdTransformer]

func OauthTokenByUserId(UserID int32) *OauthTokenByUserIdQuery {
	var expressionTypArgs oauthTokenByUserId

	expressionTypArgs.UserID = psql.Arg(UserID)

	return &OauthTokenByUserIdQuery{
		Query: orm.Query[oauthTokenByUserId, OauthTokenByUserIdRow, []OauthTokenByUserIdRow, oauthTokenByUserIdTransformer]{
			ExecQuery: orm.ExecQuery[oauthTokenByUserId]{
				BaseQuery: bob.BaseQuery[oauthTokenByUserId]{
					Expression: expressionTypArgs,
					Dialect:    dialect.Dialect,
					QueryType:  bob.QueryTypeSelect,
				},
			},
			Scanner: func(context.Context, []string) (func(*scan.Row) (any, error), func(any) (OauthTokenByUserIdRow, error)) {
				return func(row *scan.Row) (any, error) {
						var t OauthTokenByUserIdRow
						row.ScheduleScanByIndex(0, &t.ID)
						row.ScheduleScanByIndex(1, &t.AccessToken)
						row.ScheduleScanByIndex(2, &t.AccessTokenExpires)
						row.ScheduleScanByIndex(3, &t.RefreshToken)
						row.ScheduleScanByIndex(4, &t.Username)
						row.ScheduleScanByIndex(5, &t.UserID)
						row.ScheduleScanByIndex(6, &t.ArcgisID)
						row.ScheduleScanByIndex(7, &t.ArcgisLicenseTypeID)
						row.ScheduleScanByIndex(8, &t.RefreshTokenExpires)
						row.ScheduleScanByIndex(9, &t.InvalidatedAt)
						return &t, nil
					}, func(v any) (OauthTokenByUserIdRow, error) {
						return *(v.(*OauthTokenByUserIdRow)), nil
					}
			},
		},
		Mod: bob.ModFunc[*dialect.SelectQuery](func(q *dialect.SelectQuery) {
			q.AppendSelect(expressionTypArgs.subExpr(7, 501))
			q.SetTable(expressionTypArgs.subExpr(507, 518))
			q.AppendWhere(expressionTypArgs.subExpr(526, 538))
		}),
	}
}

type OauthTokenByUserIdRow = struct {
	ID                  int32               `db:"id"`
	AccessToken         string              `db:"access_token"`
	AccessTokenExpires  time.Time           `db:"access_token_expires"`
	RefreshToken        string              `db:"refresh_token"`
	Username            string              `db:"username"`
	UserID              int32               `db:"user_id"`
	ArcgisID            null.Val[string]    `db:"arcgis_id"`
	ArcgisLicenseTypeID null.Val[string]    `db:"arcgis_license_type_id"`
	RefreshTokenExpires time.Time           `db:"refresh_token_expires"`
	InvalidatedAt       null.Val[time.Time] `db:"invalidated_at"`
}

type oauthTokenByUserIdTransformer = bob.SliceTransformer[OauthTokenByUserIdRow, []OauthTokenByUserIdRow]

type oauthTokenByUserId struct {
	UserID bob.Expression
}

func (o oauthTokenByUserId) args() iter.Seq[orm.ArgWithPosition] {
	return func(yield func(arg orm.ArgWithPosition) bool) {
		if !yield(orm.ArgWithPosition{
			Name:       "userID",
			Start:      536,
			Stop:       538,
			Expression: o.UserID,
		}) {
			return
		}
	}
}

func (o oauthTokenByUserId) raw(from, to int) string {
	return oauthTokenByUserIdSQL[from:to]
}

func (o oauthTokenByUserId) subExpr(from, to int) bob.Expression {
	return orm.ArgsToExpression(oauthTokenByUserIdSQL, from, to, o.args())
}

func (o oauthTokenByUserId) WriteSQL(ctx context.Context, w io.Writer, d bob.Dialect, start int) ([]any, error) {
	return o.subExpr(0, len(oauthTokenByUserIdSQL)).WriteSQL(ctx, w, d, start)
}