rana-cli/wakatime/offlinequeue.py

132 lines
4.2 KiB
Python
Raw Normal View History

2014-05-26 00:14:38 +00:00
# -*- coding: utf-8 -*-
"""
wakatime.offlinequeue
~~~~~~~~~~~~~~~~~~~~~
2014-05-26 00:14:38 +00:00
Queue for saving heartbeats while offline.
2014-05-26 00:14:38 +00:00
:copyright: (c) 2014 Alan Hamlett.
:license: BSD, see LICENSE for more details.
"""
import logging
import os
from time import sleep
try:
import sqlite3
HAS_SQL = True
2015-09-07 01:22:05 +00:00
except ImportError: # pragma: nocover
HAS_SQL = False
2014-05-26 00:14:38 +00:00
from .compat import u
2014-05-26 00:14:38 +00:00
log = logging.getLogger('WakaTime')
2014-05-26 00:14:38 +00:00
class Queue(object):
db_file = '.wakatime.db'
table_name = 'heartbeat_1'
2014-05-26 00:14:38 +00:00
def get_db_file(self):
home = '~'
if os.environ.get('WAKATIME_HOME'):
home = os.environ.get('WAKATIME_HOME')
return os.path.join(os.path.expanduser(home), '.wakatime.db')
2014-05-26 00:14:38 +00:00
def connect(self):
conn = sqlite3.connect(self.get_db_file(), isolation_level=None)
2014-05-26 00:14:38 +00:00
c = conn.cursor()
c.execute('''CREATE TABLE IF NOT EXISTS {0} (
entity text,
type text,
2014-05-26 00:14:38 +00:00
time real,
project text,
branch text,
is_write integer,
stats text,
misc text,
2014-05-26 00:14:38 +00:00
plugin text)
'''.format(self.table_name))
2014-05-26 00:14:38 +00:00
return (conn, c)
2014-12-22 06:42:42 +00:00
def push(self, data, stats, plugin, misc=None):
if not HAS_SQL: # pragma: nocover
return
2014-05-26 21:05:54 +00:00
try:
conn, c = self.connect()
heartbeat = {
'entity': u(data.get('entity')),
'type': u(data.get('type')),
2014-05-26 21:05:54 +00:00
'time': data.get('time'),
'project': u(data.get('project')),
'branch': u(data.get('branch')),
2014-05-26 21:05:54 +00:00
'is_write': 1 if data.get('is_write') else 0,
'stats': u(stats),
'misc': u(misc),
'plugin': u(plugin),
2014-05-26 21:05:54 +00:00
}
c.execute('INSERT INTO {0} VALUES (:entity,:type,:time,:project,:branch,:is_write,:stats,:misc,:plugin)'.format(self.table_name), heartbeat)
2014-05-26 21:05:54 +00:00
conn.commit()
conn.close()
2014-05-27 03:02:30 +00:00
except sqlite3.Error:
2016-06-16 06:02:56 +00:00
log.traceback()
2014-05-26 00:14:38 +00:00
def pop(self):
if not HAS_SQL: # pragma: nocover
return None
2014-05-26 00:14:38 +00:00
tries = 3
wait = 0.1
heartbeat = None
2014-05-26 21:05:54 +00:00
try:
conn, c = self.connect()
2014-05-27 03:02:30 +00:00
except sqlite3.Error:
log.traceback(logging.DEBUG)
2014-05-26 21:05:54 +00:00
return None
2014-05-26 00:14:38 +00:00
loop = True
while loop and tries > -1:
try:
c.execute('BEGIN IMMEDIATE')
c.execute('SELECT * FROM {0} LIMIT 1'.format(self.table_name))
2014-05-26 00:14:38 +00:00
row = c.fetchone()
if row is not None:
values = []
clauses = []
index = 0
for row_name in ['entity', 'type', 'time', 'project', 'branch', 'is_write']:
if row[index] is not None:
clauses.append('{0}=?'.format(row_name))
values.append(row[index])
2015-09-27 10:32:28 +00:00
else: # pragma: nocover
clauses.append('{0} IS NULL'.format(row_name))
index += 1
if len(values) > 0:
c.execute('DELETE FROM {0} WHERE {1}'.format(self.table_name, ' AND '.join(clauses)), values)
2015-09-27 10:32:28 +00:00
else: # pragma: nocover
c.execute('DELETE FROM {0} WHERE {1}'.format(self.table_name, ' AND '.join(clauses)))
2014-05-26 00:14:38 +00:00
conn.commit()
if row is not None:
heartbeat = {
'entity': row[0],
'type': row[1],
'time': row[2],
'project': row[3],
'branch': row[4],
'is_write': True if row[5] is 1 else False,
'stats': row[6],
'misc': row[7],
'plugin': row[8],
2014-05-26 00:14:38 +00:00
}
loop = False
2015-09-07 01:22:05 +00:00
except sqlite3.Error: # pragma: nocover
log.traceback(logging.DEBUG)
2014-05-26 00:14:38 +00:00
sleep(wait)
tries -= 1
2014-05-26 21:05:54 +00:00
try:
conn.close()
2015-09-07 01:22:05 +00:00
except sqlite3.Error: # pragma: nocover
log.traceback(logging.DEBUG)
return heartbeat