tokens

type Config ¶

type Config struct {
	Endpoints string `` /* 395-byte string literal not displayed */
}

Config holds tokens service configuration.

type Endpoint ¶

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

Endpoint for querying ERC20 token information from ethereum chain.

architecture: Endpoint

func NewEndpoint(log *zap.Logger, service *Service) *Endpoint

func (endpoint *Endpoint) AllPayments(w http.ResponseWriter, r *http.Request)

func (endpoint *Endpoint) Payments(w http.ResponseWriter, r *http.Request)

func (endpoint *Endpoint) Register(router *mux.Router)

type EthEndpoint ¶ added in v1.0.5

type EthEndpoint struct {
	Name     string `json:"name"`
	URL      string `json:"url"`
	Contract string `json:"contract"`
	ChainID  int64  `json:"chainId,string,omitempty"`
}

EthEndpoint contains the URL and contract address to access a chain API.

type LatestPayments ¶

type LatestPayments struct {
	LatestBlocks []blockchain.Header
	Payments     []Payment
}

LatestPayments contains latest payments and latest chain block header.

type Payment ¶

type Payment struct {
	ChainID     int64
	From        blockchain.Address
	To          blockchain.Address
	TokenValue  currency.Amount
	USDValue    currency.Amount
	BlockHash   blockchain.Hash
	BlockNumber int64
	Transaction blockchain.Hash
	LogIndex    int
	Timestamp   time.Time
}

Payment is on chain payment made for particular contract and deposit wallet.

type Service ¶

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

Service for querying ERC20 token information from ethereum chain.

architecture: Service

func NewService(
	log *zap.Logger,
	endpoints []EthEndpoint,
	cache *blockchain.HeadersCache,
	walletDB wallets.DB,
	tokenPrice *tokenprice.Service,
	batchSize int) *Service

func (service *Service) AllPayments(ctx context.Context, satelliteID string, from map[int64]int64) (_ LatestPayments, err error)

func (service *Service) GetChainIds(ctx context.Context) (chainIds map[int64]string, err error)

func (service *Service) Payments(ctx context.Context, address blockchain.Address, from map[int64]int64) (_ LatestPayments, err error)

func (service *Service) PingAll(ctx context.Context) (err error)