pathprocessor

package
v0.180.29 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 10, 2024 License: MPL-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IncreaseEstimatedGasFactor = 1.1

	EthSymbol = "ETH"
	SntSymbol = "SNT"
	SttSymbol = "STT"

	ProcessorTransferName     = "Transfer"
	ProcessorBridgeHopName    = "Hop"
	ProcessorBridgeCelerName  = "CBridge"
	ProcessorSwapParaswapName = "Paraswap"
	ProcessorERC721Name       = "ERC721Transfer"
	ProcessorERC1155Name      = "ERC1155Transfer"
	ProcessorENSRegisterName  = "ENSRegister"
	ProcessorENSReleaseName   = "ENSRelease"
	ProcessorENSPublicKeyName = "ENSPublicKey"
)
View Source 
const (
	SevenDaysInSeconds = 604800
)

Variables

View Source 
var (
	ZeroAddress     = common.Address{}
	ZeroBigIntValue = big.NewInt(0)
)

Functions

This section is empty.

Types

type BonderFee 

type BonderFee struct {
	AmountIn                *bigint.BigInt `json:"amountIn"`
	Slippage                float32        `json:"slippage"`
	AmountOutMin            *bigint.BigInt `json:"amountOutMin"`
	DestinationAmountOutMin *bigint.BigInt `json:"destinationAmountOutMin"`
	BonderFee               *bigint.BigInt `json:"bonderFee"`
	EstimatedRecieved       *bigint.BigInt `json:"estimatedRecieved"`
	Deadline                int64          `json:"deadline"`
	DestinationDeadline     int64          `json:"destinationDeadline"`
}

func (*BonderFee) UnmarshalJSON 

func (bf *BonderFee) UnmarshalJSON(data []byte) error

type CelerBridgeProcessor 

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

func NewCelerBridgeProcessor 

func NewCelerBridgeProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface, tokenManager *token.Manager) *CelerBridgeProcessor

func (*CelerBridgeProcessor) AvailableFor 

func (s *CelerBridgeProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*CelerBridgeProcessor) BuildTransaction 

func (s *CelerBridgeProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*CelerBridgeProcessor) BuildTx 

func (s *CelerBridgeProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*CelerBridgeProcessor) CalculateAmountOut 

func (s *CelerBridgeProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*CelerBridgeProcessor) CalculateFees 

func (s *CelerBridgeProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*CelerBridgeProcessor) EstimateGas 

func (s *CelerBridgeProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*CelerBridgeProcessor) GetContractAddress 

func (s *CelerBridgeProcessor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*CelerBridgeProcessor) Name 

func (s *CelerBridgeProcessor) Name() string

func (*CelerBridgeProcessor) PackTxInputData 

func (c *CelerBridgeProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*CelerBridgeProcessor) Send 

func (s *CelerBridgeProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (types.Hash, error)

type CelerBridgeTxArgs 

type CelerBridgeTxArgs struct {
	transactions.SendTxArgs
	ChainID   uint64         `json:"chainId"`
	Symbol    string         `json:"symbol"`
	Recipient common.Address `json:"recipient"`
	Amount    *hexutil.Big   `json:"amount"`
}

type ENSPublicKeyProcessor 

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

func NewENSPublicKeyProcessor 

func NewENSPublicKeyProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface, ensService *ens.Service) *ENSPublicKeyProcessor

func (*ENSPublicKeyProcessor) AvailableFor 

func (s *ENSPublicKeyProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*ENSPublicKeyProcessor) BuildTransaction 

func (s *ENSPublicKeyProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*ENSPublicKeyProcessor) BuildTx 

func (s *ENSPublicKeyProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*ENSPublicKeyProcessor) CalculateAmountOut 

func (s *ENSPublicKeyProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*ENSPublicKeyProcessor) CalculateFees 

func (s *ENSPublicKeyProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*ENSPublicKeyProcessor) EstimateGas 

func (s *ENSPublicKeyProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*ENSPublicKeyProcessor) GetContractAddress 

