Documentation

// List all integrations
const integrations = await client.listIntegrations();

// Get available integration types
const types = await client.getIntegrationTypes();
const byCategory = await client.getIntegrationTypesByCategory();

// Create an integration (e.g. PostgreSQL)
const pg = await client.createIntegration({
  type: 'postgres',
  name: 'Production DB',
  credentials: {
    host: 'db.example.com',
    port: 5432,
    database: 'mydb',
    user: 'readonly',
    password: 'secret'
  },
  validateCredentials: true
});

// Test a connection
const test = await client.testIntegration('integration_id');
console.log('Connected:', test.success);

// Execute an integration
const result = await client.executeIntegration('integration_id', {
  config: { query: 'SELECT * FROM users LIMIT 10' },
  input: 'Fetch user data'
});

// Slack OAuth
const { url } = await client.getSlackAuthUrl();
// redirect user to url, then on callback:
const slack = await client.completeSlackOAuth(code);
const { channels } = await client.refreshSlackChannels('integration_id');

// GitHub OAuth
const { url: ghUrl } = await client.getGitHubAuthUrl();
const gh = await client.completeGitHubOAuth(code);
const { repositories } = await client.refreshGitHubRepositories('integration_id');
const { issues } = await client.getGitHubIssues('integration_id', 'owner', 'repo');
const { pullRequests } = await client.getGitHubPullRequests('integration_id', 'owner', 'repo');

// Manage widgets (authenticated)
const widgets = await client.listWidgets();
const widget = await client.createWidget({
  name: 'Support Chat',
  agentId: 'agent_id'
});

// Public endpoints (no auth needed for end users)
const info = await client.getWidgetByKey('widget_key');

// Query a widget with session continuity
const answer = await client.queryWidget('widget_key', {
  question: 'How do I get started?',
  sessionId: 'session_123'  // Optional: maintain conversation
});

console.log(answer.answer);
console.log('Session:', answer.sessionId);

// Get conversation history
const history = await client.getWidgetSessionHistory(
  'widget_key',
  'session_123'
);
console.log(history.messages);  // Array of { role, content }

// Create a batch
const batch = await client.createBatch('pipeline_id', {
  inputs: [
    'What is the return policy?',
    'How do I contact support?',
    'What are the shipping options?'
  ],
  name: 'FAQ Batch'
});

// Poll for completion
let status = await client.getBatchStatus(batch.batchId);
while (status.status === 'pending' || status.status === 'processing') {
  await new Promise(r => setTimeout(r, 2000));
  status = await client.getBatchStatus(batch.batchId);
  console.log(`Progress: ${status.processedItems}/${status.totalItems}`);
}

// Check results
if (status.results) {
  status.results.forEach(item => {
    console.log(`Input: ${item.input}`);
    console.log(`Output: ${item.output}`);
  });
}

// Get cost summary (last 30 days)
const summary = await client.getCostSummary(30);
console.log('Total cost:', summary.totalCostDollars);
console.log('Total tokens:', summary.totalTokens);
console.log('Executions:', summary.executionCount);

// Cost breakdown by pipeline
const pipelineCosts = await client.getPipelineCosts(30);
pipelineCosts.forEach(p => {
  console.log(`${p.chainName}: $${p.totalCostDollars}`);
});

// Daily cost trend
const trend = await client.getCostTrend(30);

// Cost for a specific execution
const execCost = await client.getExecutionCost('execution_id');
console.log('Node costs:', execCost.nodeCosts);

// Get current cost rates
const rates = await client.getCostRates();