fix: use submitted at epoch to calculate allocation lifetime

packages/indexer-agent/src/agent.ts

@@ -992,7 +992,10 @@ export class Agent {
           .rule?.allocationLifetime
           ? deploymentAllocationDecision.ruleMatch.rule.allocationLifetime
           : maxAllocationDuration
-        return epoch >= allocation.createdAtEpoch + desiredAllocationLifetime
+
+        const lastCollectedEpoch =
+          allocation.lastPresentedPoiEpoch ?? allocation.createdAtEpoch
+        return epoch >= lastCollectedEpoch + desiredAllocationLifetime
       },
     )
     logger.debug('Expired allocations found', {

packages/indexer-common/src/allocations/types.ts

@@ -20,6 +20,7 @@ export interface Allocation {
   poi: string | undefined
   queryFeeRebates: bigint | undefined
   queryFeesCollected: bigint | undefined
+  lastPresentedPoiEpoch: number | undefined
 }
 
 export interface Provision {

packages/indexer-common/src/indexer-management/monitor.ts

@@ -260,6 +260,9 @@ export class NetworkMonitor {
                 closedAt
                 closedAtEpoch
                 createdAtBlockHash
+                pois(first: 1, orderBy: submittedAtEpoch, orderDirection: desc) {
+                  submittedAtEpoch
+                }
                 subgraphDeployment {
                   id
                   stakedTokens

packages/indexer-common/src/indexer-management/types.ts

@@ -139,6 +139,7 @@ export const parseGraphQLAllocation = (
   poi: allocation.poi,
   queryFeeRebates: allocation.queryFeeRebates,
   queryFeesCollected: allocation.queryFeesCollected,
+  lastPresentedPoiEpoch: allocation.pois?.[0]?.submittedAtEpoch,
 })
 
 export const parseGraphQLProvision = (provision: any): Provision => ({