diff --git a/api/src/meshtastic.ts b/api/src/meshtastic.ts index aa8fc0b..02d587d 100644 --- a/api/src/meshtastic.ts +++ b/api/src/meshtastic.ts @@ -332,7 +332,7 @@ export async function connect(address?: string) { let packet: MeshPacket packet = packets.upsert({ id: message.id, message }) let node = getNodeById(packet.from) - if (packet?.viaMqtt === false) sendToMeshMap({ num: message.from }, node, packet) + if (packet?.viaMqtt === false && node.user) sendToMeshMap({ num: message.from }, node, packet) }) /** TELEMETRY_APP */ @@ -341,7 +341,7 @@ export async function connect(address?: string) { let telemetry = extractPayload(data) let packet = packets.upsert({ id, data }) let node = nodes.upsert({ num: e.from, ...telemetry }) - if (packet?.viaMqtt === false) sendToMeshMap({ num: e.from, ...telemetry }, node, packet) + if (packet?.viaMqtt === false && node.user) sendToMeshMap({ num: e.from, ...telemetry }, node, packet) }) /** POSITION_APP */ @@ -351,7 +351,7 @@ export async function connect(address?: string) { if (id && data.latitudeI) packet = packets.upsert({ id, data }) if (e.from && data.latitudeI) { let node = nodes.upsert({ num: e.from, position: data }) - if (packet?.viaMqtt === false) sendToMeshMap({ num: e.from, position: data }, node, packet) + if (packet?.viaMqtt === false && node.user) sendToMeshMap({ num: e.from, position: data }, node, packet) } })