From d5a27e1ee5e6d7cae08f2591ef91a2086edee515 Mon Sep 17 00:00:00 2001
From: Mika <kontakt@donau2space.de>
Date: Sun, 31 May 2026 02:06:40 +0000
Subject: [PATCH] Add data_analysis/src/data_analysis/cli.py

---
 data_analysis/src/data_analysis/cli.py | 76 ++++++++++++++++++++++++++
 1 file changed, 76 insertions(+)
 create mode 100644 data_analysis/src/data_analysis/cli.py

diff --git a/data_analysis/src/data_analysis/cli.py b/data_analysis/src/data_analysis/cli.py
new file mode 100644
index 0000000..f5e7f79
--- /dev/null
+++ b/data_analysis/src/data_analysis/cli.py
@@ -0,0 +1,76 @@
+import argparse
+import json
+import sys
+from pathlib import Path
+import pandas as pd
+
+from data_analysis.core import analyze_temperature_data
+
+
+class CLIError(Exception):
+    """Custom exception for CLI-related errors."""
+
+
+def parse_arguments() -> argparse.Namespace:
+    """Parses command-line arguments for input and output paths."""
+    parser = argparse.ArgumentParser(
+        description="Analyse von Infrarot-Temperaturdaten und Erzeugung einer JSON-Zusammenfassung."
+    )
+    parser.add_argument(
+        "--input",
+        required=True,
+        help="Pfad zur CSV-Datei mit Temperaturmessdaten."
+    )
+    parser.add_argument(
+        "--output",
+        required=True,
+        help="Pfad zur JSON-Datei mit Analyseergebnissen."
+    )
+    return parser.parse_args()
+
+
+def validate_paths(input_path: Path, output_path: Path) -> None:
+    """Validates that input file exists and output directory is writable."""
+    if not input_path.exists():
+        raise CLIError(f"Eingabedatei nicht gefunden: {input_path}")
+    if not input_path.is_file():
+        raise CLIError(f"Eingabepfad ist keine Datei: {input_path}")
+    output_dir = output_path.parent
+    output_dir.mkdir(parents=True, exist_ok=True)
+
+
+def main() -> None:
+    """Main CLI entrypoint for the data analysis pipeline."""
+    try:
+        args = parse_arguments()
+        input_path = Path(args.input)
+        output_path = Path(args.output)
+        validate_paths(input_path, output_path)
+
+        # Load the CSV data
+        data = pd.read_csv(input_path)
+        assert not data.empty, "Die Eingabedatei enthält keine Daten."
+        required_columns = {"surface", "temperature_c", "emissivity", "timestamp"}
+        if not required_columns.issubset(data.columns):
+            missing = required_columns - set(data.columns)
+            raise CLIError(f"Fehlende erforderliche Spalten: {', '.join(missing)}")
+
+        # Perform analysis
+        result = analyze_temperature_data(data)
+
+        # Write output JSON
+        with open(output_path, 'w', encoding='utf-8') as f:
+            json.dump(json.loads(result.to_json()), f, indent=2, ensure_ascii=False)
+
+        print(f"Analyse abgeschlossen. Ergebnisse gespeichert in: {output_path}")
+
+    except (CLIError, AssertionError) as e:
+        print(f"Fehler: {e}", file=sys.stderr)
+        sys.exit(1)
+    except Exception as e:
+        print(f"Unerwarteter Fehler: {e}", file=sys.stderr)
+        sys.exit(1)
+
+
+if __name__ == "__main__":
+    main()
\ No newline at end of file