start building the metrics setter

packages/delivery-service/src/persistence/getDatabase.ts

@@ -9,9 +9,9 @@ import { createClient } from 'redis';
 import Account from './account';
 import { getIdEnsName } from './getIdEnsName';
 import Messages from './messages';
-import Metrics from './metrics';
-import type { MetricsMap, IntervalMetric } from './metrics';
 import { syncAcknowledge } from './messages/syncAcknowledge';
+import type { MetricsMap } from './metrics';
+import Metrics from './metrics';
 import Notification from './notification';
 import Otp from './otp';
 
@@ -95,6 +95,7 @@ export async function getDatabase(
         resetOtp: Otp.resetOtp(redis),
         // Metrics
         getMetrics: Metrics.getMetrics(redis),
+        setMetrics: Metrics.setMetrics(redis),
     };
 }
 
@@ -161,6 +162,7 @@ export interface IDatabase extends IAccountDatabase {
         channelType: NotificationChannelType,
     ) => Promise<void>;
     getMetrics: () => Promise<MetricsMap>;
+    setMetrics: (metrics: MetricsMap) => Promise<void>;
 }
 
 export type Redis = Awaited<ReturnType<typeof getRedisClient>>;

packages/delivery-service/src/persistence/metrics/index.ts

@@ -1,10 +1,12 @@
 import { getMetrics } from './getMetrics';
+import type { IntervalMetric, MetricsMap } from './metricTypes';
+import { setMetrics } from './setMetrics';
 import { stringifyMetrics } from './stringifyMetrics';
-import type { MetricsMap, IntervalMetric } from './metricTypes';
 
 export default {
     getMetrics,
+    setMetrics,
     stringifyMetrics,
 };
 
-export type { MetricsMap, IntervalMetric };
+export type { IntervalMetric, MetricsMap };

packages/delivery-service/src/persistence/metrics/setMetrics.ts

@@ -0,0 +1,11 @@
+import { Redis, RedisPrefix } from '../getDatabase';
+import { MetricsMap, IntervalMetric } from './metricTypes';
+import { stringifyMetrics } from './stringifyMetrics';
+
+export function setMetrics(redis: Redis) {
+    return async (metrics: MetricsMap) => {
+        console.log('writing metrics to database:', metrics);
+        const metricsString = stringifyMetrics(metrics);
+        await redis.set(RedisPrefix.Metrics, metricsString);
+    };
+}