Amélioration de la vérification de la connectivité Internet avec un ping vers 8.8.8.8 et suppression de la vérification de connexion dans le script principal.

- Removed obsolete script `script_SANSDEMARRAGE.sh`.
- Added new `Camera.py` and `Connexion.py` files for camera handling and socket communication.
- Implemented `First_Try.py` for initial camera preview testing.
- Created `Humidity.py` for humidity sensor data acquisition.
- Developed `Send_data_stocked.py` for managing and sending stored data.
- Introduced `Time_Lapse_Connection.py` and `Time_Lapse_NoConnection.py` for connected and offline modes.
- Added `get_from_server.py` for retrieving camera status from the server.
- Updated `sync_offline_data.py` for synchronizing offline data.
- Created `timelapse.service` for managing the timelapse service on Raspberry Pi.
- Established package structure with `__init__.py` and `api_client.py` for API interactions.
- Enhanced `capture.py` for managing image captures and data storage.
- Configured `config.py` for centralized configuration management.
- Developed `sensors.py` for handling environmental sensors and camera operations.
- Implemented `timelapse_offline.py` and `timelapse_online.py` for capturing images in offline and online modes.

Automate.py

@@ -1,175 +1,142 @@
-import time
-from datetime import datetime
-import picamera2 as pc
-import smbus2
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Script d'automatisation pour la gestion du système timelapse
+Ce script vérifie le statut du serveur et configure le système en conséquence.
+"""
+
 import os
-import json
-import shutil
-import requests
+import sys
+import time
+import logging
+import subprocess
+from timelapse.config import config
+from timelapse.api_client import api_client
+from timelapse.sensors import micro_controller
 
 
-class MicroControler:
-    def __init__(self):
-        pass
+def main():
+    """
+    Fonction principale d'automatisation
+    """
+    logging.info("==================== AUTOMATISATION TIMELAPSE ====================")
     
-    def set_data(self, t):
-        bus = smbus2.SMBus(1)
-        ans = bus.write_byte(0x28, t)
-        #print(ans)
-        time.sleep(0.015)
-        ans=smbus2.i2c_msg.read(0x28,3)
-        print("I get that : ",ans)
-    
-        bus.i2c_rdwr(ans)
-        data = list(ans)
-        print(data)
-        
-    def set_data_2_octets(self, value):
-        value_16b = format(value, "016b")
-        print(value_16b)
-        #print(value_16b>>8)
-        
-        high_address = (value>>8) & 0xFF
-        low_address = value & 0xFF
-        print(high_address)
-        print(low_address)
-        
-        """High Address"""
-        self.set_data(high_address)
-        """Low Address"""
-        self.set_data(low_address)
-      
-    
-    
-class Server:
-    def __init__(self):
-        self.url_requete = "https://timelapse.kerboul.me/api/camera/status"
-        self.dic = { "set_config":False,
-                     "maintenance": False,
-                     "stop current config":False,
-                     
-                     "timelapse":3,
-                     "conf nb_images":1,
-                     "nb_images restantes":1
-                    }
-    
-    def get_request(self):
     try:
-            response = requests.get(self.url_requete)
-            print("Here is the answer from the server : ",response.json())
-            if response.status_code == 200:
-                camera_status = response.json()
-                #print(camera_status)
-                self.dic["maintenance"] = camera_status["maintenance"]
-                self.dic["timelapse"] = camera_status["interval"]
-                self.dic["conf nb_images"] = camera_status["nb_images"]
-                self.dic["set_config"] = not camera_status["idle"]
-                self.dic["stop current config"] = camera_status["stop_flag"]
+        # Récupérer le statut de la caméra depuis l'API
+        camera_status = api_client.get_camera_status()
+        
+        # Vérifier si la configuration actuelle est déjà active et non terminée
+        is_active_config = config.get("config_active", False)
+        images_remaining = config.get("nb_images_restantes", 0)
+        
+        if camera_status is None:
+            logging.warning("Impossible d'obtenir le statut de la caméra depuis l'API")
+            if is_active_config and images_remaining > 0:
+                logging.info("Utilisation de la configuration locale existante")
+                return
+            logging.info("Aucune configuration active et impossibilité de récupérer le statut")
+            return
+        
+        # Vérifier l'état de maintenance en priorité
+        if camera_status.get("maintenance", False):
+            logging.info("Caméra en mode maintenance")
+            
+            # Vérifier si un projet est déjà en cours (config active avec images restantes)
+            if is_active_config and images_remaining > 0:
+                logging.info(f"Un projet est en cours avec {images_remaining} images restantes - capture maintenue en mode maintenance")
+                
+                # Importer le gestionnaire de capture
+                from timelapse.capture import timelapse_manager
+                
+                # Prendre une image et l'envoyer
+                logging.info("Prise d'image en mode maintenance pour projet en cours")
+                online_status = api_client.check_connection()
+                timelapse_manager.single_capture(online=online_status)
+                
+                # Décrémenter le compteur d'images restantes
+                config.decrement_remaining_images()
+                
+                # Si c'était la dernière image, désactiver la configuration
+                if config.get("nb_images_restantes", 0) <= 0:
+                    logging.info("Dernière image capturée, désactivation de la configuration")
+                    config.update_config({"config_active": False})
             else:
-                print("mauvais code")
-                print(response.status_code)
-        except requests.exceptions.RequestException as e:
-            print("erreur API ou internet")
+                logging.info("Aucun projet en cours, mode maintenance sans action")
             
-    def get_dic_data(self):
-        return self.dic
+            # Mettre à jour la configuration pour refléter le mode maintenance
+            config.update_config({"maintenance": True})
+            return
         
-    def create_Json(self):
-        self.filename = "/home/timelapse/Documents/Time_Lapse/CONFIG/config.json"
-        with open(self.filename, "w") as file:
-            json.dump(self.get_dic_data(), file)
+        # Vérifier si un arrêt de la procédure est demandé
+        if camera_status.get("stop_flag", False):
+            logging.info("Arrêt de la procédure en cours...")
             
-    def get_existing_Json(self):
-        self.filename = "/home/timelapse/Documents/Time_Lapse/CONFIG/config.json"
-        with open(self.filename, "r", encoding='utf-8') as file:
-            datas = json.load(file)
-        return datas
+            # Réinitialiser les configurations actives
+            config.update_config({
+                "config_active": False,
+                "nb_images_restantes": 0,
+                "stop_current_config": True
+            })
             
-    def create_this_Json(self, dic):
-        self.dic = { "set_config":dic["set_config"],
-             "maintenance": dic["maintenance"],
-             "stop current config":dic["stop current config"],
+            # Confirmer l'arrêt au serveur
+            confirmed = api_client.confirm_stop()
+            if confirmed:
+                logging.info("Arrêt confirmé au serveur")
+            else:
+                logging.warning("Échec de la confirmation d'arrêt au serveur")
                 
-             "timelapse":dic["timelapse"],
-             "conf nb_images":dic["conf nb_images"],
-             "nb_images restantes":dic["nb_images restantes"]
+            # Configuration d'un redémarrage régulier pour vérifier les nouvelles configurations
+            config.set("restart_interval", 120)  # 2 minutes
+            
+            return
+        
+        # Vérifier si le système est en IDLE et si une configuration est déjà active
+        is_idle = camera_status.get("idle", True)
+        
+        if is_idle:
+            logging.info("Système en mode IDLE")
+            if is_active_config:
+                # Si le nombre d'images est atteint, désactiver la configuration
+                if images_remaining <= 0:
+                    logging.info("Configuration terminée: nombre d'images atteint")
+                    config.update_config({"config_active": False})
+                else:
+                    logging.info(f"Configuration active: il reste {images_remaining} images à capturer")
+            else:
+                logging.info("Aucune configuration active, attente en mode IDLE")
+                # Configuration d'un redémarrage régulier pour vérifier les nouvelles configurations
+                config.set("restart_interval", 120)  # 2 minutes
+            return
+        
+        # Si on arrive ici, il y a une nouvelle configuration à appliquer
+        logging.info("Nouvelle configuration active détectée")
+        
+        # Mettre à jour la configuration locale
+        config_update = {
+            "config_active": True,
+            "maintenance": False,
+            "timelapse": camera_status.get("interval", 3),
+            "conf_nb_images": camera_status.get("nb_images", 1),
+            "nb_images_restantes": camera_status.get("nb_images", 1),
+            "stop_current_config": False,
+            "idle": is_idle
         }
-        self.filename = "/home/timelapse/Documents/Time_Lapse/CONFIG/config.json"
-        with open(self.filename, "w") as file:
-            json.dump(dic, file)
         
-    def has_pending_tasks(self):
-        """Vérifie s'il y a des captures en attente de synchronisation."""
-        project_path = "//home//timelapse//Documents//Time_Lapse//PROJECT//"
-        offline_dir = os.path.join(project_path, "_offline")
-        
-        # Si le répertoire offline existe et n'est pas vide, il y a des tâches en attente
-        if os.path.exists(offline_dir) and os.listdir(offline_dir):
-            return True
-            
-        # Vérifier également les fichiers dans PROJECT qui pourraient être en attente d'envoi
-        if os.path.exists(project_path):
-            for item in os.listdir(project_path):
-                # Si c'est un dossier mais pas le dossier _offline
-                if os.path.isdir(os.path.join(project_path, item)) and item != "_offline":
-                    return True
-                    
-        return False
-    
-if __name__ == "__main__":
-    MC = MicroControler()
-    server = Server()
-    filename = "/home/timelapse/Documents/Time_Lapse/CONFIG/config.json"
-    
-    server.get_request()
-    datas = server.get_dic_data()
-    #datas = {'set_config': False, 'maintenance': True, 'stop current config': True, 'timelapse': 7, 'conf nb_images': 12, 'nb_images restantes': 12}
-    print("Here are the datas loaded : ",datas)
-    if (datas["maintenance"]):
-        print("- Maintenance")
-    else:
-        print("- No Maintenance")
-        if (datas["stop current config"]):
-            if (os.path.exists(filename)):
-                print("- Stopping current config") #suppresion fichier json
-                os.remove(filename)
-        if (datas["set_config"]==False): #eddition fichier config
-            print("- Working on Raspberry config")
-            if (os.path.exists(filename)):
-                print("- Existing Config : -1 on Images")
-                datas = server.get_existing_Json()
-                datas["nb_images restantes"] = datas["nb_images restantes"] - 1
-                os.remove(filename)
-                if (datas["nb_images restantes"]==0):
-                    pass
-                else:
-                    server.create_this_Json(datas)
-            else:
-                datas = {'set_config': False, 'maintenance': False, 'stop current config': False, 'timelapse': 3, 'conf nb_images': 1, 'nb_images restantes': 1}
-                server.create_this_Json(datas)
-        else:
-            server.create_this_Json(datas)
-            print("- New Config")
-            
-        # Vérifier s'il y a des tâches en attente avant d'éteindre
-        print("- Vérification si des transferts d'images sont en cours...")
+        config.update_config(config_update)
         
         # Envoyer l'intervalle au microcontrôleur
