reconcile

type BusinessSection struct {
	ChainID     string
	GeneratedAt time.Time

	// LedgerExternalDepositTotal: Σ successful EXTERNAL_DEPOSIT IN rows
	// across watched addresses — every real external inflow, credited or not.
	LedgerExternalDepositTotal sdkmath.Int
	// CreditedDepositTotal: Σ deposit records that reached CREDITED
	// (including SWEEP_PENDING / SWEPT afterwards).
	CreditedDepositTotal sdkmath.Int
	// UncreditedExternalTotal = ledger − credited. Below-minimum, review-
	// parked, awaiting-confirmation and suspended inflows live here; it is
	// never negative in a healthy system.
	UncreditedExternalTotal sdkmath.Int

	// LedgerWithdrawalOutflowTotal: Σ successful WITHDRAWAL OUT rows.
	LedgerWithdrawalOutflowTotal sdkmath.Int
	// WorkflowWithdrawalTotal: Σ CONFIRMED withdrawal record amounts.
	WorkflowWithdrawalTotal sdkmath.Int
	// InFlightWithdrawalTotal: Σ BROADCAST/INCLUDED amounts (may already be
	// in the ledger ahead of workflow confirmation, or vice versa).
	InFlightWithdrawalTotal sdkmath.Int

	// LedgerSweepInflowTotal: Σ successful SWEEP IN rows (counted on the
	// receiving side only, so one sweep is one amount).
	LedgerSweepInflowTotal sdkmath.Int
	// WorkflowSweepTotal: Σ CONFIRMED sweep job amounts.
	WorkflowSweepTotal sdkmath.Int

	// Findings are human-readable inconsistencies. An impossible state
	// (workflow total exceeding what the ledger can support) also increments
	// the discrepancy counter.
	Findings []string
}

type ChainView interface {
	Balance(ctx context.Context, addr, denom string) (sdkmath.Int, error)
	Tx(ctx context.Context, hash string) (*client.TxInfo, error)
	LatestBlock(ctx context.Context) (*client.Block, error)
}

type Comparer interface {
	Compare(ctx context.Context, req client.CompareRequest) (*client.CompareResult, error)
}

type Config struct {
	ChainID string
}

type DisagreementConfig struct {
	ChainID string
	// Interval between checks; DefaultDisagreementInterval when zero.
	Interval time.Duration
	// HeightTolerance is the allowed latest-height gap (blocks);
	// DefaultHeightTolerance when zero.
	HeightTolerance int64
	// SequenceAddress optionally adds an account-sequence check (hot wallet).
	SequenceAddress string
	// BalanceAddress optionally adds a balance check (hot wallet).
	BalanceAddress string
	// CompareHashAtCheckpoint adds a block-hash check at the scanner
	// checkpoint height (both nodes must agree on scanned history).
	CompareHashAtCheckpoint bool
}

type HotWalletReport struct {
	ChainID string
	Address string

	// LedgerExpected is the §8 ledger formula result.
	LedgerExpected sdkmath.Int
	// Observed is the live on-chain balance.
	Observed sdkmath.Int
	// Difference is Observed − LedgerExpected.
	Difference sdkmath.Int

	// PendingSignedOutflow: withdrawals SIGNED but not yet broadcast from
	// this wallet, plus signed-not-broadcast sweeps sourced here
	// (amount + known fee). Not yet on chain — never explains drift, listed
	// for the operator's forward view.
	PendingSignedOutflow sdkmath.Int
	// BroadcastUnconfirmedOutflow: withdrawals BROADCAST/INCLUDED and sweeps
	// BROADCAST sourced from this wallet (amount + known fee). These may
	// already be on chain ahead of the scanner — negative drift up to this
	// value is explained.
	BroadcastUnconfirmedOutflow sdkmath.Int
	// BroadcastUnconfirmedInflow: sweeps BROADCAST targeting this wallet.
	// Positive drift up to this value is explained.
	BroadcastUnconfirmedInflow sdkmath.Int

	// ConfirmedWithdrawalOutflow / ConfirmedSweepInflow are the ledger's
	// settled WITHDRAWAL (OUT) and SWEEP (IN) totals for this wallet.
	ConfirmedWithdrawalOutflow sdkmath.Int
	ConfirmedSweepInflow       sdkmath.Int

	// Explained is true when Difference is zero or within the in-flight
	// window: [−BroadcastUnconfirmedOutflow, +BroadcastUnconfirmedInflow].
	Explained   bool
	GeneratedAt time.Time
}

type LedgerPosition struct {
	// Expected is Σ inflows − Σ outflows − Σ fee deductions.
	Expected sdkmath.Int
	// EarliestHeight is the lowest block height among the address's
	// counted ledger rows (0 when the address has no ledger activity).
	EarliestHeight uint64
	// LatestHeight is the highest counted block height.
	LatestHeight uint64
	// RelatedTxHashes are the distinct tx hashes touched (newest last,
	// capped at maxRelatedTxHashes).
	RelatedTxHashes []string
	// Rows is the number of counted ledger rows (fee outflows excluded).
	Rows int
}

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

type MonitorOption func(*Monitor)

type Option func(*Reconciler)

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

type Schedule struct {
	NearRealTimeInterval time.Duration // default 1m
	WalletInterval       time.Duration // default 1h (adapter.yaml reconciler.wallet_interval)
	FullAddressInterval  time.Duration // default 24h (reconciler.full_address_interval)
}