Skip to content

Commit

Permalink
Initial commit
Browse files Browse the repository at this point in the history
  • Loading branch information
@mskvortsov
mskvortsov committed Apr 3, 2024
0 parents commit 409d05c
Show file tree
Hide file tree
Showing 25 changed files with 6,768 additions and 0 deletions.
674 changes: 674 additions & 0 deletions LICENSE

Large diffs are not rendered by default.

Empty file added README.md
Empty file.
35 changes: 35 additions & 0 deletions index.html
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8"/>
<title>Meshtastic Monitor</title>
<link rel="icon" type="image/x-icon" href="https://meshtastic.org/design/web/favicon.ico">
<link rel="stylesheet" href="meshmon.css">
<script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/mqtt/5.5.0/mqtt.min.js"></script>
<script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/protobufjs/7.2.6/protobuf.min.js"></script>
<script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/crypto-js/4.2.0/crypto-js.min.js"></script>
<script type="text/javascript" src="meshmon.js"></script>
</head>
<body>
<table class="main-table">
<thead>
<tr id="thead-row"></tr>
</thead>
<tbody id="tbody"></tbody>
<tfoot>
<tr id="status-row" class="status-disconnected">
<td id="status-cell"></td>
</tr>
<tr>
<td id="input-cell">
<label for="mqtt-url">MQTT URL:</label>
<input id="mqtt-url" type="text"/>
<label for="mqtt-topic">Topic:</label>
<input id="mqtt-topic" type="text"/>
<button id="mqtt-connect">Connect</button>
</td>
</tr>
</tfoot>
</table>
</body>
</html>
62 changes: 62 additions & 0 deletions meshmon.css
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
body {
background-color: #232327;
color: #b1b1b3;
}
thead, tbody {
font-family: monospace;
}

table, th, td {
white-space: nowrap;
padding-left: 8px;
padding-right: 8px;
}
thead tr {
text-align: center;
}
thead {
position: sticky;
top: 0;
}
tbody tr {
text-align: right;
}
.decoded td {
text-align: left;
font-size: 80%;
}

.main-table {
border-collapse: collapse;
border: none;
}
.main-table td {
border: 1px solid #444444;
}
.main-table tr:first-child td {
border-top: none;
}
.main-table tr:last-child td {
border-bottom: none;
}
.main-table tr td:first-child {
border-left: none;
}
.main-table tr td:last-child {
border-right: none;
}

.main-table thead tr {
background: #000000;
}

.main-table tbody tr:nth-child(odd) {
background: #333333;
}

.status-disconnected {
background-color: #ea7a6c;
}
.status-connected {
background-color: #2ea043;
}
291 changes: 291 additions & 0 deletions meshmon.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,291 @@
'use strict';

const defaultMqttUrl = 'wss://mqtt.eclipseprojects.io/mqtt';
const defaultMqttTopic = 'marsupial';
const defaultKey = CryptoJS.enc.Base64.parse('1PG7OiApB1nwvP+rz05pAQ==');

var mqttUrlInput = null;
var mqttTopicInput = null;
var mqttConnected = false;
var mqttClient = null;

var tbody = null;
var statusRow = null;
var connectButton = null;

function formatTime(v) {
const t = new Date(v * 1000);
return t.toISOString();
}

function formatNodeId(v) {
return '!' + v.toString(16).padStart(8, '0');
}

function formatFloat(v) {
const n = new Number(v);
return n.toFixed(2);
}

function formatCoord(v) {
return v / 10000000;
}

const formatters = new Map([
['nodeId', formatNodeId],
['lastSentById', formatNodeId],
['time', formatTime],
['temperature', formatFloat],
['voltage', formatFloat],
['barometricPressure', formatFloat],
['relativeHumidity', formatFloat],
['channelUtilization', formatFloat],
['airUtilTx', formatFloat],
['latitudeI', formatCoord],
['longitudeI', formatCoord],
]);

