🧠 Padrões avançados de skills

# ~/.hermes/skills/briefing-diario/skill.py
from hermes import skill, invoke
from datetime import date

@skill(
    name="briefing-diario",
    description="Use when the user asks for the daily briefing, morning summary, or 'what's new today'.",
)
def run(ctx):
    # Cada invoke roda outra skill registrada e retorna structured output
    calendar = invoke("calendar-today", {"user": ctx.user})
    inbox    = invoke("inbox-triage",   {"since": "08:00", "max": 20})
    news     = invoke("news-digest",    {"topics": ctx.prefs["topics"], "n": 5})

    return ctx.render(
        "briefing.md.j2",
        date=date.today().isoformat(),
        calendar=calendar,
        inbox=inbox,
        news=news,
    )

$ hermes skill graph briefing-diario

briefing-diario
├── calendar-today        (deps: mcp/google-calendar)
├── inbox-triage          (deps: mcp/gmail, skill/summarize-thread)
│   └── summarize-thread  (deps: llm/haiku)
└── news-digest           (deps: tool/rss-fetch, skill/dedupe-articles)
    └── dedupe-articles   (deps: llm/haiku)

5 skills · 4 MCP/tool deps · depth=2 · no cycles ✓

# ~/.hermes/skills/onboard-customer/skill.py
from hermes import skill, step, invoke

@skill(name="onboard-customer",
       description="Use when onboarding a new B2B customer end-to-end.")
class Onboard:

    @step(order=1)
    def validate_input(self, ctx, state):
        assert state["email"] and "@" in state["email"]
        state["domain"] = state["email"].split("@")[1]
        return state

    @step(order=2, retries=3, backoff=2.0)
    def create_account(self, ctx, state):
        resp = ctx.tools.crm.create_account(
            email=state["email"], domain=state["domain"]
        )
        state["account_id"] = resp["id"]
        return state

    @step(order=3, depends_on=["create_account"])
    def send_welcome(self, ctx, state):
        invoke("send-email", {
            "to": state["email"],
            "template": "welcome-b2b",
            "vars": {"account_id": state["account_id"]},
        })
        state["welcomed_at"] = ctx.now().isoformat()
        return state

    @step(order=4, depends_on=["create_account"], on_error="skip")
    def schedule_kickoff(self, ctx, state):
        slot = invoke("calendar-find-slot", {"duration_min": 30})
        state["kickoff"] = slot
        return state

# ~/.hermes/skills/policy-qa/skill.py
import chromadb
from chromadb.utils import embedding_functions
from hermes import skill

EMB = embedding_functions.SentenceTransformerEmbeddingFunction(
    model_name="all-MiniLM-L6-v2"
)
_client = chromadb.PersistentClient(path=".hermes_data/policy")
_coll = _client.get_or_create_collection(
    name="policies", embedding_function=EMB
)

@skill(
    name="policy-qa",
    description=("Use when the user asks about internal HR, security, "
                 "travel or expense policies."),
)
def run(ctx, question: str):
    hits = _coll.query(query_texts=[question], n_results=5)
    snippets = [
        f"[{m['source']}] {d}"
        for d, m in zip(hits["documents"][0], hits["metadatas"][0])
    ]

    prompt = (
        "Answer ONLY from the policy snippets below. "
        "If unsure, say you don't know.\n\n"
        + "\n---\n".join(snippets)
        + f"\n\nQuestion: {question}"
    )
    return ctx.llm.complete(prompt, model="hermes-3-llama-3.1-70b")


def ingest(path):
    """Run once via:  hermes skill exec policy-qa:ingest ./policies/"""
    import pathlib, uuid
    for f in pathlib.Path(path).glob("*.md"):
        text = f.read_text()
        chunks = [text[i:i+800] for i in range(0, len(text), 600)]
        _coll.add(
            ids=[str(uuid.uuid4()) for _ in chunks],
            documents=chunks,
            metadatas=[{"source": f.name} for _ in chunks],
        )

# ~/.hermes/skills/smart-reply/skill.py
from hermes import skill

MODELS = {
    "classify":   "claude-haiku-4",
    "extract":    "claude-haiku-4",
    "draft":      "hermes-3-llama-3.1-70b",
    "vision":     "gpt-4o-mini",
    "long_form":  "hermes-3-llama-3.1-405b",
}

def pick(task: str, payload: dict) -> str:
    if payload.get("has_image"):     return MODELS["vision"]
    if task == "classify":           return MODELS["classify"]
    if task == "extract":            return MODELS["extract"]
    if payload.get("tokens", 0) > 8000: return MODELS["long_form"]
    return MODELS["draft"]

@skill(name="smart-reply",
       description="Use when drafting a reply to an incoming customer email.")
def run(ctx, email: dict):
    # 1. classify intent — cheap model
    intent = ctx.llm.complete(
        f"Intent (one of: question, complaint, sales, spam)?\n{email['body']}",
        model=pick("classify", email),
        max_tokens=10,
    ).strip().lower()

    if intent == "spam":
        return {"action": "discard"}

    # 2. extract structured facts — cheap model
    facts = ctx.llm.json(
        f"Extract: order_id, sentiment(-1..1), urgency(low/med/high)\n{email['body']}",
        model=pick("extract", email),
    )

    # 3. draft reply — big model, has full context
    draft = ctx.llm.complete(
        ctx.render("reply.j2", email=email, intent=intent, facts=facts),
        model=pick("draft", {**email, "tokens": len(email["body"]) // 4}),
    )

    return {"intent": intent, "facts": facts, "draft": draft}

# ~/.hermes/skills/charge-customer/skill.py
import hashlib
from hermes import skill, lock, idempotent

@skill(name="charge-customer",
       description="Use to charge a customer for an order. Idempotent by order_id.")
@lock(key="charge:{order_id}", timeout=30)         # 1 execução por vez
@idempotent(key="charge:{order_id}", ttl_days=30)  # mesma chave → mesmo resultado
def run(ctx, order_id: str, amount_cents: int, currency: str = "BRL"):
    # idempotency_key derivado e estável
    ikey = hashlib.sha256(
        f"{order_id}:{amount_cents}:{currency}".encode()
    ).hexdigest()

    return ctx.tools.stripe.charge(
        amount=amount_cents,
        currency=currency,
        metadata={"order_id": order_id},
        idempotency_key=ikey,   # propaga ao provider também
        # retries da própria SDK Stripe lidam com 5xx transitórios
    )