Human-in-the-Loop (HITL)

import { AgentRein, ApprovalRejectedError } from 'agentrein';

const agentrein = new AgentRein({ apiKey: process.env.AGENTREIN_API_KEY });
const session = await agentrein.newSession({ agentId: 'billing-agent' });

const agentStripe = agentrein.wrap(stripe, session, {
    connector: 'stripe',
    requiresApproval: ['subscriptions.cancel'],
    pollIntervalMs: 2000,
    timeoutMs: 300000,
});

try {
    // This call pauses until approved from the dashboard
    await agentStripe.subscriptions.cancel({ id: 'sub_123' });
} catch (err) {
    if (err instanceof ApprovalRejectedError) {
        console.log('Rejected:', err.reason);
        // all previous session actions were already rolled back automatically
    }
}

from agentrein import AgentRein, ApprovalRejectedError

agentrein = AgentRein(api_key=os.environ["AGENTREIN_API_KEY"])
session = agentrein.new_session(agent_id="billing-agent")

agent_stripe = agentrein.wrap(
    stripe_client, session,
    connector="stripe",
    requires_approval=["subscriptions.cancel"],
    poll_interval_ms=2000,
    timeout_ms=300000,
)

try:
    # This call pauses until approved from the dashboard
    agent_stripe.subscriptions.cancel(id="sub_123")
except ApprovalRejectedError as err:
    print(f"Rejected: {err.reason}")
    # all previous session actions were already rolled back automatically