realraum zeromq listener

r3doombutton.py

#!/usr/bin/python
# -*- coding: utf-8 -*-
from r3zmq import r3zmq
import requests
########################
# r3doombutton-to-irc connector (aka r3zmq demo)
# by verr

HOOKURL = '<limnoria r3hook url>'

def sendToIrc(message):
    requests.post(HOOKURL, data = message, headers={'content-type': 'text/plain;'})

def mylistener(structname, dictdata):
    if structname == "BoreDoomButtonPressEvent":
        print "received "
        sendToIrc('Dooom! The button has been pressed! Propably someone is bored and in need of company! ;-)')
    #elif structname == "IlluminationSensorUpdate":
     #   sendToIrc('IlluminationSensorUpdate')
    # always:
    print "Got data: " + structname + ": "+ str(dictdata)



if __name__ == "__main__":
    print "loading zmq ..."
    z = r3zmq()
    z.zmqloop(mylistener)

r3zmq.py

#!/usr/bin/python
# -*- coding: utf-8 -*-
import os
import os.path
import sys
import signal
import zmq.utils.jsonapi as json
import zmq
import traceback
import time
########################
# r3zmq listener
# by verr
# based on code by xro

class r3zmq():
    def decodeR3Message(self, multipart_msg):
        try:
            return (multipart_msg[0], json.loads(multipart_msg[1]))
        except Exception, e:
            logging.debug("decodeR3Message:"+str(e))
            return ("",{})
    def exitHandler(signum, frame):
      try:
        zmqsub.close()
        zmqctx.destroy()
      except:
        pass
      sys.exit(0)
    signal.signal(signal.SIGINT, exitHandler)
    signal.signal(signal.SIGQUIT, exitHandler)


    def zmqloop(self, listener):
        while True:
          try:
            #Start zmq connection to publish / forward sensor data
            zmqctx = zmq.Context()
            zmqctx.linger = 0
            zmqsub = zmqctx.socket(zmq.SUB)
            zmqsub.setsockopt(zmq.SUBSCRIBE, "")
            zmqsub.connect("tcp://zmqbroker.realraum.at:4244")
            while True:
              data = zmqsub.recv_multipart()
              (structname, dictdata) = self.decodeR3Message(data)
              listener(structname, dictdata)
          except Exception, ex:
            print "main: "+str(ex)
            traceback.print_exc(file=sys.stdout)
            try:
              zmqsub.close()
              zmqctx.destroy()
            except:
              pass
            time.sleep(5)

def zmqlistener(structname, dictdata):
    if structname is "BoreDoomButtonPressEvent":
        print "received "
        #  Dooom! The button has been pressed! Propably someone is bored and in need of company! ;-)
    else:
        print "Got data: " + structname + ":"+ str(dictdata)

if __name__ == "__main__":
    z = r3zmq()
    z.zmqloop(zmqlistener)