OpenAI Provider

npm install @composio/openai openai

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

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

const tools = await composio.tools.get('default', {
  toolkits: ['github']
});

const openai = new OpenAI({ apiKey: 'your-openai-key' });

const response = await openai.chat.completions.create({
  model: 'gpt-4',
  tools,
  messages: [
    { role: 'user', content: 'Create a GitHub issue titled "Bug Report"' }
  ]
});

// Handle tool calls
if (response.choices[0].message.tool_calls) {
  for (const toolCall of response.choices[0].message.tool_calls) {
    const result = await composio.tools.execute(toolCall.function.name, {
      userId: 'default',
      arguments: JSON.parse(toolCall.function.arguments)
    });
    console.log('Tool result:', result.data);
  }
}

const tools = await composio.tools.get('default', {
  toolkits: ['github', 'slack'],
  limit: 10
});
// Returns: OpenAI.Chat.Completions.ChatCompletionTool[]

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

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

const openai = new OpenAI({
  apiKey: process.env.OPENAI_API_KEY!
});

async function runAgent(userMessage: string) {
  const tools = await composio.tools.get('default', {
    toolkits: ['github']
  });

  const messages: OpenAI.Chat.ChatCompletionMessageParam[] = [
    { role: 'user', content: userMessage }
  ];

  let response = await openai.chat.completions.create({
    model: 'gpt-4',
    tools,
    messages
  });

  while (response.choices[0].finish_reason === 'tool_calls') {
    const toolCalls = response.choices[0].message.tool_calls!;
    
    // Add assistant message
    messages.push(response.choices[0].message);

    // Execute tools
    for (const toolCall of toolCalls) {
      const result = await composio.tools.execute(toolCall.function.name, {
        userId: 'default',
        arguments: JSON.parse(toolCall.function.arguments)
      });

      // Add tool result
      messages.push({
        role: 'tool',
        tool_call_id: toolCall.id,
        content: JSON.stringify(result.data)
      });
    }

    // Get next response
    response = await openai.chat.completions.create({
      model: 'gpt-4',
      tools,
      messages
    });
  }

  return response.choices[0].message.content;
}

const result = await runAgent('Create an issue in my repo');
console.log(result);

interface OpenAITool {
  type: 'function';
  function: {
    name: string; // Tool slug
    description: string; // Tool description
    parameters: JSONSchema; // Input parameters
  };
}

const stream = await openai.chat.completions.create({
  model: 'gpt-4',
  tools,
  messages,
  stream: true
});

for await (const chunk of stream) {
  const delta = chunk.choices[0]?.delta;
  
  if (delta?.tool_calls) {
    // Handle streaming tool calls
    console.log('Tool call:', delta.tool_calls);
  }
  
  if (delta?.content) {
    process.stdout.write(delta.content);
  }
}

const response = await openai.chat.completions.create({
  model: 'gpt-4',
  tools,
  messages: [
    { 
      role: 'user', 
      content: 'Get my GitHub repos and Slack channels' 
    }
  ]
});

// Execute all tool calls in parallel
const toolCalls = response.choices[0].message.tool_calls || [];
const results = await Promise.all(
  toolCalls.map(toolCall =>
    composio.tools.execute(toolCall.function.name, {
      userId: 'default',
      arguments: JSON.parse(toolCall.function.arguments)
    })
  )
);

const response = await openai.chat.completions.create({
  model: 'gpt-4',
  tools,
  tool_choice: 'required', // Force tool use
  messages
});

import type { OpenAI } from 'openai';

// Tool collection type
type OpenAIToolCollection = OpenAI.Chat.Completions.ChatCompletionTool[];

// Single tool type
type OpenAITool = OpenAI.Chat.Completions.ChatCompletionTool;