1 files changed, 41 insertions, 5 deletions
diff --git a/src/gui/net.py b/src/gui/net.py
index 121cc76..820bc84 100644
--- a/src/gui/net.py
+++ b/src/gui/net.py
@@ -1,3 +1,4 @@
+import os
 import select
 import socket
 from urllib.parse import urlparse
@@ -12,19 +13,37 @@ class udpsource:
     """
     Creates an UDP listening socket
     """
-    def __init__(self, url, dtype, timeout=0.05):
+    def __init__(self, url, dtype, timeout=0.05, blocksize=1024):
         self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
         self.url = urlparse(url)
         self.dtype = dtype
         self.timeout = timeout
+        self.blocksize = blocksize
+
+        if self.url.scheme == "udp":
+            self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+        elif self.url.scheme == "file":
+            try:
+                os.unlink(self.url.path)
+            except OSError:
+                if os.path.exists(self.url.path):
+                    raise
+
+            self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
+        else:
+            raise NotImplemented
 
     def __del__(self):
         self.sock.close()
 
     def bind(self):
         self.sock.setblocking(False)
-        self.sock.bind((self.url.hostname, self.url.port))
-        # self.sock.listen()
+        if self.url.scheme == "udp":
+            self.sock.bind((self.url.hostname, self.url.port))
+        elif self.url.scheme == "file":
+            self.sock.bind(self.url.path)
+
+        # self.sock.listen(1)
 
     def read(self, nblocks):
         # TODO: run in a separate thread (it will be painful to implement)
@@ -33,8 +52,7 @@ class udpsource:
             return None
 
         # read from socket
-        blocksize = 1024 * 4
-        string = ready[0].recv(nblocks * blocksize).decode("ascii")
+        string = ready[0].recv(nblocks * self.blocksize).decode("ascii")
 
         # decode string, remove empty values
         chunks = filter(None, re.split(r"\[(.+?)\]", string))
@@ -55,6 +73,24 @@ class udpsource:
 
         return values
 
+class network_value(udpsource):
+    def __init__(self, url, dtype, refresh_func):
+        udpsource.__init__(self, url, dtype, blocksize=16)
+
+        self._refresh = refresh_func
+        self.value = None
+
+        self.bind()
+
+    def read(self):
+        return udpsource.read(self, 1)
+
+    def refresh(self):
+        self.value = self.read()
+        if self.value:
+            self._refresh(self.value)
+
+
 class network_plot(udpsource):
     """
     Wraps a udpsource while at the same time intefacing with DearPyGUI as a plot element.