-        print("TimeLapse sent is : ", datas["timelapse"])
-        MC.set_data_2_octets(datas["timelapse"])
+        interval = camera_status.get("interval", 3)
+        logging.info(f"Envoi de l'intervalle au microcontrôleur: {interval}s")
+        micro_controller.send_interval(interval)
         
-        # Attendre un moment pour s'assurer que les transferts se terminent
-        max_wait = 60  # Maximum 60 secondes d'attente
-        wait_interval = 5  # Vérifier toutes les 5 secondes
+        # Éteindre le système après configuration (mais ne pas arrêter en prod)
+        # logging.info("Configuration terminée, arrêt du système")
+        # subprocess.run(["sudo", "shutdown", "now"])
         
-        for i in range(0, max_wait, wait_interval):
-            if server.has_pending_tasks():
-                print(f"- Des images sont encore en cours de transfert, attente ({i}s)...")
-                time.sleep(wait_interval)
-            else:
-                print("- Aucun transfert en cours, extinction du système")
-                break
+    except Exception as e:
+        logging.error(f"Erreur dans le script d'automatisation: {e}")
 
-        print("- Extinction du système")
-        time.sleep(1)
-        os.system("sudo shutdown now")
+
+if __name__ == "__main__":
+    main()

CONFIG/config.json

@@ -0,0 +1,13 @@
+{
+    "set_config": false,
+    "maintenance": true,
+    "stop current config": false,
+    "timelapse": 3,
+    "conf nb_images": 1,
+    "nb_images restantes": 1,
+    "conf_nb_images": 10,
+    "idle": false,
+    "stop_current_config": false,
+    "nb_images_restantes": 8,
+    "config_active": true
+}

old_files/First_Try.py

@@ -0,0 +1,10 @@
+import time
+import picamera2 as pc
+
+camera = pc.Picamera2()
+try:
+    camera.strat_preview()
+    time.sleep(10)
+    camera.stop_preview()
+finally:
+    camera.close()

old_files/Send_data_stocked.py

@@ -54,10 +54,10 @@ class Send_data_stocked:
             'image': (image_path, open(image_path, 'rb'), 'image/jpeg')
         }
         try:
-            print("Datas are : ",data)
+            #print(data)
             #print(files)
             response = requests.post(self.url, headers=self.headers, data=data, files=files)
-            print("Answer from server is : ",response)
+            print(response)
             response.raise_for_status() 
             response_data = response.json()
             return response_data

old_files/Time_Lapse_Connection.py

@@ -61,11 +61,11 @@ class TimeLapse:
         
     def pick_Picture(self):
         cam = pc.Picamera2()
-        conf = cam.create_still_configuration(main={"size": (800, 600)})
+        conf = cam.create_preview_configuration(main={"size":(800, 600)})
         cam.configure(conf)
+        cam.start_preview(pc.Preview.QTGL)
         cam.start()
-        # Allow camera time to initialize
-        time.sleep(2)
+        time.sleep(0.1)
         timestamp = self.get_TimeStamp()
         path = self.project_path + timestamp + "//" + timestamp+".jpg"
         self.create_Folder()

old_files/Time_Lapse_NoConnection.py

@@ -60,11 +60,11 @@ class TimeLapse:
         
     def pick_Picture(self):
         cam = pc.Picamera2()
-        conf = cam.create_still_configuration(main={"size": (800, 600)})
+        conf = cam.create_preview_configuration(main={"size":(800, 600)})
         cam.configure(conf)
+        cam.start_preview(pc.Preview.QTGL)
         cam.start()
-        # Allow camera time to initialize
-        time.sleep(2)
+        time.sleep(0.1)
         timestamp = self.get_TimeStamp()
         path = self.project_path + timestamp + "//" + timestamp+".jpg"
         self.create_Folder()

old_files/get_from_server.py

@@ -0,0 +1,14 @@
+import requests
+
+url_requete = "https://timelapse.kerboul.me/api/camera/status"
+
+try:
+    response = requests.get(url_requete)
+    
+    if response.status_code == 200:
+        camera_status = response.json()
+        print(camera_status)
+    else:
+        print("mauvais code")
+except requests.exceptions.RequestException as e:
+    print("erreur API ou internet")

