feat: add import filter controls

Author: solomonneas

CHANGELOG.md

@@ -52,10 +52,13 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - `brigade work import triage` to group pending imports by source and kind.
 - `brigade work import dismiss` to close noisy imports without promoting them.
 - `brigade work import promote --all` with optional `--source` and `--kind` filters for batch promotion.
+- `brigade work import list/triage/promote/dismiss` metadata filters for scanner-specific fields such as `handoff_issue_category`.
+- `brigade work import dismiss --all` for filtered bulk dismissal of pending imports.
 - `brigade handoff doctor` to compare pending `.claude` and `.codex` memory handoffs against gitignored local source config.
 - Repo installs now include `.brigade/handoff-sources.example.json` as the local handoff ingestor source-list contract.
 - `brigade handoff doctor` ingestor-log checks for stale latest-run logs, skipped malformed handoffs, warning summaries, and no-reply/no-update masking signals.
 - `brigade handoff issues` and `brigade handoff import-issues` to turn handoff ingest warnings into grouped repair guidance and local work imports.
+- `brigade handoff issues --category` and `brigade handoff import-issues --category` for category-limited handoff issue review/import.
 - `docs/import-schema.md` documenting the local import JSONL contract for scanners and wrappers.
 - Cybersecurity plugin roadmap covering broad agent-workspace security checks plus Brigade-specific scanner, doctor, import, and multi-harness security checks.
 - Built-in `security` station and `brigade security scan` for read-only agent workspace security checks.

README.md

@@ -177,7 +177,9 @@ brigade work import memory-care
 brigade work import triage
 brigade work import promote <import-id>
 brigade work import promote --all --source memory-care --kind task
+brigade work import promote --all --source handoff-ingest --metadata handoff_issue_category=route-skip
 brigade work import dismiss <import-id> --reason "not actionable"
+brigade work import dismiss --all --source handoff-ingest --metadata handoff_issue_category=skip --reason "historical noise"
 brigade work run
 brigade work run --queue-next
 brigade work run "review today's changes"
@@ -281,11 +283,11 @@ Import inbox commands:
 - `brigade work import ingest imports.jsonl` ingests scanner output.
 - `brigade work import memory-care` converts `memory/cards/decay/refresh-queue.json` into imports.
 - `brigade work import chat-sweep` converts `.brigade/chat-memory-sweeps/latest.json` issues into imports.
-- `brigade work import triage` groups pending imports by source and kind.
+- `brigade work import triage` groups pending imports by source and kind; use `--source`, `--kind`, and repeatable `--metadata key=value` to narrow noisy queues.
 - `brigade work import show <import-id>` inspects one import.
-- `brigade work import dismiss <import-id>` removes noise.
+- `brigade work import dismiss <import-id>` removes one noisy item, while `dismiss --all` closes filtered batches.
 - `brigade work import promote <import-id>` promotes one reviewed import into the task ledger.
-- `brigade work import promote --all --source memory-care --kind task` batch-promotes filtered imports.
+- `brigade work import promote --all --source memory-care --kind task` batch-promotes filtered imports; metadata filters also work for scanner-specific fields such as `handoff_issue_category=route-skip`.
 
 Imports are stored under `.brigade/work/imports/inbox.jsonl`, stay gitignored, and do not write memory directly.
 

ROADMAP.md

@@ -27,8 +27,8 @@ Goal: make Brigade a safe target for local automations that discover useful work
 - Let wrappers import candidate tasks, findings, decisions, preferences, incidents, links, and commands without knowing Brigade internals.
 - Convert memory-care refresh queues into local task imports.
 - Promote selected imports into the work task ledger, with source metadata preserved.
-- Dismiss noisy imports so scanners can be useful without leaving permanent queue clutter.
-- Batch-promote reviewed imports by source and kind.
+- Dismiss noisy imports so scanners can be useful without leaving permanent queue clutter. Status: started with single-item dismissal and filtered `dismiss --all`.
+- Batch-promote reviewed imports by source and kind. Status: started with source, kind, and metadata filters across list, triage, promote, and dismiss.
 - Surface pending imports and grouped counts in `brigade work brief` so discovered work appears in the daily flow.
 
 ## Later Phase: Chat Surface Scanners

src/brigade/cli.py

@@ -120,11 +120,13 @@ def _build_parser() -> argparse.ArgumentParser:
     p_handoff_issues.add_argument("--sources", type=Path, default=None, help="Override .brigade/handoff-sources.json.")
     p_handoff_issues.add_argument("--json", action="store_true", help="Print machine-readable JSON.")
     p_handoff_issues.add_argument("--limit", type=int, default=20, help="Maximum issue rows to print.")
