fix: handle decoding errors

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

@@ -1,21 +1,20 @@
+export * from "./blockNumberServiceRequired.exception.js";
+export * from "./customContractError.js";
+export * from "./decodeLogDataFailure.js";
 export * from "./eboActor/index.js";
 export * from "./eboProcessor/index.js";
 export * from "./eboRegistry/index.js";
-
+export * from "./errorFactory.js";
+export * from "./invalidAccountOnClient.exception.js";
 export * from "./invalidActorState.exception.js";
+export * from "./invalidBlockHash.exception.js";
+export * from "./invalidBlockRangeError.exception.js";
 export * from "./invalidDisputeStatus.exception.js";
+export * from "./prophetDecodingError.exception.js";
 export * from "./requestAlreadyHandled.exception.js";
 export * from "./requestMismatch.exception.js";
 export * from "./responseAlreadyProposed.exception.js";
 export * from "./rpcUrlsEmpty.exception.js";
 export * from "./transactionExecutionError.exception.js";
-export * from "./invalidAccountOnClient.exception.js";
-export * from "./unsupportedEvent.exception.js";
-export * from "./decodeLogDataFailure.js";
-export * from "./invalidBlockRangeError.exception.js";
 export * from "./unknownCustomError.exception.js";
-export * from "./invalidBlockHash.exception.js";
-export * from "./unknownDisputeStatus.exception.js";
-export * from "./blockNumberServiceRequired.exception.js";
-export * from "./customContractError.js";
-export * from "./errorFactory.js";
+export * from "./unsupportedEvent.exception.js";

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

@@ -0,0 +1,13 @@
+import { ByteArray, Hex } from "viem";
+
+export class ProphetDecodingError extends Error {
+    constructor(
+        public readonly id: string,
+        public readonly data: ByteArray | Hex,
+        public readonly err?: Error,
+    ) {
+        super(`Failed to decode ${id} with data ${data}.`);
+
+        this.name = "ProphetDecodingError";
+    }
+}

packages/automated-dispute/src/providers/protocolProvider.ts

@@ -49,7 +49,6 @@ import {
     RpcUrlsEmpty,
     TransactionExecutionError,
 } from "../exceptions/index.js";
-import { ProphetCodec } from "../external.js";
 import {
     IProtocolProvider,
     IReadProvider,
@@ -467,7 +466,7 @@ export class ProtocolProvider implements IProtocolProvider {
                             responseId: HexUtils.normalize(_dispute.responseId) as ResponseId,
                             requestId: HexUtils.normalize(_dispute.requestId) as RequestId,
                         },
-                        status: ProphetCodec.decodeDisputeStatus(_status),
+                        status: _status,
                         blockNumber: event.blockNumber,
                     },
                 } as EboEvent<"DisputeStatusUpdated">;

packages/automated-dispute/src/services/eboActor.ts

