Xdesk/vpu/vpu_live4.py

#!/usr/bin/python3

import math
import random
import time
import os
import sys
import traceback
import gc

sys.path.insert(0,"/opt/LibreLight/Xdesk/")
from lib.cprint import cprint 

HOME = os.getenv('HOME')

import _thread as thread


from optparse import OptionParser
...
parser = OptionParser()
parser.add_option("-m", "--mode", dest="mode",
                  help="pixel mode pix,x,y --mode 40,10,8") #, metavar="FILE")

parser.add_option("-X", "--XX", dest="XX", #default=1,
                  help="x-split") #, metavar="FILE")

parser.add_option("-x", "--xx", dest="xsplit", #default=1,
                  help="x-split") #, metavar="FILE")
parser.add_option("-y", "--yy", dest="ysplit",#default=1,
                  help="y-split") #, metavar="FILE")

parser.add_option("", "--start-univ", dest="start_univ",default=2,
                  help="set start-univers default=2") #, metavar="FILE")

parser.add_option("", "--gobo-ch", dest="gobo_ch",default=0,
                  help="gobo ch univ on 1") #, metavar="FILE")

parser.add_option("", "--gobo-ch2", dest="gobo_ch2",default=0,
                  help="gobo ch univ on 1") #, metavar="FILE")

#os.environ['SDL_VIDEO_WINDOW_POS'] = '%i,%i' % (200,164)
parser.add_option("", "--win-pos", dest="win_pos",default="200,164",
                  help="SDL_VIDEO_WINDOW_POS --win-pos=200,164") #, metavar="FILE")

# PIXEL_MAPPING ... for gobo
parser.add_option("", "--pixel-mapping", dest="pixel_mapping",default=0,
                  help="pixel_mapping file/on --pixel-mapping=_x") #, metavar="FILE")

parser.add_option("", "--dual-vpu", dest="dual_vpu",default=0,
                  help=" --dual-vpu=1/0") #, metavar="FILE")


parser.add_option("", "--out-idim", dest="out_idim",default="",
                  help=" out_idim") #, metavar="FILE")


parser.add_option("", "--countdown", dest="countdown",#default=1,
                  help="enable countdown") #, metavar="FILE")

parser.add_option("", "--videoplayer", dest="videoplayer",#default=1,
              help="enable videoplayer") #, metavar="FILE")

parser.add_option("", "--title", dest="title",default="SCREEN",
              help="set title") #, metavar="FILE")


(options, args) = parser.parse_args()


import numpy
QUIT = 0

for o in dir(options):
    if "_" in o:
        continue
    print(o,options.__getattribute__(o))

START = time.time()

# ===== ARTNET DMX =========

import memcache
mc = memcache.Client(['127.0.0.1:11211'], debug=0)

def read_index():
    ips=mc.get("index")#cmd)
    if ips is None:
        ips = {}

    return ips

def select_ip(ips, univ=2): # artnet univ
    _univ = ":{}".format(univ)
    for ip in ips: #high priority
        if "2.0.0" in ip and _univ in ip:
            return ip

    for ip in ips:
        if "ltp-out" in ip and _univ in ip:
            return ip

INPUT_START_POS_X = 40
INPUT_START_POS_Y = 236 #320

FUNC = 0
COUNTER = []

if options.countdown:
    
    cdmx_start = options.countdown.split(",")
    for cdmx in cdmx_start:
        try:
            cdmx = int(cdmx)
            _tmp={"DMX":cdmx,"DIM":0,"PAN":127,"TILT":127
                    ,"CONTROL":0,"SEC":10
                    ,"RED":255,"GREEN":255,"BLUE":255
                    ,"_time":time.time(),"_RUN":0,"_pause":0,"_start":0
                    ,"_SEC":">{}<".format(cdmx)
                    }
            COUNTER.append(_tmp)
        except Exception as e:
            cprint("EXCEPTION COUNTER INIT ",cdmx,color="red")



def read_dmx(ip):
    r = ""
    if ip:
        #t = int(math.sin(time.time() - s)*10)
        r = mc.get(ip) #"2.0.0.13:2")
        rr = [0]*512
        for i,v in enumerate(r):
            try: #cleanup ltp-out to int
                v = int(v)
                rr[i] = v
            except:pass
        r = rr


    if not r:
        c = 0
        #time.sleep(0.1)
        r = [0] *512
        for i in range(12*8+1):
            dmx = i*4
            #print(dmx)
            r[dmx:dmx+4] = [255,10,10,40] 
    return r



# ===== ARTNET DMX =========

MEDIALIST = []
try:
    MEDIALIST = open_medialist()
except:pass


from tool.video_capture import scan_capture #as scan_capture


def _rescale_frame_by_width(frame, width):
    #print(type(frame)) #np array
    height = int(frame.shape[0]/frame.shape[1] * width )
    dim = (width, height)
    #return cv2.resize(frame, dim, interpolation =cv2.INTER_AREA)
    return cv2.resize(frame, dim, interpolation =cv2.INTER_LINEAR)

def _rescale_frame_by_procent(frame, percent=75):
    #print(type(frame))
    width  = int(frame.shape[1] * percent/ 100)
    height = int(frame.shape[0] * percent/ 100)
    dim = (width, height)
    return cv2.resize(frame, dim, interpolation =cv2.INTER_LINEAR)

def _moveImage(img,x=0,y=0,shape=None):
    #print(type(img)) #np.array
    # Creating a translation matrix
    np = numpy
    translation_matrix = np.float32([ [1,0,x], [0,1,y] ])
    
    if shape is None:
        num_cols,num_rows = img.shape[1::-1]
    else:
        num_cols,num_rows = shape #[1::-1]
    # Image translation
    frame = cv2.warpAffine(img, translation_matrix, (num_cols,num_rows))
    return frame

def _rotateImage(image, angle):
    #print(type(image)) # nm.array
    if angle in [0,360]:
        pass#return image
    try:
        #print("EE",image.shape)
        #print("EE",dir(image))
        shape = list(image.shape[1::-1])
        bg_shape = shape[:]

        delta_x = 0 # + nach rechts
        delta_y = 0 # + nach unten
        r = []
        r.extend(list(range(0-3,0+3)))
        r.extend(list(range(180-3,180+3)))
        r.extend(list(range(360-3,360+3)))

        r2 = []
        r2.extend(list(range(90-3,90+3)))
        r2.extend(list(range(270-3,270+3)))
        if angle in r:
            pass
        elif  0:#angle in r2:
            bg_shape = bg_shape[::-1]
            delta_y = -65 #shape[1]/2 # # + nach unten
            delta_x = 30 #shape[1]/2 # # + nach unten

            delta_y -= bg_shape[1]/2 - 20
            delta_x  = bg_shape[0]/2 - 10

            pass
        else:
            if shape[0] > shape[1]:
                # landscape video 
                bg_shape = (shape[0],shape[0])
                delta_y = (shape[0]-shape[1])/2
            else:
                # portrait video
                bg_shape = (shape[1],shape[1])
                delta_x = (shape[1]-shape[0])/2

        center  = (shape[0]/2+delta_x,shape[1]/2+delta_y)
        image = _moveImage(image,x=delta_x,y=delta_y,shape=bg_shape)

        bg_shape = tuple(bg_shape) # exception ... if angle 0 no tuple !!!
        rot_mat = cv2.getRotationMatrix2D(center,angle,1.0) 
        frame   = cv2.warpAffine(image, rot_mat,  bg_shape  ) #,flags=cv2.INTER_LINEAR)
        return frame
    except Exception as e:
        raise(e)

def calc_dim(dim=1,rgb=[255,255,255]):
    rgb[0] = int(rgb[0]*dim/255)  
    rgb[1] = int(rgb[1]*dim/255)  
    rgb[2] = int(rgb[2]*dim/255)  
    return rgb

def draw_media_background(wn,x,y,w,h,rgb):
    hx=int(w/2)
    hy=int(h/2)

    p1 = [x-hx ,y-hy] # links oben
    p2 = [x+hx ,y+hy] # recht unten
    p3 = [x+hx ,y-hy] # rechts oben
    p4 = [x-hx ,y+hy] # links unten

    bg_on=0
    if bg_on:
        #pygame.draw.rect(wn,rgb    ,[p1[0]  ,p1[1]  ,__xw  ,__yw])
        #pygame.draw.rect(wn,[25,20,20],[p1[0]+1,p1[1]+1,hx-2,hx-2])
        pass

    # frame border
    pygame.draw.line(wn,rgb ,p1  ,p3) # top
    pygame.draw.line(wn,rgb ,p2  ,p3) # right
    pygame.draw.line(wn,rgb ,p2  ,p4) # bottom
    pygame.draw.line(wn,rgb ,p1  ,p4) # right

    # cross lines
    pygame.draw.line(wn,rgb ,p1  ,p2) # tl - br
    pygame.draw.line(wn,rgb ,p3  ,p4) # tr - bl



class MediaImg():
    def __init__(self):
        pass

class MediaCam():
    def __init__(self):
        pass

    def draw(self,wn,im,x,y):
        w2 = int(im.get_width()/2)
        h2 = int(im.get_height()/2)
        wn.blit(im, (int(x-w2), int(y-h2)))  # draw frame

    def _open_cam(self,obj):
        # LIVE VIDEO INPUT UVC DEVICE
        cfg = self._cam_cfg()
        print("III",cfg)

        res = "HD"
        #res = "4K"
        #res = ""

        if res == "HD":
            # HD
            w = 1920
            h = 1080
        elif res == "4K":
            # 4K
            w = 3840
            h = 2160
        else:

            # LOW
            w = 1280
            h = 720
        d = 0 # VIDEO INPUT DEV 

        for c in cfg:
            try:
                if c.startswith("d"):
                    d = int(c[1:])
                if c.startswith("h"):
                    h = int(c[1:])
                if c.startswith("w"):
                    w = int(c[1:])
                if c.startswith("video"):
                    d = int(c[-1])
            except Exception as e:
                cprint("Exception", "cam_cfg 878",e,color="red")

        df = "video{}".format(d)
        if obj._stop:
            df += "_stop"
        elif os.path.exists("/dev/{}".format(df)):
            obj.Rcap = cv2.VideoCapture(d)
            obj.Rcap.set(cv2.CAP_PROP_FRAME_WIDTH, w)
            obj.Rcap.set(cv2.CAP_PROP_FRAME_HEIGHT, h)
        else:
            #obj.Rcap = None
            #obj.end = 1
            df += "_error"

        if obj.fname.startswith("cam_"): 
            obj.fname = "cam_{}".format(df)

    def _cam_cfg(self):
        fn = HOME+'/LibreLight/video_in.txt'
        if not os.path.isfile(fn):
            self._cam_cfg_new(fn)
        f = open(fn ,"r")
        lines = f.readlines()
        f.close()
        cfg = ""
        for i in lines:
            if i.startswith("d"):
                cfg = i
        cfg = cfg.split()
        capture = scan_capture(name="MiraBox",serial="")
        #capture = scan_capture(name="Integrated",serial="")
        if capture:
            print("capture",capture)
            try:
                cfg.append(capture[0][0])
            except Exception as e:
                cprint("except 2992",e,color="red")
        else:
            cprint("---- ERROR NO VIDEO CAPTURE DEV - FOUND ----",color="red")
        print("_cam_cfg:",len(cfg),[cfg])
        
        return cfg


    def _cam_cfg_new(self,fn):
        #fn = HOME+'/LibreLight/video_in.txt'
        txt = [
            "# Example",
            "d0 w640 h480 # PAL",
            "d0 w800 h600 # SVGA",
            "d0 w960 h540 # 540p",
            "d0 w1024 h768 # XGA <---",
            "d0 w1280 h720 # 720p",
            "d0 w1440 h900  # WSXGA+",
            "d0 w1600 h900  # WSXGA - Laptop 16:9",
            "d0 w1920 h1080 # HD 1080p",
            "",
            "# config",
            "d0 w1024 h768 # XGA",
        ]
        f = open(fn ,"w")
        f.write("\n".join(txt))
        f.close()