+    p_handoff_issues.add_argument("--category", action="append", default=[], help="Limit to one issue category. May be repeated.")
     p_handoff_import_issues = handoff_sub.add_parser("import-issues", help="Import handoff ingest issues into the work inbox.")
     p_handoff_import_issues.add_argument("--target", "-t", type=Path, default=Path("."), help="Repo or workspace to update.")
     p_handoff_import_issues.add_argument("--sources", type=Path, default=None, help="Override .brigade/handoff-sources.json.")
     p_handoff_import_issues.add_argument("--dry-run", action="store_true", help="Report without writing imports.")
     p_handoff_import_issues.add_argument("--json", action="store_true", help="Print machine-readable JSON.")
+    p_handoff_import_issues.add_argument("--category", action="append", default=[], help="Import only one issue category. May be repeated.")
 
     # work
     p_work = sub.add_parser("work", help="Inspect and manage a daily Brigade work session.")
@@ -199,6 +201,14 @@ def _build_parser() -> argparse.ArgumentParser:
     p_work_import_list.add_argument("--all", action="store_true", help="Include promoted imports.")
     p_work_import_list.add_argument("--json", action="store_true", help="Print machine-readable JSON.")
     p_work_import_list.add_argument("--limit", type=int, default=20, help="Maximum imports to show.")
+    p_work_import_list.add_argument("--source", default=None, help="Filter by import source.")
+    p_work_import_list.add_argument(
+        "--kind",
+        choices=["task", "finding", "decision", "preference", "incident", "link", "command"],
+        default=None,
+        help="Filter by import kind.",
+    )
+    p_work_import_list.add_argument("--metadata", action="append", default=[], help="Filter by metadata key=value. May be repeated.")
     p_work_import_validate = import_sub.add_parser("validate", help="Validate a work import JSONL file.")
     p_work_import_validate.add_argument("input_path", type=Path, help="JSONL file to validate.")
     p_work_import_validate.add_argument("--json", action="store_true", help="Print machine-readable JSON.")
@@ -232,6 +242,14 @@ def _build_parser() -> argparse.ArgumentParser:
     p_work_import_triage.add_argument("--target", "-t", type=Path, default=Path("."), help="Repo or workspace to inspect.")
     p_work_import_triage.add_argument("--json", action="store_true", help="Print machine-readable JSON.")
     p_work_import_triage.add_argument("--limit", type=int, default=50, help="Maximum imports per group to show.")
+    p_work_import_triage.add_argument("--source", default=None, help="Filter by import source.")
+    p_work_import_triage.add_argument(
+        "--kind",
+        choices=["task", "finding", "decision", "preference", "incident", "link", "command"],
+        default=None,
+        help="Filter by import kind.",
+    )
+    p_work_import_triage.add_argument("--metadata", action="append", default=[], help="Filter by metadata key=value. May be repeated.")
     p_work_import_show = import_sub.add_parser("show", help="Show one work import.")
     p_work_import_show.add_argument("import_id", help="Import id or unique prefix.")
     p_work_import_show.add_argument("--target", "-t", type=Path, default=Path("."), help="Repo or workspace to inspect.")
@@ -246,9 +264,19 @@ def _build_parser() -> argparse.ArgumentParser:
         help="Limit --all promotion to one kind.",
     )
     p_work_import_promote.add_argument("--source", default=None, help="Limit --all promotion to one source.")
+    p_work_import_promote.add_argument("--metadata", action="append", default=[], help="Limit --all promotion by metadata key=value. May be repeated.")
     p_work_import_dismiss = import_sub.add_parser("dismiss", help="Dismiss one pending work import.")
-    p_work_import_dismiss.add_argument("import_id", help="Import id or unique prefix.")
+    p_work_import_dismiss.add_argument("import_id", nargs="?", help="Import id or unique prefix.")
     p_work_import_dismiss.add_argument("--target", "-t", type=Path, default=Path("."), help="Repo or workspace to update.")
+    p_work_import_dismiss.add_argument("--all", action="store_true", help="Dismiss all pending imports matching filters.")
+    p_work_import_dismiss.add_argument(
+        "--kind",
+        choices=["task", "finding", "decision", "preference", "incident", "link", "command"],
+        default=None,
+        help="Limit --all dismissal to one kind.",
+    )
+    p_work_import_dismiss.add_argument("--source", default=None, help="Limit --all dismissal to one source.")
+    p_work_import_dismiss.add_argument("--metadata", action="append", default=[], help="Limit --all dismissal by metadata key=value. May be repeated.")
     p_work_import_dismiss.add_argument("--reason", default=None, help="Optional dismiss reason.")
     p_work_list = work_sub.add_parser("list", help="List recent Brigade work sessions.")
     p_work_list.add_argument("--target", "-t", type=Path, default=Path("."), help="Repo or workspace to inspect.")
@@ -651,9 +679,21 @@ def main(argv=None) -> int:
         if args.handoff_command == "doctor":
             return handoff_cmd.doctor(target=args.target, sources=args.sources, json_output=args.json)
         if args.handoff_command == "issues":
-            return handoff_cmd.issues(target=args.target, sources=args.sources, json_output=args.json, limit=args.limit)
+            return handoff_cmd.issues(
+                target=args.target,
+                sources=args.sources,
+                json_output=args.json,
+                limit=args.limit,
+                categories=args.category,
+            )
         if args.handoff_command == "import-issues":
