graphprotocol / indexer-rs / 19874975568

64%

push

github

feat: add allocation reconciliation (#882)

* feat(tap-agent): add periodic allocation reconciliation

   Add a background task that periodically triggers allocation
   reconciliation to ensure recovery after subgraph connectivity issues.

   Previously, the allocation watcher was purely event-driven
   and only fired when the allocation list changed. If allocations were
   closed during a connectivity outage and the list became static afterward,
   no messages would fire and stale SenderAllocation actors would keep
   running, never triggering mark_rav_last().

   This change adds:
   - New config option
    (default: 5 min)
   - ReconcileAllocations message type for SenderAccount
   - Periodic task that sends ReconcileAllocations every
   interval
   - Handler that forces re-check of all allocations against
   the watcher

   This ensures closed allocations are detected and RAVs are
   properly marked
   as 'last' for redemption, even after connectivity issues.

* test(tap-agent): add tests and validation for allocation reconciliation

   - Add unit test for ReconcileAllocations message handling that verifies
     it triggers UpdateAllocationIds with current allocations from watcher
   - Add config validation for allocation_reconciliation_interval_secs:
     error if 0, warn if < 60s
   - Add test for periodic task lifecycle verifying task spawn/abort
   - Update create_sender_account() test helper to expose
     indexer_allocations_tx and configurable reconciliation interval
   - Add tokio test-util feature for time control in tests

* chore(tap-agent): add observability improvements for allocation reconciliation

   - Add ALLOCATION_RECONCILIATION_RUNS counter metric
   - Elevate reconciliation logs from debug to info
   - Enhance config documentation explaining the connectivity failure
   scenario

194 of 217 new or added lines in 3 files covered. (89.4%)

9540 of 15053 relevant lines covered (63.38%)

75.38 hits per line