class PixelMedia():

    def __init__(self,dmx=None,_id=None):
        global MEDIALIST

        self._id = _id
        self.fpath = HOME+'/Downloads/'
        self.fpath = HOME+'/LibreLight/video/'
        self.fname = '' #'bbb_sunflower_480x320.mp4'
        #self.fname = 'no-video.mp4'
        try:
            self.fname = MEDIALIST[0]
        except Exception as e:
            cprint("Exception set video from MEDIALIST 5543:",e,color="red")

        self.cam = MediaCam()
        self.img_meta = {}
        self.restart_t = time.time()
        self.fps = 0
        self.scale = 50 #%
        self.angle = 0 #%
        self.dmx=dmx
        if self._id >= 250:
            self.fname = "cam_"
        self.dim = 0
        self.x = 0
        self.y = 0
        self.init_count = 0
        self.cap = None
        self.shape = [200,200]  
        self.img = None
        self.success = 1
        self._run = 0
        self.end = 0
        self._media_nr = 0

        self._stop = 0 # fix buffer-overflow ... ?? opencv

        self.shape_x = 370
        self.shape_y = 235

        self.dmx_change = 0
        self.frame_change = 0
        self.init()


    def update_dmx(self,x,y,scale,angle,dim):
        if int(self.x*100) != int(x*100):
            self.x = x
            self.dmx_change = 1
        if int(self.y*100) != int(y*100):
            self.y = y
            self.dmx_change = 1
        if int(self.scale*100) != int(scale*100):
            self.scale = scale
            self.dmx_change = 1
        if int(self.angle*100) != int(angle*100):
            self.angle = angle
            self.dmx_change = 1
        if int(self.dim*100) != int(dim*100):
            self.dim = dim
            self.dmx_change = 1

    def __repr__(self):
        sizeof = int(sys.getsizeof(self.buffer)/8)
        return "< id:{} buf:{} run:{} fps:{} scale:{} name:{} {}kb>".format(
                id(self),len(self.buffer),self._run,self.fps,self.scale
                ,self.fname,sizeof
                )
    def restart(self):
        print(self,"reset()")
        self.pos = 0 
        self.restart_t = time.time()

    def init(self):
        print("---- ---- PixelMedia.init()",[self.fname,self._media_nr])
        #print(MEDIALIST)
        self.time = 0
        self.t_delta = 0 
        self.t_last  = time.time()
        self.im = None
        self.pos = 0
        self.buffer = []
        self._init()
        self.init_count = 1
        self.dmx_change = 0
        self.frame_change = 0

    def select_video(self,dmx_value):
        try:
            dmx_value = int(dmx_value/10)

            if self._media_nr != dmx_value:
                self._media_nr = dmx_value

                if self._media_nr >= 25:
                    self.fname = "cam_"
                    self.init()
                elif self._media_nr < len(MEDIALIST):
                    self.fname = str(MEDIALIST[self._media_nr])
                    self.init()
            #finally:pass
        except Exception as e:
            cprint("PixelMedia.select_video()",dmx_value,e,color="red")




    def _init(self):
        print(self)
        print("videoplayer.init()",self.fpath,self.fname)

        if not os.path.isfile(self.fpath+self.fname):
            print()
            cprint("video file does not exits !! >",self.fpath,self.fname,color="red")
            print()
            #exit()
    
        self.Rsuccess = 0

        if not cv2:
            return

        if self._stop:
            return


        if self.fname.endswith(".jpg"): 
            self.img_meta = create_img_meta()        

            if self.img_meta["fname"] == self.fname:
                return

            self.img_meta["_fpath"] = self.fpath
            self.img_meta["fname"] = self.fname

            img_open(self.img_meta)
            self.buffer = [1] #,2,3] 
            return # STOP

        if self.fname.startswith("cam_"): 
            self.cam._open_cam(obj=self)
            self.img_meta = {}
        else:
            self.Rcap = cv2.VideoCapture(self.fpath+self.fname, cv2.CAP_FFMPEG) 
            #FFMPEG malloc(): unsorted double linked list corrupted ... Abgebrochen
            self.img_meta = {}

        print("_init ?",self.Rcap)
        print("open ?" ,self.Rcap.isOpened())
        self.Rcap.read()

        #self.Rfvs = FileVideoStream(self.fpath+self.fname).start()
        self.Rsuccess = 1
        self.read()

    def _del(self):
        if self.img_meta:
            return
        self._stop = 1

        self.buffer = [] #.append(self.img)
        self.Rcap.release()
        self.Rcap.retrieve()

        self.Rcap = None
        self.cap = None
        del self.Rcap #.release()
        gc.collect()


    def read(self):
        if self.img_meta:
            return
        success = self.Rsuccess
        ok = 0
        if success and self.fname:
            cap = self.Rcap
            #fvs = self.Rfvs
            _break = 0

            try:
                success, img = cap.read()

                if not success:
                    self.Rcap.release()
                    self.Rcap.retrieve()
                    self.end = 1
                    #j = json.dumps(self.buffer) #.append(img)
                    #f = open("/tmp/buff")
                    #f.write(j)
                    #f.close()
                    return

                if self.fps == 0:
                    self.fps = cap.get(cv2.CAP_PROP_FPS)
                
                img = cv2.cvtColor(img, cv2.COLOR_BGR2RGB)
                if self.fname.startswith("cam_"): 
                    pass
                    #img = _rescale_frame_by_width(img, 1200)
                else:
                    img = _rescale_frame_by_width(img, 200)
                    #img = _rescale_frame_by_width(img, 1200)

                
                # store frame into buffer list
                if self.fname.startswith("cam_"): 
                    self.buffer = [ img ]
                else:
                    self.buffer.append(img)

                ok = 1
                if len(self.buffer) % 100 == 0:
                    _id = str(self.__repr__)[-5:-1]
                    print(_id,"video read",self.dmx,len(self.buffer),self.fname,"fps",self.fps,self.dim)

            except Exception as e:
                cprint("Exception","_init",self,e,end="",color="red")
        self.success = 1
        return ok


    def prev(self):
        self.pos -= 1
        if self.pos < 0:
            self.pos = len(self.buffer)-1
        if self.pos >= len(self.buffer):
            self.pos = len(self.buffer)-1
        self.im = self.buffer[int(self.pos)]

    def _rotateImage(self,image, angle):
        if self.img_meta:
            return
        return _rotateImage(image, angle)



    def pause(self):
        if self.img_meta:
            return
        #print("pause",self.t_last)
        t = time.time()
        self.t_delta = 0 
        self.t_last = t

    def next_frame(self):
        if self.img_meta:
            return
        #return 0
        
        if self._run and len(self.buffer) > 30:
            t = time.time()
            self.t_delta = t-self.t_last 
            self.pos += int(self.t_delta*self.fps)
            self.t_last = t
            #self.frame_change = 1
        else:
            self.pause()

        if self.restart_t > time.time()-0.5:
            # prevent flickerung by reset
            #self.pause()
            self.pos = 5
            pass

        # restart at the end
        if int(self.pos) >= len(self.buffer)-1:
            self.pos = 0 
        
        self.img = None
        if self.buffer:
            self._img = self.buffer[int(self.pos)]
            self.img = self._img

    def check_cv2_check(self):
        if not cv2:
            cprint("cv2 not importet ! no VIDEO support !",color="red")
            return 0
        return 1
    def next(self):
        if self.img_meta:
            self.next_frame()
            return
         
        try:
            self.next_frame()
            if self.img is None:
                return

            self.img = _rescale_frame_by_procent(self.img, percent=self.scale)
            
            # rotate frame BUG: x,y offset ??? !!!
            self.img = self._rotateImage(self.img, self.angle)
            self.shape = self.img.shape[1::-1]

            if len(self.buffer) % 100 == 0:
                _id = str(self.__repr__)[-5:-1]
                print("next",_id)

            # add DIMER to videplayer
            cv2.normalize(self.img, self.img, 0, self.dim, cv2.NORM_MINMAX) 
            
            img = self.img 
            if img is None:
                return 
            self.im = None
            self.im = pygame.image.frombuffer(img.tobytes(), self.shape, "RGB")

            #self.next_frame()

        except AttributeError as e:
            time.sleep(.05)
            #if self.init_count % 100 == 0:
            cprint("except 776",e,color="red")
            #self.init()
        except Exception as e:
            cprint("except 756",e,color="red")
            cprint(traceback.format_exc(),color="red")
            cprint(sys.exc_info()[2],color="red")
            cprint()

    def calc_im_size(self):
        try:
            xx ,yy = self.im.get_size()[:2]
            self.shape_x = xx
            self.shape_y = yy
        except AttributeError as e:
            pass


    def calc_zoom(self,xx,yy):
        if self.scale < 255*.05:
            self.scale = 255*0.05
        xx = int(xx*self.scale/255)
        yy = int(yy*self.scale/255)
        return xx,yy

    def draw_video(self,wn,im,x,y):
        w2 = int(im.get_width()/2)
        h2 = int(im.get_height()/2)
        wn.blit(im, (int(x-w2), int(y-h2))) # draw frame

    def draw_img(self,wn,img_meta):
        self.img_meta["pos"]   = [self.x,self.y]
        self.img_meta["scale"] = self.scale #= 50 #%
        self.img_meta["dim"]   = self.dim #255
        self.img_meta["ang"]   = self.angle # 0

        if 1: #self.is_change():
            im2 = self.img_meta["raw_img"]
            im2 = img_rescale(im2, percent=self.img_meta["scale"])
            # add DIMER to videplayer
            im2 = cv2.normalize(im2, im2, 0, self.img_meta["dim"], cv2.NORM_MINMAX) 

            self.img_meta["img"] = im2

        img_draw_raw(self.img_meta)
        self.change_reset()

    def is_change(self):
        #if self.frame_change or self.dmx_change:
        if self.frame_change or self.dmx_change:
            #if self.dmx_change:
            return True

    def change_reset(self):
        if self.frame_change:
            print("media frame change")
        if self.dmx_change:
            print("media dmx change")
        self.frame_change = 0
        self.dmx_change = 0

    def draw(self,wn=None):
        if self.img_meta:
            self.draw_img(wn,self.img_meta)
            return


        if self.dim <= 1:
            return

        self.calc_im_size()

        im = self.im

        x=self.x
        y=self.y

        #w,h = self.calc_zoom(x,y)
        w = self.shape_x 
        h = self.shape_y 

        if self.success and wn and im: 
            if self.fname.startswith("cam_"):
                self.cam.draw(wn,im,x,y)
            else:
                self.draw_video(wn,im,x,y)

        self.change_reset()

    def get_meta(self):
        out = {}
        mode="x"
        if self._run:
            mode = "run"
        else:
            mode = "pause"

        out["frames"] = len(self.buffer)
        out["mode"]  = mode
        out["fname"] = self.fname
        out["scale"] =self.scale
        out["fps"] = int(self.fps)
        out["pos"] = self.pos
        out["dim"] = self.dim
        out["run"] = self._run
        out["cur"] = 0
        if self.fps > 0: # check if div zerro
            out["cur"] = (self.pos/self.fps)
        out["x"]  = self.x
        out["y"]  = self.y
        out["id"] = self._id
        out["nr"] = self._media_nr
        out["pz"] = 0
        
        return out

    def _overlay_text(self):
        meta = self.get_meta()

        keys = ["fps","pos","frames","cur","pz","x","y","scale","dim"]
        _line = create_format_line(meta,keys)

        keys= ["id","nr","mode","fname"]
        _line2 = create_format_line(meta,keys)
        
        return [_line,_line2]


