From 43162ff476a14e61d7e08af30c76bffa6eb3d9eb Mon Sep 17 00:00:00 2001
From: DJ2LS <dj2ls@proton.me>
Date: Mon, 2 Oct 2023 09:50:52 +0200
Subject: [PATCH] first working attempt of updating chat message status

---
 gui_vue/src/js/chatHandler.js | 61 +++++++++++++++++++++++++++++++++--
 gui_vue/src/js/sock.js        |  7 +++-
 2 files changed, 64 insertions(+), 4 deletions(-)

diff --git a/gui_vue/src/js/chatHandler.js b/gui_vue/src/js/chatHandler.js
index 5373faaf..465d73ad 100644
--- a/gui_vue/src/js/chatHandler.js
+++ b/gui_vue/src/js/chatHandler.js
@@ -269,6 +269,59 @@ export function deleteMessageFromDB(id){
 
 }
 
+// function to update transmission status
+export function updateTransmissionStatus(obj){
+    console.log(obj.percent)
+    console.log(obj.uuid)
+    console.log(obj.status)
+
+    // update database entries
+    databaseUpsert(obj.uuid, "percent", obj.percent)
+    databaseUpsert(obj.uuid, "bytesperminute", obj.bytesperminute)
+
+    // update screen rendering / messages
+    updateUnsortedChatListEntry(obj.uuid, "percent", obj.percent)
+    updateUnsortedChatListEntry(obj.uuid, "bytesperminute", obj.bytesperminute)
+
+}
+
+export function updateUnsortedChatListEntry(uuid, object, value){
+
+    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
+
+}
+
+
+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() {
 
@@ -390,9 +443,12 @@ function addObjToDatabase(newobj){
               console.log(err);
             });
 
-            chat.unsorted_chat_list.push(newobj)
-            chat.sorted_chat_list = sortChatList()
 
+            console.log(newobj)
+            if(newobj.command === 'msg'){
+                chat.unsorted_chat_list.push(newobj)
+                chat.sorted_chat_list = sortChatList()
+            }
 
 /*
 // upsert footer ...
@@ -510,7 +566,6 @@ export function newBeaconReceived(obj){
 
     addObjToDatabase(newChatObj)
 
-
     console.log(obj)
 
 const jsonData = [obj]
diff --git a/gui_vue/src/js/sock.js b/gui_vue/src/js/sock.js
index db6cd413..e1cbda39 100644
--- a/gui_vue/src/js/sock.js
+++ b/gui_vue/src/js/sock.js
@@ -2,7 +2,7 @@ var net = require("net");
 const path = require("path");
 const FD = require("./src/js/freedata.js");
 //import FD from './freedata.js';
-import { newMessageReceived, newBeaconReceived } from './chatHandler.js';
+import { newMessageReceived, newBeaconReceived, updateTransmissionStatus } from './chatHandler.js';
 import {displayToast} from './popupHandler.js'
 
 // ----------------- init pinia stores -------------
@@ -258,6 +258,10 @@ client.on("data", function (socketdata) {
       //init message variable
       var message = ''
       if (data["freedata"] == "tnc-message") {
+
+      console.log(data);
+
+
         switch (data["fec"]) {
           case "is_writing":
             // RX'd FECiswriting
@@ -427,6 +431,7 @@ client.on("data", function (socketdata) {
 
             case "transmitting":
               // ARQ transmitting
+              updateTransmissionStatus(data)
               break;
 
             case "transmitted":