fetcher

Documentation

Overview

Package fetcher provides fetchers to fetch data from Scribe, BridgeConfig, and Swap.

Index

• Constants
• func GetDefiLlamaData(ctx context.Context, timestamp int, coinGeckoID string) (*float64, *string)
• type ScribeFetcher
  • func NewFetcher(fetchClient *client.Client) *ScribeFetcher
  • func (s ScribeFetcher) FetchBlockTime(ctx context.Context, chainID int, blockNumber int) (*int, error)
  • func (s ScribeFetcher) FetchLastIndexed(ctx context.Context, chainID uint32, contractAddress string) (uint64, error)
  • func (s ScribeFetcher) FetchLogsInRange(ctx context.Context, chainID uint32, startBlock, endBlock uint64, ...) ([]ethTypes.Log, error)
  • func (s ScribeFetcher) FetchTxSender(ctx context.Context, chainID uint32, txHash string) (string, error)
• type Service
  • func NewBridgeConfigFetcher(bridgeConfigAddress common.Address, ...) (Service, error)
• type SwapFetcher
  • func NewSwapFetcher(swapAddress common.Address, backend bind.ContractBackend) (*SwapFetcher, error)
  • func (s *SwapFetcher) GetTokenMetaData(ctx context.Context, tokenIndex uint8) (*string, *uint8)

Constants

const NoTokenID = "NO_TOKEN_ID"

NoTokenID is the string returned when a token id is not found (not an authentic token).

Functions

func GetDefiLlamaData

func GetDefiLlamaData(ctx context.Context, timestamp int, coinGeckoID string) (*float64, *string)

GetDefiLlamaData does a get request to defi llama for the symbol and price for a token.

Types

type ScribeFetcher

type ScribeFetcher struct {
	FetchClient *client.Client
}

ScribeFetcher is the fetcher for the events. It uses GQL.

func NewFetcher

func NewFetcher(fetchClient *client.Client) *ScribeFetcher

NewFetcher creates a new fetcher.

func (ScribeFetcher) FetchBlockTime

func (s ScribeFetcher) FetchBlockTime(ctx context.Context, chainID int, blockNumber int) (*int, error)

FetchBlockTime fetches the timestamp of a block.

func (ScribeFetcher) FetchLastIndexed

func (s ScribeFetcher) FetchLastIndexed(ctx context.Context, chainID uint32, contractAddress string) (uint64, error)

FetchLastIndexed fetches the last indexed block per contract.

func (ScribeFetcher) FetchLogsInRange

func (s ScribeFetcher) FetchLogsInRange(ctx context.Context, chainID uint32, startBlock, endBlock uint64, contractAddress common.Address) ([]ethTypes.Log, error)

FetchLogsInRange fetches logs in a range with the GQL client.

func (ScribeFetcher) FetchTxSender

func (s ScribeFetcher) FetchTxSender(ctx context.Context, chainID uint32, txHash string) (string, error)

FetchTxSender fetches the sender of a transaction.

type Service

type Service interface {
	// GetTokenID gets the token id from the bridge config contract.
	GetTokenID(ctx context.Context, chainID *big.Int, tokenAddress common.Address) (tokenID *string, err error)
	// GetToken gets the token from the bridge config contract.
	GetToken(ctx context.Context, chainID uint32, tokenAddress common.Address) (token *bridgeconfig.BridgeConfigV3Token, err error)
}

Service is the interface for the fetcher service.

func NewBridgeConfigFetcher

func NewBridgeConfigFetcher(bridgeConfigAddress common.Address, bridgeConfigRef *bridgeconfig.BridgeConfigRef) (Service, error)

NewBridgeConfigFetcher creates a new config fetcher. Backend must be an archive backend.

type SwapFetcher

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

SwapFetcher is the fetcher for token data from the swap contract.

func NewSwapFetcher

func NewSwapFetcher(swapAddress common.Address, backend bind.ContractBackend) (*SwapFetcher, error)

NewSwapFetcher creates a new swap fetcher. Backend must be an archive backend.

func (*SwapFetcher) GetTokenMetaData

func (s *SwapFetcher) GetTokenMetaData(ctx context.Context, tokenIndex uint8) (*string, *uint8)

GetTokenMetaData gets the token from the erc20 token contract given a swap contract token id.