feat: use EboRegistry interface

packages/automated-dispute/src/eboActor.ts

@@ -2,8 +2,8 @@ import { BlockNumberService } from "@ebo-agent/blocknumber";
 import { Caip2ChainId } from "@ebo-agent/blocknumber/dist/types.js";
 import { ILogger } from "@ebo-agent/shared";
 
-import { EboRegistry } from "./eboRegistry.js";
 import { RequestMismatch } from "./exceptions/requestMismatch.js";
+import { EboRegistry } from "./interfaces/eboRegistry.js";
 import { ProtocolProvider } from "./protocolProvider.js";
 import { EboEvent } from "./types/events.js";
 import { Dispute, Response } from "./types/prophet.js";
@@ -37,9 +37,7 @@ export class EboActor {
             chainId,
         );
 
-        if (this.alreadyProposed(currentEpoch, chainId, epochBlockNumber)) {
-            return;
-        }
+        if (this.alreadyProposed(currentEpoch, chainId, epochBlockNumber)) return;
 
         await this.protocolProvider.proposeResponse(
             this.requestId,

packages/automated-dispute/src/eboRegistry.ts → packages/automated-dispute/src/eboMemoryRegistry.ts

@@ -1,6 +1,7 @@
+import { EboRegistry } from "./interfaces/eboRegistry.js";
 import { Dispute, Request, Response } from "./types/prophet.js";
 
-export class EboRegistry {
+export class EboMemoryRegistry implements EboRegistry {
     private requests: Map<string, Request>;
     private responses: Map<string, Response>;
     private dispute: Map<string, Dispute>;
@@ -11,21 +12,10 @@ export class EboRegistry {
         this.dispute = new Map();
     }
 
-    /**
-     * Add a `Request` by ID.
-     *
-     * @param requestId the ID of the `Request`
-     * @param request the `Request`
-     */
     public addRequest(requestId: string, request: Request) {
         this.requests.set(requestId, request);
     }
 
-    /**
-     * Return all responses
-     *
-     * @returns responses map
-     */
     public getResponses() {
         return this.responses;
     }

packages/automated-dispute/src/interfaces/eboRegistry.ts

@@ -0,0 +1,18 @@
+import { Request, Response } from "../types/prophet.js";
+
+export interface EboRegistry {
+    /**
+     * Add a `Request` by ID.
+     *
+     * @param requestId the ID of the `Request`
+     * @param request the `Request`
+     */
+    addRequest(requestId: string, request: Request): void;
+
+    /**
+     * Return all responses
+     *
+     * @returns responses map
+     */
+    getResponses(): Map<string, Response>;
+}

packages/automated-dispute/tests/eboActor.spec.ts

@@ -2,10 +2,10 @@ import { BlockNumberService } from "@ebo-agent/blocknumber";
 import { Caip2ChainId } from "@ebo-agent/blocknumber/dist/types.js";
 import { Logger } from "@ebo-agent/shared";
 import { Address } from "viem";
-import { beforeEach, describe, expect, it, Mock, vi } from "vitest";
+import { beforeEach, describe, expect, it, vi } from "vitest";
 
 import { EboActor } from "../src/eboActor.js";
-import { EboRegistry } from "../src/eboRegistry.js";
+import { EboMemoryRegistry } from "../src/eboMemoryRegistry.js";
 import { RequestMismatch } from "../src/exceptions/requestMismatch.js";
 import { ProtocolProvider } from "../src/protocolProvider.js";
 import { EboEvent } from "../src/types/events.js";
@@ -52,7 +52,7 @@ describe("EboActor", () => {
 
         let protocolProvider: ProtocolProvider;
         let blockNumberService: BlockNumberService;
-        let registry: EboRegistry;
+        let registry: EboMemoryRegistry;
 
         beforeEach(() => {
             protocolProvider = new ProtocolProvider(["http://localhost:8538"], protocolContracts);
@@ -61,7 +61,7 @@ describe("EboActor", () => {
             chainRpcUrls.set(indexedChainId, ["http://localhost:8539"]);
 
             blockNumberService = new BlockNumberService(chainRpcUrls, logger);
-            registry = new EboRegistry();
+            registry = new EboMemoryRegistry();
         });
 
         it("proposes a response", async () => {