func (s *ENSPublicKeyProcessor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*ENSPublicKeyProcessor) Name 

func (s *ENSPublicKeyProcessor) Name() string

func (*ENSPublicKeyProcessor) PackTxInputData 

func (s *ENSPublicKeyProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*ENSPublicKeyProcessor) Send 

func (s *ENSPublicKeyProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (hash types.Hash, err error)

type ENSRegisterProcessor 

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

func NewENSRegisterProcessor 

func NewENSRegisterProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface, ensService *ens.Service) *ENSRegisterProcessor

func (*ENSRegisterProcessor) AvailableFor 

func (s *ENSRegisterProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*ENSRegisterProcessor) BuildTransaction 

func (s *ENSRegisterProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*ENSRegisterProcessor) BuildTx 

func (s *ENSRegisterProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*ENSRegisterProcessor) CalculateAmountOut 

func (s *ENSRegisterProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*ENSRegisterProcessor) CalculateFees 

func (s *ENSRegisterProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*ENSRegisterProcessor) EstimateGas 

func (s *ENSRegisterProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*ENSRegisterProcessor) GetContractAddress 

func (s *ENSRegisterProcessor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*ENSRegisterProcessor) GetPriceForRegisteringEnsName 

func (s *ENSRegisterProcessor) GetPriceForRegisteringEnsName(chainID uint64) (*big.Int, error)

func (*ENSRegisterProcessor) Name 

func (s *ENSRegisterProcessor) Name() string

func (*ENSRegisterProcessor) PackTxInputData 

func (s *ENSRegisterProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*ENSRegisterProcessor) Send 

func (s *ENSRegisterProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (hash types.Hash, err error)

type ENSReleaseProcessor 

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

func NewENSReleaseProcessor 

func NewENSReleaseProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface, ensService *ens.Service) *ENSReleaseProcessor

func (*ENSReleaseProcessor) AvailableFor 

func (s *ENSReleaseProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*ENSReleaseProcessor) BuildTransaction 

func (s *ENSReleaseProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*ENSReleaseProcessor) BuildTx 

func (s *ENSReleaseProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*ENSReleaseProcessor) CalculateAmountOut 

func (s *ENSReleaseProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*ENSReleaseProcessor) CalculateFees 

func (s *ENSReleaseProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*ENSReleaseProcessor) EstimateGas 

func (s *ENSReleaseProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*ENSReleaseProcessor) GetContractAddress 

func (s *ENSReleaseProcessor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*ENSReleaseProcessor) Name 

func (s *ENSReleaseProcessor) Name() string

func (*ENSReleaseProcessor) PackTxInputData 

func (s *ENSReleaseProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*ENSReleaseProcessor) Send 

