From 7e0d5dec8a6b7ae014551e954de9144669158297 Mon Sep 17 00:00:00 2001
From: Kevin Froman <beardog@firemail.cc>
Date: Thu, 4 Jan 2018 01:12:46 -0600
Subject: [PATCH] finished core.py main functionality

---
 core.py | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

diff --git a/core.py b/core.py
index 3d994403..da6d9962 100644
--- a/core.py
+++ b/core.py
@@ -17,26 +17,38 @@ import sqlite3, os, time, math
 class Core:
     def __init__(self):
         self.queueDB = 'data/queue.db'
-        self.daemonQueue() # Call to create the DB if it doesn't exist
+        #self.daemonQueue() # Call to create the DB if it doesn't exist
         return
 
     def daemonQueue(self):
+        # This function intended to be used by the client
         # Queue to exchange data between "client" and server.
         retData = False
-        conn = sqlite3.connect(self.queueDB)
-        c = conn.cursor()
         if not os.path.exists(self.queueDB):
+            conn = sqlite3.connect(self.queueDB)
+            c = conn.cursor()
             # Create table
             c.execute('''CREATE TABLE commands
                         (id integer primary key autoincrement, command text, data text, date text)''')
             conn.commit()
+            print('created table')
         else:
-            retData = c.execute('SELECT command, data, date, min(ID) FROM commands group by id')[0]
+            conn = sqlite3.connect(self.queueDB)
+            c = conn.cursor()
+            for row in c.execute('SELECT command, data, date, min(ID) FROM commands group by id'):
+                retData = row
+                print(retData)
+                break
+            if retData != False:
+                print('3', retData[3])
+                c.execute('delete from commands where id = ?', (retData[3],))
+        conn.commit()
         conn.close()
 
         return retData
 
     def daemonQueueAdd(self, command, data=''):
+        # Intended to be used by the web server
         date = math.floor(time.time())
         conn = sqlite3.connect(self.queueDB)
         c = conn.cursor()