console.py 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828
  1. #! /usr/bin/python3
  2. # -*- coding: utf-8 -*-
  3. """
  4. This file is part of LibreLight.
  5. LibreLight is free software: you can redistribute it and/or modify
  6. it under the terms of the GNU General Public License as published by
  7. the Free Software Foundation, version 2 of the License.
  8. LibreLight is distributed in the hope that it will be useful,
  9. but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  11. GNU General Public License for more details.
  12. You should have received a copy of the GNU General Public License
  13. along with LibreLight. If not, see <http://www.gnu.org/licenses/>.
  14. (c) 2012 micha@uxsrv.de
  15. """
  16. import sys
  17. rnd_id = ""
  18. rnd_id += " Beta 22.02 "
  19. import subprocess
  20. rnd_id += subprocess.check_output(['git', 'rev-parse', '--short', 'HEAD']).decode('ascii').strip()
  21. if "__file__" in dir():
  22. sys.stdout.write("\x1b]2;"+str(__file__)+" "+rnd_id+"\x07") # terminal title
  23. else:
  24. sys.stdout.write("\x1b]2;"+str("__file__")+" "+rnd_if+"\x07") # terminal title
  25. import time
  26. import socket
  27. import struct
  28. import sys
  29. import random
  30. import math
  31. from collections import OrderedDict
  32. import lib.chat as chat
  33. import lib.ArtNetNode as ANN
  34. import _thread as thread
  35. #thread.start_new_thread
  36. import lib.motion as motion
  37. #idmx = [0]*512 # incremental dmx
  38. dmx = [0]*512 # absolute dmx data
  39. gcolor = 1
  40. def cprint(*text,color="blue",space=" ",end="\n"):
  41. #return 0 #disable print dbg
  42. if not gcolor:
  43. print(text)
  44. return 0
  45. if color == "green":
  46. txt = '\033[92m'
  47. elif color == "red":
  48. txt = '\033[0;31m\033[1m'
  49. elif color == "yellow":
  50. txt = '\033[93m\033[1m'
  51. elif color == "cyan":
  52. txt = '\033[96m'
  53. else:
  54. txt = '\033[94m'
  55. for t in text:
  56. txt += str(t ) +" "
  57. #HEADER = '\033[95m'
  58. #OKBLUE = '\033[94m'
  59. #OKCYAN = '\033[96m'
  60. #OKGREEN = '\033[92m'
  61. #WARNING = '\033[93m'
  62. #FAIL = '\033[91m'
  63. #ENDC = '\033[0m'
  64. #BOLD = '\033[1m'
  65. #UNDERLINE = '\033[4m'
  66. txt += '\033[0m'
  67. print(txt,end=end)
  68. #return txt
  69. def artnet_loop():
  70. #artnet = ANN.ArtNetNode(to="127.0.0.1",port=6555,univ=12)
  71. #artnet = ANN.ArtNetNode(to="127.0.0.1",port=6555,univ=0)
  72. artnet = ANN.ArtNetNode(to="10.10.10.255",univ=0)
  73. #artnet = ANN.ArtNetNode(to="2.0.0.255",univ=0)
  74. #artnet = ANN.ArtNetNode(to="10.10.10.255",univ=1)
  75. #dmx[205] = 255 #205 BLUE
  76. artnet.dmx= dmx #[0]*512
  77. artnet.send()
  78. while 1:
  79. #artnet._test_frame()
  80. artnet.next()
  81. time.sleep(0.01)
  82. class Main():
  83. def __init__(self):
  84. #artnet = ANN.ArtNetNode(to="127.0.0.1",port=6555,univ=12)
  85. #artnet = ANN.ArtNetNode(to="127.0.0.1",port=6555,univ=0)
  86. #artnet = ANN.ArtNetNode(to="2.0.0.255",univ=0)
  87. #artnet = ANN.ArtNetNode(to="10.10.10.255",univ=1)
  88. self.artnet = {}
  89. #self.artnet["0"] = ANN.ArtNetNode(to="10.10.10.255",univ=0)
  90. #self.artnet["0"].dmx[512-1] = 10
  91. #self.artnet["1"] = ANN.ArtNetNode(to="10.10.10.255",univ=1)
  92. #self.artnet["1"].dmx[512-1] = 11
  93. self.fx = {} # key is dmx address
  94. def loop(self):
  95. #dmx[205] = 255 #205 BLUE
  96. #self.artnet.send()
  97. xx = [0]*512
  98. #artnet = self.artnet["0"]
  99. #artnet.dmx = xx# [:] #dmx #[0]*512
  100. old_univ = -1
  101. while 1:
  102. t = clock.time()
  103. ii = 0
  104. for ii,dmxch in enumerate(Bdmx):
  105. i = ii%512
  106. univ = ii//512
  107. if str(univ) not in self.artnet:
  108. print("add uiv",univ)
  109. self.artnet[str(univ)] = ANN.ArtNetNode(to="10.10.10.255",univ=univ)
  110. self.artnet[str(univ)].dmx[512-1] = 100+univ
  111. if univ != old_univ:
  112. old_univ = univ
  113. #print("UNIV",ii/512)
  114. try:
  115. artnet.next()
  116. except:pass
  117. artnet = self.artnet[str(univ)]
  118. artnet.dmx = xx
  119. v = dmxch.next(t)
  120. if i == 0:
  121. #print(dmxch)
  122. if int(xx[i]*100) != int( v*100):
  123. #print("----v",x[i],v,t)
  124. pass
  125. #print("i:{:0.2f} xx:{:0.2f} v:{:0.2f} {:0.2f}----v {}".format(i,xx[i],v,t+100,dmxch))
  126. #print("i:{:0.2f} xx:{:0.2f} v:{:0.2f} {:0.2f}----v {}".format(i,xx[i],v,t+100,dmxch))
  127. xx[i] = int(v)
  128. try:
  129. artnet.next()
  130. except:pass
  131. time.sleep(0.01)
  132. main = Main()
  133. #thread.start_new_thread(artnet_loop,())
  134. thread.start_new_thread(main.loop,())
  135. class CLOCK():
  136. def __init__(self):
  137. self.__time = 0
  138. self.__start = time.time() # only for debugging
  139. self.__tick = 0.01 # incremental timer drift's on highe cpu load ?
  140. def time(self):
  141. return self.__time
  142. def get_drift(self):
  143. run_time = time.time() - self.__start
  144. tick_time = self.__time # * self.__tick
  145. print( "runtime:{:0.2f} tick_timer:{:0.2f} drift:{:0.2f}".format(run_time,tick_time,run_time-tick_time))
  146. def loop(self):
  147. while 1:
  148. self.__time +=self.__tick
  149. #if int(self.__time*100)/10. % 10 == 0:# self.__time % 2 == 0:
  150. # print( self.get_drift())
  151. #print(self.__time)
  152. #for i in range(10):
  153. time.sleep(self.__tick)
  154. class CLOCK_REAL():
  155. def __init__(self):
  156. self.__time = 0
  157. self.__start = time.time() # only for debugging
  158. self.__tick = 0.01 # incremental timer drift's on highe cpu load ?
  159. def time(self):
  160. self.__time = time.time()
  161. return self.__time
  162. def get_drift(self):
  163. run_time = time.time() - self.__start
  164. tick_time = self.__time # * self.__tick
  165. print( "runtime:{:0.2f} tick_timer:{:0.2f} drift:{:0.2f}".format(run_time,tick_time,run_time-tick_time))
  166. def loop(self):
  167. pass
  168. #clock = CLOCK()
  169. clock = CLOCK_REAL()
  170. thread.start_new_thread(clock.loop,())
  171. class Fade():
  172. def __init__(self,start,target,ftime,clock,delay=0):
  173. #print("init Fade ",start,target,ftime,clock)
  174. if delay < 0:
  175. delay = 0.0001
  176. if ftime <= 0:
  177. ftime = 0.0001
  178. clock += delay
  179. self.__delay = delay
  180. self.__clock = clock
  181. self.__clock_curr = clock
  182. self.__ftime = ftime
  183. self.__start = start
  184. self.__last = start
  185. self.__target = target
  186. self.run = 1
  187. #print("INIT", str(self) )
  188. def __str__(self):
  189. return self.__repr__()
  190. def __repr__(self):
  191. return "<Fade Next:{:0.2f} Start:{:0.2f} Target:{:0.2f} T{:0.2f} Clock:{:0.2f} run:{} delay:{:0.2f}>".format(
  192. self.__last, self.__start,self.__target,self.__ftime,self.__clock_curr,self.run,self.__delay )
  193. def next(self,clock=None):
  194. if self.__ftime <= 0 and self.__delay <= 0:
  195. self.__last = self.__target
  196. self.run = 0
  197. if type(clock) is float or type(clock) is int:#not None:
  198. self.__clock_curr = clock
  199. if self.__target > self.__start:
  200. if self.__last >= self.__target:
  201. self.run = 0
  202. return self.__target
  203. else:
  204. if self.__last <= self.__target:
  205. self.run = 0
  206. return self.__target
  207. current = (self.__clock - self.__clock_curr) / self.__ftime
  208. length = self.__start - self.__target
  209. self.__last = self.__start+ length*current
  210. #if self.__last < 0:
  211. # self.__last = 0
  212. #if self.__last > 255:
  213. # self.__last = 255
  214. self.run = 1
  215. return self.__last
  216. def ctl(self,cmd="",value=None): # if x-fade cmd="%" value=50
  217. # start,stop,fwd,bwd,revers
  218. pass
  219. class MASTER_FX():
  220. def __init__(self):
  221. cprint(self,"MASTER_FX INIT !",color="green")
  222. self.__data = []
  223. self.__ok = []
  224. self.i=0
  225. self.old_offsets = []
  226. self.offsets = []
  227. self.count = -1
  228. self.init = 0
  229. def add(self,fx):
  230. if fx not in self.__data:
  231. #cprint(self,"ADD TO MASTER !",color="green")
  232. self.__data.append(fx)
  233. info = fx._get_info()
  234. cprint(self,"ADD" ,info,color="green")
  235. offset = 0
  236. if "offset" in info:
  237. offset = info["offset"]
  238. self.old_offsets.append(offset)
  239. self.offsets.append(offset)
  240. if "xtype" in info:
  241. if info["xtype"] == "rnd":
  242. self._shuffle()
  243. #self.init += 1
  244. def _shuffle(self):
  245. #cprint(self,"REORDER RANDOM !",color="green")
  246. #self.init = 0
  247. #cprint(self.old_offsets)
  248. random.shuffle(self.old_offsets)
  249. #cprint(self.old_offsets)
  250. def _init(self):
  251. self._shuffle()
  252. #self.offsets = []
  253. for i,v in enumerate(self.old_offsets):
  254. offset = self.old_offsets[i]
  255. self.offsets[i] = offset
  256. self.init = 0
  257. def next(self,child):
  258. i = self.__data.index(child)
  259. offset = self.old_offsets[i]
  260. self.offsets[i] = offset
  261. return offset
  262. #for i,v in enumerate(self.old_offsets):
  263. # offset = self.old_offsets[i]
  264. # self.offsets[i] = offset
  265. def get(self,child,count):
  266. offset = 0
  267. if child not in self.__data:
  268. return offset
  269. if self.init:
  270. self._init()
  271. idx = self.__data.index(child)
  272. if self.count != count and idx == 0:
  273. self._shuffle()
  274. #print( count)
  275. self.count=count
  276. idx = self.__data.index(child)
  277. offset = self.offsets[idx]
  278. return offset
  279. class FX():
  280. def __init__(self,xtype="sinus",size=10,speed=10,invert=0,width=100,start=0,offset=0,base="",clock=0,master=None):
  281. self.__xtype=xtype
  282. self.__size = size
  283. self.__start = start
  284. if width > 200:
  285. width = 200
  286. if width <= 0:
  287. width = 1
  288. self.__width = width
  289. self.__invert = invert
  290. self.__base = base
  291. self.__speed = speed
  292. self.__offset = offset
  293. self.__clock = clock
  294. self.__clock_curr = clock
  295. self.out = 0
  296. self.old_v = -1
  297. self.run = 1
  298. self.count = -1
  299. self.__angel = self.__clock_curr*360%360
  300. if master is None:
  301. cprint(master, "MASTER_FX ERR",master,color="red")
  302. self.__master = MASTER_FX()
  303. self.__master.add(self)
  304. else:
  305. cprint( "MASTER_FX OK",master,color="red")
  306. self.__master = master
  307. self.__master.add(self)
  308. if self.__xtype == "rnd":
  309. self.__offset = self.__master.get(self,-2)
  310. self.__offset = self.__master.next(self)#,count)
  311. print("init FX",self)
  312. def _get_info(self):
  313. print(self.__offset)
  314. return {"offset":self.__offset,"xtype":self.__xtype}
  315. #return self.next(),self.__xtype, self.__size,self.__speed,self.__angel, self.__base,self.__clock_curr,self.run
  316. def __str__(self):
  317. return self.__repr__()
  318. def __repr__(self):
  319. return "<FX Next:{:0.2f} xtype:{} Size:{:0.2f} Speed:{:0.2f} ang:{:0.2f} base:{} Clock:{:0.2f} run:{}>".format(
  320. self.next(),self.__xtype, self.__size,self.__speed,self.__angel, self.__base,self.__clock_curr,self.run )
  321. def next(self,clock=None):
  322. if type(clock) is float or type(clock) is int:#not None:
  323. self.__clock_curr = clock
  324. t = self.__clock_curr * self.__speed / 60
  325. t += self.__offset / 100 #255 #1024 #255
  326. t += self.__start / 1024 #255
  327. tw = t%1
  328. count = t//1
  329. t = t * (100/self.__width)
  330. if tw > self.__width/100:
  331. t = 1
  332. self.__angel = t%1*360
  333. t = t%1
  334. rad = math.radians(self.__angel)
  335. v=0
  336. out = 0
  337. base = 0
  338. size = self.__size
  339. if self.__base == "+": # add
  340. base = size/2
  341. elif self.__base == "-": # sub
  342. base = size/2*-1
  343. if self.__xtype == "sinus":
  344. v = math.sin( rad )
  345. v/=2
  346. elif self.__xtype == "cosinus":
  347. v = math.cos( rad )
  348. if self.__base == "+": # add
  349. size *= -1
  350. v/=2
  351. elif self.__xtype == "rnd":
  352. #base = 0
  353. if self.__angel > 90 and self.__angel <=270:
  354. v=1
  355. else:
  356. v=0
  357. #if count != self.count and v: # % 2 == 0:#!= self.count:
  358. # #self.__offset = random.randint(0,1024)# /1024
  359. # self.__master._shuffle()
  360. if count != self.count and v == 0: # and v: # % 2 == 0:#!= self.count:
  361. self.__master.next(self)#,count)
  362. self.__offset = self.__master.get(self,count)
  363. base = 0
  364. if self.__base == "-": # sub
  365. if self.__invert:
  366. v = 1-v
  367. #base = -size
  368. size *=-1
  369. v *=-1
  370. elif self.__base == "+": # sub
  371. if self.__invert:
  372. v = v-1
  373. else:
  374. v = (t%1-0.5)
  375. elif self.__xtype == "on":
  376. #base = 0
  377. if self.__angel > 90 and self.__angel <=270:
  378. v=1
  379. else:
  380. v=0
  381. base = 0
  382. if self.__base == "-": # sub
  383. if self.__invert:
  384. v = 1-v
  385. #base = -size
  386. size *=-1
  387. v *=-1
  388. elif self.__base == "+": # sub
  389. if self.__invert:
  390. v = v-1
  391. else:
  392. v = (t%1-0.5)
  393. elif self.__xtype == "bump":
  394. v = (t%1)
  395. base = 0
  396. if self.__base == "-": # sub
  397. if self.__invert:
  398. v = 1-v
  399. #base = -size
  400. size *=-1
  401. v *=-1
  402. elif self.__base == "+": # sub
  403. if self.__invert:
  404. v = v-1
  405. else:
  406. v = (t%1-0.5)
  407. elif self.__xtype == "bump2":
  408. v = (t%1)
  409. v = 1-v
  410. if v == 1:
  411. v=0
  412. base = 0
  413. if self.__base == "-": # sub
  414. if self.__invert:
  415. v = 1-v
  416. #base = -size
  417. size *=-1
  418. v *=-1
  419. elif self.__base == "+": # sub
  420. if self.__invert:
  421. v = v-1
  422. else:
  423. v = (t%1-0.5)
  424. elif self.__xtype == "fade":
  425. x = t * 2
  426. if x > 1:
  427. x = 2-x
  428. x -= 0.5
  429. v = x*2
  430. #base /= 2
  431. #base *=2
  432. if self.__base == "+": # add
  433. pass#base /= 2
  434. else:
  435. v *= -1
  436. v/=2
  437. if self.__invert:
  438. v *=-1
  439. out = v *size +base
  440. self.out = out
  441. self.count = count
  442. return out
  443. class DMXCH(object):
  444. def __init__(self):
  445. self._base_value = 0
  446. self._fade = None
  447. self._fx = None
  448. self._fx_value = 0
  449. self._flash = None
  450. self._flash_fx = None
  451. self._flash_fx_value = 0
  452. self._last_val = None
  453. def fade(self,target,ftime=0,clock=0,delay=0):
  454. if target != self._base_value:
  455. try:
  456. target = float(target)
  457. self._fade = Fade(self._base_value,target,ftime=ftime,clock=clock,delay=delay)
  458. #self._fade.next()
  459. #self._fade.next()
  460. except Exception as e:
  461. print( "Except:fade",e,target,ftime,clock)
  462. def fx(self,xtype="sinus",size=40,speed=40,invert=0,width=100,start=0,offset=0,base="", clock=0,master=None):
  463. print([self,xtype,size,speed,start,offset,base, clock])
  464. if str(xtype).lower() == "off":
  465. fx_value = self._fx_value
  466. if fx_value != 0:
  467. cprint("???????______ FX OFF AS FADE",fx_value,0,255)
  468. self._fx = Fade(fx_value,0,ftime=0.5,clock=clock)#,delay=delay)
  469. else:
  470. #self._fx = Fade(self._fx_value,target=0,ftime=2,clock=clock)
  471. self._fx = None
  472. self._fx_value = 0
  473. else:
  474. self._fx = FX(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=clock,master=master)
  475. def flash(self,target,ftime=0,clock=0,delay=0):
  476. if str(target).lower() == "off":
  477. self._flash = None
  478. else:#elif target != self._base_value:
  479. try:
  480. target = float(target)
  481. self._flash = Fade(self._last_val,target,ftime=ftime,clock=clock,delay=delay)
  482. except Exception as e:
  483. print( "Except:flash",target,ftime,clock,__name__,e,)
  484. def flash_fx(self,xtype="sinus",size=40,speed=40,invert=0,width=100,start=0,offset=0,base="",clock=0,master=None):
  485. #if self._flash_fx is not None :
  486. # cprint("flash_fx",xtype)
  487. if str(xtype).lower() == "off":
  488. fx_value = self._fx_value
  489. #if fx_value != 0:
  490. # cprint("???????______ FX OFF AS FADE",fx_value,0,255)
  491. # self._flash_fx = Fade(fx_value,0,ftime=0.5,clock=clock)#,delay=delay)
  492. # self._flash_fx = None
  493. #else:
  494. # self._flash_fx = None
  495. # self._flash_fx_value = 0
  496. self._flash_fx = None
  497. self._flash_fx_value = 0
  498. else:
  499. self._flash_fx = FX(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=clock,master=master)
  500. def fx_ctl(self,cmd=""):#start,stop,off
  501. pass
  502. def __str__(self):
  503. return self.__repr__()
  504. def __repr__(self):
  505. return "< DMXCH {:0.2f} > {} {}".format( self._last_val,self._fx,self._fade)
  506. def fade_ctl(self,cmd=""):#start,stop,backw,fwd,bounce
  507. pass
  508. def next(self,clock=0):
  509. value = self._base_value
  510. if self._last_val is None:
  511. self._last_val = value
  512. fx_value = self._fx_value
  513. if self._flash is not None:
  514. value = self._flash.next(clock)
  515. #flicker bug ?!
  516. value = self._flash.next(clock)
  517. fx_value = 0
  518. elif self._fade is not None:#is Fade:# is Fade:
  519. self._base_value = self._fade.next(clock)
  520. #flicker bug ?!
  521. self._base_value = self._fade.next(clock)
  522. value = self._base_value
  523. if self._flash_fx is not None:# is FX:
  524. fx_value = self._flash_fx.next(clock)
  525. elif self._fx is not None and self._flash is None:# is FX:
  526. self._fx_value = self._fx.next(clock)
  527. fx_value = self._fx_value
  528. self._last_val = value+fx_value
  529. return self._last_val
  530. Bdmx = []
  531. for i in range(512*3):
  532. Bdmx.append( DMXCH() )
  533. #print(type(dmx[i]))
  534. def split_cmd(data):
  535. if "cmd" in data:
  536. cmd = data["cmd"]
  537. #print("cmd",cmd)
  538. if "," in cmd:
  539. cmds = cmd.split(",")
  540. else:
  541. cmds = [cmd]
  542. return cmds
  543. import time
  544. import json
  545. import zlib
  546. def JCB(data): #json client input
  547. t_start = time.time()
  548. #jdatas = data["cmd"].split("\x00")
  549. jdatas = [data["cmd"]]
  550. c = clock.time()
  551. c = float(c)
  552. print("JCB",round(c,2))
  553. ftime = 0
  554. delay = 0
  555. for j in jdatas:
  556. master_fx = MASTER_FX()
  557. if not j:
  558. continue
  559. try:
  560. cprint("JCB",j)
  561. jdata = j #jdatas[j]
  562. jtxt = jdata
  563. #jtxt = zlib.decompress(jtxt) #jtxt.decode())
  564. jtxt = str(jtxt,"UTF-8")
  565. cmds = json.loads(jtxt)
  566. for x in cmds:
  567. #cprint(int(clock.time()*1000)/1000,end=" ",color="yellow")#time.time())
  568. #cprint("json", x,type(x),color="yellow")#,cmds[x])
  569. if "DMX" in x:
  570. DMX = int(x["DMX"])
  571. else:continue
  572. if DMX > 0:
  573. DMX -=1
  574. else:continue
  575. if "VALUE" in x:# and x["VALUE"] is not None:
  576. v = x["VALUE"]
  577. else:continue
  578. if "FX" in x:# and x["VALUE"] is not None:
  579. fx = x["FX"]
  580. else:fx=""
  581. if "FX2" in x:# and x["VALUE"] is not None:
  582. fx2 = x["FX2"]
  583. else:fx2={}
  584. if "FADE" in x:
  585. ftime = x["FADE"]
  586. else:ftime=0
  587. if "DELAY" in x:
  588. delay = x["DELAY"]
  589. else:delay=0
  590. if len(Bdmx) < DMX:
  591. continue
  592. if v is not None:
  593. if "FLASH" in x:
  594. #print("FLASH")
  595. Bdmx[DMX].flash(target=v,ftime=ftime, clock=c,delay=delay)
  596. else:
  597. #print("FADE")
  598. Bdmx[DMX].fade(target=v,ftime=ftime, clock=c,delay=delay)
  599. if type(fx2) is dict and fx2:
  600. #cprint("FX2",DMX,fx2,color="green")
  601. xtype="fade"
  602. size = 10
  603. speed = 10
  604. start = 0
  605. offset= 0
  606. width=100
  607. invert=0
  608. base = "-"
  609. if "TYPE" in fx2:
  610. xtype = fx2["TYPE"]
  611. if "SIZE" in fx2:
  612. size = fx2["SIZE"]
  613. if "SPEED" in fx2:
  614. speed = fx2["SPEED"]
  615. if "OFFSET" in fx2:
  616. offset = fx2["OFFSET"]
  617. if "BASE" in fx2:
  618. base = fx2["BASE"]
  619. if "INVERT" in fx2:
  620. invert = fx2["INVERT"]
  621. if "WIDTH" in fx2:
  622. width = fx2["WIDTH"]
  623. if "off" == x["VALUE"]: #fix fx flash off
  624. xtype= "off"
  625. if "alloff" == xtype.lower():
  626. for i in Bdmx:
  627. if i is not None:
  628. i.flash_fx(xtype="off",clock=c)
  629. i.fx(xtype="off",clock=c)
  630. if "FLASH" in x:
  631. Bdmx[DMX].flash_fx(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=c,master=master_fx)
  632. else:
  633. Bdmx[DMX].fx(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=c,master=master_fx)
  634. elif type(fx) is str and fx: # old fx like sinus:200:12:244
  635. ccm = str(DMX+1)+":"+fx
  636. print("fx",ccm)
  637. if "FLASH" in x:
  638. CB({"cmd":"fxf"+ccm})
  639. else:
  640. CB({"cmd":"fx"+ccm})
  641. print(time.time()-t_start)
  642. print(time.time())
  643. return
  644. except Exception as e:
  645. cprint("EXCEPTION JCB",e,color="red")
  646. cprint("----",jdata,color="red")
  647. cprint("Error on line {}".format(sys.exc_info()[-1].tb_lineno),color="red")
  648. def CB(data): # raw/text client input
  649. #print("CB",data)
  650. cmds = split_cmd(data)
  651. c = clock.time()
  652. c = float(c)
  653. ftime = 0
  654. delay = 0
  655. for xcmd in cmds:
  656. if xcmd:
  657. cprint("CB",xcmd,end=" ")
  658. pass
  659. else:
  660. continue
  661. if xcmd.startswith("fxf"):
  662. xxcmd=xcmd[3:].split(":")
  663. #print("fxf:",xxcmd)
  664. if "alloff" == xxcmd[1].lower():
  665. for i in Bdmx:
  666. if i is not None:
  667. i.flash_fx(xtype="off",clock=c)
  668. l = xxcmd
  669. try:
  670. xtype=""
  671. size=40
  672. speed=100
  673. start=0
  674. offset=0
  675. base=""
  676. k=int(l[0])-1
  677. xtype=l[1]
  678. if len(l) >= 3:
  679. try:size=int(l[2])
  680. except:pass
  681. if len(l) >= 4:
  682. try:speed=int(l[3])
  683. except:pass
  684. if len(l) >= 5:
  685. try:start=int(l[4])
  686. except:pass
  687. if len(l) >= 6:
  688. try:offset=int(l[5])
  689. except:pass
  690. if len(l) >= 7:
  691. try:base=l[6]
  692. except:pass
  693. if len(Bdmx) > k:
  694. #Bdmx[k].fade(target=v,ftime=t, clock=c)
  695. Bdmx[k].flash_fx(xtype=xtype,size=size,speed=speed,start=start,offset=offset,base=base,clock=c)
  696. except Exception as e:
  697. print("EXCEPTION IN FX",e)
  698. print("Error on line {}".format(sys.exc_info()[-1].tb_lineno))
  699. elif xcmd.startswith("fx"):
  700. xxcmd=xcmd[2:].split(":")
  701. print("DMX:",xxcmd)
  702. if len(xxcmd) < 2:
  703. print("xxcmd err",xxcmd,xcmd)
  704. continue
  705. if "alloff" == xxcmd[1].lower():
  706. for i in Bdmx:
  707. i.fx(xtype="off",clock=c)
  708. l = xxcmd
  709. try:
  710. xtype=""
  711. size=40
  712. speed=100
  713. start=0
  714. offset=0
  715. base=""
  716. k=int(l[0])-1
  717. xtype=l[1]
  718. if len(l) >= 3:
  719. try:size=int(l[2])
  720. except:pass
  721. if len(l) >= 4:
  722. try:speed=int(l[3])
  723. except:pass
  724. if len(l) >= 5:
  725. try:start=int(l[4])
  726. except:pass
  727. if len(l) >= 6:
  728. try:offset=int(l[5])
  729. except:pass
  730. if len(l) >= 7:
  731. try:base=l[6]
  732. except:pass
  733. if len(Bdmx) > k:
  734. #Bdmx[k].fade(target=v,ftime=t, clock=c)
  735. Bdmx[k].fx(xtype=xtype,size=size,speed=speed,start=start,offset=offset,base=base,clock=c)
  736. except Exception as e:
  737. print("EXCEPTION IN FX",xcmd,e)
  738. print("Error on line {}".format(sys.exc_info()[-1].tb_lineno))
  739. #jchat = chat.CMD(CB,port=50001) # server listener
  740. #thread.start_new_thread(jchat.poll,())
  741. chat.cmd(JCB) # server listener
  742. #chat.cmd(JCB,port=50001) # server listener
  743. #input("END")