func (s *ENSReleaseProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (hash types.Hash, err error)

type ERC1155Processor 

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

func NewERC1155Processor 

func NewERC1155Processor(rpcClient *rpc.Client, transactor transactions.TransactorIface) *ERC1155Processor

func (*ERC1155Processor) AvailableFor 

func (s *ERC1155Processor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*ERC1155Processor) BuildTransaction 

func (s *ERC1155Processor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*ERC1155Processor) BuildTx 

func (s *ERC1155Processor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*ERC1155Processor) CalculateAmountOut 

func (s *ERC1155Processor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*ERC1155Processor) CalculateFees 

func (s *ERC1155Processor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*ERC1155Processor) EstimateGas 

func (s *ERC1155Processor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*ERC1155Processor) GetContractAddress 

func (s *ERC1155Processor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*ERC1155Processor) Name 

func (s *ERC1155Processor) Name() string

func (*ERC1155Processor) PackTxInputData 

func (s *ERC1155Processor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*ERC1155Processor) Send 

func (s *ERC1155Processor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (hash types.Hash, err error)

type ERC1155TxArgs 

type ERC1155TxArgs struct {
	transactions.SendTxArgs
	TokenID   *hexutil.Big   `json:"tokenId"`
	Recipient common.Address `json:"recipient"`
	Amount    *hexutil.Big   `json:"amount"`
}

type ERC721Processor 

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

func NewERC721Processor 

func NewERC721Processor(rpcClient *rpc.Client, transactor transactions.TransactorIface) *ERC721Processor

func (*ERC721Processor) AvailableFor 

func (s *ERC721Processor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*ERC721Processor) BuildTransaction 

func (s *ERC721Processor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*ERC721Processor) BuildTx 

func (s *ERC721Processor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*ERC721Processor) CalculateAmountOut 

func (s *ERC721Processor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*ERC721Processor) CalculateFees 

func (s *ERC721Processor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*ERC721Processor) EstimateGas 

func (s *ERC721Processor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*ERC721Processor) GetContractAddress 

func (s *ERC721Processor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*ERC721Processor) Name 

func (s *ERC721Processor) Name() string

func (*ERC721Processor) PackTxInputData 

func (s *ERC721Processor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*ERC721Processor) Send 

func (s *ERC721Processor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (hash types.Hash, err error)

type ERC721TxArgs 

type ERC721TxArgs struct {
	transactions.SendTxArgs
	TokenID   *hexutil.Big   `json:"tokenId"`
	Recipient common.Address `json:"recipient"`
}

type HopBridgeProcessor 

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

func NewHopBridgeProcessor 

func NewHopBridgeProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface, tokenManager *token.Manager) *HopBridgeProcessor

func (*HopBridgeProcessor) AvailableFor 

func (h *HopBridgeProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*HopBridgeProcessor) BuildTransaction 

func (h *HopBridgeProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*HopBridgeProcessor) BuildTx 

func (h *HopBridgeProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*HopBridgeProcessor) CalculateAmountOut 

func (h *HopBridgeProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*HopBridgeProcessor) CalculateFees 

func (h *HopBridgeProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*HopBridgeProcessor) EstimateGas 

func (h *HopBridgeProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*HopBridgeProcessor) GetContractAddress 

func (h *HopBridgeProcessor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*HopBridgeProcessor) Name 

func (h *HopBridgeProcessor) Name() string

func (*HopBridgeProcessor) PackTxInputData 

func (h *HopBridgeProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*HopBridgeProcessor) Send 

func (h *HopBridgeProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (hash types.Hash, err error)

type HopBridgeTxArgs 

type HopBridgeTxArgs struct {
	transactions.SendTxArgs
	ChainID   uint64         `json:"chainId"`
	Symbol    string         `json:"symbol"`
	Recipient common.Address `json:"recipient"`
	Amount    *hexutil.Big   `json:"amount"`
	BonderFee *hexutil.Big   `json:"bonderFee"`
}

type MultipathProcessorTxArgs 

type MultipathProcessorTxArgs struct {
	Name              string
	ChainID           uint64
	TransferTx        *transactions.SendTxArgs
	HopTx             *HopBridgeTxArgs
	CbridgeTx         *CelerBridgeTxArgs
	ERC721TransferTx  *ERC721TxArgs
	ERC1155TransferTx *ERC1155TxArgs
	SwapTx            *SwapParaswapTxArgs
}

func (*MultipathProcessorTxArgs) Data 

func (t *MultipathProcessorTxArgs) Data() types.HexBytes

func (*MultipathProcessorTxArgs) From 

func (t *MultipathProcessorTxArgs) From() types.Address

func (*MultipathProcessorTxArgs) To 

func (t *MultipathProcessorTxArgs) To() types.Address

func (*MultipathProcessorTxArgs) Value 

func (t *MultipathProcessorTxArgs) Value() *big.Int

type PathProcessor 

type PathProcessor interface {
	// returns the name of the bridge
	Name() string
	// checks if the bridge is available for the given networks/tokens
	AvailableFor(params ProcessorInputParams) (bool, error)
	// calculates the fees for the bridge and returns the amount BonderFee and TokenFee (used for bridges)
	CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)
	// Pack the method for sending tx and method call's data
	PackTxInputData(params ProcessorInputParams) ([]byte, error)
	EstimateGas(params ProcessorInputParams) (uint64, error)
	CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)
	Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (types.Hash, error)
	GetContractAddress(params ProcessorInputParams) (common.Address, error)
	BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)
	BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)
}

