create daemon db table if it doesn't exist
parent
65ea5cf6f0
commit
6fd0f9aded
|
@ -371,26 +371,35 @@ class Core:
|
||||||
'''
|
'''
|
||||||
retData = False
|
retData = False
|
||||||
if not os.path.exists(self.queueDB):
|
if not os.path.exists(self.queueDB):
|
||||||
conn = sqlite3.connect(self.queueDB)
|
self.makeDaemonDB()
|
||||||
c = conn.cursor()
|
|
||||||
# Create table
|
|
||||||
c.execute('''CREATE TABLE commands
|
|
||||||
(id integer primary key autoincrement, command text, data text, date text)''')
|
|
||||||
conn.commit()
|
|
||||||
else:
|
else:
|
||||||
conn = sqlite3.connect(self.queueDB)
|
conn = sqlite3.connect(self.queueDB)
|
||||||
c = conn.cursor()
|
c = conn.cursor()
|
||||||
for row in c.execute('SELECT command, data, date, min(ID) FROM commands group by id'):
|
try:
|
||||||
retData = row
|
for row in c.execute('SELECT command, data, date, min(ID) FROM commands group by id'):
|
||||||
break
|
retData = row
|
||||||
if retData != False:
|
break
|
||||||
c.execute('DELETE FROM commands WHERE id=?;', (retData[3],))
|
except sqlite3.OperationalError:
|
||||||
|
self.makeDaemonDB()
|
||||||
|
else:
|
||||||
|
if retData != False:
|
||||||
|
c.execute('DELETE FROM commands WHERE id=?;', (retData[3],))
|
||||||
conn.commit()
|
conn.commit()
|
||||||
conn.close()
|
conn.close()
|
||||||
|
|
||||||
events.event('queue_pop', data = {'data': retData}, onionr = None)
|
events.event('queue_pop', data = {'data': retData}, onionr = None)
|
||||||
|
|
||||||
return retData
|
return retData
|
||||||
|
|
||||||
|
def makeDaemonDB(self):
|
||||||
|
'''generate the daemon queue db'''
|
||||||
|
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()
|
||||||
|
conn.close()
|
||||||
|
|
||||||
def daemonQueueAdd(self, command, data=''):
|
def daemonQueueAdd(self, command, data=''):
|
||||||
'''
|
'''
|
||||||
|
|
Loading…
Reference in New Issue