Teams App Developer

import { App } from '@microsoft/teams.apps';
import { ChatPrompt } from '@microsoft/teams.ai';
import { OpenAIChatModel } from '@microsoft/teams.openai';
import { A2AClientPlugin } from '@microsoft/teams.a2a';
import { ConsoleLogger } from '@microsoft/teams.common';
import { DevtoolsPlugin } from '@microsoft/teams.dev';

const model = new OpenAIChatModel({
  apiKey: process.env.OPENAI_API_KEY,
  model: 'gpt-4o',
});

const prompt = new ChatPrompt(
  {
    model,
    instructions: `You are the main office assistant. You coordinate with specialized agents:
- askWeatherAgent: handles weather and forecast questions
- askCalendarAgent: handles scheduling and calendar queries
- askITAgent: handles IT support, password resets, and tickets

Delegate to the appropriate agent based on the user's request.
If no agent matches, answer the question yourself.
Always present the agent's response clearly to the user.`,
  },
  [new A2AClientPlugin({
    // Customize how agent functions are named
    buildFunctionMetadata: (card) => ({
      name: `ask${card.name.replace(/\s+/g, '')}`,
      description: `Ask ${card.name}: ${card.description}`,
    }),
    // Customize outgoing messages to agents
    buildMessageForAgent: (card, input) => {
      return `[Request from orchestrator to ${card.name}]: ${input}`;
    },
    // Customize how agent responses are returned to the LLM
    buildMessageFromAgentResponse: (card, response) => {
      if (response.kind === 'message') {
        const text = response.parts
          .filter((p: any) => p.kind === 'text')
          .map((p: any) => p.text)
          .join(' ');
        return `${card.name} responded: ${text}`;
      }
      return `${card.name} sent a non-text response.`;
    },
  })],
)
  .usePlugin('a2a', {
    key: 'weather',
    cardUrl: 'http://weather-agent:4000/a2a/.well-known/agent-card.json',
  })
  .usePlugin('a2a', {
    key: 'calendar',
    cardUrl: 'http://calendar-agent:4001/a2a/.well-known/agent-card.json',
  })
  .usePlugin('a2a', {
    key: 'it-support',
    cardUrl: 'http://it-agent:4002/a2a/.well-known/agent-card.json',
  });

const app = new App({
  logger: new ConsoleLogger('orchestrator', { level: 'debug' }),
  plugins: [new DevtoolsPlugin()],
});

app.on('message', async ({ send, stream, activity }) => {
  await send({ type: 'typing' });
  try {
    const result = await prompt.send(activity.text);
    if (result.content) {
      await send(result.content);
    }
  } catch (err: any) {
    await send('Sorry, one of my specialized agents is unavailable. Please try again later.');
  }
});

app.start(3978);

import { App } from '@microsoft/teams.apps';
import { ChatPrompt } from '@microsoft/teams.ai';
import { OpenAIChatModel } from '@microsoft/teams.openai';
import { A2AClientPlugin } from '@microsoft/teams.a2a';
import { McpClientPlugin } from '@microsoft/teams.mcpclient';
import { ConsoleLogger } from '@microsoft/teams.common';
import { DevtoolsPlugin } from '@microsoft/teams.dev';

const logger = new ConsoleLogger('hybrid-orchestrator');

const model = new OpenAIChatModel({
  apiKey: process.env.OPENAI_API_KEY,
  model: 'gpt-4o',
});

const prompt = new ChatPrompt(
  {
    model,
    instructions: `You are a powerful assistant with access to:
- Remote agents for complex tasks (weather, IT support)
- MCP tools for data lookup (search, documents)
- Local functions for simple operations (time, math)

Choose the best tool or agent for each request.`,
  },
  [
    new A2AClientPlugin(),
    new McpClientPlugin({ logger }),
  ],
)
  // A2A agents for complex, conversational tasks
  .usePlugin('a2a', {
    key: 'weather',
    cardUrl: 'http://weather-agent:4000/a2a/.well-known/agent-card.json',
  })
  .usePlugin('a2a', {
    key: 'it-support',
    cardUrl: 'http://it-agent:4002/a2a/.well-known/agent-card.json',
  })
  // MCP tools for data access
  .usePlugin('mcpClient', {
    url: 'http://localhost:5000/mcp',
  })
  // Local function
  .function('getTime', 'Get the current date and time', () => {
    return new Date().toISOString();
  });

const app = new App({
  logger,
  plugins: [new DevtoolsPlugin()],
});

app.on('message', async ({ send, activity }) => {
  await send({ type: 'typing' });
  const result = await prompt.send(activity.text);
  if (result.content) {
    await send(result.content);
  }
});

app.start(3978);

import { App } from '@microsoft/teams.apps';
import { ChatPrompt } from '@microsoft/teams.ai';
import { OpenAIChatModel } from '@microsoft/teams.openai';
import { A2APlugin, A2AClientPlugin } from '@microsoft/teams.a2a';
import { ConsoleLogger } from '@microsoft/teams.common';
import { DevtoolsPlugin } from '@microsoft/teams.dev';

const model = new OpenAIChatModel({
  apiKey: process.env.OPENAI_API_KEY,
  model: 'gpt-4o',
});

// This bot is both an A2A server AND an A2A client
// It can be called by other agents AND delegate to downstream agents

const prompt = new ChatPrompt(
  {
    model,
    instructions: `You are a coordinator agent. You handle general queries and delegate specialized tasks to sub-agents.`,
  },
  [new A2AClientPlugin()],
)
  .usePlugin('a2a', {
    key: 'weather',
    cardUrl: 'http://weather-agent:4000/a2a/.well-known/agent-card.json',
  });

// Agent card so other agents can call this orchestrator
const agentCard = {
  name: 'Coordinator Agent',
  description: 'A coordinator that routes requests to specialized agents',
  url: 'http://localhost:3978/a2a',
  version: '1.0.0',
  protocolVersion: '0.3.0',
  capabilities: {},
  skills: [
    {
      id: 'coordinate',
      name: 'Coordinate Request',
      description: 'Route a request to the best available specialist agent',
      tags: ['coordination', 'routing'],
      examples: ['What is the weather in Paris?', 'Help me with a general question'],
    },
  ],
};

const app = new App({
  logger: new ConsoleLogger('coordinator'),
  plugins: [
    new DevtoolsPlugin(),
    new A2APlugin({ agentCard }), // Server: accept A2A messages
  ],
});

// Handle A2A messages from other agents
app.event('a2a:message', async ({ respond, requestContext }) => {
  const textInput = requestContext.userMessage.parts
    .filter((p: any) => p.kind === 'text')
    .at(0)?.text;

  if (!textInput) {
    await respond('Please send a text message.');
    return;
  }

  const result = await prompt.send(textInput);
  await respond(result.content || 'Unable to process request.');
});

// Handle direct Teams messages
app.on('message', async ({ send, activity }) => {
  const result = await prompt.send(activity.text);
  if (result.content) await send(result.content);
});

app.start(3978);