bridgesync

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

type BackwardLET struct {
	BlockNum             uint64      `meddler:"block_num"`
	BlockPos             uint64      `meddler:"block_pos"`
	PreviousDepositCount *big.Int    `meddler:"previous_deposit_count,bigint"`
	PreviousRoot         common.Hash `meddler:"previous_root,hash"`
	NewDepositCount      *big.Int    `meddler:"new_deposit_count,bigint"`
	NewRoot              common.Hash `meddler:"new_root,hash"`
}

type Bridge struct {
	BlockNum           uint64          `meddler:"block_num"`
	BlockPos           uint64          `meddler:"block_pos"`
	FromAddress        *common.Address `meddler:"from_address,address"`
	TxHash             common.Hash     `meddler:"tx_hash,hash"`
	BlockTimestamp     uint64          `meddler:"block_timestamp"`
	LeafType           uint8           `meddler:"leaf_type"`
	OriginNetwork      uint32          `meddler:"origin_network"`
	OriginAddress      common.Address  `meddler:"origin_address"`
	DestinationNetwork uint32          `meddler:"destination_network"`
	DestinationAddress common.Address  `meddler:"destination_address"`
	Amount             *big.Int        `meddler:"amount,bigint"`
	Metadata           []byte          `meddler:"metadata"`
	DepositCount       uint32          `meddler:"deposit_count"`
	TxnSender          common.Address  `meddler:"txn_sender,address"`
	Source             BridgeSource    `meddler:"source"`
	ToAddress          common.Address  `meddler:"to_address,address"`
	// BlockHash is the hash of the block BlockNum, as stored in the block table. It is not a column of
	// the bridge tables: the read queries that serve it (GetBridgesPaged, GetBridgeByDepositCount and
	// GetBridgesByContent) join it from the block table in the same statement that reads the row, so it
	// is the hash of the block the row belonged to when it was read. Zero if that block has no hash, or
	// when the bridge was read by any other query.
	BlockHash common.Hash `meddler:"-"`
}

type BridgeDeployment byte

type BridgeSource string

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

type BridgeSyncRuntimeData struct {
	// This fields are coming from legacy sync.RuntimeData
	ChainID   uint64
	Addresses []common.Address
	// DBVersion tracks the database schema version for compatibility validation
	DBVersion *int
	// SyncFromInBridges tracks if FromAddress extraction was enabled for this database
	// By default is true
	SyncFromInBridges *bool
}

type BridgeSyncerID int

type Call struct {
	Type  string            `json:"type"`
	From  common.Address    `json:"from"`
	To    common.Address    `json:"to"`
	Value *rpctypes.ArgBig  `json:"value"`
	Err   *string           `json:"error"`
	Input rpctypes.ArgBytes `json:"input"`
	Calls []Call            `json:"calls"`
}

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 aggkittypes.BlockNumberFinality `` //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"`
	// RequireStorageContentCompatibility is true it's mandatory that data stored in the database
	// is compatible with the running environment
	RequireStorageContentCompatibility bool `mapstructure:"RequireStorageContentCompatibility"`
	// DBQueryTimeout is the timeout for database operations (queries, transactions)
	// This is separate from HTTP timeouts to allow database operations more time when needed
	DBQueryTimeout types.Duration `mapstructure:"DBQueryTimeout"`
	// SyncFromInBridges controls whether to extract FromAddress for bridge Asset events.
	// Possible values:
	//   - "true": always extracts FromAddress using debug_traceTransaction (requires archive node)
	//   - "false": never extracts FromAddress (no archive node needed)
	//   - "auto": automatically decides based on whether BRIDGE component is active
	// Note: TxnSender and ToAddress are always extracted via standard eth_getTransactionByHash.
	// Default: "auto"
	// SyncFromInBridges.Resolved is set programmatically after resolution; not read from config.
	SyncFromInBridges types.TrueFalseAutoMode `jsonschema:"enum=true, enum=false, enum=auto" mapstructure:"SyncFromInBridges"` //nolint:lll
}

