bcbd1bdb22
Integ / changes (push) Has been skipped
Pre-commit / pre-commit (push) Failing after 1s
CLI exit codes / changes (push) Has been skipped
Test (Install) / changes (push) Has been skipped
Test (Python) / changes (push) Has been skipped
Test (TypeScript) / changes (push) Has been skipped
CLI exit codes / cli-gate (push) Has been cancelled
Test (Install) / test-install-gate (push) Has been cancelled
Integ / integ-gate (push) Has been cancelled
Test (Python) / test-python-gate (push) Has been cancelled
Test (TypeScript) / test-typescript-gate (push) Has been cancelled
Test (Install) / python-minimal (3.12) (push) Has been cancelled
Test (Install) / python-minimal (3.11) (push) Has been cancelled
Test (Install) / python-extra (agno, mirage.agents.agno) (push) Has been cancelled
Test (Install) / python-extra (chroma, mirage.resource.chroma) (push) Has been cancelled
Test (Install) / python-extra (pdf, mirage.core.filetype.pdf) (push) Has been cancelled
Integ / integ (push) Has been cancelled
Integ / integ-database (push) Has been cancelled
Integ / integ-database-ts (push) Has been cancelled
Integ / integ-data (push) Has been cancelled
Integ / integ-ssh (push) Has been cancelled
Integ / integ-ssh-ts (push) Has been cancelled
Test (Python) / audit (push) Has been cancelled
Test (TypeScript) / test (push) Has been cancelled
Test (TypeScript) / python-fs-shim (push) Has been cancelled
CLI exit codes / Python CLI (push) Has been cancelled
CLI exit codes / TypeScript CLI (push) Has been cancelled
CLI exit codes / Cross-language snapshot interop (push) Has been cancelled
Test (Python) / test (push) Has been cancelled
Test (Python) / import-isolation (deepagents, openai, mirage.agents.openai_agents) (push) Has been cancelled
Test (Python) / import-isolation (deepagents, pydantic-ai, mirage.agents.pydantic_ai) (push) Has been cancelled
Integ / integ-ts (push) Has been cancelled
Integ / integ-fuse (push) Has been cancelled
Test (Install) / python-extra (databricks, mirage.resource.databricks_volume) (push) Has been cancelled
Test (Install) / python-extra (deepagents, mirage.agents.langchain) (push) Has been cancelled
Test (Install) / python-extra (email, mirage.resource.email) (push) Has been cancelled
Test (Install) / python-extra (fuse, mirage.fuse.mount) (push) Has been cancelled
Test (Install) / python-extra (hdf5, mirage.core.filetype.hdf5) (push) Has been cancelled
Test (Install) / python-extra (hf, mirage.resource.hf_buckets) (push) Has been cancelled
Test (Install) / python-extra (lancedb, mirage.resource.lancedb) (push) Has been cancelled
Test (Install) / python-extra (langfuse, mirage.resource.langfuse) (push) Has been cancelled
Test (Install) / python-extra (mongodb, mirage.resource.mongodb) (push) Has been cancelled
Test (Install) / python-extra (nextcloud, mirage.resource.nextcloud) (push) Has been cancelled
Test (Install) / python-extra (openai, mirage.agents.openai_agents) (push) Has been cancelled
Test (Install) / python-extra (openhands, mirage.agents.openhands, 3.12) (push) Has been cancelled
Test (Install) / python-extra (parquet, mirage.core.filetype.parquet) (push) Has been cancelled
Test (Install) / python-extra (postgres, mirage.resource.postgres) (push) Has been cancelled
Test (Install) / python-extra (pydantic-ai, mirage.agents.pydantic_ai) (push) Has been cancelled
Test (Install) / python-extra (qdrant, mirage.resource.qdrant) (push) Has been cancelled
Test (Install) / python-extra (redis, mirage.resource.redis) (push) Has been cancelled
Test (Install) / python-extra (s3, mirage.resource.s3) (push) Has been cancelled
Test (Install) / python-extra (ssh, mirage.resource.ssh) (push) Has been cancelled
Test (Install) / ts-minimal (push) Has been cancelled
333 lines
10 KiB
Python
333 lines
10 KiB
Python
# ========= Copyright 2026 @ Strukto.AI All Rights Reserved. =========
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
# ========= Copyright 2026 @ Strukto.AI All Rights Reserved. =========
|
|
|
|
from dataclasses import dataclass
|
|
from fnmatch import fnmatch
|
|
|
|
from mirage.types import FindType, PathSpec
|
|
|
|
|
|
def start_basename(path: PathSpec | str) -> str:
|
|
"""Basename of a find start path, as GNU would print and match it.
|
|
|
|
Single source of truth for the start path's own name across every
|
|
backend find op. Reads ``path.virtual`` (the path as written, with
|
|
its mount prefix) so the name is correct whether the start is the
|
|
mount root or a nested directory.
|
|
|
|
Args:
|
|
path (PathSpec | str): The find start path.
|
|
|
|
Returns:
|
|
str: The start path's basename, or "" for the bare root "/".
|
|
"""
|
|
original = path.virtual if isinstance(path, PathSpec) else str(path)
|
|
return original.rstrip("/").rsplit("/", 1)[-1]
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class FindEntry:
|
|
key: str
|
|
name: str
|
|
kind: str
|
|
depth: int
|
|
is_empty: bool | None = None
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class Name:
|
|
pattern: str
|
|
icase: bool = False
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class Path:
|
|
# `-path` matches the display path as printed (mount prefix + key),
|
|
# so the tree is stamped with the mount prefix before evaluation
|
|
# (`prefix_path_nodes`); entry keys stay mount-relative (#396).
|
|
pattern: str
|
|
prefix: str = ""
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class Type:
|
|
kind: str
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class Not:
|
|
kid: "PredNode"
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class And:
|
|
kids: list["PredNode"]
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class Or:
|
|
kids: list["PredNode"]
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class Empty:
|
|
pass
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class TrueNode:
|
|
pass
|
|
|
|
|
|
PredNode = Name | Path | Type | Empty | Not | And | Or | TrueNode
|
|
|
|
|
|
def display_path(prefix: str, key: str) -> str:
|
|
"""Display path for a mount-relative key, as ``find`` prints it.
|
|
|
|
Mirrors ``apply_mount_prefix`` for a single key: the mount root maps
|
|
to the bare prefix, everything else joins with one slash.
|
|
|
|
Args:
|
|
prefix (str): Mount prefix ("" for a root mount).
|
|
key (str): Mount-relative key with a leading slash.
|
|
"""
|
|
if not prefix:
|
|
return key
|
|
rel = key.lstrip("/")
|
|
return prefix if not rel else prefix + "/" + rel
|
|
|
|
|
|
def prefix_path_nodes(node: PredNode, prefix: str) -> PredNode:
|
|
"""Copy of a predicate tree with ``Path`` nodes bound to a prefix.
|
|
|
|
``-path`` matches the display path, but backend find ops evaluate
|
|
entries by mount-relative key; stamping the prefix onto the tree
|
|
keeps the evaluation site prefix-free (#396).
|
|
|
|
Args:
|
|
node (PredNode): Predicate tree to rewrite.
|
|
prefix (str): Mount prefix ("" leaves the tree unchanged).
|
|
"""
|
|
if not prefix:
|
|
return node
|
|
if isinstance(node, Path):
|
|
return Path(node.pattern, prefix=prefix)
|
|
if isinstance(node, Not):
|
|
return Not(prefix_path_nodes(node.kid, prefix))
|
|
if isinstance(node, And):
|
|
return And([prefix_path_nodes(kid, prefix) for kid in node.kids])
|
|
if isinstance(node, Or):
|
|
return Or([prefix_path_nodes(kid, prefix) for kid in node.kids])
|
|
return node
|
|
|
|
|
|
def eval_predicate(node: PredNode, entry: FindEntry) -> bool:
|
|
if isinstance(node, TrueNode):
|
|
return True
|
|
if isinstance(node, Empty):
|
|
return entry.is_empty is True
|
|
if isinstance(node, Name):
|
|
if node.icase:
|
|
return fnmatch(entry.name.lower(), node.pattern.lower())
|
|
return fnmatch(entry.name, node.pattern)
|
|
if isinstance(node, Path):
|
|
return fnmatch(display_path(node.prefix, entry.key), node.pattern)
|
|
if isinstance(node, Type):
|
|
return entry.kind == node.kind
|
|
if isinstance(node, Not):
|
|
return not eval_predicate(node.kid, entry)
|
|
if isinstance(node, And):
|
|
return all(eval_predicate(kid, entry) for kid in node.kids)
|
|
if isinstance(node, Or):
|
|
return any(eval_predicate(kid, entry) for kid in node.kids)
|
|
raise TypeError(f"unknown predicate node: {node!r}")
|
|
|
|
|
|
def tree_has_type(node: PredNode) -> bool:
|
|
if isinstance(node, Type):
|
|
return True
|
|
if isinstance(node, Not):
|
|
return tree_has_type(node.kid)
|
|
if isinstance(node, (And, Or)):
|
|
return any(tree_has_type(kid) for kid in node.kids)
|
|
return False
|
|
|
|
|
|
def tree_has_empty(node: PredNode) -> bool:
|
|
if isinstance(node, Empty):
|
|
return True
|
|
if isinstance(node, Not):
|
|
return tree_has_empty(node.kid)
|
|
if isinstance(node, (And, Or)):
|
|
return any(tree_has_empty(kid) for kid in node.kids)
|
|
return False
|
|
|
|
|
|
def keep(entry: FindEntry, tree: PredNode, min_depth: int | None) -> bool:
|
|
if min_depth is not None and entry.depth < min_depth:
|
|
return False
|
|
return eval_predicate(tree, entry)
|
|
|
|
|
|
def emit_start_path(
|
|
results: list[str],
|
|
start_key: str,
|
|
start_name: str,
|
|
*,
|
|
kind: str,
|
|
is_empty: bool | None,
|
|
exists: bool,
|
|
tree: PredNode,
|
|
maxdepth: int | None,
|
|
mindepth: int | None,
|
|
size: int | None = None,
|
|
min_size: int | None = None,
|
|
max_size: int | None = None,
|
|
) -> None:
|
|
"""Append the search start path to results when it matches.
|
|
|
|
Shared by every backend find op so the start path is emitted
|
|
uniformly. GNU lists the start path itself at depth 0, so bare
|
|
``find <dir>``, ``-type d`` on the root, ``-maxdepth 0`` (just the
|
|
start), ``-mindepth 0`` (start included), and ``-name``/``-iname``
|
|
against the start's own basename all behave the same everywhere.
|
|
|
|
A directory start path contributes size ``0`` to ``-size``
|
|
filtering (mirage directories have no meaningful content size; a
|
|
documented divergence from GNU, which compares the inode size), so
|
|
``-size +N`` excludes directory roots and ``-size -N`` keeps them
|
|
(#318). Backends whose start path can be a file
|
|
(ram/redis/chroma/dify/notion) pass the start's size so
|
|
``find <file> -size`` filters the start like GNU does; a file start
|
|
with an unknown size (``None``) skips the filter.
|
|
|
|
Args:
|
|
results (list[str]): Mount-relative result keys to append to.
|
|
start_key (str): Mount-relative key of the start path.
|
|
start_name (str): Basename of the start path as written.
|
|
kind (str): "d" for a directory or "f" for a file.
|
|
is_empty (bool | None): Emptiness for ``-empty``; None if unknown.
|
|
exists (bool): Whether the start path exists.
|
|
tree (PredNode): Predicate tree.
|
|
maxdepth (int | None): ``-maxdepth`` value.
|
|
mindepth (int | None): ``-mindepth`` value.
|
|
size (int | None): Start path size in bytes when it is a file.
|
|
min_size (int | None): ``-size +`` lower bound in bytes.
|
|
max_size (int | None): ``-size -`` upper bound in bytes.
|
|
"""
|
|
if not exists:
|
|
return
|
|
if maxdepth is not None and maxdepth < 0:
|
|
return
|
|
entry = FindEntry(key=start_key,
|
|
name=start_name,
|
|
kind=kind,
|
|
depth=0,
|
|
is_empty=is_empty)
|
|
if not keep(entry, tree, mindepth):
|
|
return
|
|
if min_size is not None or max_size is not None:
|
|
# Directories count as size 0 for -size: GNU compares the inode size
|
|
# (e.g. 4096 on ext4); see CLAUDE.md Rules.
|
|
effective = 0 if kind != "f" else size
|
|
if effective is not None:
|
|
if min_size is not None and effective < min_size:
|
|
return
|
|
if max_size is not None and effective > max_size:
|
|
return
|
|
results.append(start_key)
|
|
|
|
|
|
def _type_kind(type_arg: FindType | str | None) -> str | None:
|
|
if type_arg is None:
|
|
return None
|
|
if isinstance(type_arg, FindType):
|
|
return "d" if type_arg == FindType.DIRECTORY else "f"
|
|
if type_arg in ("file", "directory"):
|
|
return "f" if type_arg == "file" else "d"
|
|
return type_arg
|
|
|
|
|
|
def build_tree(
|
|
*,
|
|
name: str | None = None,
|
|
iname: str | None = None,
|
|
path_pattern: str | None = None,
|
|
type: FindType | str | None = None,
|
|
name_exclude: str | None = None,
|
|
or_names: list[str] | None = None,
|
|
empty: bool = False,
|
|
) -> PredNode:
|
|
kids: list[PredNode] = []
|
|
if or_names:
|
|
kids.append(Or([Name(pat) for pat in or_names]))
|
|
elif name is not None:
|
|
kids.append(Name(name))
|
|
if iname is not None:
|
|
kids.append(Name(iname, icase=True))
|
|
if path_pattern is not None:
|
|
kids.append(Path(path_pattern))
|
|
type_kind = _type_kind(type)
|
|
if type_kind is not None:
|
|
kids.append(Type(type_kind))
|
|
if name_exclude is not None:
|
|
kids.append(Not(Name(name_exclude)))
|
|
if empty:
|
|
kids.append(Empty())
|
|
if not kids:
|
|
return TrueNode()
|
|
if len(kids) == 1:
|
|
return kids[0]
|
|
return And(kids)
|
|
|
|
|
|
def compute_nonempty_dirs(keys: list[str]) -> set[str]:
|
|
nonempty: set[str] = set()
|
|
for k in keys:
|
|
cut = k.rfind("/")
|
|
parent = k[:cut] if cut > 0 else "/"
|
|
nonempty.add(parent)
|
|
return nonempty
|
|
|
|
|
|
@dataclass
|
|
class FindArgs:
|
|
name: str | None = None
|
|
iname: str | None = None
|
|
path_pattern: str | None = None
|
|
type: FindType | str | None = None
|
|
min_size: int | None = None
|
|
max_size: int | None = None
|
|
mtime_min: float | None = None
|
|
mtime_max: float | None = None
|
|
maxdepth: int | None = None
|
|
mindepth: int | None = None
|
|
name_exclude: str | None = None
|
|
or_names: list[str] | None = None
|
|
empty: bool = False
|
|
tree: PredNode | None = None
|
|
|
|
|
|
def args_to_tree(args: FindArgs) -> PredNode:
|
|
if args.tree is not None:
|
|
return args.tree
|
|
return build_tree(name=args.name,
|
|
iname=args.iname,
|
|
path_pattern=args.path_pattern,
|
|
type=args.type,
|
|
name_exclude=args.name_exclude,
|
|
or_names=args.or_names,
|
|
empty=args.empty)
|