script.sh

@@ -1,22 +1,151 @@
 #!/bin/bash
-nmcli dev wifi connect "Redmi Note 12 Pro" password "kingcard"
-check_internet() {
-	ping -c 4 8.8.8.8 > /dev/null 2>&1
-	return $?
+
+# Configuration
+CONFIG_DIR="/home/timelapse/Documents/Time_Lapse/CONFIG"
+LOG_FILE="/home/timelapse/Documents/Time_Lapse/timelapse.log"
+BASE_DIR="/home/timelapse/Documents/Time_Lapse"
+MAX_RETRIES=5
+RETRY_DELAY=10
+LOCK_FILE="/var/lock/timelapse.lock"
+
+# Fonction de journalisation
+log() {
+    echo "$(date '+%Y-%m-%d %H:%M:%S') - $1" | tee -a "$LOG_FILE"
 }
-if check_internet; then
-	echo "Connecté à internet"
-	python Time_Lapse_Connection.py
-	# Attendre un peu pour s'assurer que le processus de capture est terminé
-	sleep 5
-	python Send_data_stocked.py
-	# Attendre encore un peu pour s'assurer que l'envoi des données stockées est terminé
-	sleep 5
+
+# Vérifier si une autre instance est en cours d'exécution
+if [ -f "$LOCK_FILE" ]; then
+    PID=$(cat "$LOCK_FILE")
+    if ps -p $PID > /dev/null; then
+        log "Une autre instance est déjà en cours d'exécution (PID: $PID). Arrêt."
+        exit 1
     else
-	echo "pas connecté à internet"
-	python Time_Lapse_NoConnection.py
-	sleep 5
+        log "Fichier de verrouillage obsolète trouvé. Suppression."
+        rm -f "$LOCK_FILE"
+    fi
 fi
 
-# Exécuter l'automate à la fin, après les délais
-python Automate.py
+# Créer le fichier de verrouillage
+echo $$ > "$LOCK_FILE"
+
+# Fonction de nettoyage à la sortie
+cleanup() {
+    log "Nettoyage avant sortie"
+    rm -f "$LOCK_FILE"
+    exit $1
+}
+
+# Interception des signaux pour le nettoyage
+trap 'cleanup 1' INT TERM
+
+log "==============================================================="
+log "Démarrage du système timelapse (mode headless)"
+
+# Configuration des variables d'environnement pour mode headless
+export LIBCAMERA_LOG_LEVELS=3
+export DISPLAY=:0
+
+# Fonction pour se connecter au WiFi avec plusieurs tentatives
+connect_wifi() {
+    local ssid="Redmi Note 12 Pro"
+    local password="kingcard"
+    local retries=0
+    
+    log "Vérification de l'interface WiFi..."
+    if ! ip link show | grep -q wlan0; then
+        log "Interface WiFi non trouvée ou désactivée"
+        # Essayer d'activer l'interface si elle existe
+        if ip link show wlan0 &>/dev/null; then
+            log "Tentative d'activation de wlan0"
+            ip link set wlan0 up
+            sleep 2
+        fi
+    fi
+    
+    while [ $retries -lt $MAX_RETRIES ]; do
+        log "Tentative de connexion WiFi ($((retries+1))/$MAX_RETRIES)"
+        
+        # Essayer d'abord avec nmcli si disponible
+        if command -v nmcli >/dev/null 2>&1; then
+            nmcli dev wifi connect "$ssid" password "$password"
+        # Sinon essayer avec wpa_supplicant
+        elif command -v wpa_cli >/dev/null 2>&1; then
+            # Créer un fichier de configuration wpa_supplicant
+            wpa_conf="/tmp/wpa_supplicant.conf"
+            echo "network={" > $wpa_conf
+            echo "    ssid=\"$ssid\"" >> $wpa_conf
+            echo "    psk=\"$password\"" >> $wpa_conf
+            echo "}" >> $wpa_conf
+            
+            # Utiliser wpa_supplicant pour se connecter
+            wpa_supplicant -i wlan0 -c $wpa_conf -B
+            sleep 2
+            dhclient wlan0
+            rm -f $wpa_conf
+        fi
+        
+        if check_internet; then
+            log "Connexion WiFi établie"
+            return 0
+        fi
+        
+        retries=$((retries+1))
+        sleep $RETRY_DELAY
+    done
+    
+    log "Échec de connexion WiFi après $MAX_RETRIES tentatives"
+    return 1
+}
+
+# Fonction pour vérifier la connexion internet
+check_internet() {
+    ping -c 1 8.8.8.8 > /dev/null 2>&1
+    return $?
+}
+
+# Vérifier si la caméra est accessible
+check_camera() {
+    if libcamera-still --list-cameras &>/dev/null; then
+        log "Caméra détectée et accessible"
+        return 0
+    else
+        log "ERREUR: Caméra non détectée ou non accessible"
+        return 1
+    fi
+}
+
+# S'assurer que le répertoire de configuration existe
+mkdir -p "$CONFIG_DIR"
+
+# Principal flux d'exécution
+connect_wifi
+
+# Vérifier si les chemins Python sont corrects
+export PYTHONPATH="$BASE_DIR:$PYTHONPATH"
+
+# Vérifier que la caméra est accessible
+check_camera
+
+if check_internet; then
+    log "Connecté à internet"
+    
+    # Vérifier si des données locales doivent être envoyées
+    log "Envoi des données stockées localement"
+    python3 "$BASE_DIR/sync_offline_data.py"
+    
+    # Exécuter en mode connecté
+    log "Exécution du script en mode connecté"
+    python3 "$BASE_DIR/timelapse_online.py"
+    
+else
+    log "Pas connecté à internet"
+    log "Exécution du script en mode hors-ligne"
+    python3 "$BASE_DIR/timelapse_offline.py"
+fi
+
+# Exécuter le script d'automatisation dans tous les cas
+log "Exécution du script d'automatisation"
+python3 "$BASE_DIR/Automate.py"
+
+log "Script terminé"
+cleanup 0

setup_headless.sh

@@ -0,0 +1,80 @@
+#!/bin/bash
+
+# Script d'installation et de vérification pour le système timelapse en mode headless
+# Ce script vérifie et installe toutes les dépendances nécessaires
+
+echo "======== Configuration du système timelapse en mode headless ========"
+echo "Vérification et installation des dépendances..."
+
+# Fonction pour installer une dépendance si elle n'est pas déjà présente
+install_if_missing() {
+    if ! dpkg -l | grep -q $1; then
+        echo "Installation de $1..."
+        sudo apt install -y $1
+    else
+        echo "$1 est déjà installé."
+    fi
+}
+
+# Mise à jour des dépôts
+sudo apt update
+
+# Installation des dépendances système
+install_if_missing python3-pip
+install_if_missing python3-dev
+install_if_missing i2c-tools
+install_if_missing libcamera-dev
+install_if_missing python3-picamera2
+install_if_missing python3-libcamera
+install_if_missing libopenjp2-7
+install_if_missing libtiff5
+
+# Installation des dépendances Python
+echo "Installation des dépendances Python..."
+pip3 install --upgrade pip
+pip3 install smbus2
+pip3 install requests
+pip3 install picamera2
+pip3 install pathlib
+
+# Activation des interfaces requises
+echo "Activation de l'interface I2C..."
+if ! grep -q "dtparam=i2c_arm=on" /boot/config.txt; then
+    echo "dtparam=i2c_arm=on" | sudo tee -a /boot/config.txt
+    echo "I2C activé dans /boot/config.txt"
+else
+    echo "I2C déjà activé."
+fi
+
+echo "Activation de la caméra..."
+if ! grep -q "start_x=1" /boot/config.txt; then
+    echo "start_x=1" | sudo tee -a /boot/config.txt
+    echo "gpu_mem=128" | sudo tee -a /boot/config.txt
+    echo "Caméra activée dans /boot/config.txt"
+else
+    echo "Caméra déjà activée."
+fi
+
+# Ajout de l'utilisateur aux groupes nécessaires
+echo "Ajout de l'utilisateur aux groupes requis..."
+sudo usermod -a -G i2c,video,gpio $USER
+
+# Installation du service systemd
+echo "Installation du service timelapse..."
+sudo cp timelapse.service /etc/systemd/system/
+sudo systemctl daemon-reload
+sudo systemctl enable timelapse.service
+
+# Création des répertoires nécessaires
+echo "Création des répertoires de travail..."
+mkdir -p CONFIG
+mkdir -p PROJECT
+
+# Test des périphériques I2C
+echo "Test des périphériques I2C (si vous voyez des erreurs, vérifiez les connexions)..."
+sudo i2cdetect -y 1
+
+echo "======== Configuration terminée ========"
+echo "Le système timelapse est prêt à fonctionner en mode headless."
+echo "Un redémarrage est recommandé pour appliquer tous les changements:"
+echo "sudo reboot"

stuff.md

@@ -0,0 +1,44 @@
+./script.sh 
+2025-04-27 19:49:25 - ===============================================================
+2025-04-27 19:49:25 - Démarrage du système timelapse (mode headless)
+2025-04-27 19:49:25 - Vérification de l'interface WiFi...
+2025-04-27 19:49:25 - Tentative de connexion WiFi (1/5)
+Périphérique « wlan0 » activé avec « cb0f2de6-fe40-419c-85e5-9bb492873461 ».
+2025-04-27 19:49:31 - Connexion WiFi établie
+2025-04-27 19:49:32 - Caméra détectée et accessible
+2025-04-27 19:49:32 - Connecté à internet
+2025-04-27 19:49:32 - Envoi des données stockées localement
+-------------------------------------------------------------------
+Démarrage de la synchronisation des données hors ligne
+Statut caméra récupéré avec succès
+Caméra en mode maintenance, aucune synchronisation effectuée
+2025-04-27 19:49:34 - Exécution du script en mode connecté
+-------------------------------------------------------------------
+Démarrage de la capture d'images en mode connecté
+Statut caméra récupéré avec succès
+Configuration sauvegardée
+Configuration mise à jour depuis l'API
+Caméra en mode maintenance, arrêt du script
+2025-04-27 19:49:36 - Exécution du script d'automatisation
+==================== AUTOMATISATION TIMELAPSE ====================
+Statut caméra récupéré avec succès
+Caméra en mode maintenance
+Un projet est en cours avec 9 images restantes - capture maintenue en mode maintenance
+Prise d'image en mode maintenance pour projet en cours
+Connectivité Internet non disponible: 404
+Initialization successful.
+Camera now open.
+Camera configuration has been adjusted!
+Configuration successful!
+Camera started
+Saved <picamera2.request.Helpers object at 0x7f7bbce690> to file /home/timelapse/Documents/Time_Lapse/PROJECT/2025-04-27 19:49:38/2025-04-27 19:49:38.jpg.
+Time taken for encode: 26.50541599996359 ms.
+Camera stopped
+Camera closed successfully.
+Image capturée: /home/timelapse/Documents/Time_Lapse/PROJECT/2025-04-27 19:49:38/2025-04-27 19:49:38.jpg
+Données JSON sauvegardées: /home/timelapse/Documents/Time_Lapse/PROJECT/2025-04-27 19:49:38/2025-04-27 19:49:38.json
+Capture sauvegardée en mode hors ligne: /home/timelapse/Documents/Time_Lapse/PROJECT/_offline/2025-04-27 19:49:38
+Configuration sauvegardée
+Configuration sauvegardée
+2025-04-27 19:49:41 - Script terminé
+2025-04-27 19:49:41 - Nettoyage avant sortie

sync_offline_data.py

@@ -0,0 +1,74 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Script pour la synchronisation des données stockées en mode hors ligne.
+Remplace l'ancien Send_data_stocked.py
+"""
+
+import os
+import sys
+import logging
+import time
+from timelapse.config import config
+from timelapse.capture import timelapse_manager
+from timelapse.api_client import api_client
+
+
+def main():
+    """
+    Fonction principale pour la synchronisation des données hors ligne.
+    """
+    logging.info("-------------------------------------------------------------------")
+    logging.info("Démarrage de la synchronisation des données hors ligne")
+    
+    try:
+        # Vérifier la connexion au serveur
+        camera_status = api_client.get_camera_status()
+        if camera_status is None:
+            logging.error("Impossible de se connecter au serveur. Synchronisation reportée.")
+            sys.exit(1)
+        
+        # Vérifier si le système est en maintenance
+        if camera_status.get("maintenance", False):
+            logging.info("Caméra en mode maintenance, aucune synchronisation effectuée")
+            sys.exit(0)
+        
+        # Synchroniser les captures hors ligne
+        start_time = time.time()
+        sync_count = timelapse_manager.sync_offline_captures()
+        duration = time.time() - start_time
+        
+        if sync_count > 0:
+            logging.info(f"Synchronisation réussie de {sync_count} captures en {duration:.2f} secondes")
+            
+            # Vérifier s'il reste des images à synchroniser
+            remaining_offline = timelapse_manager.count_offline_captures()
+            if remaining_offline > 0:
+                logging.info(f"Il reste encore {remaining_offline} captures à synchroniser")
+            else:
+                logging.info("Toutes les captures hors ligne ont été synchronisées")
+        else:
+            logging.info("Aucune capture à synchroniser")
+            
+        # Vérifier si un arrêt est demandé
+        if camera_status.get("stop_flag", False):
+            logging.info("Demande d'arrêt détectée, confirmation au serveur")
+            api_client.confirm_stop()
+            
+            # Réinitialiser l'état actif
+            config.update_config({
+                "config_active": False, 
+                "nb_images_restantes": 0,
+                "stop_current_config": True
+            })
+            
+    except Exception as e:
+        logging.error(f"Erreur lors de la synchronisation des données: {e}")
+        sys.exit(1)
+    
+    logging.info("Synchronisation terminée")
+
+
+if __name__ == "__main__":
+    main()

timelapse-service.log

@@ -1,23 +0,0 @@
-Erreur : Insufficient privileges.
-Connecté à internet
-[0:13:07.775780345] [3774]  INFO Camera camera_manager.cpp:327 libcamera v0.4.0+53-29156679
-[0:13:07.806936514] [3777]  WARN RPiSdn sdn.cpp:40 Using legacy SDN tuning - please consider moving SDN inside rpi.denoise
-[0:13:07.809437125] [3777]  INFO RPI vc4.cpp:447 Registered camera /base/soc/i2c0mux/i2c@1/ov5647@36 to Unicam device /dev/media1 and ISP device /dev/media3
-[0:13:07.809535588] [3777]  INFO RPI pipeline_base.cpp:1121 Using configuration file '/usr/share/libcamera/pipeline/rpi/vc4/rpi_apps.yaml'
-[0:13:07.816878221] [3774]  INFO Camera camera.cpp:1202 configuring streams: (0) 800x600-XBGR8888 (1) 1296x972-SGBRG10_CSI2P
-[0:13:07.817365292] [3777]  INFO RPI vc4.cpp:622 Sensor: /base/soc/i2c0mux/i2c@1/ov5647@36 - Selected sensor format: 1296x972-SGBRG10_1X10 - Selected unicam format: 1296x972-pGAA
-qt.qpa.xcb: could not connect to display 
-qt.qpa.plugin: Could not load the Qt platform plugin "xcb" in "" even though it was found.
-This application failed to start because no Qt platform plugin could be initialized. Reinstalling the application may fix this problem.
-
-Available platform plugins are: eglfs, linuxfb, minimal, minimalegl, offscreen, vnc, wayland-egl, wayland, wayland-xcomposite-egl, wayland-xcomposite-glx, xcb.
-
-/home/timelapse/Documents/Time_Lapse/script.sh : ligne 14 :  3774 Abandon                 python Time_Lapse_Connection.py
-Noms des dossiers : []
-Here is the answer from the server :  {'id': 1, 'interval': 5, 'nb_images': 10, 'maintenance': False, 'stop_flag': True, 'idle': False}
-Here are the datas loaded :  {'set_config': True, 'maintenance': False, 'stop current config': True, 'timelapse': 5, 'conf nb_images': 10, 'nb_images restantes': 1}
-- No Maintenance
-- Stopping current config
-- New Config
-- Shut Down
-TimeLapse sent is :  5

timelapse.service

@@ -0,0 +1,26 @@
+[Unit]
+Description=Service Timelapse Raspberry Pi (Headless Mode)
+DefaultDependencies=no
+After=local-fs.target network-online.target
+Wants=network-online.target
+Requires=network.target
+# S'assurer que le service démarre après l'initialisation complète du réseau
+# y compris après que NetworkManager ou systemd-networkd aient essayé d'établir une connexion
+
+[Service]
+Type=simple
+ExecStart=/bin/bash /home/timelapse/Documents/Time_Lapse/script.sh
+WorkingDirectory=/home/timelapse/Documents/Time_Lapse
+User=timelapse
+Restart=on-failure
+RestartSec=30
+StandardOutput=append:/home/timelapse/Documents/Time_Lapse/timelapse-service.log
+StandardError=append:/home/timelapse/Documents/Time_Lapse/timelapse-service.log
+Environment="DISPLAY=:0"
+Environment="XAUTHORITY=/home/timelapse/.Xauthority"
+Environment="XDG_RUNTIME_DIR=/run/user/1000"
+# Ajouter un petit délai pour s'assurer que les interfaces réseau sont vraiment prêtes
+ExecStartPre=/bin/sleep 5
+
+[Install]
+WantedBy=multi-user.target

timelapse/__init__.py

@@ -0,0 +1,14 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Package timelapse pour la gestion du système de capture d'images.
+"""
+
+import logging
+
+# Configure le logger au niveau du package
+logging.getLogger(__name__).addHandler(logging.NullHandler())
+
+# Version du package
+__version__ = '1.0.0'

timelapse/api_client.py

@@ -0,0 +1,158 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Client API pour communiquer avec le serveur timelapse
+"""
+
+import os
+import json
+import logging
+import requests
+from requests.exceptions import RequestException
+from .config import config
+import subprocess
+import platform
+
+
+class APIClient:
+    """Client API pour communiquer avec le serveur timelapse."""
+    
+    def __init__(self, base_url=None):
+        """Initialisation du client API."""
+        self.base_url = base_url or config.API_BASE_URL
+        self.headers = {'accept': 'application/json'}
+    
+    def get_camera_status(self):
+        """Récupère l'état de la caméra depuis l'API."""
+        url = f"{self.base_url}{config.API_ENDPOINTS['status']}"
+        try:
+            response = requests.get(url, headers=self.headers)
+            if response.status_code == 200:
+                logging.info("Statut caméra récupéré avec succès")
+                return response.json()
+            else:
+                logging.error(f"Erreur lors de la récupération du statut: {response.status_code}")
+                return None
+        except RequestException as e:
+            logging.error(f"Erreur de connexion à l'API: {e}")
+            return None
+    
+    def upload_measurement(self, image_path, timestamp, temperature, humidity):
+        """Télécharge une mesure (image + données) vers l'API."""
+        url = f"{self.base_url}{config.API_ENDPOINTS['upload']}"
+        
+        if not os.path.exists(image_path):
+            logging.error(f"Image non trouvée: {image_path}")
+            return None
+        
+        data = {
+            'timestamp': timestamp,
+            'temperature': temperature,
+            'humidity': humidity
+        }
+        
+        files = {
+            'image': (os.path.basename(image_path), open(image_path, 'rb'), 'image/jpeg')
+        }
+        
+        try:
+            response = requests.post(url, headers=self.headers, data=data, files=files)
+            
+            if response.status_code == 200 or response.status_code == 201:
+                logging.info(f"Image téléchargée avec succès: {os.path.basename(image_path)}")
+                return response.json()
+            else:
+                logging.error(f"Erreur lors du téléchargement: {response.status_code}")
+                return None
+                
+        except RequestException as e:
+            logging.error(f"Erreur de connexion lors du téléchargement: {e}")
+            return None
+        finally:
+            # Fermer le fichier
+            files['image'][1].close()
+    
+    def confirm_stop(self):
+        """Confirme l'arrêt d'une procédure de capture."""
+        url = f"{self.base_url}{config.API_ENDPOINTS['stop']}"
+        
+        try:
+            response = requests.post(url, headers=self.headers)
+            
+            if response.status_code == 200:
+                logging.info("Arrêt de la procédure confirmé")
+                return True
+            else:
+                logging.error(f"Erreur lors de la confirmation d'arrêt: {response.status_code}")
+                return False
+                
+        except RequestException as e:
+            logging.error(f"Erreur de connexion lors de la confirmation d'arrêt: {e}")
+            return False
+    
+    def update_camera_config(self, status):
+        """Met à jour la configuration de la caméra en fonction du statut reçu."""
+        if not status:
+            return False
+            
+        try:
+            # Récupérer l'état actuel pour comparaison
+            is_currently_active = config.get("config_active", False)
+            current_nb_images = config.get("conf_nb_images", 0)
+            
+            # Vérifier si c'est une nouvelle configuration
+            is_new_config = (not is_currently_active and not status.get("idle", True))
+            
+            # Préparer la mise à jour
+            config_update = {
+                "maintenance": status.get("maintenance", False),
+                "timelapse": status.get("interval", 3),
+                "conf_nb_images": status.get("nb_images", 1),
+                "idle": status.get("idle", True),
+                "stop_current_config": status.get("stop_flag", False)
+            }
+            
+            # Ne mettre à jour le nombre d'images restantes que pour une nouvelle configuration
+            # ou si la configuration est réinitialisée
+            if is_new_config or status.get("stop_flag", False):
+                config_update["nb_images_restantes"] = status.get("nb_images", 1)
+                config_update["config_active"] = not status.get("idle", True)
+                
+                if is_new_config:
+                    logging.info(f"Nouvelle configuration: {status.get('nb_images', 1)} images à capturer")
+            
+            # Mise à jour de la configuration
+            config.update_config(config_update)
+            logging.info("Configuration mise à jour depuis l'API")
+            
+            return True
+            
+        except Exception as e:
+            logging.error(f"Erreur lors de la mise à jour de la configuration: {e}")
+            return False
+    
+    def check_connection(self):
+        """Vérifie la connectivité Internet en effectuant un ping vers 8.8.8.8."""
+        
+        try:
+            # Définir la commande ping en fonction du système d'exploitation
+            param = '-n' if platform.system().lower() == 'windows' else '-c'
+            command = ['ping', param, '1', '8.8.8.8']
+            
+            # Exécuter la commande ping
+            result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, timeout=5)
+            
+            if result.returncode == 0:
+                logging.info("Connectivité Internet vérifiée avec succès (ping 8.8.8.8)")
+                return True
+            else:
+                logging.warning("Connectivité Internet non disponible (échec du ping)")
+                return False
+        except Exception as e:
+            logging.error(f"Erreur lors de la vérification de la connectivité: {e}")
+            return False
+
+
+# Instance globale du client API
+api_client = APIClient()