function decodeDefault(proto, name, payload) {
const info = proto.decode(payload);
const replacer = (k, v) => {
const formatter = formatters.get(k);
if (formatter) {
return formatter(v);
} else {
return v;
}
};
return `${name}\n${JSON.stringify(info, replacer, 2)}`;
};

function decodeText(_proto, name, payload) {
return `${name}\n${payload.decode('utf-8')}`;
}

function buildMeshtasticProtos() {
var protobuf_root = new protobuf.Root();
protobuf_root.resolvePath = function(_origin, target) {
return 'protobufs/' + target;
};

const modules = ['meshtastic/mqtt.proto', 'meshtastic/storeforward.proto'];
var meshtastic = {};

protobuf_root.load(modules, function(err, root) {
if (err)
throw err;

meshtastic.ServiceEnvelope = root.lookupType('meshtastic.ServiceEnvelope');
meshtastic.Data = root.lookupType('meshtastic.Data');
meshtastic.PortNum = root.lookupEnum('meshtastic.PortNum');

const ports = meshtastic.PortNum.values;
const protos = [
{ port: ports.TEXT_MESSAGE_APP, name: 'Text', decode: decodeText },
{ port: ports.POSITION_APP, name: 'Position', decode: decodeDefault },
{ port: ports.NODEINFO_APP, name: 'User', decode: decodeDefault },
{ port: ports.ROUTING_APP, name: 'Routing', decode: decodeDefault },
{ port: ports.STORE_FORWARD_APP, name: 'StoreAndForward', decode: decodeDefault },
{ port: ports.TELEMETRY_APP, name: 'Telemetry', decode: decodeDefault },
{ port: ports.TRACEROUTE_APP, name: 'RouteDiscovery', decode: decodeDefault },
{ port: ports.NEIGHBORINFO_APP, name: 'NeighborInfo', decode: decodeDefault },
];

meshtastic.protos = {};
protos.forEach((p) => {
var proto = null;
try {
proto = root.lookupType('meshtastic.' + p.name);
} catch (_error) {
}
meshtastic.protos[p.port] = {
decode: (v) => { return p.decode(proto, p.name, v); },
};
});
});

return meshtastic;
}

const meshtastic = buildMeshtasticProtos();

function swap32(val) {
return ((val & 0xff000000) >>> 24)
| ((val & 0x00ff0000) >>> 8)
| ((val & 0x0000ff00) << 8)
| ((val & 0x000000ff) << 24);
}

function wordsToByteArray(wordArray) {
var byteArray = new Uint8Array(wordArray.sigBytes);
for (var i = 0; i < wordArray.sigBytes; ++i) {
byteArray[i] = (wordArray.words[i >>> 2] >>> (24 - ((i & 3) << 3))) & 0xff;
}
return byteArray;
}

function arrayToString(arr) {
return arr.map((v) => v.toString(16).padStart(2, '0')).join('');
}

function decodeEncrypted(packet, key) {
const iv = CryptoJS.lib.WordArray.create([
swap32(packet.id), 0,
swap32(packet.from), 0,
]);

const encrypted = CryptoJS.lib.WordArray.create(packet.encrypted);
const decrypted = CryptoJS.AES.decrypt(
CryptoJS.lib.CipherParams.create({
ciphertext: encrypted,
}),
key,
{
mode: CryptoJS.mode.CTR,
iv: iv,
padding: CryptoJS.pad.NoPadding,
}
);

try {
packet.decoded = meshtastic.Data.decode(wordsToByteArray(decrypted));
} catch (error) {
console.log('failed to decode encrypted packet: ' + error);
}
}

function mqttOnConnect() {
mqttConnected = true;
connectButton.textContent = 'Disconnect';
connectButton.disabled = false;
statusRow.className = 'status-connected';
mqttClient.subscribe(`${mqttTopicInput.value}/2/e/#`);
}

function mqttOnDisconnect() {
mqttConnected = false;
mqttClient = null;
connectButton.textContent = 'Connect';
connectButton.disabled = false;
mqttUrlInput.disabled = false;
mqttTopicInput.disabled = false;
statusRow.className = 'status-disconnected';
}

