ethereum

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

type Config struct {
	RPCURL             string        `yaml:"rpc_url" validate:"required"`
	WSUrl              string        `yaml:"ws_url" default:""`
	ChainID            int64         `yaml:"chain_id" validate:"required,gt=0"`
	BridgeContract     string        `yaml:"bridge_contract" validate:"required"`
	TokenContract      string        `yaml:"token_contract" default:""`
	RelayerPrivateKey  string        `yaml:"relayer_private_key" validate:"required"`
	ConfirmationBlocks int           `yaml:"confirmation_blocks" default:"12"`
	GasLimit           uint64        `yaml:"gas_limit" validate:"required,gt=0"`
	MaxGasPrice        string        `yaml:"max_gas_price" default:""`
	PollingInterval    time.Duration `yaml:"polling_interval" validate:"required,gt=0"`
	StartBlock         int64         `yaml:"start_block" default:"0"`
	LookbackBlocks     int64         `yaml:"lookback_blocks" default:"1000"`
	MaxBlockRange      uint64        `yaml:"max_block_range" default:"100" validate:"required,gt=0"`
}

type DepositEvent struct {
	Token           common.Address
	Sender          common.Address
	CantonRecipient [32]byte
	Amount          *big.Int
	Nonce           *big.Int
	BlockNumber     uint64
	TxHash          common.Hash
	LogIndex        uint
}

type Metrics struct {
	// RPCCallsTotal counts outbound Ethereum RPC operations by method name and
	// terminal status. method is a stable lowercase identifier (see the
	// method=... call sites in client.go); status is "ok" or "error".
	RPCCallsTotal *prometheus.CounterVec

	// RPCDuration is the per-method latency distribution for RPC calls. Paired
	// with RPCCallsTotal so dashboards can show p95 latency next to error rate
	// for the same operation.
	RPCDuration *prometheus.HistogramVec

	// EventPollDuration is the wall-clock duration of one deposit-event poll
	// cycle (one tick of WatchDepositEvents). Empty cycles still contribute.
	EventPollDuration prometheus.Histogram

	// EventPollFailuresTotal counts poll cycles that hit an error at a
	// specific phase. reason ∈
	//   get_latest_block – HeaderByNumber failed at the start of the cycle
	//   filter_events    – FilterDepositToCanton failed
	//   iterator         – iter.Error() reported a problem while ranging
	// A single cycle can contribute to more than one reason if multiple phases
	// fail (rare but possible).
	EventPollFailuresTotal *prometheus.CounterVec

	// EventsFetchedTotal is the running count of deposit events the poll loop
	// has consumed (one increment per iter.Next() returning true). Pair with
	// rate() to get throughput.
	EventsFetchedTotal prometheus.Counter

	// LatestBlockSeen is the most recent block number the client has observed
	// from HeaderByNumber. Stale = the Ethereum node is unreachable or behind.
	LatestBlockSeen prometheus.Gauge

	// LastScannedBlock is the highest block number the poll loop has scanned
	// for deposit events. Distance from LatestBlockSeen = backlog the poller
	// is working through.
	LastScannedBlock prometheus.Gauge
}

type WithdrawalEvent struct {
	Token        common.Address
	Recipient    common.Address
	Amount       *big.Int
	Nonce        *big.Int
	CantonTxHash [32]byte
	BlockNumber  uint64
	TxHash       common.Hash
}