testing: evm rollback test
This commit is contained in:
Evan Gray
Evan Gray
parent
7edbbd3677
commit
ea1b852b98
File diff suppressed because it is too large
Load Diff
|
|
@ -0,0 +1,12 @@
|
|||
{
|
||||
"name": "rollback-test",
|
||||
"version": "0.0.1",
|
||||
"private": true,
|
||||
"dependencies": {
|
||||
"@certusone/wormhole-sdk": "^0.1.6",
|
||||
"@improbable-eng/grpc-web-node-http-transport": "^0.15.0",
|
||||
"axios": "^0.24.0",
|
||||
"ethers": "^5.5.2"
|
||||
},
|
||||
"scripts": {}
|
||||
}
|
||||
|
|
@ -0,0 +1,236 @@
|
|||
// This test is intended to be run on devnet without an active eth miner
|
||||
// see https://github.com/trufflesuite/ganache-cli-archive#custom-methods
|
||||
|
||||
const {
|
||||
NodeHttpTransport,
|
||||
} = require("@improbable-eng/grpc-web-node-http-transport");
|
||||
const { ethers } = require("ethers");
|
||||
const { parseUnits } = require("ethers/lib/utils");
|
||||
const {
|
||||
approveEth,
|
||||
transferFromEth,
|
||||
CHAIN_ID_BSC,
|
||||
CHAIN_ID_ETH,
|
||||
hexToUint8Array,
|
||||
nativeToHexString,
|
||||
parseSequenceFromLogEth,
|
||||
getEmitterAddressEth,
|
||||
getSignedVAA,
|
||||
} = require("@certusone/wormhole-sdk");
|
||||
const { default: axios } = require("axios");
|
||||
|
||||
const ETH_NODE_URL = "ws://localhost:8545";
|
||||
const ETH_PRIVATE_KEY =
|
||||
"0x4f3edf983ac636a65a842ce7c78d9aa706d3b113bce9c46f30d7d21715b23b1d";
|
||||
const ETH_CORE_BRIDGE_ADDRESS = "0xC89Ce4735882C9F0f0FE26686c53074E09B0D550";
|
||||
const ETH_TOKEN_BRIDGE_ADDRESS = "0x0290FB167208Af455bB137780163b7B7a9a10C16";
|
||||
const TEST_ERC20 = "0x2D8BE6BF0baA74e0A907016679CaE9190e80dD0A";
|
||||
const WORMHOLE_RPC_HOST = "http://localhost:7071";
|
||||
|
||||
(async () => {
|
||||
// create a signer for Eth
|
||||
const provider = new ethers.providers.WebSocketProvider(ETH_NODE_URL);
|
||||
const signer = new ethers.Wallet(ETH_PRIVATE_KEY, provider);
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
|
||||
// TEST 1 - send with 20 blocks conf
|
||||
const amount = parseUnits("1", 18);
|
||||
// approve the bridge to spend tokens
|
||||
await approveEth(ETH_TOKEN_BRIDGE_ADDRESS, TEST_ERC20, signer, amount);
|
||||
// transfer tokens
|
||||
const receipt = await transferFromEth(
|
||||
ETH_TOKEN_BRIDGE_ADDRESS,
|
||||
signer,
|
||||
TEST_ERC20,
|
||||
amount,
|
||||
CHAIN_ID_BSC,
|
||||
hexToUint8Array(
|
||||
nativeToHexString(await signer.getAddress(), CHAIN_ID_ETH) || ""
|
||||
)
|
||||
);
|
||||
// get the sequence from the logs (needed to fetch the vaa)
|
||||
const sequence = parseSequenceFromLogEth(receipt, ETH_CORE_BRIDGE_ADDRESS);
|
||||
const emitterAddress = getEmitterAddressEth(ETH_TOKEN_BRIDGE_ADDRESS);
|
||||
console.log(`FIRST TX, SEQ ${sequence}`);
|
||||
for (let i = 1; i <= 20; i++) {
|
||||
console.log(`Attempt ${i}`);
|
||||
await axios.post("http://localhost:8545", {
|
||||
id: 1337,
|
||||
jsonrpc: "2.0",
|
||||
method: "evm_mine",
|
||||
params: [Date.now()],
|
||||
});
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
try {
|
||||
const { vaaBytes: signedVAA } = await getSignedVAA(
|
||||
WORMHOLE_RPC_HOST,
|
||||
CHAIN_ID_ETH,
|
||||
emitterAddress,
|
||||
sequence,
|
||||
{
|
||||
transport: NodeHttpTransport(),
|
||||
}
|
||||
);
|
||||
console.log(!!signedVAA);
|
||||
} catch (e) {
|
||||
console.error(e.message);
|
||||
}
|
||||
}
|
||||
|
||||
// TEST 2 - send with 1 conf, rollback before tx, 30 confs
|
||||
const {
|
||||
data: { result: snapshotId },
|
||||
} = await axios.post("http://localhost:8545", {
|
||||
id: 1337,
|
||||
jsonrpc: "2.0",
|
||||
method: "evm_snapshot",
|
||||
params: [],
|
||||
});
|
||||
console.log(`SNAPSHOT ${snapshotId}`);
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
const amount2 = parseUnits("2", 18);
|
||||
// approve the bridge to spend tokens
|
||||
await approveEth(ETH_TOKEN_BRIDGE_ADDRESS, TEST_ERC20, signer, amount2);
|
||||
// transfer tokens
|
||||
const receipt2 = await transferFromEth(
|
||||
ETH_TOKEN_BRIDGE_ADDRESS,
|
||||
signer,
|
||||
TEST_ERC20,
|
||||
amount2,
|
||||
CHAIN_ID_BSC,
|
||||
hexToUint8Array(
|
||||
nativeToHexString(await signer.getAddress(), CHAIN_ID_ETH) || ""
|
||||
)
|
||||
);
|
||||
// get the sequence from the logs (needed to fetch the vaa)
|
||||
const sequence2 = parseSequenceFromLogEth(receipt2, ETH_CORE_BRIDGE_ADDRESS);
|
||||
console.log(`SECOND TX, SEQ ${sequence2}`);
|
||||
console.log(`Attempt 1`);
|
||||
await axios.post("http://localhost:8545", {
|
||||
id: 1337,
|
||||
jsonrpc: "2.0",
|
||||
method: "evm_mine",
|
||||
params: [Date.now()],
|
||||
});
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
try {
|
||||
const { vaaBytes: signedVAA } = await getSignedVAA(
|
||||
WORMHOLE_RPC_HOST,
|
||||
CHAIN_ID_ETH,
|
||||
emitterAddress,
|
||||
sequence2,
|
||||
{
|
||||
transport: NodeHttpTransport(),
|
||||
}
|
||||
);
|
||||
console.log(!!signedVAA);
|
||||
} catch (e) {
|
||||
console.error(e.message);
|
||||
}
|
||||
console.log(`Rollback 1`);
|
||||
await axios.post("http://localhost:8545", {
|
||||
id: 1337,
|
||||
jsonrpc: "2.0",
|
||||
method: "evm_revert",
|
||||
params: [snapshotId],
|
||||
});
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
try {
|
||||
const { vaaBytes: signedVAA } = await getSignedVAA(
|
||||
WORMHOLE_RPC_HOST,
|
||||
CHAIN_ID_ETH,
|
||||
emitterAddress,
|
||||
sequence2,
|
||||
{
|
||||
transport: NodeHttpTransport(),
|
||||
}
|
||||
);
|
||||
console.log(!!signedVAA);
|
||||
} catch (e) {
|
||||
console.error(e.message);
|
||||
}
|
||||
for (let i = 1; i <= 30; i++) {
|
||||
console.log(`Attempt ${i}`);
|
||||
await axios.post("http://localhost:8545", {
|
||||
id: 1337,
|
||||
jsonrpc: "2.0",
|
||||
method: "evm_mine",
|
||||
params: [Date.now()],
|
||||
});
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
try {
|
||||
const { vaaBytes: signedVAA } = await getSignedVAA(
|
||||
WORMHOLE_RPC_HOST,
|
||||
CHAIN_ID_ETH,
|
||||
emitterAddress,
|
||||
sequence2,
|
||||
{
|
||||
transport: NodeHttpTransport(),
|
||||
}
|
||||
);
|
||||
console.log(!!signedVAA);
|
||||
} catch (e) {
|
||||
console.error(e.message);
|
||||
}
|
||||
}
|
||||
|
||||
// TEST 3 - repeat test 1 and verify test 2 is still not found
|
||||
const amount3 = parseUnits("3", 18);
|
||||
// approve the bridge to spend tokens
|
||||
await approveEth(ETH_TOKEN_BRIDGE_ADDRESS, TEST_ERC20, signer, amount3);
|
||||
// transfer tokens
|
||||
const receipt3 = await transferFromEth(
|
||||
ETH_TOKEN_BRIDGE_ADDRESS,
|
||||
signer,
|
||||
TEST_ERC20,
|
||||
amount3,
|
||||
CHAIN_ID_BSC,
|
||||
hexToUint8Array(
|
||||
nativeToHexString(await signer.getAddress(), CHAIN_ID_ETH) || ""
|
||||
)
|
||||
);
|
||||
// get the sequence from the logs (needed to fetch the vaa)
|
||||
const sequence3 = parseSequenceFromLogEth(receipt3, ETH_CORE_BRIDGE_ADDRESS);
|
||||
console.log(`FIRST TX, SEQ ${sequence3}`);
|
||||
for (let i = 1; i <= 20; i++) {
|
||||
console.log(`Attempt ${i}`);
|
||||
await axios.post("http://localhost:8545", {
|
||||
id: 1337,
|
||||
jsonrpc: "2.0",
|
||||
method: "evm_mine",
|
||||
params: [Date.now()],
|
||||
});
|
||||
console.log(`Height ${await provider.getBlockNumber()}`);
|
||||
try {
|
||||
const { vaaBytes: signedVAA } = await getSignedVAA(
|
||||
WORMHOLE_RPC_HOST,
|
||||
CHAIN_ID_ETH,
|
||||
emitterAddress,
|
||||
sequence3,
|
||||
{
|
||||
transport: NodeHttpTransport(),
|
||||
}
|
||||
);
|
||||
console.log(!!signedVAA);
|
||||
} catch (e) {
|
||||
console.error(e.message);
|
||||
}
|
||||
}
|
||||
console.log("Checking SEQ from test 2");
|
||||
try {
|
||||
const { vaaBytes: signedVAA } = await getSignedVAA(
|
||||
WORMHOLE_RPC_HOST,
|
||||
CHAIN_ID_ETH,
|
||||
emitterAddress,
|
||||
sequence2,
|
||||
{
|
||||
transport: NodeHttpTransport(),
|
||||
}
|
||||
);
|
||||
console.log(!!signedVAA);
|
||||
} catch (e) {
|
||||
console.error(e.message);
|
||||
}
|
||||
|
||||
provider.destroy();
|
||||
})();
|
||||
Loading…
Reference in New Issue