[OTE-821] Affiliates roundtable metrics

indexer/services/roundtable/__tests__/tasks/update-affiliate-info.test.ts

@@ -1,3 +1,4 @@
+import { stats } from '@dydxprotocol-indexer/base';
 import {
   dbHelpers,
   testConstants,
@@ -263,6 +264,23 @@ describe('update-affiliate-info', () => {
     const updatedInfo = await AffiliateInfoTable.findById(testConstants.defaultWallet2.address);
     expect(updatedInfo).toEqual(expectedAffiliateInfo);
   });
+
+  it('Successfully records metrics', async () => {
+    jest.spyOn(stats, 'gauge');
+
+    await PersistentCacheTable.create({
+      key: PersistentCacheKeys.AFFILIATE_INFO_UPDATE_TIME,
+      value: DateTime.utc().toISO(),
+    });
+
+    await affiliateInfoUpdateTask();
+
+    expect(stats.gauge).toHaveBeenCalledWith(
+      `roundtable.persistent_cache_${PersistentCacheKeys.AFFILIATE_INFO_UPDATE_TIME}_lag_seconds`,
+      expect.any(Number),
+      { cache: PersistentCacheKeys.AFFILIATE_INFO_UPDATE_TIME },
+    );
+  });
 });
 
 async function getAffiliateInfoUpdateTime(): Promise<DateTime | undefined> {

indexer/services/roundtable/__tests__/tasks/update-wallet-total-volume.test.ts

@@ -1,3 +1,4 @@
+import { stats } from '@dydxprotocol-indexer/base';
 import {
   dbHelpers,
   testConstants,
@@ -222,6 +223,23 @@ describe('update-wallet-total-volume', () => {
       totalVolume: '14', // 1 + 4 + 9
     }));
   });
+
+  it('Successfully records metrics', async () => {
+    jest.spyOn(stats, 'gauge');
+
+    await PersistentCacheTable.create({
+      key: PersistentCacheKeys.TOTAL_VOLUME_UPDATE_TIME,
+      value: DateTime.utc().toISO(),
+    });
+
+    await walletTotalVolumeUpdateTask();
+
+    expect(stats.gauge).toHaveBeenCalledWith(
+      `roundtable.persistent_cache_${PersistentCacheKeys.TOTAL_VOLUME_UPDATE_TIME}_lag_seconds`,
+      expect.any(Number),
+      { cache: PersistentCacheKeys.TOTAL_VOLUME_UPDATE_TIME },
+    );
+  });
 });
 
 async function getTotalVolumeUpdateTime(): Promise<DateTime | undefined> {

indexer/services/roundtable/src/tasks/update-affiliate-info.ts

@@ -1,4 +1,4 @@
-import { logger } from '@dydxprotocol-indexer/base';
+import { logger, stats } from '@dydxprotocol-indexer/base';
 import {
   PersistentCacheTable,
   AffiliateInfoTable,
@@ -10,6 +10,8 @@ import {
 } from '@dydxprotocol-indexer/postgres';
 import { DateTime } from 'luxon';
 
+import config from '../config';
+
 const defaultLastUpdateTime: string = '2024-09-16T00:00:00Z';
 
 /**
@@ -36,6 +38,13 @@ export default async function runTask(): Promise<void> {
       ? persistentCacheEntry.value
       : defaultLastUpdateTime);
 
+    // Track how long ago the last update time (windowStartTime) in persistent cache was
+    stats.gauge(
+      `${config.SERVICE_NAME}.persistent_cache_${PersistentCacheKeys.AFFILIATE_INFO_UPDATE_TIME}_lag_seconds`,
+      DateTime.utc().diff(windowStartTime).as('seconds'),
+      { cache: PersistentCacheKeys.AFFILIATE_INFO_UPDATE_TIME },
+    );
+
     let windowEndTime = DateTime.fromISO(latestBlock.time);
     // During backfilling, we process one day at a time to reduce roundtable runtime.
     if (windowEndTime > windowStartTime.plus({ days: 1 })) {

indexer/services/roundtable/src/tasks/update-wallet-total-volume.ts

@@ -1,4 +1,4 @@
-import { logger } from '@dydxprotocol-indexer/base';
+import { logger, stats } from '@dydxprotocol-indexer/base';
 import {
   PersistentCacheTable,
   WalletTable,
@@ -10,6 +10,8 @@ import {
 } from '@dydxprotocol-indexer/postgres';
 import { DateTime } from 'luxon';
 
+import config from '../config';
+
 const defaultLastUpdateTime: string = '2023-10-26T00:00:00Z';
 
 /**
@@ -39,6 +41,13 @@ export default async function runTask(): Promise<void> {
       ? persistentCacheEntry.value
       : defaultLastUpdateTime);
 
+    // Track how long ago the last update time (windowStartTime) in persistent cache was
+    stats.gauge(
+      `${config.SERVICE_NAME}.persistent_cache_${PersistentCacheKeys.TOTAL_VOLUME_UPDATE_TIME}_lag_seconds`,
+      DateTime.utc().diff(windowStartTime).as('seconds'),
+      { cache: PersistentCacheKeys.TOTAL_VOLUME_UPDATE_TIME },
+    );
+
     let windowEndTime = DateTime.fromISO(latestBlock.time);
     // During backfilling, we process one day at a time to reduce roundtable runtime.
     if (windowEndTime > windowStartTime.plus({ days: 1 })) {