disable metrics collection on retention 0

packages/delivery-service/README.md

@@ -37,3 +37,5 @@ This delivery service implementation collects these metrics:
 These metrics are accumulated over the `metricsCollectionIntervalInSeconds`, which can be defined in the config file and defaults to 1 hour. They are retained for `metricsRetentionDurationInSeconds`, which defaults to 10 days.
 
 The metrics are not sent anywhere, but can be accessed by anyone via the `/metrics` endpoint. This endpoint censors the current collection interval to prevent real-time tracking, which would reduce the privacy of the users.
+
+In order to disable metrics collection, set `metricsRetentionDurationInSeconds` to 0.

packages/delivery-service/src/message/MessageProcessor.ts

@@ -174,7 +174,14 @@ export class MessageProcessor {
                     deliveryInformation,
                     this.db.getUsersNotificationChannels,
                 );
-                await this.db.countNotification(this.deliveryServiceProperties);
+                if (
+                    this.deliveryServiceProperties
+                        .metricsRetentionDurationInSeconds > 0
+                ) {
+                    await this.db.countNotification(
+                        this.deliveryServiceProperties,
+                    );
+                }
             } catch (err) {
                 console.log(
                     'Unable to send Notification. There might be an error in the config.yml. Message has been received regardless',

packages/delivery-service/src/rpc/methods/handleSubmitMessage.ts

@@ -74,10 +74,12 @@ export async function handleSubmitMessage(
 
     try {
         await messageProcessor.processEnvelop(envelop);
-        await db.countMessage(
-            getEnvelopSize(envelop),
-            deliveryServiceProperties,
-        );
+        if (deliveryServiceProperties.metricsRetentionDurationInSeconds > 0) {
+            await db.countMessage(
+                getEnvelopSize(envelop),
+                deliveryServiceProperties,
+            );
+        }
         res.sendStatus(200);
     } catch (error) {
         console.error('handle submit message error');