2023-09-06 13:36:54 +00:00
|
|
|
var net = require("net");
|
|
|
|
const path = require("path");
|
2023-10-08 07:57:03 +00:00
|
|
|
//const FD = require("./src/js/freedata.js");
|
|
|
|
import {atob_FD, btoa_FD} from "./freedata.js"
|
2023-09-06 13:36:54 +00:00
|
|
|
//import FD from './freedata.js';
|
2023-10-08 07:57:03 +00:00
|
|
|
|
2023-10-09 14:11:01 +00:00
|
|
|
import {addDataToWaterfall} from "../js/waterfallHandler.js"
|
|
|
|
|
2023-10-08 07:57:03 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
import {
|
|
|
|
newMessageReceived,
|
|
|
|
newBeaconReceived,
|
|
|
|
updateTransmissionStatus,
|
|
|
|
setStateSuccess,
|
|
|
|
setStateFailed,
|
|
|
|
} from "./chatHandler.js";
|
|
|
|
import { displayToast } from "./popupHandler.js";
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// ----------------- init pinia stores -------------
|
2023-10-03 13:15:17 +00:00
|
|
|
import { setActivePinia } from "pinia";
|
|
|
|
import pinia from "../store/index";
|
2023-09-06 13:36:54 +00:00
|
|
|
setActivePinia(pinia);
|
2023-10-03 13:15:17 +00:00
|
|
|
import { useStateStore } from "../store/stateStore.js";
|
2023-09-06 13:36:54 +00:00
|
|
|
const stateStore = useStateStore(pinia);
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
import { useSettingsStore } from "../store/settingsStore.js";
|
2023-09-06 13:36:54 +00:00
|
|
|
const settings = useSettingsStore(pinia);
|
|
|
|
|
|
|
|
var client = new net.Socket();
|
|
|
|
var socketchunk = ""; // Current message, per connection.
|
|
|
|
|
|
|
|
// split character
|
|
|
|
//const split_char = "\0;\1;";
|
|
|
|
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;
|
|
|
|
|
|
|
|
// network connection Timeout
|
|
|
|
setTimeout(connectTNC, 2000);
|
|
|
|
|
|
|
|
function connectTNC() {
|
|
|
|
//exports.connectTNC = function(){
|
|
|
|
//console.log('connecting to TNC...')
|
|
|
|
|
|
|
|
//clear message buffer after reconnecting or initial connection
|
|
|
|
socketchunk = "";
|
|
|
|
|
2023-09-09 05:48:29 +00:00
|
|
|
client.connect(settings.tnc_port, settings.tnc_host);
|
2023-09-06 13:36:54 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
client.on("connect", function (data) {
|
|
|
|
console.log("TNC connection established");
|
|
|
|
|
|
|
|
stateStore.busy_state = "-";
|
|
|
|
stateStore.arq_state = "-";
|
|
|
|
stateStore.frequency = "-";
|
|
|
|
stateStore.mode = "-";
|
|
|
|
stateStore.bandwidth = "-";
|
|
|
|
stateStore.dbfs_level = 0;
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.updateTncState(client.readyState);
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
tncShowConnectStateError = 1;
|
|
|
|
});
|
|
|
|
|
|
|
|
client.on("error", function (data) {
|
|
|
|
if (tncShowConnectStateError == 1) {
|
|
|
|
console.log("TNC connection error");
|
|
|
|
tncShowConnectStateError = 0;
|
|
|
|
}
|
2023-10-03 13:15:17 +00:00
|
|
|
setTimeout(connectTNC, 500);
|
|
|
|
client.destroy();
|
|
|
|
stateStore.busy_state = "-";
|
|
|
|
stateStore.arq_state = "-";
|
|
|
|
stateStore.frequency = "-";
|
|
|
|
stateStore.mode = "-";
|
|
|
|
stateStore.bandwidth = "-";
|
|
|
|
stateStore.dbfs_level = 0;
|
|
|
|
stateStore.updateTncState(client.readyState);
|
2023-09-06 13:36:54 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
/*
|
|
|
|
client.on('close', function(data) {
|
|
|
|
console.log(' TNC connection closed');
|
|
|
|
setTimeout(connectTNC, 2000)
|
|
|
|
});
|
|
|
|
*/
|
|
|
|
|
|
|
|
client.on("end", function (data) {
|
2023-10-03 13:15:17 +00:00
|
|
|
console.log("TNC connection ended");
|
|
|
|
stateStore.busy_state = "-";
|
|
|
|
stateStore.arq_state = "-";
|
|
|
|
stateStore.frequency = "-";
|
|
|
|
stateStore.mode = "-";
|
|
|
|
stateStore.bandwidth = "-";
|
|
|
|
stateStore.dbfs_level = 0;
|
|
|
|
stateStore.updateTncState(client.readyState);
|
|
|
|
client.destroy();
|
|
|
|
|
|
|
|
setTimeout(connectTNC, 500);
|
2023-09-06 13:36:54 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
function writeTncCommand(command) {
|
2023-10-03 13:15:17 +00:00
|
|
|
console.log(command);
|
2023-09-06 13:36:54 +00:00
|
|
|
// 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") {
|
2023-09-20 04:46:37 +00:00
|
|
|
console.log("TNC SOCKET CONNECTION CLOSED!");
|
2023-09-06 13:36:54 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
if (client.readyState == "opening") {
|
|
|
|
console.log("connecting to TNC...");
|
|
|
|
}
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
client.on("data", function (socketdata) {
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.updateTncState(client.readyState);
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
/*
|
|
|
|
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 (var i = 0; i < socketchunk.length; i++) {
|
|
|
|
if (socketchunk[i] === "") {
|
|
|
|
socketchunk.splice(i, 1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
//iterate through socketchunks array to execute multiple commands in row
|
|
|
|
for (var 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("Throwing away data!!!!\n" + e); // "SyntaxError
|
|
|
|
//console.log(e); // "SyntaxError
|
|
|
|
console.log(socketchunk[i]);
|
|
|
|
socketchunk = "";
|
|
|
|
//If we're here, I don't think we want to process any data that may be in data variable
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
2023-10-18 11:45:57 +00:00
|
|
|
// console.log(data)
|
2023-09-06 13:36:54 +00:00
|
|
|
if (data["command"] == "tnc_state") {
|
2023-09-20 12:06:16 +00:00
|
|
|
//console.log(data)
|
2023-09-06 13:36:54 +00:00
|
|
|
// set length of RX Buffer to global variable
|
|
|
|
rxBufferLengthTnc = data["rx_buffer_length"];
|
|
|
|
//rxMsgBufferLengthTnc = data["rx_msg_buffer_length"];
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.frequency = data["frequency"];
|
|
|
|
stateStore.busy_state = data["tnc_state"];
|
|
|
|
stateStore.arq_state = data["arq_state"];
|
|
|
|
stateStore.mode = data["mode"];
|
|
|
|
stateStore.bandwidth = data["bandwidth"];
|
|
|
|
stateStore.dbfs_level = data["audio_dbfs"];
|
|
|
|
stateStore.ptt_state = data["ptt_state"];
|
|
|
|
stateStore.speed_level = data["speed_level"];
|
2023-10-09 14:11:01 +00:00
|
|
|
stateStore.fft = JSON.parse(data["fft"]);
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.channel_busy = data["channel_busy"];
|
|
|
|
stateStore.channel_busy_slot = data["channel_busy_slot"];
|
|
|
|
|
2023-10-09 14:11:01 +00:00
|
|
|
addDataToWaterfall(JSON.parse(data["fft"]))
|
|
|
|
|
|
|
|
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
if (data["scatter"].length > 0) {
|
|
|
|
stateStore.scatter = data["scatter"];
|
2023-10-02 18:02:56 +00:00
|
|
|
}
|
2023-09-09 16:29:32 +00:00
|
|
|
// s meter strength
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.s_meter_strength_raw = data["strength"];
|
2023-09-23 04:47:36 +00:00
|
|
|
if (stateStore.s_meter_strength_raw == "") {
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.s_meter_strength_raw = "Unsupported";
|
|
|
|
stateStore.s_meter_strength_percent = 0;
|
2023-09-23 04:47:36 +00:00
|
|
|
} else {
|
2023-10-03 13:15:17 +00:00
|
|
|
// https://www.moellerstudios.org/converting-amplitude-representations/
|
|
|
|
stateStore.s_meter_strength_percent = Math.round(
|
|
|
|
Math.pow(10, stateStore.s_meter_strength_raw / 20) * 100,
|
|
|
|
);
|
2023-09-23 04:47:36 +00:00
|
|
|
}
|
2023-09-20 18:38:21 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.dbfs_level_percent = Math.round(
|
|
|
|
Math.pow(10, stateStore.dbfs_level / 20) * 100,
|
|
|
|
);
|
|
|
|
stateStore.dbfs_level = Math.round(stateStore.dbfs_level);
|
2023-09-20 18:38:21 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.arq_total_bytes = data["total_bytes"];
|
|
|
|
stateStore.heard_stations = data["stations"];
|
|
|
|
stateStore.dxcallsign = data["dxcallsign"];
|
2023-09-20 18:38:21 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.beacon_state = data["beacon_state"];
|
|
|
|
stateStore.audio_recording = data["audio_recording"];
|
2023-09-09 18:29:47 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.hamlib_status = data["hamlib_status"];
|
|
|
|
stateStore.alc = data["alc"];
|
|
|
|
stateStore.rf_level = data["rf_level"];
|
2023-09-09 18:29:47 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.is_codec2_traffic = data["is_codec2_traffic"];
|
2023-09-09 18:29:47 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.arq_session_state = data["arq_session"];
|
|
|
|
stateStore.arq_state = data["arq_state"];
|
|
|
|
stateStore.arq_transmission_percent = data["arq_transmission_percent"];
|
|
|
|
stateStore.arq_seconds_until_finish = data["arq_seconds_until_finish"];
|
|
|
|
stateStore.arq_seconds_until_timeout =
|
|
|
|
data["arq_seconds_until_timeout"];
|
|
|
|
stateStore.arq_seconds_until_timeout_percent =
|
|
|
|
(stateStore.arq_seconds_until_timeout / 180) * 100;
|
2023-09-20 18:38:21 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
if (data["speed_list"].length > 0) {
|
|
|
|
prepareStatsDataForStore(data["speed_list"]);
|
|
|
|
}
|
2023-09-20 18:38:21 +00:00
|
|
|
|
2023-09-09 16:29:32 +00:00
|
|
|
// TODO: Remove ported objects
|
2023-09-06 13:36:54 +00:00
|
|
|
let Data = {
|
|
|
|
mycallsign: data["mycallsign"],
|
|
|
|
mygrid: data["mygrid"],
|
|
|
|
//channel_state: data['CHANNEL_STATE'],
|
2023-09-09 16:29:32 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
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:
|
2023-10-11 18:26:44 +00:00
|
|
|
data["arq_n_arq_frames_per_data_frame"],
|
2023-09-06 13:36:54 +00:00
|
|
|
arq_bytes_per_minute: data["arq_bytes_per_minute"],
|
|
|
|
arq_compression_factor: data["arq_compression_factor"],
|
|
|
|
routing_table: data["routing_table"],
|
|
|
|
mesh_signalling_table: data["mesh_signalling_table"],
|
|
|
|
listen: data["listen"],
|
|
|
|
//speed_table: [{"bpm" : 5200, "snr": -3, "timestamp":1673555399},{"bpm" : 2315, "snr": 12, "timestamp":1673555500}],
|
|
|
|
};
|
|
|
|
|
|
|
|
//continue to next for loop iteration, nothing else needs to be done here
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
// ----------- catch tnc messages START -----------
|
2023-09-20 17:19:10 +00:00
|
|
|
//init message variable
|
2023-10-03 13:15:17 +00:00
|
|
|
var message = "";
|
2023-09-06 13:36:54 +00:00
|
|
|
if (data["freedata"] == "tnc-message") {
|
2023-10-02 12:50:39 +00:00
|
|
|
// break early if we received a dummy callsign
|
|
|
|
// thats a kind of hotfix, as long as the tnc isnt handling this better
|
2023-10-15 07:57:35 +00:00
|
|
|
if (data["dxcallsign"] == "AA0AA-0" || data["dxcallsign"] == "ZZ9YY-0") {
|
2023-10-03 13:15:17 +00:00
|
|
|
break;
|
2023-10-02 12:50:39 +00:00
|
|
|
}
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
console.log(data);
|
2023-10-02 07:50:52 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
switch (data["fec"]) {
|
|
|
|
case "is_writing":
|
|
|
|
// RX'd FECiswriting
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "broadcast":
|
|
|
|
// RX'd FEC BROADCAST
|
2023-10-08 07:57:03 +00:00
|
|
|
var encoded_data = atob_FD(data["data"]);
|
2023-09-06 13:36:54 +00:00
|
|
|
var splitted_data = encoded_data.split(split_char);
|
|
|
|
var messageArray = [];
|
|
|
|
if (splitted_data[0] == "m") {
|
|
|
|
messageArray.push(data);
|
|
|
|
console.log(data);
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
switch (data["cq"]) {
|
|
|
|
case "transmitting":
|
|
|
|
// CQ TRANSMITTING
|
2023-10-03 13:15:17 +00:00
|
|
|
displayToast(
|
|
|
|
"success",
|
|
|
|
"bi-arrow-left-right",
|
|
|
|
"transmitting CQ",
|
|
|
|
5000,
|
|
|
|
);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "received":
|
|
|
|
// CQ RECEIVED
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "CQ from " + data["dxcallsign"];
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("success", "bi-person-arms-up", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
switch (data["qrv"]) {
|
|
|
|
case "transmitting":
|
|
|
|
// QRV TRANSMITTING
|
2023-10-03 13:15:17 +00:00
|
|
|
displayToast(
|
2023-10-18 12:40:33 +00:00
|
|
|
"info",
|
|
|
|
"bi-person-raised-hand",
|
2023-10-03 13:15:17 +00:00
|
|
|
"transmitting QRV ",
|
|
|
|
5000,
|
|
|
|
);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "received":
|
|
|
|
// QRV RECEIVED
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "QRV from " + data["dxcallsign"] + " | " + data["dxgrid"];
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("success", "bi-person-raised-hand", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
switch (data["beacon"]) {
|
|
|
|
case "transmitting":
|
|
|
|
// BEACON TRANSMITTING
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("success", "bi-broadcast-pin", "BEACON... ", 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "received":
|
|
|
|
// BEACON RECEIVED
|
2023-10-03 13:15:17 +00:00
|
|
|
newBeaconReceived(data);
|
2023-09-30 18:30:19 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
message =
|
|
|
|
"BEACON from " + data["dxcallsign"] + " | " + data["dxgrid"];
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("info", "bi-broadcast", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
switch (data["ping"]) {
|
|
|
|
case "transmitting":
|
|
|
|
// PING TRANSMITTING
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "PING to " + data["dxcallsign"];
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("success", "bi-arrow-right", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "received":
|
|
|
|
// PING RECEIVED
|
2023-10-03 13:15:17 +00:00
|
|
|
message =
|
|
|
|
"PING from " + data["dxcallsign"] + " | " + data["dxgrid"];
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("success", "bi-arrow-right-short", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "acknowledge":
|
|
|
|
// PING ACKNOWLEDGE
|
2023-10-03 13:15:17 +00:00
|
|
|
message =
|
|
|
|
"PING ACK from " + data["dxcallsign"] + " | " + data["dxgrid"];
|
2023-09-20 17:19:10 +00:00
|
|
|
displayToast("success", "bi-arrow-left-right", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
// ARQ SESSION && freedata == tnc-message
|
|
|
|
if (data["arq"] == "session") {
|
|
|
|
switch (data["status"]) {
|
|
|
|
case "connecting":
|
|
|
|
// ARQ Open
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "connected":
|
|
|
|
// ARQ Opening
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "waiting":
|
|
|
|
// ARQ Opening
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "close":
|
|
|
|
// ARQ Closing
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "failed":
|
|
|
|
// ARQ Failed
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// ARQ TRANSMISSION && freedata == tnc-message
|
|
|
|
if (data["arq"] == "transmission") {
|
|
|
|
switch (data["status"]) {
|
|
|
|
case "opened":
|
|
|
|
// ARQ Open
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "ARQ session opened:" + data["dxcallsign"];
|
|
|
|
displayToast("success", "bi-arrow-left-right", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "opening":
|
|
|
|
// ARQ Opening IRS/ISS
|
|
|
|
if (data["irs"] == "False") {
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "ARQ session opening:" + data["dxcallsign"];
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("info", "bi-arrow-left-right", message, 5000);
|
2023-09-09 16:29:32 +00:00
|
|
|
break;
|
2023-09-06 13:36:54 +00:00
|
|
|
} else {
|
2023-10-03 13:15:17 +00:00
|
|
|
message = data["dxcallsign"] + "is requesting an ARQ session";
|
|
|
|
displayToast("success", "bi-arrow-left-right", message, 5000);
|
2023-09-09 16:29:32 +00:00
|
|
|
break;
|
2023-09-06 13:36:54 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "waiting":
|
|
|
|
// ARQ waiting
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "busy channel | ARQ protocol is waiting";
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("warning", "bi-hourglass-split", message, 5000);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "receiving":
|
|
|
|
// ARQ RX
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "failed":
|
|
|
|
// ARQ TX Failed
|
|
|
|
if (data["reason"] == "protocol version missmatch") {
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "protocol version missmatch";
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("danger", "bi-chevron-bar-expand", message, 5000);
|
2023-10-03 13:15:17 +00:00
|
|
|
setStateFailed();
|
2023-10-02 18:50:24 +00:00
|
|
|
|
2023-09-09 16:29:32 +00:00
|
|
|
break;
|
2023-09-06 13:36:54 +00:00
|
|
|
} else {
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "transmission failed";
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("danger", "bi-x-octagon", message, 5000);
|
2023-10-03 13:15:17 +00:00
|
|
|
updateTransmissionStatus(data);
|
|
|
|
setStateFailed();
|
2023-09-09 16:29:32 +00:00
|
|
|
break;
|
2023-09-06 13:36:54 +00:00
|
|
|
}
|
|
|
|
switch (data["irs"]) {
|
|
|
|
case "True":
|
2023-10-03 13:15:17 +00:00
|
|
|
updateTransmissionStatus(data);
|
2023-10-02 18:50:24 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
default:
|
2023-10-03 13:15:17 +00:00
|
|
|
updateTransmissionStatus(data);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "received":
|
2023-09-20 12:06:16 +00:00
|
|
|
// ARQ data received
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
console.log(data);
|
|
|
|
// we need to encode here to do a deep check for checking if file or message
|
|
|
|
//var encoded_data = atob(data['data'])
|
2023-10-08 07:57:03 +00:00
|
|
|
var encoded_data = atob_FD(data["data"]);
|
2023-09-06 13:36:54 +00:00
|
|
|
var splitted_data = encoded_data.split(split_char);
|
|
|
|
|
2023-09-20 12:06:16 +00:00
|
|
|
// new message received
|
2023-09-06 13:36:54 +00:00
|
|
|
if (splitted_data[0] == "m") {
|
2023-10-03 13:15:17 +00:00
|
|
|
console.log(splitted_data);
|
|
|
|
newMessageReceived(splitted_data, data);
|
2023-09-06 13:36:54 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
case "transmitting":
|
|
|
|
// ARQ transmitting
|
2023-10-03 13:15:17 +00:00
|
|
|
updateTransmissionStatus(data);
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
|
|
|
|
case "transmitted":
|
|
|
|
// ARQ transmitted
|
2023-10-03 13:15:17 +00:00
|
|
|
message = "data transmitted";
|
2023-10-18 12:40:33 +00:00
|
|
|
displayToast("success", "bi-check-sqaure", message, 5000);
|
2023-10-03 13:15:17 +00:00
|
|
|
updateTransmissionStatus(data);
|
|
|
|
setStateSuccess();
|
2023-10-02 18:50:24 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
//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 () {
|
2023-10-03 13:15:17 +00:00
|
|
|
function getTncState() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "get", "command" : "tnc_state"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//Get DATA State
|
|
|
|
//exports.getDataState = function () {
|
2023-10-03 13:15:17 +00:00
|
|
|
function getDataState() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "get", "command" : "data_state"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
//writeTncCommand(command)
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Send Ping
|
|
|
|
//exports.sendPing = function (dxcallsign) {
|
2023-10-03 13:15:17 +00:00
|
|
|
export function sendPing(dxcallsign) {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command =
|
2023-09-06 13:36:54 +00:00
|
|
|
'{"type" : "ping", "command" : "ping", "dxcallsign" : "' +
|
|
|
|
dxcallsign +
|
|
|
|
'"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Send Mesh Ping
|
|
|
|
//exports.sendMeshPing = function (dxcallsign) {
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendMeshPing(dxcallsign) {
|
2023-09-06 13:36:54 +00:00
|
|
|
command =
|
|
|
|
'{"type" : "mesh", "command" : "ping", "dxcallsign" : "' +
|
|
|
|
dxcallsign +
|
|
|
|
'"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Send CQ
|
|
|
|
//exports.sendCQ = function () {
|
2023-10-03 13:15:17 +00:00
|
|
|
export function sendCQ() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "broadcast", "command" : "cqcqcq"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Set AUDIO Level
|
2023-10-03 13:15:17 +00:00
|
|
|
export function setTxAudioLevel(value) {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command =
|
2023-09-06 13:36:54 +00:00
|
|
|
'{"type" : "set", "command" : "tx_audio_level", "value" : "' + value + '"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Send File
|
|
|
|
//exports.sendFile = function (
|
|
|
|
function sendFile(
|
|
|
|
dxcallsign,
|
|
|
|
mode,
|
|
|
|
frames,
|
|
|
|
filename,
|
|
|
|
filetype,
|
|
|
|
data,
|
|
|
|
checksum,
|
|
|
|
) {
|
|
|
|
console.log(data);
|
|
|
|
console.log(filetype);
|
|
|
|
console.log(filename);
|
|
|
|
|
|
|
|
var datatype = "f";
|
|
|
|
|
|
|
|
data =
|
|
|
|
datatype +
|
|
|
|
split_char +
|
|
|
|
filename +
|
|
|
|
split_char +
|
|
|
|
filetype +
|
|
|
|
split_char +
|
|
|
|
checksum +
|
|
|
|
split_char +
|
|
|
|
data;
|
|
|
|
console.log(data);
|
|
|
|
//console.log(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)
|
2023-10-08 07:57:03 +00:00
|
|
|
data = btoa_FD(data);
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
command =
|
|
|
|
'{"type" : "arq", "command" : "send_raw", "parameter" : [{"dxcallsign" : "' +
|
|
|
|
dxcallsign +
|
|
|
|
'", "mode" : "' +
|
|
|
|
mode +
|
|
|
|
'", "n_frames" : "' +
|
|
|
|
frames +
|
|
|
|
'", "data" : "' +
|
|
|
|
data +
|
|
|
|
'"}]}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Send Message
|
2023-10-18 12:29:51 +00:00
|
|
|
export function sendMessage(obj) {
|
|
|
|
|
|
|
|
let dxcallsign = obj.dxcallsign
|
|
|
|
let checksum = obj.checksum
|
|
|
|
let uuid = obj.uuid
|
|
|
|
let command = obj.command
|
|
|
|
|
|
|
|
let filename = Object.keys(obj._attachments)[0]
|
|
|
|
//let filetype = filename.split(".")[1]
|
|
|
|
let filetype = obj._attachments[filename].content_type
|
|
|
|
let file = obj._attachments[filename].data
|
|
|
|
|
|
|
|
//console.log(obj._attachments)
|
|
|
|
//console.log(filename)
|
|
|
|
//console.log(filetype)
|
|
|
|
//console.log(file)
|
|
|
|
|
|
|
|
|
|
|
|
let data_with_attachment =
|
|
|
|
obj.timestamp +
|
|
|
|
split_char +
|
|
|
|
obj.msg +
|
|
|
|
split_char +
|
|
|
|
filename +
|
|
|
|
split_char +
|
|
|
|
filetype +
|
|
|
|
split_char +
|
|
|
|
file;
|
|
|
|
|
|
|
|
let data = btoa_FD(
|
2023-09-06 13:36:54 +00:00
|
|
|
"m" +
|
|
|
|
split_char +
|
|
|
|
command +
|
|
|
|
split_char +
|
|
|
|
checksum +
|
|
|
|
split_char +
|
|
|
|
uuid +
|
|
|
|
split_char +
|
2023-10-18 12:29:51 +00:00
|
|
|
data_with_attachment,
|
2023-09-06 13:36:54 +00:00
|
|
|
);
|
2023-09-20 04:46:37 +00:00
|
|
|
|
|
|
|
// TODO: REMOVE mode and frames from TNC!
|
2023-10-03 13:15:17 +00:00
|
|
|
var mode = 255;
|
|
|
|
var frames = 5;
|
2023-09-20 04:46:37 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
command =
|
|
|
|
'{"type" : "arq", "command" : "send_raw", "uuid" : "' +
|
|
|
|
uuid +
|
|
|
|
'", "parameter" : [{"dxcallsign" : "' +
|
|
|
|
dxcallsign +
|
|
|
|
'", "mode" : "' +
|
|
|
|
mode +
|
|
|
|
'", "n_frames" : "' +
|
|
|
|
frames +
|
|
|
|
'", "data" : "' +
|
|
|
|
data +
|
|
|
|
'", "attempts": "10"}]}';
|
|
|
|
console.log(command);
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Send Request message
|
|
|
|
//It would be then „m + split + request + split + request-type“
|
|
|
|
function sendRequest(dxcallsign, mode, frames, data, command) {
|
2023-10-08 07:57:03 +00:00
|
|
|
data = btoa_FD("m" + split_char + command + split_char + data);
|
2023-09-06 13:36:54 +00:00
|
|
|
command =
|
|
|
|
'{"type" : "arq", "command" : "send_raw", "parameter" : [{"dxcallsign" : "' +
|
|
|
|
dxcallsign +
|
|
|
|
'", "mode" : "' +
|
|
|
|
mode +
|
|
|
|
'", "n_frames" : "' +
|
|
|
|
frames +
|
|
|
|
'", "data" : "' +
|
|
|
|
data +
|
|
|
|
'", "attempts": "10"}]}';
|
|
|
|
console.log(command);
|
|
|
|
console.log("--------------REQ--------------------");
|
|
|
|
writeTncCommand(command);
|
|
|
|
}
|
|
|
|
|
|
|
|
// Send Response message
|
|
|
|
//It would be then „m + split + request + split + request-type“
|
|
|
|
function sendResponse(dxcallsign, mode, frames, data, command) {
|
2023-10-08 07:57:03 +00:00
|
|
|
data = btoa_FD("m" + split_char + command + split_char + data);
|
2023-09-06 13:36:54 +00:00
|
|
|
command =
|
|
|
|
'{"type" : "arq", "command" : "send_raw", "parameter" : [{"dxcallsign" : "' +
|
|
|
|
dxcallsign +
|
|
|
|
'", "mode" : "' +
|
|
|
|
mode +
|
|
|
|
'", "n_frames" : "' +
|
|
|
|
frames +
|
|
|
|
'", "data" : "' +
|
|
|
|
data +
|
|
|
|
'", "attempts": "10"}]}';
|
|
|
|
console.log(command);
|
|
|
|
console.log("--------------RES--------------------");
|
|
|
|
writeTncCommand(command);
|
|
|
|
}
|
|
|
|
|
|
|
|
//Send station info request
|
|
|
|
//exports.sendRequestInfo = function (dxcallsign) {
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendRequestInfo(dxcallsign) {
|
2023-09-06 13:36:54 +00:00
|
|
|
//Command 0 = user/station information
|
|
|
|
//Command 1 = shared folder list
|
|
|
|
//Command 2 = shared file transfer
|
|
|
|
sendRequest(dxcallsign, 255, 1, "0", "req");
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//Send shared folder file list request
|
|
|
|
//exports.sendRequestSharedFolderList = function (dxcallsign) {
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendRequestSharedFolderList(dxcallsign) {
|
2023-09-06 13:36:54 +00:00
|
|
|
//Command 0 = user/station information
|
|
|
|
//Command 1 = shared folder list
|
|
|
|
//Command 2 = shared file transfer
|
|
|
|
sendRequest(dxcallsign, 255, 1, "1", "req");
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//Send shared file request
|
|
|
|
//exports.sendRequestSharedFile = function (dxcallsign, file) {
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendRequestSharedFile(dxcallsign, file) {
|
2023-09-06 13:36:54 +00:00
|
|
|
//Command 0 = user/station information
|
|
|
|
//Command 1 = shared folder list
|
|
|
|
//Command 2 = shared file transfer
|
|
|
|
sendRequest(dxcallsign, 255, 1, "2" + file, "req");
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//Send station info response
|
|
|
|
//exports.sendResponseInfo = function (dxcallsign, userinfo) {
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendResponseInfo(dxcallsign, userinfo) {
|
2023-09-06 13:36:54 +00:00
|
|
|
//Command 0 = user/station information
|
|
|
|
//Command 1 = shared folder list
|
|
|
|
//Command 2 = shared file transfer
|
|
|
|
sendResponse(dxcallsign, 255, 1, userinfo, "res-0");
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//Send shared folder response
|
|
|
|
//exports.sendResponseSharedFolderList = function (dxcallsign, sharedFolderList) {
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendResponseSharedFolderList(dxcallsign, sharedFolderList) {
|
2023-09-06 13:36:54 +00:00
|
|
|
//Command 0 = user/station information
|
|
|
|
//Command 1 = shared folder list
|
|
|
|
//Command 2 = shared file transfer
|
|
|
|
sendResponse(dxcallsign, 255, 1, sharedFolderList, "res-1");
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//Send shared file response
|
|
|
|
//exports.sendResponseSharedFile = function (
|
2023-10-03 13:15:17 +00:00
|
|
|
function sendResponseSharedFile(dxcallsign, sharedFile, sharedFileData) {
|
2023-09-06 13:36:54 +00:00
|
|
|
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");
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
//STOP TRANSMISSION
|
2023-10-03 13:15:17 +00:00
|
|
|
export function stopTransmission() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "arq", "command": "stop_transmission"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// Get RX BUffer
|
2023-10-03 13:15:17 +00:00
|
|
|
export function getRxBuffer() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "get", "command" : "rx_buffer"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
writeTncCommand(command);
|
2023-10-11 18:26:44 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// START BEACON
|
2023-10-03 13:15:17 +00:00
|
|
|
export function startBeacon(interval) {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command =
|
2023-09-06 13:36:54 +00:00
|
|
|
'{"type" : "broadcast", "command" : "start_beacon", "parameter": "' +
|
|
|
|
interval +
|
|
|
|
'"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// STOP BEACON
|
2023-10-03 13:15:17 +00:00
|
|
|
export function stopBeacon() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "broadcast", "command" : "stop_beacon"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// OPEN ARQ SESSION
|
2023-10-03 13:15:17 +00:00
|
|
|
export function connectARQ(dxcallsign) {
|
2023-09-06 13:36:54 +00:00
|
|
|
command =
|
|
|
|
'{"type" : "arq", "command" : "connect", "dxcallsign": "' +
|
|
|
|
dxcallsign +
|
|
|
|
'", "attempts": "10"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// CLOSE ARQ SESSION
|
2023-10-03 13:15:17 +00:00
|
|
|
export function disconnectARQ() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "arq", "command" : "disconnect"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// SEND TEST FRAME
|
2023-10-03 13:15:17 +00:00
|
|
|
export function sendTestFrame() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "set", "command" : "send_test_frame"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// SEND FEC
|
2023-10-03 13:15:17 +00:00
|
|
|
export function sendFEC(mode, payload) {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command =
|
2023-09-06 13:36:54 +00:00
|
|
|
'{"type" : "fec", "command" : "transmit", "mode" : "' +
|
|
|
|
mode +
|
|
|
|
'", "payload" : "' +
|
|
|
|
payload +
|
|
|
|
'"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// SEND FEC IS WRITING
|
2023-10-03 13:15:17 +00:00
|
|
|
export function sendFecIsWriting(mycallsign) {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command =
|
2023-09-06 13:36:54 +00:00
|
|
|
'{"type" : "fec", "command" : "transmit_is_writing", "mycallsign" : "' +
|
|
|
|
mycallsign +
|
|
|
|
'"}';
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// SEND FEC TO BROADCASTCHANNEL
|
2023-10-03 13:15:17 +00:00
|
|
|
export function sendBroadcastChannel(channel, data_out, uuid) {
|
2023-09-06 13:36:54 +00:00
|
|
|
let checksum = "";
|
|
|
|
let command = "";
|
2023-10-08 07:57:03 +00:00
|
|
|
let data = btoa_FD(
|
2023-09-06 13:36:54 +00:00
|
|
|
"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);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// RECORD AUDIO
|
2023-10-03 13:15:17 +00:00
|
|
|
export function record_audio() {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "set", "command" : "record_audio"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// SET FREQUENCY
|
2023-10-03 13:15:17 +00:00
|
|
|
export function set_frequency(frequency) {
|
2023-09-11 14:09:17 +00:00
|
|
|
var command =
|
2023-09-06 13:36:54 +00:00
|
|
|
'{"type" : "set", "command" : "frequency", "frequency": ' + frequency + "}";
|
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
|
|
|
// SET MODE
|
2023-10-03 13:15:17 +00:00
|
|
|
export function set_mode(mode) {
|
2023-09-10 13:05:28 +00:00
|
|
|
var command = '{"type" : "set", "command" : "mode", "mode": "' + mode + '"}';
|
2023-09-06 13:36:54 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-06 13:36:54 +00:00
|
|
|
|
2023-09-11 14:53:24 +00:00
|
|
|
// SET rf_level
|
2023-10-03 13:15:17 +00:00
|
|
|
export function set_rf_level(rf_level) {
|
|
|
|
var command =
|
|
|
|
'{"type" : "set", "command" : "rf_level", "rf_level": "' + rf_level + '"}';
|
2023-09-11 14:53:24 +00:00
|
|
|
writeTncCommand(command);
|
2023-10-03 13:15:17 +00:00
|
|
|
}
|
2023-09-11 14:53:24 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
// https://stackoverflow.com/a/50579690
|
|
|
|
// crc32 calculation
|
|
|
|
//console.log(crc32('abc'));
|
|
|
|
//console.log(crc32('abc').toString(16).toUpperCase()); // hex
|
2023-09-20 04:46:37 +00:00
|
|
|
|
2023-09-06 13:36:54 +00:00
|
|
|
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;
|
|
|
|
};
|
2023-10-02 18:16:07 +00:00
|
|
|
|
|
|
|
// TODO: Maybe moving this to another module
|
2023-10-03 13:15:17 +00:00
|
|
|
function prepareStatsDataForStore(data) {
|
|
|
|
// dummy data
|
|
|
|
//state.arq_speed_list = [{"snr":0.0,"bpm":104,"timestamp":1696189769},{"snr":0.0,"bpm":80,"timestamp":1696189778},{"snr":0.0,"bpm":70,"timestamp":1696189783},{"snr":0.0,"bpm":58,"timestamp":1696189792},{"snr":0.0,"bpm":52,"timestamp":1696189797},{"snr":"NaN","bpm":42,"timestamp":1696189811},{"snr":0.0,"bpm":22,"timestamp":1696189875},{"snr":0.0,"bpm":21,"timestamp":1696189881},{"snr":0.0,"bpm":17,"timestamp":1696189913},{"snr":0.0,"bpm":15,"timestamp":1696189932},{"snr":0.0,"bpm":15,"timestamp":1696189937},{"snr":0.0,"bpm":14,"timestamp":1696189946},{"snr":-6.1,"bpm":14,"timestamp":1696189954},{"snr":-6.1,"bpm":14,"timestamp":1696189955},{"snr":-5.5,"bpm":28,"timestamp":1696189963},{"snr":-5.5,"bpm":27,"timestamp":1696189963}]
|
2023-10-02 18:16:07 +00:00
|
|
|
|
|
|
|
if (typeof data == "undefined") {
|
|
|
|
var speed_listSize = 0;
|
|
|
|
} else {
|
|
|
|
var speed_listSize = data.length;
|
|
|
|
}
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
var speed_list_bpm = [];
|
2023-10-02 18:23:02 +00:00
|
|
|
|
2023-10-02 18:16:07 +00:00
|
|
|
for (var i = 0; i < speed_listSize; i++) {
|
2023-10-02 18:23:02 +00:00
|
|
|
speed_list_bpm.push(data[i].bpm);
|
2023-10-02 18:16:07 +00:00
|
|
|
}
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
var speed_list_timestamp = [];
|
2023-10-02 18:16:07 +00:00
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
for (var i = 0; i < speed_listSize; i++) {
|
2023-10-02 18:16:07 +00:00
|
|
|
var timestamp = data[i].timestamp * 1000;
|
|
|
|
var h = new Date(timestamp).getHours();
|
|
|
|
var m = new Date(timestamp).getMinutes();
|
|
|
|
var s = new Date(timestamp).getSeconds();
|
|
|
|
var time = h + ":" + m + ":" + s;
|
2023-10-02 18:23:02 +00:00
|
|
|
speed_list_timestamp.push(time);
|
2023-10-02 18:16:07 +00:00
|
|
|
}
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
var speed_list_snr = [];
|
2023-10-02 18:16:07 +00:00
|
|
|
for (var i = 0; i < speed_listSize; i++) {
|
|
|
|
let snr = NaN;
|
|
|
|
if (data[i].snr !== 0) {
|
|
|
|
snr = data[i].snr;
|
|
|
|
} else {
|
|
|
|
snr = NaN;
|
|
|
|
}
|
2023-10-02 18:23:02 +00:00
|
|
|
speed_list_snr.push(snr);
|
2023-10-02 18:16:07 +00:00
|
|
|
}
|
|
|
|
|
2023-10-03 13:15:17 +00:00
|
|
|
stateStore.arq_speed_list_bpm = speed_list_bpm;
|
|
|
|
stateStore.arq_speed_list_timestamp = speed_list_timestamp;
|
|
|
|
stateStore.arq_speed_list_snr = speed_list_snr;
|
|
|
|
}
|