new lazy update (beta)

Client/client.py

@@ -94,6 +94,8 @@ class App:
         self.ccisdecryptpassword = None
         self.paudio = pyaudio.PyAudio()
         self.cprotocol = None
+        self.cciswaitlogoim = True
+        self.ccthreadlogorecisworking = False
 
     def connecttoserver(self, sender, data):
         dpg.configure_item("connectservergroup", show=False)
@@ -149,6 +151,8 @@ class App:
         self.ccisencrypt = None
         self.ccisdecrypt = None
         self.ccisdecryptpassword = None
+        self.cciswaitlogoim = True
+        self.ccthreadlogorecisworking = False
 
     def RDSshow(self):
         try:
@@ -160,11 +164,54 @@ class App:
             dpg.configure_item("RDSCTlocal", default_value="Time Local: " + datetime.fromtimestamp(self.RDS["CT"]["Local"]).strftime('%H:%M:%S'))
             dpg.configure_item("RDSCTUTC", default_value="Time UTC: " + datetime.fromtimestamp(self.RDS["CT"]["UTC"]).strftime('%H:%M:%S'))
             try:
-                dpg.set_value("station_logo", CV22DPG(
+                if self.RDS["images"]["logo"]["lazy"] and not self.ccthreadlogorecisworking:
-                    cv2.imdecode(np.frombuffer(self.RDS["images"]["logo"], np.uint8),
+                    if not self.RDS["images"]["logo"]["contents"] == b'':
-                                 cv2.IMREAD_COLOR)))
+                        print(self.RDS["images"]["logo"]["contents"] == b'',
-            except:
+                            self.RDS["images"]["logo"]["part"]["total"] == \
+                            self.RDS["images"]["logo"]["part"]["current"],
+                            self.RDS["images"]["logo"]["part"]["current"] > 0)
+                        self.ccthreadlogorecisworking = True
+                        logoreciveprocessingthread = threading.Thread(target=self.RDSlogorecivelazy)
+                        logoreciveprocessingthread.start()
+                else:
+                    if not self.RDS["images"]["logo"]["lazy"]:
+                        dpg.set_value("station_logo", CV22DPG(cv2.imdecode(np.frombuffer(self.RDS["images"]["logo"], np.uint8), cv2.IMREAD_COLOR)))
+            except Exception as e:
                 dpg.configure_item("station_logo_config", show=False)
+                print(e)
+
+        except Exception as e:
+            pass
+
+    def RDSlogorecivelazy(self):
+        try:
+            received_data = b""
+            received_data_current_past = b""
+            received_data_current = b""
+            try:
+                print(self.RDS["images"]["logo"]["part"]["current"], self.RDS["images"]["logo"]["part"]["total"])
+                while not self.RDS["images"]["logo"]["part"]["current"] == self.RDS["images"]["logo"]["part"]["total"]:
+                    currentprocess = self.RDS["images"]["logo"]["part"]["current"]
+                    totalprocess = self.RDS["images"]["logo"]["part"]["total"]
+
+                    received_data_current = self.RDS["images"]["logo"]["contents"]
+
+                    if received_data_current != received_data_current_past:
+                        print(received_data_current)
+                        received_data_current_past = received_data_current
+                        received_data += received_data_current
+
+                    dpg.configure_item("logostatus", color=(255, 255, 0), default_value=f"Receiving... ({currentprocess}/{totalprocess})")
+
+                dpg.set_value("station_logo", CV22DPG(cv2.imdecode(np.frombuffer(received_data_current, np.uint8), cv2.IMREAD_COLOR)))
+                dpg.configure_item("logostatus", color=(0, 255, 0), default_value=f"Received logo! waiting for new image...")
+                dpg.configure_item("station_logo_config", show=True)
+                self.ccthreadlogorecisworking = False
+            except Exception as e:
+                print("receive error", e)
+                dpg.configure_item("logostatus", color=(255, 0, 0), default_value=f"Receive logo error! waiting for new image...")
+                dpg.configure_item("station_logo_config", show=False)
+                self.ccthreadlogorecisworking = False
 
         except Exception as e:
             pass
@@ -297,9 +344,21 @@ class App:
                             dpg.configure_item("mediachannelselect", show=True, items=channel_info)
                         dpg.configure_item("morerdsbutton", show=True)
                         dpg.configure_item("serverinfobutton", show=True)
+                        dpg.configure_item("logostatus", show=True)
                         try:
-                            dpg.set_value("station_logo", CV22DPG(cv2.imdecode(np.frombuffer(datadecoded["channel"][self.readchannel]["RDS"]["images"]["logo"], np.uint8), cv2.IMREAD_COLOR)))
+                            if self.RDS["images"]["logo"]["lazy"] and not self.ccthreadlogorecisworking:
-                            dpg.configure_item("station_logo_config", show=True)
+                                if not self.RDS["images"]["logo"]["contents"] == b'' or \
+                                        self.RDS["images"]["logo"]["part"]["total"] == \
+                                        self.RDS["images"]["logo"]["part"]["current"] or \
+                                        self.RDS["images"]["logo"]["part"]["current"] > 0:
+                                    self.ccthreadlogorecisworking = True
+                                    logoreciveprocessingthread = threading.Thread(target=self.RDSlogorecivelazy)
+                                    logoreciveprocessingthread.start()
+                            else:
+                                if not self.RDS["images"]["logo"]["lazy"]:
+                                    dpg.set_value("station_logo", CV22DPG(
+                                        cv2.imdecode(np.frombuffer(self.RDS["images"]["logo"], np.uint8),
+                                                     cv2.IMREAD_COLOR)))
                         except:
                             dpg.configure_item("station_logo_config", show=False)
                         dpg.configure_item("disconnectbutton", show=True)
@@ -436,6 +495,7 @@ class App:
             dpg.add_combo([], label="Channel", tag="mediachannelselect", default_value="Main Channel", show=False, callback=self.changechannel)
             dpg.add_spacer()
             dpg.add_image("station_logo", show=False, tag="station_logo_config")
+            dpg.add_text("Logo not available", tag="logostatus", color=(255, 0, 0), show=False)
             dpg.add_text("", tag="RDSinfo", show=False)
             with dpg.child_window(tag="connectservergroup", label="Server", use_internal_label=True, height=130):
                 dpg.add_button(label="select server", tag="selectserverbutton")

Server/RDS.py

@@ -1,9 +1,7 @@
 import time
 from datetime import datetime
-
 import cv2
 import numpy as np
-
 from damp11113 import scrollTextBySteps
 
 
@@ -15,6 +13,28 @@ def encodelogoimage(path, quality=50):
     encoded_bytes = np.array(encoded_image).tobytes()
     return encoded_bytes
 
+def sendimagelazy(data, chunk_size, RDSimage, imagetype, delay=0.1):
+    if not RDSimage["images"][imagetype]["lazy"]:
+        RDSimage["images"][imagetype]["contents"] = data
+        return
+
+    # Break the data into chunks
+    chunks = [data[i:i + chunk_size] for i in range(0, len(data), chunk_size)]
+    total_chunks = len(chunks)
+    RDSimage["images"][imagetype]["part"]["total"] = total_chunks
+
+    # Send each chunk
+    for i, chunk in enumerate(chunks):
+        RDSimage["images"][imagetype]["contents"] = chunk
+        RDSimage["images"][imagetype]["part"]["current"] = i
+
+        print(f"[contentpart={chunk}, currentpart={i}, totalpart={total_chunks}]")
+        time.sleep(delay)
+
+    RDSimage["images"][imagetype]["contents"] = b''
+    RDSimage["images"][imagetype]["part"]["current"] = 0
+    RDSimage["images"][imagetype]["part"]["total"] = 0
+
 RDS = {
     "PS": "DPRadio",
     "RT": "Testing internet radio",
@@ -53,7 +73,14 @@ RDS = {
         "samplerates": 48000
     },
     "images": {
-        "logo": encodelogoimage(r"C:\Users\sansw\3D Objects\dpstream iptv logo.png")
+        "logo": {
+            "lazy": True,
+            'contents': b'',
+            "part": {
+                "current": 0,
+                "total": 0
+            }
+        }
     }
 }
 
@@ -120,10 +147,10 @@ def update_RDS_time():
 def update_RDS_images():
     global RDS
     while True:
-        RDS["images"]["logo"] = encodelogoimage(r"C:\Users\sansw\3D Objects\dpstream iptv logo.png", 25)
+        sendimagelazy(encodelogoimage(r"C:\Users\sansw\3D Objects\dpstream iptv logo.png", 25), 100, RDS, "logo")
         time.sleep(10)
-        RDS["images"]["logo"] = encodelogoimage(r"C:\Users\sansw\3D Objects\140702_hi-res-logo.jpg", 25)
+        sendimagelazy(encodelogoimage(r"C:\Users\sansw\3D Objects\140702_hi-res-logo.jpg", 25), 100, RDS, "logo")
         time.sleep(10)
-        RDS["images"]["logo"] = encodelogoimage(r"IDRBfavicon.jpg", 25)
+        sendimagelazy(encodelogoimage(r"IDRBfavicon.jpg", 25), 100, RDS, "logo")
         time.sleep(10)