timelapse/capture.py

@@ -0,0 +1,229 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Module principal de gestion du timelapse
+"""
+
+import os
+import time
+import json
+import logging
+import shutil
+from pathlib import Path
+from datetime import datetime
+from .config import config
+from .api_client import api_client
+from .sensors import env_sensor, camera
+
+
+class TimelapseCaptureManager:
+    """Gestion de la capture timelapse."""
+
+    def __init__(self):
+        """Initialisation du gestionnaire de capture."""
+        self.offline_dir = os.path.join(config.PROJECT_DIR, "_offline")
+        Path(self.offline_dir).mkdir(parents=True, exist_ok=True)
+        
+    def single_capture(self, online=True):
+        """
+        Effectue une capture unique avec sauvegarde des mesures.
+        
+        Args:
+            online: Si la caméra est connectée au serveur
+            
+        Returns:
+            dict: Résultat de l'opération
+        """
+        # Capture des données environnementales
+        env_data = env_sensor.read_data()
+        temperature = env_data["temperature"]
+        humidity = env_data["humidity"]
+        
+        # Capture de l'image
+        image_path, timestamp = camera.capture_image()
+        
+        if not image_path:
+            logging.error("Échec de la capture d'image")
+            return None
+            
+        # Créer un fichier JSON avec les mesures
+        json_path = os.path.join(os.path.dirname(image_path), f"{timestamp}.json")
+        data = {
+            "timestamp": timestamp,
+            "temperature": temperature,
+            "humidity": humidity
+        }
+        
+        with open(json_path, "w", encoding="utf-8") as json_file:
+            json.dump(data, json_file, indent=4)
+            
+        logging.info(f"Données JSON sauvegardées: {json_path}")
+        
+        # Si online, envoi des données au serveur
+        if online:
+            response = api_client.upload_measurement(image_path, timestamp, temperature, humidity)
+            if response:
+                logging.info(f"Image téléchargée avec succès, ID: {response.get('id', 'unknown')}")
+                # On peut éventuellement supprimer l'image locale si nécessaire
+                # self._cleanup_local_capture(image_path, json_path)
+            else:
+                logging.warning("Échec du téléchargement, sauvegarde locale conservée")
+                # Déplacer les fichiers vers le dossier offline pour synchro ultérieure
+                self._move_to_offline(image_path, json_path)
+        else:
+            # Stockage offline
+            self._move_to_offline(image_path, json_path)
+        
+        return data
+    
+    def _move_to_offline(self, image_path, json_path):
+        """
+        Déplace les fichiers dans le dossier offline pour synchronisation ultérieure.
+        
+        Args:
+            image_path: Chemin de l'image
+            json_path: Chemin du fichier JSON
+        """
+        timestamp = os.path.basename(os.path.dirname(image_path))
+        offline_subdir = os.path.join(self.offline_dir, timestamp)
+        Path(offline_subdir).mkdir(parents=True, exist_ok=True)
+        
+        # Copier les fichiers
+        shutil.copy2(image_path, os.path.join(offline_subdir, os.path.basename(image_path)))
+        shutil.copy2(json_path, os.path.join(offline_subdir, os.path.basename(json_path)))
+        
+        logging.info(f"Capture sauvegardée en mode hors ligne: {offline_subdir}")
+    
+    def _cleanup_local_capture(self, image_path, json_path):
+        """
+        Nettoie les fichiers locaux après un téléchargement réussi.
+        
+        Args:
+            image_path: Chemin de l'image
+            json_path: Chemin du fichier JSON
+        """
+        capture_dir = os.path.dirname(image_path)
+        try:
+            os.remove(image_path)
+            os.remove(json_path)
+            os.rmdir(capture_dir)  # Supprime le dossier s'il est vide
+            logging.debug(f"Nettoyage local effectué: {capture_dir}")
+        except Exception as e:
+            logging.error(f"Erreur lors du nettoyage local: {e}")
+    
+    def sync_offline_captures(self):
+        """
+        Synchronise les captures hors ligne avec le serveur.
+        
+        Returns:
+            int: Nombre de captures synchronisées
+        """
+        if not os.path.exists(self.offline_dir):
+            return 0
+            
+        success_count = 0
+        offline_dirs = os.listdir(self.offline_dir)
+        
+        for timestamp_dir in offline_dirs:
+            dir_path = os.path.join(self.offline_dir, timestamp_dir)
+            if not os.path.isdir(dir_path):
+                continue
+                
+            image_path = os.path.join(dir_path, f"{timestamp_dir}.jpg")
+            json_path = os.path.join(dir_path, f"{timestamp_dir}.json")
+            
+            if not (os.path.exists(image_path) and os.path.exists(json_path)):
+                continue
+                
+            # Charger les données JSON
+            try:
+                with open(json_path, 'r', encoding='utf-8') as f:
+                    data = json.load(f)
+                
+                # Envoyer les données au serveur
+                timestamp = data.get("timestamp")
+                temperature = data.get("temperature")
+                humidity = data.get("humidity")
+                
+                response = api_client.upload_measurement(image_path, timestamp, temperature, humidity)
+                
+                if response:
+                    logging.info(f"Capture hors ligne synchronisée: {timestamp_dir}")
+                    # Supprimer le dossier local
+                    shutil.rmtree(dir_path)
+                    success_count += 1
+                else:
+                    logging.warning(f"Échec de synchronisation pour: {timestamp_dir}")
+                    
+            except Exception as e:
+                logging.error(f"Erreur lors de la synchronisation de {timestamp_dir}: {e}")
+                
+        return success_count
+    
+    def run_capture_sequence(self, online=True):
+        """
+        Exécute une séquence de capture selon la configuration.
+        
+        Args:
+            online: Si la caméra est connectée au serveur
+        
+        Returns:
+            bool: True si la séquence est terminée (toutes les images capturées), False sinon
+        """
+        # Vérifier si la configuration est active
+        is_active = config.get("config_active", False)
+        is_stopped = config.get("stop_current_config", False)
+        
+        if not is_active or is_stopped:
+            logging.info("Aucune configuration active ou configuration arrêtée")
+            return True
+            
+        # Vérifier si des images sont restantes à capturer
+        remaining_images = config.get("nb_images_restantes", 0)
+        
+        if remaining_images <= 0:
+            logging.info("Toutes les images ont été capturées")
+            # Désactiver la configuration active
+            config.update_config({"config_active": False})
+            return True
+            
+        logging.info(f"Démarrage d'une séquence de capture ({remaining_images} images restantes)")
+        
+        # Capturer une image
+        result = self.single_capture(online)
+        
+        if result:
+            # Décrémenter le compteur d'images restantes
+            remaining_images = config.decrement_remaining_images()
+            logging.info(f"Images restantes: {remaining_images}")
+            
+            # Vérifier si c'était la dernière image
+            if remaining_images <= 0:
+                logging.info("Toutes les images ont été capturées")
+                # Désactiver la configuration active
+                config.update_config({"config_active": False})
+                return True
+        else:
+            logging.error("Échec de la séquence de capture")
+            
+        return False
+    
+    def count_offline_captures(self):
+        """
+        Compte le nombre de captures hors ligne en attente de synchronisation.
+        
+        Returns:
+            int: Nombre de captures hors ligne
+        """
+        if not os.path.exists(self.offline_dir):
+            return 0
+            
+        offline_dirs = [d for d in os.listdir(self.offline_dir) 
+                      if os.path.isdir(os.path.join(self.offline_dir, d))]
+                      
+        return len(offline_dirs)
+
+
+# Instance globale du gestionnaire de capture
+timelapse_manager = TimelapseCaptureManager()

timelapse/config.py

@@ -0,0 +1,127 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Configuration centralisée pour le système timelapse
+"""
+
+import os
+import json
+import logging
+from pathlib import Path
+
+
+class Config:
+    """Classe pour gérer la configuration du système timelapse."""
+    
+    # Chemins par défaut
+    BASE_DIR = "/home/timelapse/Documents/Time_Lapse"
+    CONFIG_DIR = os.path.join(BASE_DIR, "CONFIG")
+    PROJECT_DIR = os.path.join(BASE_DIR, "PROJECT")
+    LOG_FILE = os.path.join(BASE_DIR, "timelapse.log")
+    CONFIG_FILE = os.path.join(CONFIG_DIR, "config.json")
+    
+    # Configuration API
+    API_BASE_URL = "https://timelapse.kerboul.me/api"
+    API_ENDPOINTS = {
+        "status": "/camera/status",
+        "upload": "/camera/upload",
+        "stop": "/camera/stop"
+    }
+    
+    # Configuration WiFi
+    WIFI_SSID = "Redmi Note 12 Pro"
+    WIFI_PASSWORD = "kingcard"
+    WIFI_MAX_RETRIES = 5
+    WIFI_RETRY_DELAY = 10
+    
+    # Configuration par défaut
+    DEFAULT_CONFIG = {
+        "set_config": False,
+        "maintenance": False,
+        "stop_current_config": False,
+        "timelapse": 3,
+        "conf_nb_images": 1,
+        "nb_images_restantes": 1
+    }
+    
+    def __init__(self):
+        """Initialisation de la configuration."""
+        self.ensure_directories()
+        self.setup_logging()
+        self.config = self.load_config()
+    
+    def ensure_directories(self):
+        """S'assure que les répertoires nécessaires existent."""
+        Path(self.CONFIG_DIR).mkdir(parents=True, exist_ok=True)
+        Path(self.PROJECT_DIR).mkdir(parents=True, exist_ok=True)
+    
+    def setup_logging(self):
+        """Configure le système de logging."""
+        logging.basicConfig(
+            filename=self.LOG_FILE,
+            level=logging.INFO,
+            format='%(asctime)s - %(levelname)s - %(message)s',
+            datefmt='%Y-%m-%d %H:%M:%S'
+        )
+        # Ajouter également la sortie console
+        console = logging.StreamHandler()
+        console.setLevel(logging.INFO)
+        formatter = logging.getLogger()
+        formatter.addHandler(console)
+    
+    def load_config(self):
+        """Charge la configuration depuis le fichier ou crée une configuration par défaut."""
+        if os.path.exists(self.CONFIG_FILE):
+            try:
+                with open(self.CONFIG_FILE, "r", encoding="utf-8") as file:
+                    return json.load(file)
+            except Exception as e:
+                logging.error(f"Erreur lors du chargement de la configuration: {e}")
+                return self.DEFAULT_CONFIG
+        else:
+            self.save_config(self.DEFAULT_CONFIG)
+            return self.DEFAULT_CONFIG
+    
+    def save_config(self, config_data=None):
+        """Sauvegarde la configuration dans le fichier."""
+        if config_data is None:
+            config_data = self.config
+        
+        try:
+            with open(self.CONFIG_FILE, "w", encoding="utf-8") as file:
+                json.dump(config_data, file, indent=4)
+            logging.info("Configuration sauvegardée")
+        except Exception as e:
+            logging.error(f"Erreur lors de la sauvegarde de la configuration: {e}")
+    
+    def update_config(self, new_config):
+        """Met à jour la configuration avec de nouvelles valeurs."""
+        self.config.update(new_config)
+        self.save_config()
+    
+    def get(self, key, default=None):
+        """Récupère une valeur de configuration par sa clé."""
+        return self.config.get(key, default)
+    
+    def set(self, key, value):
+        """Définit une valeur de configuration."""
+        self.config[key] = value
+        self.save_config()
+    
+    def delete_config_file(self):
+        """Supprime le fichier de configuration."""
+        if os.path.exists(self.CONFIG_FILE):
+            os.remove(self.CONFIG_FILE)
+            logging.info("Fichier de configuration supprimé")
+    
+    def decrement_remaining_images(self):
+        """Décrémente le nombre d'images restantes."""
+        if "nb_images_restantes" in self.config:
+            self.config["nb_images_restantes"] -= 1
+            self.save_config()
+        return self.config.get("nb_images_restantes", 0)
+
+
+# Instance globale de configuration
+config = Config()

