indiserver indi_sbig_ccd

2016-08-22 13:35:24,190 new device DEVICE NAME

indiserver indi_sbig_ccd

import sys, time, logging
import PyIndi
 
print('1')
sys.stdout.flush()         
 
 
class IndiClient(PyIndi.BaseClient):
    device = None
    def __init__(self):
 
        super(IndiClient, self).__init__()
        self.logger = logging.getLogger('PyQtIndi.IndiClient')
        self.logger.info('creating an instance of PyQtIndi.IndiClient')
        print('2')
        sys.stdout.flush()                 
 
    def newDevice(self, d):
        print('3')
        sys.stdout.flush()     
 
        self.logger.info("new device " + d.getDeviceName())
 
        if d.getDeviceName() == "SBIG CCD":
		self.logger.info("Set new device CCD Simulator!")
		# save reference to the device in member variable
		self.device = d
    def newProperty(self, p):
        print('4')
        sys.stdout.flush()            
 
        self.logger.info("new property "+ p.getName() + " for device "+ p.getDeviceName())
        if self.device is not None and p.getName() == "CONNECTION" and p.getDeviceName() == self.device.getDeviceName():
		self.logger.info("Got property CONNECTION for CCD Simulator!")
		# connect to device
		self.connectDevice(self.device.getDeviceName())
		# set BLOB mode to BLOB_ALSO
		self.setBLOBMode(1, self.device.getDeviceName(), None)
        if p.getName() == "CCD_EXPOSURE":
		# take first exposure
		self.takeExposure()
    def removeProperty(self, p):
        print('5')
        sys.stdout.flush(             
 
        self.logger.info("remove property "+ p.getName() + " for device "+ p.getDeviceName())
    def newBLOB(self, bp):
        print('6')
        sys.stdout.flush() 
 
        self.logger.info("new BLOB "+ bp.name.decode())
	# get image data
	img = bp.getblobdata()
	import cStringIO
	# write image data to StringIO buffer
	blobfile = cStringIO.StringIO(img)
	# open a file and save buffer to disk
	with open("frame.fit", "wb") as f:
		f.write(blobfile.getvalue())
	# start new exposure for timelapse images!
	self.takeExposure()
    def newSwitch(self, svp):
 
        self.logger.info ("new Switch "+ svp.name.decode() + " for device "+ svp.device.decode())
    def newNumber(self, nvp):
        self.logger.info("new Number "+ nvp.name.decode() + " for device "+ nvp.device.decode())
    def newText(self, tvp):
        self.logger.info("new Text "+ tvp.name.decode() + " for device "+ tvp.device.decode())
    def newLight(self, lvp):
        self.logger.info("new Light "+ lvp.name.decode() + " for device "+ lvp.device.decode())
    def newMessage(self, d, m):
        self.logger.info("new Message "+ d.messageQueue(m).decode())
    def serverConnected(self):
        print("Server connected ("+self.getHost()+":"+str(self.getPort())+")")
    def serverDisconnected(self, code):
        self.logger.info("Server disconnected (exit code = "+str(code)+","+str(self.getHost())+":"+str(self.getPort())+")")
    def takeExposure(self):
        self.logger.info("<<<<<<<< Exposure >>>>>>>>>")
	# get current exposure time
        exp = self.device.getNumber("CCD_EXPOSURE")
	# set exposure time to 5 seconds
        exp[0].value = 1
	# send new exposure time to server/device
        self.sendNewNumber(exp)
 
 
logging.basicConfig(format='%(asctime)s %(message)s', level=logging.INFO)
 
# instantiate the client
indiclient=IndiClient()
# set indi server localhost and port 7624
indiclient.setServer("localhost",7624)
# connect to indi server
print("Connecting and waiting 2secs")
print("7")
sys.stdout.flush()        
 
if (not(indiclient.connectServer())):
     print("No indiserver running on "+indiclient.getHost()+":"+str(indiclient.getPort())+" - Try to run")
     print("  indiserver indi_simulator_telescope indi_simulator_ccd")
     print("8")
     sys.stdout.flush()          
 
     sys.exit(1)
time.sleep(1)
 
# start endless loop, client works asynchron in background
while True:
	time.sleep(1)

def newProperty(self, p):
    if p.getName() == "CCD_BINNING":
	    bin = self.device.getNumber("CCD_BINNING")
            bin[0].value = 5
            self.sendNewNumber(bin)