#!/usr/bin/env python3
"""
Wetterstation Ingestion Service - HTTP-POST Datenempfang
Empfängt Wetterdaten via POST und speichert sie in der Datenbank
"""

import sqlite3
import os
from flask import Flask, jsonify, request
from dotenv import load_dotenv

# Lade Umgebungsvariablen aus .env Datei
load_dotenv()

# Konfiguration aus Umgebungsvariablen
DB_FILE = os.getenv("DB_FILE", "wetterdaten.db")
HTTP_PORT = int(os.getenv("INGESTION_PORT", 5004))

app = Flask(__name__)
app.url_map.strict_slashes = False


class WetterDB:
    """Klasse für Datenbankoperationen"""
    
    def __init__(self, db_file):
        self.db_file = db_file
        self.init_db()
    
    def init_db(self):
        """Datenbank initialisieren"""
        conn = sqlite3.connect(self.db_file)
        cursor = conn.cursor()
        cursor.execute('''
            CREATE TABLE IF NOT EXISTS wetterdaten (
                id INTEGER PRIMARY KEY AUTOINCREMENT,
                dateTime INTEGER NOT NULL,
                barometer REAL,
                outTemp REAL,
                outHumidity INTEGER,
                windSpeed REAL,
                windDir REAL,
                windGust REAL,
                rainRate REAL,
                rain REAL
            )
        ''')
        cursor.execute('''
            CREATE INDEX IF NOT EXISTS idx_dateTime ON wetterdaten(dateTime)
        ''')
        conn.commit()
        conn.close()
    
    def save_data(self, data):
        """Wetterdaten speichern"""
        conn = sqlite3.connect(self.db_file)
        cursor = conn.cursor()
        cursor.execute('''
            INSERT INTO wetterdaten 
            (dateTime, barometer, outTemp, outHumidity, windSpeed, windDir, windGust, rainRate, rain)
            VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
        ''', (
            data.get('dateTime'),
            data.get('barometer'),
            data.get('outTemp'),
            data.get('outHumidity'),
            data.get('windSpeed'),
            data.get('windDir'),
            data.get('windGust'),
            data.get('rainRate'),
            data.get('rain')
        ))
        conn.commit()
        conn.close()
        print(f"Daten gespeichert: {data.get('dateTime')}")


# Globale Datenbankinstanz
db = WetterDB(DB_FILE)


# Flask Routes
@app.route('/health')
def health():
    """Health-Check Endpoint"""
    return jsonify({'status': 'ok', 'service': 'ingestion'}), 200


# @app.route('/api/data/upload', methods=['POST'])
@app.route('/api/data/upload/', methods=['POST'])
def upload_data():
    """HTTP-POST Endpoint für Wetterdaten"""
    try:
        data = request.get_json()
        
        if not data:
            return jsonify({'error': 'Keine Daten empfangen'}), 400
        
        # Daten speichern
        db.save_data(data)
        
        return jsonify({
            'status': 'success',
            'message': 'Daten empfangen und gespeichert'
        }), 200
    
    except Exception as e:
        print(f"Fehler beim Verarbeiten der POST-Anfrage: {e}")
        return jsonify({'error': str(e)}), 400


def main():
    """Hauptprogramm"""
    print("Wetterstation Ingestion Service wird gestartet...")
    print(f"\nHTTP-POST Endpoint: http://0.0.0.0:{HTTP_PORT}/api/data/upload")
    print(f"Health-Check: http://0.0.0.0:{HTTP_PORT}/health")
    print("Drücke CTRL+C zum Beenden\n")
    app.run(host='0.0.0.0', port=HTTP_PORT, debug=False)


if __name__ == '__main__':
    main()