Collect portnums for ServiceEnvelopes

prisma/migrations/20250415153323_add_portnum_to_service_envelopes/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE `service_envelopes` ADD COLUMN `portnum` INTEGER NULL;

prisma/schema.prisma

@@ -204,6 +204,7 @@ model ServiceEnvelope {
   gateway_id BigInt?
   to         BigInt
   from       BigInt
+  portnum    Int?
   protobuf   Bytes
 
   created_at DateTime @default(now())

src/mqtt.js

@@ -750,6 +750,7 @@ client.on("message", async (topic, message) => {
                         gateway_id: envelope.gatewayId ? convertHexIdToNumericId(envelope.gatewayId) : null,
                         to: envelope.packet.to,
                         from: envelope.packet.from,
+                        portnum: portnum,
                         protobuf: message,
                     },
                 });