|
|
|
|
@ -1,49 +1,70 @@ |
|
|
|
|
import { ethers } from 'ethers'; |
|
|
|
|
import { BigNumber, ethers } from 'ethers'; |
|
|
|
|
|
|
|
|
|
import { TypedListener } from '@abacus-network/core/dist/common'; |
|
|
|
|
import { |
|
|
|
|
AbacusApp, |
|
|
|
|
AbacusCore, |
|
|
|
|
ChainMap, |
|
|
|
|
ChainName, |
|
|
|
|
ChainNameToDomainId, |
|
|
|
|
MultiProvider, |
|
|
|
|
Remotes, |
|
|
|
|
} from '@abacus-network/sdk'; |
|
|
|
|
|
|
|
|
|
import { ReceivedHelloWorldEvent } from '../types/contracts/HelloWorld'; |
|
|
|
|
|
|
|
|
|
import { HelloWorldContracts } from './contracts'; |
|
|
|
|
|
|
|
|
|
type Counts = { |
|
|
|
|
sent: number; |
|
|
|
|
received: number; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
export class HelloWorldApp< |
|
|
|
|
Chain extends ChainName = ChainName, |
|
|
|
|
> extends AbacusApp<HelloWorldContracts, Chain> { |
|
|
|
|
constructor( |
|
|
|
|
public readonly core: AbacusCore<Chain>, |
|
|
|
|
contractsMap: ChainMap<Chain, HelloWorldContracts>, |
|
|
|
|
multiProvider: MultiProvider<Chain>, |
|
|
|
|
) { |
|
|
|
|
super(contractsMap, multiProvider); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
async sendHelloWorld<From extends Chain>( |
|
|
|
|
from: From, |
|
|
|
|
to: Remotes<Chain, From>, |
|
|
|
|
message: string, |
|
|
|
|
receiveHandler?: TypedListener<ReceivedHelloWorldEvent>, |
|
|
|
|
value: BigNumber, |
|
|
|
|
): Promise<ethers.ContractReceipt> { |
|
|
|
|
const sender = this.getContracts(from).router; |
|
|
|
|
const toDomain = ChainNameToDomainId[to]; |
|
|
|
|
const chainConnection = this.multiProvider.getChainConnection(from); |
|
|
|
|
const tx = await sender.sendHelloWorld( |
|
|
|
|
|
|
|
|
|
// apply gas buffer due to https://github.com/abacus-network/abacus-monorepo/issues/634
|
|
|
|
|
const estimated = await sender.estimateGas.sendHelloWorld( |
|
|
|
|
toDomain, |
|
|
|
|
message, |
|
|
|
|
chainConnection.overrides, |
|
|
|
|
{ ...chainConnection.overrides, value }, |
|
|
|
|
); |
|
|
|
|
const receipt = await tx.wait(chainConnection.confirmations); |
|
|
|
|
const gasLimit = estimated.mul(12).div(10); |
|
|
|
|
|
|
|
|
|
if (receiveHandler) { |
|
|
|
|
const recipient = this.getContracts(to).router; |
|
|
|
|
const filter = recipient.filters.ReceivedHelloWorld( |
|
|
|
|
ChainNameToDomainId[from], |
|
|
|
|
ChainNameToDomainId[to], |
|
|
|
|
); |
|
|
|
|
recipient.once(filter, receiveHandler); |
|
|
|
|
} |
|
|
|
|
const tx = await sender.sendHelloWorld(toDomain, message, { |
|
|
|
|
...chainConnection.overrides, |
|
|
|
|
gasLimit, |
|
|
|
|
value, |
|
|
|
|
}); |
|
|
|
|
console.log(tx); |
|
|
|
|
return tx.wait(chainConnection.confirmations); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return receipt; |
|
|
|
|
async waitForMessageReceipt( |
|
|
|
|
receipt: ethers.ContractReceipt, |
|
|
|
|
): Promise<ethers.ContractReceipt[]> { |
|
|
|
|
return this.core.waitForMessageProcessing(receipt); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
async channelStats<From extends Chain>(from: From, to: Remotes<Chain, From>) { |
|
|
|
|
async channelStats<From extends Chain>( |
|
|
|
|
from: From, |
|
|
|
|
to: Remotes<Chain, From>, |
|
|
|
|
): Promise<Counts> { |
|
|
|
|
const sent = await this.getContracts(from).router.sentTo( |
|
|
|
|
ChainNameToDomainId[to], |
|
|
|
|
); |
|
|
|
|
@ -54,8 +75,8 @@ export class HelloWorldApp< |
|
|
|
|
return { sent: sent.toNumber(), received: received.toNumber() }; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
async stats() { |
|
|
|
|
const entries = await Promise.all( |
|
|
|
|
async stats(): Promise<Record<Chain, Record<Chain, Counts>>> { |
|
|
|
|
const entries: Array<[Chain, Record<Chain, Counts>]> = await Promise.all( |
|
|
|
|
this.chains().map(async (source) => { |
|
|
|
|
const destinationEntries = await Promise.all( |
|
|
|
|
this.remoteChains(source).map(async (destination) => [ |
|
|
|
|
@ -63,9 +84,12 @@ export class HelloWorldApp< |
|
|
|
|
await this.channelStats(source, destination), |
|
|
|
|
]), |
|
|
|
|
); |
|
|
|
|
return [source, Object.fromEntries(destinationEntries)]; |
|
|
|
|
return [ |
|
|
|
|
source, |
|
|
|
|
Object.fromEntries(destinationEntries) as Record<Chain, Counts>, |
|
|
|
|
]; |
|
|
|
|
}), |
|
|
|
|
); |
|
|
|
|
return Object.fromEntries(entries); |
|
|
|
|
return Object.fromEntries(entries) as Record<Chain, Record<Chain, Counts>>; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
J M Rossy
2 years ago
committed by
GitHub