from inputs.snap7_connect import SiemensCPU
from database.influxdb import Point, Database
from datetime import datetime
import time

localtz = datetime.now().astimezone().tzinfo

db = Database()

cpu = SiemensCPU()

cpu.connect("10.0.10.1", 0, 0)
cpu.get_connected()

print(cpu.synchronize())

while True:
  values = cpu.read()
  print(values)
  points = []
  for timestamp, value in values:
    date = datetime.fromtimestamp(timestamp, localtz)
    p = Point("24v").time(date).tag("cpu", "siemens").field("current", value)
    points.append(p)
  db.write(points)

  time.sleep(cpu.interval * 0.9)