"""Tcp client for asynchronous uhd message tcp port"""

import threading
import Queue
import time
import socket

class TcpAsyncClient(threading.Thread):
    """Thead for message polling"""
    queue = Queue.Queue()
    q_quit = Queue.Queue()

    ip_address = None
    port = None
    BUFFER_SIZE = 1

    def run(self, ip_address = "127.0.0.1", port = 47010):
        """connect and poll messages to queue"""

        self.ip_address = ip_address
        self.port = port


        #Establish connection
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        while 1:
            try:
                sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                sock.connect((self.ip_address, self.port))
                break
            except socket.error:
                print("connecting to asynchronous uhd message tcp port " + str(self.port))
                #traceback.print_exc()
                sock.close()
                time.sleep(0.5)

        #Read messages
        sock.settimeout(1)
        while self.q_quit.empty():
            try:
                data = sock.recv(self.BUFFER_SIZE)
                self.queue.put(data)
            except socket.timeout:
                pass

        sock.close()

    def stop(self):
        """stop thread"""
        print("stop tcp_async uhd message tcp thread")
        self.q_quit.put("end")


class UhdAsyncMsg(object):
    """Creates a thread to connect to the asynchronous uhd messages tcp port"""
    tcpa = TcpAsyncClient()

    def __init__(self):
        self.tcpa.start()

    def stop(self):
        """stop tcp thread"""
        self.tcpa.stop()

    def get_res(self):
        """get received messages as string of integer"""
        out = ""
        while not self.tcpa.queue.empty():
            out += str(ord(self.tcpa.queue.get()))
        return out

    def has_msg(self):
        """Checks if one or more messages were received and empties the message queue"""
        return self.get_res() != ""