tf_code/packages/opencode/src/file/watcher.ts

import z from "zod/v4"
import { Bus } from "../bus"
import chokidar from "chokidar"
import { Flag } from "../flag/flag"
import { Instance } from "../project/instance"
import { Log } from "../util/log"
import { FileIgnore } from "./ignore"
import { Config } from "../config/config"

export namespace FileWatcher {
  const log = Log.create({ service: "file.watcher" })

  export const Event = {
    Updated: Bus.event(
      "file.watcher.updated",
      z.object({
        file: z.string(),
        event: z.union([z.literal("add"), z.literal("change"), z.literal("unlink")]),
      }),
    ),
  }

  const state = Instance.state(
    async () => {
      if (Instance.project.vcs !== "git") return {}
      log.info("init")
      const cfg = await Config.get()
      const ignore = (cfg.watcher?.ignore ?? []).map((v) => new Bun.Glob(v))
      const watcher = chokidar.watch(Instance.directory, {
        ignoreInitial: true,
        ignored: (filepath) => {
          return FileIgnore.match(filepath, {
            whitelist: [new Bun.Glob("**/.git/{index,logs/HEAD}")],
            extra: ignore,
          })
        },
      })
      watcher.on("change", (file) => {
        Bus.publish(Event.Updated, { file, event: "change" })
      })
      watcher.on("add", (file) => {
        Bus.publish(Event.Updated, { file, event: "add" })
      })
      watcher.on("unlink", (file) => {
        Bus.publish(Event.Updated, { file, event: "unlink" })
      })
      watcher.on("ready", () => {
        log.info("ready")
      })
      return { watcher }
    },
    async (state) => {
      state.watcher?.close()
    },
  )

  export function init() {
    if (!Flag.OPENCODE_EXPERIMENTAL_WATCHER) return
    state()
  }
}