def create_format_line(meta,keys):
    _line = []
    for k in keys:
        v=meta.get(k,"-")
        _line.append(str(k))
        _line.append(":")
        if type(v) is float:
            _line.append("{:02f}".format(v))
        else:
            _line.append(str(v))
        _line.append(" ")
    _line = "".join(_line)
    return _line

PixelMedia = PixelMedia

VIDEO = []
videoplayer=[]            
cv2 = None
FileVideoStream = None

_vid = 0
if type(options.videoplayer) is str:
    try:
        import cv2
    except Exception as e:
        cprint("Except Import:",e,color="red")
    try:
        # faster video reading ... ???
        from imutils.video import FileVideoStream
    except Exception as e:
        cprint("Except Import:",e,color="red")

    max_videoplayer = 4
    dmx_start =  options.videoplayer.split(",")
    univ = 0
    for cdmx in dmx_start:
        if "." in cdmx:
            univ,cdmx=cdmx.split(".",1)

        if len(videoplayer) > max_videoplayer:
            print("-- videoplayer max count {} !! break".format(max_videoplayer))
            break
        print("-- videoplayer dmx:",cdmx)
        try:
            cdmx = int(cdmx)
            univ = int(univ)
            videoplayer.append( PixelMedia(cdmx,_id=_vid) )
            _vid += 1
            _tmp = {"DMX":cdmx,"UNIV":univ,"DIM":0,"PAN":127,"TILT":127
                    ,"CONTROL":0,"SEC":10,"VIDEO":"3"
                    ,"RED":255,"GREEN":255,"BLUE":255
                    ,"_time":time.time()
                    ,"_RUN":0,"_SEC":">{}<".format(cdmx)
                   }
            VIDEO.append(_tmp)
        except Exception as e:
            cprint("EXCEPTION COUNTER INIT ",cdmx,color="red")

def loop_videoplayer():
    while 1:
        _videoplayer = videoplayer[:]
        #print(".")
        ok = 0
        for i in _videoplayer: #.append( PixelMedia(cdmx,_id=_vid) )
            try:
                r = i.read() # read next frame from file
                if r:
                    ok = 1
            except Exception as e:
                cprint("EXCEPTION loop_videoplayer ",e,color="red")
                cprint(traceback.format_exc(),color="red")
                cprint(sys.exc_info()[2],color="red")
                cprint()

        if ok == 0:
            time.sleep(0.1)
        else:
            time.sleep(0.005)

        if QUIT:
            break

thread.start_new_thread(loop_videoplayer,())

p = 16
block = [p,p]
_x = 8
_y = 8


#HD = "0"
if options.mode:
    try:
        HD = options.mode
        p,_x,_y = HD.split(",")
        _x = int(_x)
        _y = int(_y)
        p = int(p)

        block = [p,p]
    except Exception as e:
        cprint( "Exc",options.mode,e,color="red")

# PARSE COMMANDLINE ARGUMENTS
CFG_IN    = {"name":"CFG_IN","x1":40,"y1":60,"x2":0,"y2":0 ,"w":0,"h":300}

# OUTPUT CFG INIT
CFG_OUT = []
out_idim = options.out_idim
if out_idim:
    out_idim = options.out_idim.split(",")
    x1 = 40
    for i,v in enumerate(out_idim):
        print("--out-idim",[i,v])
        _t={}
        try:
            v = int(v)
            _t  = {"name":"CFG_OUT{}".format(i+1),"x1":x1,"y1":60,"x2":0,"y2":0 ,"w":30,"h":30,"on":1,"DMX-CH":v}
            print(_t,v)
            CFG_OUT.append(_t)
            x1 += p*8
        except Exception as e:
            print("err",_t,color="red")
            print("err",e,color="red")

CFG_BLOCK = {"name":"CFG_BLOCK","size":16,"h-split":2,"v-split":2,"h-count":8,"v-count":8}

if _x < 1:
    _x = 1
if _y < 1:
    _y = 1

CFG_BLOCK["h-count"] = _x
CFG_BLOCK["v-count"] = _y # int(8*8/_x) #/_x+0.5) #_y
CFG_BLOCK["size"]    = p

print( [options.xsplit])
print( [options.ysplit])

try:
    if options.xsplit:
        CFG_BLOCK["h-split"] = int(options.xsplit)
    if options.ysplit:
        CFG_BLOCK["v-split"] = int(options.ysplit)
except Exception as e:
    cprint( "Exc",options.mode,e,color="red")


print("HD",CFG_BLOCK["h-split"],CFG_BLOCK["v-split"])
print("xy",_x,_y)
print("++++++++++++++++++", p,_x,_y)

_x2 = _x

try:
    if options.XX:
        pass#_x2 = int(options.XX)
except Exception as e:
    cprint( "Exc",options.mode,e,color="red")

print("_x2 , -X",_x2)
# ===== GUI =========
import pygame
import pygame.gfxdraw
import pygame.font
clock = pygame.time.Clock()

os.environ['SDL_VIDEO_WINDOW_POS'] = '%i,%i' % (200,164)
if options.win_pos:
    if "," in options.win_pos:
        win_pos = options.win_pos.split(",")
        try:
            WIN_POS = '%i,%i' % (int(win_pos[0]),int(win_pos[1]) )
            os.environ['SDL_VIDEO_WINDOW_POS'] = WIN_POS
        except Excetpion as e:
            cprint("win_pos",win_pos,e,color="red")


os.environ['SDL_VIDEO_CENTERED'] = '0'

pg = pygame
pygame.init()
pygame.mixer.quit()


f = pygame.font.get_fonts()
for i in f:
    if "mono" in i.lower():
        print(i)
    

font = pygame.font.SysFont("freemonobold",22)
font10 = pygame.font.SysFont("freemonobold",10)
font12 = pygame.font.SysFont("freemonobold",12)
font12l = pygame.font.SysFont("freemono",12)
font15 = pygame.font.SysFont("freemonobold",15)
font40 = pygame.font.SysFont("freemonobold",40)
font80 = pygame.font.SysFont("freemonobold",70)
#font = pygame.font.SysFont(None,30)

fr = font.render("hallo" ,1, (200,0,255))


def clean_path(path):
    _path = path[:]
    _path = _path.replace("/","-")
    _path = _path.replace(".","-")
    _path = _path.replace("\"","-")
    _path = _path.replace("'","-")
    return _path


PIXEL_MAPPING = 0
vpu_wall_conf_file = HOME+"/LibreLight/vpu_wall_conf.csv"

grid_file  = "/tmp/vpu_grid_hd.csv"
text_file  = HOME+"/LibreLight/vpu_text_hd.csv"
media_list = HOME+"/LibreLight/video/" #.format(path)

pm_wy = 0
if options.pixel_mapping:
    PIXEL_MAPPING = 1
    path = options.pixel_mapping
    path = clean_path(path)
    grid_file = HOME+"/LibreLight/vpu_grid_hd{}.csv".format(path)
    if options.dual_vpu:
        grid_file = HOME+"/LibreLight/vpu_grid_dual{}.csv".format(path)

    text_file = HOME+"/LibreLight/vpu_text_hd{}.csv".format(path)
    media_list = HOME+"/LibreLight/video/" #.format(path)

if not options.out_idim:    
    PIXEL_MAPPING = 0

print("  ",[options.pixel_mapping],"grid_file",grid_file)
#grid_file = HOME+"/LibreLight/vpu_grid_hd.csv"


MAIN_SIZE=(600,500)
try:
    if _x < 8 and PIXEL_MAPPING >= 1:
        wx = 30+30+block[0] * 8
        CFG_IN["w"] = CFG_BLOCK["size"] * 8
    else:
        wx = 30+30+block[0] * _x 

    wy = 40+40+block[1] * _y 

    if type(options.videoplayer) is str:
        wy += 150 # video medialist

    MAIN_SIZE=(wx,wy)

    if PIXEL_MAPPING >= 1:
        pm_wy = 11*p #+ p*3
        CFG_IN["y1"] += 11*p
        if options.dual_vpu:
            if wx < p*16+155:
                wx = p*16+155
        MAIN_SIZE=(wx,wy+pm_wy)