timelapse/sensors.py

@@ -0,0 +1,175 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Module de gestion des capteurs (température, humidité) et de la caméra
+"""
+
+import os
+import time
+import logging
+import smbus2
+from datetime import datetime
+import picamera2 as pc
+from pathlib import Path
+from .config import config
+
+
+class EnvironmentSensor:
+    """Classe pour gérer le capteur d'environnement (température, humidité)."""
+    
+    def __init__(self, bus=1, address=0x44):
+        """
+        Initialisation du capteur d'environnement.
+        
+        Args:
+            bus: Numéro de bus I2C (par défaut 1)
+            address: Adresse I2C du capteur (par défaut 0x44)
+        """
+        self.bus_num = bus
+        self.address = address
+        
+    def read_data(self):
+        """
+        Lit les données du capteur.
+        
+        Returns:
+            dict: Dictionnaire contenant la température et l'humidité
+        """
+        try:
+            bus = smbus2.SMBus(self.bus_num)
+            # Demande de mesure
+            bus.write_byte(self.address, 0xFD)
+            time.sleep(0.1)
+            # Lecture des données
+            ans = smbus2.i2c_msg.read(self.address, 6)
+            bus.i2c_rdwr(ans)
+            data = list(ans)
+            
+            # Calcul des valeurs
+            t_ticks = data[0]*256 + data[1]  # Pas de CRC utilisé
+            rh_ticks = data[3]*256 + data[4]  # Pas de CRC utilisé
+            
+            temperature = (175*t_ticks)/65535. - 45
+            humidity = (125*rh_ticks)/65535. - 6
+            
+            return {
+                "temperature": round(temperature, 2),
+                "humidity": round(humidity, 2)
+            }
+            
+        except Exception as e:
+            logging.error(f"Erreur lors de la lecture du capteur: {e}")
+            return {
+                "temperature": 0.0,
+                "humidity": 0.0
+            }
+
+
+class Camera:
+    """Classe pour gérer la caméra Raspberry Pi."""
+    
+    def __init__(self):
+        """Initialisation de la caméra."""
+        self.image_path = config.PROJECT_DIR
+    
+    def capture_image(self, timestamp=None):
+        """
+        Capture une image avec la caméra.
+        
+        Args:
+            timestamp: Horodatage à utiliser pour le nom du fichier (optionnel)
+            
+        Returns:
+            tuple: (chemin de l'image, timestamp)
+        """
+        if timestamp is None:
+            timestamp = self.get_timestamp()
+        
+        folder_path = os.path.join(self.image_path, timestamp)
+        Path(folder_path).mkdir(parents=True, exist_ok=True)
+        
+        image_path = os.path.join(folder_path, f"{timestamp}.jpg")
+        
+        try:
+            # Configuration pour mode headless (sans écran)
+            cam = pc.Picamera2()
+            config = cam.create_still_configuration(main={"size": (800, 600)})
+            cam.configure(config)
+            cam.start()
+            # Attente pour stabilisation de l'exposition
+            time.sleep(2)
+            # Capture de l'image
+            cam.capture_file(image_path)
+            cam.close()
+            
+            logging.info(f"Image capturée: {image_path}")
+            return image_path, timestamp
+            
+        except Exception as e:
+            logging.error(f"Erreur lors de la capture d'image: {e}")
+            return None, timestamp
+    
+    @staticmethod
+    def get_timestamp():
+        """
+        Génère un horodatage pour nommer les fichiers.
+        
+        Returns:
+            str: Horodatage au format YYYY-MM-DD HH:MM:SS
+        """
+        now = datetime.now()
+        return now.strftime("%Y-%m-%d %H:%M:%S")
+
+
+class MicroController:
+    """Classe pour gérer la communication avec le microcontrôleur."""
+    
+    def __init__(self, bus=1, address=0x28):
+        """
+        Initialisation de la communication avec le microcontrôleur.
+        
+        Args:
+            bus: Numéro de bus I2C (par défaut 1)
+            address: Adresse I2C du microcontrôleur (par défaut 0x28)
+        """
+        self.bus_num = bus
+        self.address = address
+    
+    def send_interval(self, interval):
+        """
+        Envoie l'intervalle de capture au microcontrôleur.
+        
+        Args:
+            interval: Intervalle de capture en secondes
+        """
+        high_address = (interval >> 8) & 0xFF
+        low_address = interval & 0xFF
+        
+        try:
+            self._send_byte(high_address)
+            time.sleep(0.015)
+            self._send_byte(low_address)
+            
+            logging.info(f"Intervalle envoyé au microcontrôleur: {interval}s")
+            return True
+            
+        except Exception as e:
+            logging.error(f"Erreur lors de l'envoi au microcontrôleur: {e}")
+            return False
+    
+    def _send_byte(self, value):
+        """
+        Envoie un octet au microcontrôleur.
+        
+        Args:
+            value: Valeur à envoyer (0-255)
+        """
+        bus = smbus2.SMBus(self.bus_num)
+        bus.write_byte(self.address, value)
+
+
+# Instances globales
+env_sensor = EnvironmentSensor()
+camera = Camera()
+micro_controller = MicroController()

