@dfdao/network v6.7.31

@dfdao/network

This package contains functions and classes useful for communicating with the blockchain.

Installation

You can install this package using npm or yarn by running:

npm install --save @dfdao/network

yarn add @dfdao/network

When using this in a plugin, you might want to load it with skypack

import * as network from 'http://cdn.skypack.dev/@dfdao/network';

Table of contents

Classes

• ContractCaller
• EthConnection
• ThrottledConcurrentQueue
• TxCollection
• TxExecutor

Interfaces

• ConcurrentQueueConfiguration
• Queue

Type aliases

• AfterTransaction
• BeforeQueued
• BeforeTransaction
• ContractLoader
• GasPriceSettingProvider
• RetryErrorHandler

Functions

• aggregateBulkGetter
• assertProperlySigned
• callWithRetry
• createContract
• createEthConnection
• ethToWei
• getAutoGasPrices
• getGasSettingGwei
• gweiToWei
• isPurchase
• makeProvider
• neverResolves
• verifySignature
• waitForTransaction
• weiToEth
• weiToGwei

Classes

ContractCaller

• ContractCaller: Class ContractCaller

Instead of allowing the game to call view functions on the blockchain directly, all contract calls should go through this class. Its purpose is to throttle the calls to a reasonable rate, and to gracefully handle errors and retries

EthConnection

• EthConnection: Class EthConnection

Responsible for

1. loading the contracts
2. connecting to the network

ThrottledConcurrentQueue

• ThrottledConcurrentQueue: Class ThrottledConcurrentQueue<U>

A queue that executes promises with a max throughput, and optionally max concurrency.

Type parameters

TxCollection

• TxCollection: Class TxCollection

Default implementation of a transaction collection - provides a simple api for adding, removing, and querying by type of transaction.

TxExecutor

• TxExecutor: Class TxExecutor

Interfaces

ConcurrentQueueConfiguration

• ConcurrentQueueConfiguration: Interface ConcurrentQueueConfiguration

Queue

• Queue: Interface Queue

Let's keep things flexible by keeping this type small.

Type aliases

AfterTransaction

Ƭ AfterTransaction: Function

Type declaration

▸ (transactionRequest, performanceMetrics): Promise<void>

{@link TxExecutor} calls this after executing a transaction.

Parameters

Returns

Promise<void>

BeforeQueued

Ƭ BeforeQueued: Function

Type declaration

▸ (id, intent, overrides?): Promise<void>

{@link TxExecutor} calls this before queueing a function to determine whether or not that function should be queued. If this function rejects, a transaction is not queued.

Parameters

Returns

Promise<void>

BeforeTransaction

Ƭ BeforeTransaction: Function

Type declaration

▸ (transactionRequest): Promise<void>

{@link TxExecutor} calls this before executing a function to determine whether or not that function should execute. If this function rejects, the transaction is cancelled.

Parameters

Returns

Promise<void>

ContractLoader

Ƭ ContractLoader: Function

Type parameters

Type declaration

▸ (address, provider, signer?): Promise<T>

Parameters

Returns

Promise<T>

GasPriceSettingProvider

Ƭ GasPriceSettingProvider: Function

Type declaration

▸ (transactionRequest): AutoGasSetting | string

Returns either a string that represents the gas price we should use by default for transactions, or a string that represents the fact that we should be using one of the automatic gas prices.

Parameters

Returns

AutoGasSetting | string

RetryErrorHandler

Ƭ RetryErrorHandler: Function

Type declaration

▸ (i, e): void

Parameters

Returns

void

Functions

aggregateBulkGetter

▸ Const aggregateBulkGetter<T>(total, querySize, getterFn, onProgress?, offset?): Promise<T[]>

A useful utility function that breaks up the proverbial number line (defined by {@code total} and {@code querySize}), and calls {@code getterFn} for each of the sections on the number line.

Type parameters

Parameters

Returns

Promise<T[]>

a list of each of the individual items that were loaded.

assertProperlySigned

▸ assertProperlySigned(message): void

Ensures that the given message was properly signed.

Parameters

Returns

void

callWithRetry

▸ Const callWithRetry<T>(fn, args?, onError?, maxRetries?, retryInterval?): Promise<T>

Calls the given function, retrying it if there is an error.

todo Get rid of this, and make use of {@link ContractCaller}.

Type parameters

Parameters

Returns

Promise<T>

createContract

▸ createContract<C>(contractAddress, contractABI, provider, signer?): C

Type parameters

Parameters

Returns

C

createEthConnection

▸ createEthConnection(rpcUrl): Promise<EthConnection>

Parameters

Returns

Promise<EthConnection>

ethToWei

▸ ethToWei(eth): BigNumber

Returns the given amount of eth in wei as a big integer.

Parameters

Returns

BigNumber

getAutoGasPrices

▸ getAutoGasPrices(): Promise<GasPrices>

Gets the current gas prices from xDai's price oracle. If the oracle is broken, return some sane defaults.

Returns

Promise<GasPrices>

getGasSettingGwei

▸ getGasSettingGwei(setting, gasPrices): number | undefined

Given the user's auto gas setting, and the current set of gas prices on the network, returns the preferred gas price. If an invalid {@link AutoGasSetting} is provided, then returns undefined.

Parameters

Returns

number | undefined

gweiToWei

▸ gweiToWei(gwei): BigNumber

Returns the given amount of gwei in wei as a big integer.

Parameters

Returns

BigNumber

isPurchase

▸ isPurchase(tx?): boolean

Whether or not some value is being transferred in this transaction.

Parameters

Returns

boolean

makeProvider

▸ makeProvider(rpcUrl): providers.JsonRpcProvider

Creates a new {@link JsonRpcProvider}, and makes sure that it's connected to xDai if we're in production.

Parameters

Returns

providers.JsonRpcProvider

neverResolves

▸ neverResolves(): Promise<void>

A function that just never resolves.s

Returns

Promise<void>

verifySignature

▸ verifySignature(message, signature, addr): boolean

Returns whether or not the given message was signed by the given address.

Parameters

Returns

boolean

waitForTransaction

▸ waitForTransaction(provider, txHash): Promise<providers.TransactionReceipt>

Given a transaction hash and a JsonRpcProvider, waits for the given transaction to complete.

Parameters

Returns

Promise<providers.TransactionReceipt>

weiToEth

▸ weiToEth(wei): number

Returns the given amount of wei in gwei as a number.

Parameters

Returns

number

weiToGwei

▸ weiToGwei(wei): number

Returns the given amount of wei in gwei as a number.

Parameters

Returns

number