#!micropython
print("Start main.py")

import os
import machine
import socket
import time
import micropython as mp


HOST = config['CONFIG_INFLUXDB_HOST']
PORT = config['CONFIG_INFLUXDB_PORT']
PATH = config['CONFIG_INFLUXDB_PATH']

H_REQUEST = bytes('POST /%s HTTP/1.1\r\n' % PATH, 'utf8')
H_HOST = bytes('Host: %s\r\n' % HOST, 'utf8')
H_CONTENT_TYPE = bytes('Content-Type: application/x-www-urlencoded\r\n', 'utf8')
H_CONTENT_LENGTH = bytes('Content-Length: %s\r\n', 'utf8')
H_CONNECTION = bytes('Connection: close\r\n', 'utf8')
H_NL = bytes('\r\n', 'utf8')

def post(data):
    print('[%d] Send HTTP POST: %s. Response: ' % (time.ticks_ms(), data), end='')
    addr = socket.getaddrinfo(HOST, PORT)[0][-1]
    data = bytes(data, 'utf8')
    s = socket.socket()
    s.connect(addr)
    s.send(H_REQUEST)
    s.send(H_HOST)
    s.send(H_CONTENT_TYPE)
    s.send(H_CONTENT_LENGTH % len(data))
    s.send(H_CONNECTION)
    s.send(H_NL)
    s.send(data)

    first_data = s.recv(100)
    if first_data:
        line, *_ = first_data.split(b'\r\n')
        print(line, end='')
        while data:
            data = s.recv(100)
    s.close()
    print('')

d4_total = 0
d4_count = 0

d1_total = 0
d1_count = 0

def update(t):
    global d4_total, d4_count, d1_total, d1_count
    d4 = d4_count
    d1 = d1_count
    post('stromzaehler3 d4_count=%d,d4_total=%d,d1_count=%d,d1_total=%d' % (
        d4, d4_total, d1, d1_total))
    d4_count -= d4
    d1_count -= d1

timer1 = machine.Timer(-1)
timer1.init(period=10000, mode=machine.Timer.PERIODIC, callback=update)

def persist(t):
    write_persistent_int("d4_total.txt", d4_total)
    write_persistent_int("d1_total.txt", d1_total)


# Import
def cb_d4(p):
    global d4_total, d4_count
    v = p.value()
    if v != 1: # skip rising edge
        d4_total += 1
        d4_count += 1

d4 = machine.Pin(2, machine.Pin.IN, pull=machine.Pin.PULL_UP)
d4.irq(handler=lambda p: mp.schedule(cb_d4, p))

# Export
def cb_d1(p):
    global d1_total, d1_count
    v = p.value()
    if v != 1: # skip rising edge
        d1_count += 1
        d1_total += 1

d1 = machine.Pin(5, machine.Pin.IN)
d1.irq(handler=lambda p: mp.schedule(cb_d1, p))

# Pumpe
d3_last_value = 0

def cb_d3(p):
    global d3_last_value
    print('[%d] %s = %d' % (time.ticks_ms(), repr(p), p.value()))
    v = 1 - p.value()
    if v != d3_last_value:
        post('stromzaehler3.Pumpe Status=%s' % v)
        d3_last_value = v

d3 = machine.Pin(0, machine.Pin.IN, pull=machine.Pin.PULL_UP)
d3.irq(handler=lambda p: mp.schedule(cb_d3, p))

print("main.py finished")