from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
import requests
import time

class UpdateHandler(FileSystemEventHandler):
    def on_modified(self, event):
        if not event.is_directory:
            print(f"Fichier modifié : {event.src_path}")
            # Extraire l'ID du document depuis le chemin (à adapter)
            document_id = event.src_path.split('/')[-1].split('.')[0]
            requests.get(f"http://knowledge.local/update_document/{document_id}")

if __name__ == "__main__":
    observer = Observer()
    observer.schedule(UpdateHandler(), '/var/sftp/uploads', recursive=True)
    observer.start()
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        observer.stop()
    observer.join()