function onClick() {
connectButton.disabled = true;
if (mqttConnected) {
mqttClient.end(false, null, mqttOnDisconnect);
} else {
mqttUrlInput.disabled = true;
mqttTopicInput.disabled = true;
mqttClient = mqtt.connect(mqttUrlInput.value);
mqttClient.on('connect', mqttOnConnect);
mqttClient.on('message', mqttOnMessage);
mqttClient.on('error', mqttOnDisconnect);
}
}

const fields = [
'rxTime', 'gatewayId', 'channelId', 'id', 'hopStart', 'hopLimit',
'wantAck', 'viaMqtt', 'rxRssi', 'rxSnr', 'from', 'to', 'portnum',
];

function mqttOnMessage(topic, message) {
var se = null;
try {
se = meshtastic.ServiceEnvelope.decode(message);
} catch (error) {
console.error(`Failed to decode ServiceEnvelope: ${error}`);
console.error(`Topic: ${topic}`);
console.error(`Message: x${arrayToString(message)}`);
return;
}

var row = tbody.insertRow();
var cells = {};
fields.forEach((field) => {
cells[field] = row.insertCell();
});

cells['rxTime'].innerHTML = formatTime(se.packet.rxTime);
cells['gatewayId'].innerHTML = se.gatewayId;
cells['channelId'].innerHTML = se.channelId;
cells['id'].innerHTML = se.packet.id.toString(16).padStart(8, '0');
cells['hopStart'].innerHTML = se.packet.hopStart;
cells['hopLimit'].innerHTML = se.packet.hopLimit;
cells['wantAck'].innerHTML = se.packet.wantAck ? '1' : '0';
cells['viaMqtt'].innerHTML = se.packet.viaMqtt ? '1' : '0';
cells['rxRssi'].innerHTML = se.packet.rxRssi;
cells['rxSnr'].innerHTML = se.packet.rxSnr;
cells['from'].innerHTML = formatNodeId(se.packet.from);
cells['to'].innerHTML = formatNodeId(se.packet.to);

if (se.packet.payloadVariant == 'encrypted' && se.channelId == 'LongFast') {
decodeEncrypted(se.packet, defaultKey);
}

var row = tbody.insertRow();
row.className = 'decoded';
var cell = row.insertCell();
cell.colSpan = fields.length;
var decoded = document.createElement('pre');
cell.appendChild(decoded);

var decodedText = "";
if (se.packet.encrypted) {
decodedText += `x${arrayToString(se.packet.encrypted)} Encrypted\n`;
}

if (se.packet.decoded) {
decodedText += `x${arrayToString(se.packet.decoded.payload)} `

const port = se.packet.decoded.portnum;
cells['portnum'].innerHTML = port;

var decode = null;
if (port in meshtastic.protos) {
decode = meshtastic.protos[port].decode;
}

if (decode) {
try {
decodedText += decode(se.packet.decoded.payload);
} catch (error) {
decodedText += `Error ${error}`;
}
} else {
decodedText += `NYI ${port}`;
}
} else {
cells['portnum'].innerHTML = '?';
}
decoded.textContent = decodedText;

window.scrollTo(0, document.body.scrollHeight);
}

window.onload = function() {
var theadRow = document.getElementById('thead-row');
fields.forEach((field) => {
var th = theadRow.insertCell();
th.innerHTML = field;
});

tbody = document.getElementById('tbody');

statusRow = document.getElementById('status-row');
document.getElementById('status-cell').colSpan = fields.length;
document.getElementById('input-cell').colSpan = fields.length;

mqttUrlInput = document.getElementById('mqtt-url');
mqttUrlInput.placeholder = defaultMqttUrl;
mqttUrlInput.defaultValue = defaultMqttUrl;

mqttTopicInput = document.getElementById('mqtt-topic');
mqttTopicInput.placeholder = defaultMqttTopic;
mqttTopicInput.defaultValue = defaultMqttTopic;

connectButton = document.getElementById('mqtt-connect');
connectButton.addEventListener('click', onClick);
};
Loading

0 comments on commit 409d05c

Please sign in to comment.