how to send data to protoserver

'''
Kodi inspired.
'''


import socket
import struct


#protobuf message includes
from message_pb2 import HyperionRequest
from message_pb2 import HyperionReply
from message_pb2 import ColorRequest
from message_pb2 import ImageRequest
from message_pb2 import ClearRequest


import PIL.Image


class Hyperion(object):
    '''Hyperion connection class

    A Hyperion object will connect to the Hyperion server and provide
    easy to use functions to send requests

    Note that the function will block until a reply has been received
    from the Hyperion server (or the call has timed out)
    '''

    def __init__(self):
        '''Constructor
        - server : server address of Hyperion
        - port   : port number of Hyperion
        '''
        # create a new socket
        self.__socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.__socket.settimeout(2)

        server = "192.168.1.119"
        port = 19445

        # Connect socket to the provided server
        self.__socket.connect((server, port))

        print 'b'
        self.sendImage()
        print 'bc'


    def __del__(self):
        '''Destructor
        '''
        # close the socket
        self.__socket.close()


      
    #def sendImage(self, width, height, data, priority, duration = -1):
    def sendImage(self):
        '''Send an image to Hyperion
        - width    : width of the image
        - height   : height of the image
        - data     : image data (byte string containing 0xRRGGBB pixel values)
        - priority : the priority channel to use
        - duration : duration the leds should be set
        '''


        priority = 100
        duration = 5


        width = 180
        height = 144
#         f = open('white.png', 'r+')
#         data = f.read()
#         f.close()
        data = PIL.Image.open("white.png")

        #read data
        #data =

        # create the request
        request = HyperionRequest()
        request.command = HyperionRequest.IMAGE
        imageRequest = request.Extensions[ImageRequest.imageRequest]
        imageRequest.imagewidth = width
        imageRequest.imageheight = height
        imageRequest.imagedata = str(data)
        imageRequest.priority = priority
        imageRequest.duration = duration


        print imageRequest.imagedata


        # send the message
        self.__sendMessage(request)


    def __sendMessage(self, message):
        '''Send the given proto message to Hyperion. A RuntimeError will
        be raised if the reply contains an error
        - message : proto request to send
        '''
        #print "send message to Hyperion (%d):\n%s" % (len(message.SerializeToString()), message)


        # send message to Hyperion"
        binaryRequest = message.SerializeToString()
        binarySize = struct.pack(">I", len(binaryRequest))
        self.__socket.sendall(binarySize)
        self.__socket.sendall(binaryRequest);

        # receive a reply from Hyperion
        size = struct.unpack(">I", self.__socket.recv(4))[0]
        reply = HyperionReply()
        reply.ParseFromString(self.__socket.recv(size))

        print'a'

        # check the reply
        #print "Reply received:\n%s" % (reply)
        if not reply.success:
            raise RuntimeError("Hyperion server error: " + reply.error)




hyperiongo = Hyperion()