bridgesync

type Bridge struct {
	BlockNum           uint64         `meddler:"block_num" json:"block_num"`
	BlockPos           uint64         `meddler:"block_pos" json:"block_pos"`
	BlockTimestamp     uint64         `meddler:"block_timestamp" json:"block_timestamp"`
	LeafType           uint8          `meddler:"leaf_type" json:"leaf_type"`
	OriginNetwork      uint32         `meddler:"origin_network" json:"origin_network"`
	OriginAddress      common.Address `meddler:"origin_address" json:"origin_address"`
	DestinationNetwork uint32         `meddler:"destination_network" json:"destination_network"`
	DestinationAddress common.Address `meddler:"destination_address" json:"destination_address"`
	Amount             *big.Int       `meddler:"amount,bigint" json:"amount"`
	Metadata           []byte         `meddler:"metadata" json:"metadata"`
	DepositCount       uint32         `meddler:"deposit_count" json:"deposit_count"`
	TxHash             common.Hash    `meddler:"tx_hash,hash" json:"tx_hash"`
	FromAddress        common.Address `meddler:"from_address,address" json:"from_address"`
	Calldata           []byte         `meddler:"calldata" json:"calldata"`
}

type BridgeResponse struct {
	BridgeHash common.Hash `json:"bridge_hash"`
	Bridge
}

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

type Claim struct {
	BlockNum            uint64         `meddler:"block_num"`
	BlockPos            uint64         `meddler:"block_pos"`
	GlobalIndex         *big.Int       `meddler:"global_index,bigint"`
	OriginNetwork       uint32         `meddler:"origin_network"`
	OriginAddress       common.Address `meddler:"origin_address"`
	DestinationAddress  common.Address `meddler:"destination_address"`
	Amount              *big.Int       `meddler:"amount,bigint"`
	ProofLocalExitRoot  types.Proof    `meddler:"proof_local_exit_root,merkleproof"`
	ProofRollupExitRoot types.Proof    `meddler:"proof_rollup_exit_root,merkleproof"`
	MainnetExitRoot     common.Hash    `meddler:"mainnet_exit_root,hash"`
	RollupExitRoot      common.Hash    `meddler:"rollup_exit_root,hash"`
	GlobalExitRoot      common.Hash    `meddler:"global_exit_root,hash"`
	DestinationNetwork  uint32         `meddler:"destination_network"`
	Metadata            []byte         `meddler:"metadata"`
	IsMessage           bool           `meddler:"is_message"`
	BlockTimestamp      uint64         `meddler:"block_timestamp"`
	TxHash              common.Hash    `meddler:"tx_hash,hash"`
	FromAddress         common.Address `meddler:"from_address,address"`
}

type ClaimResponse struct {
	BlockNum           uint64         `json:"block_num"`
	BlockTimestamp     uint64         `json:"block_timestamp"`
	TxHash             common.Hash    `json:"tx_hash"`
	GlobalIndex        *big.Int       `json:"global_index"`
	OriginAddress      common.Address `json:"origin_address"`
	OriginNetwork      uint32         `json:"origin_network"`
	DestinationAddress common.Address `json:"destination_address"`
	DestinationNetwork uint32         `json:"destination_network"`
	Amount             *big.Int       `json:"amount"`
	FromAddress        common.Address `json:"from_address"`
}

type Config struct {
	// DBPath path of the DB
	DBPath string `mapstructure:"DBPath"`
	// BlockFinality indicates the status of the blocks that will be queried in order to sync
	BlockFinality string `` //nolint:lll
	/* 134-byte string literal not displayed */
	// InitialBlockNum is the first block that will be queried when starting the synchronization from scratch.
	// It should be a number equal or bellow the creation of the bridge contract
	InitialBlockNum uint64 `mapstructure:"InitialBlockNum"`
	// BridgeAddr is the address of the bridge smart contract
	BridgeAddr common.Address `mapstructure:"BridgeAddr"`
	// SyncBlockChunkSize is the amount of blocks that will be queried to the client on each request
	SyncBlockChunkSize uint64 `mapstructure:"SyncBlockChunkSize"`
	// RetryAfterErrorPeriod is the time that will be waited when an unexpected error happens before retry
	RetryAfterErrorPeriod types.Duration `mapstructure:"RetryAfterErrorPeriod"`
	// MaxRetryAttemptsAfterError is the maximum number of consecutive attempts that will happen before panicing.
	// Any number smaller than zero will be considered as unlimited retries
	MaxRetryAttemptsAfterError int `mapstructure:"MaxRetryAttemptsAfterError"`
	// WaitForNewBlocksPeriod time that will be waited when the synchronizer has reached the latest block
	WaitForNewBlocksPeriod types.Duration `mapstructure:"WaitForNewBlocksPeriod"`
}

type Event struct {
	Pos          uint64
	Bridge       *Bridge
	Claim        *Claim
	TokenMapping *TokenMapping
}

type LastReorg struct {
	DetectedAt int64  `json:"detected_at"`
	FromBlock  uint64 `json:"from_block"`
	ToBlock    uint64 `json:"to_block"`
}

type ReorgDetector interface {
	sync.ReorgDetector
	GetLastReorgEvent(ctx context.Context) (reorgdetector.ReorgEvent, error)
}

type TokenMapping struct {
	BlockNum            uint64         `meddler:"block_num" json:"block_num"`
	BlockPos            uint64         `meddler:"block_pos" json:"block_pos"`
	BlockTimestamp      uint64         `meddler:"block_timestamp" json:"block_timestamp"`
	TxHash              common.Hash    `meddler:"tx_hash,hash" json:"tx_hash"`
	OriginNetwork       uint32         `meddler:"origin_network" json:"origin_network"`
	OriginTokenAddress  common.Address `meddler:"origin_token_address,address" json:"origin_token_address"`
	WrappedTokenAddress common.Address `meddler:"wrapped_token_address,address" json:"wrapped_token_address"`
	Metadata            []byte         `meddler:"metadata" json:"metadata"`
	Calldata            []byte         `meddler:"calldata" json:"calldata"`
}