except Exception as e:
    cprint("Exception:",e,color="red")

CFG_IN["w"] = CFG_BLOCK["size"] * CFG_BLOCK["h-count"] 
CFG_IN["h"] = CFG_BLOCK["size"] * CFG_BLOCK["v-count"] 

for CFG_OUTx in CFG_OUT:
    CFG_OUTx["w"] = CFG_BLOCK["size"] * 8
    CFG_OUTx["h"] = CFG_BLOCK["size"] * 8


def CFG_CALC_P(CFG):
    CFG["x2"] = CFG["x1"]+CFG["w"]
    CFG["y2"] = CFG["y1"]+CFG["h"] 
    CFG["p1"] = [CFG["x1"] ,CFG["y1"]] 
    CFG["p2"] = [CFG["x2"] ,CFG["y2"]] 
    print("CFG",CFG)

# ?
#CFG_IN["w"] = int(CFG_BLOCK["v-count"]-2) * CFG_BLOCK["size"] 

CFG_CALC_P(CFG_IN)

for CFG_OUTx in CFG_OUT:
    CFG_CALC_P(CFG_OUTx)

print("CFG_BLOCK",CFG_BLOCK)
print()
print()
print()
print()
print()

window = pygame.display.set_mode(MAIN_SIZE,pg.RESIZABLE)#,32)#,pygame.FULLSCREEN) #x left->right ,y top-> bottom

pg.display.set_caption('LibreLight VPU-{}'.format(options.title))


class Fix():
    def __init__(self,_id,pos,block=[16,16],univ=0,dmx=0,ch=4):
        #print("Fix",_id)
        self._id = _id
        self.dmx = (_id-1) * ch +1 #dmx
        self.univ = univ
        self.ch  = ch
        self.pos = pos
        self.rgb = [0,0,0]
        self.block = block #[10,10]
        self.x = pos[0]
        self.y = pos[1]
        self._x = 0
        self._y = 0
        self.strobo = time.time()
        self.bmp = 250
        self.sub_fix = []
        
        sub_block =[block[0]/CFG_BLOCK["h-split"],block[1]/CFG_BLOCK["v-split"]] 
        if _id <= 0: #exit 
            return

        spalte = (_id-1)%_y +1
        zeile = int((_id-1)/_x2) #+1

        add_row = _x*CFG_BLOCK["h-split"]*CFG_BLOCK["v-split"]

        #zeile 1
        sid = (_id-1)*2  + zeile*CFG_BLOCK["h-split"]*_x2
        sid = sid+1
        sub_pos= [pos[0]*block[0],pos[1]*block[1]]
        sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
        self.sub_fix.append(sub_fix)

        sid = sid+1
        sub_pos= [pos[0]*block[0]+block[0]/2,pos[1]*block[1]]
        sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
        self.sub_fix.append(sub_fix)

        #zeile 2
        sid = (_id-1)*2+1 + _x2*CFG_BLOCK["h-split"]  + zeile*CFG_BLOCK["h-split"]*_x2 # int(add_row)
        sub_pos= [pos[0]*block[0],pos[1]*block[1]+block[1]/2]
        sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
        self.sub_fix.append(sub_fix)

        #sid = sid+1
        sid = sid+1   
        sub_pos= [pos[0]*block[0]+block[0]/2,pos[1]*block[1]+block[1]/2]
        sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
        self.sub_fix.append(sub_fix)

    def __repr__(self):
        return "<Fix: {} {} {} {}>".format(id(self),self.x,self.y,self.dmx)


    def calc(self,data):
        _rgb = [0,255,0]
        return _rgb

    def sub_calc(self,data):
        _rgb = [0,255,0]
        for sub_fix in self.sub_fix:
            sub_fix.block = self.block[:]
            _rgb = sub_fix.dmx_calc(data)
        return _rgb
        
    def _calc(self,a,b):
        A = (self.pos[0])*self.block[0]
        B = (self.pos[1])*self.block[1]
        C = self.block[0]-a
        D = self.block[1]-b
        return A,B,C,D

    def POS(self,x=None,y=None,a=0,b=0):
        if type(x) is int:
            self._x=x
        if type(y) is int:
            self._y=y

        A,B,C,D = self._calc(a,b)

        return [self._x+A,self._y+B,C,D]

    def XXXsubPOS(self,x=0,y=0,a=0,b=0):
        __out = []
        for sub_fix in self.sub_fix:
            __out.append( sub_fix.POS(x,y,a,b) )
        return __out 


class SubFix():
    def __init__(self,_id,pos,block=[16,16],univ=0,dmx=0,ch=4):
        #print("Fix",_id)
        self._id = _id
        self.dmx = (_id-1) * ch +1 #dmx
        self.univ = univ
        self.ch  = ch
        self.pos = pos
        self.rgb = [0,0,40]
        self.block = block #[10,10]
        self.x = pos[0]
        self.y = pos[1]
        self._x = 0
        self._y = 0
        self.strobo = time.time()
        self.bmp = 250

    def dmx_calc(self,data):
        #return [130,30,20]
        dmx_sub = [30]*10
        dmx = self.dmx -1
        _dmx_sub = []
        if self.dmx >= 0:
            dmx = rDMX(self.univ,self.dmx)-1
            if dmx+self.ch < len(data):
                _dmx_sub = data[dmx:dmx+self.ch]
        if _dmx_sub:
            dmx_sub = _dmx_sub
        dim = dmx_sub[0]/255

        r = dmx_sub[1]*dim
        g = dmx_sub[2]*dim
        b = dmx_sub[3]*dim

        r = int(r)
        g = int(g)
        b = int(b)
        self.rgb = [r,g,b]
        return self.rgb
     
    def _calc(self,a,b):
        A = (self.pos[0]) #+self.block[0]
        B = (self.pos[1]) #+self.block[1]
        C = self.block[0]-a
        D = self.block[1]-b
        return A,B,C,D

    def POS(self,x=None,y=None,a=0,b=0):
        if type(x) is int:
            self._x=x
        if type(y) is int:
            self._y=y

        A,B,C,D = self._calc(a,b)
        #if NR:
        #    C-=1
        #    D-=1
        return [int(self._x+A),int(self._y+B),int(C),int(D)]

class POINTER():
    def __init__(self):
        self.pos = [0,0,0,0]
        self.on = 0
        self.rgb = [0,100,10]
        self._x = 0
        self._y = 0
        self.x = 0
        self.y = 0
        self.fix = Fix(0 ,[999,999],[16,16],0,0,0)

    def row_move(self,x,y):
        self._x = x
        self._y = y

    def move(self,pos):
        self.pos = pos
        self.on = 1

    def cross(self,x,y):
        self.x = x
        self.y = y

    def draw(self,x,y):
        pos = self.pos[:]
        #print("draw",x,y,pos)
        pos[0] += x
        pos[1] += y
        fix_x= self.fix.x
        fix_y= self.fix.y +y

        if 0:# self.on:
            pygame.draw.rect(window,self.rgb,pos)
        
            # mouse grid posision
            fr = font15.render("{}/{}".format(fix_x+1,fix_y) ,1, (200,200,200))
            
            _nr = fix_y * _x + fix_x +1
            fr = font15.render("{:02}".format(_nr ) ,1, (200,200,200))

            window.blit(fr,(pos[0]+2,pos[1]+2 ))
            window.blit(fr,(130,1))

        if 1:# lupe / looking-glass / lens
            __t = 60
            f_x = CFG_IN["y2"]+5
            rgb=[255,0,0]
            pos=[400,400,160,160]
            pos=[400,f_x,160,160]
            #pos=[400,400,f_x,f_x]
            draw_box_frame(window,rgb,pos,offset=1)
            r_sub = grab(x=self._x-__t/2,y=self._y-__t/2,w=__t,h=__t)
            if r_sub:
                r_sub = pygame.transform.scale(r_sub,(160,160))
                if r_sub: # target
                    window.blit(r_sub, (400,f_x))
                    #pos=[400+40,400+40,80,80]
                    pos=[400+80,400+80,80,80]
                    pos=[400+80,f_x+80,80,80]
                    draw_box_frame(window,rgb,pos,offset=3)
                    draw_box_frame(window,rgb,pos,offset=2)
                    draw_box_frame(window,rgb,pos,offset=0)
                    draw_box_frame(window,rgb,pos,offset=1)

        # fix pos
        #txt=str(pos) #"[0, 0, 0, 0]"
        #fr = font15.render(txt ,1, (200,200,200))
        #window.blit(fr,(10,1))

        # pointer
        fr = font15.render("X:{:03}".format(self._x) ,1, (200,200,200))
        window.blit(fr,(10,30))
        fr = font15.render("Y:{:03}".format(self._y) ,1, (200,200,200))
        window.blit(fr,(10,40))

        if 1: #self._x > 30 and self._y > 230:
            # pointer
            _x = self._x-INPUT_START_POS_X
            _y = self._y-INPUT_START_POS_Y
            rgb = [200,200,200]
            if _x < 0:
                rgb = [200,0,0]
            fr = font40.render("X:{:03}".format(_x) ,1, rgb)
            f_x = CFG_IN["y2"]+8
            window.blit(fr,(100,f_x))
            rgb = [200,200,200]
            if _y < 0:
                rgb = [200,0,0]
            fr = font40.render("Y:{:03}".format(_y) ,1, rgb)
            window.blit(fr,(200,f_x))
        
        p=110

        # crosshair
        self.rgb = [0,0,200]
        pygame.draw.line(window,self.rgb, (self.x-p,self.y) , (self.x-2,self.y),2 ) 
        #pygame.draw.line(window,self.rgb, (self.x,self.y-p) , (self.x,self.y-2),2 ) 
        self.rgb = [0,100,200]
        pygame.draw.line(window,self.rgb, (self.x,self.y-p/3) , (self.x,self.y-2),2 ) 

        self.rgb = [0,200,0]
        pygame.draw.line(window,self.rgb, (self.x+2,self.y) , (self.x+p,self.y),2 ) 
        pygame.draw.line(window,self.rgb, (self.x,self.y+2) , (self.x,self.y+p),2 ) 
        self.rgb = [200,0,0]

pointer = POINTER()

NR = 0

