PYTHON (ZMQ CLIENT - REQ)

__author__ = 'maqister'

import zmq
import rpi_protocol_pb2
import sys
reload(sys)
sys.setdefaultencoding("utf-8")

context = zmq.Context()

#  Socket to talk to server
print("Connecting to hello world server...")
socket = context.socket(zmq.REQ)
socket.connect("tcp://192.168.0.10:5555")

#  Do 10 requests, waiting each time for a response
for correlator in range(10):

    print("Sending request %s..." % correlator)

    request = rpi_protocol_pb2.Message()
    request.type = rpi_protocol_pb2.Message.REQUEST
    request.command = rpi_protocol_pb2.Message.GET_SYS_INFO
    request.version = 12
    request.correlator = correlator

    socket.send(request.SerializeToString())

    #  Get the reply.
    message = socket.recv()
    #xx = z85.decode(message)
    print len(message)
    print ':'.join(x.encode('hex') for x in str(message))
    response = rpi_protocol_pb2.Message()

    # This line fails
    response.ParseFromString(message)

    print("Received reply %s [ %s ]" % (correlator, message))