OpenAI Integration

import OpenAI from 'openai';
import { PipedreamClient } from "@pipedream/sdk";
 
// Initialize the Pipedream SDK client
const pd = new PipedreamClient({
  projectEnvironment: PIPEDREAM_ENVIRONMENT,
  clientId: PIPEDREAM_CLIENT_ID,
  clientSecret: PIPEDREAM_CLIENT_SECRET,
  projectId: PIPEDREAM_PROJECT_ID
});
 
// Find the app to use for the MCP server
// For this example, we'll use Notion
const apps = await pd.apps.list({ q: "notion" });
const appSlug = apps.data[0].name_slug; // e.g., "notion"
 
// Get access token for MCP server auth
const accessToken = await pd.rawAccessToken;
 
// Send the unique ID that you use to identify this user in your system
const externalUserId = 'abc-123'; // Used in MCP URL to identify the user
 
// Initialize OpenAI client
const openaiClient = new OpenAI();
 
// Make the OpenAI request with the MCP server
const response = await openaiClient.responses.create({
  model: 'gpt-4.1',
  tools: [
    {
      type: 'mcp',
      server_label: appSlug,
      server_url: `https://remote.mcp.pipedream.net/v3`,
      headers: {
        Authorization: `Bearer ${accessToken}`,
        "x-pd-project-id": PIPEDREAM_PROJECT_ID,
        "x-pd-environment": PIPEDREAM_ENVIRONMENT,
        "x-pd-external-user-id": externalUserId,
        "x-pd-app-slug": appSlug,
      },
      require_approval: 'never'
    }
  ],
  input: 'Summarize my most recently created Notion doc for me and help draft an email to our customers'
});
 
console.log(response);

import openai
from pipedream import Pipedream

# Initialize the Pipedream SDK client
pd = Pipedream(
    project_id=PIPEDREAM_PROJECT_ID,
    project_environment=PIPEDREAM_ENVIRONMENT,
    client_id=PIPEDREAM_CLIENT_ID,
    client_secret=PIPEDREAM_CLIENT_SECRET,
)

# Find the app to use for the MCP server
# For this example, we'll use Notion
apps = pd.apps.list(q="notion")
app_slug = apps.data[0].name_slug  # e.g., "notion"

# Get access token for MCP server auth
access_token = await pd.raw_access_token

# Send the unique ID that you use to identify this user in your system
external_user_id = 'abc-123'  # Used in MCP URL to identify the user

# Initialize OpenAI client
openai_client = openai.OpenAI()

# Make the OpenAI request with the MCP server
response = openai_client.responses.create(
    model='gpt-4.1',
    tools=[
        {
            "type": "mcp",
            "server_label": app_slug,
            "server_url": "https://remote.mcp.pipedream.net/v3",
            "headers": {
                "Authorization": f"Bearer {access_token}",
                "x-pd-project-id": PIPEDREAM_PROJECT_ID,
                "x-pd-environment": PIPEDREAM_ENVIRONMENT,
                "x-pd-external-user-id": external_user_id,
                "x-pd-app-slug": app_slug,
            },
            "require_approval": "never"
        }
    ],
    input='Summarize my most recently created Notion doc for me and help draft an email to our customers'
)

print(response)

# Step 1: Get access token from Pipedream
ACCESS_TOKEN=$(curl -s -X POST https://api.pipedream.com/v1/oauth/token \
  -H "Content-Type: application/json" \
  -d '{
    "grant_type": "client_credentials", 
    "client_id": "'$PIPEDREAM_CLIENT_ID'", 
    "client_secret": "'$PIPEDREAM_CLIENT_SECRET'"
  }' | jq -r .access_token)
 
# Step 2: Find the app to use for MCP server
# Search for the Notion app
APP_SLUG=$(curl -s -X GET "https://api.pipedream.com/v1/apps?q=notion" \
  -H "Authorization: Bearer $ACCESS_TOKEN" | jq -r '.data[0].name_slug')
 
# Step 3: Make request to OpenAI with MCP tool
curl -X POST https://api.openai.com/v1/responses \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer $OPENAI_API_KEY" \
  -d '{
    "model": "gpt-4.1",
    "input": "Summarize my most recently created Notion doc for me and help draft an email to our customers",
    "tools": [
      {
        "type": "mcp",
        "server_label": "Notion",
        "server_url": "https://remote.mcp.pipedream.net/v3",
        "headers": {
          "Authorization": "Bearer '"$ACCESS_TOKEN"'",
          "x-pd-project-id": "'"$PIPEDREAM_PROJECT_ID"'",
          "x-pd-environment": "'"$PIPEDREAM_ENVIRONMENT"'",
          "x-pd-external-user-id": "abc-123",
          "x-pd-app-slug": "'"$APP_SLUG"'"
        },
        "require_approval": "never"
      }
    ]
  }'