deposits

type BlockEventEntry struct {
	// EventIndex is 2 × the finalize_block_events index (+1 for OUT rows)
	// so one event touching two watched addresses yields distinct rows
	// under UNIQUE(chain_id, block_height, event_index).
	EventIndex      uint32
	Direction       storage.LedgerDirection
	Address         string
	CounterpartySet []string
	AmountBaseUnits sdkmath.Int
	Reason          string
}

type BlockParse struct {
	ChainID       string
	Height        uint64
	BlockHash     string
	LastBlockHash string
	Time          time.Time

	Transfers        []TransferCandidate
	FeeDeductions    []FeeDeduction
	ReviewCandidates []ReviewCandidate
	BlockEvents      []BlockEventEntry
}

type CreditDecision string

type CreditGate struct {
	CreditPaused      bool // FR-051 deposit-crediting pause
	ScanWithoutCredit bool // FR-051 scan-without-credit — parks as SUSPENDED
	ChainReviewOpen   bool // FR-044 open condition closes the crediting gate
}

type FeeDeduction struct {
	TxHash         string
	PayerAddress   string
	FeeBaseUnits   sdkmath.Int
	TxCode         uint32
	FeeGranterUsed bool
	GranterAddress string
}

type RecordOutcome struct {
	LedgerAppends     int
	FeeOutflows       int
	DepositsInserted  int
	DepositsRevived   int
	Duplicates        int
	ReviewItemsOpened int
}

type RecordPolicy struct {
	ChainID string
	// MinimumDepositUsovr parks smaller validated deposits as BELOW_MINIMUM;
	// nil or zero disables parking (threshold is exchange configuration,
	// never a code constant — FR-040).
	MinimumDepositUsovr sdkmath.Int
}

type ReviewCandidate struct {
	TxHash       string
	MessageIndex uint32
	EventIndex   uint32
	// OpIndex is ReviewOpIndexBase + 2×EventIndex (+1 for OUT rows).
	OpIndex         uint32
	Direction       storage.LedgerDirection
	Address         string
	CounterpartySet []string
	AmountBaseUnits sdkmath.Int
	TxCode          uint32
	Reason          string
}

type Scanner struct {
	// contains filtered or unexported fields
}

type ScannerConfig struct {
	ChainID string
	// Confirmations defaults to DefaultConfirmations when zero.
	Confirmations uint64
	// PollInterval defaults to DefaultPollInterval when zero.
	PollInterval time.Duration
	// StartHeight, when non-zero, is the explicit rescan base applied on the
	// first cycle; zero resumes from the durable checkpoint (FR-026).
	StartHeight uint64
	// MinimumDepositUsovr parks smaller deposits BELOW_MINIMUM; nil/zero
	// disables parking.
	MinimumDepositUsovr sdkmath.Int
	// DisableHashChainVerification turns off the R6 last_block_id.hash chain
	// check (on by default; disable only in tests).
	DisableHashChainVerification bool
	// MemoRecognizer recognizes omnibus memos (FR-016); nil ⇒ any non-empty
	// memo is recognized.
	MemoRecognizer func(memo string) bool
	// PendingBatchLimit bounds each per-status pending sweep; default 500.
	PendingBatchLimit int

	Logger  *slog.Logger
	Metrics *metrics.Set
	// Now is the clock; nil ⇒ time.Now (tests inject).
	Now func() time.Time
}

type TransferCandidate struct {
	TxHash       string
	MessageIndex uint32
	// CoinIndex is the deposit-identity output-coin index (FR-024):
	// outputs' coins flattened in wire order, non-usovr coins included in
	// the numbering so indexes are stable regardless of filtering.
	CoinIndex uint32
	// OpIndex is the ledger row index: IN rows reuse CoinIndex; sender-side
	// OUT rows continue the numbering after all output coins.
	OpIndex   uint32
	Direction storage.LedgerDirection
	// Address is the watched address this row is about.
	Address string
	// CounterpartySet is the full opposite-side address set — MsgMultiSend
	// inputs have no deterministic input→output attribution.
	CounterpartySet []string
	// SenderAddress is the single unambiguous input for IN rows; nil when
	// the input set is ambiguous.
	SenderAddress   *string
	Denom           string
	AmountBaseUnits sdkmath.Int
	Memo            string
	TxCode          uint32
	TxLog           string
	Classification  storage.Classification
	// ReviewReason is non-empty when the movement must route to review
	// (omnibus memo policy, mixed watched/external input set).
	ReviewReason string
}

type WatchSet struct {
	// contains filtered or unexported fields
}