timelapse_offline.py

@@ -0,0 +1,70 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Script principal pour la capture d'images en mode hors ligne.
+Remplace l'ancien Time_Lapse_NoConnection.py
+"""
+
+import os
+import sys
+import time
+import logging
+from timelapse.config import config
+from timelapse.capture import timelapse_manager
+from timelapse.sensors import micro_controller
+
+
+def main():
+    """
+    Fonction principale pour la capture d'images en mode hors ligne.
+    """
+    logging.info("-------------------------------------------------------------------")
+    logging.info("Démarrage de la capture d'images en mode hors ligne")
+    
+    try:
+        # Vérifier si une configuration active existe
+        is_active_config = config.get("config_active", False)
+        is_stopped = config.get("stop_current_config", False)
+        remaining_images = config.get("nb_images_restantes", 0)
+        
+        # Si arrêté ou pas de configuration active, ne rien faire
+        if is_stopped:
+            logging.info("Configuration arrêtée, aucune action à effectuer")
+            return
+        
+        if not is_active_config:
+            logging.info("Aucune configuration active en mode hors ligne")
+            return
+            
+        if remaining_images <= 0:
+            logging.info("Aucune image restante à capturer")
+            # Désactiver la configuration puisqu'elle est terminée
+            config.update_config({"config_active": False})
+            return
+        
+        logging.info(f"Configuration: {remaining_images} images à capturer")
+        
+        # Exécuter la séquence de capture en mode hors ligne
+        sequence_completed = timelapse_manager.run_capture_sequence(online=False)
+        
+        # Obtenir l'intervalle de timelapse pour le microcontrôleur si nécessaire
+        interval = config.get("timelapse", 3)
+        if interval > 0 and is_active_config and not sequence_completed:
+            logging.info(f"Envoi de l'intervalle au microcontrôleur: {interval}s")
+            micro_controller.send_interval(interval)
+        else:
+            # Si la séquence est terminée, réinitialiser l'intervalle
+            if sequence_completed:
+                logging.info("Séquence terminée, réinitialisation de l'intervalle")
+                micro_controller.send_interval(0)  # 0 pour désactiver
+            
+    except Exception as e:
+        logging.error(f"Erreur lors de la capture en mode hors ligne: {e}")
+        sys.exit(1)
+    
+    logging.info("Capture en mode hors ligne terminée")
+
+
+if __name__ == "__main__":
+    main()

timelapse_online.py

@@ -0,0 +1,84 @@
+#!/usr/bin/env python3
+# coding: utf-8
+
+"""
+Script principal pour la capture d'images en mode connecté.
+Remplace l'ancien Time_Lapse_Connection.py
+"""
+
+import os
+import sys
+import time
+import logging
+from timelapse.config import config
+from timelapse.api_client import api_client
+from timelapse.capture import timelapse_manager
+
+
+def main():
+    """
+    Fonction principale pour la capture d'images en mode connecté.
+    """
+    logging.info("-------------------------------------------------------------------")
+    logging.info("Démarrage de la capture d'images en mode connecté")
+    
+    try:
+        # Vérifier le statut de la caméra via l'API
+        status = api_client.get_camera_status()
+        
+        if status is None:
+            logging.error("Impossible d'obtenir le statut de la caméra depuis l'API")
+            
+            # Dans le cas où une configuration active existe déjà, continuer avec celle-ci
+            if config.get("config_active", False) and config.get("nb_images_restantes", 0) > 0:
+                logging.info("Utilisation de la configuration locale existante")
+                timelapse_manager.run_capture_sequence(online=False)  # Mode hors ligne si API inaccessible
+            else:
+                logging.info("Pas de configuration active, abandon de la capture")
+            
+            sys.exit(1)
+            
+        # Mise à jour de la configuration
+        api_client.update_camera_config(status)
+        
+        # Vérification de l'état de maintenance
+        if status.get("maintenance", False):
+            logging.info("Caméra en mode maintenance, arrêt du script")
+            sys.exit(0)
+        
+        # Vérifier si un arrêt est demandé
+        if status.get("stop_flag", False):
+            logging.info("Demande d'arrêt détectée, confirmation au serveur")
+            api_client.confirm_stop()
+            
+            # Réinitialiser l'état actif
+            config.update_config({
+                "config_active": False, 
+                "nb_images_restantes": 0
+            })
+            
+            sys.exit(0)
+            
+        # Si le mode est IDLE et qu'aucune configuration n'est active, ne rien faire
+        if status.get("idle", True) and not config.get("config_active", False):
+            logging.info("Mode IDLE, aucune action à effectuer")
+            sys.exit(0)
+            
+        # Exécuter la séquence de capture
+        sequence_completed = timelapse_manager.run_capture_sequence(online=True)
+        
+        # Si la séquence est terminée (toutes les images capturées), notifier l'API
+        if sequence_completed and config.get("nb_images_restantes", 0) <= 0:
+            logging.info("Toutes les images ont été capturées, notification au serveur")
+            # TODO: Implémenter une méthode pour notifier la fin de la séquence
+            # api_client.notify_sequence_complete()
+        
+    except Exception as e:
+        logging.error(f"Erreur lors de la capture en mode connecté: {e}")
+        sys.exit(1)
+    
+    logging.info("Capture en mode connecté terminée")
+
+
+if __name__ == "__main__":
+    main()