2013-07-08 01:38:01 +00:00
|
|
|
# -*- coding: utf-8 -*-
|
2013-07-09 02:28:45 +00:00
|
|
|
"""
|
2015-09-29 10:11:25 +00:00
|
|
|
wakatime.main
|
2015-03-09 22:23:29 +00:00
|
|
|
~~~~~~~~~~~~~
|
2013-07-08 01:38:01 +00:00
|
|
|
|
2017-02-21 00:18:38 +00:00
|
|
|
Module entry point.
|
2013-07-08 01:38:01 +00:00
|
|
|
|
|
|
|
:copyright: (c) 2013 Alan Hamlett.
|
|
|
|
:license: BSD, see LICENSE for more details.
|
|
|
|
"""
|
|
|
|
|
|
|
|
from __future__ import print_function
|
|
|
|
|
|
|
|
import logging
|
|
|
|
import os
|
|
|
|
import sys
|
|
|
|
import traceback
|
|
|
|
|
2016-03-06 20:48:42 +00:00
|
|
|
pwd = os.path.dirname(os.path.abspath(__file__))
|
|
|
|
sys.path.insert(0, os.path.dirname(pwd))
|
|
|
|
sys.path.insert(0, os.path.join(pwd, 'packages'))
|
2014-06-09 20:18:30 +00:00
|
|
|
|
2015-03-09 22:23:29 +00:00
|
|
|
from .__about__ import __version__
|
2017-11-09 07:12:05 +00:00
|
|
|
from .api import send_heartbeats
|
|
|
|
from .arguments import parse_arguments
|
|
|
|
from .compat import u, json
|
2017-11-09 17:09:28 +00:00
|
|
|
from .constants import SUCCESS, UNKNOWN_ERROR
|
2015-04-04 18:03:55 +00:00
|
|
|
from .logger import setup_logging
|
2017-05-25 06:53:28 +00:00
|
|
|
|
|
|
|
log = logging.getLogger('WakaTime')
|
|
|
|
|
2017-11-09 07:12:05 +00:00
|
|
|
from .heartbeat import Heartbeat
|
2015-05-12 22:03:23 +00:00
|
|
|
from .offlinequeue import Queue
|
2016-04-28 22:04:46 +00:00
|
|
|
|
|
|
|
|
2015-09-29 10:11:25 +00:00
|
|
|
def execute(argv=None):
|
|
|
|
if argv:
|
|
|
|
sys.argv = ['wakatime'] + argv
|
2013-12-13 14:35:49 +00:00
|
|
|
|
2017-11-09 07:12:05 +00:00
|
|
|
args, configs = parse_arguments()
|
2013-12-13 14:35:49 +00:00
|
|
|
|
2013-07-08 01:38:01 +00:00
|
|
|
setup_logging(args, __version__)
|
2013-12-13 14:35:49 +00:00
|
|
|
|
2016-01-06 21:57:03 +00:00
|
|
|
try:
|
2017-11-09 07:12:05 +00:00
|
|
|
heartbeats = []
|
2016-01-06 21:57:03 +00:00
|
|
|
|
2017-11-09 07:12:05 +00:00
|
|
|
hb = Heartbeat(vars(args), args, configs)
|
|
|
|
if hb:
|
|
|
|
heartbeats.append(hb)
|
|
|
|
else:
|
|
|
|
log.debug(hb.skip)
|
2016-04-28 22:04:46 +00:00
|
|
|
|
|
|
|
if args.extra_heartbeats:
|
|
|
|
try:
|
2017-11-09 07:12:05 +00:00
|
|
|
for extra_data in json.loads(sys.stdin.readline()):
|
|
|
|
hb = Heartbeat(extra_data, args, configs)
|
|
|
|
if hb:
|
|
|
|
heartbeats.append(hb)
|
|
|
|
else:
|
|
|
|
log.debug(hb.skip)
|
|
|
|
except json.JSONDecodeError as ex:
|
|
|
|
log.warning(u('Malformed extra heartbeats json: {msg}').format(
|
|
|
|
msg=u(ex),
|
|
|
|
))
|
2016-04-28 22:04:46 +00:00
|
|
|
|
2017-11-09 07:12:05 +00:00
|
|
|
retval = send_heartbeats(heartbeats, args, configs)
|
2016-04-28 22:04:46 +00:00
|
|
|
if retval == SUCCESS:
|
2017-11-09 07:12:05 +00:00
|
|
|
queue = Queue(args, configs)
|
|
|
|
offline_heartbeats = queue.pop_many()
|
|
|
|
if len(offline_heartbeats) > 0:
|
|
|
|
retval = send_heartbeats(offline_heartbeats, args, configs)
|
2016-04-28 22:04:46 +00:00
|
|
|
|
|
|
|
return retval
|
2013-12-13 14:35:49 +00:00
|
|
|
|
2016-01-06 21:57:03 +00:00
|
|
|
except:
|
2016-09-02 08:50:54 +00:00
|
|
|
log.traceback(logging.ERROR)
|
2016-04-28 22:04:46 +00:00
|
|
|
print(traceback.format_exc())
|
2016-03-06 22:13:27 +00:00
|
|
|
return UNKNOWN_ERROR
|