Execution Methods

import { AgentRein } from 'agentrein';
import { Octokit } from '@octokit/rest';

const agentrein = new AgentRein({ apiKey: '...' });
const octokit = new Octokit({ auth: '...' });

const agentOctokit = agentrein.wrap(octokit, session, { connector: 'github' });

// Use exactly as before — rollback is automatic on any failure
await agentOctokit.issues.create({ owner: 'my-org', repo: 'my-repo', title: 'Task' });

from agentrein import AgentRein
from github import Github

agentrein = AgentRein(api_key="...")
gh = Github(auth="...")
repo = gh.get_repo("my-org/my-repo")

agent_repo = agentrein.wrap(repo, session, connector="github")

# Use exactly as before — rollback is automatic on any failure
agent_repo.create_issue(title="Task")

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

// Executes immediately — no approval needed
await agentStripe.invoices.create({ customer: 'cus_123', amount: 500 });

// Pauses here until a reviewer approves from the dashboard
await agentStripe.subscriptions.cancel({ id: 'sub_123' });

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

# Executes immediately — no approval needed
agent_stripe.invoices.create(customer="cus_123", amount=500)

# Pauses here until a reviewer approves from the dashboard
agent_stripe.subscriptions.cancel(id="sub_123")