+
+
+
+
+
+
+
${message_html}
+
+ ${timestamp} -
+ ${get_icon_for_state(
+ obj.status,
+ )}
+
+
+
+ ${attempt}/${max_retry_attempts}
+ retries
+
+
+
+
+
+ `;
+ }
+
+ if (obj.type == "transmit") {
+ //console.log(obj);
+ //console.log('msg-' + obj._id + '-status')
+
+ if (obj.status == "failed") {
+ var progressbar_bg = "bg-danger";
+ var percent_value = "TRANSMISSION FAILED";
+ //Set to 100 so progressbar background populates
+ obj.percent = 100;
+ } else if (obj.status == "transmitted") {
+ var progressbar_bg = "bg-success";
+ var percent_value = "TRANSMITTED";
+ } else {
+ var progressbar_bg = "bg-primary";
+ var percent_value = obj.percent + " %";
+ }
+
+ //Sneak in low graphics mode if so enabled for progress bars
+ if (config.high_graphics.toString().toUpperCase() != "TRUE") {
+ progressbar_bg += " disable-effects";
+ //console.log("Low graphics enabled for chat module");
+ }
+
+ var new_message = `
+
+ ${controlarea_transmit}
+
+
+ ${fileheader}
+
+
${message_html}
+
+ ${timestamp} -
+ ${get_icon_for_state(
+ obj.status,
+ )}
+
+
+
+ ${attempt}/${max_retry_attempts}
+ retries
+
+
+
+
${percent_value} - ${
+ obj.bytesperminute
+ } Bpm
+
+
+
+
+
+ `;
+ }
+ // CHECK CHECK CHECK --> This could be done better
+ var id = "chat-" + obj.dxcallsign;
+ document.getElementById(id).insertAdjacentHTML("beforeend", new_message);
+
+ /* UPDATE EXISTING ELEMENTS */
+ } else if (document.getElementById("msg-" + obj._id)) {
+ //console.log("element already exists......");
+ //console.log(obj);
+
+ // console.log(obj.status)
+ // console.log(obj.attempt)
+
+ if (
+ obj.status != "broadcast_transmit" ||
+ obj.status != "broadcast_received"
+ ) {
+ document.getElementById("msg-" + obj._id + "-status").innerHTML =
+ get_icon_for_state(obj.status);
+
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .setAttribute("aria-valuenow", obj.percent);
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .setAttribute("style", "width:" + obj.percent + "%;");
+ document.getElementById(
+ "msg-" + obj._id + "-progress-information",
+ ).innerHTML = obj.percent + "% - " + obj.bytesperminute + " Bpm";
+
+ document.getElementById("msg-" + obj._id + "-attempts").innerHTML =
+ obj.attempt + "/" + max_retry_attempts;
+ }
+
+ if (obj.status == "transmit") {
+ document.getElementById("msg-" + obj._id + "-status").innerHTML =
+ get_icon_for_state(obj.status);
+
+ if (typeof obj.percent !== "undefined") {
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .setAttribute("aria-valuenow", obj.percent);
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .setAttribute("style", "width:" + obj.percent + "%;");
+ document.getElementById(
+ "msg-" + obj._id + "-progress-information",
+ ).innerHTML = obj.percent + "% - " + obj.bytesperminute + " Bpm";
+ } else {
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .setAttribute("aria-valuenow", 0);
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .setAttribute("style", "width:0%;");
+ document.getElementById(
+ "msg-" + obj._id + "-progress-information",
+ ).innerHTML = "0% - 0 Bpm";
+ }
+
+ document.getElementById("msg-" + obj._id + "-attempts").innerHTML =
+ obj.attempt + "/" + max_retry_attempts;
+ }
+
+ if (obj.status == "transmitted") {
+ //document.getElementById('msg-' + obj._id + '-progress').classList.remove("progress-bar-striped");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.remove("progress-bar-animated");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.remove("bg-danger");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.add("bg-success");
+
+ document.getElementById("msg-" + obj._id + "-progress").innerHTML = "";
+ document.getElementById(
+ "msg-" + obj._id + "-progress-information",
+ ).innerHTML = "TRANSMITTED - " + obj.bytesperminute + " Bpm";
+ } else if (
+ obj.status != "broadcast_transmit" ||
+ obj.status != "broadcast_received"
+ ) {
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.add("progress-bar-striped");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.add("progress-bar-animated");
+ }
+
+ if (obj.status == "failed") {
+ //document.getElementById('msg-' + obj._id + '-progress').classList.remove("progress-bar-striped");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.remove("progress-bar-animated");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.remove("bg-primary");
+ document
+ .getElementById("msg-" + obj._id + "-progress")
+ .classList.add("bg-danger");
+
+ console.log(
+ document.getElementById("msg-" + obj._id + "-progress").classList,
+ );
+
+ document.getElementById(
+ "msg-" + obj._id + "-progress-information",
+ ).innerHTML = "TRANSMISSION FAILED - " + obj.bytesperminute + " Bpm";
+ }
+
+ //document.getElementById(id).className = message_class;
+ }
+
+ //Delete message event listener
+ if (
+ document.getElementById("del-msg-" + obj._id) &&
+ !document
+ .getElementById("del-msg-" + obj._id)
+ .hasAttribute("listenerOnClick")
+ ) {
+ // set Attribute to determine if we already created an EventListener for this element
+ document
+ .getElementById("del-msg-" + obj._id)
+ .setAttribute("listenerOnClick", "true");
+ document
+ .getElementById("del-msg-" + obj._id)
+ .addEventListener("click", () => {
+ db.get(obj._id, {
+ attachments: true,
+ })
+ .then(function (doc) {
+ db.remove(doc._id, doc._rev, function (err) {
+ if (err) console.log("Error removing item " + err);
+ });
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+
+ document.getElementById("msg-" + obj._id).remove();
+ document.getElementById("msg-" + obj._id + "-control-area").remove();
+ console.log("Removed message " + obj._id.toString());
+
+ // stop transmission if deleted message is still in progress
+ if (obj.status == "transmitting") {
+ let Data = {
+ command: "stop_transmission",
+ };
+ ipcRenderer.send("run-tnc-command", Data);
+ }
+ });
+ //scrollMessagesToBottom();
+ }
+
+ // CREATE SAVE TO FOLDER EVENT LISTENER
+ if (
+ document.getElementById("save-file-msg-" + obj._id) &&
+ !document
+ .getElementById("save-file-msg-" + obj._id)
+ .hasAttribute("listenerOnClick")
+ ) {
+ // set Attribute to determine if we already created an EventListener for this element
+ document
+ .getElementById("save-file-msg-" + obj._id)
+ .setAttribute("listenerOnClick", "true");
+
+ document
+ .getElementById("save-file-msg-" + obj._id)
+ .addEventListener("click", () => {
+ saveFileToFolder(obj._id);
+ });
+ }
+ // CREATE RESEND MSG EVENT LISTENER
+
+ // check if element exists and if we already created NOT created an event listener
+ if (
+ document.getElementById("retransmit-msg-" + obj._id) &&
+ !document
+ .getElementById("retransmit-msg-" + obj._id)
+ .hasAttribute("listenerOnClick")
+ ) {
+ // set Attribute to determine if we already created an EventListener for this element
+ document
+ .getElementById("retransmit-msg-" + obj._id)
+ .setAttribute("listenerOnClick", "true");
+ document
+ .getElementById("retransmit-msg-" + obj._id)
+ .addEventListener("click", () => {
+ // increment attempt
+ db.upsert(obj._id, function (doc) {
+ if (!doc.attempt) {
+ doc.attempt = 1;
+ }
+ doc.attempt++;
+ return doc;
+ })
+ .then(function (res) {
+ // success, res is {rev: '1-xxx', updated: true, id: 'myDocId'}
+ console.log(res);
+ update_chat_obj_by_uuid(obj.uuid);
+ })
+ .catch(function (err) {
+ // error
+ console.log(err);
+ });
+
+ db.get(obj._id, {
+ attachments: true,
+ })
+ .then(function (doc) {
+ // handle doc
+ console.log(doc);
+
+ var filename = Object.keys(obj._attachments)[0];
+ var filetype = filename.content_type;
+
+ console.log(filename);
+ console.log(filetype);
+ var file = obj._attachments[filename].data;
+ console.log(file);
+ console.log(Object.keys(obj._attachments)[0].data);
+
+ //var file = atob(obj._attachments[filename]["data"])
+ db.getAttachment(obj._id, filename).then(function (data) {
+ console.log(data);
+ //Rewrote this part to use buffers to ensure encoding is corect -- n1qm
+ var binaryString = FD.atob_FD(data);
+
+ console.log(binaryString);
+ var data_with_attachment =
+ doc.timestamp +
+ split_char +
+ doc.msg +
+ split_char +
+ filename +
+ split_char +
+ filetype +
+ split_char +
+ binaryString;
+ let Data = {
+ command: "msg",
+ dxcallsign: doc.dxcallsign,
+ mode: 255,
+ frames: 5,
+ data: data_with_attachment,
+ checksum: doc.checksum,
+ uuid: doc.uuid,
+ };
+ console.log(Data);
+ ipcRenderer.send("run-tnc-command", Data);
+ });
+ /*
+ // convert blob data to binary string
+ blobUtil.blobToBinaryString(data).then(function (binaryString) {
+ console.log(binaryString)
+ }).catch(function (err) {
+ // error
+ console.log(err);
+ binaryString = blobUtil.arrayBufferToBinaryString(data);
+
+ }).then(function(){
+
+ console.log(binaryString)
+ console.log(binaryString.length)
+
+ var data_with_attachment = doc.timestamp + split_char + utf8.encode(doc.msg) + split_char + filename + split_char + filetype + split_char + binaryString;
+ let Data = {
+ command: "msg",
+ dxcallsign: doc.dxcallsign,
+ mode: 255,
+ frames: 1,
+ data: data_with_attachment,
+ checksum: doc.checksum,
+ uuid: doc.uuid
+ };
+ console.log(Data)
+ ipcRenderer.send('run-tnc-command', Data);
+
+ });
+ });
+ */
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ });
+ }
+ //window.location = window.location
+
+ // scroll to bottom on new message
+ scrollMessagesToBottom();
+};
+
+function saveFileToFolder(id) {
+ db.get(id, {
+ attachments: true,
+ })
+ .then(function (obj) {
+ console.log(obj);
+ console.log(Object.keys(obj._attachments)[0].content_type);
+ var filename = Object.keys(obj._attachments)[0];
+ var filetype = filename.content_type;
+ var file = filename.data;
+ console.log(file);
+ console.log(filename.data);
+ db.getAttachment(id, filename)
+ .then(function (data) {
+ // handle result
+ console.log(data.length);
+ //data = new Blob([data.buffer], { type: 'image/png' } /* (1) */)
+ console.log(data);
+ // we need to encode data because of error "an object could not be cloned"
+ let Data = {
+ file: data,
+ filename: filename,
+ filetype: filetype,
+ };
+ console.log(Data);
+ ipcRenderer.send("save-file-to-folder", Data);
+ })
+ .catch(function (err) {
+ console.log(err);
+ return false;
+ });
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+}
+
+// function for setting an ICON to the corresponding state
+function get_icon_for_state(state) {
+ if (state == "transmit") {
+ var status_icon = '
';
+ } else if (state == "transmitting") {
+ //var status_icon = '
';
+ var status_icon = `
+
+ `;
+ } else if (state == "failed") {
+ var status_icon =
+ '
';
+ } else if (state == "transmitted") {
+ var status_icon = '
';
+ } else {
+ var status_icon = '
';
+ }
+ return status_icon;
+}
+
+update_chat_obj_by_uuid = function (uuid) {
+ db.get(uuid, {
+ attachments: true,
+ })
+ .then(function (doc) {
+ update_chat(doc);
+ //return doc
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+};
+
+add_obj_to_database = function (obj) {
+ console.log(obj);
+ db.put({
+ _id: obj.uuid,
+ timestamp: parseInt(obj.timestamp),
+ broadcast_sender: obj.broadcast_sender,
+ uuid: obj.uuid,
+ dxcallsign: obj.dxcallsign,
+ dxgrid: obj.dxgrid,
+ msg: obj.msg,
+ checksum: obj.checksum,
+ type: obj.type,
+ command: obj.command,
+ status: obj.status,
+ snr: obj.snr,
+ attempt: obj.attempt,
+ hmac_signed: obj.hmac_signed,
+ new: obj.new,
+ _attachments: {
+ [obj.filename]: {
+ content_type: obj.filetype,
+ data: obj.file,
+ },
+ },
+ })
+ .then(function (response) {
+ console.log("new database entry");
+ console.log(response);
+ })
+ .catch(function (err) {
+ console.log("already exists");
+ console.log(err);
+ console.log(obj);
+ db.upsert(obj.uuid, function (doc) {
+ doc = obj;
+ return doc;
+ })
+ .then(function (response) {
+ console.log("upsert");
+ console.log(response);
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ });
+};
+/* users database functions */
+addUserToDatabaseIfNotExists = function (obj) {
+ /*
+ "user_info_callsign",
+ "user_info_gridsquare",
+ "user_info_name",
+ "user_info_age",
+ "user_info_location",
+ "user_info_radio",
+ "user_info_antenna",
+ "user_info_email",
+ "user_info_website",
+ "user_info_comments",
+*/
+ console.log(obj);
+ users
+ .find({
+ selector: {
+ user_info_callsign: obj.user_info_callsign,
+ },
+ })
+ .then(function (result) {
+ // handle result
+ console.log(result);
+ if (result.docs.length > 0) {
+ users
+ .put({
+ _id: result.docs[0]._id,
+ _rev: result.docs[0]._rev,
+ user_info_callsign: obj.user_info_callsign,
+ user_info_gridsquare: obj.user_info_gridsquare,
+ user_info_name: obj.user_info_name,
+ user_info_age: obj.user_info_age,
+ user_info_location: obj.user_info_location,
+ user_info_radio: obj.user_info_radio,
+ user_info_antenna: obj.user_info_antenna,
+ user_info_email: obj.user_info_email,
+ user_info_website: obj.user_info_website,
+ user_info_comments: obj.user_info_comments,
+ user_info_image: obj.user_info_image,
+ })
+ .then(function (response) {
+ console.log("UPDATED USER");
+ console.log(response);
+ console.log(obj);
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ } else {
+ users
+ .post({
+ user_info_callsign: obj.user_info_callsign,
+ user_info_gridsquare: obj.user_info_gridsquare,
+ user_info_name: obj.user_info_name,
+ user_info_age: obj.user_info_age,
+ user_info_location: obj.user_info_location,
+ user_info_radio: obj.user_info_radio,
+ user_info_antenna: obj.user_info_antenna,
+ user_info_email: obj.user_info_email,
+ user_info_website: obj.user_info_website,
+ user_info_comments: obj.user_info_comments,
+ })
+ .then(function (response) {
+ console.log("NEW USER ADDED");
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ }
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+};
+
+addFileListToUserDatabaseIfNotExists = function (obj) {
+ console.log(obj);
+ users
+ .find({
+ selector: {
+ user_info_callsign: obj.user_info_callsign,
+ },
+ })
+ .then(function (result) {
+ // handle result
+ if (result.docs.length > 0) {
+ users
+ .put({
+ _id: result.docs[0]._id,
+ _rev: result.docs[0]._rev,
+ user_shared_folder: obj.user_shared_folder,
+ user_info_callsign: result.docs[0].user_info_callsign,
+ user_info_gridsquare: result.docs[0].user_info_gridsquare,
+ user_info_name: result.docs[0].user_info_name,
+ user_info_age: result.docs[0].user_info_age,
+ user_info_location: result.docs[0].user_info_location,
+ user_info_radio: result.docs[0].user_info_radio,
+ user_info_antenna: result.docs[0].user_info_antenna,
+ user_info_email: result.docs[0].user_info_email,
+ user_info_website: result.docs[0].user_info_website,
+ user_info_comments: result.docs[0].user_info_comments,
+ })
+ .then(function (response) {
+ console.log("File List: UPDATED USER");
+ console.log(response);
+ console.log(obj);
+ getSetUserSharedFolder(obj.user_info_callsign);
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ } else {
+ users
+ .post({
+ user_info_callsign: obj.user_info_callsign,
+ user_shared_folder: obj.user_shared_folder,
+ })
+ .then(function (response) {
+ console.log("File List: NEW USER ADDED");
+ getSetUserSharedFolder(obj.user_info_callsign);
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ }
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+};
+
+// Scroll to bottom of message-container
+function scrollMessagesToBottom() {
+ var messageBody = document.getElementById("message-container");
+ messageBody.scrollTop = messageBody.scrollHeight - messageBody.clientHeight;
+}
+
+// CRC CHECKSUMS
+// https://stackoverflow.com/a/50579690
+// crc32 calculation
+//console.log(crc32('abc'));
+//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
>>8^o[255&(n^r.charCodeAt(t))];return(-1^n)>>>0};
+//console.log(crc32('abc').toString(16).toUpperCase()); // hex
+
+var makeCRCTable = function () {
+ var c;
+ var crcTable = [];
+ for (var n = 0; n < 256; n++) {
+ c = n;
+ for (var k = 0; k < 8; k++) {
+ c = c & 1 ? 0xedb88320 ^ (c >>> 1) : c >>> 1;
+ }
+ crcTable[n] = c;
+ }
+ return crcTable;
+};
+
+var crc32 = function (str) {
+ var crcTable = window.crcTable || (window.crcTable = makeCRCTable());
+ var crc = 0 ^ -1;
+
+ for (var i = 0; i < str.length; i++) {
+ crc = (crc >>> 8) ^ crcTable[(crc ^ str.charCodeAt(i)) & 0xff];
+ }
+
+ return (crc ^ -1) >>> 0;
+};
+
+function returnObjFromCallsign(database, callsign) {
+ return new Promise((resolve, reject) => {
+ users
+ .find({
+ selector: {
+ user_info_callsign: callsign,
+ },
+ })
+ .then(function (result) {
+ //return new Promise((resolve, reject) => {
+ if (typeof result.docs[0] !== "undefined") {
+ resolve(result.docs[0]);
+ } else {
+ reject("Promise rejected");
+ }
+
+ /*
+ if (typeof result.docs[0] !== "undefined") {
+ return result.docs[0];
+
+
+
+
+ } else {
+ return false;
+ }
+
+ */
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ });
+}
+
+function createChatIndex() {
+ db.createIndex({
+ index: {
+ fields: [
+ "timestamp",
+ "uuid",
+ "dxcallsign",
+ "dxgrid",
+ "msg",
+ "checksum",
+ "type",
+ "command",
+ "status",
+ "percent",
+ "attempt",
+ "hmac_signed",
+ "bytesperminute",
+ "_attachments",
+ "new",
+ ],
+ },
+ })
+ .then(function (result) {
+ // handle result
+ console.log(result);
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+}
+
+function createUserIndex() {
+ users
+ .createIndex({
+ index: {
+ fields: [
+ "timestamp",
+ "user_info_callsign",
+ "user_info_gridsquare",
+ "user_info_name",
+ "user_info_age",
+ "user_info_location",
+ "user_info_radio",
+ "user_info_antenna",
+ "user_info_email",
+ "user_info_website",
+ "user_info_comments",
+ "user_info_image",
+ ],
+ },
+ })
+ .then(function (result) {
+ // handle result
+ console.log(result);
+ return true;
+ })
+ .catch(function (err) {
+ console.log(err);
+ return false;
+ });
+}
+
+async function updateAllChat(clear) {
+ if (clear == true) {
+ filetype = "";
+ file = "";
+ filename = "";
+ callsign_counter = 0;
+ //selected_callsign = "";
+ dxcallsigns.clear();
+ document.getElementById("list-tab-chat").innerHTML = "";
+ document.getElementById("nav-tabContent-Chat").innerHTML = "";
+ //document.getElementById("list-tab-chat").childNodes.remove();
+ //document.getElementById("nav-tab-content").childrenNodes.remove();
+ }
+ //Ensure we create an index before running db.find
+ //We can't rely on the default index existing before we get here...... :'(
+ await db
+ .createIndex({
+ index: {
+ fields: [{ dxcallsign: "asc" }, { timestamp: "asc" }],
+ },
+ })
+ .then(async function (result) {
+ // handle result
+ await db
+ .find({
+ selector: {
+ $and: [
+ { dxcallsign: { $exists: true } },
+ { timestamp: { $exists: true } },
+ { $or: chatFilter },
+ ],
+ //$or: chatFilter
+ },
+ sort: [{ dxcallsign: "asc" }, { timestamp: "asc" }],
+ })
+ .then(async function (result) {
+ console.log(result);
+ // handle result async
+ //document.getElementById("blurOverlay").classList.add("bg-primary");
+ console.log(result);
+ if (typeof result !== "undefined") {
+ for (const item of result.docs) {
+ //await otherwise history will not be in chronological order
+ await db
+ .get(item._id, {
+ attachments: true,
+ })
+ .then(function (item_with_attachments) {
+ update_chat(item_with_attachments);
+ });
+ }
+ }
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ if (clear == true && dxcallsigns.has(selected_callsign) == false) {
+ //Selected call sign is not visible, reset to first call sign
+ let tmp = dxcallsigns.entries().next().value[0];
+ selected_callsign = tmp;
+ document
+ .getElementById("chat-" + tmp + "-list")
+ .classList.add("active", "show");
+ document.getElementById("chat-" + tmp).classList.add("active", "show");
+ scrollMessagesToBottom();
+ }
+}
+
+function getSetUserSharedFolder(selected_callsign) {
+ // TODO: This is a dirty hotfix for avoiding, this function is canceld too fast.
+ //Should be fixed
+ //console.log("get set user information:" + selected_callsign);
+
+ if (
+ selected_callsign == "" ||
+ selected_callsign == null ||
+ typeof selected_callsign == "undefined"
+ ) {
+ console.log("return triggered");
+ return;
+ }
+
+ // disable button if broadcast
+ if (selected_callsign.startsWith("BC-")) {
+ document.getElementById("sharedFolderDXButton").disabled = true;
+ } else {
+ document.getElementById("sharedFolderDXButton").disabled = false;
+ }
+
+ returnObjFromCallsign(users, selected_callsign)
+ .then(function (data) {
+ console.log(data);
+
+ if (typeof data.user_shared_folder !== "undefined") {
+ console.log(data.user_shared_folder);
+ // shared folder table
+ var icons = [
+ "aac",
+ "ai",
+ "bmp",
+ "cs",
+ "css",
+ "csv",
+ "doc",
+ "docx",
+ "exe",
+ "gif",
+ "heic",
+ "html",
+ "java",
+ "jpg",
+ "js",
+ "json",
+ "jsx",
+ "key",
+ "m4p",
+ "md",
+ "mdx",
+ "mov",
+ "mp3",
+ "mp4",
+ "otf",
+ "pdf",
+ "php",
+ "png",
+ "ppt",
+ "pptx",
+ "psd",
+ "py",
+ "raw",
+ "rb",
+ "sass",
+ "scss",
+ "sh",
+ "sql",
+ "svg",
+ "tiff",
+ "tsx",
+ "ttf",
+ "txt",
+ "wav",
+ "woff",
+ "xls",
+ "xlsx",
+ "xml",
+ "yml",
+ ];
+ var tbl = document.getElementById("sharedFolderTableDX");
+ tbl.innerHTML = "";
+ let counter = 0;
+ data.user_shared_folder.forEach((file) => {
+ var row = document.createElement("tr");
+
+ let dxcall = selected_callsign;
+ let name = file["name"];
+ let type = file["extension"];
+
+ if (icons.indexOf(type) == -1) {
+ type = "bi-file-earmark";
+ } else {
+ type = "bi-filetype-" + type;
+ }
+
+ let id = document.createElement("td");
+ let idText = document.createElement("span");
+ counter += 1;
+ idText.innerHTML +=
+ '" + data.user_info_gridsquare + " ";
+ document.getElementById("user-image-" + selected_callsign).className =
+ "p-1 rounded-circle";
+ document.getElementById("user-image-" + selected_callsign).style =
+ "width: 60px";
+
+ // DX Station tab
+ document.getElementById("dx_user_info_name").innerHTML =
+ data.user_info_name;
+ document.getElementById("dx_user_info_age").innerHTML =
+ data.user_info_age;
+ document.getElementById("dx_user_info_gridsquare").innerHTML =
+ data.user_info_gridsquare;
+ document.getElementById("dx_user_info_location").innerHTML =
+ data.user_info_location;
+ document.getElementById("dx_user_info_email").innerHTML =
+ data.user_info_email;
+ document.getElementById("dx_user_info_website").innerHTML =
+ data.user_info_website;
+ document.getElementById("dx_user_info_radio").innerHTML =
+ data.user_info_radio;
+ document.getElementById("dx_user_info_antenna").innerHTML =
+ data.user_info_antenna;
+ document.getElementById("dx_user_info_comments").innerHTML =
+ data.user_info_comments;
+
+ document.getElementById("dx_user_info_gridsquare").className = "";
+ document.getElementById("dx_user_info_name").className =
+ "badge bg-secondary";
+ document.getElementById("dx_user_info_age").className =
+ "badge bg-secondary";
+ document.getElementById("dx_user_info_gridsquare").className = "";
+ document.getElementById("dx_user_info_location").className = "";
+ document.getElementById("dx_user_info_email").className = "";
+ document.getElementById("dx_user_info_website").className = "";
+ document.getElementById("dx_user_info_radio").className = "";
+ document.getElementById("dx_user_info_antenna").className = "";
+ document.getElementById("dx_user_info_comments").className = "";
+ })
+ .catch(function (err) {
+ console.log("writing user info to modal failed");
+ console.log(err);
+
+ if (selected_callsign.startsWith("BC-")) {
+ var userIcon = defaultGroupIcon;
+ } else {
+ var userIcon = defaultUserIcon;
+ }
+
+ // Callsign list elements
+ document.getElementById("user-image-" + selected_callsign).src = userIcon;
+ document.getElementById("user-image-" + selected_callsign).className =
+ "p-1 rounded-circle w-100";
+ document.getElementById("user-image-" + selected_callsign).style =
+ "height:60px";
+ document.getElementById(
+ "chat-" + selected_callsign + "-list-dxgrid",
+ ).innerHTML = "no grid ";
+
+ // DX Station tab
+
+ document.getElementById("dx_user_info_image").src = defaultUserIcon;
+ document.getElementById("dx_user_info_gridsquare").className =
+ "placeholder col-4";
+ document.getElementById("dx_user_info_name").className =
+ "placeholder col-4";
+ document.getElementById("dx_user_info_age").className =
+ "placeholder col-2";
+ document.getElementById("dx_user_info_gridsquare").className =
+ "placeholder col-3";
+ document.getElementById("dx_user_info_location").className =
+ "placeholder col-3";
+ document.getElementById("dx_user_info_email").className =
+ "placeholder col-7";
+ document.getElementById("dx_user_info_website").className =
+ "placeholder col-7";
+ document.getElementById("dx_user_info_radio").className =
+ "placeholder col-4";
+ document.getElementById("dx_user_info_antenna").className =
+ "placeholder col-4";
+ document.getElementById("dx_user_info_comments").className =
+ "placeholder col-7";
+ });
+}
+
+function sendSharedFolderList(dxcallsign) {
+ ipcRenderer.send("read-files-in-folder", {
+ folder: config.shared_folder_path,
+ });
+
+ console.log(sharedFolderFileList);
+ let fileListWithCallsign = "";
+ fileListWithCallsign += dxcallsign;
+ fileListWithCallsign += split_char;
+ fileListWithCallsign += JSON.stringify(sharedFolderFileList);
+
+ console.log(fileListWithCallsign);
+
+ ipcRenderer.send("run-tnc-command", {
+ command: "responseSharedFolderList",
+ dxcallsign: dxcallsign,
+ folderFileList: fileListWithCallsign,
+ });
+}
+
+function sendSharedFolderFile(dxcallsign, filename) {
+ let filePath = path.join(config.shared_folder_path, filename);
+ console.log("In function sendSharedFolderFile ", filePath);
+
+ //Make sure nothing sneaky is going on
+ if (!filePath.startsWith(config.shared_folder_path)) {
+ console.error("File is outside of shared folder path!");
+ return;
+ }
+
+ if (!fs.existsSync(filePath)) {
+ console.warn("File doesn't seem to exist");
+ return;
+ }
+
+ //Read file's data
+ let fileData = null;
+ try {
+ //Has to be binary
+ let data = fs.readFileSync(filePath);
+ fileData = data.toString("utf-8");
+ } catch (err) {
+ console.log(err);
+ return;
+ }
+
+ ipcRenderer.send("run-tnc-command", {
+ command: "responseSharedFile",
+ dxcallsign: dxcallsign,
+ file: filename,
+ filedata: fileData,
+ });
+}
+
+function sendUserData(dxcallsign) {
+ const userInfoFields = [
+ "user_info_image",
+ "user_info_callsign",
+ "user_info_gridsquare",
+ "user_info_name",
+ "user_info_age",
+ "user_info_location",
+ "user_info_radio",
+ "user_info_antenna",
+ "user_info_email",
+ "user_info_website",
+ "user_info_comments",
+ ];
+
+ let info = "";
+ userInfoFields.forEach(function (subelem) {
+ if (subelem !== "user_info_image") {
+ info += document.getElementById(subelem).value;
+ info += split_char;
+ } else {
+ info += document.getElementById(subelem).src;
+ info += split_char;
+ }
+ });
+
+ console.log(info);
+
+ ipcRenderer.send("run-tnc-command", {
+ command: "responseUserInfo",
+ dxcallsign: dxcallsign,
+ userinfo: info,
+ });
+}
+
+//Temporarily disable a button with timeout
+function pauseButton(btn, timems) {
+ btn.disabled = true;
+ var curText = btn.innerHTML;
+ if (config.high_graphics.toUpperCase() == "TRUE") {
+ btn.innerHTML =
+ '';
+ }
+ setTimeout(() => {
+ btn.innerHTML = curText;
+ btn.disabled = false;
+ }, timems);
+}
+ipcRenderer.on("update-config", (event, data) => {
+ config = data;
+});
+
+ipcRenderer.on("action-update-unread-messages", (event) => {
+ checkForNewMessages().then(function (count) {
+ ipcRenderer.send("request-update-unread-messages-main", count);
+ });
+});
+
+ipcRenderer.on("action-clean-db", (event) => {
+ dbClean();
+});
+
+// https://stackoverflow.com/a/18650828
+function formatBytes(bytes, decimals = 2) {
+ if (!+bytes) return "0 Bytes";
+
+ const k = 1024;
+ const dm = decimals < 0 ? 0 : decimals;
+ const sizes = ["Bytes", "KB", "MB", "GB", "TB", "PB", "EB", "ZB", "YB"];
+
+ const i = Math.floor(Math.log(bytes) / Math.log(k));
+
+ return `${parseFloat((bytes / Math.pow(k, i)).toFixed(dm))} ${sizes[i]}`;
+}
+function sendFileReq(dxcall, file) {
+ //console.log(file," clicked");
+ ipcRenderer.send("run-tnc-command", {
+ command: "requestSharedFile",
+ dxcallsign: dxcall,
+ file: file,
+ });
+}
+
+function changeGuiDesign(design) {
+ console.log(design);
+ if (
+ design != "default" &&
+ design != "default_light" &&
+ design != "default_dark" &&
+ design != "default_auto"
+ ) {
+ var theme_path =
+ "../node_modules/bootswatch/dist/" + design + "/bootstrap.min.css";
+ document.getElementById("bootstrap_theme").href = escape(theme_path);
+ } else if (design == "default" || design == "default_light") {
+ var theme_path = "../node_modules/bootstrap/dist/css/bootstrap.min.css";
+ document.getElementById("bootstrap_theme").href = escape(theme_path);
+ document.documentElement.setAttribute("data-bs-theme", "light");
+ } else if (design == "default_dark") {
+ var theme_path = "../node_modules/bootstrap/dist/css/bootstrap.min.css";
+ document.getElementById("bootstrap_theme").href = escape(theme_path);
+ document.querySelector("html").setAttribute("data-bs-theme", "dark");
+ } else if (design == "default_auto") {
+ var theme_path = "../node_modules/bootstrap/dist/css/bootstrap.min.css";
+ document.getElementById("bootstrap_theme").href = escape(theme_path);
+
+ // https://stackoverflow.com/a/57795495
+ // check if dark mode or light mode used in OS
+ if (
+ window.matchMedia &&
+ window.matchMedia("(prefers-color-scheme: dark)").matches
+ ) {
+ // dark mode
+ document.documentElement.setAttribute("data-bs-theme", "dark");
+ } else {
+ document.documentElement.setAttribute("data-bs-theme", "light");
+ }
+
+ // also register event listener for automatic change
+ window
+ .matchMedia("(prefers-color-scheme: dark)")
+ .addEventListener("change", (event) => {
+ let newColorScheme = event.matches ? "dark" : "light";
+ if (newColorScheme == "dark") {
+ document.documentElement.setAttribute("data-bs-theme", "dark");
+ } else {
+ document.documentElement.setAttribute("data-bs-theme", "light");
+ }
+ });
+ } else {
+ var theme_path = "../node_modules/bootstrap/dist/css/bootstrap.min.css";
+ document.getElementById("bootstrap_theme").href = escape(theme_path);
+ document.documentElement.setAttribute("data-bs-theme", "light");
+ }
+
+ //update path to css file
+ document.getElementById("bootstrap_theme").href = escape(theme_path);
+}
+
+function checkForWaitingMessages(dxcall) {
+ db.find({
+ selector: {
+ dxcallsign: dxcall,
+ type: "transmit",
+ status: "failed",
+ //attempt: { $lt: parseInt(config.max_retry_attempts) }
+ },
+ })
+ .then(function (result) {
+ console.log(
+ "Found " + result.docs.length + " messages waiting for " + dxcall,
+ );
+ // handle result
+ if (result.docs.length > 0) {
+ // only want to process the first available item object, then return
+ // this ensures, we are only sending one message at once
+
+ if (typeof result.docs[0].attempt == "undefined") {
+ db.upsert(result.docs[0]._id, function (doc) {
+ if (!doc.attempt) {
+ doc.attempt = 1;
+ }
+ doc.attempt++;
+ return doc;
+ });
+ console.log("old message found - adding attempt field");
+ result.docs[0].attempt = 1;
+ }
+
+ if (result.docs[0].attempt < config.max_retry_attempts) {
+ console.log("RESENDING MESSAGE TRIGGERED BY BEACON OR PING");
+ console.log(result.docs[0]);
+ document
+ .getElementById("retransmit-msg-" + result.docs[0]._id)
+ .click();
+ } else {
+ console.log("max retries reached...can't auto repeat");
+ document
+ .getElementById("msg-" + result.docs[0]._id + "-attempts-badge")
+ .classList.remove("bg-primary");
+ document
+ .getElementById("msg-" + result.docs[0]._id + "-attempts-badge")
+ .classList.add("bg-danger");
+ }
+ return;
+ } else {
+ //console.log("nope");
+ }
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+}
+
+async function checkForNewMessages() {
+ var newmsgs;
+ await db
+ .find({
+ selector: {
+ new: { $eq: 1 },
+ },
+ limit: 1,
+ })
+ .then(function (result) {
+ if (result.docs.length > 0) newmsgs = true;
+ else newmsgs = false;
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ return newmsgs;
+}
+
+function clearUnreadMessages(dxcall) {
+ //console.log(dxcall);
+ //Selector of dxcall and new $eq: 1 isn't working, don't know why
+ //For now parse all messages of callsign to clear new flag
+ db.find({
+ //{
+ selector:
+ //$and:[
+ { dxcallsign: dxcall }, //, {new: { $gte: 1}}
+ //]
+ // }
+ })
+ .then(function (result) {
+ //console.log(result);
+ //console.log ("New messages count to clear for " + dxcall + ": " + result.docs.length)
+ result.docs.forEach(function (item) {
+ if (item.new == 1) {
+ db.upsert(item._id, function (doc) {
+ doc.new = 0;
+ //console.log("Clearing new on _id " + item._id);
+ return doc;
+ });
+ }
+ });
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+
+
+}
+
+//Have the operating system show a notification popup
+function showOsPopUp(title, message) {
+ if (config.enable_sys_notification == 0) return;
+ const NOTIFICATION_TITLE = title;
+ const NOTIFICATION_BODY = message;
+ new Notification(NOTIFICATION_TITLE, { body: NOTIFICATION_BODY });
+}
+
+//Function to clean old beacons and optimize database
+async function dbClean() {
+ //Only keep the most x latest days of beacons
+ let beaconKeep = 7;
+ let itemCount = 0;
+ let timestampPurge = Math.floor(
+ (Date.now() - beaconKeep * 24 * 60 * 60 * 1000) / 1000,
+ );
+ if (
+ confirm(
+ "Delete beacons and pings older than " +
+ beaconKeep +
+ " days and compact database?",
+ )
+ ) {
+ } else {
+ ipcRenderer.send("request-update-dbclean-spinner");
+ return;
+ }
+
+ //Items to purge from database
+ var purgeFilter = [
+ { type: "beacon" },
+ { type: "ping-ack" },
+ { type: "ping" },
+ ];
+
+ await db
+ .find({
+ selector: {
+ $and: [{ timestamp: { $lt: timestampPurge } }, { $or: purgeFilter }],
+ },
+ })
+ .then(async function (result) {
+ //console.log("Purging " + result.docs.length + " beacons received before " + timestampPurge);
+ itemCount = result.docs.length;
+ result.docs.forEach(async function (item) {
+ await db
+ .get(item._id)
+ .then(async function (doc) {
+ await db.remove(doc);
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+ });
+ })
+ .catch(function (err) {
+ console.log(err);
+ });
+
+ //Compact database
+ await db.compact();
+ window.alert(
+ "Database maintenance is complete. " +
+ itemCount +
+ " items removed from database. It's recommended you now restart the GUI.",
+ );
+ ipcRenderer.send("request-update-dbclean-spinner");
+}
diff --git a/gui_vue/src/js/preload-log.js b/gui_vue/src/js/preload-log.js
new file mode 100644
index 00000000..9e2bcbc2
--- /dev/null
+++ b/gui_vue/src/js/preload-log.js
@@ -0,0 +1,186 @@
+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);
+});
diff --git a/gui_vue/src/js/preload-mesh.js b/gui_vue/src/js/preload-mesh.js
new file mode 100644
index 00000000..6035b058
--- /dev/null
+++ b/gui_vue/src/js/preload-mesh.js
@@ -0,0 +1,231 @@
+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 += `${call} `;
+ 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 += `${call} `;
+ 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 += `${call} `;
+ 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 = '${status_icon}
+ ${routes[i]["status"]}
+ `;
+ 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);
+ }
+});
diff --git a/gui_vue/src/js/sock.js b/gui_vue/src/js/sock.js
new file mode 100644
index 00000000..95bdbe9c
--- /dev/null
+++ b/gui_vue/src/js/sock.js
@@ -0,0 +1,957 @@
+var net = require("net");
+const path = require("path");
+const { ipcRenderer } = require("electron");
+const FD = require("./src/js/freedata.js");
+//import FD from './freedata.js';
+
+// ----------------- init pinia stores -------------
+import { setActivePinia } from 'pinia';
+import pinia from '../store/index';
+setActivePinia(pinia);
+import { useStateStore } from '../store/stateStore.js';
+const stateStore = useStateStore(pinia);
+
+import { useSettingsStore } from '../store/settingsStore.js';
+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 = "";
+
+ if (settings.tnclocation == "localhost") {
+ client.connect(3000, "127.0.0.1");
+ } else {
+ client.connect(settings.tnc_port, settings.tnc_host);
+ }
+}
+
+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;
+ stateStore.updateTncState(client.readyState)
+
+ tncShowConnectStateError = 1;
+});
+
+client.on("error", function (data) {
+ if (tncShowConnectStateError == 1) {
+ console.log("TNC connection error");
+ tncShowConnectStateError = 0;
+ }
+ 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)
+
+});
+
+/*
+client.on('close', function(data) {
+ console.log(' TNC connection closed');
+ setTimeout(connectTNC, 2000)
+});
+*/
+
+client.on("end", function (data) {
+ 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);
+});
+
+//exports.writeTncCommand = function (command) {
+//writeTncCommand = function (command) {
+function writeTncCommand(command) {
+ //console.log(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") {
+ console.log("CLOSED!");
+ }
+
+ if (client.readyState == "opening") {
+ console.log("connecting to TNC...");
+ }
+};
+
+client.on("data", function (socketdata) {
+ stateStore.updateTncState(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 (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;
+ }
+ }
+
+ if (data["command"] == "tnc_state") {
+ //console.log(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 = [];
+
+ 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'])
+ 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") {
+ console.log(data);
+ // iterate through buffer list and sort it to file or message array
+ dataArray = [];
+ messageArray = [];
+
+ for (var 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) {
+ console.log(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 () {
+function getTncState(){
+ command = '{"type" : "get", "command" : "tnc_state"}';
+ writeTncCommand(command);
+};
+
+//Get DATA State
+//exports.getDataState = function () {
+function getDataState(){
+ command = '{"type" : "get", "command" : "data_state"}';
+ //writeTncCommand(command)
+};
+
+// Send Ping
+//exports.sendPing = function (dxcallsign) {
+function sendPing(dxcallsign){
+ command =
+ '{"type" : "ping", "command" : "ping", "dxcallsign" : "' +
+ dxcallsign +
+ '"}';
+ writeTncCommand(command);
+};
+
+// Send Mesh Ping
+//exports.sendMeshPing = function (dxcallsign) {
+function sendMeshPing(dxcallsign){
+ command =
+ '{"type" : "mesh", "command" : "ping", "dxcallsign" : "' +
+ dxcallsign +
+ '"}';
+ writeTncCommand(command);
+};
+
+// Send CQ
+//exports.sendCQ = function () {
+function sendCQ(){
+ command = '{"type" : "broadcast", "command" : "cqcqcq"}';
+ writeTncCommand(command);
+};
+
+// Set AUDIO Level
+//exports.setTxAudioLevel = function (value) {
+function setTxAudioLevel(value){
+ command =
+ '{"type" : "set", "command" : "tx_audio_level", "value" : "' + value + '"}';
+ writeTncCommand(command);
+};
+
+// 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)
+ 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 (
+function sendMessage(
+ 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"}]}';
+ console.log(command);
+ console.log("-------------------------------------");
+ 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"}]}';
+ 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) {
+ 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"}]}';
+ console.log(command);
+ console.log("--------------RES--------------------");
+ writeTncCommand(command);
+}
+
+//Send station info request
+//exports.sendRequestInfo = function (dxcallsign) {
+function sendRequestInfo(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) {
+function sendRequestSharedFolderList(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) {
+function sendRequestSharedFile(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) {
+function sendResponseInfo(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) {
+function sendResponseSharedFolderList(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 (
+function sendResponseSharedFile(
+ 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 () {
+function stopTransmission(){
+ command = '{"type" : "arq", "command": "stop_transmission"}';
+ writeTncCommand(command);
+};
+
+// Get RX BUffer
+//exports.getRxBuffer = function () {
+function getRxBuffer(){
+ command = '{"type" : "get", "command" : "rx_buffer"}';
+
+ // call command only if new data arrived
+ if (rxBufferLengthGui != rxBufferLengthTnc) {
+ writeTncCommand(command);
+ }
+};
+
+// START BEACON
+//exports.startBeacon = function (interval) {
+function startBeacon(interval){
+ command =
+ '{"type" : "broadcast", "command" : "start_beacon", "parameter": "' +
+ interval +
+ '"}';
+ writeTncCommand(command);
+};
+
+// STOP BEACON
+//exports.stopBeacon = function () {
+function stopBeacon(){
+ command = '{"type" : "broadcast", "command" : "stop_beacon"}';
+ writeTncCommand(command);
+};
+
+// OPEN ARQ SESSION
+//exports.connectARQ = function (dxcallsign) {
+function connectARQ(dxcallsign){
+ command =
+ '{"type" : "arq", "command" : "connect", "dxcallsign": "' +
+ dxcallsign +
+ '", "attempts": "10"}';
+ writeTncCommand(command);
+};
+
+// CLOSE ARQ SESSION
+//exports.disconnectARQ = function () {
+function disconnectARQ(){
+ command = '{"type" : "arq", "command" : "disconnect"}';
+ writeTncCommand(command);
+};
+
+// SEND TEST FRAME
+//exports.sendTestFrame = function () {
+function sendTestFrame(){
+ command = '{"type" : "set", "command" : "send_test_frame"}';
+ writeTncCommand(command);
+};
+
+// SEND FEC
+//exports.sendFEC = function (mode, payload) {
+function sendFEC(mode, payload){
+ command =
+ '{"type" : "fec", "command" : "transmit", "mode" : "' +
+ mode +
+ '", "payload" : "' +
+ payload +
+ '"}';
+ writeTncCommand(command);
+};
+
+// SEND FEC IS WRITING
+//exports.sendFecIsWriting = function (mycallsign) {
+function sendFecIsWriting(mycallsign){
+ command =
+ '{"type" : "fec", "command" : "transmit_is_writing", "mycallsign" : "' +
+ mycallsign +
+ '"}';
+ writeTncCommand(command);
+};
+
+// SEND FEC TO BROADCASTCHANNEL
+//exports.sendBroadcastChannel = function (channel, data_out, uuid) {
+function sendBroadcastChannel(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 () {
+function record_audio(){
+ command = '{"type" : "set", "command" : "record_audio"}';
+ writeTncCommand(command);
+};
+
+// SET FREQUENCY
+//exports.set_frequency = function (frequency) {
+function set_frequency(frequency){
+ command =
+ '{"type" : "set", "command" : "frequency", "frequency": ' + frequency + "}";
+ writeTncCommand(command);
+};
+
+// SET MODE
+//exports.set_mode = function (mode) {
+function set_mode(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;
+};
diff --git a/gui_vue/src/store/settingsStore.js b/gui_vue/src/store/settingsStore.js
index d06a7525..c03923d4 100644
--- a/gui_vue/src/store/settingsStore.js
+++ b/gui_vue/src/store/settingsStore.js
@@ -1,80 +1,80 @@
-import { defineStore } from 'pinia';
-import { ref, computed } from 'vue';
+import { defineStore } from 'pinia'
+import { ref, computed } from 'vue'
export const useSettingsStore = defineStore('settingsStore', () => {
// network
- var tnc_host = ref("127.0.0.1");
- var tnc_port = ref(3000);
- var daemon_host = ref("127.0.0.1");
- var daemon_port = ref(3001);
- var tnclocation = ref("localhost");
+ var tnc_host = ref("127.0.0.1")
+ var tnc_port = ref(3000)
+ var daemon_host = ref("127.0.0.1")
+ var daemon_port = ref(3001)
+ var tnclocation = ref("localhost")
// app
- var screen_height = ref(430);
- var screen_width = ref(1050);
- var theme = ref("default");
- var wftheme = ref(2);
- var high_graphics = ref("False");
- var auto_start = ref(0);
- var enable_sys_notification = ref(1);
+ var screen_height = ref(430)
+ var screen_width = ref(1050)
+ var theme = ref("default")
+ var wftheme = ref(2)
+ var high_graphics = ref("False")
+ var auto_start = ref(0)
+ var enable_sys_notification = ref(1)
// chat
- var shared_folder_path = ref(".");
- var enable_request_profile = ref("True");
- var enable_request_shared_folder = ref("False");
- var max_retry_attempts = ref(5);
- var enable_auto_retry = ref("False");
+ var shared_folder_path = ref(".")
+ var enable_request_profile = ref("True")
+ var enable_request_shared_folder = ref("False")
+ var max_retry_attempts = ref(5)
+ var enable_auto_retry = ref("False")
// station
- var mycall = ref("AA0AA-0");
- var mygrid = ref("JN20aa");
+ var mycall = ref("AA0AA-0")
+ var mygrid = ref("JN20aa")
// rigctld
- var hamlib_rigctld_port = ref(4532);
- var hamlib_rigctld_ip = ref("127.0.0.1");
- var radiocontrol = ref("disabled");
- var hamlib_deviceid = ref("RIG_MODEL_DUMMY_NOVFO");
- var hamlib_deviceport = ref("ignore");
- var hamlib_stop_bits = ref("ignore");
- var hamlib_data_bits = ref("ignore");
- var hamlib_handshake = ref("ignore");
- var hamlib_serialspeed = ref("ignore");
- var hamlib_dtrstate = ref("ignore");
- var hamlib_pttprotocol = ref("ignore");
- var hamlib_ptt_port = ref("ignore");
- var hamlib_dcd = ref("ignore");
- var hamlbib_serialspeed_ptt = ref(9600);
- var hamlib_rigctld_port = ref(4532);
- var hamlib_rigctld_ip = ref("127.0.0.1");
- var hamlib_rigctld_path = ref("");
- var hamlib_rigctld_server_port = ref(4532);
- var hamlib_rigctld_custom_args = ref("");
+ var hamlib_rigctld_port = ref(4532)
+ var hamlib_rigctld_ip = ref("127.0.0.1")
+ var radiocontrol = ref("disabled")
+ var hamlib_deviceid = ref("RIG_MODEL_DUMMY_NOVFO")
+ var hamlib_deviceport = ref("ignore")
+ var hamlib_stop_bits = ref("ignore")
+ var hamlib_data_bits = ref("ignore")
+ var hamlib_handshake = ref("ignore")
+ var hamlib_serialspeed = ref("ignore")
+ var hamlib_dtrstate = ref("ignore")
+ var hamlib_pttprotocol = ref("ignore")
+ var hamlib_ptt_port = ref("ignore")
+ var hamlib_dcd = ref("ignore")
+ var hamlbib_serialspeed_ptt = ref(9600)
+ var hamlib_rigctld_port = ref(4532)
+ var hamlib_rigctld_ip = ref("127.0.0.1")
+ var hamlib_rigctld_path = ref("")
+ var hamlib_rigctld_server_port = ref(4532)
+ var hamlib_rigctld_custom_args = ref("")
// tci
- var tci_ip = ref('127.0.0.1');
- var tci_port = ref(50001);
+ var tci_ip = ref('127.0.0.1')
+ var tci_port = ref(50001)
//tnc
- var spectrum = ref("waterfall");
- var enable_scatter = ref("False");
- var enable_fft = ref("False");
- var enable_fsk = ref("False");
- var low_bandwidth_mode = ref("False");
- var update_channel = ref("latest");
- var beacon_interval = ref(300);
- var received_files_folder = ref("None");
- var tuning_range_fmin = ref(-50.0);
- var tuning_range_fmax = ref(50.0);
- var respond_to_cq = ref("True");
- var rx_buffer_size = ref(16);
- var enable_explorer = ref("False");
- var explorer_stats = ref("False");
- var auto_tune = ref("False");
- var enable_is_writing = ref("True");
- var tx_delay = ref(0);
- var enable_mesh_features = ref("False");
+ var spectrum = ref("waterfall")
+ var enable_scatter = ref("False")
+ var enable_fft = ref("False")
+ var enable_fsk = ref("False")
+ var low_bandwidth_mode = ref("False")
+ var update_channel = ref("latest")
+ var beacon_interval = ref(300)
+ var received_files_folder = ref("None")
+ var tuning_range_fmin = ref(-50.0)
+ var tuning_range_fmax = ref(50.0)
+ var respond_to_cq = ref("True")
+ var rx_buffer_size = ref(16)
+ var enable_explorer = ref("False")
+ var explorer_stats = ref("False")
+ var auto_tune = ref("False")
+ var enable_is_writing = ref("True")
+ var tx_delay = ref(0)
+ var enable_mesh_features = ref("False")
function getJSON(){
var config_export = {
@@ -134,7 +134,7 @@ var config_export = {
"auto_start": auto_start.value,
"enable_sys_notification": enable_sys_notification.value,
"enable_mesh_features": enable_mesh_features.value
- };
+ }
return config_export
}
@@ -202,6 +202,6 @@ var config_export = {
tx_delay,
enable_mesh_features,
getJSON
- };
+ }
-});
+})
+ 
';
+ } else {
+ var user_image =
+ '
';
+
+ getSetUserInformation(dxcallsign);
+ getSetUserSharedFolder(dxcallsign);
+ }
+
+ var new_callsign = `
+
+
+