Counter Bot (WIP)

contracts/scripts/counterBot.ts

@@ -0,0 +1,76 @@
+import env from "./utils/env";
+import loggerFactory from "./utils/logger";
+import hre = require("hardhat");
+import { KlerosCore, DisputeResolver, SortitionModule } from "../typechain-types";
+import { BigNumber } from "ethers";
+const { ethers } = hre;
+
+const HEARTBEAT_URL = undefined; //env.optionalNoDefault("HEARTBEAT_URL_DISPUTOR_BOT");
+const loggerOptions = env.optionalNoDefault("LOGTAIL_TOKEN_COUNTER_BOT")
+  ? {
+      transportTargetOptions: {
+        target: "@logtail/pino",
+        options: { sourceToken: env.require("LOGTAIL_TOKEN_COUNTER_BOT") },
+        level: env.optional("LOG_LEVEL", "info"),
+      },
+      level: env.optional("LOG_LEVEL", "info"), // for pino-pretty
+    }
+  : {};
+const logger = loggerFactory.createLogger(loggerOptions);
+
+const enum Phase {
+  staking, // No disputes that need drawing.
+  generating, // Waiting for a random number. Pass as soon as it is ready.
+  drawing, // Jurors can be drawn.
+}
+
+export default async function main() {
+  logger.info("Starting up");
+
+  const core = (await ethers.getContract("KlerosCore")) as KlerosCore;
+  const sortition = (await ethers.getContract("SortitionModule")) as SortitionModule;
+  const resolver = (await ethers.getContract("DisputeResolver")) as DisputeResolver;
+
+  if (HEARTBEAT_URL) {
+    logger.debug("Sending heartbeat");
+    fetch(HEARTBEAT_URL);
+  } else {
+    logger.debug("Heartbeat not set up, skipping");
+  }
+
+  const phase = await sortition.phase();
+  const now = (await ethers.provider.getBlock("latest")).timestamp;
+  const lastPhaseChange = await sortition.lastPhaseChange();
+  const durationInPhase = now - lastPhaseChange.toNumber();
+
+  let remainingTimeInPhase: number | undefined;
+
+  if (phase === Phase.staking) {
+    logger.debug("Phase is staking");
+    const disputesWithoutJurors = await sortition.disputesWithoutJurors();
+    if (disputesWithoutJurors.gt(0)) {
+      remainingTimeInPhase = await sortition
+        .minStakingTime()
+        .then((minStakingTime) => (minStakingTime.sub(durationInPhase).lte(0) ? 0 : undefined));
+    }
+  } else {
+    logger.debug("Phase is generating or drawing");
+    remainingTimeInPhase = await sortition
+      .maxDrawingTime()
+      .then((maxDrawingTime) => maxDrawingTime.sub(durationInPhase).toNumber());
+  }
+  logger.info({ phase, durationInPhase, remainingTimeInPhase }, "data");
+  await delay(1000);
+}
+
+const delay = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
+
+main()
+  .then(() => process.exit(0))
+  .catch((error) => {
+    console.error(error);
+    process.exit(1);
+  })
+  .finally(() => {
+    logger.flush();
+  });