import sqlite3 import json from wicd import misc import libs.websocket as websocket aria2_ws = "ws://localhost:6800/jsonrpc" @misc.threaded def game_install_thread(): pass def on_message(ws, message): print("got message") print(message) def on_error(ws, error): print(error) def on_close(ws): print("### closed ###") def on_open(ws): print "on open" def create_connection(db_file): conn = None try: conn = sqlite3.connect(db_file) return conn except Error as e: print(e) return conn def create_table(conn, create_table_sql): try: c = conn.cursor() c.execute(create_table_sql) except Error as e: print(e) def init_sqlite3(): database = r"aria2tasks.db" sql_create_tasks_table = """ CREATE TABLE IF NOT EXISTS tasks ( id integer PRIMARY KEY, gid text NOT NULL, status text, totalLength text, completedLength text ); """ conn = create_connection(database) if conn is not None: create_table(conn, sql_create_tasks_table) else: print("Error! cannot create the database connection.") exit() if __name__ == "__main__": init_sqlite3() websocket.enableTrace(True) ws = websocket.WebSocketApp(aria2_ws, on_message = on_message, on_error = on_error, on_close = on_close) # ws.on_open = on_open ws.run_forever()