Providers API

Providers are adapters that allow Composio tools to be used with different AI platforms. The SDK comes with a default OpenAI provider and supports creating custom providers.

Base Provider Classes

Composio provides abstract base classes for creating providers:

BaseComposioProvider

The base type for all providers:

type BaseComposioProvider<TToolCollection, TTool> =
  | BaseNonAgenticProvider<TToolCollection, TTool>
  | BaseAgenticProvider<TToolCollection, TTool>;

BaseNonAgenticProvider

Base class for non-agentic providers (those that don't have their own agency/autonomy):

abstract class BaseNonAgenticProvider<TToolCollection, TTool> extends BaseProvider {
  readonly _isAgentic = false;

  // Wrap a tool in the provider specific format
  abstract wrapTool(tool: Tool): TTool;

  // Wrap a list of tools in the provider specific format
  abstract wrapTools(tools: Tool[]): TToolCollection;
}

BaseAgenticProvider

Base class for agentic providers (those with their own agency/autonomy):

abstract class BaseAgenticProvider<TToolCollection, TTool> extends BaseProvider {
  readonly _isAgentic = true;

  // Wrap a tool in the provider specific format
  abstract wrapTool(tool: Tool, executeTool: ExecuteToolFn): TTool;

  // Wrap a list of tools in the provider specific format
  abstract wrapTools(tools: Tool[], executeTool: ExecuteToolFn): TToolCollection;
}

OpenAI Provider

The default provider for Composio SDK is the OpenAI Provider, which formats tools for use with OpenAI's API.

import { Composio } from '@composio/core';
import { OpenAIProvider } from '@composio/openai';

const composio = new Composio({
  apiKey: 'your-api-key',
  provider: new OpenAIProvider(),
});

Methods

wrapTool(tool)

Transforms a Composio tool into an OpenAI function tool format.

const openaiTool = openaiProvider.wrapTool(composioTool);

Parameters:

• tool (Tool): The Composio tool to transform

Returns: OpenAI.ChatCompletionTool - The tool in OpenAI format

wrapTools(tools)

Transforms a list of Composio tools into an array of OpenAI function tools.

const openaiTools = openaiProvider.wrapTools(composioTools);

Parameters:

• tools (Tool[]): The list of Composio tools to transform

Returns: Array<OpenAI.ChatCompletionTool> - The tools in OpenAI format

executeToolCall(userId, tool, options?, modifiers?)

Executes a tool call from an OpenAI assistant.

const result = await openaiProvider.executeToolCall(
  'user123',
  toolCall,
  { connectedAccountId: 'conn_abc123' },
  {
    beforeExecute: ({ toolSlug, toolkitSlug, params }) => params,
    afterExecute: ({ toolSlug, toolkitSlug, result }) => result,
  }
);

Parameters:

• userId (string): The user ID
• tool (OpenAI.ChatCompletionMessageToolCall): The tool call from OpenAI
• options (ExecuteToolFnOptions): Optional parameters for tool execution
• modifiers (ExecuteToolModifiers): Optional modifiers for request/response transformation

Returns: Promise<string> - The result of the tool call as JSON string

handleToolCalls(userId, chatCompletion, options?, modifiers?)

Handles tool calls from an OpenAI chat completion.

const outputs = await openaiProvider.handleToolCalls('user123', chatCompletion);

Parameters:

• userId (string): The user ID
• chatCompletion (OpenAI.ChatCompletion): The chat completion containing tool calls
• options (ExecuteToolFnOptions): Optional parameters for tool execution
• modifiers (ExecuteToolModifiers): Optional modifiers for request/response transformation

Returns: Promise<OpenAI.ChatCompletionToolMessageParam[]> - The results of the tool calls

handleAssistantMessage(userId, run, options?, modifiers?)

Handles tool calls from an OpenAI assistant run.

const toolOutputs = await openaiProvider.handleAssistantMessage('user123', run);

Parameters:

• userId (string): The user ID
• run (OpenAI.Beta.Threads.Run): The run object containing tool calls
• options (ExecuteToolFnOptions): Optional parameters for tool execution
• modifiers (ExecuteToolModifiers): Optional modifiers for request/response transformation

Returns: Promise<OpenAI.Beta.Threads.Runs.RunSubmitToolOutputsParams.ToolOutput[]> - The tool outputs

waitAndHandleAssistantStreamToolCalls(userId, client, runStream, thread, options?, modifiers?)

Waits for and handles tool calls from an OpenAI assistant stream.

for await (const event of openaiProvider.waitAndHandleAssistantStreamToolCalls(
  'user123',
  openaiClient,
  runStream,
  thread
)) {
  console.log(event);
}

Parameters:

• userId (string): The user ID
• client (OpenAI): The OpenAI client
• runStream (Stream<OpenAI.Beta.Assistants.AssistantStreamEvent>): The run stream
• thread (OpenAI.Beta.Threads.Thread): The thread object
• options (ExecuteToolFnOptions): Optional parameters for tool execution
• modifiers (ExecuteToolModifiers): Optional modifiers for request/response transformation

Returns: AsyncGenerator<OpenAI.Beta.Assistants.AssistantStreamEvent, void, unknown> - Generator of stream events

waitAndHandleAssistantToolCalls(userId, client, run, thread, options?, modifiers?)

Waits for and handles tool calls from an OpenAI assistant.

const finalRun = await openaiProvider.waitAndHandleAssistantToolCalls(
  'user123',
  openaiClient,
  run,
  thread
);

Parameters:

• userId (string): The user ID
• client (OpenAI): The OpenAI client
• run (OpenAI.Beta.Threads.Run): The run object containing tool calls
• thread (OpenAI.Beta.Threads.Thread): The thread object
• options (ExecuteToolFnOptions): Optional parameters for tool execution
• modifiers (ExecuteToolModifiers): Optional modifiers for request/response transformation

Returns: Promise<OpenAI.Beta.Threads.Run> - The final run object

Creating Custom Providers

You can create custom providers by extending either BaseNonAgenticProvider or BaseAgenticProvider:

import { BaseNonAgenticProvider, Tool } from '@composio/core';

type AnthropicTool = {
  name: string;
  description: string;
  parameters: Record<string, unknown>;
};

type AnthropicToolCollection = AnthropicTool[];

export class AnthropicProvider extends BaseNonAgenticProvider<
  AnthropicToolCollection,
  AnthropicTool
> {
  readonly name = 'anthropic';

  override wrapTool(tool: Tool): AnthropicTool {
    return {
      name: tool.slug,
      description: tool.description || '',
      parameters: tool.inputParameters || {},
    };
  }

  override wrapTools(tools: Tool[]): AnthropicToolCollection {
    return tools.map(tool => this.wrapTool(tool));
  }

  // Additional methods for handling Anthropic-specific functionality
}

Types

ExecuteToolFn

type ExecuteToolFn = (
  toolSlug: string,
  input: Record<string, unknown>
) => Promise<ToolExecuteResponse>;

ExecuteToolFnOptions

interface ExecuteToolFnOptions {
  connectedAccountId?: string;
  customAuthParams?: CustomAuthParams;
}

ExecuteToolModifiers

interface ExecuteToolModifiers {
  beforeExecute?: beforeExecuteModifier;
  afterExecute?: afterExecuteModifier;
}

TransformToolSchemaModifier

type TransformToolSchemaModifier = (toolSlug: string, toolkitSlug: string, tool: Tool) => Tool;

beforeExecuteModifier

type beforeExecuteModifier = (
  toolSlug: string,
  toolkitSlug: string,
  params: ToolExecuteParams
) => ToolExecuteParams;

afterExecuteModifier

type afterExecuteModifier = (
  toolSlug: string,
  toolkitSlug: string,
  result: ToolExecuteResponse
) => ToolExecuteResponse;

// Get tools with filters const githubTools = await composio.tools.getRawComposioTools({ toolkits: ['github'], });

// Get tools with schema transformation const tools = await composio.tools.getRawComposioTools({}, (toolSlug, toolkitSlug, tool) => { // Add custom properties to tool schema return { ...tool, customProperty: 'value' }; });