test(actions): add unit tests for PRESENT_POI action type

Add tests for the new PRESENT_POI action type covering:
- Building action input with correct structure
- POI parameter normalization (zero values)
- Block number validation
- Required field validation
- Database action insertion and querying
- Filter generation for action queries

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: MoonBoi9001

packages/indexer-cli/src/__tests__/actions.unit.test.ts

@@ -0,0 +1,106 @@
+import { ActionStatus, ActionType } from '@graphprotocol/indexer-common'
+import { buildActionInput, validateActionInput } from '../actions'
+
+describe('buildActionInput', () => {
+  test('builds PRESENT_POI action input with correct structure', async () => {
+    const result = await buildActionInput(
+      ActionType.PRESENT_POI,
+      {
+        targetDeployment: 'QmTest123',
+        param1: '0xallocationId',
+        param2: '0x' + 'ab'.repeat(32), // poi
+        param3: 'false', // force
+        param4: '12345', // blockNumber
+        param5: '0x' + 'cd'.repeat(32), // publicPOI
+        param6: undefined,
+      },
+      'test',
+      'test',
+      ActionStatus.QUEUED,
+      0,
+      'arbitrum-sepolia',
+    )
+    expect(result.type).toBe(ActionType.PRESENT_POI)
+    expect(result.deploymentID).toBe('QmTest123')
+    expect(result.allocationID).toBe('0xallocationId')
+    expect(result.poiBlockNumber).toBe(12345)
+  })
+
+  test('normalizes zero POI values for PRESENT_POI', async () => {
+    const result = await buildActionInput(
+      ActionType.PRESENT_POI,
+      {
+        targetDeployment: 'QmTest123',
+        param1: '0xallocationId',
+        param2: '0', // poi = '0'
+        param3: 'false',
+        param4: undefined,
+        param5: '0x0', // publicPOI = '0x0'
+        param6: undefined,
+      },
+      'test',
+      'test',
+      ActionStatus.QUEUED,
+      0,
+      'arbitrum-sepolia',
+    )
+    const zeroPOI = '0x' + '00'.repeat(32)
+    expect(result.poi).toBe(zeroPOI)
+    expect(result.publicPOI).toBe(zeroPOI)
+    expect(result.force).toBe(false)
+    expect(result.allocationID).toBe('0xallocationId')
+    expect(result.poiBlockNumber).toBeUndefined()
+  })
+})
+
+describe('validateActionInput', () => {
+  test('validates PRESENT_POI with required fields', async () => {
+    await expect(
+      validateActionInput(ActionType.PRESENT_POI, {
+        targetDeployment: 'QmTest123',
+        param1: '0xallocationId',
+        param2: undefined,
+        param3: undefined,
+        param4: undefined,
+        param5: undefined,
+        param6: undefined,
+      }),
+    ).resolves.not.toThrow()
+  })
+
+  test('rejects PRESENT_POI with invalid block number', async () => {
+    await expect(
+      buildActionInput(
+        ActionType.PRESENT_POI,
+        {
+          targetDeployment: 'QmTest123',
+          param1: '0xallocationId',
+          param2: undefined,
+          param3: undefined,
+          param4: 'not-a-number', // invalid blockNumber
+          param5: undefined,
+          param6: undefined,
+        },
+        'test',
+        'test',
+        ActionStatus.QUEUED,
+        0,
+        'arbitrum-sepolia',
+      ),
+    ).rejects.toThrow('Invalid block number: not-a-number')
+  })
+
+  test('rejects PRESENT_POI missing allocationID', async () => {
+    await expect(
+      validateActionInput(ActionType.PRESENT_POI, {
+        targetDeployment: 'QmTest123',
+        param1: undefined, // missing allocationID
+        param2: undefined,
+        param3: undefined,
+        param4: undefined,
+        param5: undefined,
+        param6: undefined,
+      }),
+    ).rejects.toThrow()
+  })
+})

packages/indexer-common/src/indexer-management/__tests__/helpers.test.ts

@@ -29,7 +29,9 @@ import {
   resolveChainId,
   SubgraphDeployment,
   getTestProvider,
+  IndexingStatusCode,
 } from '@graphprotocol/indexer-common'
+import { encodeCollectData } from '../allocations'
 import { mockLogger, mockProvider } from '../../__tests__/subgraph.test'
 import { hexlify, Provider } from 'ethers'
 import {
@@ -293,7 +295,52 @@ describe('Actions', () => {
       }),
     ).resolves.toHaveLength(1)
   })
+
+  test('Insert and fetch PRESENT_POI action', async () => {
+    const action = {
+      status: ActionStatus.QUEUED,
+      type: ActionType.PRESENT_POI,
+      deploymentID: 'QmQ44hgrWWt3Qf2X9XEX2fPyTbmQbChxwNm5c1t4mhKpGt',
+      allocationID: '0x1234567890123456789012345678901234567890',
+      force: false,
+      source: 'indexerAgent',
+      reason: 'test',
+      priority: 0,
+      protocolNetwork: 'eip155:421614',
+      isLegacy: false,
+    }
+    await models.Action.upsert(action)
+    await expect(
+      ActionManager.fetchActions(models, null, { type: ActionType.PRESENT_POI }),
+    ).resolves.toHaveLength(1)
+  })
+
+  test('Generate where options for PRESENT_POI', () => {
+    const filter = {
+      status: ActionStatus.QUEUED,
+      type: ActionType.PRESENT_POI,
+    }
+    expect(actionFilterToWhereOptions(filter)).toEqual({
+      [Op.and]: [{ status: 'queued' }, { type: 'present_poi' }],
+    })
+  })
 })
+
+describe('Encoding', () => {
+  test('encodeCollectData encodes POI data correctly', () => {
+    const allocationId = '0x1234567890123456789012345678901234567890'
+    const poiData = {
+      poi: '0x' + 'ab'.repeat(32),
+      publicPOI: '0x' + 'cd'.repeat(32),
+      blockNumber: 12345,
+      indexingStatus: IndexingStatusCode.Healthy,
+    }
+    const result = encodeCollectData(allocationId, poiData)
+    expect(result).toMatch(/^0x/)
+    expect(result.length).toBeGreaterThan(2)
+  })
+})
+
 describe('Types', () => {
   test('Fail to resolve chain id', () => {
     expect(() => resolveChainId('arbitrum')).toThrow(