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

#fix temperature offsets

#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.

    class Meta:

        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='water_flow_rate', value=(float)(message.FlowRate.value))

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

class CanBus:

    def __init__(self, database):

        self.database = database

        self.dev = socketcan.SocketCanDev("can0")

        parser = jsondb.JsonDbParser()

        self.msgdb = parser.parse('hydrobot_can.json')

        "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",

                   }

        }

    ]

}