From 0be80d417710035d46ce463b13029832f735bcc3 Mon Sep 17 00:00:00 2001 From: Anton Roslund Date: Wed, 13 Aug 2025 21:50:50 +0200 Subject: [PATCH] Collect channel_id --- .../20250813193012_add_node_channel_id/migration.sql | 2 ++ prisma/schema.prisma | 2 ++ src/mqtt.js | 4 +++- 3 files changed, 7 insertions(+), 1 deletion(-) create mode 100644 prisma/migrations/20250813193012_add_node_channel_id/migration.sql diff --git a/prisma/migrations/20250813193012_add_node_channel_id/migration.sql b/prisma/migrations/20250813193012_add_node_channel_id/migration.sql new file mode 100644 index 0000000..9498fea --- /dev/null +++ b/prisma/migrations/20250813193012_add_node_channel_id/migration.sql @@ -0,0 +1,2 @@ +-- AlterTable +ALTER TABLE `nodes` ADD COLUMN `channel_id` VARCHAR(191) NULL; diff --git a/prisma/schema.prisma b/prisma/schema.prisma index 10bd2c8..db6aab7 100644 --- a/prisma/schema.prisma +++ b/prisma/schema.prisma @@ -57,6 +57,8 @@ model Node { is_backbone Boolean? max_hops Int? + channel_id String? + created_at DateTime @default(now()) updated_at DateTime @default(now()) @updatedAt diff --git a/src/mqtt.js b/src/mqtt.js index 6078f10..bb9d693 100644 --- a/src/mqtt.js +++ b/src/mqtt.js @@ -948,6 +948,7 @@ client.on("message", async (topic, message) => { is_unmessagable: user.isUnmessagable, ok_to_mqtt: isOkToMqtt, max_hops: envelope.packet.hopStart, + channel_id: envelope.channelId, firmware_version: '<2.5.0', ...(user.publicKey != '' && { @@ -967,7 +968,8 @@ client.on("message", async (topic, message) => { is_unmessagable: user.isUnmessagable, ok_to_mqtt: isOkToMqtt, max_hops: envelope.packet.hopStart, - + channel_id: envelope.channelId, + firmware_version: '<2.5.0', ...(user.publicKey != '' && { firmware_version: '>2.5.0',