"""Drain the dispatch service inbox once (QMS §7 asset events → knowledge-ingest)."""
from __future__ import annotations

import argparse
import sys
from pathlib import Path

ROOT = Path(__file__).resolve().parents[1]
if str(ROOT) not in sys.path:
    sys.path.insert(0, str(ROOT))

from app.integrations.dispatch_inbox_consumer import consume_once  # noqa: E402


def main(argv: list[str] | None = None) -> int:
    parser = argparse.ArgumentParser(description=__doc__)
    parser.add_argument("--limit", type=int, default=25)
    args = parser.parse_args(argv)
    print(consume_once(limit=args.limit))
    return 0


if __name__ == "__main__":
    raise SystemExit(main())