#!/usr/bin/env python3
"""
database.py – Modul für SQLite‑Datenbank
"""
import sqlite3
import os
import datetime

DB_PATH = os.path.join(os.path.dirname(__file__), 'growcontrol.db')

def init_db():
    conn = sqlite3.connect(DB_PATH)
    c = conn.cursor()
    c.execute('''
        CREATE TABLE IF NOT EXISTS measurements (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            timestamp TEXT NOT NULL,
            temperature REAL,
            humidity REAL
        )
    ''')
    conn.commit()
    conn.close()

def insert_measurement(temperature, humidity):
    conn = sqlite3.connect(DB_PATH)
    c = conn.cursor()
    ts = datetime.datetime.utcnow().isoformat()
    c.execute('INSERT INTO measurements (timestamp, temperature, humidity) VALUES (?, ?, ?)',
              (ts, temperature, humidity))
    conn.commit()
    conn.close()

def get_measurements_since(timestamp):
    conn = sqlite3.connect(DB_PATH)
    c = conn.cursor()
    c.execute('''
        SELECT timestamp, temperature, humidity
        FROM measurements
        WHERE timestamp >= ?
        ORDER BY timestamp ASC
    ''', (timestamp,))
    rows = c.fetchall()
    conn.close()
    return rows