#!/usr/bin/env python

import requests
import time
import logging
import socket
import json
import subprocess

# Configuration de l'API REFMAR
# API_URL = "https://services.data.shom.fr/maregraphie/service/completetidegauge"
# API_URL = "https://services.data.shom.fr/maregraphie/observation/json"
# curl -X GET "https://services.data.shom.fr/maregraphie/observation/json/386?sources=1&dtStart=2025-05-22T15%3A56%3A00Z&dtEnd=2025-05-22T15%3A57%3A00Z&interval=1" -H  "accept: application/json"
# API_KEY = "votre_cle_api"  # Remplacez par votre clé API
# STATION = '386'  # Identifiant de la station du Havre

API_URL = "https://data.haropaport.com/sig/capteur/hauteur"

UDP_IP = "127.0.0.1"
UDP_PORT = 8765

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# Configuration du logging
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')

def fetch_data():
    """Récupère les données du marégraphe via l'API REFMAR."""
    headers = {
        # "Ocp-Apim-Subscription-Key": API_KEY,
    }
    params = {
        # "sources": 1,
        # "dtStart": "2025-05-22T10:00:00Z",
        # "dtEnd": "2025-05-22T17:00:00Z",
        # # "interval": 1
    }
    try:
        response = requests.get(API_URL, headers=headers, params=params)
        response.raise_for_status()
        return response.json()
    except requests.RequestException as e:
        logging.error(f"Erreur lors de la récupération des données de l'API : {e}")
        return None
    

def process_data(data):
    """Traite les données récupérées."""
    try:
        for item in data['items']:
            if item['id'] == "hauteur_shom":
                logging.info(f"{item["capteur"]} Hauteur d'eau : {item["valeur"]} mètres")
                hauteurdeau_bytes = f"{item["valeur"]};".encode('utf-8')
                sock.sendto(hauteurdeau_bytes, (UDP_IP, UDP_PORT))
            # else:
            #     logging.error('error in parsing')
            #     sock.sendto(f"{0};".encode('utf-8'), (UDP_IP, UDP_PORT))
    except Exception as e:
        logging.error(f"Erreur lors du traitement des données : {e}")
        sock.sendto(f"{0};".encode('utf-8'), (UDP_IP, UDP_PORT))

def main():
    """Fonction principale qui exécute la boucle de récupération et de traitement des données."""
    logging.info("Démarrage de l'application de traitement des données du marégraphe.")
    # lancement du patch pd
    pd_patch = "./maregraphe.pd"  # Remplace par le chemin de ton patch
    # pd_process = subprocess.Popen(["pd", "-nogui", "-open", pd_patch])
    pd_process = subprocess.Popen(["pd", "-open", pd_patch])

    try:
        while True:
            print('/ / / / / / / / / / / / / / / / / / / / / / / / / / / / / /')
            data = fetch_data()
            # logging.info(json.dumps(data, indent=2))
            if data:
                process_data(data)
            else:
                logging.warning('no data')
                sock.sendto(f"{0};".encode('utf-8'), (UDP_IP, UDP_PORT))
            time.sleep(10)  # 300 Attendre 5 minutes
    except KeyboardInterrupt:
        print("Arrêt du script, fermeture de Pure Data...")
        pd_process.terminate()


if __name__ == "__main__":
    main()