PyRadmon install and set up on Raspberry Pi (Wheezy Raspbian)

class gmc(baseGeigerCommunication):

    def initCommunication(self):
        print "Initializing GMC protocol communication => geiger 1\r\n"
        # get firmware version
        response=self.sendCommand("< GETVER >>")

        if len(response)>0:
            print "Found GMC-compatible device, version => geiger 1: ", response, "\r\n"
            # get serial number
            # serialnum=self.sendCommand("<GETSERIAL>>")
            # serialnum.int=struct.unpack('!1H', serialnum(7))[0]
            # print "Device Serial Number is: ", serialnum.int
            # disable heartbeat, we will request data from script
            self.sendCommand("< HEARTBEAT0 >>")
            print "Please note data will be acquired once per 5 seconds => geiger 1\r\n"
            # update the device time
            unitTime=self.sendCommand("< GETDATETIME >>")
            time.sleep(0.5)# just to ensure all CPM bytes are in serial port buffer
            print "Unit shows time as => geiger 1: ", unitTime, "\r\n"
            # self.sendCommand("<SETDATETIME[" + time.strftime("%y%m%d%H%M%S") + "]>>")
            # print "<SETDATETIME[" + time.strftime("%y%m%d%H%M%S") + "]>>"

        else:
            print "No response from device => geiger 1\r\n"
            self.stop()
            sys.exit(1)

    def getData(self):
        cpm=-1
            
        try:
            # wait, we want sample every 30s
            for i in range(0,3):
                time.sleep(1)

            # send request
            response=self.sendCommand("< GETCPM >>")
            # wait for data
            time.sleep(0.5) # just to ensure all CPM bytes are in serial port buffer

            if len(response)==2:
                # convert bytes to 16 bit int
                cpm=cpm + ord(response[0])*256+ord(response[1])
            else:
                edata=""
                for i in range(1,len(response)):
                    edata = edata + ord(response[0])*256+ord(response[i])
                print "Unknown response to CPM request, device is not GMC-compatible? => geiger 1\r\n"
                print "Data recieved was: ",str(edata),"\r\n"

        except Exception as e:
            print "\r\nProblem in getData procedure (disconnected USB device?) => geiger 1:\r\n\t",str(e),"\r\nExiting\r\n"
            self.stop()
            sys.exit(1)
            
        utcTime=datetime.datetime.utcnow()
        data=[cpm, utcTime]
        return data

class gmc(baseGeigerCommunication):

    def initCommunication(self):
        print "Initializing GMC protocol communication => geiger 1\r\n"
        # get firmware version
        self.serialPort.flushInput()
        self.serialPort.write("< GETVER >>")
        # assume that device responds within 1s
        time.sleep(1)
        response=""
        while (self.serialPort.inWaiting()>0 and self.stopwork==0):
            response = response + self.serialPort.read()
        # response=self.sendCommand("< GETVER >>")

        if len(response)>0:
            print "Found GMC-compatible device, version => geiger 1: ", response, "\r\n"
            # get serial number
            # serialnum=self.sendCommand("<GETSERIAL>>")
            # serialnum.int=struct.unpack('!1H', serialnum(7))[0]
            # print "Device Serial Number is: ", serialnum.int
            # disable heartbeat, we will request data from script
            self.serialPort.flushInput()
            self.serialPort.write("< HEARTBEAT0 >>")
            # self.sendCommand("< HEARTBEAT0 >>")
            print "Please note data will be acquired once per 5 seconds => geiger 1\r\n"
            # update the device time
            self.serialPort.flushInput()
            self.serialPort.write("< GETDATETIME >>")
            # assume that device responds within 1s
            time.sleep(1)
            response=""
            while (self.serialPort.inWaiting()>0 and self.stopwork==0):
                unitTime = unitTime + self.serialPort.read()
            # unitTime=self.sendCommand("< GETDATETIME >>")
            time.sleep(0.5)# just to ensure all CPM bytes are in serial port buffer
            print "Unit shows time as => geiger 1: ", unitTime, "\r\n"
            # self.sendCommand("<SETDATETIME[" + time.strftime("%y%m%d%H%M%S") + "]>>")
            # print "<SETDATETIME[" + time.strftime("%y%m%d%H%M%S") + "]>>"

        else:
            print "No response from device => geiger 1\r\n"
            self.stop()
            sys.exit(1)

    def getData(self):
        cpm=-1
            
        try:
            # wait, we want sample every 30s
            for i in range(0,3):
                time.sleep(1)

            # send request
            self.serialPort.flushInput()
            self.serialPort.write("< GETCPM >>")
            # assume that device responds within 1s
            time.sleep(1)
            response=""
            while (self.serialPort.inWaiting()>0 and self.stopwork==0):
                response = response + self.serialPort.read()
            # response=self.sendCommand("< GETCPM >>")
            # wait for data
            time.sleep(0.5) # just to ensure all CPM bytes are in serial port buffer

            if len(response)==2:
                # convert bytes to 16 bit int
                cpm = cpm + ord(response[0])*256+ord(response[1])
            elif len(response) > 2:
                edata=""
                for i in range(1,len(response)):
                    edata = edata + ord(response[0])*256+ord(response[i])
                cpm = int( ( float(cpm) / ( len(response) - 1 ) ) +0.5)
            else:
                edata=""
                for i in range(1,len(response)):
                    edata = edata + ord(response[0])*256+ord(response[i])
                print "Unknown response to CPM request, device is not GMC-compatible? => geiger 1\r\n"
                print "Data recieved was: ",str(edata),"\r\n"

        except Exception as e:
            print "\r\nProblem in getData procedure (disconnected USB device?) => geiger 1:\r\n\t",str(e),"\r\nExiting\r\n"
            self.stop()
            sys.exit(1)
            
        utcTime=datetime.datetime.utcnow()
        data=[cpm, utcTime]
        return data

