ctmesh/map
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add cli option to log packets for unknown portnums

Browse Source
This commit is contained in:
liamcottle
2024-09-09 13:28:04 +12:00
parent 6260b58f81
commit 2aec144e91
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/mqtt.js
View File

@ -43,6 +43,11 @@ const optionsList = [
typeLabel: '<topic> ...', typeLabel: '<topic> ...',
description: "MQTT Topic to subscribe to (e.g: msh/#)", description: "MQTT Topic to subscribe to (e.g: msh/#)",
}, },
{
name: "log-unknown-portnums",
type: Boolean,
description: "This option will log packets for unknown portnums to the console.",
},
{ {
name: "collect-service-envelopes", name: "collect-service-envelopes",
type: Boolean, type: Boolean,
@ -172,6 +177,7 @@ const mqttUsername = options["mqtt-username"] ?? "meshdev";
const mqttPassword = options["mqtt-password"] ?? "large4cats"; const mqttPassword = options["mqtt-password"] ?? "large4cats";
const mqttClientId = options["mqtt-client-id"] ?? null; const mqttClientId = options["mqtt-client-id"] ?? null;
const mqttTopics = options["mqtt-topic"] ?? ["msh/#"]; const mqttTopics = options["mqtt-topic"] ?? ["msh/#"];
const logUnknownPortnums = options["log-unknown-portnums"] ?? false;
const collectServiceEnvelopes = options["collect-service-envelopes"] ?? false; const collectServiceEnvelopes = options["collect-service-envelopes"] ?? false;
const collectPositions = options["collect-positions"] ?? true; const collectPositions = options["collect-positions"] ?? true;
const collectTextMessages = options["collect-text-messages"] ?? false; const collectTextMessages = options["collect-text-messages"] ?? false;
@ -655,7 +661,6 @@ client.on("message", async (topic, message) => {
} }
const logKnownPacketTypes = false; const logKnownPacketTypes = false;
const logUnknownPacketTypes = false;
const portnum = envelope.packet?.decoded?.portnum; const portnum = envelope.packet?.decoded?.portnum;
if(portnum === 1) { if(portnum === 1) {
@ -1212,7 +1217,7 @@ client.on("message", async (topic, message) => {
} }
else { else {
if(logUnknownPacketTypes){ if(logUnknownPortnums){
// ignore packets we don't want to see for now // ignore packets we don't want to see for now
if(portnum === undefined // ignore failed to decrypt if(portnum === undefined // ignore failed to decrypt