Эх сурвалжийг харах

add dmx-input-api -> Editor

micha 2 жил өмнө
parent
commit
53c89165f9
3 өөрчлөгдсөн 174 нэмэгдсэн , 0 устгасан
  1. 50 0
      remote/client.py
  2. 79 0
      remote/fader_in.py
  3. 45 0
      remote/server.py

+ 50 - 0
remote/client.py

@@ -0,0 +1,50 @@
+import sys
+import os
+
+sys.path.append(os.getcwd() + '/..')
+import lib.zchat as chat
+
+#print("-----")
+
+#print(dir())
+#print("-----")
+#print(dir(chat))
+
+#def JCB(x):
+#    for i in x:
+#        print(i)
+#chat.cmd(JCB) # server listener
+#s = chat.Server(port=30001)
+#print("-----")
+#print(dir(s))
+#chat.cmd(port=30002)
+#jclient = s
+#
+#jclient = chat.tcp_sender()#port=50001)
+
+#import json
+
+#jtxt = {"hi":1}
+#jtxt = json.dumps(jtxt)
+#jtxt = bytes(jtxt,"ascii")
+#jclient.send( jtxt ) #b"\00 ")
+
+
+
+#sys.path.append(os.getcwd() + '/..')
+import time
+data = "hi"
+data = data.encode("utf-8")
+c = chat.Client(port=30002)
+client = c
+time.sleep(0.05)
+client.send(data)
+import time
+while 1:
+    try:
+        data = input("<")
+        data = bytes(data,"utf-8")
+        client.send(data)
+    except Exception as e:
+        print("Exc",e)
+    time.sleep(0.1)

+ 79 - 0
remote/fader_in.py

@@ -0,0 +1,79 @@
+import sys
+import os
+
+sys.path.append(os.getcwd() + '/..')
+import lib.zchat as chat
+
+
+#sys.path.append(os.getcwd() + '/..')
+import time
+data = "hi"
+data = data.encode("utf-8")
+c = chat.Client(port=30002)
+client = c
+time.sleep(0.05)
+client.send(data)
+import time
+#while 1:
+#    try:
+#        data = input("<")
+#        data = bytes(data,"utf-8")
+#        client.send(data)
+#    except Exception as e:
+#        print("Exc",e)
+#    time.sleep(0.1)
+
+
+
+
+import memcache
+mc = memcache.Client(['127.0.0.1:11211'], debug=0)
+
+mc.set("some_key", "Some value")
+value = mc.get("some_key")
+
+mc.set("another_key", 3)
+mc.delete("another_key")
+
+import time
+
+data = {}
+while 1:
+    send = 0
+    try:
+        x=mc.get("dmx-0")
+    except Exception as e:
+        print("exc", e)
+        time.sleep(1)
+    #print(dir(mc))
+
+    #if type(x) is None:
+    #    mc = memcache.Client(['127.0.0.1:11211'], debug=0)
+    #    time.sleep(1)
+    #    print("recon memcache")
+    #    continue
+
+
+    if type(x) is list and len(x) == 512: 
+        ch = 140
+        print(x[ch])
+        #data = input("<")
+
+        v = x[ch]
+        cmd="VAL: {} {}".format(ch,v)
+        if ch in data:
+            if data[ch] != cmd:
+                data[ch] = cmd
+                send = 1
+        else:
+            data[ch] = cmd
+            send = 1
+
+        if send:
+            _data = bytes(cmd,"utf-8")
+            client.send(_data)
+
+    time.sleep(0.01)
+
+
+

+ 45 - 0
remote/server.py

@@ -0,0 +1,45 @@
+import sys
+import os
+
+sys.path.append(os.getcwd() + '/..')
+import lib.zchat as chat
+
+print("-----")
+
+print(dir())
+print("-----+")
+print(dir(chat))
+import time
+def JCB(x):
+    for i in x:
+        v = x[i]
+        print(round(time.time(),0),"x",i,v)
+#chat.cmd(JCB) # server listener
+
+if 0:
+    s = chat.Server(port=30002)
+    #print("-----")
+    print(dir(s))
+    import time
+    while 1:
+        x = s.poll()
+        a = s.get_clients()
+        print(a)
+        #if x:
+        #    pass#
+        #
+        #print(time.time(),x)
+        time.sleep(0.1)
+#chat.cmd(port=30002) # SERVER
+chat.cmd(JCB,port=30002) # SERVER
+#jclient = s
+#
+#jclient = chat.tcp_sender()#port=50001)
+
+import json
+
+#jtxt = {"hi":1}
+#jtxt = json.dumps(jtxt)
+#jtxt = bytes(jtxt,"ascii")
+#jclient.send( jtxt ) #b"\00 ")
+