running = True
def event():
    global NR,running
    for event in pygame.event.get(): 
        #print(event.dict)

        _button = None
        if "button" in event.dict:
             _button =  event.dict["button"]

        _state = None
        if "state" in event.dict:
            _state  = event.state 

        _key = None
        if "key" in event.dict:
            _key  = event.key 

        _pos = None
        if "pos" in event.dict:
            _pos  = event.pos 

        _type = None
        if "type" in event.dict:
            _type  = event.type 
        _type  = event.type 

        _mod = None
        if "mod" in event.dict:
            _mod  = event.mod 
        if 0:
            print( " ")
            print( "{:.02f}".format( time.time() - START ))
            print("button -",_button,end="\t| ")
            #print("state  -",_state)
            print("pos    -",_pos)
            print("type   -",_type, end="\t| ")
            print("key    -",_key)
            print("mod    -",_mod)

        try:
            if _type in [5,1025]:
                if _button == 1:
                    NR += 1
                    if NR > 1:
                        NR = 0
                if _button == 3:
                    NR -= 1
                    if NR < 0:
                        NR = 1

            if _pos:
                posA = _pos 
                fix = find_pix(_pos[0]-40,_pos[1]-60+pm_wy)
                if fix:
                    #pos = fix.POS(40,60+pm_wy) 
                    pos = fix.POS() #(CFG_IN["x1"],CFG_IN["y1"])#0,0) #+pm_wy) 
                    rgb = [0,0,0] 
                    pointer.move(pos) 
                    pointer.fix  = fix
                else:
                    pointer.on = 0
                pointer.row_move(_pos[0],_pos[1]) 
                pointer.cross(_pos[0],_pos[1])

            if event.type == pygame.VIDEORESIZE:
                 window = pygame.display.set_mode((event.w, event.h), pygame.RESIZABLE)
        except Exception as e:
            cprint(e,color="red")

        if event.type==pygame.QUIT: 
            global QUIT
            QUIT = 1
            cprint("QUIT",color="red")
            running=False
            #time.sleep(1)
            #sys.exit()


fps = 0
fps2 = 0
frame = 0
frame2 = 0
frame_t = time.time()
frame2_t = time.time()
IP = "yyy"

vplay=[]
vplay1=0
vplay2=0
if options.videoplayer:
    try:
        t=options.videoplayer.split(",")
        vplay=t
        vplay1=t[0]
        vplay2=t[1]
    except:pass


def output_mask(): # oben
    RGB = [0,0,50]
    #RGB = [120,0,0] # test
    start = 0

    # oben  
    pygame.draw.rect(window,RGB,[0,start,MAIN_SIZE[0]+200,57]) # background
    # unten
    pygame.draw.rect(window,RGB,[0,start+192,MAIN_SIZE[0]+200,35]) # background
    # links 
    pygame.draw.rect(window,RGB,[0,start+0,35,235]) # background

def input_mask(): # unten
    RGB = [0,0,50]
    #RGB = [120,0,110] # test
    start = 227
    #f_x = CFG_IN["x2"]-50
    f_x = CFG_IN["y2"]+3
    
    # oben
    pygame.draw.rect(window,RGB,[0,start,MAIN_SIZE[0]+200,7]) # background
    # links 
    pygame.draw.rect(window,RGB,[0,start,35,200]) # background
    # unten
    #pygame.draw.rect(window,RGB,[0,start+173,MAIN_SIZE[0]+200,198]) # background
    pygame.draw.rect(window,RGB,[0,f_x,MAIN_SIZE[0]+200,198]) # background

def draw_main_overlay():
    global fps,fps2
    fr = font15.render("DMX-FPS: {}".format(fps) ,1, (200,0,255))
    window.blit(fr,(10,2))

    fr = font15.render("GUI-FPS  : {}".format(fps2) ,1, (200,0,255))
    window.blit(fr,(10,12))

    #fr = font15.render("ip:{}".format(IP) ,1, (200,0,255))
    #window.blit(fr,(100,2))

    fr = font15.render("start-uni: {:}.xx dRGB".format(START_UNIV) ,1, (200,0,255))
    window.blit(fr,(90,2))

    fr = font15.render("gobo_ch1: {}.{:}".format(START_UNIV_A,options.gobo_ch) ,1, (200,0,255))
    window.blit(fr,(210,2))
    fr = font15.render("gobo_ch2: {}.{:}".format(START_UNIV_A,options.gobo_ch2) ,1, (200,0,255))
    window.blit(fr,(210,12))

    
    for i,v in enumerate(vplay):
        fr = font15.render("v-play{}: {}.{:}".format(i+1,START_UNIV_A,v) ,1, (200,0,255))
        window.blit(fr,(300,2+12*i))

    try:
        global pointer
        # pointer
        fr = font15.render("X:{:03}".format(pointer._x) ,1, (200,200,200))
        window.blit(fr,(10,30))
        fr = font15.render("Y:{:03}".format(pointer._y) ,1, (200,200,200))
        window.blit(fr,(10,40))
    except Exception as e:
        print("Overlay err:",e)

def draw_marker():
    # kennlinie linker rand 
    # limit marker INPUT AREA 
    rgb = [0,127,255] # orange
    for CFG_OUTx in CFG_OUT: #["y1"]
        f_x = CFG_OUTx["y1"]
        pygame.draw.line(window,rgb,[0,f_x],[20,f_x]) 
        f_x = CFG_OUTx["y2"]
        pygame.draw.line(window,rgb,[0,f_x],[20,f_x]) 

    if CFG_OUT:
        f_x = CFG_OUT[0]["y1"]
        for i,v in enumerate("OUTPUT"):
            fr = font15.render(v ,1, rgb) #(200,0,255))
            if v == "I":
                window.blit(fr,(10+2,f_x+i*15+15))
            else:
                window.blit(fr,(10,f_x+i*15+15))

    # kennlinie linker rand 
    # limit marker INPUT AREA 
    rgb = [255,127,0] # orange
    f_x = CFG_IN["y1"]
    pygame.draw.line(window,rgb,[0,f_x],[20,f_x]) 
    f_x = CFG_IN["y2"]
    pygame.draw.line(window,rgb,[0,f_x],[20,f_x]) 

    f_x = CFG_IN["y1"]
    for i,v in enumerate("INPUT"):
        fr = font15.render(v ,1, rgb) #(200,0,255))
        if v == "I":
            window.blit(fr,(10+2,f_x+i*15+15))
        else:
            window.blit(fr,(10,f_x+i*15+15))

def draw_box_frame(window,rgb,pos,offset=0):
    p1 = [pos[0],pos[1]]
    p2 = [pos[0]+pos[2],pos[1]+pos[3]]
    o = offset 
    _p1 = [p1[0]-o,p1[1]-o]
    _p2 = [p1[0]-o,p2[1]+o]
    pygame.draw.line(window,rgb,_p1,_p2)  # left
    _p1 = [p2[0]+o,p2[1]+o]
    pygame.draw.line(window,rgb,_p1,_p2)  # bottom
    _p2 = [p2[0]+o,p1[1]-o]
    pygame.draw.line(window,rgb,_p1,_p2)  # right
    _p1 = [p1[0]-o,p1[1]-o]
    pygame.draw.line(window,rgb,_p1,_p2)  # top

def draw_frame(window,rgb,p1,p2,offset=0):
    o = offset 
    _p1 = [p1[0]-o,p1[1]-o]
    _p2 = [p1[0]-o,p2[1]+o]
    #pygame.draw.line(window,rgb,_p1,_p2)  # left
    _p1 = [p2[0]+o,p2[1]+o]
    pygame.draw.line(window,rgb,_p1,_p2)  # bottom
    _p2 = [p2[0]+o,p1[1]-o]
    #pygame.draw.line(window,rgb,_p1,_p2)  # right
    _p1 = [p1[0]-o,p1[1]-o]
    pygame.draw.line(window,rgb,_p1,_p2)  # top

def calc_fps():
    global fps,frame,frame_t
    t = time.time()
    if frame_t+1 < t:
        fps = frame #frame_t- t #frame
        frame = 1
        frame_t = time.time()

def calc_fps2():
    global fps2,frame2,frame2_t
    t = time.time()
    if frame2_t+0.1 < t:
        fps2 = frame2*10 #frame_t- t #frame
        frame2 = 1
        frame2_t = t #time.time()


TEXT_BLOCK = []

def _create_text_block():
    print("======== CREATE NEW TEXT FILE !!",text_file)
    f = open(text_file,"w")
    for i in range(10):
        f.write("TEXT {}\n".format(i+1))
    f.close()

def open_text_block():
    print("======== OPEN TEXT FILE !!",text_file)
    _lines = []
    try:
        f = open(text_file,"r")
        _lines = f.readlines()
        f.close()
    except FileNotFoundError as e:
        print("TEXT",e)
        _create_text_block()

    if len(_lines) <= 0:
        _create_text_block()
    lines = []
    for l in _lines:
        #print(">> ",l.strip())
        lines.append(l.strip())
    if len(lines) <= 10:
        for i in range(10-len(lines)):
            lines.append("LINE ERROR")
    return lines

TEXT_BLOCK = open_text_block()
TEXT_BLOCK_TIME = time.time()

# video medialist 

MEDIALIST = []


def open_medialist():
    print("======== OPEN MEDIALIST DIR !!",media_list)

    if not os.path.isdir(media_list):
        os.system("mkdir -p {}".format(media_list))

    _lines = os.listdir(media_list)
    _lines.sort()

    lines = ['']*25 
    i=0
    for l in _lines:
        l = l.strip()
        if "_" in l:
            ll = l.split("_",1)
            #print(">> ",ll)
            try:
                lll = int(ll[0])
                lines[lll] = l
            except:pass

    if len(lines) <= 10:
        for i in range(10-len(lines)):
            lines.append("")#"LINE ERROR")
    return lines

MEDIALIST_TIME = time.time()
MEDIALIST = open_medialist()
# ===== GUI =========


def draw_circle(surface,color, pos, radius):
    x,y=pos
    pygame.gfxdraw.aacircle(surface, int(x), int(y), radius-1, color)
    pygame.gfxdraw.filled_circle(surface, int(x), int(y), radius-1, color)

def rDMX(univ,dmx):
    return univ*512+dmx

def generate_grid(mapping=0):
    _log = []
    #if PIXEL_MAPPING:
    #    log = open(grid_file,"w")
    head = "i,univ,dmx,x,y,ch\n"
    head = "i,univ,dmx,ch\n"
    head = "univ,dmx,x,y,ch\n"
    head = "nr,id,info\n"
    print("csv:",head)

    _log.append(head)
    dmx = 1-1
    ch = 4

    y=0
    x=0

    for i in range((_y)*(_x)):
        #if x > _x and i%_x == 0:
        if x > 8 and i%8 == 0:
            #print("--> -->")
            x=0
            y+=1
        
        _univ = int(dmx/512)
        _dmx = dmx - (_univ)*512 

        pos=[x,y]
        line="{},{},x\n".format(i+1,i+1)
        _log.append(line)
        dmx += ch
        x+=1

    if mapping and PIXEL_MAPPING:
        print("CREATE NEW PIXELMAP FILE !!",grid_file)
        log = open(grid_file,"w")
        log.writelines(_log)
        log.close()

    return _log[:] #GRID



