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',