Collect packet_id for ServiceEnvelopes

prisma/migrations/20250415184546_add_packet_id_to_service_envelopes/migration.sql

@@ -0,0 +1,5 @@
+-- AlterTable
+ALTER TABLE `service_envelopes` ADD COLUMN `packet_id` BIGINT NULL;
+
+-- CreateIndex
+CREATE INDEX `service_envelopes_packet_id_idx` ON `service_envelopes`(`packet_id`);

prisma/schema.prisma

@@ -205,6 +205,7 @@ model ServiceEnvelope {
   to         BigInt
   from       BigInt
   portnum    Int?
+  packet_id  BigInt?
   protobuf   Bytes
 
   created_at DateTime @default(now())
@@ -213,6 +214,7 @@ model ServiceEnvelope {
   @@index(created_at)
   @@index(updated_at)
   @@index(gateway_id)
+  @@index(packet_id)
   @@map("service_envelopes")
 }
 

src/mqtt.js

@@ -751,6 +751,7 @@ client.on("message", async (topic, message) => {
                         to: envelope.packet.to,
                         from: envelope.packet.from,
                         portnum: portnum,
+                        packet_id: envelope.packet.id,
                         protobuf: message,
                     },
                 });