def init_grid(mapping=0,_x=4,_y=4,_xp=0,_yp=0,start=0,name="init_gird"):

    if mapping and PIXEL_MAPPING:
        try:
            log = open(grid_file,"r")
        except:
            generate_grid(mapping=mapping)
            log = open(grid_file,"r")
        lines = log.readlines()
    else:
        lines = generate_grid()
    

    GRID = []
    
    y=0
    x=0
    print("CSV header",[lines[0]],[PIXEL_MAPPING,"len:",len(lines),"start:",start,name])

    for i,line in enumerate(lines[1+start:]): #exclude first line
        #print("rcsv",[line])
        line = line.strip()
        line = line.split(",") # csv

        if i >= _x and i%_x == 0:
            x=0
            y+=1
        if y >= _y:
            break

        _id    = int(line[1])

        pos = [x+_xp,y+_yp] 
        f   = Fix(_id,pos,block) #pos,univ,dmx,ch)
        GRID.append(f)
        x+=1
    return GRID

def find_pix(x,y):
    global GRID
    for fix in GRID:
        X = 0
        Y = 0

        pos = fix.POS()
        if x > pos[0] and x < pos[0]+pos[2]:
            X = 1
        if y > pos[1] and y < pos[1]+pos[3]:
            Y = 1
        if X and Y:
            return fix
            
GRID = []

GRID_A = []

NR = 0
START_UNIV_A=1
START_UNIV=2
if options.start_univ:
    try:
        START_UNIV=int(options.start_univ)
    except Exception as e:
        print("Exception START UNIV",e) 

gobo_ch=1
if options.gobo_ch:
    try:
        gobo_ch=int(options.gobo_ch)
    except Exception as e:
        print("Exception gobo_ch",e) 

if gobo_ch <= 0:
    gobo_ch = 1

def grab(x=55,y=55,w=60,h=60):
    crop = None
    rect = pygame.Rect(x, y, w, h)
    try:
        sub = window.subsurface(rect)
        crop = pygame.Surface((w,h))
        crop.blit(sub, (0,0))
    except ValueError as e:
        #cprint("grab():",e,x,y,w,h,color="red")
        pass
        
    return crop
        
vpu_wall_txt="""---,quelle,,---,ziel,---,---
out,x,y,ang,row,col,info
Wall1,0,0,0,1,1,
Wall1,0,0,0,2,2,
Wall1,0,0,0,3,3,
Wall1,0,0,0,4,4,
Wall1,0,0,0,5,5,
Wall1,0,0,0,6,6,
Wall1,0,0,0,7,7,
,,,,,,
Wall2,0,0,0,4,1,----
Wall2,0,0,0,5,2,
Wall2,4,4,0,6,3,
Wall2,0,0,0,7,4,
Wall2,0,0,0,8,5,
Wall2,0,0,0,9,6,
,,,,,,
,,,,,,
Wall3,64,48,0,12,1,----
Wall3,64,64,0,12,2,
Wall3,64,80,0,12,3,
Wall3,64,96,0,12,4,
Wall3,64,112,0,12,5,
Wall3,64,128,0,12,6,"""
def create_vpu_wall_conf():
    f=open(vpu_wall_conf_file,"w")
    f.write(vpu_wall_txt)
    f.close() 
    print("CREATE VPU CONFIG !")

wall_data = []
_last_wall_config_time = time.time()
def read_wall_pix(init=0):
    global _last_wall_config_time 
    global wall_data, NR
    grid = []

    #if not NR and init==0:
    #    return
    ok = 0
    if init:
        ok = 1

    if NR:
        if time.time()-_last_wall_config_time > 3:
            ok = 1
    else:
        if time.time()-_last_wall_config_time > 10:
            ok = 1

    if not ok:
        return
    print("read_wall_pix",vpu_wall_conf_file)

    _last_wall_config_time = time.time()
    if not os.path.isfile(vpu_wall_conf_file):
        create_vpu_wall_conf()

    f=open(vpu_wall_conf_file,"r") 
    lines = f.readlines()
    for i,line in enumerate(lines):
        line = line.strip()
        if not line:
            continue
        line = line.split(",")
        if not line[0]:
            continue
        #print(i,line)
        if len(line) >= 3:
            _l = []
            for i in line:
                try:
                    _l.append(int(i))
                except Exception as e:
                    _l.append(i)
            grid.append(_l)

    #for i,v in enumerate(grid):
    #    print(i,v)

    wall_data = grid
read_wall_pix(init=1)

def reshape2(GRID,GRID_OUT,_x,_y,name="GRID_Z"): 
    global W_ANG
    _w = 16
    _h = 16
    from_x_min = INPUT_START_POS_X 
    from_y_min = INPUT_START_POS_Y

    target_x = 40 # min
    target_y = 60 # min
    ang=0

    #read_block_pix()
    read_wall_pix()
    _wall_data = wall_data[:]
    for i,_wall in enumerate(_wall_data):
        #print(_wall)
        if len(_wall) <=6:
            continue
        try:
            if type(_wall[1]) is str:
                continue
            if type(_wall[2]) is str:
                continue
            if type(_wall[3]) is str:
                continue
            if type(_wall[4]) is str:
                continue
            if type(_wall[5]) is str:
                continue
            from_x=from_x_min+_wall[1]#*_w
            from_y=from_y_min+_wall[2]#*_h
            _a= _wall[3]
            ang=0
            if _a < 0:
                ang=0
            elif _a > 0 and _a <= 90:
                ang = 90
            elif _a > 90 and _a <= 180:
                ang = 180
            elif _a > 180 and _a <= 270:
                ang = 270
            x_k = _wall[4]
            y_k = _wall[5]
            target_x=40+(x_k-1)*_w
            target_y=60+(y_k-1)*_h
            sub = grab(from_x,from_y,_w,_h)
            key="{}:{}".format(x_k,y_k)

            W_ANG[key] = ang
            

            if sub:
                #sub = grab(from_x,from_y,_w,_h)
                sub = pygame.transform.rotate(sub,ang)
                window.blit(sub,(target_x,target_y))
        except Exception as e:
            cprint("   ",_wall,color="red")
            cprint("WALL err:",e,color="red")



def reload_grid():
    print("==== reload_grid")
    global GRID
    global GRID_A
    try:
        GRID   = init_grid(_x=_x,_y=_y,name="GRID") #init_gird()
        GRID_A = init_grid(_x=8,_y=16,mapping=1,name="GRID_A") #init_gird()
    except Exception as e:
        cprint("Except: grid re init",e,color="red")

W_ANG = {}
def draw_kachel_nr(): #GRID,_x=0,_y=0):
    if not NR:
        return
    n = 0
    _max_row = 40
    _y=0
    for i in range(8): # ROW / ZEILEN -> ->
        _x=0
        OUT_COUNT = len(CFG_OUT)

        for j in range(8*OUT_COUNT): # COLUMS / SPALTEN | |
            #pygame.draw.rect(window,[10,20,10],[40+_x+2,60+_y+2,14,9]) #background
            pygame.draw.rect(window,[10,20,10],[6,6,14,9]) #background
            _j=j 
            key="{}:{}".format(_j+1,i+1) 
            fr = font12.render(key,1, (200,200,55))
            window.blit(fr,(6,6))
            #window.blit(fr,(40+_x+2,60+_y+2))

            ang = W_ANG.get(key,0)
            sub = grab(6,6,14,9)
            if sub: # rotate nr label
                sub = pygame.transform.rotate(sub,ang)
                if ang == 270: # pos compensation
                    window.blit(sub,(40+_x+6,60+_y+1))
                elif ang == 180:# pos compensation
                    window.blit(sub,(40+_x+1,60+_y+6))
                else:
                    window.blit(sub,(40+_x+1,60+_y+1))

            #if ang != 0:
            #    print("W_ANG",key,ang)
            _x+=16 # pix
        _y +=16 # pix


def draw_counter(COUNTER):
    for count in COUNTER:
        cpan = 0
        ctilt = 0
        cr=255
        cg=255
        cb=255
        csize=10
        cdim=0
        k = "DIM"
        if k in count:
            cdim = int(count[k])
        k = "RED"
        if k in count:
            cr = int(count[k])
        k = "GREEN"
        if k in count:
            cg = int(count[k])
        k = "BLUE"
        if k in count:
            cb = int(count[k])

        k = "SIZE"
        if k in count:
            csize = int(count[k]) #/60*p)
        if csize < 5:
            csize = 5

        k = "PAN"
        if k in count:
            cpan = int(count[k])/255*(block[0] *(_x))
            #cpan = int(cpan * 1.2)
            cpan = int(cpan)
        k = "TILT"
        if k in count:
            ctilt = int(count[k])/255*(block[1] *(_y))
            #ctilt = int(cpan * 1.2)
            ctilt = int(ctilt)

        ddim = cdim/255
        if "DIM" in count and count["DIM"] > 0:
            tmp_font = pygame.font.SysFont("freemonobold",int(p/100*csize))
            rgb =(int(cr*ddim),int(cg*ddim),int(cb*ddim),cdim) 
            
            _sec = count["_SEC"]
            
            try:
                _sec = int(count["_SEC"])
            except:
                pass

            if type(_sec) is int:
                #print(_sec)
                if _sec <= 60:
                    fr = tmp_font.render("{:0}".format(_sec) ,1, rgb)
                else:
                    _xx = time.strftime("%M:%S",time.localtime(_sec))
                    #print("_xx",_xx)
                    fr = tmp_font.render("{}".format(_xx) ,1, rgb)
            else:
                fr = tmp_font.render("{}".format((count["_SEC"])) ,1, rgb)

            fr_r = fr.get_rect(center=(40+cpan-(block[0]),60+ctilt+pm_wy))
            pygame.draw.rect(window,[0,0,0],fr_r)
            window.blit(fr,fr_r)


