npm install @composio/core @composio/langchain @langchain/core @langchain/openai
# or
yarn add @composio/core @composio/langchain @langchain/core @langchain/openai
# or
pnpm add @composio/core @composio/langchain @langchain/core @langchain/openai

import { Composio } from '@composio/core';
import { LangChainProvider } from '@composio/langchain';

// Initialize Composio with LangChain provider
const composio = new Composio({
  apiKey: 'your-composio-api-key',
  provider: new LangChainProvider(),
});

// Get available tools
const tools = await composio.tools.get('user123', {
  toolkits: ['gmail', 'googlecalendar'],
  limit: 10,
});

// Get tools with version control
const versionedTools = await composio.tools.get('user123', {
  toolkits: ['gmail'],
  toolkitVersions: { gmail: '20250909_00' },
});

// Get a specific tool
const sendEmailTool = await composio.tools.get('user123', 'GMAIL_SEND_EMAIL');

import { Composio } from '@composio/core';
import { LangChainProvider } from '@composio/langchain';
import { ChatPromptTemplate } from '@langchain/core/prompts';
import { StringOutputParser } from '@langchain/core/output_parsers';
import { ChatOpenAI } from '@langchain/openai';

const composio = new Composio({
  apiKey: process.env.COMPOSIO_API_KEY,
  provider: new LangChainProvider(),
});

// Get tools for the chain
const tools = await composio.tools.get('user123', {
  toolkits: ['gmail'],
  limit: 10,
});

const model = new ChatOpenAI({
  modelName: 'gpt-4',
  streaming: true,
});

const prompt = ChatPromptTemplate.fromTemplate('Tell me a joke about {topic}');
const parser = new StringOutputParser();

const chain = prompt.pipe(model).pipe(parser);

// Stream the response
const stream = await chain.stream({
  topic: 'programming',
});

for await (const chunk of stream) {
  console.log(chunk);
}

import { Composio } from '@composio/core';
import { LangChainProvider } from '@composio/langchain';
import { ChatPromptTemplate } from '@langchain/core/prompts';
import { JsonOutputParser } from '@langchain/core/output_parsers';
import { ChatOpenAI } from '@langchain/openai';

const composio = new Composio({
  apiKey: process.env.COMPOSIO_API_KEY,
  provider: new LangChainProvider(),
});

// Get tools for the chain
const tools = await composio.tools.get('user123', {
  toolkits: ['gmail'],
});

const model = new ChatOpenAI({
  modelName: 'gpt-4',
  streaming: true,
});

const chain = model.pipe(new JsonOutputParser());
const eventStream = await chain.streamEvents(
  `Output a list of the countries france, spain and japan and their populations in JSON format.`,
  { version: 'v2' }
);

for await (const event of eventStream) {
  const eventType = event.event;
  if (eventType === 'on_chat_model_stream') {
    console.log(`Chat model chunk: ${event.data.chunk.content}`);
  } else if (eventType === 'on_parser_stream') {
    console.log(`Parser chunk: ${JSON.stringify(event.data.chunk)}`);
  }
}

const provider = new LangChainProvider({
  // Default model configuration
  model: new ChatOpenAI({
    modelName: 'gpt-4',
    streaming: true,
  }),
  // Custom execution modifiers
  modifiers: {
    beforeExecute: params => {
      // Transform parameters before execution
      return params;
    },
    afterExecute: response => {
      // Transform response after execution
      return response;
    },
  },
  // Enable tracing
  tracing: true,
});

const result = await provider.executeToolCall(tool);