collect ok-to-mqtt falg

prisma/migrations/20250328205405_add_ok_to_mqtt_to_node/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE `nodes` ADD COLUMN `ok_to_mqtt` BOOLEAN NULL;

prisma/schema.prisma

@@ -51,6 +51,8 @@ model Node {
   // this column tracks when an mqtt gateway node uplinked a packet
   mqtt_connection_state_updated_at DateTime?
 
+  ok_to_mqtt  Boolean?
+
   created_at DateTime @default(now())
   updated_at DateTime @default(now()) @updatedAt
 

src/mqtt.js

@@ -914,6 +914,7 @@ client.on("message", async (topic, message) => {
         else if(portnum === 4) {
 
             const user = User.decode(envelope.packet.decoded.payload);
+            let isOkToMqtt = null
 
             if(logKnownPacketTypes) {
                 console.log("NODEINFO_APP", {
@@ -922,6 +923,11 @@ client.on("message", async (topic, message) => {
                 });
             }
 
+            // check if bitfield is available, then check if ok-to-mqtt
+            if(bitfield != null){
+                isOkToMqtt = Boolean(bitfield & BITFIELD_OK_TO_MQTT_MASK);
+            }
+
             // create or update node in db
             try {
                 await prisma.node.upsert({
@@ -936,6 +942,7 @@ client.on("message", async (topic, message) => {
                         is_licensed: user.isLicensed === true,
                         role: user.role,
                         firmware_version: bitfield ? '2.5.0 or newer' : '2.4.3 or older', 
+                        ok_to_mqtt: isOkToMqtt,
                     },
                     update: {
                         long_name: user.longName,
@@ -944,6 +951,7 @@ client.on("message", async (topic, message) => {
                         is_licensed: user.isLicensed === true,
                         role: user.role,
                         firmware_version: bitfield ? '2.5.0 or newer' : '2.4.3 or older',
+                        ok_to_mqtt: isOkToMqtt,
                     },
                 });
             } catch (e) {