def video_overlay_draw(wn=None,lines=["line1","line2"],i=0):
    # overlay 

    pygame.draw.rect(wn,[255,200,0],[5,MAIN_SIZE[1]-(i+1)*35,380,28])
    font15 = pygame.font.SysFont("freemonobold",17)

    rgb = [255,100,0]
    pygame.draw.rect(wn,rgb,[5,MAIN_SIZE[1]-(i+1)*35,200,13])

    _line = lines[0]
    fr = font15.render(_line ,1, (0,0,0))
    wn.blit(fr,(10,MAIN_SIZE[1]-(i+1)*35))

    _line = lines[1]
    fr = font15.render(_line ,1, (0,0,0))
    wn.blit(fr,(10,MAIN_SIZE[1]-(i+1)*35+15))

    #_line = lines[2]
    #fr = font15.render(_line ,1, (0,0,0))
    #wn.blit(fr,(75,MAIN_SIZE[1]-(i+1)*35+15))

def draw_all_video_overlay(VIDEO):
    global videplayer
    i=0
    for count in VIDEO:
        video1 = videoplayer[i]
        #video1.overlay_draw(window,"run") # old
        lines = video1._overlay_text()

        video_overlay_draw(wn=window,lines=lines,i=i)
        i += 1

def del_all_video():
    global videplayer
    i = 0
    print()
    cprint("del_all_video")
    for video in videoplayer:
        cprint("- del video",video)
        video._del()

def draw_all_video(VIDEO):
    global videplayer
    i = 0

    # set DMX-VALUE to videoplayer Object
    for count in VIDEO:
        cpan = 0
        ctilt = 0
        cr=255
        cg=255
        cb=255
        csize=10
        cang=0
        cdim=0
        

        video1 = videoplayer[i]
        k = "VIDEO"
        if k in count:
            #video1.select_video(count[k])

            if type(count[k]) is str:
                cprint("ERR count[k] is str not int !")
                continue
            play_nr = int(count[k]/10)
            if play_nr != video1._media_nr:
                print( "+ + + +  + + + + + + +", play_nr , video1._media_nr ,str(video1))
                _vid  = video1._id
                _cdmx = video1.dmx
                del_video1 = video1

                video1 = PixelMedia(cdmx,_id=_vid) 
                video1.select_video(count[k])
                videoplayer[i] = video1

                del_video1._del()
                del del_video1

        k = "DIM"
        if k in count:
            cdim = int(count[k])
            #video1.dim = cdim
        #if i == 0:
        #    print(i,cdim)

        k = "ANG"
        if k in count:
            cang = int(count[k])

        k = "SIZE"
        if k in count:
            csize = int(count[k]/16*p)
        if csize < 5:
            csize = 5

        k = "PAN"
        cpan_max = block[0] *(_x) #+block[0]
        if k in count:
            cpan = int(count[k]) / 255*cpan_max
            cpan = int(cpan)

        k = "TILT"
        ctilt_max = block[1] *(_y) #+block[1]
        if k in count:
            ctilt = int(count[k]) / 255*ctilt_max
            ctilt = int(ctilt)

        


        k = "_reset"
        if k in count:
            if count[k]:
                count[k] = 0
                video1.restart()

        k = "_RUN"
        if k in count:
            video1._run = count[k]



        #video1.pos 
        #video1.x=40+0+cpan 
        #video1.y=60+0+pm_wy+ctilt
        x=CFG_IN["x1"]+cpan 
        y=CFG_IN["y1"]+ctilt
        scale = int((csize))
        angle = int(360-(cang))
        video1.update_dmx(x,y,scale,angle,cdim)

        if cdim:
            video1.next()
        i += 1

    # draw

    i=0
    for count in VIDEO:
        video1 = videoplayer[i]
        video1.draw(window) #,x=0,y=0)
        i+=1





def counter_dmx(COUNTER,dataA):
    for count in COUNTER:
        cDMX=count["DMX"]-1
        try:
            count["DIM"]   = dataA[cDMX]
            count["PAN"]   = dataA[cDMX+1]
            count["TILT"]  = dataA[cDMX+2]
            count["CONTROL"] = dataA[cDMX+3]
            count["SIZE"]  = dataA[cDMX+4]
            count["SEC"]   = dataA[cDMX+5]
            count["RED"]   = dataA[cDMX+6]
            count["GREEN"] = dataA[cDMX+7]
            count["BLUE"]  = dataA[cDMX+8]

            if count["CONTROL"] >= 10 and count["CONTROL"] < 20: # RESET COUNTER
                count["_RUN"]   = 0 
                count["_pause"] = 0
                count["_time"]  = time.time()
                count["_start"] = int(count["SEC"])
                count["_SEC"]   = int(count["_start"]) 
            if count["CONTROL"] >= 20 and count["CONTROL"] < 30: # PAUSE COUNTER
                if count["_RUN"] == 0:
                    print("CONTROL SET TO PAUSE",self)
                count["_RUN"] = 0 
            if count["CONTROL"] >= 30 and count["CONTROL"] < 40: # PLAY COUNTER
                if count["_RUN"] == 1:
                    print("CONTROL SET TO RUN",self)
                count["_RUN"] = 1



            if count["_RUN"]:
                try:
                    if count["_pause"] > 0:
                        count["_time"] += time.time()-count["_pause"]
                        count["_pause"] = 0
                    count["_SEC"] = int(count["_start"] - (time.time() - count["_time"]))

                except Exception as e:
                    pass
            else:
                if count["_pause"] == 0:
                    count["_pause"] = time.time()
            if type(count["_SEC"]) is int:
                if count["_SEC"] < 0:
                    count["_SEC"] = 0
            for ti in range(10):
                #print(ti,(ti+6)*10)
                if count["CONTROL"] >= (ti+6)*10 and count["CONTROL"] < (ti+7)*10:
                    count["_SEC"] = "----" #text 1
                    try:
                        count["_SEC"] = TEXT_BLOCK[ti]
                    except Exception as e:
                        pass

            if count["CONTROL"] >= 250 and count["CONTROL"] < 256:
                count["_SEC"] = "DMX:{}-{}".format(cDMX+1,cDMX+8+1)

        except Exception as e:
            cprint("EXC FUNC",e,count,color="red")
        #print(count)


def video_dmx(VIDEO,dataA):
    for count in VIDEO:
        cDMX=count["DMX"]-1
        try:
            count["DIM"]   = dataA[cDMX]
            count["PAN"]   = dataA[cDMX+1]
            count["TILT"]  = dataA[cDMX+2]
            count["CONTROL"] = dataA[cDMX+3]

            if count["CONTROL"] >= 10 and count["CONTROL"] < 20:
                count["_reset"] = 1

            if count["CONTROL"] >= 20 and count["CONTROL"] < 30:
                if count["_RUN"] == 1:
                    print(  "_RUN:0",count["DMX"]-1)
                count["_RUN"] = 0 

            if count["CONTROL"] >= 30 and count["CONTROL"] < 40:
                if count["_RUN"] == 0:
                    print(  "_RUN:1",count["DMX"]-1)
                count["_RUN"] = 1

            count["SIZE"]  = dataA[cDMX+4]#*2
            count["SEC"]   = dataA[cDMX+5]

            #count["RED"]   = dataA[cDMX+6]
            count["VIDEO"] = dataA[cDMX+6]
            #count["GREEN"] = dataA[cDMX+7]
            count["ANG"] = (int(dataA[cDMX+7])/255*360)
            #count["BLUE"]  = dataA[cDMX+8]
        except Exception as e:
            cprint("VIDEOPLAYER EXCEPT FUNC",e,count,color="red")
        #print(count)

def read_dmx_data(ip,ips):
    ip = select_ip(ips,univ=START_UNIV)
    IP = ip
    data = read_dmx(ip)


    ip = select_ip(ips,univ=START_UNIV+1)
    data3 = read_dmx(ip)
    data.extend(data3)

    ip = select_ip(ips,univ=START_UNIV+2)
    data3 = read_dmx(ip)
    data.extend(data3)

    ip = select_ip(ips,univ=START_UNIV+3)
    data3 = read_dmx(ip)
    data.extend(data3)

    if options.dual_vpu:
        ip = select_ip(ips,univ=START_UNIV+4)
        data3 = read_dmx(ip)
        data.extend(data3)
        
        ip = select_ip(ips,univ=START_UNIV+5)
        data3 = read_dmx(ip)
        data.extend(data3)
    return data

def set_pos(GRID,_x=0,_y=0):
    for fix in GRID:
        pos = fix.POS(_x,_y)#40,60+pm_wy)
        for subfix in fix.sub_fix:
            #subfix.dmc_calc(data)
            spos = subfix.POS(_x,_y)
        
def draw_gobo(GRID,data,_x=0,_y=0):

    i = 0
    dmx = 1
    h = 1
    v = 1
    for fix in GRID:
        rgb = fix.rgb
        pos = fix.POS() #CFG_IN["x1"],CFG_IN["y1"]) 

        pygame.draw.rect(window,rgb,pos)

        # DRAW SUB-FIXTURE
        j = 0
        for subfix in fix.sub_fix:#calc(data):
            subfix.dmx_calc(data)
            spos = subfix.POS() #_x,_y)#+pm_wy)
            srgb = subfix.rgb

            if FUNC > 10 and FUNC <= 20: # big dot
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
            elif FUNC > 20 and FUNC <= 30:#small dot
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
            elif FUNC > 30 and FUNC <= 40:#donut
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
                draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
            elif FUNC > 40 and FUNC <= 50: # rec with hole
                pygame.draw.rect(window,srgb,spos)
                draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
            elif FUNC > 50 and FUNC <= 60: # rec with big hole
                pygame.draw.rect(window,srgb,spos)
                draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
            elif FUNC > 60 and FUNC <= 70: # rec with donat
                pygame.draw.rect(window,srgb,spos)
                draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
            elif FUNC > 70 and FUNC <= 80: # rec boarder
                pygame.draw.rect(window,srgb,[spos[0]+1,spos[1]+1,spos[2]-2,spos[3]-2])
            elif FUNC > 80 and FUNC <= 90: # rec big boarder
                pygame.draw.rect(window,srgb,[spos[0]+2,spos[1]+2,spos[2]-4,spos[3]-4])
            elif FUNC > 90 and FUNC <= 100: # rec thin line
                pygame.draw.rect(window,srgb,spos)
                pygame.draw.rect(window,[0,0,0],[spos[0]+1,spos[1]+1,spos[2]-2,spos[3]-2])
            elif FUNC > 100 and FUNC <= 110: # rec big line
                pygame.draw.rect(window,srgb,spos)
                pygame.draw.rect(window,[0,0,0],[spos[0]+2,spos[1]+2,spos[2]-4,spos[3]-4])
            elif FUNC > 110 and FUNC <= 120: # rec with dot
                pygame.draw.rect(window,srgb,spos)
                pygame.draw.rect(window,[0,0,0],[spos[0]+1,spos[1]+1,spos[2]-2,spos[3]-2])
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
            elif FUNC > 120 and FUNC <= 130: # rec inline
                pygame.draw.rect(window,srgb,[spos[0]+2,spos[1]+2,spos[2]-4,spos[3]-4])
                pygame.draw.rect(window,[0,0,0],[spos[0]+3,spos[1]+3,spos[2]-6,spos[3]-6])
            elif FUNC > 130 and FUNC <= 140: # 3 dot (heart)
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2)+2,spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2)-2,spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
                draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)+2),int(spos[3]/3.5))
            else:
                pygame.draw.rect(window,srgb,spos)


        i += 1


