I played around with this code a little and was able to find a way to speak to a particular set of lamps (given their IP addresses are known) by simply jumping over the discovery section of the script altogether and just make a socket connection for each individual bulb by simply inputing the IP addresses directly. This is probably the most inelegant way to do this, but hey it works. I'm not even remotely a coder, I don't even really know what I was doing exactly, but for the interested, here's the changed code:
Code:
import xbmc
import xbmcaddon
import xbmcgui
import os
import socket
import sys
import binascii
import colorsys
import struct
from binascii import unhexlify
def long_to_bytes (val):
val = long(val);
val = struct.pack('<Q',val);
val = val[::-1]
val = ''.join( [ "%02X" % ord( x ) for x in val ] ).strip();
return val[12:16]
"""def get_bulb_ip ():
sender = socket.socket(socket.AF_INET, socket.SOCK_DGRAM);
sender.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
sender.connect(('255.255.255.255', 56700));
listener = socket.socket(socket.AF_INET, socket.SOCK_DGRAM);
listener.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
listener.bind(('',56700));
ownIp = socket.gethostbyname(socket.gethostname());
packetArray = bytearray([0x24, 0x00, 0x00, 0x34, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x65, 0x00, 0x00, 0x00])
sender.send(packetArray);
sender.close();
deviceIp = ownIp;
while deviceIp == ownIp:
data, addr =listener.recvfrom(2048);
deviceIp = addr[0];
listener.close();
sender.close();
return addr[0];
"""
useLegacyApi = True
capture = xbmc.RenderCapture()
if useLegacyApi:
capture.capture(32, 32, xbmc.CAPTURE_FLAG_CONTINUOUS)
host1 = '192.168.1.12'
host2 = '192.168.1.13'
host3 = '192.168.1.14'
port = 56700
s1 = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
s1.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
s1.connect((host1, port))
s2 = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
s2.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
s2.connect((host2, port))
s3 = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
s3.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
s3.connect((host3, port))
class PlayerMonitor( xbmc.Player ):
def __init__( self, *args, **kwargs ):
xbmc.Player.__init__( self )
def onPlayBackStarted( self ):
if not useLegacyApi:
capture.capture(32, 32)
while not xbmc.abortRequested:
xbmc.sleep(100)
if capture.getCaptureState() == xbmc.CAPTURE_STATE_DONE:
width = capture.getWidth();
height = capture.getHeight();
pixels = capture.getImage(1000);
if useLegacyApi:
capture.waitForCaptureStateChangeEvent(1000)
pixels = capture.getImage(1000)
red = [];
green = [];
blue = [];
for y in range(height):
row = width * y * 4
for x in range(width):
red.append(pixels[row + x * 4 + 2]);
green.append(pixels[row + x * 4 + 1]);
blue.append(pixels[row + x * 4]);
red = (sum(red)/len(red))/255.00;
green = (sum(green)/len(green))/255.00;
blue = (sum(blue)/len(blue))/255.00;
hsb = colorsys.rgb_to_hsv(red, green, blue);
huevalue = int(hsb[0]*65535);
huevalueHex = long_to_bytes(huevalue);
satvalue = int(hsb[1]*65535);
satvalueHex = long_to_bytes(satvalue);
brightnessvalue = int(hsb[2]*65535);
brightnessvalueHex = long_to_bytes(brightnessvalue);
packetArray = bytearray([0x31,0x00,0x00,0x34,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x66,0x00,0x00,0x00,0x00,0x55,0x55,0xFF,0xFF,0xFF,0xFF,0xAC,0x0D,0x00,0x00,0x00,0x00])
packetArray[38] = unhexlify(huevalueHex[0:2]);
packetArray[37] = unhexlify(huevalueHex[2:4]);
packetArray[40] = unhexlify(satvalueHex[0:2]);
packetArray[39] = unhexlify(satvalueHex[2:4]);
packetArray[43] = unhexlify(brightnessvalueHex[0:2]);
packetArray[42] = unhexlify(brightnessvalueHex[2:4]);
try:
s1.send(packetArray);
s2.send(packetArray);
s3.send(packetArray);
except:
print "Caught exception socket.error"
s.close()
if ( __name__ == "__main__" ):
player_monitor = PlayerMonitor()
try:
capture.getCaptureState()
except AttributeError:
useLegacyApi = False
You have to change the number of hosts, IP addresses etc. so it reflects your local setup of course. have fun.
