# -*- coding: utf-8 -*-
from ws4py.client.threadedclient import WebSocketClient
import time

class EchoClient(WebSocketClient):

    def closed(self, code, reason):
        print(("Closed down", code, reason))

    def received_message(self, m):
        print("[server says:  %s]" % (str(m)))

    def snd(self, m):
        self.send(m)

if __name__ == '__main__':
    server = raw_input("host:port --> ")
    if (server == ""):
        server = "10.1.6.61:80"
    url = 'ws://' + server + '/ws/'
    try:

        ws = EchoClient(url, protocols=['http-only', 'chat'])
        ws.daemon = False
        ws.connect()
        while True:
            msg =  raw_input('--> ')
            if msg == "bye":
                break
            ws.snd(msg)
            time.sleep(1)
        ws.close()

    except KeyboardInterrupt:
        ws.close()
