1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374 |
- 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()
|