Agent Classes

import { Agent } from '@ensemble/conductor';

const agent = new Agent(name: string, conductor: Conductor);

async execute(inputs: Record<string, any>): Promise<AgentResult>

const agent = new Agent('company-enricher', conductor);

const result = await agent.execute({
  company_name: 'Anthropic'
});

console.log('Company data:', result.output);

interface AgentResult {
  output: any;
  duration: number;
  cached: boolean;
  operations: OperationResult[];
}

interface OperationResult {
  name: string;
  operation: string;
  output: any;
  duration: number;
  cached: boolean;
  error?: OperationError;
}

import { AgentBuilder } from '@ensemble/conductor';

const builder = new AgentBuilder();

name(name: string): AgentBuilder

description(desc: string): AgentBuilder

input(name: string, schema: InputSchema): AgentBuilder

builder.input('company_name', {
  type: 'string',
  required: true,
  description: 'Company name to enrich'
});

operation(
  name: string,
  operation: string,
  config: Record<string, any>
): AgentBuilder

builder.operation('search', 'http', {
  url: 'https://api.example.com/search',
  method: 'GET',
  params: {
    q: '${input.company_name}'
  }
});

output(name: string, expression: string): AgentBuilder

cache(config: CacheConfig): AgentBuilder

build(): Agent

const agent = new AgentBuilder()
  .name('company-enricher')
  .description('Enrich company data')
  .input('company_name', {
    type: 'string',
    required: true
  })
  .operation('search', 'http', {
    url: 'https://api.duckduckgo.com/',
    params: {
      q: '${input.company_name}'
    }
  })
  .operation('scrape', 'http', {
    url: '${search.output.results[0].url}'
  })
  .operation('extract', 'think', {
    provider: 'openai',
    model: 'gpt-4o-mini',
    prompt: 'Extract company info from: ${scrape.output.body}'
  })
  .output('company_data', '${extract.output}')
  .cache({
    ttl: 86400,
    key: 'enrich-${input.company_name}'
  })
  .build();

const result = await agent.execute({
  company_name: 'Anthropic'
});

import { createAgent } from '@ensemble/conductor/sdk';

const agent = createAgent({
  name: 'my-agent',
  operations: [
    {
      name: 'step1',
      operation: 'think',
      config: {
        provider: 'openai',
        model: 'gpt-4o',
        prompt: 'Process: ${input.data}'
      }
    }
  ],
  outputs: {
    result: '${step1.output}'
  }
});

import { thinkOperation } from '@ensemble/conductor/sdk';

const op = thinkOperation({
  name: 'analyze',
  provider: 'openai',
  model: 'gpt-4o',
  prompt: 'Analyze: ${input.text}'
});

import { httpOperation } from '@ensemble/conductor/sdk';

const op = httpOperation({
  name: 'fetch',
  url: 'https://api.example.com/data',
  method: 'POST',
  body: {
    query: '${input.query}'
  }
});

import { storageOperation } from '@ensemble/conductor/sdk';

const op = storageOperation({
  name: 'query',
  type: 'd1',
  query: 'SELECT * FROM users WHERE id = ?',
  params: ['${input.user_id}']
});