appinstaller.py 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. import sqlite3
  2. import json
  3. from wicd import misc
  4. import libs.websocket as websocket
  5. aria2_ws = "ws://localhost:6800/jsonrpc"
  6. @misc.threaded
  7. def game_install_thread():
  8. pass
  9. def on_message(ws, message):
  10. print("got message")
  11. print(message)
  12. def on_error(ws, error):
  13. print(error)
  14. def on_close(ws):
  15. print("### closed ###")
  16. def on_open(ws):
  17. print "on open"
  18. def create_connection(db_file):
  19. conn = None
  20. try:
  21. conn = sqlite3.connect(db_file)
  22. return conn
  23. except Error as e:
  24. print(e)
  25. return conn
  26. def create_table(conn, create_table_sql):
  27. try:
  28. c = conn.cursor()
  29. c.execute(create_table_sql)
  30. except Error as e:
  31. print(e)
  32. def init_sqlite3():
  33. database = r"aria2tasks.db"
  34. sql_create_tasks_table = """ CREATE TABLE IF NOT EXISTS tasks (
  35. id integer PRIMARY KEY,
  36. gid text NOT NULL,
  37. status text,
  38. totalLength text,
  39. completedLength text
  40. ); """
  41. conn = create_connection(database)
  42. if conn is not None:
  43. create_table(conn, sql_create_tasks_table)
  44. else:
  45. print("Error! cannot create the database connection.")
  46. exit()
  47. if __name__ == "__main__":
  48. init_sqlite3()
  49. websocket.enableTrace(True)
  50. ws = websocket.WebSocketApp(aria2_ws,
  51. on_message = on_message,
  52. on_error = on_error,
  53. on_close = on_close)
  54. # ws.on_open = on_open
  55. ws.run_forever()