Use a UDP socket instead of a pipe in uecp_parse

1 files changed, 19 insertions, 7 deletions

diff --git a/uecpparse/uecp_parse.py b/uecpparse/uecp_parse.py
index d586252..b0d8822 100755
--- a/uecpparse/uecp_parse.py
+++ b/uecpparse/uecp_parse.py
@@ -24,12 +24,13 @@
 #    THE SOFTWARE.
 #
 #
-# A UECP decoder, reading from a file generated by
-# my patched VLC, from ancillary MP2 bytes in a MPEG-TS
+# A UECP decoder, reading from a UDP socket, receiving
+# data generated by my patched VLC, from ancillary MP2 bytes in a MPEG-TS
 #
 # Please refer to RDS UECP specification
 
 import sys
+import socket
 import struct
 import crc
 
@@ -62,7 +63,7 @@ uecp_mec_names = {
         0x2C: "SET_COMM_MODE"  } # Set communication mode for the encoder
 
 def usage():
-    print("Usage:\n{} <filename>".format(sys.argv[0]))
+    print("Usage:\n{} <port>".format(sys.argv[0]))
 
 if len(sys.argv) < 2:
     usage()
@@ -169,8 +170,6 @@ class UECP_Frame_Decoder():
 
         UECP_Message_Decoder(self.msg)
 
-in_fd = open(sys.argv[1], "r")
-
 uecp = UECP_Frame_Decoder()
 
 def parse_anc_bytes(anc_bytes):
@@ -186,8 +185,21 @@ def parse_anc_bytes(anc_bytes):
                 uecp.msg, uecp.crc, uecp.crc_calc, uecp.crc_ok))
             uecp = UECP_Frame_Decoder()
 
-for line_nr, line in enumerate(in_fd):
-    line_bytes = [int(i, 16) for i in line.split()]
+UDP_IP = "127.0.0.1"
+port = int(sys.argv[1])
+
+sock = socket.socket(socket.AF_INET, # Internet
+                     socket.SOCK_DGRAM) # UDP
+sock.bind((UDP_IP, port))
+
+
+while True:
+    data, addr = sock.recvfrom(1024)
+
+    if not data:
+        break
+
+    line_bytes = [int(i) for i in data]
 
     line_bytes.reverse()