#!/usr/bin/env python3

from time import sleep

from apscheduler.schedulers.background import BlockingScheduler
from usv_driver import Usv
from influxdb import InfluxDBClient

import sys
import argparse
import logging

INTERVAL=14 # execution takes about 6s


parser = argparse.ArgumentParser()
parser.add_argument('--host', help='Database host', default='localhost')
parser.add_argument('--port', help='Database port', default='8086')
parser.add_argument('--db', help='Database name', default='test')
parser.add_argument('--serial', help='Serial port', default='/dev/ttyU0')
parser.add_argument('--baud', help='Serial baudrate', default='600')
parser.add_argument('--param', help='Parameter JSON file', default='./usv_param.json')
args = parser.parse_args(sys.argv[1:])

#scheduler = BlockingScheduler(timezone="Europe/Berlin")

db_client = InfluxDBClient(host=args.host,
        port=args.port,
        database=args.db)

logging.basicConfig(level=logging.ERROR, filename='log/usv_scheduler.log')

usv = Usv(args.serial, int(args.baud), args.param)
usv_lock = False

#@scheduler.scheduled_job('interval', seconds=INTERVAL)
def timed_job():
    global usv_lock

    if usv_lock:
        logging.info("JOB CURRENTLY LOCKED")
        return

    usv_lock = True
    parameters = usv.get_parameters()
    data = []
    for name in parameters:
        data.append({
            'measurement': 'usv_parameters',
            'tags': {
                'name': name,
                'id': 'LI????VA',
                },
            'fields': {'value': parameters[name]}
            });
    print("insert: %s" % ",".join("%s=%s" % \
            (name,parameters[name]) for name in parameters))
    
    try:
        db_client.write_points(data)
    except Exception as e:
        logging.error("%s" % e)

    usv_lock = False

while True:
    timed_job()
    sleep(24)

#scheduler.start()