console.py 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831
  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 = 10
  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 ) or self.init == 0:
  273. self.init = 1
  274. self._shuffle()
  275. #print( count)
  276. self.count=count
  277. idx = self.__data.index(child)
  278. offset = self.offsets[idx]
  279. return offset
  280. class FX():
  281. def __init__(self,xtype="sinus",size=10,speed=10,invert=0,width=100,start=0,offset=0,base="",clock=0,master=None):
  282. self.__xtype=xtype
  283. self.__size = size
  284. self.__start = start
  285. if width > 200:
  286. width = 200
  287. if width <= 0:
  288. width = 1
  289. self.__width = width
  290. self.__invert = invert
  291. self.__base = base
  292. self.__speed = speed
  293. self.__offset = offset
  294. self.__clock = clock
  295. self.__clock_curr = clock
  296. self.out = 0
  297. self.old_v = -1
  298. self.run = 1
  299. self.count = -1
  300. self.__angel = self.__clock_curr*360%360
  301. if master is None:
  302. cprint(master, "MASTER_FX ERR",master,color="red")
  303. self.__master = MASTER_FX()
  304. self.__master.add(self)
  305. else:
  306. cprint( "MASTER_FX OK",master,color="red")
  307. self.__master = master
  308. self.__master.add(self)
  309. if self.__xtype == "rnd":
  310. self.__offset = self.__master.get(self,-2)
  311. self.__offset = self.__master.next(self)#,count)
  312. print("init FX",self)
  313. def _get_info(self):
  314. print(self.__offset)
  315. return {"offset":self.__offset,"xtype":self.__xtype}
  316. #return self.next(),self.__xtype, self.__size,self.__speed,self.__angel, self.__base,self.__clock_curr,self.run
  317. def __str__(self):
  318. return self.__repr__()
  319. def __repr__(self):
  320. return "<FX Next:{:0.2f} xtype:{} Size:{:0.2f} Speed:{:0.2f} ang:{:0.2f} base:{} Clock:{:0.2f} run:{}>".format(
  321. self.next(),self.__xtype, self.__size,self.__speed,self.__angel, self.__base,self.__clock_curr,self.run )
  322. def next(self,clock=None):
  323. if type(clock) is float or type(clock) is int:#not None:
  324. self.__clock_curr = clock
  325. t = self.__clock_curr * self.__speed / 60
  326. t += self.__offset / 100 #255 #1024 #255
  327. t += self.__start / 1024 #255
  328. tw = t%1
  329. count = t//1
  330. t = t * (100/self.__width)
  331. if tw > self.__width/100:
  332. t = 1
  333. self.__angel = t%1*360
  334. t = t%1
  335. rad = math.radians(self.__angel)
  336. v=0
  337. out = 0
  338. base = 0
  339. size = self.__size
  340. if self.__base == "+": # add
  341. base = size/2
  342. elif self.__base == "-": # sub
  343. base = size/2*-1
  344. if self.__xtype == "sinus":
  345. v = math.sin( rad )
  346. v/=2
  347. elif self.__xtype == "cosinus":
  348. v = math.cos( rad )
  349. if self.__base == "+": # add
  350. size *= -1
  351. v/=2
  352. elif self.__xtype == "rnd":
  353. #base = 0
  354. if self.__angel > 90 and self.__angel <=270:
  355. v=1
  356. else:
  357. v=0
  358. #if count != self.count and v: # % 2 == 0:#!= self.count:
  359. # #self.__offset = random.randint(0,1024)# /1024
  360. # self.__master._shuffle()
  361. if count != self.count and v == 0: # and v: # % 2 == 0:#!= self.count:
  362. self.__master.next(self)#,count)
  363. #self.__master.next(self)#,count)
  364. self.__offset = self.__master.get(self,count)
  365. base = 0
  366. if self.__base == "-": # sub
  367. if self.__invert:
  368. v = 1-v
  369. #base = -size
  370. size *=-1
  371. v *=-1
  372. elif self.__base == "+": # sub
  373. if self.__invert:
  374. v = v-1
  375. else:
  376. v = (t%1-0.5)
  377. elif self.__xtype == "on":
  378. #base = 0
  379. if self.__angel > 90 and self.__angel <=270:
  380. v=1
  381. else:
  382. v=0
  383. base = 0
  384. if self.__base == "-": # sub
  385. if self.__invert:
  386. v = 1-v
  387. #base = -size
  388. size *=-1
  389. v *=-1
  390. elif self.__base == "+": # sub
  391. if self.__invert:
  392. v = v-1
  393. else:
  394. v = (t%1-0.5)
  395. elif self.__xtype == "bump":
  396. v = (t%1)
  397. base = 0
  398. if self.__base == "-": # sub
  399. if self.__invert:
  400. v = 1-v
  401. #base = -size
  402. size *=-1
  403. v *=-1
  404. elif self.__base == "+": # sub
  405. if self.__invert:
  406. v = v-1
  407. else:
  408. v = (t%1-0.5)
  409. elif self.__xtype == "bump2":
  410. v = (t%1)
  411. v = 1-v
  412. if v == 1:
  413. v=0
  414. base = 0
  415. if self.__base == "-": # sub
  416. if self.__invert:
  417. v = 1-v
  418. #base = -size
  419. size *=-1
  420. v *=-1
  421. elif self.__base == "+": # sub
  422. if self.__invert:
  423. v = v-1
  424. else:
  425. v = (t%1-0.5)
  426. elif self.__xtype == "fade":
  427. x = t * 2
  428. if x > 1:
  429. x = 2-x
  430. x -= 0.5
  431. v = x*2
  432. #base /= 2
  433. #base *=2
  434. if self.__base == "+": # add
  435. pass#base /= 2
  436. else:
  437. v *= -1
  438. v/=2
  439. if self.__invert:
  440. v *=-1
  441. out = v *size +base
  442. self.out = out
  443. self.count = count
  444. return out
  445. class DMXCH(object):
  446. def __init__(self):
  447. self._base_value = 0
  448. self._fade = None
  449. self._fx = None
  450. self._fx_value = 0
  451. self._flash = None
  452. self._flash_fx = None
  453. self._flash_fx_value = 0
  454. self._last_val = None
  455. def fade(self,target,ftime=0,clock=0,delay=0):
  456. if target != self._base_value:
  457. try:
  458. target = float(target)
  459. self._fade = Fade(self._base_value,target,ftime=ftime,clock=clock,delay=delay)
  460. #self._fade.next()
  461. #self._fade.next()
  462. except Exception as e:
  463. print( "Except:fade",e,target,ftime,clock)
  464. def fx(self,xtype="sinus",size=40,speed=40,invert=0,width=100,start=0,offset=0,base="", clock=0,master=None):
  465. print([self,xtype,size,speed,start,offset,base, clock])
  466. if str(xtype).lower() == "off":
  467. fx_value = self._fx_value
  468. if fx_value != 0:
  469. cprint("???????______ FX OFF AS FADE",fx_value,0,255)
  470. self._fx = Fade(fx_value,0,ftime=0.5,clock=clock)#,delay=delay)
  471. else:
  472. #self._fx = Fade(self._fx_value,target=0,ftime=2,clock=clock)
  473. self._fx = None
  474. self._fx_value = 0
  475. else:
  476. self._fx = FX(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=clock,master=master)
  477. def flash(self,target,ftime=0,clock=0,delay=0):
  478. if str(target).lower() == "off":
  479. self._flash = None
  480. else:#elif target != self._base_value:
  481. try:
  482. target = float(target)
  483. self._flash = Fade(self._last_val,target,ftime=ftime,clock=clock,delay=delay)
  484. except Exception as e:
  485. print( "Except:flash",target,ftime,clock,__name__,e,)
  486. def flash_fx(self,xtype="sinus",size=40,speed=40,invert=0,width=100,start=0,offset=0,base="",clock=0,master=None):
  487. #if self._flash_fx is not None :
  488. # cprint("flash_fx",xtype)
  489. if str(xtype).lower() == "off":
  490. fx_value = self._fx_value
  491. #if fx_value != 0:
  492. # cprint("???????______ FX OFF AS FADE",fx_value,0,255)
  493. # self._flash_fx = Fade(fx_value,0,ftime=0.5,clock=clock)#,delay=delay)
  494. # self._flash_fx = None
  495. #else:
  496. # self._flash_fx = None
  497. # self._flash_fx_value = 0
  498. self._flash_fx = None
  499. self._flash_fx_value = 0
  500. else:
  501. self._flash_fx = FX(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=clock,master=master)
  502. def fx_ctl(self,cmd=""):#start,stop,off
  503. pass
  504. def __str__(self):
  505. return self.__repr__()
  506. def __repr__(self):
  507. return "< DMXCH {:0.2f} > {} {}".format( self._last_val,self._fx,self._fade)
  508. def fade_ctl(self,cmd=""):#start,stop,backw,fwd,bounce
  509. pass
  510. def next(self,clock=0):
  511. value = self._base_value
  512. if self._last_val is None:
  513. self._last_val = value
  514. fx_value = self._fx_value
  515. if self._flash is not None:
  516. value = self._flash.next(clock)
  517. #flicker bug ?!
  518. value = self._flash.next(clock)
  519. fx_value = 0
  520. elif self._fade is not None:#is Fade:# is Fade:
  521. self._base_value = self._fade.next(clock)
  522. #flicker bug ?!
  523. self._base_value = self._fade.next(clock)
  524. value = self._base_value
  525. if self._flash_fx is not None:# is FX:
  526. fx_value = self._flash_fx.next(clock)
  527. elif self._fx is not None and self._flash is None:# is FX:
  528. self._fx_value = self._fx.next(clock)
  529. fx_value = self._fx_value
  530. self._last_val = value+fx_value
  531. return self._last_val
  532. Bdmx = []
  533. for i in range(512*3):
  534. Bdmx.append( DMXCH() )
  535. #print(type(dmx[i]))
  536. def split_cmd(data):
  537. if "cmd" in data:
  538. cmd = data["cmd"]
  539. #print("cmd",cmd)
  540. if "," in cmd:
  541. cmds = cmd.split(",")
  542. else:
  543. cmds = [cmd]
  544. return cmds
  545. import time
  546. import json
  547. import zlib
  548. def JCB(data): #json client input
  549. t_start = time.time()
  550. #jdatas = data["cmd"].split("\x00")
  551. jdatas = [data["cmd"]]
  552. c = clock.time()
  553. c = float(c)
  554. print("JCB",round(c,2))
  555. ftime = 0
  556. delay = 0
  557. for j in jdatas:
  558. master_fx = MASTER_FX()
  559. if not j:
  560. continue
  561. try:
  562. cprint("JCB",j)
  563. jdata = j #jdatas[j]
  564. jtxt = jdata
  565. #jtxt = zlib.decompress(jtxt) #jtxt.decode())
  566. jtxt = str(jtxt,"UTF-8")
  567. cmds = json.loads(jtxt)
  568. for x in cmds:
  569. #cprint(int(clock.time()*1000)/1000,end=" ",color="yellow")#time.time())
  570. #cprint("json", x,type(x),color="yellow")#,cmds[x])
  571. if "DMX" in x:
  572. DMX = int(x["DMX"])
  573. else:continue
  574. if DMX > 0:
  575. DMX -=1
  576. else:continue
  577. if "VALUE" in x:# and x["VALUE"] is not None:
  578. v = x["VALUE"]
  579. else:continue
  580. if "FX" in x:# and x["VALUE"] is not None:
  581. fx = x["FX"]
  582. else:fx=""
  583. if "FX2" in x:# and x["VALUE"] is not None:
  584. fx2 = x["FX2"]
  585. else:fx2={}
  586. if "FADE" in x:
  587. ftime = x["FADE"]
  588. else:ftime=0
  589. if "DELAY" in x:
  590. delay = x["DELAY"]
  591. else:delay=0
  592. if len(Bdmx) < DMX:
  593. continue
  594. if v is not None:
  595. if "FLASH" in x:
  596. #print("FLASH")
  597. Bdmx[DMX].flash(target=v,ftime=ftime, clock=c,delay=delay)
  598. else:
  599. #print("FADE")
  600. Bdmx[DMX].fade(target=v,ftime=ftime, clock=c,delay=delay)
  601. if type(fx2) is dict and fx2:
  602. #cprint("FX2",DMX,fx2,color="green")
  603. xtype="fade"
  604. size = 10
  605. speed = 10
  606. start = 0
  607. offset= 0
  608. width=100
  609. invert=0
  610. base = "-"
  611. if "TYPE" in fx2:
  612. xtype = fx2["TYPE"]
  613. if "SIZE" in fx2:
  614. size = fx2["SIZE"]
  615. if "SPEED" in fx2:
  616. speed = fx2["SPEED"]
  617. if "OFFSET" in fx2:
  618. offset = fx2["OFFSET"]
  619. if "BASE" in fx2:
  620. base = fx2["BASE"]
  621. if "INVERT" in fx2:
  622. invert = fx2["INVERT"]
  623. if "WIDTH" in fx2:
  624. width = fx2["WIDTH"]
  625. if "off" == x["VALUE"]: #fix fx flash off
  626. xtype= "off"
  627. if "alloff" == xtype.lower():
  628. for i in Bdmx:
  629. if i is not None:
  630. i.flash_fx(xtype="off",clock=c)
  631. i.fx(xtype="off",clock=c)
  632. if "FLASH" in x:
  633. 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)
  634. else:
  635. Bdmx[DMX].fx(xtype=xtype,size=size,speed=speed,invert=invert,width=width,start=start,offset=offset,base=base,clock=c,master=master_fx)
  636. elif type(fx) is str and fx: # old fx like sinus:200:12:244
  637. ccm = str(DMX+1)+":"+fx
  638. print("fx",ccm)
  639. if "FLASH" in x:
  640. CB({"cmd":"fxf"+ccm})
  641. else:
  642. CB({"cmd":"fx"+ccm})
  643. print(time.time()-t_start)
  644. print(time.time())
  645. return
  646. except Exception as e:
  647. cprint("EXCEPTION JCB",e,color="red")
  648. cprint("----",jdata,color="red")
  649. cprint("Error on line {}".format(sys.exc_info()[-1].tb_lineno),color="red")
  650. def CB(data): # raw/text client input
  651. #print("CB",data)
  652. cmds = split_cmd(data)
  653. c = clock.time()
  654. c = float(c)
  655. ftime = 0
  656. delay = 0
  657. for xcmd in cmds:
  658. if xcmd:
  659. cprint("CB",xcmd,end=" ")
  660. pass
  661. else:
  662. continue
  663. if xcmd.startswith("fxf"):
  664. xxcmd=xcmd[3:].split(":")
  665. #print("fxf:",xxcmd)
  666. if "alloff" == xxcmd[1].lower():
  667. for i in Bdmx:
  668. if i is not None:
  669. i.flash_fx(xtype="off",clock=c)
  670. l = xxcmd
  671. try:
  672. xtype=""
  673. size=40
  674. speed=100
  675. start=0
  676. offset=0
  677. base=""
  678. k=int(l[0])-1
  679. xtype=l[1]
  680. if len(l) >= 3:
  681. try:size=int(l[2])
  682. except:pass
  683. if len(l) >= 4:
  684. try:speed=int(l[3])
  685. except:pass
  686. if len(l) >= 5:
  687. try:start=int(l[4])
  688. except:pass
  689. if len(l) >= 6:
  690. try:offset=int(l[5])
  691. except:pass
  692. if len(l) >= 7:
  693. try:base=l[6]
  694. except:pass
  695. if len(Bdmx) > k:
  696. #Bdmx[k].fade(target=v,ftime=t, clock=c)
  697. Bdmx[k].flash_fx(xtype=xtype,size=size,speed=speed,start=start,offset=offset,base=base,clock=c)
  698. except Exception as e:
  699. print("EXCEPTION IN FX",e)
  700. print("Error on line {}".format(sys.exc_info()[-1].tb_lineno))
  701. elif xcmd.startswith("fx"):
  702. xxcmd=xcmd[2:].split(":")
  703. print("DMX:",xxcmd)
  704. if len(xxcmd) < 2:
  705. print("xxcmd err",xxcmd,xcmd)
  706. continue
  707. if "alloff" == xxcmd[1].lower():
  708. for i in Bdmx:
  709. i.fx(xtype="off",clock=c)
  710. l = xxcmd
  711. try:
  712. xtype=""
  713. size=40
  714. speed=100
  715. start=0
  716. offset=0
  717. base=""
  718. k=int(l[0])-1
  719. xtype=l[1]
  720. if len(l) >= 3:
  721. try:size=int(l[2])
  722. except:pass
  723. if len(l) >= 4:
  724. try:speed=int(l[3])
  725. except:pass
  726. if len(l) >= 5:
  727. try:start=int(l[4])
  728. except:pass
  729. if len(l) >= 6:
  730. try:offset=int(l[5])
  731. except:pass
  732. if len(l) >= 7:
  733. try:base=l[6]
  734. except:pass
  735. if len(Bdmx) > k:
  736. #Bdmx[k].fade(target=v,ftime=t, clock=c)
  737. Bdmx[k].fx(xtype=xtype,size=size,speed=speed,start=start,offset=offset,base=base,clock=c)
  738. except Exception as e:
  739. print("EXCEPTION IN FX",xcmd,e)
  740. print("Error on line {}".format(sys.exc_info()[-1].tb_lineno))
  741. #jchat = chat.CMD(CB,port=50001) # server listener
  742. #thread.start_new_thread(jchat.poll,())
  743. chat.cmd(JCB) # server listener
  744. #chat.cmd(JCB,port=50001) # server listener
  745. #input("END")