Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add : get latest checkpoint count from main chain #117

Merged
merged 3 commits into from
Nov 23, 2022
Merged

add : get latest checkpoint count from main chain #117

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
0234142
add : get latest checkpoint count from main chain
nikhil0360 Nov 21, 2022
4dde0e2
add: fetching contract address from remote file
nikhil0360 Nov 22, 2022
69d35d0
chg: console logs, function names from Bor to Rootchain
nikhil0360 Nov 22, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
48 changes: 45 additions & 3 deletions src/express/commands/monitor.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ const yaml = require("js-yaml");
const fs = require("fs");
const Web3 = require('web3');
const timer = ms => new Promise(res => setTimeout(res, ms))
const {runScpCommand, maxRetries} = require("../common/remote-worker");

const lastStateIdABI = [
{
Expand All @@ -22,6 +23,23 @@ const lastStateIdABI = [
}
]

const currentHeaderBlockABI = [
{
"constant":true,
"inputs":[],
"name":"currentHeaderBlock",
"outputs": [
{
"internalType":"uint256",
"name":"",
"type":"uint256"
}
],
"payable":false,
"stateMutability":"view",
"type":"function"
}
]

var stateReceiverAddress = '0x0000000000000000000000000000000000001001'

Expand Down Expand Up @@ -77,6 +95,16 @@ async function lastStateIdFromBor(ip) {
return lastStateId
}

async function getLatestCheckpointFromRootChain(ip, rootChainProxyAddress){
let web3 = new Web3(`http://${ip}:9545`);

let RootChainContract = await new web3.eth.Contract(currentHeaderBlockABI, rootChainProxyAddress);
let currentHeaderBlock = await RootChainContract.methods.currentHeaderBlock().call();
let lastestCheckpoint = currentHeaderBlock.toString().slice(0, -4);

return lastestCheckpoint
}

export async function monitor() {
let doc

Expand All @@ -96,19 +124,33 @@ export async function monitor() {
let machine0 = doc['devnetBorHosts'][0];
console.log("📍Checking for StateSyncs && Checkpoints")

let src = `${doc['ethHostUser']}@${machine0}:~/matic-cli/devnet/code/contracts/contractAddresses.json`
let dest = `./contractAddresses.json`
await runScpCommand(src, dest, maxRetries)

let contractAddresses = require("../../../contractAddresses.json");

let rootChainProxyAddress = contractAddresses.root.RootChainProxy;

while (true) {

await timer(1000);
console.log()

let checkpointCount = await checkCheckpoint(machine0);
if (checkpointCount > 0) {
console.log("📍Checkpoint found ✅ ; Count: ", checkpointCount);
console.log("📍Checkpoint found on Heimdall ✅ ; Count: ", checkpointCount);
} else {
console.log("📍Awaiting Checkpoint on Heimdall 🚌")
}

var checkpointCountFromRootChain = await getLatestCheckpointFromRootChain(machine0, rootChainProxyAddress);
if(checkpointCountFromRootChain > 0) {
console.log("📍Checkpoint found on Root chain ✅ ; Count: ", checkpointCountFromRootChain);
} else {
console.log("📍Awaiting Checkpoint 🚌")
console.log("📍Awaiting Checkpoint on Root chain 🚌")
}


var firstStateSyncTx = await checkStateSyncTx(machine0,1);
if (firstStateSyncTx) {
let timeOfFirstStateSyncTx = firstStateSyncTx.record_time
Expand Down