class main():
    # main loop is in while loop
    # check if file exists, if not, create one and exit
    if (os.path.isfile("config.txt")==0):
        print "\tNo configuration file, creating default one.\r\n\t"

        try:
            f = open("config.txt", 'w')
            f.write("# Parameter names are not case-sensitive\r\n")
            f.write("# Parameter values are case-sensitive\r\n")
            f.write("user=test_user\r\n")
            f.write("password=test_password\r\n")
            f.write("# Port is usually /dev/ttyUSBx in Linux and COMx in Windows\r\n")
            f.write("serialport=/dev/ttyUSB0\r\n")
            f.write("speed=2400\r\n")
            f.write("# Protocols: demo, mygeiger, gmc, netio, audio\r\n")
            f.write("protocol=demo\r\n")
            f.write("# In case of audio, input the device number here, default is 0.\r\n")
            p = pyaudio.PyAudio()
            info = p.get_host_api_info_by_index(0)
            #for each audio device, determine if is an input or an output and add it to the appropriate list and dictionary
            for i in range (0,info.get('deviceCount')):
                if p.get_device_info_by_host_api_device_index(0,i).get('maxInputChannels')>0:
                    f.write("# %d - %s \r\n"%(i,p.get_device_info_by_host_api_device_index(0,i).get('name')))
            f.write("device=0\r\n")
            print "\tPlease open config.txt file using text editor and update configuration.\r\n"
        except Exception as e:
            print "\tFailed to create configuration file\r\n\t",str(e)
        finally:
            time.sleep(1)
            p.terminate()
            f.close()
        sys.exit(1)
    else:
        # create and read configuration data
        cfg=config()
        cfg.readConfig()
        # create geiger communication object
        if cfg.protocol==config.MYGEIGER:
            print "Using myGeiger protocol for 1 => geiger 1\r\n"
            geigerCommunication=myGeiger(cfg)
        elif cfg.protocol==config.DEMO:
            print "Using Demo mode for 1 => geiger 1\r\n"
            geigerCommunication=Demo(cfg)
        elif cfg.protocol==config.GMC:
            print "Using GMC protocol for 1 => geiger 1\r\n"
            geigerCommunication=gmc(cfg)
        elif cfg.protocol==config.NETIO:
            print "Using NetIO protocol for 1 => geiger 1\r\n"
            geigerCommunication=netio(cfg)
        elif cfg.protocol==config.AUDIO:
            print "Using audio protocol for 1 => geiger 1\r\n"
            geigerCommunication = audioCommunication(cfg)
        else:
            print "Unknown protocol configured, can't run => geiger 1\r\n"
            sys.exit(1)

        try:
            # create web server communication object
            webService=webCommunication(cfg)

            # start measuring thread
            geigerCommunication.start()

            # Now send data to web site every 30 seconds
            while(geigerCommunication.is_running==1):
                sample=geigerCommunication.getResult()

                if sample[0]!=-1:
                    # sample is valid, CPM !=-1
                    print "Average result => geiger 1:\tCPM =",sample[0],"\t",str(sample[1]),"\r\n"
                    try:
                        webService.sendSample(sample)
                    except Exception as e:
                        print "Error communicating server => geiger 1:\r\n\t", str(e),"\r\n"

                    print "Waiting 30 seconds => geiger 1\r\n"
                    # Waiting 60x0.5 seconds,
                    # it has a better response when CTRL+C is used,
                    # might be changed in future
                    for i in range(0,60):
                        time.sleep(0.5)
                else:
                    print "No samples in queue, waiting 5 seconds => geiger 1\r\n"
                    for i in range(0,5):
                        time.sleep(1)
                    continue

        except KeyboardInterrupt as e:
            print "\r\nCTRL+C pressed, exiting program\r\n\t", str(e), "\r\n"

        except SystemExit:
            print "\r\nSystem exit\r\n\t",str(e),"\r\n"

        except Exception as e:
            print "\r\nUnhandled error\r\n\t",str(e),"\r\n"

        geigerCommunication.stop()

        # Threading fix
        print "Waiting and reap threads"
        time.sleep(1)
        for numThread in threading.enumerate():
            if numThread.isDaemon(): continue
            if numThread.getName() == 'MainThread': continue
            print "Stopping alive thread: ", numThread.getName(), "\r\n\t"
            numThread.stop()
            time.sleep(1)
        sys.exit(0)

if __name__ == '__main__':
    main()