Introduction

import { AgentRein } from 'agentrein';
import { Octokit } from '@octokit/rest';
import { WebClient } from '@slack/web-api';

const agentrein = new AgentRein({ apiKey: process.env.AGENTREIN_API_KEY });
const octokit = new Octokit({ auth: process.env.GITHUB_TOKEN });
const slack = new WebClient(process.env.SLACK_TOKEN);

// 1. Start a tracked session with an explicit intent
const session = await agentrein.newSession({
  agentId: 'incident-responder',
  intent: 'Create incident tracking issue and notify the engineering channel',
});

// 2. Wrap standard clients with AgentRein
const agentOctokit = agentrein.wrap(octokit, session, { connector: 'github' });
const agentSlack   = agentrein.wrap(slack, session, { connector: 'slack' });

try {
  // 3. Execute calls naturally — side-effects and rollbacks are tracked automatically
  const issue = await agentOctokit.issues.create({
    owner: 'acme-corp',
    repo: 'infrastructure',
    title: 'High Memory Usage Alert',
  });

  await agentSlack.chat.postMessage({
    channel: '#incidents',
    text: `Created GitHub issue: ${issue.data.html_url}`,
  });

  // 4. Mark session complete when successful
  await agentrein.completeSession(session);
} catch (err) {
  // Automatic LIFO rollback has already executed for all logged actions in this session!
  console.error('Session failed and rolled back:', err);
}

import os
from agentrein import AgentRein
from github import Github
from slack_sdk import WebClient

agentrein = AgentRein(api_key=os.environ["AGENTREIN_API_KEY"])
gh = Github(os.environ["GITHUB_TOKEN"])
slack = WebClient(token=os.environ["SLACK_TOKEN"])

# 1. Start a tracked session with an explicit intent
session = agentrein.new_session(
    agent_id="incident-responder",
    intent="Create incident tracking issue and notify the engineering channel",
)

# 2. Wrap standard clients with AgentRein
repo = gh.get_repo("acme-corp/infrastructure")
agent_repo = agentrein.wrap(repo, session, connector="github")
agent_slack = agentrein.wrap(slack, session, connector="slack")

try:
    # 3. Execute calls naturally — side-effects and rollbacks are tracked automatically
    issue = agent_repo.create_issue(title="High Memory Usage Alert")
    
    agent_slack.chat_postMessage(
        channel="#incidents",
        text=f"Created GitHub issue: {issue.html_url}",
    )
    
    # 4. Mark session complete when successful
    agentrein.complete_session(session)
except Exception as err:
    # Automatic LIFO rollback has already executed for all logged actions in this session!
    print(f"Session failed and rolled back: {err}")