type ProcessorInputParams 

type ProcessorInputParams struct {
	FromChain *params.Network
	ToChain   *params.Network
	FromAddr  common.Address
	ToAddr    common.Address
	FromToken *token.Token
	ToToken   *token.Token
	AmountIn  *big.Int

	// extra params
	BonderFee *big.Int
	Username  string
	PublicKey string
}

type SwapParaswapProcessor 

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

func NewSwapParaswapProcessor 

func NewSwapParaswapProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface, tokenManager *walletToken.Manager) *SwapParaswapProcessor

func (*SwapParaswapProcessor) AvailableFor 

func (s *SwapParaswapProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*SwapParaswapProcessor) BuildTransaction 

func (s *SwapParaswapProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*SwapParaswapProcessor) BuildTx 

func (s *SwapParaswapProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*SwapParaswapProcessor) CalculateAmountOut 

func (s *SwapParaswapProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*SwapParaswapProcessor) CalculateFees 

func (s *SwapParaswapProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*SwapParaswapProcessor) EstimateGas 

func (s *SwapParaswapProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*SwapParaswapProcessor) GetContractAddress 

func (s *SwapParaswapProcessor) GetContractAddress(params ProcessorInputParams) (address common.Address, err error)

func (*SwapParaswapProcessor) Name 

func (s *SwapParaswapProcessor) Name() string

func (*SwapParaswapProcessor) PackTxInputData 

func (s *SwapParaswapProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*SwapParaswapProcessor) Send 

func (s *SwapParaswapProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (types.Hash, error)

type SwapParaswapTxArgs 

type SwapParaswapTxArgs struct {
	transactions.SendTxArgs
	ChainID uint64 `json:"chainId"`
}

type TransferProcessor 

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

func NewTransferProcessor 

func NewTransferProcessor(rpcClient *rpc.Client, transactor transactions.TransactorIface) *TransferProcessor

func (*TransferProcessor) AvailableFor 

func (s *TransferProcessor) AvailableFor(params ProcessorInputParams) (bool, error)

func (*TransferProcessor) BuildTransaction 

func (s *TransferProcessor) BuildTransaction(sendArgs *MultipathProcessorTxArgs) (*ethTypes.Transaction, error)

func (*TransferProcessor) BuildTx 

func (s *TransferProcessor) BuildTx(params ProcessorInputParams) (*ethTypes.Transaction, error)

func (*TransferProcessor) CalculateAmountOut 

func (s *TransferProcessor) CalculateAmountOut(params ProcessorInputParams) (*big.Int, error)

func (*TransferProcessor) CalculateFees 

func (s *TransferProcessor) CalculateFees(params ProcessorInputParams) (*big.Int, *big.Int, error)

func (*TransferProcessor) EstimateGas 

func (s *TransferProcessor) EstimateGas(params ProcessorInputParams) (uint64, error)

func (*TransferProcessor) GetContractAddress 

func (s *TransferProcessor) GetContractAddress(params ProcessorInputParams) (common.Address, error)

func (*TransferProcessor) Name 

func (s *TransferProcessor) Name() string

func (*TransferProcessor) PackTxInputData 

func (s *TransferProcessor) PackTxInputData(params ProcessorInputParams) ([]byte, error)

func (*TransferProcessor) Send 

func (s *TransferProcessor) Send(sendArgs *MultipathProcessorTxArgs, verifiedAccount *account.SelectedExtKey) (types.Hash, error)

Source Files

View all Source files

Directories

Path Synopsis
Package mock_pathprocessor is a generated GoMock package.
 Package mock_pathprocessor is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.