adding some common stuff, less code replica

1 files changed, 21 insertions, 0 deletions

diff --git a/common/queue.py b/common/queue.py
new file mode 100644
index 0000000..7804c8d
--- /dev/null
+++ b/common/queue.py
@@ -0,0 +1,21 @@
+#!/usr/bin/env python3
+''' common functions and stuff '''
+
+import os
+import sys
+import pickle
+from litequeue import SQLQueue
+
+QUEUE_DB = os.environ.get('el_QUEUE_db', 'litequeue.db')
+
+# Initialize queue
+q = SQLQueue(QUEUE_DB, maxsize=None)
+
+def dbi(sql,values,**kwargs):
+    print("lolqu")
+    verbose = bool(kwargs['verbose']) if 'verbose' in kwargs else False
+
+    q.put(pickle.dumps([sql, values]))
+    if verbose is True:
+        print("Inserted into queue")
+    return True