1
import time
2
from watchdog.observers import Observer
3
from watchdog.events import FileSystemEventHandler
4
from vault import add_to_vault
5
from ingest import process_file
6

7
class ForgeHandler(FileSystemEventHandler):
8
    def on_modified(self, event):
9
        if event.src_path.endswith(".mdx"):
10
            print(f"Core Alert: Synchronizing {event.src_path}")
11
            chunks = process_file(event.src_path)
12
            add_to_vault(chunks, {"id": event.src_path, "type": "auto_sync"})
13

14
observer = Observer()
15
observer.schedule(ForgeHandler(), path="./lessons", recursive=False)
16
observer.start()
17

18
try:
19
    while True: time.sleep(1)
20
except KeyboardInterrupt:
21
    observer.stop()

1
import chokidar from 'chokidar';
2
import { ingestFile } from './ingest.js';
3
import { addToVault } from './vault.js';
4

5
console.log("Sentinel Active: Watching the Forge...");
6

7
const watcher = chokidar.watch('./lessons', { persistent: true });
8

9
watcher.on('change', async (path) => {
10
    if (path.endsWith('.mdx')) {
11
        console.log(`Core Alert: Change detected in ${path}`);
12
        const chunks = await ingestFile(path);
13
        await addToVault(chunks, { id: path, type: 'auto_update' });
14
        console.log("Sentinel: JS Vault Synchronized.");
15
    }
16
});

1
import java.nio.file.*;
2
import static java.nio.file.StandardWatchEventKinds.*;
3

4
public class Sentinel {
5
    public static void watchForge() throws Exception {
6
        WatchService watcher = FileSystems.getDefault().newWatchService();
7
        Path dir = Paths.get("./lessons");
8
        dir.register(watcher, ENTRY_MODIFY);
9

10
        System.out.println("Sentinel Active: Watching the Forge...");
11

12
        while (true) {
13
            WatchKey key = watcher.take();
14
            for (WatchEvent<?> event : key.pollEvents()) {
15
                Path fileName = (Path) event.context();
16
                if (fileName.toString().endsWith(".mdx")) {
17
                    System.out.println("Core Alert: Syncing " + fileName);
18
                    // Trigger Ingestor and Vault logic from 2.2/2.3
19
                }
20
            }
21
            if (!key.reset()) break;
22
        }
23
    }
24
}