8eda97cafb
Follow-up to the salvaged mirror commit. - Opt-in (`mirror_to_session: true`, or `hermes webhook subscribe --mirror-to-session`), default off like cron's `mirror_delivery`. The mirrored text lands with user authority in the target chat, and on `deliver_only` routes it is the raw rendered payload, so a route author has to ask for it. Only a real boolean `true` opts in (a YAML string "false" no longer does). - The mirror runs inside the routed profile's scope, so a `/p/<profile>/` delivery writes into THAT profile's state.db. A Telegram DM chat_id is the user's id on every bot; an unscoped mirror landed in the default profile's DM with the same person (live-probed). - Tests trimmed to two invariants against a real state.db: an opted-in delivery lands in the routed profile's chat session and not the default profile's; a route without the opt-in (including `mirror_to_session: "false"`) never touches the target transcript. - Docs: webhooks guide section "Replying to a delivery" (default, profile scope, trust note), CLI reference row, bundled hermes-agent skill reference.
67 lines
3.6 KiB
Python
67 lines
3.6 KiB
Python
"""``hermes webhook`` subcommand parser."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from typing import Callable
|
|
|
|
|
|
def build_webhook_parser(subparsers, *, cmd_webhook: Callable) -> None:
|
|
"""Attach the ``webhook`` subcommand to ``subparsers``."""
|
|
webhook_parser = subparsers.add_parser(
|
|
"webhook", help="Manage dynamic webhook subscriptions",
|
|
description="Create, list, and remove webhook subscriptions for event-driven agent activation",
|
|
)
|
|
webhook_subparsers = webhook_parser.add_subparsers(dest="webhook_action")
|
|
|
|
wh_sub = webhook_subparsers.add_parser(
|
|
"subscribe", aliases=["add"], help="Create a webhook subscription")
|
|
wh_sub.add_argument("name", help="Route name (used in URL: /webhooks/<name>)")
|
|
wh_sub.add_argument(
|
|
"--prompt", default="", help="Prompt template with {dot.notation} payload refs")
|
|
wh_sub.add_argument("--events", default="", help="Comma-separated event types to accept")
|
|
wh_sub.add_argument("--description", default="", help="What this subscription does")
|
|
wh_sub.add_argument("--skills", default="", help="Comma-separated skill names to load")
|
|
wh_sub.add_argument(
|
|
"--deliver", default="log", help="Delivery target: log, telegram, discord, slack, etc.")
|
|
wh_sub.add_argument(
|
|
"--deliver-chat-id", default="", help="Target chat ID for cross-platform delivery")
|
|
wh_sub.add_argument("--secret", default="", help="HMAC secret (auto-generated if omitted)")
|
|
wh_sub.add_argument(
|
|
"--route-profile", dest="route_profile", default=None, metavar="PROFILE",
|
|
help="Bind the route to a multiplexed profile: only POSTs to /p/PROFILE/webhooks/<name> "
|
|
"are accepted and the agent runs as that profile (default: default; kept on update). "
|
|
"Distinct from the global -p/--profile, which picks the gateway whose subscriptions "
|
|
"file is written.")
|
|
wh_sub.add_argument(
|
|
"--deliver-only", action="store_true",
|
|
help="Skip the agent — deliver the rendered prompt directly as the "
|
|
"message. Zero LLM cost. Requires --deliver to be a real target "
|
|
"(not 'log').")
|
|
wh_sub.add_argument(
|
|
"--mirror-to-session", action="store_true",
|
|
help="Also write each delivered message into the target chat's session, so replying to it "
|
|
"in that chat has context. Only for sources whose content you trust in your conversation.")
|
|
wh_sub.add_argument(
|
|
"--script", default="",
|
|
help="Filter/transform script under ~/.hermes/scripts/. The route "
|
|
"payload is passed as JSON on stdin; empty stdout, [SILENT], or a "
|
|
"nonzero exit code ignores the webhook.")
|
|
wh_sub.add_argument(
|
|
"--cron-job", default="",
|
|
help="Fire an existing cron job (by ID or name) when this route receives an event, instead of "
|
|
"starting a fresh agent run. The rendered --prompt template is passed to the job as transient "
|
|
"per-run context; the job's own prompt, skills, and delivery settings apply. Mutually exclusive "
|
|
"with --deliver-only.")
|
|
|
|
webhook_subparsers.add_parser("list", aliases=["ls"], help="List all dynamic subscriptions")
|
|
|
|
wh_rm = webhook_subparsers.add_parser("remove", aliases=["rm"], help="Remove a subscription")
|
|
wh_rm.add_argument("name", help="Subscription name to remove")
|
|
|
|
wh_test = webhook_subparsers.add_parser("test", help="Send a test POST to a webhook route")
|
|
wh_test.add_argument("name", help="Subscription name to test")
|
|
wh_test.add_argument(
|
|
"--payload", default="", help="JSON payload to send (default: test payload)")
|
|
|
|
webhook_parser.set_defaults(func=cmd_webhook)
|