def grid_label(GRID,_x=0,_y=0):

    for fix in GRID:
        #pos = fix.POS(_x,_y)
        pos = fix.POS() #CFG_IN["x1"],CFG_IN["y1"])
        rgb = fix.rgb

        # draw row/col grid number
        if pos[0] == 0:
            fr = font12.render("{}".format(pos[1]+1) ,1, (200,200,200))
            window.blit(fr,(10,pos[1]+3 ))
        if pos[1] == 0:
            fr = font12.render("{}".format(pos[0]+1) ,1, (200,200,200))
            window.blit(fr,(pos[0]+2,35 ))




def out_frame():
    rgb = [255,255,0]
    rgb = [255,0,0]

    for CFG_OUTx in CFG_OUT:
        if CFG_OUTx["on"]:
            rgb = [255,0,0]
            p1 = CFG_OUTx["p1"][:]
            p2 = CFG_OUTx["p2"][:]
            p1[0] += 4
            p2[0] -= 4
            draw_frame(window,rgb,p1,p2,offset=3)


ips=[]
dataA=[]
data=[]

def dmx_raw():
    global frame
    frame += 1

    global ips,dataA,data
    ips = read_index()
    
    # ----
    ip = select_ip(ips,univ=6) # univ 1 gobo
    dataA = read_dmx(ip)
    # ----

    #data = read_dmx_data(ip,ips)


    if options.countdown:
        #counter_dmx(COUNTER,dataA)
        pass
    
    if len(VIDEO) > 0:
        video_dmx(VIDEO,dataA)
    return ips,dataA,data


def dmx_loop():
    while 1:
        dmx_raw()
        time.sleep(1/40) # fast high cpu
        if QUIT:
            break

thread.start_new_thread(dmx_loop,())

def draw_output_label(CFG,value,dmx="0.0",name="GRID_XX"):
    dim_raw = value

    pygame.draw.rect(window,[5,5,155],[CFG["x1"]+2,CFG["y2"]+5,CFG["w"]-6,25]) # background

    # GRID_A1_DIM_LABEL
    fr   = font15.render("Name: "+name,1, (255,255,255))
    fr_r = fr.get_rect(center=(int(wx/2),int(0+pm_wy-p*0-10)))
    window.blit(fr,(CFG["x1"]+4,CFG["y2"]+5))

    fr   = font15.render("inv-dim: "+str(dim_raw) ,1, (255,255,255))
    fr_r = fr.get_rect(center=(int(wx/2),int(0+pm_wy-p*0-10)))
    window.blit(fr,(CFG["x1"]+64,CFG["y2"]+20))

    fr   = font15.render("dmx: {}.{}".format(START_UNIV_A,dmx) ,1, (255,255,255))
    window.blit(fr,(CFG["x1"]+4,CFG["y2"]+20))

def _check_dim(_dim):
    dim = 255
    try:
        dim = int(_dim)
        if dim > 255:
            dim = 255
        if dim <=0:
            dim = 0
    except:
        pass
    return dim

def _GRID_DIM(dim,x,y):
    dim = _check_dim(dim)
    dim_raw = dim*-1
    s = pygame.Surface((p*8,p*8))   # the size of your rect
    s.set_alpha(dim)                # alpha level
    s.fill((0,0,0))                 # this fills the entire surface
    window.blit(s, (x,y))

def GRID_DIM():
    for CFG in CFG_OUT:
        dim_ch = int(CFG["DMX-CH"])
        dim = dataA[dim_ch-1]
        _GRID_DIM(dim,x=CFG["x1"],y=CFG["y2"]-p*8)
        draw_output_label(CFG,dim,dim_ch,name=CFG["name"])
    

def cvImageToSurface(cvImage): 
    if cvImage.dtype.name == 'uint16':
        cvImage = (cvImage / 256).astype('uint8')
    size = cvImage.shape[1::-1]
    if len(cvImage.shape) == 2:
        cvImage = np.repeat(cvImage.reshape(size[1], size[0], 1), 3, axis = 2)
        format = 'RGB'
    else:
        format = 'RGBA' if cvImage.shape[2] == 4 else 'RGB'
        cvImage[:, :, [0, 2]] = cvImage[:, :, [2, 0]]
    surface = pygame.image.frombuffer(cvImage.flatten(), size, format)
    return surface.convert_alpha() if format == 'RGBA' else surface.convert()

def create_img_meta():
    out = {}
    #40 235
    out["pos"] = (0,0) # x,y
    out["ipos"] = (0,0) # x,y
    out["scale"] = 50
    out["dim"] = 100
    out["ang"] = 0
    out["_fpath"] = '/opt/LibreLight/Xdesk/icon/'
    out["fname"] = "picker.png"
    out["raw_img"] = ""
    out["img"] = ""
    out["err"] = []
    return out

def img_open(img_meta):
    cprint("img_open",img_meta["fname"],"-------")
    fname = img_meta["_fpath"] +"/"+ img_meta["fname"] #'/opt/LibreLight/Xdesk/icon/picker.png'
    im2 = cv2.imread(fname)
    width  = int(im2.shape[1])
    height = int(im2.shape[0])
    w_max = 480
    h_max = 320
    #w_max = 600
    #h_max = 400
    w_max = 4800 # max input jpg resolution
    h_max = 3200 # max input jpg resolution
    if width > w_max:
        h = int(height*(w_max/width))
        w = w_max
        im2 = cv2.resize(im2, (w,h), interpolation =cv2.INTER_LINEAR)

    if height > h_max:
        w = int(width*(h_max/height))
        h = h_max
        if w < w_max:
            im2 = cv2.resize(im2, (w,h), interpolation =cv2.INTER_LINEAR)

    img_meta["raw_img"] = im2
    img_meta["img"] = im2
    return im2

def img_jitter(img_meta):
    r1=random.randint(0,3)
    r2=random.randint(0,3)
    img_meta["ipos"] = [r1,r2]

def img_rescale_width(img_meta, _width):
    frame = img_meta["raw_img"]
    width  = int(frame.shape[1])
    height = int(frame.shape[0])
    dim = (width, height)
    if 1: #width > _width:
        h = int(height*( width/_width))
        dim = (_width, h)
        im = cv2.resize(frame, dim, interpolation =cv2.INTER_LINEAR)
    else:
        im = cv2.resize(frame, dim, interpolation =cv2.INTER_LINEAR)
    return im

def img_rescale(img, percent=75):
    frame = img
    #frame = img_meta["raw_img"]
    width  = int(frame.shape[1] * percent/ 100)
    height = int(frame.shape[0] * percent/ 100)
    dim = (width, height)
    return cv2.resize(frame, dim, interpolation =cv2.INTER_LINEAR)

def img_draw_raw(img_meta):
    #img_jitter(img_meta)

    pos  = img_meta["pos"]
    ipos = img_meta["ipos"]
    im2  = img_meta["img"]
    dim  = img_meta["dim"]

    im2 = cvImageToSurface(im2)

    w2 = int(im2.get_width()/2)
    h2 = int(im2.get_height()/2)

    x=pos[0]+ipos[0]
    y=pos[1]+ipos[1]

    window.blit(im2, (x-w2,y-h2))

img_meta_a = create_img_meta()


count_tilt = 0
def main():
    global IP
    global GRID

    global GRID_A
    global FUNC
    global count_tilt
    global TEXT_BLOCK
    global TEXT_BLOCK_TIME
    global MEDIALIST
    global MEDIALIST_TIME
    global dataA
    global frame2
    global runnung

    reload_grid()

    s=time.time()
    r = ""
    IP = "xx"

    while running:
        if  TEXT_BLOCK_TIME+5 < time.time():
            TEXT_BLOCK = open_text_block()
            TEXT_BLOCK_TIME = time.time()

        if  MEDIALIST_TIME+6 < time.time():
            MEDIALIST = open_medialist()
            MEDIALIST_TIME = time.time()


        pygame.display.flip()
        set_pos(GRID,_x=CFG_IN["x1"],_y=CFG_IN["y1"]) 

        event()

        window.fill((10,0,30))
        calc_fps()
        calc_fps2()

        # GRID loop
        try:
            FUNC = dataA[gobo_ch-1]
            FUNC2 = FUNC
        except Exception as e:
            print("EXC FUNC",e)

        draw_gobo(GRID,data) #,_x=CFG_IN["x1"],_y=CFG_IN["y1"]) 
        grid_label(GRID,_x=CFG_IN["x1"],_y=CFG_IN["y1"])

        if VIDEO:
            draw_all_video(VIDEO)

        if options.countdown:
            draw_counter(COUNTER)

        # output background mask   
        _w = 8*16 
        if len(out_idim): 
            _w = len(out_idim)*8*16
        pygame.draw.rect(window,[0,0,0],[35,57,_w+16,135]) # background
        pointer.draw(0,pm_wy) #wy


        spos = [0,0,0,0]
        if PIXEL_MAPPING >= 1:
            #try:
            if options.dual_vpu:
                GRID_X = GRID_A[8*8:]
                xx = p*8

            reshape2(GRID,GRID_A,CFG_OUT[0]["x1"],CFG_OUT[0]["y1"],name="GRID_A1") #start pos


        if options.out_idim:    
            out_frame()

        # OUTPUT -> MAPING
        if options.out_idim:    
            draw_kachel_nr()

        if options.out_idim:    
            input_mask()  # mask background

        if options.out_idim:    
            output_mask() # mask background
            GRID_DIM() # overlay

        if VIDEO:
            draw_all_video_overlay(VIDEO)

        draw_main_overlay()
        draw_marker()

        pointer.draw(0,pm_wy) #wy
        pygame.display.flip()
        clock.tick(25)

        if 'SDL_VIDEO_WINDOW_POS' in os.environ:
            del os.environ['SDL_VIDEO_WINDOW_POS'] #= '%i,%i' % (200,164)

        frame2 += 1

if __name__ == "__main__":
    try:
        main()
    finally:
        del_all_video()