from influxdb import InfluxDBClient

from apscheduler.schedulers.background import BackgroundScheduler

#TODO

#fix temperature offset

#database series helper

#database time interval logging

config = configparser.ConfigParser(allow_no_value = True)

config.read("hydrobot.conf")

DEBUG_CAN = config.getboolean("debug", "can")

DEBUG_CAN_DETAIL = config.getboolean("debug", "can_detail")

class Database:

    def __init__(self):

        host = config.get("database", "host")

        port = config.get("database", "port")

        username = config.get("database", "username")

        password = config.get("database", "password")

        database = config.get("database", "database")

        self.name = config.get("system", "name")

        self.client = InfluxDBClient(host, port, username, password, database)

        self.relay_send_msg.Output2.value = 1

        self.relay_send_msg.Output3.value = 1

        self.relay_send_msg.Output4.value = 1

        if DEBUG_CAN:

            print("Send CAN message! ID: " + hex(self.relay_send_msg.id))

        if DEBUG_CAN_DETAIL:

            print(self.relay_send_msg)

        self.dev.send(self.relay_send_msg.encode())

    def set_output(self, module, output, state):

        msg = self.msgdb.lookup_message(module)

        msg.lookup_signal(output).value = state

        self.dev.send(msg.encode())

class Scheduler:

    def __init__(self, canbus):

        self.canbus = canbus

        self.apscheduler = BackgroundScheduler()

    def start(self):

        self.apscheduler.start()

        for section in config.sections():

                        off_time = ast.literal_eval(item[1])

                    if item[0] == 'on_duration':

                        on_duration = ast.literal_eval(item[1])

                    if item[0] == 'off_duration':

                        off_duration = ast.literal_eval(item[1])

                if trigger == 'cron':

                    self.apscheduler.add_job(self.canbus.set_output, trigger, [module, output, 1], day = on_time[0], day_of_week = on_time[1], hour = on_time[2], minute = on_time[3], second = on_time[4])

                    self.apscheduler.add_job(self.canbus.set_output, trigger, [module, output, 0], day = off_time[0], day_of_week = off_time[1], hour = off_time[2], minute = off_time[3], second = off_time[4])

                if trigger == 'interval':

                    self.apscheduler.add_job(self.interval_off, trigger, [module, output, section + "_off", section + "_on", on_duration], id = section + "_off", weeks = off_duration[0], days = off_duration[1], hours = off_duration[2], minutes = off_duration[3], seconds = off_duration[4])

                    timer = self.apscheduler.add_job(self.interval_on, trigger, [module, output, section + "_off", section + "_on", off_duration], id = section + "_on", weeks = on_duration[0], days = on_duration[1], hours = on_duration[2], minutes = on_duration[3], seconds = on_duration[4])

                    timer.pause()

    def interval_off(self, module, output, timer_off, timer_on, on_duration):

        self.canbus.set_output(module, output, 1)

        self.apscheduler.get_job(timer_on).reschedule("interval", weeks = on_duration[0], days = on_duration[1], hours = on_duration[2], minutes = on_duration[3], seconds = on_duration[4])

        self.apscheduler.get_job(timer_on).resume()

        self.apscheduler.get_job(timer_off).pause()

    def interval_on(self, module, output, timer_off, timer_on, off_duration):

        self.canbus.set_output(module, output, 0)

        self.apscheduler.get_job(timer_off).reschedule("interval", weeks = off_duration[0], days = off_duration[1], hours = off_duration[2], minutes = off_duration[3], seconds = off_duration[4])

        self.apscheduler.get_job(timer_off).resume()

        self.apscheduler.get_job(timer_on).pause()

def func():

    print(1)

def main():

    database = Database()

    canbus = CanBus(database)

    canbus.start()

    canbus.start_receive()

name: my-system

[database]

host: www.example.org

port: 8086

username: admin

password: admin

database: hydrobot

[debug]

can: True

can_detail: False

[timer1]

module: RelayDriveOut

output: Output1

trigger: cron

#day(1-31), weekday(0-6), hour(0-23), minute(0-59), second(0-59)

on_time: [None, None, None, None, 0]

off_time: [None, None, None, None, 30]

[timer2]

module: RelayDriveOut

output: Output2