type Event struct {
	Bridge *Bridge

	TokenMapping         *TokenMapping
	LegacyTokenMigration *LegacyTokenMigration
	RemoveLegacyToken    *RemoveLegacyToken
	BackwardLET          *BackwardLET
	ForwardLET           *ForwardLET
}

type ForwardLET struct {
	BlockNum             uint64      `meddler:"block_num"`
	BlockPos             uint64      `meddler:"block_pos"`
	BlockTimestamp       uint64      `meddler:"block_timestamp"`
	TxnHash              common.Hash `meddler:"tx_hash,hash"`
	PreviousDepositCount *big.Int    `meddler:"previous_deposit_count,bigint"`
	PreviousRoot         common.Hash `meddler:"previous_root,hash"`
	NewDepositCount      *big.Int    `meddler:"new_deposit_count,bigint"`
	NewRoot              common.Hash `meddler:"new_root,hash"`
	NewLeaves            []byte      `meddler:"new_leaves"`
}

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

type LeafData struct {
	LeafType           uint8          `abi:"leafType"`
	OriginNetwork      uint32         `abi:"originNetwork"`
	OriginAddress      common.Address `abi:"originAddress"`
	DestinationNetwork uint32         `abi:"destinationNetwork"`
	DestinationAddress common.Address `abi:"destinationAddress"`
	Amount             *big.Int       `abi:"amount"`
	Metadata           []byte         `abi:"metadata"`
}

type LegacyTokenMigration struct {
	BlockNum            uint64         `meddler:"block_num"`
	BlockPos            uint64         `meddler:"block_pos"`
	BlockTimestamp      uint64         `meddler:"block_timestamp"`
	TxHash              common.Hash    `meddler:"tx_hash,hash"`
	Sender              common.Address `meddler:"sender,address"`
	LegacyTokenAddress  common.Address `meddler:"legacy_token_address,address"`
	UpdatedTokenAddress common.Address `meddler:"updated_token_address,address"`
	Amount              *big.Int       `meddler:"amount,bigint"`
}

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

type RecordUpdate struct {
	BlockNum  uint64
	BlockPos  uint64
	TxnSender common.Address
	FromAddr  *common.Address // nil means not available (e.g. syncFromInBridges=false for asset events)
	ToAddr    common.Address
}

type RemoveLegacyToken struct {
	BlockNum           uint64         `meddler:"block_num"`
	BlockPos           uint64         `meddler:"block_pos"`
	BlockTimestamp     uint64         `meddler:"block_timestamp"`
	TxHash             common.Hash    `meddler:"tx_hash,hash"`
	LegacyTokenAddress common.Address `meddler:"legacy_token_address,address"`
}

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

type TokenMapping struct {
	BlockNum            uint64                       `meddler:"block_num"`
	BlockPos            uint64                       `meddler:"block_pos"`
	BlockTimestamp      uint64                       `meddler:"block_timestamp"`
	TxHash              common.Hash                  `meddler:"tx_hash,hash"`
	OriginNetwork       uint32                       `meddler:"origin_network"`
	OriginTokenAddress  common.Address               `meddler:"origin_token_address,address"`
	WrappedTokenAddress common.Address               `meddler:"wrapped_token_address,address"`
	Metadata            []byte                       `meddler:"metadata"`
	IsNotMintable       bool                         `meddler:"is_not_mintable"`
	Type                bridgetypes.TokenMappingType `meddler:"token_type"`
}

type Transaction struct {
	FromRaw          string `json:"from"`
	To               string `json:"to"`
	Hash             string `json:"hash"`
	Value            string `json:"value"`
	Gas              string `json:"gas"`
	GasPrice         string `json:"gasPrice"`
	Nonce            string `json:"nonce"`
	Input            string `json:"input"`
	BlockHash        string `json:"blockHash"`
	BlockNumber      string `json:"blockNumber"`
	TransactionIndex string `json:"transactionIndex"`
}

type TxnSenderJob struct {
	Record RecordToBackfill
}

type TxnSenderResult struct {
	Update RecordUpdate
	Error  error
}