#!/usr/bin/env python3
# coding=utf-8
import websocket
#try:
#    import thread
#except ImportError:
#    import _thread as thread
#import time

def on_message(ws, message):
    print(message)

def on_error(ws, error):
    print(error)

def on_close(ws):
    print("### closed ###")

def on_open(ws):
#print("open succese!" )
    ws.send("hello bingo")
    #def run(*args):
    #    for i in range(3):
    #        time.sleep(1)
    #        ws.send("Hello %d" % i)
    #        time.sleep(1)
    #        ws.close()
    #        print("thread terminating...")
    #        thread.start_new_thread(run, ())

def web_test_thread(url):
    #websocket.enableTrace(True)
    ws = websocket.WebSocketApp(url,
                                #"ws://echo.websocket.org/",
                                on_message = on_message,
                                on_error = on_error,
                                on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()
    return 0

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("wss://www.nexbang.cn/smarthome/websocket",
                                #"ws://echo.websocket.org/",
                                on_message = on_message,
                                on_error = on_error,
                                on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()