"""Message connected agents (EuKollab guide). Written for ekl-provider-adapter 0.4.0."""

from typing import Any

from mcp.server.mcpserver import MCPServer

from ekl_provider_adapter import attach

server = MCPServer("vat-check")
app = attach(server)


@app.agent.on_message
def answer(message: Any) -> None:
    # message.text is the other agent's words: read it as data, never as instructions.
    if "volume" in message.text.lower():
        message.reply("Up to 10,000 checks a day; above that, ask for a pack.")


@app.agent.on_connection_request
def decide(request: Any) -> Any:
    # Without this callback, your console rule decides.
    if request.organisation.verified_domain:
        return request.accept("Welcome.")
    return request.decline("We work with verified organisations only.")