-            return handoff_cmd.import_issues(target=args.target, sources=args.sources, dry_run=args.dry_run, json_output=args.json)
+            return handoff_cmd.import_issues(
+                target=args.target,
+                sources=args.sources,
+                dry_run=args.dry_run,
+                json_output=args.json,
+                categories=args.category,
+            )
         parser.error(f"unknown handoff command: {args.handoff_command}")
         return 2
     if cmd == "work":
@@ -708,6 +748,9 @@ def main(argv=None) -> int:
                     all_imports=args.all,
                     json_output=args.json,
                     limit=args.limit,
+                    source=args.source,
+                    kind=args.kind,
+                    metadata=args.metadata,
                 )
             if args.import_command == "validate":
                 return work_cmd.import_validate(input_path=args.input_path, json_output=args.json)
@@ -733,7 +776,14 @@ def main(argv=None) -> int:
                     json_output=args.json,
                 )
             if args.import_command == "triage":
-                return work_cmd.import_triage(target=args.target, json_output=args.json, limit=args.limit)
+                return work_cmd.import_triage(
+                    target=args.target,
+                    json_output=args.json,
+                    limit=args.limit,
+                    source=args.source,
+                    kind=args.kind,
+                    metadata=args.metadata,
+                )
             if args.import_command == "show":
                 return work_cmd.import_show(target=args.target, import_id=args.import_id)
             if args.import_command == "promote":
@@ -743,9 +793,18 @@ def main(argv=None) -> int:
                     all_matching=args.all,
                     kind=args.kind,
                     source=args.source,
+                    metadata=args.metadata,
                 )
             if args.import_command == "dismiss":
-                return work_cmd.import_dismiss(target=args.target, import_id=args.import_id, reason=args.reason)
+                return work_cmd.import_dismiss(
+                    target=args.target,
+                    import_id=args.import_id,
+                    reason=args.reason,
+                    all_matching=args.all,
+                    kind=args.kind,
+                    source=args.source,
+                    metadata=args.metadata,
+                )
             parser.error(f"unknown import command: {args.import_command}")
             return 2
         if args.work_command == "list":

src/brigade/handoff_cmd.py

@@ -260,7 +260,11 @@ def doctor_checks(target: Path, sources: Path | None = None) -> list[tuple[str,
     return checks
 
 
-def collect_issues(target: Path, sources: Path | None = None) -> list[HandoffIssue]:
+def collect_issues(
+    target: Path,
+    sources: Path | None = None,
+    categories: list[str] | None = None,
+) -> list[HandoffIssue]:
     health = inspect(target, sources=sources)
     issues: list[HandoffIssue] = []
     for inbox in health.inboxes:
@@ -320,7 +324,7 @@ def collect_issues(target: Path, sources: Path | None = None) -> list[HandoffIss
             )
         if ingestor.exists and ingestor.log_path is not None:
             issues.extend(_parse_ingestor_log_issues(ingestor.log_path))
-    return _dedupe_issues(issues)
+    return _filter_issues_by_category(_dedupe_issues(issues), categories)
 
 
 def issues(
@@ -329,6 +333,7 @@ def issues(
     sources: Path | None = None,
     json_output: bool = False,
     limit: int = 20,
+    categories: list[str] | None = None,
 ) -> int:
     if limit < 1:
         print("error: --limit must be a positive integer", file=sys.stderr)
@@ -337,7 +342,7 @@ def issues(
     if not target.is_dir():
         print(f"error: --target is not a directory: {target}", file=sys.stderr)
         return 2
-    found = collect_issues(target, sources=sources)
+    found = collect_issues(target, sources=sources, categories=categories)
     payload = _issues_payload(target, found)
     if json_output:
         print(json.dumps(payload, indent=2, sort_keys=True))
@@ -365,12 +370,13 @@ def import_issues(
     sources: Path | None = None,
     dry_run: bool = False,
     json_output: bool = False,
+    categories: list[str] | None = None,
 ) -> int:
     target = target.expanduser().resolve()
     if not target.is_dir():
         print(f"error: --target is not a directory: {target}", file=sys.stderr)
         return 2
-    found = collect_issues(target, sources=sources)
+    found = collect_issues(target, sources=sources, categories=categories)
     records = [issue.as_import_record() for issue in found]
     from . import work_cmd
 
@@ -441,6 +447,16 @@ def _dedupe_issues(issues: list[HandoffIssue]) -> list[HandoffIssue]:
     return deduped
 
 
+def _filter_issues_by_category(
+    issues: list[HandoffIssue],
+    categories: list[str] | None,
+) -> list[HandoffIssue]:
+    wanted = {category for category in categories or [] if category}
+    if not wanted:
+        return issues
+    return [issue for issue in issues if issue.category in wanted]
+
+
 def _make_issue(
     *,
     category: str,