From 2e9344bba7600c22f955951524cfe19a14773705 Mon Sep 17 00:00:00 2001
From: DJ2LS <dj2ls@proton.me>
Date: Sat, 27 Jan 2024 17:44:18 +0100
Subject: [PATCH] cleanup and first implementation of server side message sytem

---
 gui/src/components/chat_conversations.vue     |   49 +-
 gui/src/components/chat_messages.vue          |   32 +-
 gui/src/components/chat_messages_received.vue |   11 +-
 gui/src/components/chat_navbar.vue            |   42 +-
 gui/src/components/chat_new_message.vue       |   10 +-
 gui/src/components/main_modals.vue            |   92 +-
 gui/src/js/api.js                             |   19 +-
 gui/src/js/chatHandler.ts                     | 1110 -----------------
 gui/src/js/deprecated_sock.js                 |  886 -------------
 gui/src/js/eventHandler.js                    |   15 +
 gui/src/js/messagesHandler.ts                 |   66 +
 gui/src/store/chatStore.js                    |   16 +-
 12 files changed, 237 insertions(+), 2111 deletions(-)
 delete mode 100644 gui/src/js/chatHandler.ts
 delete mode 100644 gui/src/js/deprecated_sock.js
 create mode 100644 gui/src/js/messagesHandler.ts

diff --git a/gui/src/components/chat_conversations.vue b/gui/src/components/chat_conversations.vue
index 29884103..d6eec968 100644
--- a/gui/src/components/chat_conversations.vue
+++ b/gui/src/components/chat_conversations.vue
@@ -6,14 +6,9 @@ setActivePinia(pinia);
 import { useChatStore } from "../store/chatStore.js";
 const chat = useChatStore(pinia);
 
