from reactivity.hmr.fs import *¶

@defaultdict
def fs_signals():
    return Subscribable(context=HMR_CONTEXT)

@cache
def setup_fs_audithook():
    @sys.addaudithook
    def _(event: str, args: tuple):
        if event == "open":
            file, _, flags = args

            if (flags % 2 == 0) and _filters and isinstance(file, str) and HMR_CONTEXT.leaf.current_computations:
                p = Path(file).resolve()
                if any(f(p) for f in _filters):
                    track(p)

def track(file: Path):
    fs_signals[file].track()

def notify(file: Path):
    fs_signals[file].notify()