import zmq
import time
import msgpack

ctx = zmq.Context()
pupil_remote = zmq.Socket(ctx, zmq.REQ)
pupil_remote.connect('tcp://164.8.66.61:50020')
print("povezan")
pupil_remote.send_string('v')
print(pupil_remote.recv_string())
pupil_remote.send_string('SUB_PORT')
sub_port = pupil_remote.recv_string()
print("sub port: ", sub_port)
subscriber = ctx.socket(zmq.SUB)
pupil_remote.send_string('R')
print(pupil_remote.recv_string())
subscriber.connect(f'tcp://164.8.66.61:{sub_port}')
subscriber.subscribe('pupil') 
subscriber.subscribe('gaze') 

t_end = time.time() + 10

while time.time() < t_end:
    print ("-----------------------------------------------------")
    time.sleep(1)
    topic, payload = subscriber.recv_multipart()
    message = msgpack.loads(payload)
    print(f"{topic}: {message}")


pupil_remote.send_string('r')
print(pupil_remote.recv_string())