From 24fdcdb7075e70b6fcf41036f532f8bfb5037e8f Mon Sep 17 00:00:00 2001
From: liamcottle <liam@liamcottle.com>
Date: Sat, 23 Mar 2024 09:41:51 +1300
Subject: [PATCH] add env var to enable and disable collecting all service
 envelopes

---
 src/mqtt.js | 32 +++++++++++++++++---------------
 1 file changed, 17 insertions(+), 15 deletions(-)

diff --git a/src/mqtt.js b/src/mqtt.js
index e8bafc1..bca7206 100644
--- a/src/mqtt.js
+++ b/src/mqtt.js
@@ -91,21 +91,23 @@ client.on("message", async (topic, message) => {
         }
 
         // create service envelope in db
-        try {
-            await prisma.serviceEnvelope.create({
-                data: {
-                    mqtt_topic: topic,
-                    channel_id: envelope.channelId,
-                    gateway_id: envelope.gatewayId ? BigInt('0x' + envelope.gatewayId.replaceAll("!", "")) : null, // convert hex id "!f96a92f0" to bigint
-                    to: envelope.packet.to,
-                    from: envelope.packet.from,
-                    protobuf: message,
-                },
-            });
-        } catch (e) {
-            console.error(e, {
-                envelope: envelope.packet,
-            });
+        if(process.env.MM_COLLECT_SERVICE_ENVELOPES === "true"){
+            try {
+                await prisma.serviceEnvelope.create({
+                    data: {
+                        mqtt_topic: topic,
+                        channel_id: envelope.channelId,
+                        gateway_id: envelope.gatewayId ? BigInt('0x' + envelope.gatewayId.replaceAll("!", "")) : null, // convert hex id "!f96a92f0" to bigint
+                        to: envelope.packet.to,
+                        from: envelope.packet.from,
+                        protobuf: message,
+                    },
+                });
+            } catch (e) {
+                console.error(e, {
+                    envelope: envelope.packet,
+                });
+            }
         }
 
         // attempt to decrypt encrypted packets