Initial commit

2025-06-17 21:25:16 +02:00
commit e7a07a37b5
20 changed files with 900 additions and 0 deletions
@@ -0,0 +1,50 @@
+import pyotherside
+import threading
+import socket
+import re
+
+#     'ST:urn:schemas-upnp-org:device:MediaRenderer:1',
+
+
+def slow_function():
+    msg = "\r\n".join([
+        'M-SEARCH * HTTP/1.1',
+        'HOST:239.255.255.250:1900',
+        'MAN:"ssdp:discover"',
+        'ST:urn:schemas-upnp-org:device:MediaRenderer:1',
+        'MX:2',
+        '',
+        '',
+    ])
+
+    bytesmsg = msg.encode()
+    mr = "urn:schemas-upnp-org:device:MediaRenderer:1".encode()
+    # mr = ".".encode()
+    se = "(?P<url>https?://[^\s]+)".encode()
+    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
+    s.settimeout(3)
+    s.sendto(bytesmsg, ('239.255.255.250', 1900))
+
+    try:
+        while True:
+            data = s.recvfrom(65507)
+            for line in data:
+                if mr in line:
+                    url = re.search(se, line).group("url")
+                    pyotherside.send('progress', url)
+
+    except socket.timeout:
+        pyotherside.send('finished', "DONE")
+
+class Discoverer:
+    def __init__(self):
+        self.bgthread = threading.Thread()
+        self.bgthread.start()
+
+    def discover(self):
+        if self.bgthread.is_alive():
+            return
+        self.bgthread = threading.Thread(target=slow_function)
+        self.bgthread.start()
+
+discoverer = Discoverer()