Update retrieve checker contract address and add tests for dispute handling

Author: lordshashank

lib/constants.js

@@ -5,5 +5,5 @@ export const MAX_JITTER_BETWEEN_TASKS_IN_MS = 10_000 // 10 seconds
 export const RPC_URL = 'https://api.calibration.node.glif.io/'
 export const RPC_AUTH = 'KZLIUb9ejreYOm-mZFM3UNADE0ux6CrHjxnS2D2Qgb8='
 export const MINER_TO_PEERID_CONTRACT_ADDRESS = '0x14183aD016Ddc83D638425D6328009aa390339Ce' // Contract address on the Filecoin EVM
-export const RETRIEVE_CHECKER_CONTRACT_ADDRESS = '0x917d506cd99c80230d2db53d096491a41d92300e' // Replace with actual address
+export const RETRIEVE_CHECKER_CONTRACT_ADDRESS = '0xD708573EdaeF9B2C4ce5242742bff99C0C3d7298' // Replace with actual address
 export const MAX_REQUEST_DURATION_MS = 90_000

test.js

@@ -2,6 +2,7 @@ import './test/http-assertions.test.js'
 import './test/ipni-client.test.js'
 import './test/miner-info.test.js'
 import './test/multiaddr.test.js'
+import './test/retrieve-checker-client.test.js'
 
 import './test/integration.js'
 import './test/spark.js'

test/retrieve-checker-client.test.js

@@ -0,0 +1,103 @@
+import { test } from 'zinnia:test'
+import { assertEquals, assertRejects } from 'zinnia:assert'
+import { getPendingDisputes, submitDisputeResult } from '../lib/retrieve-checker-client.js'
+// dummy tests as of now
+// Mock environment and contract for testing
+const TEST_PRIVATE_KEY = '0x1234567890abcdef1234567890abcdef1234567890abcdef1234567890abcdef'
+
+// Ensure private key is available in test environment
+Deno.env.set('CHECKER_PRIVATE_KEY', TEST_PRIVATE_KEY)
+
+// Mock contract factory for testing
+function createMockContract(mockDisputes = {}) {
+  return {
+    getDisputesByStatus: async (status) => {
+      return mockDisputes.ids || []
+    },
+    getDisputeDetails: async (id) => {
+      const dispute = mockDisputes[id]
+      if (!dispute) {
+        throw new Error(`Dispute ID ${id} not found`)
+      }
+      return dispute
+    },
+    resolveDispute: async (disputeId, newStatus) => {
+      mockDisputes.resolvedDisputes = mockDisputes.resolvedDisputes || []
+      mockDisputes.resolvedDisputes.push({ disputeId, newStatus })
+      // Return mock transaction and receipt for ethers compatibility
+      return {
+        hash: '0xmocktxhash',
+        wait: async () => ({ blockNumber: 12345 })
+      }
+    }
+  }
+}
+
+test('getPendingDisputes returns empty array when no pending disputes exist', async () => {
+  const mockContract = createMockContract()
+  const result = await getPendingDisputes({ smartContract: mockContract })
+  assertEquals(result, [])
+})
+
+test('getPendingDisputes returns array of pending disputes', async () => {
+  const mockDisputes = {
+    ids: [1, 2],
+    1: {
+      disputeId: 1,
+      cid: '0x' + Buffer.from('QmTest1').toString('hex'),
+      spActorId: 12345
+    },
+    2: {
+      disputeId: 2,
+      cid: '0x' + Buffer.from('QmTest2').toString('hex'),
+      spActorId: 67890
+    }
+  }
+  const mockContract = createMockContract(mockDisputes)
+  
+  const result = await getPendingDisputes({ smartContract: mockContract })
+  assertEquals(result, [
+    { id: '1', cid: 'QmTest1', minerId: 'f012345' },
+    { id: '2', cid: 'QmTest2', minerId: 'f067890' }
+  ])
+})
+
+test('submitDisputeResult resolves dispute with correct status for successful retrieval', async () => {
+  const mockDisputes = { resolvedDisputes: [] }
+  const mockContract = createMockContract(mockDisputes)
+  
+  await submitDisputeResult(1, { statusCode: 200 }, { smartContract: mockContract })
+  assertEquals(mockDisputes.resolvedDisputes, [
+    { disputeId: 1, newStatus: 2 } // DisputeStatus.Resolved
+  ])
+})
+
+test('submitDisputeResult resolves dispute with failed status for timeout', async () => {
+  const mockDisputes = { resolvedDisputes: [] }
+  const mockContract = createMockContract(mockDisputes)
+  
+  await submitDisputeResult(1, { statusCode: 200, timeout: true }, { smartContract: mockContract })
+  assertEquals(mockDisputes.resolvedDisputes, [
+    { disputeId: 1, newStatus: 3 } // DisputeStatus.Failed
+  ])
+})
+
+test('submitDisputeResult resolves dispute with failed status for error response', async () => {
+  const mockDisputes = { resolvedDisputes: [] }
+  const mockContract = createMockContract(mockDisputes)
+  
+  await submitDisputeResult(1, { statusCode: 404 }, { smartContract: mockContract })
+  assertEquals(mockDisputes.resolvedDisputes, [
+    { disputeId: 1, newStatus: 3 } // DisputeStatus.Failed
+  ])
+})
+
+test('submitDisputeResult resolves dispute with rejected status for invalid check', async () => {
+  const mockDisputes = { resolvedDisputes: [] }
+  const mockContract = createMockContract(mockDisputes)
+  
+  await submitDisputeResult(1, { statusCode: 302 }, { smartContract: mockContract })
+  assertEquals(mockDisputes.resolvedDisputes, [
+    { disputeId: 1, newStatus: 4 } // DisputeStatus.Rejected
+  ])
+})