-

Author: LorimerJenkins

src/ao/messaging/DryRunFIFO.ts

@@ -1,4 +1,8 @@
-import { DryRun, DryRunResult, MessageInput } from "@permaweb/aoconnect/dist/lib/dryrun";
+import {
+  DryRun,
+  DryRunResult,
+  MessageInput,
+} from "@permaweb/aoconnect/dist/lib/dryrun";
 import { connect } from "@permaweb/aoconnect";
 
 interface DryRunQueueItem {
@@ -15,9 +19,10 @@ export class DryRunFIFO {
   constructor(CUs: string[], delay = 500) {
     this.#queue = [];
     this.#running = false;
-    this.#availableDryRuns = new DryRunList(CUs.map(
-      (CU_URL) => connect({ MODE: "legacy", CU_URL }).dryrun
-    ), delay);
+    this.#availableDryRuns = new DryRunList(
+      CUs.map((CU_URL) => connect({ MODE: "legacy", CU_URL }).dryrun),
+      delay,
+    );
   }
 
   put(msg: MessageInput) {

src/ao/messaging/getData.ts

@@ -1,4 +1,8 @@
-import { DryRun, DryRunResult, MessageInput } from "@permaweb/aoconnect/dist/lib/dryrun";
+import {
+  DryRun,
+  DryRunResult,
+  MessageInput,
+} from "@permaweb/aoconnect/dist/lib/dryrun";
 import { connectToAO, Services } from "../utils/connect";
 import { dryRunAwait } from "../utils/dryRunAwait";
 import { connect } from "@permaweb/aoconnect";
@@ -44,9 +48,9 @@ export async function getData(
       tags: convertedMessageTags,
       Owner: messageTags.Owner || "1234",
     };
-    const { Messages, Spawns, Output, Error } = LiquidOps.dryRunFifo ?
-        await LiquidOps.dryRunFifo.put(msg) :
-        await dryrun(msg);
+    const { Messages, Spawns, Output, Error } = LiquidOps.dryRunFifo
+      ? await LiquidOps.dryRunFifo.put(msg)
+      : await dryrun(msg);
 
     return {
       Messages,

tests.ts

@@ -1,4 +1,4 @@
-import LiquidOps from "./src";
+import LiquidOps, { DryRunFIFO } from "./src";
 import { ownerToAddress } from "./tests/testsHelpers/arweaveUtils";
 import { createDataItemSigner } from "@permaweb/aoconnect";
 import { formatGlobalPosition } from "./src/ao/utils/formatGlobalPosition";
@@ -9,6 +9,16 @@ if (!process.env.JWK) {
 
 const JWK: any = JSON.parse(process.env.JWK);
 const signer = createDataItemSigner(JWK);
+
+LiquidOps.dryRunFifo = new DryRunFIFO([
+  "https://cu1.ao-testnet.xyz",
+  "https://cu24.ao-testnet.xyz",
+  "https://cu-af.dataos.so",
+  "https://cu.perplex.finance",
+  "https://cu.arweave.asia",
+  "https://cu.ardrive.io",
+]);
+
 const client = new LiquidOps(signer);
 
 const walletAddress = await ownerToAddress(JWK.n);
@@ -80,9 +90,9 @@ const walletAddress = await ownerToAddress(JWK.n);
 
 //--------------------------------------------------------------------------------------------------------------- liquidations
 
-// const getLiquidationsMap = await client.getLiquidationsMap();
+const getLiquidationsMap = await client.getLiquidationsMap();
 
-// console.log(getLiquidationsMap);
+console.log(getLiquidationsMap);
 
 //-------------------------------