prepare systems for deploy

Author: frolic

packages/cli/src/commands/mirror.ts

@@ -33,7 +33,11 @@ const options = {
   },
   fromIndexer: {
     type: "string",
-    desc: "MUD indexer URL of source chain to mirror from.",
+    desc: "MUD indexer URL of source chain to mirror from. Used to fetch table data.",
+  },
+  fromBlockscout: {
+    type: "string",
+    desc: "Blockscout URL of source chain to mirror from. Used to fetch contract init code.",
   },
   toWorld: {
     type: "string",
@@ -67,11 +71,21 @@ const commandModule: CommandModule<Options, Options> = {
       pollingInterval: 500,
     });
     const fromChainId = await getChainId(fromClient);
-    const fromIndexer = opts.fromIndexer ?? defaultChains.find((chain) => chain.id === fromChainId)?.indexerUrl;
+    const fromChain = defaultChains.find((chain) => chain.id === fromChainId);
+    const fromIndexer = opts.fromIndexer ?? fromChain?.indexerUrl;
     if (!fromIndexer) {
       throw new MUDError(`No \`--fromIndexer\` provided or indexer URL configured for chain ${fromChainId}.`);
     }
 
+    const fromBlockscout = opts.fromBlockscout
+      ? ({ name: "Blockscout", url: opts.fromBlockscout } as const)
+      : fromChain?.blockExplorers.default;
+    if (!fromBlockscout || fromBlockscout.name !== "Blockscout") {
+      throw new MUDError(
+        `No \`--fromBlockscout\` provided or Blockscout block explorer URL configured for chain ${fromChainId}.`,
+      );
+    }
+
     const account = await (async () => {
       if (opts.kms) {
         const keyId = process.env.AWS_KMS_KEY_ID;
@@ -121,6 +135,7 @@ const commandModule: CommandModule<Options, Options> = {
         indexer: fromIndexer,
         world: fromWorld,
         block: opts.fromBlock != null ? BigInt(opts.fromBlock) : undefined,
+        blockscout: fromBlockscout.url,
       },
       to: {
         client: toClient,

packages/cli/src/mirror/common.ts

@@ -6,15 +6,12 @@ import { StoreLog } from "@latticexyz/store";
 export const mirrorPlansDirectory = `${mudDataDirectory}/mirror-plans`;
 
 export type PlanStep =
-  | { step: "mirror"; chainId: number; worldAddress: Address }
   | { step: "deploySystem"; system: DeployedSystem; bytecode: DeployedBytecode }
-  | { step: "start:setRecords" }
-  | { step: "setRecord"; record: Extract<StoreLog, { eventName: "Store_SetRecord" }>["args"] }
-  | { step: "end:setRecords" };
+  | { step: "setRecord"; record: Extract<StoreLog, { eventName: "Store_SetRecord" }>["args"] };
 
 export type DeployedBytecode = {
   address: Address;
-  code: Hex;
+  initCode: Hex;
   libraries: {
     offset: number;
     reference: DeployedBytecode;

packages/cli/src/mirror/createMirrorPlan.ts

@@ -26,20 +26,19 @@ export async function createMirrorPlan({
     world: Address;
     client: Client;
     indexer: string;
+    blockscout: string;
   };
 }) {
   const fromChainId = await getChainId(from.client);
 
   const planFilename = path.join(rootDir, mirrorPlansDirectory, `${fromChainId}_${from.world.toLowerCase()}.ndjson.gz`);
-  return planFilename;
   await mkdir(path.dirname(planFilename), { recursive: true });
 
   const plan = createPlanWriter(planFilename);
 
   const makePlan = (async () => {
-    plan.write({ step: "mirror", chainId: fromChainId, worldAddress: from.world });
-
     const worldDeploy = await getWorldDeploy(from.client, from.world, from.block);
+
     console.log("getting systems");
     const systems = await getSystems({
       client: from.client,
@@ -51,7 +50,13 @@ export async function createMirrorPlan({
     console.log("getting bytecode for", systems.length, "systems");
     const systemsWithBytecode = await Promise.all(
       systems.map(async (system) => {
-        const bytecode = await getDeployedBytecode({ client: from.client, address: system.address });
+        const bytecode = await getDeployedBytecode({
+          client: from.client,
+          address: system.address,
+          debugLabel: `${resourceToLabel(system)} system`,
+          allowedStorage: ["empty", { worldConsumer: worldDeploy.address }],
+          blockscoutUrl: from.blockscout,
+        });
         return { system, bytecode };
       }),
     );
@@ -70,7 +75,6 @@ export async function createMirrorPlan({
     // TODO: sort tables so that the insert order is correct (e.g. namespaces first)
 
     let count = 0;
-    plan.write({ step: "start:setRecords" });
     for (const table of tables) {
       const logs = await pRetry(() =>
         getRecordsAsLogs<Table>({
@@ -87,7 +91,6 @@ export async function createMirrorPlan({
       }
       count += logs.length;
     }
-    plan.write({ step: "end:setRecords" });
     console.log("got", count, "total record logs");
   })();