client.py

import paho.mqtt.client as mqtt
import re
import sys
reload(sys)
sys.setdefaultencoding('utf-8')
from src import lights

light = lights.Lights()
rg_set = re.compile(light.topic_sub.format(group_name='(.*?)',light_name='(.*?)').replace('/','\\/'))
rg_status = re.compile(light.topic_status.format(group_name='(.*?)',light_name='(.*?)').replace('/','\\/'))

# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
	#print("Connected with result code "+str(rc))

	# Subscribing in on_connect() means that if we lose the connection and
	# reconnect then subscriptions will be renewed.
	client.subscribe("deconz/#")

# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
	#print(msg.topic+" "+str(msg.payload))
	m = rg_set.search(msg.topic)
	if m:
		light_name = m.group(2)
		light.set_light(light_name, msg.payload)

	m = rg_status.search(msg.topic)
	if m:
		light_name = m.group(2)
		light.get_light(light_name)



client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect(light.mqtt_ip, light.mqtt_port, 60)

# Publish the status of all lights
light.get_lights()

# Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a
# manual interface.
client.loop_forever()