class Detector(ReadonlyRegisterBase):
    def __init__(self):
        self.status = -1
        self.det1 = -1
        self.det2 = -1
        self.det3 = -1
        self.det4 = -1



class Esera(TcpDevice):    
    def __init__(self, name, server, timeout = 1000, retries = 1):
         TcpDevice.__init__(self, name, server) 
         self.setMode(self.Mode.FullDuplex)
         self.detectors = []
         for i in range(30):
             self.detectors.append(Detector())    

    def start(self):
        self.write("set,sys,run,1\n")

    def stop(self):
        self.write("set,sys,run,0\n")

    def list(self):
        self.write("get,owb,listall1\n")

    def doInitialize(self):           
        super(Esera, self).doInitialize()
        
        self.setState(State.Ready) #So can communicate
        self.stop()
        time.sleep(0.1)
        self.flush()
        self.detectors = []
        for i in range(30):
            self.detectors.append(Detector())            
        self.list()        
        self.start()

    def onByte(self, rx):
        print rx
    
     
    def onString(self, msg):
        print "HERE"

     


#count = 1
#while (True):
#    print    onewire.waitString("\n", 1000)#
#
#    print count
#    count = count + 1






add_device(Esera("onewire", "129.129.126.83:5000"), force = True)