fargate done! now replacing docker calls with viem WITHOUT a testnet...

Author: signorecello

tooling/sparta/Dockerfile

@@ -0,0 +1,16 @@
+FROM oven/bun:latest
+
+ENV PATH="/root/.foundry/bin:${PATH}"
+
+RUN apt update && apt install -y curl apt-utils
+RUN curl -fsSL https://get.docker.com | bash
+RUN curl -L https://foundry.paradigm.xyz | bash
+
+RUN foundryup
+RUN cast --version
+
+WORKDIR /app
+COPY src ./
+
+RUN bun install
+CMD ["bun", "run", "start"]

tooling/sparta/src/commands/getChainInfo.ts

@@ -16,6 +16,7 @@ export default {
 		});
 
 		try {
+			console.log("Getting chain info");
 			const {
 				pendingBlockNum,
 				provenBlockNum,

tooling/sparta/src/env.ts

@@ -4,9 +4,7 @@ import dotenv from "dotenv";
 const loadSecrets = async () => {
 	try {
 		console.log("Loading secrets from AWS Secrets Manager");
-		const secretsManager = new SecretsManager({
-			region: process.env.AWS_REGION || "us-west-2",
-		});
+		const secretsManager = new SecretsManager();
 
 		const secretKeys = [
 			"TOKEN",

tooling/sparta/src/package.json

@@ -3,8 +3,8 @@
     "version": "1.0.0",
     "type": "module",
     "scripts": {
-        "build": "tsc",
-        "start": "node dist/index.js",
+        "build": "bun build index.ts --target bun --minify --outdir=dist",
+        "dev": "bun run --watch index.ts",
         "watch": "tsc -w",
         "test": "jest",
         "lint": "eslint . --ext .ts",
@@ -13,7 +13,8 @@
     "dependencies": {
         "@aws-sdk/client-secrets-manager": "^3.529.1",
         "discord.js": "^14.14.1",
-        "dotenv": "^16.3.1"
+        "dotenv": "^16.3.1",
+        "viem": "^2.22.15"
     },
     "devDependencies": {
         "@types/node": "^20.10.5",

tooling/sparta/src/services/chaininfo-service.ts

@@ -1,5 +1,4 @@
-import { exec } from "child_process";
-import { promisify } from "util";
+import { Ethereum } from "../utils/ethereum.js";
 
 type ChainInfo = {
 	pendingBlockNum: string;
@@ -12,39 +11,47 @@ type ChainInfo = {
 	proposerNow: string;
 };
 
-const execAsync = promisify(exec);
-
 export class ChainInfoService {
 	static async getInfo(): Promise<ChainInfo> {
 		try {
-			// Add validator to the set
-			const command = `docker run --rm aztecprotocol/aztec:unhinged-unicorn debug-rollup -u ${process.env.ETHEREUM_HOST} --rollup ${process.env.ETHEREUM_ROLLUP_ADDRESS} --l1-chain-id ${process.env.ETHEREUM_CHAIN_ID} `;
-			const { stdout, stderr } = await execAsync(command);
+			const ethereum = new Ethereum();
+			const rollup = ethereum.getRollupContract();
+			const [
+				pendingNum,
+				provenNum,
+				validators,
+				committee,
+				archive,
+				epochNum,
+				slot,
+				nextBlockTS,
+			] = await Promise.all([
+				rollup.read.getPendingBlockNumber(),
+				rollup.read.getProvenBlockNumber(),
+				rollup.read.getAttesters(),
+				rollup.read.getCurrentEpochCommittee(),
+				rollup.read.archive(),
+				rollup.read.getCurrentEpoch(),
+				rollup.read.getCurrentSlot(),
+				rollup.read.getCurrentProposer(),
+				(async () => {
+					const block = await ethereum.getPublicClient().getBlock();
+					return BigInt(block.timestamp + BigInt(12));
+				})(),
+			]);
 
-			if (stderr) {
-				throw new Error(stderr);
-			}
+			const proposer = await rollup.read.getProposerAt([nextBlockTS]);
 
-			// looks like hell, but it just parses the output of the command
-			// into a key-value object
-			const info = stdout
-				.split("\n")
-				.map((line) => line.trim())
-				.filter(Boolean)
-				.reduce((acc, s) => {
-					let [key, value] = s.split(": ");
-					const sanitizedKey = key
-						.toLowerCase()
-						.replace(/\s+(.)/g, (_, c) => c.toUpperCase());
-					return { ...acc, [sanitizedKey]: value };
-				}, {}) as ChainInfo;
-			if (typeof info.validators === "string") {
-				info.validators = info.validators.split(", ").map(String);
-			}
-			if (typeof info.committee === "string") {
-				info.committee = info.committee.split(", ").map(String);
-			}
-			return info as ChainInfo;
+			return {
+				pendingBlockNum: pendingNum as string,
+				provenBlockNum: provenNum as string,
+				validators: validators as string[],
+				committee: committee as string[],
+				archive: archive as string[],
+				currentEpoch: epochNum as string,
+				currentSlot: slot as string,
+				proposerNow: proposer as string,
+			};
 		} catch (error) {
 			console.error("Error getting chain info:", error);
 			throw error;

tooling/sparta/src/tsconfig.json

@@ -8,7 +8,8 @@
 		"strict": true,
 		"esModuleInterop": true,
 		"skipLibCheck": true,
-		"forceConsistentCasingInFileNames": true
+		"forceConsistentCasingInFileNames": true,
+		"resolveJsonModule": true
 	},
 	"include": ["**/*.ts"],
 	"exclude": ["node_modules", "dist"]

tooling/sparta/src/utils/ethereum.ts

@@ -0,0 +1,54 @@
+import {
+	AbiConstructorNotFoundError,
+	createPublicClient,
+	createWalletClient,
+	getContract,
+	http,
+	PublicClient,
+} from "viem";
+
+import RollupAbi from "./rollupAbi.json";
+
+import {
+	generatePrivateKey,
+	mnemonicToAccount,
+	privateKeyToAccount,
+} from "viem/accounts";
+
+export class Ethereum {
+	public publicClient: PublicClient;
+
+	constructor() {
+		this.publicClient = createPublicClient({
+			chain: {
+				id: process.env.ETHEREUM_CHAIN_ID as unknown as number,
+				name: "Ethereum",
+				rpcUrls: {
+					default: {
+						http: [process.env.ETHEREUM_HOST as unknown as string],
+					},
+				},
+				nativeCurrency: {
+					decimals: 18,
+					name: "Ether",
+					symbol: "ETH",
+				},
+			},
+			transport: http(process.env.ETHEREUM_HOST as unknown as string),
+		});
+	}
+
+	getPublicClient = () => {
+		return this.publicClient;
+	};
+
+	getRollupContract = () => {
+		const rollup = getContract({
+			address: process.env
+				.ETHEREUM_ROLLUP_ADDRESS as unknown as `0x${string}`,
+			abi: RollupAbi.abi,
+			client: this.publicClient,
+		});
+		return rollup;
+	};
+}