-import {
-  getNewMessagesByDXCallsign,
-  resetIsNewMessage,
-} from "../js/chatHandler";
 
 function chatSelected(callsign) {
   chat.selectedCallsign = callsign.toUpperCase();
-
   // scroll message container to bottom
   var messageBody = document.getElementById("message-container");
   if (messageBody != null) {
@@ -21,27 +16,6 @@ function chatSelected(callsign) {
     messageBody.scrollTop = messageBody.scrollHeight - messageBody.clientHeight;
   }
 
-  if (getNewMessagesByDXCallsign(callsign)[1] > 0) {
-    let messageArray = getNewMessagesByDXCallsign(callsign)[2];
-    console.log(messageArray);
-
-    for (const key in messageArray) {
-      resetIsNewMessage(messageArray[key].uuid, false);
-    }
-  }
-
-  try {
-    chat.beaconLabelArray = Object.values(
-      chat.sorted_beacon_list[chat.selectedCallsign].timestamp,
-    );
-    chat.beaconDataArray = Object.values(
-      chat.sorted_beacon_list[chat.selectedCallsign].snr,
-    );
-  } catch (e) {
-    console.log("beacon data not fetched: " + e);
-    chat.beaconLabelArray = [];
-    chat.beaconDataArray = [];
-  }
 }
 </script>
 <template>
@@ -50,33 +24,30 @@ function chatSelected(callsign) {
     id="chat-list-tab"
     role="chat-tablist"
   >
-    <template v-for="(item, key) in chat.callsign_list" :key="item.dxcallsign">
+
+    <template v-for="(details, callsign, key) in chat.callsign_list" :key="callsign">
       <a
         class="list-group-item list-group-item-action list-group-item-dark rounded-2 border-0 mb-2"
         :class="{ active: key == 0 }"
-        :id="`list-chat-list-${item}`"
+        :id="`list-chat-list-${callsign}`"
         data-bs-toggle="list"
-        :href="`#list-${item}-messages`"
+        :href="`#list-${callsign}-messages`"
         role="tab"
-        aria-controls="list-{{item}}-messages"
-        @click="chatSelected(item)"
+        aria-controls="list-{{callsign}}-messages"
+        @click="chatSelected(callsign)"
       >
         <div class="row">
           <div class="col-9">
-            <strong>{{ item }}</strong>
-            <span
-              class="badge rounded-pill bg-danger"
-              v-if="getNewMessagesByDXCallsign(item)[1] > 0"
-            >
-              {{ getNewMessagesByDXCallsign(item)[1] }} new messages
-            </span>
+            <strong>{{ callsign }}</strong>
+            <!--<small> {{details.timestamp}} </small>-->
+
           </div>
           <div class="col-3">
             <button
               class="btn btn-sm btn-outline-secondary ms-2 border-0"
               data-bs-target="#deleteChatModal"
               data-bs-toggle="modal"
-              @click="chatSelected(item)"
+              @click="chatSelected(callsign)"
             >
               <i class="bi bi-three-dots-vertical"></i>
             </button>
diff --git a/gui/src/components/chat_messages.vue b/gui/src/components/chat_messages.vue
index bb00ca6e..2a390f6d 100644
--- a/gui/src/components/chat_messages.vue
+++ b/gui/src/components/chat_messages.vue
@@ -30,7 +30,7 @@ function getDateTime(timestampRaw) {
 
 <template>
   <div class="tab-content" id="nav-tabContent-chat-messages">
-    <template v-for="(callsign, key) in chat.callsign_list">
+    <template v-for="(details, callsign, key) in chat.callsign_list" :key="callsign">
       <div
         class="tab-pane fade show"
         :class="{ active: key == 0 }"
@@ -38,38 +38,44 @@ function getDateTime(timestampRaw) {
         role="tabpanel"
         :aria-labelledby="`list-chat-list-${callsign}`"
       >
+
+
         <template
           v-for="item in chat.sorted_chat_list[callsign]"
-          :key="item._id"
         >
+        <!--
           <div v-if="prevChatMessageDay !== getDateTime(item.timestamp)">
             <div class="separator my-2">
               {{ (prevChatMessageDay = getDateTime(item.timestamp)) }}
             </div>
           </div>
+        -->
 
-          <div v-if="item.type === 'beacon' && item.status === 'received'">
-            <!-- {{ item }} -->
+
+
+            {{item}}
+            <hr>
+          <div v-if="item.direction === 'transmit'">
+            {{ console.log('Item direction:', item.direction) }}
+            <!--<sent-message :message="item" />-->
           </div>
 
-          <div v-if="item.type === 'ping'">{{ item.snr }} dB ping received</div>
 
-          <div v-if="item.type === 'ping-ack'">
-            {{ item.snr }} dB ping-ack received
-          </div>
 
-          <div v-if="item.type === 'transmit'">
-            <sent-message :message="item" />
-          </div>
-          <div v-else-if="item.type === 'received'">
-            <received-message :message="item" />
+          <div v-else-if="item.direction === 'receive'">
+          {{ console.log('Item direction:', item.direction) }}
+
+
+            <!--<received-message :message="item" />-->
           </div>
+          <!--
           <div v-if="item.type === 'broadcast_transmit'">
             <sent-broadcast-message :message="item" />
           </div>
           <div v-else-if="item.type === 'broadcast_received'">
             <received-broadcast-message :message="item" />
           </div>
+          -->
         </template>
       </div>
     </template>
diff --git a/gui/src/components/chat_messages_received.vue b/gui/src/components/chat_messages_received.vue
index aaa11afb..b1fab3a6 100644
--- a/gui/src/components/chat_messages_received.vue
+++ b/gui/src/components/chat_messages_received.vue
@@ -1,4 +1,5 @@
 <template>
+
   <div class="row justify-content-start mb-2">
     <div :class="messageWidthClass">
       <div class="card bg-light border-0 text-dark">
@@ -11,7 +12,7 @@
         </div>
 
         <div class="card-body">
-          <p class="card-text">{{ message.msg }}</p>
+          <p class="card-text">{{ message.body }}</p>
         </div>
 
         <div class="card-footer p-0 bg-light border-top-0">
@@ -70,20 +71,20 @@ export default {
   },
   methods: {
     showMessageInfo() {
-      requestMessageInfo(this.message._id);
+      requestMessageInfo(this.message.id);
       //let infoModal = Modal.getOrCreateInstance(document.getElementById('messageInfoModal'))
       //console.log(this.infoModal)
       //this.infoModal.show()
     },
     deleteMessage() {
-      deleteMessageFromDB(this.message._id);
+      deleteMessageFromDB(this.message.id);
     },
     async downloadAttachment() {
       try {
         // reset file store
         chat.downloadFileFromDB = [];
 
-        const attachment = await getMessageAttachment(this.message._id);
+        const attachment = await getMessageAttachment(this.message.id);
         const blob = new Blob([atob_FD(attachment[2])], {
           type: `${attachment[1]};charset=utf-8`,
         });
@@ -121,6 +122,8 @@ export default {
     },
 
     getDateTime() {
+
+    console.log(this.message.timestamp)
       var datetime = new Date(this.message.timestamp * 1000).toLocaleString(
         navigator.language,
         {
diff --git a/gui/src/components/chat_navbar.vue b/gui/src/components/chat_navbar.vue
index 4fff980c..fbb69f52 100644
--- a/gui/src/components/chat_navbar.vue
+++ b/gui/src/components/chat_navbar.vue
@@ -108,14 +108,11 @@ function newChat() {
   let callsign = this.newChatCall.value;
   callsign = callsign.toUpperCase().trim();
   if (callsign === "") return;
-  startChatWithNewStation(callsign);
+  //startChatWithNewStation(callsign);
   //updateAllChat(false);
   this.newChatCall.value = "";
 }
 
-function syncWithModem() {
-  getRxBuffer();
-}
 </script>
 
 <template>
@@ -123,26 +120,15 @@ function syncWithModem() {
     <div class="container">
       <div class="row w-100">
         <div class="col-3 p-0 me-2">
-          <div class="input-group bottom-0 m-0 ms-1">
-            <input
-              class="form-control"
-              maxlength="9"
-              style="text-transform: uppercase"
-              placeholder="callsign"
-              @keypress.enter="newChat()"
-              ref="newChatCall"
-            />
-            <button
-              class="btn btn-sm btn-outline-success"
-              id="createNewChatButton"
-              type="button"
-              title="Start a new chat (enter dx call sign first)"
-              @click="newChat()"
+          <button
+              class="btn btn-outline-primary"
+              data-bs-target="#newChatModal"
+              data-bs-toggle="modal"
             >
-              new chat
-              <i class="bi bi-pencil-square" style="font-size: 1.2rem"></i>
+              <i class="bi bi-pencil-square"> Start a new chat</i>
             </button>
-          </div>
+
+
         </div>
         <div class="col-5 ms-2 p-0">
           <!-- right side of chat nav bar-->
@@ -164,18 +150,6 @@ function syncWithModem() {
             </div>
           </div>
         </div>
-
-        <div class="col-2 ms-2 p-0">
-          <div class="input-group mb-0 p-0">
-            <button
-              type="button"
-              class="btn btn-outline-secondary"
-              @click="syncWithModem()"
-            >
-              Modem Sync {{ state.rx_buffer_length }}
-            </button>
-          </div>
-        </div>
       </div>
     </div>
   </nav>
diff --git a/gui/src/components/chat_new_message.vue b/gui/src/components/chat_new_message.vue
index 4350d6d7..e7415cb7 100644
--- a/gui/src/components/chat_new_message.vue
+++ b/gui/src/components/chat_new_message.vue
@@ -17,8 +17,7 @@ import chat_navbar from './chat_navbar.vue'
 import chat_conversations from './chat_conversations.vue'
 import chat_messages from './chat_messages.vue'
 
-import {updateAllChat, newMessage, newBroadcast} from '../js/chatHandler'
-
+import { newMessage } from '../js/messagesHandler.ts'
 
 import {
   Chart as ChartJS,
@@ -54,10 +53,11 @@ function transmitNewMessage(){
       return;
     if (chat.selectedCallsign.startsWith("BC-")) {
 
-        newBroadcast(chat.selectedCallsign, chat.inputText)
+        return "new broadcast"
 
     } else {
-        newMessage(chat.selectedCallsign, chat.inputText, chat.inputFile, chat.inputFileName, chat.inputFileSize, chat.inputFileType)
+        //newMessage(chat.selectedCallsign, chat.inputText, chat.inputFile, chat.inputFileName, chat.inputFileSize, chat.inputFileType)
+        newMessage(chat.selectedCallsign, chat.inputText)
     }
     // finally do a cleanup
     //chatModuleMessage.reset();
@@ -195,9 +195,11 @@ const speedChartData = computed(() => ({
 
 
                                         <!-- trigger file selection modal -->
+                            <!--
                             <button type="button" class="btn btn-outline-secondary border-0 rounded-pill me-1" data-bs-toggle="modal" data-bs-target="#fileSelectionModal">
                               <i class="bi bi-paperclip" style="font-size: 1.2rem"></i>
                             </button>
+                            -->
 
 
                           <textarea
diff --git a/gui/src/components/main_modals.vue b/gui/src/components/main_modals.vue
index c56adb50..983dbe94 100644
--- a/gui/src/components/main_modals.vue
+++ b/gui/src/components/main_modals.vue
@@ -9,19 +9,16 @@ import { useChatStore } from "../store/chatStore.js";
 const chat = useChatStore(pinia);
 
 import { settingsStore as settings, onChange } from "../store/settingsStore.js";
-
 import { sendModemTestFrame } from "../js/api";
-
-import {
-  deleteChatByCallsign,
-  getNewMessagesByDXCallsign,
-} from "../js/chatHandler";
-
 import main_startup_check from "./main_startup_check.vue";
+import { newMessage } from '../js/messagesHandler.ts'
+
+function newChat(){
+    newMessage(chat.newChatCallsign, chat.newChatMessage)
+}
 
 function deleteChat() {
-  //console.log(chat.selectedCallsign)
-  deleteChatByCallsign(chat.selectedCallsign);
+    return
 }
 
 import {
@@ -181,16 +178,12 @@ const transmissionSpeedChartDataMessageInfo = computed(() => ({
             <span class="input-group-text" id="basic-addon1"
               >Total Messages</span
             >
-            <span class="input-group-text" id="basic-addon1">{{
-              getNewMessagesByDXCallsign(chat.selectedCallsign)[0]
-            }}</span>
+            <span class="input-group-text" id="basic-addon1">...</span>
           </div>
 
           <div class="input-group mb-3">
             <span class="input-group-text" id="basic-addon1">New Messages</span>
-            <span class="input-group-text" id="basic-addon1">{{
-              getNewMessagesByDXCallsign(chat.selectedCallsign)[1]
-            }}</span>
+            <span class="input-group-text" id="basic-addon1">...</span>
           </div>
         </div>
         <div class="modal-footer">
@@ -316,6 +309,75 @@ const transmissionSpeedChartDataMessageInfo = computed(() => ({
     </div>
   </div>
 
+<div
+    class="modal fade"
+    ref="modalEle"
+    id="newChatModal"
+    tabindex="-1"
+    aria-hidden="true"
+  >
+    <div class="modal-dialog">
+      <div class="modal-content">
+        <div class="modal-header">
+          <h1 class="modal-title fs-5" id="deleteChatModalLabel">
+            Start a new chat
+          </h1>
+          <button
+            type="button"
+            class="btn-close"
+            data-bs-dismiss="modal"
+            aria-label="Close"
+          ></button>
+        </div>
+        <div class="modal-body">
+
+<div class="alert alert-info" role="alert">
+  1. Enter destination callsign
+  <br>
+  2. Enter a first message
+  <br>
+  3. Pressing "START NEW CHAT"
+</div>
+
+<div class="form-floating mb-3">
+  <input type="text" class="form-control" id="floatingInputDestination" placeholder="dxcallsign / destination" maxlength="9"
+              style="text-transform: uppercase" @keypress.enter="newChat()" v-model="chat.newChatCallsign">
+  <label for="floatingInputDestination">dxcallsign / destination</label>
+</div>
+
+<div class="form-floating">
+  <textarea class="form-control" placeholder="Your first message" id="floatingTextareaNewChatMessage" style="height: 100px" v-model="chat.newChatMessage"></textarea>
+  <label for="floatingTextareaNewChatMessage">First message</label>
+</div>
+
+
+
+        </div>
+        <div class="modal-footer">
+          <button
+            type="button"
+            class="btn btn-secondary"
+            data-bs-dismiss="modal"
+          >
+            Close
+          </button>
+          <button
+              class="btn btn-sm btn-outline-success"
+              id="createNewChatButton"
+              type="button"
+              data-bs-dismiss="modal"
+              title="Start a new chat (enter dx call sign first)"
+              @click="newChat()"
+            >
+              START NEW CHAT
+              <i class="bi bi-pencil-square" style="font-size: 1.2rem"></i>
+            </button>
+        </div>
+      </div>
+    </div>
+  </div>
+
+
   <!-- HELP MODALS AUDIO -->
   <div
     class="modal fade"
diff --git a/gui/src/js/api.js b/gui/src/js/api.js
index 4dd9b641..3c3257c9 100644
--- a/gui/src/js/api.js
+++ b/gui/src/js/api.js
@@ -4,6 +4,10 @@ import {
   validateCallsignWithoutSSID,
 } from "./freedata";
 
+import {
+processFreedataMessages
+} from "./messagesHandler"
+
 function buildURL(params, endpoint) {
   const url = "http://" + params.host + ":" + params.port + endpoint;
   return url;
@@ -15,8 +19,7 @@ async function apiGet(endpoint) {
     if (!response.ok) {
       throw new Error(`REST response not ok: ${response.statusText}`);
     }
-    const data = await response.json();
-    return data;
+    return await response.json();
   } catch (error) {
     console.error("Error getting from REST:", error);
   }
@@ -127,3 +130,15 @@ export function setRadioParameters(frequency, mode, rf_level) {
 export function getRadioStatus() {
   return apiGet("/radio");
 }
+
+export async function getFreedataMessages(){
+    let res = await apiGet("/freedata/messages")
+    processFreedataMessages(res)
+}
+
+export async function sendFreedataMessage(dxcall, body) {
+  return await apiPost("/freedata/messages", {
+    dxcall: dxcall,
+    body: body,
+  });
+}
\ No newline at end of file
diff --git a/gui/src/js/chatHandler.ts b/gui/src/js/chatHandler.ts
deleted file mode 100644
index 50c664ba..00000000
--- a/gui/src/js/chatHandler.ts
+++ /dev/null
@@ -1,1110 +0,0 @@
-const path = require("path");
-
-const { v4: uuidv4 } = require("uuid");
-
-// pinia store setup
-import { setActivePinia } from "pinia";
-import pinia from "../store/index";
-setActivePinia(pinia);
-
-import { useChatStore } from "../store/chatStore.js";
-const chat = useChatStore(pinia);
-
-import { useStateStore } from "../store/stateStore.js";
-const state = useStateStore(pinia);
-
-import { settingsStore as settings } from "../store/settingsStore.js";
-import { getAppDataPath } from "../js/freedata";
-
-import { displayToast } from "./popupHandler.js";
-
-//const FD = require("./src/js/freedata.js");
-import {
-  atob_FD,
-  btoa_FD,
-  sortByProperty,
-  sortByPropertyDesc,
-} from "./freedata.js";
-
-import { sendModemARQRaw } from "../js/api.js";
-
-const split_char = "0;1;";
-
-// define default message object
-interface Attachment {
-  content_type: string;
-  data: string;
-}
-
-interface messageDefaultObject {
-  command: string;
-  hmac_signed: boolean;
-  percent: number;
-  bytesperminute: number;
-  is_new: boolean;
-  _id: string;
-  timestamp: number;
-  dxcallsign: string;
-  dxgrid: string;
-  msg: string;
-  checksum: string;
-  type: string;
-  status: string;
-  attempt: number;
-  uuid: string;
-  duration: number;
-  nacks: number;
-  speed_list: string;
-  broadcast_sender?: string; // optional for broadcasts
-
-  _attachments: {
-    [filename: string]: Attachment;
-  };
-}
-
-interface beaconDefaultObject {
-  command: string;
-  is_new: boolean;
-  _id: string;
-  timestamp: number;
-  dxcallsign: string;
-  dxgrid: string;
-  type: string;
-  status: string;
-  uuid: string;
-  snr: string;
-}
-
-interface newChatDefaultObject {
-  command: string;
-  is_new: boolean;
-  timestamp: number;
-  dxcallsign: string;
-}
-
-// ---- MessageDB
-try {
-  var PouchDB = require("pouchdb");
-} catch (err) {
-  console.log(err);
-  /*
-    This is a fix for raspberryPi where we get an error when loading pouchdb because of
-    leveldown package isnt running on ARM devices.
-    pouchdb-browser does not depend on leveldb and seems to be working.
-    */
-  console.log("using pouchdb-browser fallback");
-  var PouchDB = require("pouchdb-browser");
-}
-
-PouchDB.plugin(require("pouchdb-find"));
-//PouchDB.plugin(require('pouchdb-replication'));
-PouchDB.plugin(require("pouchdb-upsert"));
-
-var appDataPath = getAppDataPath();
-var configFolder = path.join(appDataPath, "FreeDATA");
-
-var chatDB = path.join(configFolder, "chatDB");
-console.log("database path:" + chatDB);
-
-var db = new PouchDB(chatDB);
-
-/* -------- CREATE DATABASE INDEXES */
-//These aren't needed anylonger aslong as we await createIndex() where necessary
-//createChatIndex();
-
-/* -------- RUN A DATABASE CLEANUP ON STARTUP */
-//dbClean()
-
-updateAllChat(true);
-
-// create callsign set for storing unique callsigns
-chat.callsign_list = new Set();
-
-// function for creating a new broadcast
-export function newBroadcast(broadcastChannel, chatmessage) {
-  var file = "";
-  var filetype = "text";
-  var filename = "";
-
-  var file_checksum = ""; //crc32(file).toString(16).toUpperCase();
-  var message_type = "broadcast_transmit";
-
-  var timestamp = Math.floor(Date.now() / 1000);
-  var uuid = uuidv4();
-  // TODO: Not sure what this uuid part is needed for ...
-  let uuidlast = uuid.lastIndexOf("-");
-  uuidlast += 1;
-  if (uuidlast > 0) {
-    uuid = uuid.substring(uuidlast);
-  }
-  // slice uuid for reducing overhead
-  uuid = uuid.slice(-4);
-
-  let newChatObj: messageDefaultObject = {
-    command: "broadcast",
-    hmac_signed: false,
-    percent: 0,
-    bytesperminute: 0, // You need to assign a value here
-    is_new: false,
-    _id: uuid,
-    timestamp: timestamp,
-    dxcallsign: broadcastChannel,
-    dxgrid: "null",
-    msg: chatmessage,
-    checksum: file_checksum,
-    type: message_type,
-    status: "transmitting",
-    attempt: 1,
-    uuid: uuid,
-    duration: 0,
-    nacks: 0,
-    speed_list: "null",
-    _attachments: {
-      [filename]: {
-        content_type: filetype,
-        data: btoa_FD(file),
-      },
-    },
-  };
-
-  //sendMessage(newChatObj)
-  //sendBroadcastChannel(newChatObj);
-
-  addObjToDatabase(newChatObj);
-}
-
-// function for creating a new message
-export function newMessage(
-  dxcallsign,
-  chatmessage,
-  chatFile,
-  chatFileName,
-  chatFileSize,
-  chatFileType,
-) {
-  var filename = "";
-  var filetype = "";
-  var file = "";
-  if (typeof chatFile !== "undefined") {
-    file = chatFile;
-    filetype = chatFileType;
-    filename = chatFileName;
-  } else {
-    file = "";
-    filetype = "";
-    filename = "";
-  }
-
-  console.log(file);
-  console.log(filetype);
-  console.log(filename);
-
-  var file_checksum = ""; //crc32(file).toString(16).toUpperCase();
-  var message_type = "transmit";
-  var command = "msg";
-
-  var timestamp = Math.floor(Date.now() / 1000);
-  var uuid = uuidv4();
-  // TODO: Not sure what this uuid part is needed for ...
-  let uuidlast = uuid.lastIndexOf("-");
-  uuidlast += 1;
-  if (uuidlast > 0) {
-    uuid = uuid.substring(uuidlast);
-  }
-  // slice uuid for reducing overhead
-  uuid = uuid.slice(-8);
-
-  let newChatObj: messageDefaultObject = {
-    command: command,
-    hmac_signed: false,
-    percent: 0,
-    bytesperminute: 0, // You need to assign a value here
-    is_new: false,
-    _id: uuid,
-    timestamp: timestamp,
-    dxcallsign: dxcallsign,
-    dxgrid: "null",
-    msg: chatmessage,
-    checksum: file_checksum,
-    type: message_type,
-    status: "transmitting",
-    attempt: 1,
-    uuid: uuid,
-    duration: 0,
-    nacks: 0,
-    speed_list: "null",
-    _attachments: {
-      [filename]: {
-        content_type: filetype,
-        data: btoa_FD(file),
-      },
-    },
-  };
-
-  sendMessage(newChatObj);
-  addObjToDatabase(newChatObj);
-}
-
-// function for creating a list, accessible by callsign
-function sortChatList() {
-  // Create an empty object to store the reordered data dynamically
-  var reorderedData = {};
-  var jsonObjects = chat.unsorted_chat_list;
-  // Iterate through the list of JSON objects and reorder them dynamically
-  jsonObjects.forEach((obj) => {
-    var dxcallsign = obj.dxcallsign;
-    if (dxcallsign) {
-      if (!reorderedData[dxcallsign]) {
-        reorderedData[dxcallsign] = [];
-      }
-      reorderedData[dxcallsign].push(obj);
-
-      reorderedData[dxcallsign] = reorderedData[dxcallsign].sort(
-        sortByProperty("timestamp"),
-      );
-    }
-  });
-  //console.log(reorderedData["2LS-0"])
-  return reorderedData;
-}
-
-export function getMessageAttachment(id) {
-  return new Promise(async (resolve, reject) => {
-    try {
-      const findResult = await db.find({
-        selector: {
-          _id: id,
-        },
-      });
-
-      const getResult = await db.get(findResult.docs[0]._id, {
-        attachments: true,
-      });
-
-      let obj = getResult;
-      let filename = Object.keys(obj._attachments)[0];
-      let filetype = obj._attachments[filename].content_type;
-      let file = obj._attachments[filename].data;
-      resolve([filename, filetype, file]);
-    } catch (err) {
-      console.log(err);
-      reject(false); // Reject the Promise if there's an error
-    }
-  });
-}
-
-//repeat a message
-export function repeatMessageTransmission(id) {
-  // 1. get message object by ID
-  // 2. Upsert Attempts
-  // 3. send message
-
-  db.find({
-    selector: {
-      _id: id,
-    },
-  })
-    .then(function (result) {
-      console.log(result);
-      let obj = result.docs[0];
-      console.log(obj);
-      obj.attempt += 1;
-      databaseUpsert(obj.uuid, "attempt", obj.attempt);
-      updateUnsortedChatListEntry(obj.uuid, "attempt", obj.attempt);
-      sendMessage(obj);
-    })
-    .catch(function (err) {
-      console.log(err);
-    });
-}
-
-// delete a message from databse and gui
-export function deleteMessageFromDB(id) {
-  console.log("deleting: " + id);
-  db.get(id).then(function (doc) {
-    db.remove(doc);
-  });
-
-  // overwrote unsorted chat list  by filtering if not ID
-  chat.unsorted_chat_list = chat.unsorted_chat_list.filter(
-    (entry) => entry.uuid !== id,
-  );
-
-  // and finally generate our sorted chat list, which is the key store for chat gui rendering
-  // the removed entry should be removed now from gui
-  chat.sorted_chat_list = sortChatList();
-}
-
-//Function to clean old beacons and optimize database
-async function dbClean() {
-  //Only keep the most x latest days of beacons
-  let beaconKeep = 4;
-  let itemCount = 0;
-  let timestampPurge = Math.floor(
-    (Date.now() - beaconKeep * 24 * 60 * 60 * 1000) / 1000,
-  );
-
-  //Items to purge from database
-  var purgeFilter = [
-    { type: "beacon" },
-    { type: "ping-ack" },
-    { type: "ping" },
-    { type: "request" },
-    { type: "response" },
-  ];
-
-  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 deleteMessageFromDB(item._id);
-      });
-    })
-    .catch(function (err) {
-      console.log(err);
-    });
-
-  //Compact database
-  //Too slow on older/slower machines
-  //await db.compact();
-
-  let message = "Database maintenance is complete, ";
-  //displayToast("info", "bi bi-info-circle", message, 5000);
-
-  message += "removed " + itemCount + " items from database";
-  console.log(message);
-}
-
-// function to update transmission status
-export function updateTransmissionStatus(obj) {
-  // update database entries
-  databaseUpsert(obj.uuid, "percent", obj.percent);
-  databaseUpsert(obj.uuid, "bytesperminute", obj.bytesperminute);
-  databaseUpsert(obj.uuid, "status", obj.status);
-
-  // update screen rendering / messages
-  updateUnsortedChatListEntry(obj.uuid, "percent", obj.percent);
-  updateUnsortedChatListEntry(obj.uuid, "bytesperminute", obj.bytesperminute);
-  updateUnsortedChatListEntry(obj.uuid, "status", obj.status);
-}
-
-export function updateUnsortedChatListEntry(uuid, object, value) {
-  var data = getFromUnsortedChatListByUUID(uuid);
-  if (data) {
-    data[object] = value;
-    //console.log("Entry updated:", data[object]);
-    chat.sorted_chat_list = sortChatList();
-    return data;
-  }
-
-  /*
-  for (const entry of chat.unsorted_chat_list) {
-    if (entry.uuid === uuid) {
-      entry[object] = value;
-      console.log("Entry updated:", entry[object]);
-      chat.sorted_chat_list = sortChatList();
-      return entry;
-    }
-  }
-  */
-
-  //console.log("Entry not updated:", object);
-  return null; // Return null if not found
-}
-
-function getFromUnsortedChatListByUUID(uuid) {
-  for (const entry of chat.unsorted_chat_list) {
-    if (entry.uuid === uuid) {
-      return entry;
-    }
-  }
-  return false;
-}
-
-export function getNewMessagesByDXCallsign(dxcallsign): [number, number, any] {
-  let new_counter = 0;
-  let total_counter = 0;
-  let item_array = [];
-  try {
-    if (
-      typeof dxcallsign !== "undefined" &&
-      typeof chat.sorted_chat_list[dxcallsign] !== "undefined"
-    ) {
-      for (const key in chat.sorted_chat_list[dxcallsign]) {
-        //console.log(chat.sorted_chat_list[dxcallsign][key])
-        //item_array.push(chat.sorted_chat_list[dxcallsign][key])
-        if (chat.sorted_chat_list[dxcallsign][key].is_new) {
-          item_array.push(chat.sorted_chat_list[dxcallsign][key]);
-          new_counter += 1;
-        }
-        total_counter += 1;
-      }
-    }
-
-    return [total_counter, new_counter, item_array];
-  } catch (e) {
-    console.log(e);
-    return [0, 0, item_array];
-  }
-}
-
-export function resetIsNewMessage(uuid, value) {
-  databaseUpsert(uuid, "is_new", value);
-  updateUnsortedChatListEntry(uuid, "is_new", value);
-}
-
-export function databaseUpsert(id, object, value) {
-  db.upsert(id, function (doc) {
-    if (!doc[object]) {
-      doc[object] = value;
-    }
-    doc[object] = value;
-    return doc;
-  })
-    .then(function (res) {
-      // success, res is {rev: '1-xxx', updated: true, id: 'myDocId'}
-      //console.log(res);
-    })
-    .catch(function (err) {
-      // error
-      console.log(err);
-    });
-}
-
-// function for fetching all messages from chat / updating chat
-export async function updateAllChat(cleanup) {
-  // run cleanup if requested
-  if (cleanup) {
-    await dbClean();
-  }
-  let indexFields = [{ dxcallsign: "asc" }, { timestamp: "asc" }];
-  let filter = {
-    selector: {
-      $and: [
-        { dxcallsign: { $exists: true } },
-        { timestamp: { $exists: true } },
-        //{ $or: chat.chat_filter },
-      ],
-    },
-    sort: [{ dxcallsign: "asc" }, { timestamp: "asc" }],
-  };
-  //"{ dxcallsign: \"asc\" }, { timestamp: \"asc\" }"
-  await createIndex(indexFields);
-  getFromDBByFilter(filter)
-    .then(function (result) {
-      for (var item of (result as any).docs) {
-        const dxcallsign = item.dxcallsign;
-        // Check if dxcallsign already exists as a property in the result object
-        if (!chat.sorted_beacon_list[dxcallsign]) {
-          // If not, initialize it with an empty array for snr values
-          chat.sorted_beacon_list[dxcallsign] = {
-            dxcallsign,
-            snr: [],
-            timestamp: [],
-          };
-          chat.callsign_list.add(dxcallsign);
-        }
-
-        if (item.type === "beacon") {
-          //console.log(item);
-
-          // TODO: sort beacon list .... maybe a part for a separate function
-          const jsonData = [item];
-
-          // Process each JSON item step by step
-          jsonData.forEach((jsonitem) => {
-            const { snr, timestamp } = item;
-
-            // Push the snr value to the corresponding dxcallsign's snr array
-            chat.sorted_beacon_list[dxcallsign].snr.push(snr);
-            chat.sorted_beacon_list[dxcallsign].timestamp.push(timestamp);
-          });
-        } else {
-          chat.unsorted_chat_list.push(item);
-          chat.sorted_chat_list = sortChatList();
-
-          // check if message is expired
-          let timeNow = Math.floor(Date.now() / 1000);
-          let expireTimestamp = timeNow - 10 * 60;
-          let isExpired = false;
-          if (expireTimestamp >= item.timestamp) {
-            isExpired = true;
-          }
-          if (item.status == "transmitting" && isExpired) {
-            console.log("message expired - resetting status");
-            console.log(item);
-            databaseUpsert(item.uuid, "status", "failed");
-            updateUnsortedChatListEntry(item.uuid, "status", "failed");
-            databaseUpsert(item.uuid, "percent", 0);
-            updateUnsortedChatListEntry(item.uuid, "percent", 0);
-          }
-          // lets update the message if it is failed. Then its always 0 percent
-          if (item.status == "failed") {
-            databaseUpsert(item.uuid, "percent", 0);
-            updateUnsortedChatListEntry(item.uuid, "percent", 0);
-            databaseUpsert(item.uuid, "bytesperminute", 0);
-            updateUnsortedChatListEntry(item.uuid, "bytesperminute", 0);
-          }
-        }
-      }
-    })
-    .catch(function (err) {
-      console.log(err);
-    });
-}
-
-function addObjToDatabase(newobj) {
-  console.log(newobj);
-  /*
-        db.upsert(newobj._id, function (doc) {
-          if (!doc._id) {
-            console.log("upsert")
-            console.log(doc)
-            doc = newobj
-          } else {
-                        console.log("new...")
-            */
-  db.post(newobj)
-    .then(function (response) {
-      // handle response
-      console.log("new database entry");
-      console.log(response);
-
-      if (newobj.command === "msg" || newobj.command === "newchat") {
-        chat.unsorted_chat_list.push(newobj);
-        chat.sorted_chat_list = sortChatList();
-      }
-    })
-    .catch(function (err) {
-      console.log(err);
-      console.log(newobj);
-
-      // try upserting status in case we tried sending a message to our selfes
-      databaseUpsert(newobj.uuid, "status", newobj.status);
-      updateUnsortedChatListEntry(newobj.uuid, "status", newobj.status);
-    });
-
-  /*
-// upsert footer ...
-
-          }
-          return doc;
-        })
-*/
-}
-
-/*
-function createChatIndex() {
-  db.createIndex({
-    index: {
-      fields: [
-        "timestamp",
-        "uuid",
-        "dxcallsign",
-        "dxgrid",
-        "msg",
-        "checksum",
-        "type",
-        "command",
-        "status",
-        "percent",
-        "attempt",
-        "hmac_signed",
-        "bytesperminute",
-        "_attachments",
-        "is_new",
-        "nacks",
-        "duration",
-        "speed_list",
-      ],
-    },
-  })
-    .then(function (result) {
-      // handle result
-      console.log(result);
-    })
-    .catch(function (err) {
-      console.log(err);
-    });
-}
-*/
-
-export function deleteChatByCallsign(callsign) {
-  chat.callsign_list.delete(callsign);
-  // @ts-expect-error
-  delete chat.unsorted_chat_list.callsign;
-  delete chat.sorted_chat_list.callsign;
-
-  deleteFromDatabaseByCallsign(callsign);
-}
-
-function deleteFromDatabaseByCallsign(callsign) {
-  db.find({
-    selector: {
-      dxcallsign: callsign,
-    },
-  })
-    .then(function (result) {
-      // handle result
-      if (typeof result !== "undefined") {
-        result.docs.forEach(function (item) {
-          console.log(item);
-          db.get(item._id)
-            .then(function (doc) {
-              db.remove(doc)
-                .then(function () {
-                  //updateAllChat(false);
-                  return true;
-                })
-                .catch(function (err) {
-                  console.log(err);
-                });
-            })
-            .catch(function (err) {
-              console.log(err);
-            });
-        });
-      }
-    })
-    .catch(function (err) {
-      console.log(err);
-    });
-}
-//Function creates a new 'newchat' database entry when user initates a new chat, otherwise cannot send messages unless receiving a message/beacon from user first
-/**
- * Add a newuser to the database, for when newuser button is clicked
- * @param {string} call callsign of new user
- */
-export function startChatWithNewStation(call) {
-  let newchat: newChatDefaultObject = {
-    command: "newchat",
-    is_new: false,
-    timestamp: Math.floor(new Date().getTime() / 1000),
-    dxcallsign: call,
-  };
-  addObjToDatabase(newchat);
-  if (!chat.sorted_beacon_list[call]) {
-    // If not, initialize it with an empty array for snr values
-    chat.sorted_beacon_list[call] = {
-      call,
-      snr: [],
-      timestamp: [],
-    };
-    chat.callsign_list.add(call);
-  }
-  //chat.unsorted_chat_list.push(newchat);
-  //chat.sorted_chat_list = sortChatList();
-}
-
-// function for handling a received beacon
-export function newBeaconReceived(obj) {
-  /*
-{
-    "freedata": "modem-message",
-    "beacon": "received",
-    "uuid": "12741312-3dbb-4a53-b0cc-100f6c930ab8",
-    "timestamp": 1696076869,
-    "dxcallsign": "DJ2LS-0",
-    "dxgrid": "JN48CS",
-    "snr": "-2.8",
-    "mycallsign": "DJ2LS-0"
-}
-*/
-  let newChatObj: beaconDefaultObject = {
-    command: "beacon",
-    is_new: false,
-    _id: obj["uuid"],
-    timestamp: obj["timestamp"],
-    dxcallsign: obj["dxcallsign"],
-    dxgrid: obj["dxgrid"],
-    type: "beacon",
-    status: obj["beacon"],
-    uuid: obj["uuid"],
-    snr: obj["snr"], // adding the new field
-  };
-
-  addObjToDatabase(newChatObj);
-
-  console.log(obj);
-
-  const jsonData = [obj];
-  const dxcallsign = obj.dxcallsign;
-  // Process each JSON item step by step
-  jsonData.forEach((item) => {
-    const { snr, timestamp } = obj;
-
-    // Check if dxcallsign already exists as a property in the result object
-    if (!chat.sorted_beacon_list[dxcallsign]) {
-      // If not, initialize it with an empty array for snr values
-      chat.sorted_beacon_list[dxcallsign] = {
-        dxcallsign,
-        snr: [],
-        timestamp: [],
-      };
-    }
-
-    // Push the snr value to the corresponding dxcallsign's snr array
-    chat.sorted_beacon_list[dxcallsign].snr.push(snr);
-    chat.sorted_beacon_list[dxcallsign].timestamp.push(timestamp);
-  });
-
-  // check if auto retry enabled
-  //console.log("-----------------------------------------");
-  //console.log(settings.enable_auto_retry.toUpperCase());
-  //if (settings.enable_auto_retry.toUpperCase() == "TRUE") {
-  //  checkForWaitingMessages(dxcallsign);
-  //}
-}
-
-// function for handling a received message
-export function newMessageReceived(message, protocol) {
-  /*
-
-    PROTOCOL
-{
-    "freedata": "modem-message",
-    "arq": "transmission",
-    "status": "received",
-    "uuid": "5a3caa57-7feb-4436-853d-e341b085350f",
-    "percent": 100,
-    "bytesperminute": 206,
-    "compression": 0.5833333333333334,
-    "timestamp": 1697048385,
-    "finished": 0,
-    "mycallsign": "DJ2LS-0",
-    "dxcallsign": "DJ2LS-0",
-    "dxgrid": "------",
-    "data": "bTA7MTttc2cwOzE7MDsxOzBlNGE3YjQ2MDsxOzE2OTcwNDgzMTkwOzE7dGVzdDMwOzE7MDsxO3RleHQwOzE7",
-    "irs": "False",
-    "hmac_signed": "False",
-    "duration": 44.385897636413574,
-    "nacks": 1,
-    "speed_list": [
-        {
-            "snr": 0,
-            "bpm": 106,
-            "timestamp": 1697048362
-        },
-        {
-            "snr": -6,
-            "bpm": 104,
-            "timestamp": 1697048370
-        },
-        {
-            "snr": -6,
-            "bpm": 81,
-            "timestamp": 1697048370
-        },
-        {
-            "snr": -5.7,
-            "bpm": 161,
-            "timestamp": 1697048378
-        },
-        {
-            "snr": -5.7,
-            "bpm": 133,
-            "timestamp": 1697048379
-        },
-        {
-            "snr": -5.4,
-            "bpm": 206,
-            "timestamp": 1697048385
-        },
-        {
-            "snr": -5.8,
-            "bpm": 179,
-            "timestamp": 1697048391
-        }
-    ]
-}
-
-    MESSAGE; decoded from "data"
-    [
-    0 - protocol type message   -     "m",
-    1 - type             -     "msg",
-    2 - checksum     "",
-    3 - uuid -     "07e2",
-    4 - timestamp -    "1695203833",
-    5 - message      -    "test",
-    6 - file name    -   "",
-    7 - mime         -    "plain/text",
-    8 - file         -    ""
-    ]
-
-
-    */
-
-  console.log(protocol);
-
-  var encoded_data = atob_FD(message);
-  var splitted_data = encoded_data.split(split_char);
-
-  // new message received
-  if (splitted_data[0] == "m") {
-    console.log(splitted_data);
-    message = splitted_data;
-  } else {
-    return;
-  }
-
-  let newChatObj: messageDefaultObject = {
-    command: "msg",
-    hmac_signed: false,
-    percent: 100,
-    bytesperminute: 0,
-    is_new: true,
-    _id: message[3],
-    timestamp: message[4],
-    dxcallsign: protocol["dxcall"],
-    dxgrid: "",
-    msg: message[5],
-    checksum: message[2],
-    type: "received",
-    status: "received",
-    attempt: 1,
-    uuid: message[3],
-    duration: 0,
-    nacks: 0,
-    speed_list: "[]",
-    _attachments: {
-      [message[6]]: {
-        content_type: message[7],
-        data: btoa_FD(message[8]),
-      },
-    },
-  };
-
-  // some tweaks for broadcasts
-  if (protocol.fec == "broadcast") {
-    newChatObj.broadcast_sender = protocol["dxcallsign"];
-    newChatObj.type = "broadcast_received";
-  }
-
-  addObjToDatabase(newChatObj);
-}
-
-export function setStateFailed() {
-  state.arq_seconds_until_finish = 0;
-  state.arq_seconds_until_timeout = 180;
-  state.arq_seconds_until_timeout_percent = 100;
-}
-
-export function setStateSuccess() {
-  state.arq_seconds_until_finish = 0;
-  state.arq_seconds_until_timeout = 180;
-  state.arq_seconds_until_timeout_percent = 100;
-}
-
-export function requestMessageInfo(id) {
-  console.log(id);
-
-  chat.arq_speed_list_bpm = [];
-  chat.arq_speed_list_timestamp = [];
-  chat.arq_speed_list_snr = [];
-  //@ts-expect-error
-  chat.selectedMessageObject = [];
-
-  // id and uuid are the same
-  var data = getFromUnsortedChatListByUUID(id);
-  chat.selectedMessageObject = data;
-  console.log(data);
-  if (
-    typeof data["speed_list"] !== "undefined" &&
-    data["speed_list"].length > 0
-  ) {
-    prepareStatsDataForStore(data["speed_list"]);
-  } else {
-    prepareStatsDataForStore([{}]);
-  }
-
-  return;
-}
-
-// THis is a nearly duplicate of the same function in sock.js :-(
-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}]
-  console.log(data);
-  console.log();
-  var speed_listSize = 0;
-  if (typeof data == "undefined") {
-    speed_listSize = 0;
-  } else {
-    speed_listSize = data.length;
-  }
-
-  var speed_list_bpm = [];
-
-  for (let i = 0; i < speed_listSize; i++) {
-    speed_list_bpm.push(data[i].bpm);
-  }
-
-  var speed_list_timestamp = [];
-
-  for (let i = 0; i < speed_listSize; i++) {
-    let timestamp = data[i].timestamp * 1000;
-    let h = new Date(timestamp).getHours();
-    let m = new Date(timestamp).getMinutes();
-    let s = new Date(timestamp).getSeconds();
-    let time = h + ":" + m + ":" + s;
-    speed_list_timestamp.push(time);
-  }
-
-  var speed_list_snr = [];
-  for (let i = 0; i < speed_listSize; i++) {
-    let snr = NaN;
-    if (data[i].snr !== 0) {
-      snr = data[i].snr;
-    } else {
-      snr = NaN;
-    }
-    speed_list_snr.push(snr);
-  }
-
-  chat.arq_speed_list_bpm = speed_list_bpm;
-  chat.arq_speed_list_timestamp = speed_list_timestamp;
-  chat.arq_speed_list_snr = speed_list_snr;
-
-  return;
-}
-
-async function createIndex(myIndexFields) {
-  db.createIndex({
-    index: {
-      fields: myIndexFields,
-    },
-  }).catch((err) => {
-    console.log(err);
-  });
-}
-
-async function getFromDBByFilter(filter) {
-  /*
-USAGE:
-
-let filter = {
-    selector: {
-      dxcallsign: dxcall,
-      type: "transmit",
-      status: "failed",
-      //attempt: { $lt: parseInt(config.max_retry_attempts) }
-    },
-  }
-
-getFromDBByFilter(filter)
-  .then(result => {
-    console.log(result)
-  })
-  .catch(err => {
-    console.log(err)
-  });
-
-*/
-  return new Promise((resolve, reject) => {
-    return db
-      .find(filter)
-      .then((result) => {
-        //console.log(result);
-        resolve(result);
-      })
-      .catch((err) => {
-        console.log(err);
-        reject(err);
-      });
-  });
-}
-
-async function checkForWaitingMessages(dxcall) {
-  let filter = {
-    selector: {
-      dxcallsign: dxcall,
-      type: "transmit",
-      status: "failed",
-      //attempt: { $lt: parseInt(config.max_retry_attempts) }
-    },
-  };
-
-  getFromDBByFilter(filter)
-    .then((result) => {
-      let message =
-        // @ts-expect-error
-        "Found " + result.docs.length + " waiting messages for " + dxcall;
-
-      console.log(message);
-      displayToast("info", "bi bi-info-circle", message, 5000);
-      console.log(result);
-      // @ts-expect-error
-      console.log(result.docs);
-      // @ts-expect-error
-      console.log(result.docs.length);
-      // handle result
-      // @ts-expect-error
-      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
-        // @ts-expect-error
-        console.log(result.docs[0]);
-        //console.log(
-        //  "attempt: " +
-        //    result.docs[0].attempt +
-        //    "/" +
-        //    settings.max_retry_attempts,
-        //);
-        // @ts-expect-error
-        if (result.docs[0].attempt < settings.max_retry_attempts) {
-          console.log("repeating message...");
-          // @ts-expect-error
-          repeatMessageTransmission(result.docs[0].uuid);
-        }
-        return;
-      }
-    })
-    .catch((err) => {
-      console.log(err);
-    });
-}
-
-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;
-
-  let data_with_attachment =
-    obj.timestamp +
-    split_char +
-    obj.msg +
-    split_char +
-    filename +
-    split_char +
-    filetype +
-    split_char +
-    file;
-
-  let data = btoa_FD(
-    "m" +
-      split_char +
-      command +
-      split_char +
-      checksum +
-      split_char +
-      uuid +
-      split_char +
-      data_with_attachment,
-  );
-
-  let mycallsign =
-    settings.remote.STATION.mycall + "-" + settings.remote.STATION.myssid;
-  sendModemARQRaw(mycallsign, dxcallsign, data, uuid);
-}
diff --git a/gui/src/js/deprecated_sock.js b/gui/src/js/deprecated_sock.js
deleted file mode 100644
index 7cc2ae52..00000000
--- a/gui/src/js/deprecated_sock.js
+++ /dev/null
@@ -1,886 +0,0 @@
-var net = require("net");
-import { atob_FD, btoa_FD, sortByPropertyDesc } from "./freedata";
-import { addDataToWaterfall } from "../js/waterfallHandler.js";
-
-import {
-  newMessageReceived,
-  newBeaconReceived,
-  updateTransmissionStatus,
-  setStateSuccess,
-  setStateFailed,
-} from "./chatHandler";
-import { displayToast } from "./popupHandler";
-
-// ----------------- 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 { settingsStore as settings } from "../store/settingsStore.js";
-
-var client = new net.Socket();
-var socketchunk = ""; // Current message, per connection.
-
-// split character
-//const split_char = "\0;\1;";
-const split_char = "0;1;";
-
-// global to keep track of Modem connection error emissions
-var modemShowConnectStateError = 1;
-var setTxAudioLevelOnce = true;
-var setRxAudioLevelOnce = true;
-
-// network connection Timeout
-//setTimeout(connectModem, 2000);
-
-function connectModem() {
-  //exports.connectModem = function(){
-  //console.log('connecting to Modem...')
-
-  //clear message buffer after reconnecting or initial connection
-  socketchunk = "";
-
-  client.connect(settings.modem_port, settings.modem_host);
-}
-
-client.on("connect", function () {
-  console.log("Modem connection established");
-  stateStore.modem_running_state = "running";
-  stateStore.busy_state = "-";
-  stateStore.arq_state = "-";
-  stateStore.frequency = "-";
-  stateStore.mode = "-";
-  stateStore.bandwidth = "-";
-  stateStore.dbfs_level = 0;
-  stateStore.updateTncState(client.readyState);
-
-  modemShowConnectStateError = 1;
-});
-
-client.on("error", function (err) {
-  if (modemShowConnectStateError == 1) {
-    console.log("Modem connection error");
-    console.log(err);
-    modemShowConnectStateError = 0;
-    stateStore.modem_running_state = "stopped";
-  }
-
-  setTimeout(connectModem, 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(' Modem connection closed');
-    setTimeout(connectModem, 2000)
-});
-*/
-
-client.on("end", function (data) {
-  console.log("Modem connection ended");
-  console.log(data);
-  stateStore.busy_state = "-";
-  stateStore.arq_state = "-";
-  stateStore.frequency = "-";
-  stateStore.mode = "-";
-  stateStore.bandwidth = "-";
-  stateStore.dbfs_level = 0;
-  stateStore.updateTncState(client.readyState);
-  client.destroy();
-  stateStore.modem_running_state = "stopped";
-
-  setTimeout(connectModem, 500);
-});
-
-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("Modem SOCKET CONNECTION CLOSED!");
-  }
-
-  if (client.readyState == "opening") {
-    console.log("connecting to Modem...");
-  }
-}
-
-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 (let i = 0; i < socketchunk.length; i++) {
-      if (socketchunk[i] === "") {
-        socketchunk.splice(i, 1);
-      }
-    }
-
-    //iterate through socketchunks array to execute multiple commands in row
-    for (let 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;
-        }
-      }
-      //console.log(data)
-      if (data["command"] == "modem_state") {
-        //console.log(data)
-
-        stateStore.rx_buffer_length = data["rx_buffer_length"];
-        stateStore.frequency = data["frequency"];
-        stateStore.busy_state = data["modem_state"];
-        stateStore.arq_state = data["arq_state"];
-        stateStore.mode = data["mode"];
-        stateStore.bandwidth = data["bandwidth"];
-        stateStore.tx_audio_level = data["tx_audio_level"];
-        stateStore.rx_audio_level = data["rx_audio_level"];
-        // if audio level is different from config one, send new audio level to modem
-        //console.log(parseInt(stateStore.tx_audio_level))
-        //console.log(parseInt(settings.tx_audio_level))
-        if (
-          parseInt(stateStore.tx_audio_level) !==
-            parseInt(settings.tx_audio_level) &&
-          setTxAudioLevelOnce === true
-        ) {
-          setTxAudioLevelOnce = false;
-          console.log(setTxAudioLevelOnce);
-          setTxAudioLevel(settings.tx_audio_level);
-        }
-
-        if (
-          parseInt(stateStore.rx_audio_level) !==
-            parseInt(settings.rx_audio_level) &&
-          setRxAudioLevelOnce === true
-        ) {
-          setRxAudioLevelOnce = false;
-          console.log(setRxAudioLevelOnce);
-          setRxAudioLevel(settings.rx_audio_level);
-        }
-
-        stateStore.dbfs_level = data["audio_dbfs"];
-        stateStore.ptt_state = data["ptt_state"];
-        stateStore.speed_level = data["speed_level"];
-        stateStore.fft = JSON.parse(data["fft"]);
-        stateStore.channel_busy = data["channel_busy"];
-        stateStore.channel_busy_slot = data["channel_busy_slot"];
-
-        addDataToWaterfall(JSON.parse(data["fft"]));
-
-        if (data["scatter"].length > 0) {
-          stateStore.scatter = data["scatter"];
-        }
-        // s meter strength
-        stateStore.s_meter_strength_raw = data["strength"];
-        if (stateStore.s_meter_strength_raw == "") {
-          stateStore.s_meter_strength_raw = "Unsupported";
-          stateStore.s_meter_strength_percent = 0;
-        } else {
-          // https://www.moellerstudios.org/converting-amplitude-representations/
-          stateStore.s_meter_strength_percent = Math.round(
-            Math.pow(10, stateStore.s_meter_strength_raw / 20) * 100,
-          );
-        }
-
-        stateStore.dbfs_level_percent = Math.round(
-          Math.pow(10, stateStore.dbfs_level / 20) * 100,
-        );
-        stateStore.dbfs_level = Math.round(stateStore.dbfs_level);
-
-        stateStore.arq_total_bytes = data["total_bytes"];
-        stateStore.heard_stations = data["stations"].sort(
-          sortByPropertyDesc("timestamp"),
-        );
-        stateStore.dxcallsign = data["dxcallsign"];
-
-        stateStore.beacon_state = data["beacon_state"];
-        stateStore.audio_recording = data["audio_recording"];
-
-        stateStore.hamlib_status = data["hamlib_status"];
-        stateStore.alc = data["alc"];
-        stateStore.rf_level = data["rf_level"];
-
-        stateStore.is_codec2_traffic = data["is_codec2_traffic"];
-
-        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;
-
-        if (data["speed_list"].length > 0) {
-          prepareStatsDataForStore(data["speed_list"]);
-        }
-
-        // TODO: Remove ported objects
-        /*
-        let Data = {
-          mycallsign: data["mycallsign"],
-          mygrid: data["mygrid"],
-          //channel_state: data['CHANNEL_STATE'],
-
-          info: data["info"],
-          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_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 modem messages START -----------
-      //init message variable
-      var message = "";
-      if (data["freedata"] == "modem-message") {
-        // break early if we received a dummy callsign
-        // thats a kind of hotfix, as long as the modem isnt handling this better
-        if (
-          data["dxcallsign"] == "AA0AA-0" ||
-          data["dxcallsign"] == "ZZ9YY-0"
-        ) {
-          break;
-        }
-
-        console.log(data);
-
-        switch (data["fec"]) {
-          case "is_writing":
-            // RX'd FECiswriting
-            break;
-
-          case "broadcast":
-            // RX'd FEC BROADCAST
-            var encoded_data = 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);
-            }
-            break;
-        }
-
-        switch (data["cq"]) {
-          case "transmitting":
-            // CQ TRANSMITTING
-            displayToast(
-              "success",
-              "bi-arrow-left-right",
-              "Transmitting CQ",
-              5000,
-            );
-            break;
-
-          case "received":
-            // CQ RECEIVED
-            message = "CQ from " + data["dxcallsign"];
-            displayToast("success", "bi-person-arms-up", message, 5000);
-            break;
-        }
-
-        switch (data["qrv"]) {
-          case "transmitting":
-            // QRV TRANSMITTING
-            displayToast(
-              "info",
-              "bi-person-raised-hand",
-              "Transmitting QRV ",
-              5000,
-            );
-            break;
-
-          case "received":
-            // QRV RECEIVED
-            message = "QRV from " + data["dxcallsign"] + " | " + data["dxgrid"];
-            displayToast("success", "bi-person-raised-hand", message, 5000);
-            break;
-        }
-
-        switch (data["beacon"]) {
-          case "transmitting":
-            // BEACON TRANSMITTING
-            displayToast(
-              "success",
-              "bi-broadcast-pin",
-              "Transmitting beacon",
-              5000,
-            );
-            break;
-
-          case "received":
-            // BEACON RECEIVED
-            newBeaconReceived(data);
-
-            message =
-              "Beacon from " + data["dxcallsign"] + " | " + data["dxgrid"];
-            displayToast("info", "bi-broadcast", message, 5000);
-            break;
-        }
-
-        switch (data["ping"]) {
-          case "transmitting":
-            // PING TRANSMITTING
-            message = "Sending ping to " + data["dxcallsign"];
-            displayToast("success", "bi-arrow-right", message, 5000);
-            break;
-
-          case "received":
-            // PING RECEIVED
-            message =
-              "Ping request from " +
-              data["dxcallsign"] +
-              " | " +
-              data["dxgrid"];
-            displayToast("success", "bi-arrow-right-short", message, 5000);
-            break;
-
-          case "acknowledge":
-            // PING ACKNOWLEDGE
-            message =
-              "Received ping-ack from " +
-              data["dxcallsign"] +
-              " | " +
-              data["dxgrid"];
-            displayToast("success", "bi-arrow-left-right", message, 5000);
-            break;
-        }
-
-        // ARQ SESSION && freedata == modem-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 == modem-message
-        if (data["arq"] == "transmission") {
-          switch (data["status"]) {
-            case "opened":
-              // ARQ Open
-              message = "ARQ session opened: " + data["dxcallsign"];
-              displayToast("success", "bi-arrow-left-right", message, 5000);
-              break;
-
-            case "opening":
-              // ARQ Opening IRS/ISS
-              if (data["irs"] == "False") {
-                message = "ARQ session opening: " + data["dxcallsign"];
-                displayToast("info", "bi-arrow-left-right", message, 5000);
-                break;
-              } else {
-                message = "ARQ sesson request from: " + data["dxcallsign"];
-                displayToast("success", "bi-arrow-left-right", message, 5000);
-                break;
-              }
-
-            case "waiting":
-              // ARQ waiting
-              message = "Channel busy | ARQ protocol is waiting";
-              displayToast("warning", "bi-hourglass-split", message, 5000);
-              break;
-
-            case "receiving":
-              // ARQ RX
-              break;
-
-            case "failed":
-              // ARQ TX Failed
-              if (data["reason"] == "protocol version missmatch") {
-                message = "Protocol version mismatch!";
-                displayToast("danger", "bi-chevron-bar-expand", message, 5000);
-                setStateFailed();
-
-                break;
-              } else {
-                message = "Transmission failed";
-                displayToast("danger", "bi-x-octagon", message, 5000);
-                updateTransmissionStatus(data);
-                setStateFailed();
-                break;
-              }
-              switch (data["irs"]) {
-                case "True":
-                  updateTransmissionStatus(data);
-
-                  break;
-                default:
-                  updateTransmissionStatus(data);
-                  break;
-              }
-              break;
-
-            case "received":
-              // ARQ data received
-
-              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 = atob_FD(data["data"]);
-              var splitted_data = encoded_data.split(split_char);
-
-              // new message received
-              if (splitted_data[0] == "m") {
-                console.log(splitted_data);
-                newMessageReceived(splitted_data, data);
-              }
-
-              break;
-
-            case "transmitting":
-              // ARQ transmitting
-              updateTransmissionStatus(data);
-              break;
-
-            case "transmitted":
-              // ARQ transmitted
-              message = "Data transmitted";
-              displayToast("success", "bi-check-sqaure", message, 5000);
-              updateTransmissionStatus(data);
-              setStateSuccess();
-
-              break;
-          }
-        }
-      }
-    }
-
-    //finally delete message buffer
-    socketchunk = "";
-  }
-});
-
-// Send Ping
-//exports.sendPing = function (dxcallsign) {
-export function sendPing(dxcallsign) {
-  var command =
-    '{"type" : "ping", "command" : "ping", "dxcallsign" : "' +
-    dxcallsign +
-    '"}';
-  writeTncCommand(command);
-}
-
-// Send Mesh Ping
-//exports.sendMeshPing = function (dxcallsign) {
-function sendMeshPing(dxcallsign) {
-  var command =
-    '{"type" : "mesh", "command" : "ping", "dxcallsign" : "' +
-    dxcallsign +
-    '"}';
-  writeTncCommand(command);
-}
-
-// Send CQ
-//exports.sendCQ = function () {
-export function sendCQ() {
-  var command = '{"type" : "broadcast", "command" : "cqcqcq"}';
-  writeTncCommand(command);
-}
-
-// Set AUDIO Level
-export function setTxAudioLevel(value) {
-  var command =
-    '{"type" : "set", "command" : "tx_audio_level", "value" : "' + value + '"}';
-  writeTncCommand(command);
-}
-export function setRxAudioLevel(value) {
-  var command =
-    '{"type" : "set", "command" : "rx_audio_level", "value" : "' + value + '"}';
-  writeTncCommand(command);
-}
-
-// Send Message
-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(
-    "m" +
-      split_char +
-      command +
-      split_char +
-      checksum +
-      split_char +
-      uuid +
-      split_char +
-      data_with_attachment,
-  );
-
-  // TODO: REMOVE mode and frames from Modem!
-  var mode = 255;
-  var frames = 5;
-
-  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);
-}
-/*
-// Send Request message
-//It would be then „m + split + request + split + request-type“
-function sendRequest(dxcallsign, mode, frames, data, command) {
-  data = 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 = 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");
-}
-*/
-
-// Get RX BUffer
-export function getRxBuffer() {
-  var command = '{"type" : "get", "command" : "rx_buffer"}';
-
-  writeTncCommand(command);
-}
-
-// OPEN ARQ SESSION
-export function connectARQ(dxcallsign) {
-  var command =
-    '{"type" : "arq", "command" : "connect", "dxcallsign": "' +
-    dxcallsign +
-    '", "attempts": "10"}';
-  writeTncCommand(command);
-}
-
-// CLOSE ARQ SESSION
-export function disconnectARQ() {
-  var command = '{"type" : "arq", "command" : "disconnect"}';
-  writeTncCommand(command);
-}
-
-// SEND TEST FRAME
-export function sendTestFrame() {
-  var command = '{"type" : "set", "command" : "send_test_frame"}';
-  writeTncCommand(command);
-}
-
-// SEND FEC
-export function sendFEC(mode, payload) {
-  var command =
-    '{"type" : "fec", "command" : "transmit", "mode" : "' +
-    mode +
-    '", "payload" : "' +
-    payload +
-    '"}';
-  writeTncCommand(command);
-}
-
-// SEND FEC IS WRITING
-export function sendFecIsWriting(mycallsign) {
-  var command =
-    '{"type" : "fec", "command" : "transmit_is_writing", "mycallsign" : "' +
-    mycallsign +
-    '"}';
-  writeTncCommand(command);
-}
-
-// SEND FEC TO BROADCASTCHANNEL
-//export function sendBroadcastChannel(channel, data_out, uuid) {
-export function sendBroadcastChannel(obj) {
-  //let checksum = obj.checksum;
-  let command = obj.command;
-  let uuid = obj.uuid;
-  let channel = obj.dxcallsign;
-  let data_out = obj.msg;
-
-  let data = 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
-export function record_audio() {
-  var command = '{"type" : "set", "command" : "record_audio"}';
-  writeTncCommand(command);
-}
-
-// SET FREQUENCY
-export function set_frequency(frequency) {
-  var command =
-    '{"type" : "set", "command" : "frequency", "frequency": ' + frequency + "}";
-  writeTncCommand(command);
-}
-
-// SET MODE
-export function set_mode(mode) {
-  var command = '{"type" : "set", "command" : "mode", "mode": "' + mode + '"}';
-  writeTncCommand(command);
-}
-
-// SET rf_level
-export function set_rf_level(rf_level) {
-  var command =
-    '{"type" : "set", "command" : "rf_level", "rf_level": "' + rf_level + '"}';
-  writeTncCommand(command);
-}
-
-// https://stackoverflow.com/a/50579690
-// crc32 calculation
-//console.log(crc32('abc'));
-//console.log(crc32('abc').toString(16).toUpperCase()); // hex
-/*
-function crc32(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;
-};
-*/
-
-// TODO Maybe moving this to another module
-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}]
-
-  var speed_listSize = 0;
-  if (typeof data == "undefined") {
-    speed_listSize = 0;
-  } else {
-    speed_listSize = data.length;
-  }
-
-  var speed_list_bpm = [];
-
-  for (let i = 0; i < speed_listSize; i++) {
-    speed_list_bpm.push(data[i].bpm);
-  }
-
-  var speed_list_timestamp = [];
-
-  for (let i = 0; i < speed_listSize; i++) {
-    let timestamp = data[i].timestamp * 1000;
-    let h = new Date(timestamp).getHours();
-    let m = new Date(timestamp).getMinutes();
-    let s = new Date(timestamp).getSeconds();
-    let time = h + ":" + m + ":" + s;
-    speed_list_timestamp.push(time);
-  }
-
-  var speed_list_snr = [];
-  for (let i = 0; i < speed_listSize; i++) {
-    let snr = NaN;
-    if (data[i].snr !== 0) {
-      snr = data[i].snr;
-    } else {
-      snr = NaN;
-    }
-    speed_list_snr.push(snr);
-  }
-
-  stateStore.arq_speed_list_bpm = speed_list_bpm;
-  stateStore.arq_speed_list_timestamp = speed_list_timestamp;
-  stateStore.arq_speed_list_snr = speed_list_snr;
-}
diff --git a/gui/src/js/eventHandler.js b/gui/src/js/eventHandler.js
index 05f8c7b9..36de8961 100644
--- a/gui/src/js/eventHandler.js
+++ b/gui/src/js/eventHandler.js
@@ -1,3 +1,4 @@
+/*
 import {
   newMessageReceived,
   newBeaconReceived,
@@ -5,7 +6,10 @@ import {
   setStateSuccess,
   setStateFailed,
 } from "./chatHandler";
+*/
 import { displayToast } from "./popupHandler";
+import { getFreedataMessages } from "./api"
+import { processFreedataMessages } from "./messagesHandler.ts"
 
 // ----------------- init pinia stores -------------
 import { setActivePinia } from "pinia";
@@ -58,6 +62,14 @@ export function eventDispatcher(data) {
     return;
   }
 
+switch (data["message-db"]) {
+    case "changed":
+      console.log("fetching new messages...")
+      var messages = getFreedataMessages()
+      processFreedataMessages(messages)
+      return;
+  }
+
   switch (data["ptt"]) {
     case true:
     case false:
@@ -97,6 +109,9 @@ export function eventDispatcher(data) {
       message = "Connected to server";
       displayToast("success", "bi-ethernet", message, 5000);
       stateStore.modem_connection = "connected";
+
+      getFreedataMessages()
+
       return;
 
     case "arq":
diff --git a/gui/src/js/messagesHandler.ts b/gui/src/js/messagesHandler.ts
new file mode 100644
index 00000000..7088252a
--- /dev/null
+++ b/gui/src/js/messagesHandler.ts
@@ -0,0 +1,66 @@
+// pinia store setup
+import { setActivePinia } from "pinia";
+import pinia from "../store/index";
+setActivePinia(pinia);
+
+import { useChatStore } from "../store/chatStore.js";
+const chatStore = useChatStore(pinia);
+
+import { sendFreedataMessage } from "./api"
+
+interface Message {
+  id: string;
+  timestamp: string;
+  origin: string;
+  destination: string;
+  direction: string;
+  body: string;
+  attachments: any[];
+  status: any;
+  statistics: any;
+}
+
+
+export function processFreedataMessages(data){
+    let jsondata = JSON.parse(data);
+    chatStore.callsign_list = createCallsignListFromAPI(jsondata)
+    chatStore.sorted_chat_list = createSortedMessagesList(jsondata)
+}
+
+function createCallsignListFromAPI(data: { total_messages: number, messages: Message[] }): {[key: string]: {timestamp: string, body: string}} {
+  const callsignList: {[key: string]: {timestamp: string, body: string}} = {};
+
+  data.messages.forEach(message => {
+    let callsign = message.direction === 'receive' ? message.origin : message.destination;
+
+    if (!callsignList[callsign] || callsignList[callsign].timestamp < message.timestamp) {
+      callsignList[callsign] = { timestamp: message.timestamp, body: message.body };
+    }
+  });
+
+  return callsignList;
+}
+
+
+
+function createSortedMessagesList(data: { total_messages: number, messages: Message[] }): {[key: string]: Message[]} {
+  const callsignMessages: {[key: string]: Message[]} = {};
+
+  data.messages.forEach(message => {
+    let callsign = message.direction === 'receive' ? message.origin : message.destination;
+
+    if (!callsignMessages[callsign]) {
+      callsignMessages[callsign] = [];
+    }
+
+    callsignMessages[callsign].push(message);
+  });
+
+  return callsignMessages;
+}
+
+
+
+export function newMessage(dxcall, body){
+    sendFreedataMessage(dxcall, body)
+}
\ No newline at end of file
diff --git a/gui/src/store/chatStore.js b/gui/src/store/chatStore.js
index 1041f429..69261cf3 100644
--- a/gui/src/store/chatStore.js
+++ b/gui/src/store/chatStore.js
@@ -2,6 +2,16 @@ import { defineStore } from "pinia";
 import { ref } from "vue";
 
 export const useChatStore = defineStore("chatStore", () => {
+
+  var callsign_list = ref();
+  var sorted_chat_list = ref();
+  var newChatCallsign = ref();
+  var newChatMessage = ref();
+
+
+
+/* ------------------------------------------------ */
+
   var chat_filter = ref([
     { type: "newchat" },
     { type: "received" },
@@ -46,9 +56,6 @@ export const useChatStore = defineStore("chatStore", () => {
   var inputFileType = ref("-");
   var inputFileSize = ref("-");
 
-  var callsign_list = ref();
-  var sorted_chat_list = ref();
-  var unsorted_chat_list = ref([]);
 
   var sorted_beacon_list = ref({});
   var unsorted_beacon_list = ref({});
@@ -68,12 +75,13 @@ export const useChatStore = defineStore("chatStore", () => {
 
   return {
     selectedCallsign,
+    newChatCallsign,
+    newChatMessage,
     selectedMessageObject,
     inputText,
     chat_filter,
     callsign_list,
     sorted_chat_list,
-    unsorted_chat_list,
     inputFileName,
     inputFileSize,
     inputFileType,