feat: handle invalid state for duplicate request

packages/automated-dispute/src/eboActor.ts

@@ -3,6 +3,7 @@ import { Caip2ChainId } from "@ebo-agent/blocknumber/dist/types.js";
 import { ILogger } from "@ebo-agent/shared";
 import { ContractFunctionRevertedError } from "viem";
 
+import { InvalidActorState } from "./exceptions/invalidActorState.exception.js";
 import { RequestMismatch } from "./exceptions/requestMismatch.js";
 import { EboRegistry } from "./interfaces/eboRegistry.js";
 import { ProtocolProvider } from "./protocolProvider.js";
@@ -27,6 +28,14 @@ export class EboActor {
         if (event.metadata.requestId != this.requestId)
             throw new RequestMismatch(this.requestId, event.metadata.requestId);
 
+        if (this.registry.getRequest(event.metadata.requestId)) {
+            this.logger.error(
+                `The request ${event.metadata.requestId} was already being handled by an actor.`,
+            );
+
+            throw new InvalidActorState();
+        }
+
         this.registry.addRequest(event.metadata.requestId, event.metadata.request);
 
         if (this.anyActiveProposal()) {

packages/automated-dispute/src/exceptions/index.ts

@@ -1 +1,2 @@
 export * from "./rpcUrlsEmpty.exception.js";
+export * from "./invalidActorState.exception.js";

packages/automated-dispute/src/exceptions/invalidActorState.exception.ts

@@ -0,0 +1,8 @@
+export class InvalidActorState extends Error {
+    constructor() {
+        // TODO: we'll want to dump the Actor state into stderr at this point
+        super("The actor is in an invalid state.");
+
+        this.name = "InvalidActorState";
+    }
+}

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

@@ -10,6 +10,13 @@ export interface EboRegistry {
      */
     addRequest(requestId: string, request: Request): void;
 
+    /**
+     * Get a `Request` by ID.
+     *
+     * @param requestId request ID
+     */
+    getRequest(requestId: string): Request;
+
     /**
      * Return all responses
      *