feat: implement get events (#50)

apps/agent/src/config/schemas.ts

@@ -1,4 +1,4 @@
-import { Caip2ChainId, Caip2Utils } from "@ebo-agent/blocknumber/src/index.js";
+import { Caip2ChainId, Caip2Utils } from "@ebo-agent/blocknumber";
 import { isAddress, isHex } from "viem";
 import { z } from "zod";
 

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

@@ -0,0 +1,7 @@
+export class DecodeLogDataFailure extends Error {
+    constructor(err: unknown) {
+        super(`Error decoding log data: ${err}`);
+
+        this.name = "DecodeLogDataFailure";
+    }
+}

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

@@ -10,6 +10,9 @@ 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 "./customContractError.js";
 export * from "./errorFactory.js";

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

@@ -0,0 +1,8 @@
+export class InvalidBlockRangeError extends Error {
+    constructor(fromBlock: bigint, toBlock: bigint) {
+        super(
+            `Invalid block range: fromBlock (${fromBlock}) must be less than or equal to toBlock (${toBlock})`,
+        );
+        this.name = "InvalidBlockRangeError";
+    }
+}

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

@@ -0,0 +1,6 @@
+export class UnsupportedEvent extends Error {
+    constructor(message: string) {
+        super(message);
+        this.name = "UnsupportedEvent";
+    }
+}

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

@@ -1,7 +1,15 @@
 import { Caip2ChainId } from "@ebo-agent/blocknumber";
 import { Address, Block } from "viem";
 
-import type { Dispute, EboEvent, EboEventName, Epoch, Request, Response } from "../types/index.js";
+import type {
+    Dispute,
+    EboEvent,
+    EboEventName,
+    Epoch,
+    Request,
+    RequestId,
+    Response,
+} from "../types/index.js";
 import { ProtocolContractsNames } from "../constants.js";
 
 export type ProtocolContract = (typeof ProtocolContractsNames)[number];
@@ -194,3 +202,79 @@ export interface IProtocolProvider {
      */
     read: IReadProvider;
 }
+
+/**
+ * @type DecodedLogArgsMap
+ * Represents the mapping of event names to their respective argument structures.
+ */
+export type DecodedLogArgsMap = {
+    /**
+     * Event arguments for the RequestCreated event.
+     * @property {RequestId} requestId - The ID of the request.
+     * @property {bigint} epoch - The epoch time when the request was created.
+     * @property {Caip2ChainId} chainId - The chain ID where the request was created.
+     */
+    RequestCreated: {
+        requestId: RequestId;
+        epoch: bigint;
+        chainId: Caip2ChainId;
+    };
+
+    /**
+     * Event arguments for the ResponseProposed event.
+     * @property {RequestId} requestId - The ID of the request.
+     * @property {string} responseId - The ID of the response.
+     * @property {string} response - The response content.
+     */
+    ResponseProposed: {
+        requestId: RequestId;
+        responseId: string;
+        response: string;
+    };
+
+    /**
+     * Event arguments for the ResponseDisputed event.
+     * @property {string} responseId - The ID of the response.
+     * @property {string} disputeId - The ID of the dispute.
+     * @property {string} dispute - The dispute content.
+     */
+    ResponseDisputed: {
+        responseId: string;
+        disputeId: string;
+        dispute: string;
+    };
+
+    /**
+     * Event arguments for the DisputeStatusUpdated event.
+     * @property {string} disputeId - The ID of the dispute.
+     * @property {string} dispute - The dispute content.
+     * @property {number} status - The new status of the dispute.
+     */
+    DisputeStatusUpdated: {
+        disputeId: string;
+        dispute: string;
+        status: number;
+    };
+
+    /**
+     * Event arguments for the DisputeEscalated event.
+     * @property {string} caller - The address of the caller who escalated the dispute.
+     * @property {string} disputeId - The ID of the dispute.
+     */
+    DisputeEscalated: {
+        caller: string;
+        disputeId: string;
+    };
+
+    /**
+     * Event arguments for the OracleRequestFinalized event.
+     * @property {RequestId} requestId - The ID of the request.
+     * @property {string} responseId - The ID of the response.
+     * @property {string} caller - The address of the caller who finalized the request.
+     */
+    OracleRequestFinalized: {
+        requestId: RequestId;
+        responseId: string;
+        caller: string;
+    };
+};