import _thread

import ast

import configparser

import datetime

from canard import can, messaging

from canard.hw import socketcan

from canard.file import jsondb

from influxdb import InfluxDBClient

from influxdb import SeriesHelper

from apscheduler.schedulers.background import BackgroundScheduler

#TODO

#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")

DEBUG_TIMER = config.getboolean("debug", "timer")

class MySeriesHelper(SeriesHelper):

    # Meta class stores time series helper configuration.

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

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

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

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

        MySeriesHelper.Meta.client = self.client

        MySeriesHelper.Meta.series_name = self.name + '.{measurement}'

        # To manually submit data points which are not yet written, call commit:

        #MySeriesHelper.commit()

    def log_data(self, msgdb, message):

        if message == msgdb.AirSense:

            MySeriesHelper(measurement='air_temp', value=(float)(message.Temperature.value))

            MySeriesHelper(measurement='air_humidity', value=(float)(message.Humidity.value))

            MySeriesHelper(measurement='air_pressure', value=(float)(message.Pressure.value))

        if message == msgdb.RelayDriveIn:

            MySeriesHelper(measurement='input_1', value=(float)(message.Input1.value))

            MySeriesHelper(measurement='input_2', value=(float)(message.Input2.value))

            MySeriesHelper(measurement='input_3', value=(float)(message.Input3.value))

            MySeriesHelper(measurement='input_4', value=(float)(message.Input4.value))

        if message == msgdb.WaterSense:

            MySeriesHelper(measurement='water_level', value=(float)(message.PercentFull.value))

            MySeriesHelper(measurement='water_temp', value=(float)(message.Temperature.value))

            MySeriesHelper(measurement='water_raw_debug', value=(float)(message.RawDebug.value))

class CanBus:

        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():

            if "timer" in section:

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

        if DEBUG_TIMER:

            print("Turning " + timer_off + "! " + str(datetime.datetime.now().time()))

def func():

    print(1)

def main():

    database = Database()

    canbus = CanBus(database)

    canbus.start()

    canbus.start_receive()

    scheduler = Scheduler(canbus)

    scheduler.start()

    while True:

        time.sleep(1)

        "name": "RelayDriveOut",

        "id": "0x203",

        "signals": { "0": {"name": "Nothing", "bit_length": 32, "factor": 1, "offset": 0, "unit": ""},

                    "32": {"name": "Output1", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "40": {"name": "Output2", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "48": {"name": "Output3", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "56": {"name": "Output4", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"}

                   }

        },

        {

        "name": "RelayDriveIn",

        "id": "0x204",

                    "32": {"name": "Input1", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "40": {"name": "Input2", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "48": {"name": "Input3", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "56": {"name": "Input4", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"}

                   }

        },

        {

        "name": "Stuff",

        "id": "0x205",

        "signals": { "0": {"name": "Nothing", "bit_length": 32, "factor": 1, "offset": 0, "unit": ""},

                    "32": {"name": "Input1", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "40": {"name": "Input2", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "48": {"name": "Input3", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"},

                    "56": {"name": "Input4", "bit_length": 8, "factor": 1, "offset": 0, "unit": "bool"}

                   }

        },

        {

        "name": "WaterSense",

        "id": "0x206",

        "signals": { "0": {"name": "Nothing", "bit_length": 16, "factor": 1, "offset": 0, "unit": ""},

                   }

        }

    ]

}