init

2026-07-06 01:41:22 +02:00 · 2025-10-18 11:04:39 +02:00
parent f8c80b32ae
commit 69ccc65bab
3 changed files with 131 additions and 0 deletions
@@ -0,0 +1,106 @@
+import {
+  BufferUtils, Packet, Constants,
+  NodeJSSerialConnection, TCPConnection,
+  Advert
+} from '@liamcottle/meshcore.js';
+
+import crypto from 'crypto';
+
+const device = process.argv[2] ?? '/dev/ttyACM0';
+const apiURL = 'https://map.meshcore.dev/api/v1/uploader/node';
+const seenAdverts = {};
+let clientInfo = {};
+
+const signData = async (connection, data) => {
+  const json = JSON.stringify(data);
+  const dataHash = new Uint8Array(
+    await crypto.subtle.digest('SHA-256', new TextEncoder().encode(json))
+  );
+
+  return { data: json, signature: BufferUtils.bytesToHex(await connection.sign(dataHash)) }
+}
+
+const processPacket = async (connection, rawPacket) => {
+  const packet = Packet.fromBytes(rawPacket);
+
+  if(packet.payload_type_string !== 'ADVERT') return;
+
+  const advert = Advert.fromBytes(packet.payload);
+  // console.log(advert);
+  if(advert.parsed.type === 'CHAT') return;
+
+  const pubKey = BufferUtils.bytesToHex(advert.publicKey);
+  const node = { pubKey, name: advert.parsed.name, ts: advert.timestamp, type: advert.parsed.type.toLowerCase() };
+
+  if(!advert.isVerified()) {
+    console.warn('ignoring: signature verification failed', node);
+    return;
+  }
+
+  if(seenAdverts[pubKey]) {
+    if(seenAdverts[pubKey] >= advert.timestamp) {
+      console.warn('ignoring: possible replay attack', node);
+      return;
+    }
+    if(advert.timestamp < seenAdverts[pubKey] + 3600) {
+      console.warn('ignoring: timestamp too new to reupload', node)
+      return;
+    }
+  }
+
+  console.log(`uploading`, node);
+  const data = {
+    params: {
+      freq: clientInfo.radioFreq / 1000,
+      cr: clientInfo.radioCr,
+      sf: clientInfo.radioSf,
+      bw: clientInfo.radioBw / 1000
+    },
+    links: [`meshcore://${BufferUtils.bytesToHex(rawPacket)}`]
+  };
+
+  const requestData = await signData(connection, data);
+  requestData.publicKey = BufferUtils.bytesToHex(clientInfo.publicKey);
+
+  const req = await fetch(apiURL, {
+    method: 'POST',
+    body: JSON.stringify(requestData)
+  });
+
+  console.log('sending', requestData)
+  console.log(await req.json());
+
+  seenAdverts[pubKey] = advert.timestamp;
+}
+
+console.log(`Connecting to ${device}...`);
+
+let connection;
+if(device.startsWith('/') || device.startsWith('COM')){
+  connection = new NodeJSSerialConnection(device);
+} else {
+  const [ host, port ] = device.split(':');
+  connection = new TCPConnection(host, port ?? 5000);
+}
+
+connection.on('connected', async () => {
+  console.log(`Connected.`);
+
+  connection.setManualAddContacts();
+
+  clientInfo = await connection.getSelfInfo();
+  // console.log('info', clientInfo);
+
+  console.log('Map uploader waiting for adverts...');
+});
+
+connection.on(Constants.PushCodes.LogRxData, async (event) => {
+  try {
+    await processPacket(connection, event.raw);
+  }
+  catch(e) {
+    console.error(e);
+  }
+});
+
+await connection.connect();