@@ -23,6 +23,7 @@ import {
     InvalidActorState,
     InvalidDisputeStatus,
     PastEventEnqueueError,
+    ProphetDecodingError,
     RequestMismatch,
     ResponseAlreadyProposed,
     ResponseNotFound,
@@ -149,9 +150,26 @@ export class EboActor {
             while ((event = this.eventsQueue.pop())) {
                 this.lastEventProcessed = event;
 
-                const updateStateCommand = this.buildUpdateStateCommand(event);
+                let updateStateCommand: EboRegistryCommand;
 
-                updateStateCommand.run();
+                try {
+                    updateStateCommand = this.buildUpdateStateCommand(event);
+                    updateStateCommand.run();
+                } catch (err) {
+                    if (err instanceof ProphetDecodingError) {
+                        // Skipping malformed entities
+                        this.logger.warn(
+                            stringify({
+                                reason: err.err?.name,
+                                message: err.message,
+                            }),
+                        );
+
+                        continue;
+                    } else {
+                        throw err;
+                    }
+                }
 
                 try {
                     if (this.eventsQueue.isEmpty()) {
@@ -391,12 +409,12 @@ export class EboActor {
     private getActiveDisputes(): Dispute[] {
         const disputes = this.registry.getDisputes();
 
-        return disputes.filter((dispute) => dispute.status === "Active");
+        return disputes.filter((dispute) => dispute.decodedData.status === "Active");
     }
 
     // TODO: extract this into another service
     private canBeSettled(request: Request, dispute: Dispute, atTimestamp: UnixTimestamp): boolean {
-        if (dispute.status !== "Active") return false;
+        if (dispute.decodedData.status !== "Active") return false;
 
         const { bondEscalationDeadline, tyingBuffer } = request.decodedData.disputeModuleData;
         const deadline = (dispute.createdAt.timestamp +
@@ -499,7 +517,7 @@ export class EboActor {
         // Response is still able to be disputed
         if (atTimestamp <= disputeWindow) return false;
 
-        return dispute ? ["Lost", "None"].includes(dispute.status) : true;
+        return dispute ? ["Lost", "None"].includes(dispute.decodedData.status) : true;
     }
 
     /**
@@ -548,7 +566,7 @@ export class EboActor {
             // the proposal non-active.
             const activeStatus: DisputeStatus[] = ["None", "Active"];
 
-            return activeStatus.includes(dispute.status);
+            return activeStatus.includes(dispute.decodedData.status);
         });
     }
 
@@ -941,7 +959,7 @@ export class EboActor {
     private async onDisputeStatusChanged(event: EboEvent<"DisputeStatusUpdated">): Promise<void> {
         const request = this.getActorRequest();
         const disputeId = event.metadata.disputeId;
-        const disputeStatus = event.metadata.status;
+        const disputeStatus = ProphetCodec.decodeDisputeStatus(event.metadata.status);
 
         this.logger.info(`Dispute ${disputeId} status changed to ${disputeStatus}.`);
 

packages/automated-dispute/src/services/eboProcessor.ts

@@ -177,6 +177,7 @@ export class EboProcessor {
         const currentEpoch = await this.protocolProvider.getCurrentEpoch();
 
         this.logger.info(`Current epoch fetched.`);
+        this.logger.debug(stringify(currentEpoch));
 
         return currentEpoch;
     }

packages/automated-dispute/src/services/eboRegistry/commands/addDispute.ts

@@ -21,7 +21,9 @@ export class AddDispute implements EboRegistryCommand {
                 blockNumber: event.blockNumber,
                 logIndex: event.logIndex,
             },
-            status: "Active",
+            decodedData: {
+                status: "Active",
+            },
             prophetData: event.metadata.dispute,
         };
 

packages/automated-dispute/src/services/eboRegistry/commands/updateDisputeStatus.ts

@@ -1,6 +1,7 @@
 import { CommandAlreadyRun, CommandNotRun, DisputeNotFound } from "../../../exceptions/index.js";
 import { EboRegistry, EboRegistryCommand } from "../../../interfaces/index.js";
 import { DisputeStatus, EboEvent, EboEventName } from "../../../types/index.js";
+import { ProphetCodec } from "../../prophetCodec.js";
 
 export class UpdateDisputeStatus implements EboRegistryCommand {
     private wasRun: boolean = false;
@@ -19,7 +20,7 @@ export class UpdateDisputeStatus implements EboRegistryCommand {
         const disputeId = event.metadata.disputeId;
 
         const status = this.isDisputeStatusChangedEvent(event)
-            ? event.metadata.status
+            ? ProphetCodec.decodeDisputeStatus(event.metadata.status)
             : "Escalated";
 
         return new UpdateDisputeStatus(registry, disputeId, status);
@@ -38,7 +39,7 @@ export class UpdateDisputeStatus implements EboRegistryCommand {
 
         if (!dispute) throw new DisputeNotFound(this.disputeId);
 
-        this.previousStatus = dispute.status;
+        this.previousStatus = dispute.decodedData.status;
 
         this.registry.updateDisputeStatus(this.disputeId, this.status);
 

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

@@ -96,7 +96,9 @@ export class EboMemoryRegistry implements EboRegistry {
 
         this.disputes.set(disputeId, {
             ...dispute,
-            status: status,
+            decodedData: {
+                status: status,
+            },
         });
     }
 

packages/automated-dispute/src/services/prophetCodec.ts

@@ -1,7 +1,15 @@
 import { Caip2ChainId } from "@ebo-agent/shared";
-import { Address, decodeAbiParameters, encodeAbiParameters } from "viem";
+import {
+    AbiParameter,
+    Address,
+    ByteArray,
+    decodeAbiParameters,
+    encodeAbiParameters,
+    Hex,
+    toHex,
+} from "viem";
 
-import { UnknownDisputeStatus } from "../exceptions/unknownDisputeStatus.exception.js";
+import { ProphetDecodingError } from "../exceptions/index.js";
 import { DisputeStatus, Request, Response } from "../types/prophet.js";
 
 const REQUEST_MODULE_DATA_REQUEST_ABI_FIELDS = [
@@ -60,6 +68,27 @@ const DISPUTE_STATUS_ENUM: DisputeStatus[] = [
 
 /** Class to encode/decode Prophet's structs into/from a byte array */
 export class ProphetCodec {
+    /**
+     * Decodes byte-serialized data.
+     *
+     * @param id identifier of the decoding to be used in case it fails
+     * @param params abi fields to use for decoding
+     * @param data data to be decoded
+     * @throws {ProphetDecodingError}
+     * @returns the decoded data
+     */
+    private static decode<const params extends readonly AbiParameter[]>(
+        id: string,
+        params: params,
+        data: ByteArray | Hex,
+    ) {
+        try {
+            return decodeAbiParameters(params, data);
+        } catch (err) {
+            throw new ProphetDecodingError(id, data, err instanceof Error ? err : undefined);
+        }
+    }
+
     /**
      * Decodes the request's request module data bytes into an object.
      *
@@ -70,7 +99,8 @@ export class ProphetCodec {
     static decodeRequestRequestModuleData(
         requestModuleData: Request["prophetData"]["requestModuleData"],
     ): Request["decodedData"]["requestModuleData"] {
-        const decodeParameters = decodeAbiParameters(
+        const decodeParameters = this.decode(
+            "request.requestModuleData",
             REQUEST_MODULE_DATA_REQUEST_ABI_FIELDS,
             requestModuleData,
         );
@@ -107,7 +137,8 @@ export class ProphetCodec {
     static decodeRequestResponseModuleData(
         responseModuleData: Request["prophetData"]["responseModuleData"],
     ): Request["decodedData"]["responseModuleData"] {
-        const decodedParameters = decodeAbiParameters(
+        const decodedParameters = this.decode(
+            "request.responseModuleData",
             RESPONSE_MODULE_DATA_REQUEST_ABI_FIELDS,
             responseModuleData,
         );
@@ -138,7 +169,8 @@ export class ProphetCodec {
     static decodeRequestDisputeModuleData(
         disputeModuleData: Request["prophetData"]["disputeModuleData"],
     ): Request["decodedData"]["disputeModuleData"] {
-        const decodedParameters = decodeAbiParameters(
+        const decodedParameters = this.decode(
+            "request.disputeModuleData",
             DISPUTE_MODULE_DATA_REQUEST_ABI_FIELDS,
             disputeModuleData,
         );
@@ -182,7 +214,11 @@ export class ProphetCodec {
     static decodeResponse(
         response: Response["prophetData"]["response"],
     ): Response["decodedData"]["response"] {
-        const decodedParameters = decodeAbiParameters(RESPONSE_RESPONSE_ABI_FIELDS, response);
+        const decodedParameters = this.decode(
+            "response.response",
+            RESPONSE_RESPONSE_ABI_FIELDS,
+            response,
+        );
 
         return {
             block: decodedParameters[0],
@@ -201,9 +237,23 @@ export class ProphetCodec {
      * @returns The DisputeStatus string corresponding to the input value.
      */
     static decodeDisputeStatus(status: number): DisputeStatus {
-        const disputeStatus = DISPUTE_STATUS_ENUM[status];
+        const disputeStatus: DisputeStatus | undefined = DISPUTE_STATUS_ENUM[status];
+
+        if (disputeStatus) return disputeStatus;
+        else throw new ProphetDecodingError("dispute.status", toHex(status.toString()));
+    }
+
+    /**
+     * Encodes a DisputeStatus string into its enum uint8 index.
+     *
+     * @param {Response["prophetData"]["response"]} response - The response body bytes.
+     * @throws {DecodeAbiParametersErrorType}
+     * @returns {Response["decodedData"]["response"]} Decoded response body object.
+     */
+    static encodeDisputeStatus(status: DisputeStatus): number {
+        const index = DISPUTE_STATUS_ENUM.indexOf(status);
 
-        if (!disputeStatus) throw new UnknownDisputeStatus(status);
-        else return disputeStatus;
+        // TODO: throw ProphetEncodingError
+        return index;
     }
 }

packages/automated-dispute/src/types/events.ts

@@ -1,15 +1,7 @@
 import { UnixTimestamp } from "@ebo-agent/shared";
 import { Address, Hex, Log } from "viem";
 
-import {
-    Dispute,
-    DisputeId,
-    DisputeStatus,
-    Request,
-    RequestId,
-    Response,
-    ResponseId,
-} from "./prophet.js";
+import { Dispute, DisputeId, Request, RequestId, Response, ResponseId } from "./prophet.js";
 
 export type EboEventName =
     | "RequestCreated"
@@ -40,7 +32,7 @@ export interface ResponseDisputed {
 export interface DisputeStatusUpdated {
     disputeId: DisputeId;
     dispute: Dispute["prophetData"];
-    status: DisputeStatus;
+    status: number;
     blockNumber: bigint;
 }
 

packages/automated-dispute/src/types/prophet.ts

@@ -96,7 +96,10 @@ export interface Dispute {
         blockNumber: bigint;
         logIndex: number;
     };
-    status: DisputeStatus;
+
+    decodedData: {
+        status: DisputeStatus;
+    };
 
     prophetData: {
         disputer: Address;

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

@@ -196,12 +196,14 @@ export function buildDispute(
 ): Dispute {
     const baseDispute: Dispute = {
         id: "0x01" as DisputeId,
-        status: "Active",
         createdAt: {
             timestamp: (response.createdAt.timestamp + 1n) as UnixTimestamp,
             blockNumber: response.createdAt.blockNumber + 1n,
             logIndex: response.createdAt.logIndex + 1,
         },
+        decodedData: {
+            status: "Active",
+        },
         prophetData: {
             disputer: "0x01",
             proposer: response.prophetData.proposer,