mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
file cleanup
This commit is contained in:
parent
56f2fdeb89
commit
e9d8b786b1
8 changed files with 1 additions and 8596 deletions
|
@ -1,351 +0,0 @@
|
||||||
var net = require("net");
|
|
||||||
const path = require("path");
|
|
||||||
const { ipcRenderer } = require("electron");
|
|
||||||
const log = require("electron-log");
|
|
||||||
const daemonLog = log.scope("daemon");
|
|
||||||
|
|
||||||
// https://stackoverflow.com/a/26227660
|
|
||||||
var appDataFolder =
|
|
||||||
process.env.APPDATA ||
|
|
||||||
(process.platform == "darwin"
|
|
||||||
? process.env.HOME + "/Library/Application Support"
|
|
||||||
: process.env.HOME + "/.config");
|
|
||||||
var configFolder = path.join(appDataFolder, "FreeDATA");
|
|
||||||
var configPath = path.join(configFolder, "config.json");
|
|
||||||
const config = require(configPath);
|
|
||||||
|
|
||||||
var daemon = new net.Socket();
|
|
||||||
var socketchunk = ""; // Current message, per connection.
|
|
||||||
|
|
||||||
// global to keep track of daemon connection error emissions
|
|
||||||
var daemonShowConnectStateError = 1;
|
|
||||||
|
|
||||||
// global for storing ip information
|
|
||||||
var daemon_port = config.daemon_port;
|
|
||||||
var daemon_host = config.daemon_host;
|
|
||||||
|
|
||||||
setTimeout(connectDAEMON, 500);
|
|
||||||
|
|
||||||
function connectDAEMON() {
|
|
||||||
if (daemonShowConnectStateError == 1) {
|
|
||||||
daemonLog.info("connecting to daemon");
|
|
||||||
}
|
|
||||||
|
|
||||||
//clear message buffer after reconnecting or initial connection
|
|
||||||
socketchunk = "";
|
|
||||||
|
|
||||||
if (config.tnclocation == "localhost") {
|
|
||||||
daemon.connect(3001, "127.0.0.1");
|
|
||||||
} else {
|
|
||||||
daemon.connect(daemon_port, daemon_host);
|
|
||||||
}
|
|
||||||
|
|
||||||
//client.setTimeout(5000);
|
|
||||||
}
|
|
||||||
|
|
||||||
daemon.on("connect", function (err) {
|
|
||||||
daemonLog.info("daemon connection established");
|
|
||||||
let Data = {
|
|
||||||
daemon_connection: daemon.readyState,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-daemon-connection", Data);
|
|
||||||
|
|
||||||
daemonShowConnectStateError = 1;
|
|
||||||
});
|
|
||||||
|
|
||||||
daemon.on("error", function (err) {
|
|
||||||
if (daemonShowConnectStateError == 1) {
|
|
||||||
daemonLog.error("daemon connection error");
|
|
||||||
daemonLog.info("Make sure the daemon is started.");
|
|
||||||
daemonLog.info('Run "python daemon.py" in the tnc directory.');
|
|
||||||
|
|
||||||
daemonShowConnectStateError = 0;
|
|
||||||
}
|
|
||||||
setTimeout(connectDAEMON, 500);
|
|
||||||
daemon.destroy();
|
|
||||||
let Data = {
|
|
||||||
daemon_connection: daemon.readyState,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-daemon-connection", Data);
|
|
||||||
});
|
|
||||||
|
|
||||||
/*
|
|
||||||
client.on('close', function(data) {
|
|
||||||
console.log(' TNC connection closed');
|
|
||||||
setTimeout(connectTNC, 2000)
|
|
||||||
let Data = {
|
|
||||||
daemon_connection: daemon.readyState,
|
|
||||||
};
|
|
||||||
ipcRenderer.send('request-update-daemon-connection', Data);
|
|
||||||
});
|
|
||||||
*/
|
|
||||||
|
|
||||||
daemon.on("end", function (data) {
|
|
||||||
daemonLog.warn("daemon connection ended");
|
|
||||||
daemon.destroy();
|
|
||||||
setTimeout(connectDAEMON, 500);
|
|
||||||
let Data = {
|
|
||||||
daemon_connection: daemon.readyState,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-daemon-connection", Data);
|
|
||||||
});
|
|
||||||
|
|
||||||
//exports.writeCommand = function(command){
|
|
||||||
writeDaemonCommand = function (command) {
|
|
||||||
// we use the writingCommand function to update our TCPIP state because we are calling this function a lot
|
|
||||||
// if socket opened, we are able to run commands
|
|
||||||
if (daemon.readyState == "open") {
|
|
||||||
//uiMain.setDAEMONconnection('open')
|
|
||||||
daemon.write(command + "\n");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (daemon.readyState == "closed") {
|
|
||||||
//uiMain.setDAEMONconnection('closed')
|
|
||||||
}
|
|
||||||
|
|
||||||
if (daemon.readyState == "opening") {
|
|
||||||
//uiMain.setDAEMONconnection('opening')
|
|
||||||
}
|
|
||||||
|
|
||||||
let Data = {
|
|
||||||
daemon_connection: daemon.readyState,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-daemon-connection", Data);
|
|
||||||
};
|
|
||||||
|
|
||||||
// "https://stackoverflow.com/questions/9070700/nodejs-net-createserver-large-amount-of-data-coming-in"
|
|
||||||
|
|
||||||
daemon.on("data", function (socketdata) {
|
|
||||||
/*
|
|
||||||
inspired by:
|
|
||||||
stackoverflow.com questions 9070700 nodejs-net-createserver-large-amount-of-data-coming-in
|
|
||||||
*/
|
|
||||||
|
|
||||||
socketdata = socketdata.toString("utf8"); // convert data to string
|
|
||||||
socketchunk += socketdata; // append data to buffer so we can stick long data together
|
|
||||||
|
|
||||||
// check if we received begin and end of json data
|
|
||||||
if (socketchunk.startsWith('{"') && socketchunk.endsWith('"}\n')) {
|
|
||||||
var data = "";
|
|
||||||
|
|
||||||
// split data into chunks if we received multiple commands
|
|
||||||
socketchunk = socketchunk.split("\n");
|
|
||||||
data = JSON.parse(socketchunk[0]);
|
|
||||||
|
|
||||||
// search for empty entries in socketchunk and remove them
|
|
||||||
for (i = 0; i < socketchunk.length; i++) {
|
|
||||||
if (socketchunk[i] === "") {
|
|
||||||
socketchunk.splice(i, 1);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//iterate through socketchunks array to execute multiple commands in row
|
|
||||||
for (i = 0; i < socketchunk.length; i++) {
|
|
||||||
//check if data is not empty
|
|
||||||
if (socketchunk[i].length > 0) {
|
|
||||||
//try to parse JSON
|
|
||||||
try {
|
|
||||||
data = JSON.parse(socketchunk[i]);
|
|
||||||
} catch (e) {
|
|
||||||
console.log(e); // "SyntaxError
|
|
||||||
daemonLog.error(e);
|
|
||||||
daemonLog.debug(socketchunk[i]);
|
|
||||||
socketchunk = "";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (data["command"] == "daemon_state") {
|
|
||||||
let Data = {
|
|
||||||
input_devices: data["input_devices"],
|
|
||||||
output_devices: data["output_devices"],
|
|
||||||
python_version: data["python_version"],
|
|
||||||
hamlib_version: data["hamlib_version"],
|
|
||||||
serial_devices: data["serial_devices"],
|
|
||||||
tnc_running_state: data["daemon_state"][0]["status"],
|
|
||||||
ram_usage: data["ram"],
|
|
||||||
cpu_usage: data["cpu"],
|
|
||||||
version: data["version"],
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-daemon-state", Data);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (data["command"] == "test_hamlib") {
|
|
||||||
let Data = {
|
|
||||||
hamlib_result: data["result"],
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-hamlib-test", Data);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//finally delete message buffer
|
|
||||||
socketchunk = "";
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
function hexToBytes(hex) {
|
|
||||||
for (var bytes = [], c = 0; c < hex.length; c += 2)
|
|
||||||
bytes.push(parseInt(hex.substr(c, 2), 16));
|
|
||||||
return bytes;
|
|
||||||
}
|
|
||||||
|
|
||||||
exports.getDaemonState = function () {
|
|
||||||
//function getDaemonState(){
|
|
||||||
command = '{"type" : "get", "command" : "daemon_state"}';
|
|
||||||
writeDaemonCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// START TNC
|
|
||||||
// ` `== multi line string
|
|
||||||
|
|
||||||
exports.startTNC = function (
|
|
||||||
mycall,
|
|
||||||
mygrid,
|
|
||||||
rx_audio,
|
|
||||||
tx_audio,
|
|
||||||
radiocontrol,
|
|
||||||
devicename,
|
|
||||||
deviceport,
|
|
||||||
pttprotocol,
|
|
||||||
pttport,
|
|
||||||
serialspeed,
|
|
||||||
data_bits,
|
|
||||||
stop_bits,
|
|
||||||
handshake,
|
|
||||||
rigctld_ip,
|
|
||||||
rigctld_port,
|
|
||||||
enable_fft,
|
|
||||||
enable_scatter,
|
|
||||||
low_bandwidth_mode,
|
|
||||||
tuning_range_fmin,
|
|
||||||
tuning_range_fmax,
|
|
||||||
enable_fsk,
|
|
||||||
tx_audio_level,
|
|
||||||
respond_to_cq,
|
|
||||||
rx_buffer_size,
|
|
||||||
enable_explorer,
|
|
||||||
explorer_stats,
|
|
||||||
auto_tune,
|
|
||||||
tx_delay,
|
|
||||||
tci_ip,
|
|
||||||
tci_port,
|
|
||||||
enable_mesh,
|
|
||||||
) {
|
|
||||||
var json_command = JSON.stringify({
|
|
||||||
type: "set",
|
|
||||||
command: "start_tnc",
|
|
||||||
parameter: [
|
|
||||||
{
|
|
||||||
mycall: mycall,
|
|
||||||
mygrid: mygrid,
|
|
||||||
rx_audio: rx_audio,
|
|
||||||
tx_audio: tx_audio,
|
|
||||||
radiocontrol: radiocontrol,
|
|
||||||
devicename: devicename,
|
|
||||||
deviceport: deviceport,
|
|
||||||
pttprotocol: pttprotocol,
|
|
||||||
pttport: pttport,
|
|
||||||
serialspeed: serialspeed,
|
|
||||||
data_bits: data_bits,
|
|
||||||
stop_bits: stop_bits,
|
|
||||||
handshake: handshake,
|
|
||||||
rigctld_port: rigctld_port,
|
|
||||||
rigctld_ip: rigctld_ip,
|
|
||||||
enable_scatter: enable_scatter,
|
|
||||||
enable_fft: enable_fft,
|
|
||||||
enable_fsk: enable_fsk,
|
|
||||||
low_bandwidth_mode: low_bandwidth_mode,
|
|
||||||
tuning_range_fmin: tuning_range_fmin,
|
|
||||||
tuning_range_fmax: tuning_range_fmax,
|
|
||||||
tx_audio_level: tx_audio_level,
|
|
||||||
respond_to_cq: respond_to_cq,
|
|
||||||
rx_buffer_size: rx_buffer_size,
|
|
||||||
enable_explorer: enable_explorer,
|
|
||||||
enable_stats: explorer_stats,
|
|
||||||
enable_auto_tune: auto_tune,
|
|
||||||
tx_delay: tx_delay,
|
|
||||||
tci_ip: tci_ip,
|
|
||||||
tci_port: tci_port,
|
|
||||||
enable_mesh: enable_mesh,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
});
|
|
||||||
|
|
||||||
daemonLog.debug(json_command);
|
|
||||||
writeDaemonCommand(json_command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// STOP TNC
|
|
||||||
exports.stopTNC = function () {
|
|
||||||
command = '{"type" : "set", "command": "stop_tnc" , "parameter": "---" }';
|
|
||||||
writeDaemonCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// TEST HAMLIB
|
|
||||||
exports.testHamlib = function (
|
|
||||||
radiocontrol,
|
|
||||||
devicename,
|
|
||||||
deviceport,
|
|
||||||
serialspeed,
|
|
||||||
pttprotocol,
|
|
||||||
pttport,
|
|
||||||
data_bits,
|
|
||||||
stop_bits,
|
|
||||||
handshake,
|
|
||||||
rigctld_ip,
|
|
||||||
rigctld_port,
|
|
||||||
) {
|
|
||||||
var json_command = JSON.stringify({
|
|
||||||
type: "get",
|
|
||||||
command: "test_hamlib",
|
|
||||||
parameter: [
|
|
||||||
{
|
|
||||||
radiocontrol: radiocontrol,
|
|
||||||
devicename: devicename,
|
|
||||||
deviceport: deviceport,
|
|
||||||
pttprotocol: pttprotocol,
|
|
||||||
pttport: pttport,
|
|
||||||
serialspeed: serialspeed,
|
|
||||||
data_bits: data_bits,
|
|
||||||
stop_bits: stop_bits,
|
|
||||||
handshake: handshake,
|
|
||||||
rigctld_port: rigctld_port,
|
|
||||||
rigctld_ip: rigctld_ip,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
});
|
|
||||||
daemonLog.debug(json_command);
|
|
||||||
writeDaemonCommand(json_command);
|
|
||||||
};
|
|
||||||
|
|
||||||
//Save myCall
|
|
||||||
exports.saveMyCall = function (callsign) {
|
|
||||||
command =
|
|
||||||
'{"type" : "set", "command": "mycallsign" , "parameter": "' +
|
|
||||||
callsign +
|
|
||||||
'"}';
|
|
||||||
writeDaemonCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Save myGrid
|
|
||||||
exports.saveMyGrid = function (grid) {
|
|
||||||
command =
|
|
||||||
'{"type" : "set", "command": "mygrid" , "parameter": "' + grid + '"}';
|
|
||||||
writeDaemonCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
ipcRenderer.on("action-update-daemon-ip", (event, arg) => {
|
|
||||||
daemon.destroy();
|
|
||||||
let Data = {
|
|
||||||
busy_state: "-",
|
|
||||||
arq_state: "-",
|
|
||||||
//channel_state: "-",
|
|
||||||
frequency: "-",
|
|
||||||
mode: "-",
|
|
||||||
bandwidth: "-",
|
|
||||||
dbfs_level: 0,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-tnc-state", Data);
|
|
||||||
daemon_port = arg.port;
|
|
||||||
daemon_host = arg.adress;
|
|
||||||
connectDAEMON();
|
|
||||||
});
|
|
|
@ -1,37 +0,0 @@
|
||||||
const fs = require("fs");
|
|
||||||
const { ipcRenderer } = require("electron");
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Save config and update config setting globally
|
|
||||||
* @param {string} config - config data
|
|
||||||
* @param {string} configPath
|
|
||||||
*/
|
|
||||||
exports.saveConfig = function (config, configPath) {
|
|
||||||
fs.writeFileSync(configPath, JSON.stringify(config, null, 2));
|
|
||||||
ipcRenderer.send("set-config-global", config);
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Binary to ASCII replacement
|
|
||||||
* @param {string} data in normal/usual utf-8 format
|
|
||||||
* @returns base64 encoded string
|
|
||||||
*/
|
|
||||||
exports.btoa_FD = function (data) {
|
|
||||||
return Buffer.from(data, "utf-8").toString("base64");
|
|
||||||
};
|
|
||||||
/**
|
|
||||||
* ASCII to Binary replacement
|
|
||||||
* @param {string} data in base64 encoding
|
|
||||||
* @returns utf-8 normal/usual string
|
|
||||||
*/
|
|
||||||
exports.atob_FD = function (data) {
|
|
||||||
return Buffer.from(data, "base64").toString("utf-8");
|
|
||||||
};
|
|
||||||
/**
|
|
||||||
* UTF8 to ASCII btoa
|
|
||||||
* @param {string} data in base64 encoding
|
|
||||||
* @returns base64 bota compatible data for use in browser
|
|
||||||
*/
|
|
||||||
exports.atob = function (data) {
|
|
||||||
return window.btoa(Buffer.from(data, "base64").toString("utf8"));
|
|
||||||
};
|
|
|
@ -1 +1 @@
|
||||||
"use strict";const o=require("electron"),n=require("node:path");process.env.ELECTRON_DISABLE_SECURITY_WARNINGS="true";process.env.DIST=n.join(__dirname,"../dist");process.env.PUBLIC=o.app.isPackaged?process.env.DIST:n.join(process.env.DIST,"../public");let e;const s=process.env.VITE_DEV_SERVER_URL;function a(){e=new o.BrowserWindow({icon:n.join(process.env.PUBLIC,"electron-vite.svg"),webPreferences:{preload:n.join(__dirname,"preload-main.js"),backgroundThrottle:!1,nodeIntegration:!0,contextIsolation:!1,enableRemoteModule:!1,sandbox:!1}}),e.webContents.on("did-finish-load",()=>{e==null||e.webContents.send("main-process-message",new Date().toLocaleString())}),s?e.loadURL(s):e.loadFile(n.join(process.env.DIST,"index.html"))}o.app.on("window-all-closed",()=>{e=null});o.app.whenReady().then(a);o.ipcMain.on("request-update-daemon-state",(i,t)=>{e.webContents.send("action-update-daemon-state",t)});
|
"use strict";const o=require("electron"),n=require("node:path");process.env.ELECTRON_DISABLE_SECURITY_WARNINGS="true";process.env.DIST=n.join(__dirname,"../dist");process.env.PUBLIC=o.app.isPackaged?process.env.DIST:n.join(process.env.DIST,"../public");let e;const s=process.env.VITE_DEV_SERVER_URL;function a(){e=new o.BrowserWindow({icon:n.join(process.env.PUBLIC,"electron-vite.svg"),webPreferences:{preload:n.join(__dirname,"preload.js"),backgroundThrottle:!1,nodeIntegration:!0,contextIsolation:!1,enableRemoteModule:!1,sandbox:!1}}),e.webContents.on("did-finish-load",()=>{e==null||e.webContents.send("main-process-message",new Date().toLocaleString())}),s?e.loadURL(s):e.loadFile(n.join(process.env.DIST,"index.html"))}o.app.on("window-all-closed",()=>{e=null});o.app.whenReady().then(a);o.ipcMain.on("request-update-daemon-state",(r,t)=>{e.webContents.send("action-update-daemon-state",t)});
|
||||||
|
|
File diff suppressed because it is too large
Load diff
|
@ -1,186 +0,0 @@
|
||||||
const path = require("path");
|
|
||||||
const { ipcRenderer } = require("electron");
|
|
||||||
|
|
||||||
// https://stackoverflow.com/a/26227660
|
|
||||||
var appDataFolder =
|
|
||||||
process.env.APPDATA ||
|
|
||||||
(process.platform == "darwin"
|
|
||||||
? process.env.HOME + "/Library/Application Support"
|
|
||||||
: process.env.HOME + "/.config");
|
|
||||||
var configFolder = path.join(appDataFolder, "FreeDATA");
|
|
||||||
var configPath = path.join(configFolder, "config.json");
|
|
||||||
const config = require(configPath);
|
|
||||||
|
|
||||||
// WINDOW LISTENER
|
|
||||||
window.addEventListener("DOMContentLoaded", () => {
|
|
||||||
document
|
|
||||||
.getElementById("enable_filter_info")
|
|
||||||
.addEventListener("click", () => {
|
|
||||||
if (document.getElementById("enable_filter_info").checked) {
|
|
||||||
display_class("table-info", true);
|
|
||||||
} else {
|
|
||||||
display_class("table-info", false);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
document
|
|
||||||
.getElementById("enable_filter_debug")
|
|
||||||
.addEventListener("click", () => {
|
|
||||||
if (document.getElementById("enable_filter_debug").checked) {
|
|
||||||
display_class("table-debug", true);
|
|
||||||
} else {
|
|
||||||
display_class("table-debug", false);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
document
|
|
||||||
.getElementById("enable_filter_warning")
|
|
||||||
.addEventListener("click", () => {
|
|
||||||
if (document.getElementById("enable_filter_warning").checked) {
|
|
||||||
display_class("table-warning", true);
|
|
||||||
} else {
|
|
||||||
display_class("table-warning", false);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
document
|
|
||||||
.getElementById("enable_filter_error")
|
|
||||||
.addEventListener("click", () => {
|
|
||||||
if (document.getElementById("enable_filter_error").checked) {
|
|
||||||
display_class("table-danger", true);
|
|
||||||
} else {
|
|
||||||
display_class("table-danger", false);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
function display_class(class_name, state) {
|
|
||||||
var collection = document.getElementsByClassName(class_name);
|
|
||||||
console.log(collection);
|
|
||||||
for (let i = 0; i < collection.length; i++) {
|
|
||||||
if (state == true) {
|
|
||||||
collection[i].style.display = "table-row";
|
|
||||||
} else {
|
|
||||||
collection[i].style.display = "None";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
ipcRenderer.on("action-update-log", (event, arg) => {
|
|
||||||
var entry = arg.entry;
|
|
||||||
|
|
||||||
// remove ANSI characters from string, caused by color logging
|
|
||||||
// https://stackoverflow.com/a/29497680
|
|
||||||
entry = entry.replace(
|
|
||||||
/[\u001b\u009b][[()#;?]*(?:[0-9]{1,4}(?:;[0-9]{0,4})*)?[0-9A-ORZcf-nqry=><]/g,
|
|
||||||
"",
|
|
||||||
);
|
|
||||||
|
|
||||||
var tbl = document.getElementById("log");
|
|
||||||
var row = document.createElement("tr");
|
|
||||||
|
|
||||||
var timestamp = document.createElement("td");
|
|
||||||
var timestampText = document.createElement("span");
|
|
||||||
|
|
||||||
//datetime = new Date();
|
|
||||||
//timestampText.innerText = datetime.toISOString();
|
|
||||||
timestampText.innerText = entry.slice(0, 19);
|
|
||||||
timestamp.appendChild(timestampText);
|
|
||||||
|
|
||||||
var type = document.createElement("td");
|
|
||||||
var typeText = document.createElement("span");
|
|
||||||
// typeText.innerText = entry.slice(10, 30).match(/[\[](.*)[^\]]/g);
|
|
||||||
console.log(entry.match(/\[[^\]]+\]/g));
|
|
||||||
|
|
||||||
try {
|
|
||||||
typeText.innerText = entry.match(/\[[^\]]+\]/g)[0];
|
|
||||||
} catch (e) {
|
|
||||||
typeText.innerText = "-";
|
|
||||||
}
|
|
||||||
|
|
||||||
// let res = str.match(/[\[](.*)[^\]]/g);
|
|
||||||
|
|
||||||
type.appendChild(typeText);
|
|
||||||
|
|
||||||
var area = document.createElement("td");
|
|
||||||
var areaText = document.createElement("span");
|
|
||||||
//areaText.innerText = entry.slice(10, 50).match(/[\] \[](.*)[^\]]/g);
|
|
||||||
//areaText.innerText = entry.match(/\[[^\]]+\]/g)[1];
|
|
||||||
|
|
||||||
try {
|
|
||||||
areaText.innerText = entry.match(/\[[^\]]+\]/g)[1];
|
|
||||||
} catch (e) {
|
|
||||||
areaText.innerText = "-";
|
|
||||||
}
|
|
||||||
area.appendChild(areaText);
|
|
||||||
|
|
||||||
var logEntry = document.createElement("td");
|
|
||||||
var logEntryText = document.createElement("span");
|
|
||||||
try {
|
|
||||||
logEntryText.innerText = entry.split("]")[2];
|
|
||||||
} catch (e) {
|
|
||||||
logEntryText.innerText = "-";
|
|
||||||
}
|
|
||||||
logEntry.appendChild(logEntryText);
|
|
||||||
|
|
||||||
row.appendChild(timestamp);
|
|
||||||
row.appendChild(type);
|
|
||||||
row.appendChild(area);
|
|
||||||
row.appendChild(logEntry);
|
|
||||||
|
|
||||||
//row.classList.add("table-blablubb");
|
|
||||||
/*
|
|
||||||
if (logEntryText.innerText.includes('ALSA lib pcm')) {
|
|
||||||
row.classList.add("table-secondary");
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
if (typeText.innerText.includes("info")) {
|
|
||||||
row.classList.add("table-info");
|
|
||||||
}
|
|
||||||
if (typeText.innerText.includes("debug")) {
|
|
||||||
row.classList.add("table-secondary");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (typeText.innerText.includes("warning")) {
|
|
||||||
row.classList.add("table-warning");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (typeText.innerText.includes("error")) {
|
|
||||||
row.classList.add("table-danger");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (document.getElementById("enable_filter_info").checked) {
|
|
||||||
row.style.display = "table-row";
|
|
||||||
display_class("table-info", true);
|
|
||||||
} else {
|
|
||||||
row.style.display = "None";
|
|
||||||
display_class("table-info", false);
|
|
||||||
}
|
|
||||||
if (document.getElementById("enable_filter_debug").checked) {
|
|
||||||
row.style.display = "table-row";
|
|
||||||
display_class("table-secondary", true);
|
|
||||||
} else {
|
|
||||||
row.style.display = "None";
|
|
||||||
display_class("table-secondary", false);
|
|
||||||
}
|
|
||||||
if (document.getElementById("enable_filter_warning").checked) {
|
|
||||||
row.style.display = "table-row";
|
|
||||||
display_class("table-warning", true);
|
|
||||||
} else {
|
|
||||||
row.style.display = "None";
|
|
||||||
display_class("table-warning", false);
|
|
||||||
}
|
|
||||||
if (document.getElementById("enable_filter_error").checked) {
|
|
||||||
row.style.display = "table-row";
|
|
||||||
display_class("table-danger", true);
|
|
||||||
} else {
|
|
||||||
row.style.display = "None";
|
|
||||||
display_class("table-danger", false);
|
|
||||||
}
|
|
||||||
|
|
||||||
tbl.appendChild(row);
|
|
||||||
|
|
||||||
// scroll to bottom of page
|
|
||||||
// https://stackoverflow.com/a/11715670
|
|
||||||
window.scrollTo(0, document.body.scrollHeight);
|
|
||||||
});
|
|
File diff suppressed because it is too large
Load diff
|
@ -1,231 +0,0 @@
|
||||||
const path = require("path");
|
|
||||||
const { ipcRenderer } = require("electron");
|
|
||||||
|
|
||||||
// https://stackoverflow.com/a/26227660
|
|
||||||
var appDataFolder =
|
|
||||||
process.env.APPDATA ||
|
|
||||||
(process.platform == "darwin"
|
|
||||||
? process.env.HOME + "/Library/Application Support"
|
|
||||||
: process.env.HOME + "/.config");
|
|
||||||
var configFolder = path.join(appDataFolder, "FreeDATA");
|
|
||||||
var configPath = path.join(configFolder, "config.json");
|
|
||||||
const config = require(configPath);
|
|
||||||
|
|
||||||
var callsignPath = path.join(configFolder, "callsigns.json");
|
|
||||||
const callsigns = require(callsignPath);
|
|
||||||
|
|
||||||
// WINDOW LISTENER
|
|
||||||
window.addEventListener("DOMContentLoaded", () => {
|
|
||||||
// startPing button clicked
|
|
||||||
document
|
|
||||||
.getElementById("transmit_mesh_ping")
|
|
||||||
.addEventListener("click", () => {
|
|
||||||
var dxcallsign = document
|
|
||||||
.getElementById("dxCallMesh")
|
|
||||||
.value.toUpperCase();
|
|
||||||
if (dxcallsign == "" || dxcallsign == null || dxcallsign == undefined)
|
|
||||||
return;
|
|
||||||
//pauseButton(document.getElementById("transmit_mesh_ping"), 2000);
|
|
||||||
ipcRenderer.send("run-tnc-command", {
|
|
||||||
command: "mesh_ping",
|
|
||||||
dxcallsign: dxcallsign,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
ipcRenderer.on("action-update-mesh-table", (event, arg) => {
|
|
||||||
var routes = arg.routing_table;
|
|
||||||
|
|
||||||
if (typeof routes == "undefined") {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var tbl = document.getElementById("mesh-table");
|
|
||||||
if (tbl !== null) {
|
|
||||||
tbl.innerHTML = "";
|
|
||||||
}
|
|
||||||
|
|
||||||
for (i = 0; i < routes.length; i++) {
|
|
||||||
var row = document.createElement("tr");
|
|
||||||
var datetime = new Date(routes[i]["timestamp"] * 1000).toLocaleString(
|
|
||||||
navigator.language,
|
|
||||||
{
|
|
||||||
hourCycle: "h23",
|
|
||||||
year: "numeric",
|
|
||||||
month: "2-digit",
|
|
||||||
day: "2-digit",
|
|
||||||
hour: "2-digit",
|
|
||||||
minute: "2-digit",
|
|
||||||
second: "2-digit",
|
|
||||||
},
|
|
||||||
);
|
|
||||||
var timestamp = document.createElement("td");
|
|
||||||
var timestampText = document.createElement("span");
|
|
||||||
timestampText.innerText = datetime;
|
|
||||||
timestamp.appendChild(timestampText);
|
|
||||||
|
|
||||||
var dxcall = document.createElement("td");
|
|
||||||
var dxcallText = document.createElement("span");
|
|
||||||
dxcallText.innerText = routes[i]["dxcall"];
|
|
||||||
|
|
||||||
// check for callsign in callsign list, else use checksum
|
|
||||||
for (let call in callsigns) {
|
|
||||||
if (callsigns[call] == routes[i]["dxcall"]) {
|
|
||||||
dxcallText.innerText += " (" + call + ")";
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
dxcall.appendChild(dxcallText);
|
|
||||||
|
|
||||||
var router = document.createElement("td");
|
|
||||||
var routerText = document.createElement("span");
|
|
||||||
routerText.innerText = routes[i]["router"];
|
|
||||||
|
|
||||||
// check for callsign in callsign list, else use checksum
|
|
||||||
for (let call in callsigns) {
|
|
||||||
if (callsigns[call] == routes[i]["router"]) {
|
|
||||||
routerText.innerHTML += `<span class="badge ms-2 bg-secondary">${call}</span>`;
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
router.appendChild(routerText);
|
|
||||||
|
|
||||||
var hops = document.createElement("td");
|
|
||||||
var hopsText = document.createElement("span");
|
|
||||||
hopsText.innerText = routes[i]["hops"];
|
|
||||||
hops.appendChild(hopsText);
|
|
||||||
|
|
||||||
var score = document.createElement("td");
|
|
||||||
var scoreText = document.createElement("span");
|
|
||||||
scoreText.innerText = routes[i]["score"];
|
|
||||||
score.appendChild(scoreText);
|
|
||||||
|
|
||||||
var snr = document.createElement("td");
|
|
||||||
var snrText = document.createElement("span");
|
|
||||||
snrText.innerText = routes[i]["snr"];
|
|
||||||
snr.appendChild(snrText);
|
|
||||||
|
|
||||||
row.appendChild(timestamp);
|
|
||||||
row.appendChild(dxcall);
|
|
||||||
row.appendChild(router);
|
|
||||||
row.appendChild(hops);
|
|
||||||
row.appendChild(score);
|
|
||||||
row.appendChild(snr);
|
|
||||||
|
|
||||||
tbl.appendChild(row);
|
|
||||||
}
|
|
||||||
/*-------------------------------------------*/
|
|
||||||
var routes = arg.mesh_signalling_table;
|
|
||||||
|
|
||||||
//console.log(routes);
|
|
||||||
if (typeof routes == "undefined") {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var tbl = document.getElementById("mesh-signalling-table");
|
|
||||||
if (tbl !== null) {
|
|
||||||
tbl.innerHTML = "";
|
|
||||||
}
|
|
||||||
|
|
||||||
for (i = 0; i < routes.length; i++) {
|
|
||||||
var row = document.createElement("tr");
|
|
||||||
var datetime = new Date(routes[i]["timestamp"] * 1000).toLocaleString(
|
|
||||||
navigator.language,
|
|
||||||
{
|
|
||||||
hourCycle: "h23",
|
|
||||||
year: "numeric",
|
|
||||||
month: "2-digit",
|
|
||||||
day: "2-digit",
|
|
||||||
hour: "2-digit",
|
|
||||||
minute: "2-digit",
|
|
||||||
second: "2-digit",
|
|
||||||
},
|
|
||||||
);
|
|
||||||
var timestamp = document.createElement("td");
|
|
||||||
var timestampText = document.createElement("span");
|
|
||||||
timestampText.innerText = datetime;
|
|
||||||
timestamp.appendChild(timestampText);
|
|
||||||
|
|
||||||
var destination = document.createElement("td");
|
|
||||||
var destinationText = document.createElement("span");
|
|
||||||
destinationText.innerText = routes[i]["destination"];
|
|
||||||
// check for callsign in callsign list, else use checksum
|
|
||||||
for (let call in callsigns) {
|
|
||||||
if (callsigns[call] == routes[i]["destination"]) {
|
|
||||||
destinationText.innerHTML += `<span class="badge ms-2 bg-secondary">${call}</span>`;
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
destination.appendChild(destinationText);
|
|
||||||
|
|
||||||
var origin = document.createElement("td");
|
|
||||||
var originText = document.createElement("span");
|
|
||||||
originText.innerText = routes[i]["origin"];
|
|
||||||
// check for callsign in callsign list, else use checksum
|
|
||||||
for (let call in callsigns) {
|
|
||||||
if (callsigns[call] == routes[i]["origin"]) {
|
|
||||||
originText.innerHTML += `<span class="badge ms-2 bg-secondary">${call}</span>`;
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
origin.appendChild(originText);
|
|
||||||
|
|
||||||
var frametype = document.createElement("td");
|
|
||||||
var frametypeText = document.createElement("span");
|
|
||||||
frametypeText.innerText = routes[i]["frametype"];
|
|
||||||
frametype.appendChild(frametypeText);
|
|
||||||
|
|
||||||
var payload = document.createElement("td");
|
|
||||||
var payloadText = document.createElement("span");
|
|
||||||
payloadText.innerText = routes[i]["payload"];
|
|
||||||
payload.appendChild(payloadText);
|
|
||||||
|
|
||||||
var attempt = document.createElement("td");
|
|
||||||
var attemptText = document.createElement("span");
|
|
||||||
attemptText.innerText = routes[i]["attempt"];
|
|
||||||
attempt.appendChild(attemptText);
|
|
||||||
|
|
||||||
var status = document.createElement("td");
|
|
||||||
var statusText = document.createElement("span");
|
|
||||||
//statusText.innerText = routes[i]["status"];
|
|
||||||
switch (routes[i]["status"]) {
|
|
||||||
case "acknowledged":
|
|
||||||
var status_icon = '<i class="bi bi-check-circle-fill"></i>';
|
|
||||||
var status_color = "bg-success";
|
|
||||||
break;
|
|
||||||
case "acknowledging":
|
|
||||||
var status_icon = '<i class="bi bi-check-circle"></i>';
|
|
||||||
var status_color = "bg-warning";
|
|
||||||
break;
|
|
||||||
case "forwarding":
|
|
||||||
var status_icon = '<i class="bi bi-arrow-left-right"></i>';
|
|
||||||
var status_color = "bg-secondary";
|
|
||||||
break;
|
|
||||||
case "awaiting_ack":
|
|
||||||
var status_icon = '<i class="bi bi-clock-history"></i>';
|
|
||||||
var status_color = "bg-info";
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
var status_icon = '<i class="bi bi-question-circle-fill"></i>';
|
|
||||||
var status_color = "bg-primary";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
statusText.innerHTML = `
|
|
||||||
<span class="badge ${status_color}">${status_icon}</span>
|
|
||||||
<span class="badge ${status_color}">${routes[i]["status"]}</span>
|
|
||||||
`;
|
|
||||||
status.appendChild(statusText);
|
|
||||||
|
|
||||||
row.appendChild(timestamp);
|
|
||||||
row.appendChild(destination);
|
|
||||||
row.appendChild(origin);
|
|
||||||
row.appendChild(frametype);
|
|
||||||
row.appendChild(payload);
|
|
||||||
row.appendChild(attempt);
|
|
||||||
row.appendChild(status);
|
|
||||||
|
|
||||||
tbl.appendChild(row);
|
|
||||||
}
|
|
||||||
});
|
|
|
@ -1,939 +0,0 @@
|
||||||
var net = require("net");
|
|
||||||
const path = require("path");
|
|
||||||
const { ipcRenderer } = require("electron");
|
|
||||||
const FD = require("./freedata");
|
|
||||||
const log = require("electron-log");
|
|
||||||
const socketLog = log.scope("tnc");
|
|
||||||
//const utf8 = require("utf8");
|
|
||||||
|
|
||||||
// https://stackoverflow.com/a/26227660
|
|
||||||
var appDataFolder =
|
|
||||||
process.env.APPDATA ||
|
|
||||||
(process.platform == "darwin"
|
|
||||||
? process.env.HOME + "/Library/Application Support"
|
|
||||||
: process.env.HOME + "/.config");
|
|
||||||
var configFolder = path.join(appDataFolder, "FreeDATA");
|
|
||||||
var configPath = path.join(configFolder, "config.json");
|
|
||||||
const config = require(configPath);
|
|
||||||
|
|
||||||
var client = new net.Socket();
|
|
||||||
var socketchunk = ""; // Current message, per connection.
|
|
||||||
|
|
||||||
// split character
|
|
||||||
const split_char = "\0;\1;";
|
|
||||||
|
|
||||||
// globals for getting new data only if available so we are saving bandwidth
|
|
||||||
var rxBufferLengthTnc = 0;
|
|
||||||
var rxBufferLengthGui = 0;
|
|
||||||
//var rxMsgBufferLengthTnc = 0;
|
|
||||||
//var rxMsgBufferLengthGui = 0;
|
|
||||||
|
|
||||||
// global to keep track of TNC connection error emissions
|
|
||||||
var tncShowConnectStateError = 1;
|
|
||||||
|
|
||||||
// global for storing ip information
|
|
||||||
var tnc_port = config.tnc_port;
|
|
||||||
var tnc_host = config.tnc_host;
|
|
||||||
|
|
||||||
// network connection Timeout
|
|
||||||
setTimeout(connectTNC, 2000);
|
|
||||||
|
|
||||||
function connectTNC() {
|
|
||||||
//exports.connectTNC = function(){
|
|
||||||
//socketLog.info('connecting to TNC...')
|
|
||||||
|
|
||||||
//clear message buffer after reconnecting or initial connection
|
|
||||||
socketchunk = "";
|
|
||||||
|
|
||||||
if (config.tnclocation == "localhost") {
|
|
||||||
client.connect(3000, "127.0.0.1");
|
|
||||||
} else {
|
|
||||||
client.connect(tnc_port, tnc_host);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
client.on("connect", function (data) {
|
|
||||||
socketLog.info("TNC connection established");
|
|
||||||
let Data = {
|
|
||||||
busy_state: "-",
|
|
||||||
arq_state: "-",
|
|
||||||
//channel_state: "-",
|
|
||||||
frequency: "-",
|
|
||||||
mode: "-",
|
|
||||||
bandwidth: "-",
|
|
||||||
dbfs_level: 0,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-tnc-state", Data);
|
|
||||||
|
|
||||||
// also update tnc connection state
|
|
||||||
ipcRenderer.send("request-update-tnc-connection", {
|
|
||||||
tnc_connection: client.readyState,
|
|
||||||
});
|
|
||||||
|
|
||||||
tncShowConnectStateError = 1;
|
|
||||||
});
|
|
||||||
|
|
||||||
client.on("error", function (data) {
|
|
||||||
if (tncShowConnectStateError == 1) {
|
|
||||||
socketLog.error("TNC connection error");
|
|
||||||
tncShowConnectStateError = 0;
|
|
||||||
}
|
|
||||||
setTimeout(connectTNC, 500);
|
|
||||||
client.destroy();
|
|
||||||
let Data = {
|
|
||||||
tnc_connection: client.readyState,
|
|
||||||
busy_state: "-",
|
|
||||||
arq_state: "-",
|
|
||||||
//channel_state: "-",
|
|
||||||
frequency: "-",
|
|
||||||
mode: "-",
|
|
||||||
bandwidth: "-",
|
|
||||||
dbfs_level: 0,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-tnc-state", Data);
|
|
||||||
ipcRenderer.send("request-update-tnc-connection", {
|
|
||||||
tnc_connection: client.readyState,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
/*
|
|
||||||
client.on('close', function(data) {
|
|
||||||
socketLog.info(' TNC connection closed');
|
|
||||||
setTimeout(connectTNC, 2000)
|
|
||||||
});
|
|
||||||
*/
|
|
||||||
|
|
||||||
client.on("end", function (data) {
|
|
||||||
socketLog.info("TNC connection ended");
|
|
||||||
ipcRenderer.send("request-update-tnc-connection", {
|
|
||||||
tnc_connection: client.readyState,
|
|
||||||
});
|
|
||||||
client.destroy();
|
|
||||||
|
|
||||||
setTimeout(connectTNC, 500);
|
|
||||||
});
|
|
||||||
|
|
||||||
writeTncCommand = function (command) {
|
|
||||||
//socketLog.info(command)
|
|
||||||
// we use the writingCommand function to update our TCPIP state because we are calling this function a lot
|
|
||||||
// if socket opened, we are able to run commands
|
|
||||||
|
|
||||||
if (client.readyState == "open") {
|
|
||||||
client.write(command + "\n");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (client.readyState == "closed") {
|
|
||||||
socketLog.info("CLOSED!");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (client.readyState == "opening") {
|
|
||||||
socketLog.info("connecting to TNC...");
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
client.on("data", function (socketdata) {
|
|
||||||
ipcRenderer.send("request-update-tnc-connection", {
|
|
||||||
tnc_connection: client.readyState,
|
|
||||||
});
|
|
||||||
|
|
||||||
/*
|
|
||||||
inspired by:
|
|
||||||
stackoverflow.com questions 9070700 nodejs-net-createserver-large-amount-of-data-coming-in
|
|
||||||
*/
|
|
||||||
|
|
||||||
socketdata = socketdata.toString("utf8"); // convert data to string
|
|
||||||
socketchunk += socketdata; // append data to buffer so we can stick long data together
|
|
||||||
|
|
||||||
// check if we received begin and end of json data
|
|
||||||
if (socketchunk.startsWith('{"') && socketchunk.endsWith('"}\n')) {
|
|
||||||
var data = "";
|
|
||||||
|
|
||||||
// split data into chunks if we received multiple commands
|
|
||||||
socketchunk = socketchunk.split("\n");
|
|
||||||
//don't think this is needed anymore
|
|
||||||
//data = JSON.parse(socketchunk[0])
|
|
||||||
|
|
||||||
// search for empty entries in socketchunk and remove them
|
|
||||||
for (i = 0; i < socketchunk.length; i++) {
|
|
||||||
if (socketchunk[i] === "") {
|
|
||||||
socketchunk.splice(i, 1);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//iterate through socketchunks array to execute multiple commands in row
|
|
||||||
for (i = 0; i < socketchunk.length; i++) {
|
|
||||||
//check if data is not empty
|
|
||||||
if (socketchunk[i].length > 0) {
|
|
||||||
//try to parse JSON
|
|
||||||
try {
|
|
||||||
data = JSON.parse(socketchunk[i]);
|
|
||||||
} catch (e) {
|
|
||||||
socketLog.info("Throwing away data!!!!\n" + e); // "SyntaxError
|
|
||||||
//socketLog.info(e); // "SyntaxError
|
|
||||||
socketLog.info(socketchunk[i]);
|
|
||||||
socketchunk = "";
|
|
||||||
//If we're here, I don't think we want to process any data that may be in data variable
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (data["command"] == "tnc_state") {
|
|
||||||
//socketLog.info(data)
|
|
||||||
// set length of RX Buffer to global variable
|
|
||||||
rxBufferLengthTnc = data["rx_buffer_length"];
|
|
||||||
//rxMsgBufferLengthTnc = data["rx_msg_buffer_length"];
|
|
||||||
|
|
||||||
let Data = {
|
|
||||||
mycallsign: data["mycallsign"],
|
|
||||||
mygrid: data["mygrid"],
|
|
||||||
ptt_state: data["ptt_state"],
|
|
||||||
busy_state: data["tnc_state"],
|
|
||||||
arq_state: data["arq_state"],
|
|
||||||
arq_session: data["arq_session"],
|
|
||||||
//channel_state: data['CHANNEL_STATE'],
|
|
||||||
frequency: data["frequency"],
|
|
||||||
speed_level: data["speed_level"],
|
|
||||||
mode: data["mode"],
|
|
||||||
bandwidth: data["bandwidth"],
|
|
||||||
dbfs_level: data["audio_dbfs"],
|
|
||||||
fft: data["fft"],
|
|
||||||
channel_busy: data["channel_busy"],
|
|
||||||
channel_busy_slot: data["channel_busy_slot"],
|
|
||||||
scatter: data["scatter"],
|
|
||||||
info: data["info"],
|
|
||||||
rx_buffer_length: data["rx_buffer_length"],
|
|
||||||
rx_msg_buffer_length: data["rx_msg_buffer_length"],
|
|
||||||
tx_n_max_retries: data["tx_n_max_retries"],
|
|
||||||
arq_tx_n_frames_per_burst: data["arq_tx_n_frames_per_burst"],
|
|
||||||
arq_tx_n_bursts: data["arq_tx_n_bursts"],
|
|
||||||
arq_tx_n_current_arq_frame: data["arq_tx_n_current_arq_frame"],
|
|
||||||
arq_tx_n_total_arq_frames: data["arq_tx_n_total_arq_frames"],
|
|
||||||
arq_rx_frame_n_bursts: data["arq_rx_frame_n_bursts"],
|
|
||||||
arq_rx_n_current_arq_frame: data["arq_rx_n_current_arq_frame"],
|
|
||||||
arq_n_arq_frames_per_data_frame:
|
|
||||||
data["arq_n_arq_frames_per_data_frame"],
|
|
||||||
arq_bytes_per_minute: data["arq_bytes_per_minute"],
|
|
||||||
arq_seconds_until_finish: data["arq_seconds_until_finish"],
|
|
||||||
arq_compression_factor: data["arq_compression_factor"],
|
|
||||||
total_bytes: data["total_bytes"],
|
|
||||||
arq_transmission_percent: data["arq_transmission_percent"],
|
|
||||||
stations: data["stations"],
|
|
||||||
routing_table: data["routing_table"],
|
|
||||||
mesh_signalling_table: data["mesh_signalling_table"],
|
|
||||||
beacon_state: data["beacon_state"],
|
|
||||||
hamlib_status: data["hamlib_status"],
|
|
||||||
listen: data["listen"],
|
|
||||||
audio_recording: data["audio_recording"],
|
|
||||||
speed_list: data["speed_list"],
|
|
||||||
strength: data["strength"],
|
|
||||||
is_codec2_traffic: data["is_codec2_traffic"],
|
|
||||||
//speed_table: [{"bpm" : 5200, "snr": -3, "timestamp":1673555399},{"bpm" : 2315, "snr": 12, "timestamp":1673555500}],
|
|
||||||
};
|
|
||||||
|
|
||||||
ipcRenderer.send("request-update-tnc-state", Data);
|
|
||||||
//continue to next for loop iteration, nothing else needs to be done here
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ----------- catch tnc messages START -----------
|
|
||||||
if (data["freedata"] == "tnc-message") {
|
|
||||||
switch (data["fec"]) {
|
|
||||||
case "is_writing":
|
|
||||||
// RX'd FECiswriting
|
|
||||||
ipcRenderer.send("request-show-fec-toast-iswriting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "broadcast":
|
|
||||||
// RX'd FEC BROADCAST
|
|
||||||
var encoded_data = FD.atob_FD(data["data"]);
|
|
||||||
var splitted_data = encoded_data.split(split_char);
|
|
||||||
var messageArray = [];
|
|
||||||
if (splitted_data[0] == "m") {
|
|
||||||
messageArray.push(data);
|
|
||||||
console.log(data);
|
|
||||||
}
|
|
||||||
|
|
||||||
let Messages = {
|
|
||||||
data: messageArray,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-new-msg-received", Messages);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (data["cq"]) {
|
|
||||||
case "transmitting":
|
|
||||||
// CQ TRANSMITTING
|
|
||||||
ipcRenderer.send("request-show-cq-toast-transmitting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "received":
|
|
||||||
// CQ RECEIVED
|
|
||||||
ipcRenderer.send("request-show-cq-toast-received", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (data["qrv"]) {
|
|
||||||
case "transmitting":
|
|
||||||
// QRV TRANSMITTING
|
|
||||||
ipcRenderer.send("request-show-qrv-toast-transmitting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "received":
|
|
||||||
// QRV RECEIVED
|
|
||||||
ipcRenderer.send("request-show-qrv-toast-received", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (data["beacon"]) {
|
|
||||||
case "transmitting":
|
|
||||||
// BEACON TRANSMITTING
|
|
||||||
ipcRenderer.send("request-show-beacon-toast-transmitting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "received":
|
|
||||||
// BEACON RECEIVED
|
|
||||||
ipcRenderer.send("request-show-beacon-toast-received", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
ipcRenderer.send("request-new-msg-received", { data: [data] });
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (data["ping"]) {
|
|
||||||
case "transmitting":
|
|
||||||
// PING TRANSMITTING
|
|
||||||
ipcRenderer.send("request-show-ping-toast-transmitting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "received":
|
|
||||||
// PING RECEIVED
|
|
||||||
ipcRenderer.send("request-show-ping-toast-received", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
ipcRenderer.send("request-new-msg-received", { data: [data] });
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "acknowledge":
|
|
||||||
// PING ACKNOWLEDGE
|
|
||||||
ipcRenderer.send("request-show-ping-toast-received-ack", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
ipcRenderer.send("request-new-msg-received", { data: [data] });
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ARQ SESSION && freedata == tnc-message
|
|
||||||
if (data["arq"] == "session") {
|
|
||||||
switch (data["status"]) {
|
|
||||||
case "connecting":
|
|
||||||
// ARQ Open
|
|
||||||
ipcRenderer.send("request-show-arq-toast-session-connecting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "connected":
|
|
||||||
// ARQ Opening
|
|
||||||
ipcRenderer.send("request-show-arq-toast-session-connected", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "waiting":
|
|
||||||
// ARQ Opening
|
|
||||||
ipcRenderer.send("request-show-arq-toast-session-waiting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "close":
|
|
||||||
// ARQ Closing
|
|
||||||
ipcRenderer.send("request-show-arq-toast-session-close", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "failed":
|
|
||||||
// ARQ Failed
|
|
||||||
ipcRenderer.send("request-show-arq-toast-session-failed", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// ARQ TRANSMISSION && freedata == tnc-message
|
|
||||||
if (data["arq"] == "transmission") {
|
|
||||||
switch (data["status"]) {
|
|
||||||
case "opened":
|
|
||||||
// ARQ Open
|
|
||||||
ipcRenderer.send("request-show-arq-toast-datachannel-opened", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "opening":
|
|
||||||
// ARQ Opening IRS/ISS
|
|
||||||
if (data["irs"] == "False") {
|
|
||||||
ipcRenderer.send("request-show-arq-toast-datachannel-opening", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
ipcRenderer.send("request-update-transmission-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
ipcRenderer.send(
|
|
||||||
"request-show-arq-toast-datachannel-received-opener",
|
|
||||||
{ data: [data] },
|
|
||||||
);
|
|
||||||
ipcRenderer.send("request-update-reception-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "waiting":
|
|
||||||
// ARQ waiting
|
|
||||||
ipcRenderer.send("request-show-arq-toast-datachannel-waiting", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "receiving":
|
|
||||||
// ARQ RX
|
|
||||||
ipcRenderer.send("request-update-reception-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "failed":
|
|
||||||
// ARQ TX Failed
|
|
||||||
if (data["reason"] == "protocol version missmatch") {
|
|
||||||
ipcRenderer.send(
|
|
||||||
"request-show-arq-toast-transmission-failed-ver",
|
|
||||||
{ data: [data] },
|
|
||||||
);
|
|
||||||
} else {
|
|
||||||
ipcRenderer.send("request-show-arq-toast-transmission-failed", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
}
|
|
||||||
switch (data["irs"]) {
|
|
||||||
case "True":
|
|
||||||
ipcRenderer.send("request-update-reception-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
ipcRenderer.send("request-update-transmission-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "received":
|
|
||||||
// ARQ Received
|
|
||||||
ipcRenderer.send("request-show-arq-toast-transmission-received", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
|
|
||||||
ipcRenderer.send("request-update-reception-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
|
|
||||||
dataArray = [];
|
|
||||||
messageArray = [];
|
|
||||||
|
|
||||||
socketLog.info(data);
|
|
||||||
// we need to encode here to do a deep check for checking if file or message
|
|
||||||
//var encoded_data = atob(data['data'])
|
|
||||||
var encoded_data = FD.atob_FD(data["data"]);
|
|
||||||
var splitted_data = encoded_data.split(split_char);
|
|
||||||
|
|
||||||
if (splitted_data[0] == "f") {
|
|
||||||
dataArray.push(data);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (splitted_data[0] == "m") {
|
|
||||||
messageArray.push(data);
|
|
||||||
console.log(data);
|
|
||||||
}
|
|
||||||
|
|
||||||
rxBufferLengthGui = dataArray.length;
|
|
||||||
let Files = {
|
|
||||||
data: dataArray,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-rx-buffer", Files);
|
|
||||||
ipcRenderer.send("request-new-msg-received", Files);
|
|
||||||
|
|
||||||
//rxMsgBufferLengthGui = messageArray.length;
|
|
||||||
let Messages = {
|
|
||||||
data: messageArray,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-new-msg-received", Messages);
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "transmitting":
|
|
||||||
// ARQ transmitting
|
|
||||||
ipcRenderer.send(
|
|
||||||
"request-show-arq-toast-transmission-transmitting",
|
|
||||||
{ data: [data] },
|
|
||||||
);
|
|
||||||
ipcRenderer.send("request-update-transmission-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "transmitted":
|
|
||||||
// ARQ transmitted
|
|
||||||
ipcRenderer.send(
|
|
||||||
"request-show-arq-toast-transmission-transmitted",
|
|
||||||
{ data: [data] },
|
|
||||||
);
|
|
||||||
ipcRenderer.send("request-update-transmission-status", {
|
|
||||||
data: [data],
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// ----------- catch tnc info messages END -----------
|
|
||||||
|
|
||||||
// if we manually checking for the rx buffer we are getting an array of multiple data
|
|
||||||
if (data["command"] == "rx_buffer") {
|
|
||||||
socketLog.info(data);
|
|
||||||
// iterate through buffer list and sort it to file or message array
|
|
||||||
dataArray = [];
|
|
||||||
messageArray = [];
|
|
||||||
|
|
||||||
for (i = 0; i < data["data-array"].length; i++) {
|
|
||||||
try {
|
|
||||||
// we need to encode here to do a deep check for checking if file or message
|
|
||||||
//var encoded_data = atob(data['data-array'][i]['data'])
|
|
||||||
var encoded_data = FD.atob_FD(data["data-array"][i]["data"]);
|
|
||||||
var splitted_data = encoded_data.split(split_char);
|
|
||||||
|
|
||||||
if (splitted_data[0] == "f") {
|
|
||||||
dataArray.push(data["data-array"][i]);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (splitted_data[0] == "m") {
|
|
||||||
messageArray.push(data["data-array"][i]);
|
|
||||||
}
|
|
||||||
} catch (e) {
|
|
||||||
socketLog.info(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
rxBufferLengthGui = dataArray.length;
|
|
||||||
let Files = {
|
|
||||||
data: dataArray,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-rx-buffer", Files);
|
|
||||||
|
|
||||||
//rxMsgBufferLengthGui = messageArray.length;
|
|
||||||
let Messages = {
|
|
||||||
data: messageArray,
|
|
||||||
};
|
|
||||||
//ipcRenderer.send('request-update-rx-msg-buffer', Messages);
|
|
||||||
ipcRenderer.send("request-new-msg-received", Messages);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//finally delete message buffer
|
|
||||||
socketchunk = "";
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
function hexToBytes(hex) {
|
|
||||||
for (var bytes = [], c = 0; c < hex.length; c += 2)
|
|
||||||
bytes.push(parseInt(hex.substr(c, 2), 16));
|
|
||||||
return bytes;
|
|
||||||
}
|
|
||||||
|
|
||||||
//Get TNC State
|
|
||||||
exports.getTncState = function () {
|
|
||||||
command = '{"type" : "get", "command" : "tnc_state"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
//Get DATA State
|
|
||||||
exports.getDataState = function () {
|
|
||||||
command = '{"type" : "get", "command" : "data_state"}';
|
|
||||||
//writeTncCommand(command)
|
|
||||||
};
|
|
||||||
|
|
||||||
// Send Ping
|
|
||||||
exports.sendPing = function (dxcallsign) {
|
|
||||||
command =
|
|
||||||
'{"type" : "ping", "command" : "ping", "dxcallsign" : "' +
|
|
||||||
dxcallsign +
|
|
||||||
'"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Send Mesh Ping
|
|
||||||
exports.sendMeshPing = function (dxcallsign) {
|
|
||||||
command =
|
|
||||||
'{"type" : "mesh", "command" : "ping", "dxcallsign" : "' +
|
|
||||||
dxcallsign +
|
|
||||||
'"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Send CQ
|
|
||||||
exports.sendCQ = function () {
|
|
||||||
command = '{"type" : "broadcast", "command" : "cqcqcq"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Set AUDIO Level
|
|
||||||
exports.setTxAudioLevel = function (value) {
|
|
||||||
command =
|
|
||||||
'{"type" : "set", "command" : "tx_audio_level", "value" : "' + value + '"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Send File
|
|
||||||
exports.sendFile = function (
|
|
||||||
dxcallsign,
|
|
||||||
mode,
|
|
||||||
frames,
|
|
||||||
filename,
|
|
||||||
filetype,
|
|
||||||
data,
|
|
||||||
checksum,
|
|
||||||
) {
|
|
||||||
socketLog.info(data);
|
|
||||||
socketLog.info(filetype);
|
|
||||||
socketLog.info(filename);
|
|
||||||
|
|
||||||
var datatype = "f";
|
|
||||||
|
|
||||||
data =
|
|
||||||
datatype +
|
|
||||||
split_char +
|
|
||||||
filename +
|
|
||||||
split_char +
|
|
||||||
filetype +
|
|
||||||
split_char +
|
|
||||||
checksum +
|
|
||||||
split_char +
|
|
||||||
data;
|
|
||||||
socketLog.info(data);
|
|
||||||
//socketLog.info(btoa(data))
|
|
||||||
//Btoa / atob will not work with charsets > 8 bits (i.e. the emojis); should probably move away from using it
|
|
||||||
//TODO: Will need to update anyother occurences and throughly test
|
|
||||||
//data = btoa(data)
|
|
||||||
data = FD.btoa_FD(data);
|
|
||||||
|
|
||||||
command =
|
|
||||||
'{"type" : "arq", "command" : "send_raw", "parameter" : [{"dxcallsign" : "' +
|
|
||||||
dxcallsign +
|
|
||||||
'", "mode" : "' +
|
|
||||||
mode +
|
|
||||||
'", "n_frames" : "' +
|
|
||||||
frames +
|
|
||||||
'", "data" : "' +
|
|
||||||
data +
|
|
||||||
'"}]}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Send Message
|
|
||||||
exports.sendMessage = function (
|
|
||||||
dxcallsign,
|
|
||||||
mode,
|
|
||||||
frames,
|
|
||||||
data,
|
|
||||||
checksum,
|
|
||||||
uuid,
|
|
||||||
command,
|
|
||||||
) {
|
|
||||||
data = FD.btoa_FD(
|
|
||||||
"m" +
|
|
||||||
split_char +
|
|
||||||
command +
|
|
||||||
split_char +
|
|
||||||
checksum +
|
|
||||||
split_char +
|
|
||||||
uuid +
|
|
||||||
split_char +
|
|
||||||
data,
|
|
||||||
);
|
|
||||||
command =
|
|
||||||
'{"type" : "arq", "command" : "send_raw", "uuid" : "' +
|
|
||||||
uuid +
|
|
||||||
'", "parameter" : [{"dxcallsign" : "' +
|
|
||||||
dxcallsign +
|
|
||||||
'", "mode" : "' +
|
|
||||||
mode +
|
|
||||||
'", "n_frames" : "' +
|
|
||||||
frames +
|
|
||||||
'", "data" : "' +
|
|
||||||
data +
|
|
||||||
'", "attempts": "10"}]}';
|
|
||||||
socketLog.info(command);
|
|
||||||
socketLog.info("-------------------------------------");
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Send Request message
|
|
||||||
//It would be then „m + split + request + split + request-type“
|
|
||||||
function sendRequest(dxcallsign, mode, frames, data, command) {
|
|
||||||
data = FD.btoa_FD("m" + split_char + command + split_char + data);
|
|
||||||
command =
|
|
||||||
'{"type" : "arq", "command" : "send_raw", "parameter" : [{"dxcallsign" : "' +
|
|
||||||
dxcallsign +
|
|
||||||
'", "mode" : "' +
|
|
||||||
mode +
|
|
||||||
'", "n_frames" : "' +
|
|
||||||
frames +
|
|
||||||
'", "data" : "' +
|
|
||||||
data +
|
|
||||||
'", "attempts": "10"}]}';
|
|
||||||
socketLog.info(command);
|
|
||||||
socketLog.info("--------------REQ--------------------");
|
|
||||||
writeTncCommand(command);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Send Response message
|
|
||||||
//It would be then „m + split + request + split + request-type“
|
|
||||||
function sendResponse(dxcallsign, mode, frames, data, command) {
|
|
||||||
data = FD.btoa_FD("m" + split_char + command + split_char + data);
|
|
||||||
command =
|
|
||||||
'{"type" : "arq", "command" : "send_raw", "parameter" : [{"dxcallsign" : "' +
|
|
||||||
dxcallsign +
|
|
||||||
'", "mode" : "' +
|
|
||||||
mode +
|
|
||||||
'", "n_frames" : "' +
|
|
||||||
frames +
|
|
||||||
'", "data" : "' +
|
|
||||||
data +
|
|
||||||
'", "attempts": "10"}]}';
|
|
||||||
socketLog.info(command);
|
|
||||||
socketLog.info("--------------RES--------------------");
|
|
||||||
writeTncCommand(command);
|
|
||||||
}
|
|
||||||
|
|
||||||
//Send station info request
|
|
||||||
exports.sendRequestInfo = function (dxcallsign) {
|
|
||||||
//Command 0 = user/station information
|
|
||||||
//Command 1 = shared folder list
|
|
||||||
//Command 2 = shared file transfer
|
|
||||||
sendRequest(dxcallsign, 255, 1, "0", "req");
|
|
||||||
};
|
|
||||||
|
|
||||||
//Send shared folder file list request
|
|
||||||
exports.sendRequestSharedFolderList = function (dxcallsign) {
|
|
||||||
//Command 0 = user/station information
|
|
||||||
//Command 1 = shared folder list
|
|
||||||
//Command 2 = shared file transfer
|
|
||||||
sendRequest(dxcallsign, 255, 1, "1", "req");
|
|
||||||
};
|
|
||||||
|
|
||||||
//Send shared file request
|
|
||||||
exports.sendRequestSharedFile = function (dxcallsign, file) {
|
|
||||||
//Command 0 = user/station information
|
|
||||||
//Command 1 = shared folder list
|
|
||||||
//Command 2 = shared file transfer
|
|
||||||
sendRequest(dxcallsign, 255, 1, "2" + file, "req");
|
|
||||||
};
|
|
||||||
|
|
||||||
//Send station info response
|
|
||||||
exports.sendResponseInfo = function (dxcallsign, userinfo) {
|
|
||||||
//Command 0 = user/station information
|
|
||||||
//Command 1 = shared folder list
|
|
||||||
//Command 2 = shared file transfer
|
|
||||||
sendResponse(dxcallsign, 255, 1, userinfo, "res-0");
|
|
||||||
};
|
|
||||||
|
|
||||||
//Send shared folder response
|
|
||||||
exports.sendResponseSharedFolderList = function (dxcallsign, sharedFolderList) {
|
|
||||||
//Command 0 = user/station information
|
|
||||||
//Command 1 = shared folder list
|
|
||||||
//Command 2 = shared file transfer
|
|
||||||
sendResponse(dxcallsign, 255, 1, sharedFolderList, "res-1");
|
|
||||||
};
|
|
||||||
|
|
||||||
//Send shared file response
|
|
||||||
exports.sendResponseSharedFile = function (
|
|
||||||
dxcallsign,
|
|
||||||
sharedFile,
|
|
||||||
sharedFileData,
|
|
||||||
) {
|
|
||||||
console.log(
|
|
||||||
"In sendResponseSharedFile",
|
|
||||||
dxcallsign,
|
|
||||||
sharedFile,
|
|
||||||
sharedFileData,
|
|
||||||
);
|
|
||||||
//Command 0 = user/station information
|
|
||||||
//Command 1 = shared folder list
|
|
||||||
//Command 2 = shared file transfer
|
|
||||||
sendResponse(dxcallsign, 255, 1, sharedFile + "/" + sharedFileData, "res-2");
|
|
||||||
};
|
|
||||||
|
|
||||||
//STOP TRANSMISSION
|
|
||||||
exports.stopTransmission = function () {
|
|
||||||
command = '{"type" : "arq", "command": "stop_transmission"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// Get RX BUffer
|
|
||||||
exports.getRxBuffer = function () {
|
|
||||||
command = '{"type" : "get", "command" : "rx_buffer"}';
|
|
||||||
|
|
||||||
// call command only if new data arrived
|
|
||||||
if (rxBufferLengthGui != rxBufferLengthTnc) {
|
|
||||||
writeTncCommand(command);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
// START BEACON
|
|
||||||
exports.startBeacon = function (interval) {
|
|
||||||
command =
|
|
||||||
'{"type" : "broadcast", "command" : "start_beacon", "parameter": "' +
|
|
||||||
interval +
|
|
||||||
'"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// STOP BEACON
|
|
||||||
exports.stopBeacon = function () {
|
|
||||||
command = '{"type" : "broadcast", "command" : "stop_beacon"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// OPEN ARQ SESSION
|
|
||||||
exports.connectARQ = function (dxcallsign) {
|
|
||||||
command =
|
|
||||||
'{"type" : "arq", "command" : "connect", "dxcallsign": "' +
|
|
||||||
dxcallsign +
|
|
||||||
'", "attempts": "10"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// CLOSE ARQ SESSION
|
|
||||||
exports.disconnectARQ = function () {
|
|
||||||
command = '{"type" : "arq", "command" : "disconnect"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// SEND TEST FRAME
|
|
||||||
exports.sendTestFrame = function () {
|
|
||||||
command = '{"type" : "set", "command" : "send_test_frame"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// SEND FEC
|
|
||||||
exports.sendFEC = function (mode, payload) {
|
|
||||||
command =
|
|
||||||
'{"type" : "fec", "command" : "transmit", "mode" : "' +
|
|
||||||
mode +
|
|
||||||
'", "payload" : "' +
|
|
||||||
payload +
|
|
||||||
'"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// SEND FEC IS WRITING
|
|
||||||
exports.sendFecIsWriting = function (mycallsign) {
|
|
||||||
command =
|
|
||||||
'{"type" : "fec", "command" : "transmit_is_writing", "mycallsign" : "' +
|
|
||||||
mycallsign +
|
|
||||||
'"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// SEND FEC TO BROADCASTCHANNEL
|
|
||||||
exports.sendBroadcastChannel = function (channel, data_out, uuid) {
|
|
||||||
let checksum = "";
|
|
||||||
let command = "";
|
|
||||||
let data = FD.btoa_FD(
|
|
||||||
"m" +
|
|
||||||
split_char +
|
|
||||||
channel +
|
|
||||||
//split_char +
|
|
||||||
//checksum +
|
|
||||||
split_char +
|
|
||||||
uuid +
|
|
||||||
split_char +
|
|
||||||
data_out,
|
|
||||||
);
|
|
||||||
console.log(data.length);
|
|
||||||
let payload = data;
|
|
||||||
command =
|
|
||||||
'{"type" : "fec", "command" : "transmit", "mode": "datac4", "wakeup": "True", "payload" : "' +
|
|
||||||
payload +
|
|
||||||
'"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// RECORD AUDIO
|
|
||||||
exports.record_audio = function () {
|
|
||||||
command = '{"type" : "set", "command" : "record_audio"}';
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// SET FREQUENCY
|
|
||||||
exports.set_frequency = function (frequency) {
|
|
||||||
command =
|
|
||||||
'{"type" : "set", "command" : "frequency", "frequency": ' + frequency + "}";
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// SET MODE
|
|
||||||
exports.set_mode = function (mode) {
|
|
||||||
command = '{"type" : "set", "command" : "mode", "mode": "' + mode + '"}';
|
|
||||||
console.log(command);
|
|
||||||
writeTncCommand(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
ipcRenderer.on("action-update-tnc-ip", (event, arg) => {
|
|
||||||
client.destroy();
|
|
||||||
let Data = {
|
|
||||||
busy_state: "-",
|
|
||||||
arq_state: "-",
|
|
||||||
//channel_state: "-",
|
|
||||||
frequency: "-",
|
|
||||||
mode: "-",
|
|
||||||
bandwidth: "-",
|
|
||||||
dbfs_level: 0,
|
|
||||||
};
|
|
||||||
ipcRenderer.send("request-update-tnc-state", Data);
|
|
||||||
tnc_port = arg.port;
|
|
||||||
tnc_host = arg.adress;
|
|
||||||
connectTNC();
|
|
||||||
});
|
|
||||||
|
|
||||||
// https://stackoverflow.com/a/50579690
|
|
||||||
// crc32 calculation
|
|
||||||
//console.log(crc32('abc'));
|
|
||||||
//console.log(crc32('abc').toString(16).toUpperCase()); // hex
|
|
||||||
var crc32 = function (r) {
|
|
||||||
for (var a, o = [], c = 0; c < 256; c++) {
|
|
||||||
a = c;
|
|
||||||
for (var f = 0; f < 8; f++) a = 1 & a ? 3988292384 ^ (a >>> 1) : a >>> 1;
|
|
||||||
o[c] = a;
|
|
||||||
}
|
|
||||||
for (var n = -1, t = 0; t < r.length; t++)
|
|
||||||
n = (n >>> 8) ^ o[255 & (n ^ r.charCodeAt(t))];
|
|
||||||
return (-1 ^ n) >>> 0;
|
|
||||||
};
|
|
Loading…
Reference in a new issue