common

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

type ChainClient interface {
	// ChainID returns the CAIP-2 format chain identifier
	ChainID() string

	// Start initializes and starts the chain client
	Start(ctx context.Context) error

	// Stop gracefully shuts down the chain client
	Stop() error

	// IsHealthy checks if the chain client is operational
	IsHealthy() bool

	// GetConfig returns the chain configuration
	GetConfig() *uregistrytypes.ChainConfig

	// SetVoteHandler sets the vote handler for confirmed transactions
	SetVoteHandler(handler VoteHandler)

	// GetGasPrice fetches the current gas price from the chain
	GetGasPrice(ctx context.Context) (*big.Int, error)

	// Configuration access methods
	GetRPCURLs() []string
	GetCleanupSettings() (cleanupInterval, retentionPeriod int)
	GetGasOracleFetchInterval() time.Duration
	GetChainSpecificConfig() *config.ChainSpecificConfig

	// Gateway operations (optional - clients can implement GatewayOperations)
	GatewayOperations
}

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

type GasPrice struct {
	ChainID   string   `json:"chain_id"`
	Price     *big.Int `json:"price"`
	Unit      string   `json:"unit"` // "wei" for EVM, "lamports/cu" for Solana
	Timestamp int64    `json:"timestamp"`
}

type GasPriceFetcher interface {
	// GetGasPrice fetches the current gas price from the chain
	// For EVM chains, returns the price in Wei
	// For Solana, returns the price in lamports per compute unit
	GetGasPrice(ctx context.Context) (*big.Int, error)
}

type GatewayEvent struct {
	ChainID          string
	TxHash           string
	BlockNumber      uint64
	EventID          string
	Payload          []byte
	Confirmations    uint64
	ConfirmationType string // "STANDARD" or "FAST" - from gateway method config
}

type GatewayOperations interface {
	// GetLatestBlock returns the latest block/slot number
	GetLatestBlock(ctx context.Context) (uint64, error)

	// WatchGatewayEvents starts watching for gateway events from a specific block
	WatchGatewayEvents(ctx context.Context, fromBlock uint64) (<-chan *GatewayEvent, error)

	// GetTransactionConfirmations returns the number of confirmations for a transaction
	GetTransactionConfirmations(ctx context.Context, txHash string) (uint64, error)

	// IsConfirmed checks if a transaction has enough confirmations
	IsConfirmed(ctx context.Context, txHash string) (bool, error)
}

type RetryConfig struct {
	MaxRetries     int              // Maximum number of retry attempts
	InitialDelay   time.Duration    // Initial delay between retries
	MaxDelay       time.Duration    // Maximum delay between retries
	BackoffFactor  float64          // Exponential backoff factor (e.g., 2.0)
	RetryableError func(error) bool // Function to determine if error is retryable
}

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

type UniversalTx struct {
	SourceChain         string                   `json:"sourceChain"`
	LogIndex            uint                     `json:"logIndex"`
	Sender              string                   `json:"sender"`
	Recipient           string                   `json:"recipient"`
	Token               string                   `json:"bridgeToken"`
	Amount              string                   `json:"bridgeAmount"` // uint256 as decimal string
	Payload             uetypes.UniversalPayload `json:"universalPayload"`
	VerificationData    string                   `json:"verificationData"`
	RevertFundRecipient string                   `json:"revertFundRecipient,omitempty"`
	RevertMsg           string                   `json:"revertMsg,omitempty"` // hex-encoded bytes (0x…)
	TxType              uint                     `json:"txType"`              // enum backing uint as decimal string
}

type VoteHandler interface {
	VoteAndConfirm(ctx context.Context, tx *store.ChainTransaction) error
}