FileWatcher.py

# BEGIN
#
# IMPORT necessary modules:
#     - time
#     - logging
#     - watchdog.observers.Observer
#     - watchdog.events.FileSystemEventHandler
#     - os
import time
import logging
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
import os
# SETUP logging:
#     - Define log file name
#     - Configure logging to write to both file and console
#     - Set format and logging level
log_file_name = "log.txt"
logging.basicConfig(filename=log_file_name,level=logging.INFO,datefmt="%d/%m/%Y %I:%M:%S %p")

# DEFINE FileEventHandler class (inherits from FileSystemEventHandler):
#
#     METHOD on_created(event):
#         IF event is not a directory:
#             Log "File created" with event path
#
#     METHOD on_modified(event):
#         IF event is not a directory:
#             Log "File modified" with event path
#
#     METHOD on_deleted(event):
#         IF event is not a directory:
#             Log "File deleted" with event path
class FileWatcher(FileSystemEventHandler):
    def on_created(self, event):
        if not event.is_directory:
            logging.log(logging.INFO, msg="file created {event.src_path}")


# DEFINE start_watching(directory_path):
#
#     IF directory_path does not exist:
#         Log error and RETURN
#
#     CREATE instance of FileEventHandler
#     CREATE Observer
#     Schedule observer to watch directory_path (non-recursively)
#     START observer
#     Log "Started watching"
#
#     TRY:
#         LOOP forever:
#             Sleep for a short time (e.g., 1 second)
#     EXCEPT KeyboardInterrupt:
#         STOP observer
#         Log "Stopped watching"
#     JOIN observer thread
def start_watching(directory_path):
    event_handler = FileWatcher()
    observer = Observer()
    observer.schedule(event_handler, path=directory_path, recursive=True)
    observer.start()
    logging.log(logging.INFO, msg="file watcher started")
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        observer.stop()
        logging.log(logging.INFO, msg="file watcher stopped")
        observer.join()

# IN MAIN block:
#     SET folder_to_watch (e.g., "C:\\your\\path")
#     CALL start_watching with folder_to_watch
#
# END