#!/usr/bin/python

import paho.mqtt.client as mqtt
import opc,time

numLEDs = 400
client2 = opc.Client('localhost:7890')
mqtt_username = "username"
mqtt_password = "password"
mqtt_topic = "light"
mqtt_broker_ip = "ip_address"

client = mqtt.Client()
client.username_pw_set(mqtt_username, mqtt_password)


def on_connect(client, userdata,flag, rc):
    print "Connected!", str(rc)
    
    client.subscribe(mqtt_topic)
    
def on_message(client, userdata, msg):

    if "red" in msg.payload:
        tmp = msg.payload.strip().split()
        red = tmp[0].split(":")[1]
        green  = tmp[1].split(":")[1]
        blue  = tmp[2].split(":")[1]
        treecolor = [ (int(red),int(green),int(blue))] *numLEDs 
        client2.put_pixels(treecolor)
client.on_connect = on_connect
client.on_message = on_message


client.connect(mqtt_broker_ip, 1883)

client.loop_forever()
client.disconnect()