database

type AuthUser struct {
	Aud          *string `db:"aud"`
	Sub          string  `db:"sub"`
	LastLoggedIn uint64  `db:"last_logged_in"`
}

type BlindSigsCountByKeyset struct {
	KeysetId    string `json:"keyset_id"`
	TotalAmount uint64 `json:"total_amount"`
	Count       uint64 `json:"count"`
}

type MintDB interface {
	GetTx(ctx context.Context) (pgx.Tx, error)
	Commit(ctx context.Context, tx pgx.Tx) error
	Rollback(ctx context.Context, tx pgx.Tx) error
	SubTx(ctx context.Context, tx pgx.Tx) (pgx.Tx, error)

	/// Calls for the Functioning of the mint
	GetAllSeeds() ([]cashu.Seed, error)
	GetSeedsByUnit(tx pgx.Tx, unit cashu.Unit) ([]cashu.Seed, error)
	SaveNewSeed(tx pgx.Tx, seed cashu.Seed) error
	SaveNewSeeds(seeds []cashu.Seed) error
	// This should be used to only update the Active Status of seed on the db
	UpdateSeedsActiveStatus(tx pgx.Tx, seeds []cashu.Seed) error

	SaveMintRequest(tx pgx.Tx, request cashu.MintRequestDB) error
	ChangeMintRequestState(tx pgx.Tx, quote string, state cashu.ACTION_STATE, minted bool) error
	GetMintRequestById(tx pgx.Tx, quote string) (cashu.MintRequestDB, error)
	GetMintRequestByRequest(tx pgx.Tx, request string) (cashu.MintRequestDB, error)

	GetMeltRequestById(tx pgx.Tx, quote string) (cashu.MeltRequestDB, error)
	SaveMeltRequest(tx pgx.Tx, request cashu.MeltRequestDB) error
	ChangeMeltRequestState(tx pgx.Tx, quote string, state cashu.ACTION_STATE, melted bool, fee_paid uint64) error
	AddPreimageMeltRequest(tx pgx.Tx, quote string, preimage string) error
	ChangeCheckingId(tx pgx.Tx, quote string, checking_id string) error

	GetMeltQuotesByState(state cashu.ACTION_STATE) ([]cashu.MeltRequestDB, error)

	SaveProof(tx pgx.Tx, proofs []cashu.Proof) error
	GetProofsFromSecret(tx pgx.Tx, SecretList []string) (cashu.Proofs, error)
	GetProofsFromSecretCurve(tx pgx.Tx, Ys []cashu.WrappedPublicKey) (cashu.Proofs, error)
	GetProofsFromQuote(tx pgx.Tx, quote string) (cashu.Proofs, error)
	SetProofsState(tx pgx.Tx, proofs cashu.Proofs, state cashu.ProofState) error
	DeleteProofs(tx pgx.Tx, proofs cashu.Proofs) error

	GetRestoreSigsFromBlindedMessages(tx pgx.Tx, B_ []cashu.WrappedPublicKey) ([]cashu.RecoverSigDB, error)
	SaveRestoreSigs(tx pgx.Tx, recover_sigs []cashu.RecoverSigDB) error

	// GetProofsTimeSeries returns proofs aggregated by time buckets for charting
	// since: lower bound unix timestamp (inclusive)
	// bucketMinutes: size of each time bucket in minutes
	GetProofsTimeSeries(since int64, bucketMinutes int) ([]ProofTimeSeriesPoint, error)
	// GetBlindSigsTimeSeries returns blind signatures aggregated by time buckets for charting
	// since: lower bound unix timestamp (inclusive)
	// bucketMinutes: size of each time bucket in minutes
	GetBlindSigsTimeSeries(since int64, bucketMinutes int) ([]ProofTimeSeriesPoint, error)

	// GetProofsMintReserve(since time.Time, until *time.Time) (EcashInventory, error)
	// GetBlindSigsMintReserve(since time.Time, until *time.Time) (EcashInventory, error)
	GetConfig() (utils.Config, error)
	SetConfig(config utils.Config) error
	UpdateConfig(config utils.Config) error

	SaveMeltChange(tx pgx.Tx, change []cashu.BlindedMessage, quote string) error
	GetMeltChangeByQuote(tx pgx.Tx, quote string) ([]cashu.MeltChange, error)
	DeleteChangeByQuote(tx pgx.Tx, quote string) error

	GetMintMeltBalanceByTime(time int64) (MintMeltBalance, error)
	// GetProofsCountByKeyset returns the total amount and count of proofs grouped by keyset ID
	// since: lower bound time (inclusive)
	GetProofsCountByKeyset(since time.Time) (map[string]ProofsCountByKeyset, error)
	// GetBlindSigsCountByKeyset returns the total amount and count of blind signatures grouped by keyset ID
	// since: lower bound time (inclusive)
	GetBlindSigsCountByKeyset(since time.Time) (map[string]BlindSigsCountByKeyset, error)

	SaveNostrAuth(auth NostrLoginAuth) error
	UpdateNostrAuthActivation(tx pgx.Tx, nonce string, activated bool) error
	GetNostrAuth(tx pgx.Tx, nonce string) (NostrLoginAuth, error)

	// liquidity swaps
	AddLiquiditySwap(tx pgx.Tx, swap utils.LiquiditySwap) error
	GetLiquiditySwapById(tx pgx.Tx, id string) (utils.LiquiditySwap, error)
	ChangeLiquiditySwapState(tx pgx.Tx, id string, state utils.SwapState) error
	GetAllLiquiditySwaps() ([]utils.LiquiditySwap, error)
	GetLiquiditySwapsByStates(tx pgx.Tx, states []utils.SwapState) ([]string, error)

	// Mint Auth
	GetAuthUser(tx pgx.Tx, sub string) (AuthUser, error)
	MakeAuthUser(tx pgx.Tx, auth AuthUser) error
	UpdateLastLoggedIn(tx pgx.Tx, sub string, lastLoggedIn uint64) error

	GetMintRequestsByTimeAndId(ctx context.Context, since time.Time, id *string) ([]cashu.MintRequestDB, error)
	GetMeltRequestsByTimeAndId(ctx context.Context, since time.Time, id *string) ([]cashu.MeltRequestDB, error)
}

type MintMeltBalance struct {
	Mint []cashu.MintRequestDB
	Melt []cashu.MeltRequestDB
}

type NostrLoginAuth struct {
	Nonce     string
	Activated bool
	Expiry    int
}

type ProofTimeSeriesPoint struct {
	Timestamp   int64  `json:"timestamp"`   // Unix timestamp (seconds) for the bucket start
	TotalAmount uint64 `json:"totalAmount"` // Sum of proof amounts in this bucket
	Count       uint64 `json:"count"`       // Number of proofs in this bucket
}

type ProofsCountByKeyset struct {
	KeysetId    string `json:"keyset_id"`
	TotalAmount uint64 `json:"total_amount"`
	Count       uint64 `json:"count"`
}