Send a multichannel campaign using an Infobip MCP server and OpenAI Agents SDK

import os
 
from agents.mcp import MCPServerStreamableHttp, MCPServerStreamableHttpParams
 
IB_API_KEY = os.getenv("IB_API_KEY")
 
sms_mcp_server = MCPServerStreamableHttp(
    params=MCPServerStreamableHttpParams(
        url="https://mcp.infobip.com/sms",
        headers={"Authorization": f"App {IB_API_KEY}"},
    ),
    client_session_timeout_seconds=30,
)
 
viber_mcp_server = MCPServerStreamableHttp(
    params=MCPServerStreamableHttpParams(
        url="https://mcp.infobip.com/viber",
        headers={"Authorization": f"App {IB_API_KEY}"},
    ),
    client_session_timeout_seconds=30,
)

from agents import Agent, ModelSettings
 
MODEL_NAME = os.getenv("MODEL_NAME")
 
sms_agent = Agent(
    name="Infobip SMS MCP Agent",
    handoff_description="Specialist agent for Infobip SMS MCP questions",
    instructions="Send SMS messages, read delivery reports and logs, and manage campaigns using the Infobip SMS MCP API.",  
    mcp_servers=[sms_mcp_server],
    model_settings=ModelSettings(tool_choice="required", store=True),
    model=MODEL_NAME,
)
 
viber_agent = Agent(
    name="Infobip Viber MCP Agent",
    handoff_description="Specialist agent for Infobip Viber MCP questions",
    instructions="Send Viber messages, read delivery reports and logs, and manage campaigns using the Infobip Viber MCP API.",
    mcp_servers=[viber_mcp_server],
    model_settings=ModelSettings(tool_choice="required", store=True),
    model=MODEL_NAME,
)

orchestrator_agent = Agent(
    name="Orchestrator Agent",
    instructions="You are an orchestrator agent that decides which specialist agent to use based on the user's request.",
    handoffs=[sms_agent, viber_agent],
    model=MODEL_NAME,
)

import asyncio
 
from agents import Runner
 
def create_campaign_prompt(channel: str, sender: str, destinations: list[str], message: str) -> str:
    return f"""
        Send a bulk black Friday promotional message to the following phone numbers: {", ".join(destinations)}.
        Send the messages under the sender {sender}.
        
        The message should be sent via {channel} channel.
        
        The company offering the promotion is Infobip. Use the following message: {message}.
        
        After sending the messages, check if they were sent successfully and provide a summary of the results.
    """
 
async def main():
    destinations = ["441134960001, 441134960002, 441134960003"]
    promotion_message = "BLACK FRIDAY: 70% OFF! Code: BF70. Shop now, ends midnight!"
 
    async with sms_mcp_server, viber_mcp_server:
        result = await Runner.run(
            orchestrator_agent,
            create_campaign_prompt("SMS", "ServiceSMS", destinations, promotion_message),
        )
        print("SMS: ", result.final_output)
        
        result = await Runner.run(
            orchestrator_agent,
            create_campaign_prompt("Viber", "DemoCompany", destinations, promotion_message),
        )
        print("Viber: ", result.final_output)
 
 
if __name__ == "__main__":
    asyncio.run(main())

SMS:  ### Bulk Black Friday Promotion Summary

**Messages Sent:**
Each message contained the text:  
> BLACK FRIDAY: 70% OFF! Code: BF70. Shop now - ends midnight!  
It was sent from sender ID **ServiceSMS** to the following recipients:  
1. **+441134960001**  
2. **+441134960002**  
3. **+441134960003**

---

### Delivery Results:

**1. Recipient:** +441134960001
- **Status:** PENDING
- The message is en route to the recipient's device.  

**2. Recipient:** +441134960002
- **Status:** DELIVERED TO HANDSET
- The message was successfully delivered to the recipient's device.  

**3. Recipient:** +441134960003
- **Status:** DELIVERED TO HANDSET
- The message was successfully delivered to the recipient's device.

---

**Notes:**  
- Two messages were successfully delivered, while the status for one is still pending.

Viber:  ### Summary of Actions:
1. **Message Sent**: Promotional messages about Black Friday were sent to three recipients:
    - **+441134960001**
    - **+441134960002**
    - **+441134960003**
    - Sender: **DemoCompany**

### Delivery Summary:

- The sending was successful, but messages are currently in the **PENDING** state across the recipients. This means:
  - The message was accepted and sent to the next instance for delivery.
  - Delivery has not yet been completed nor failed.

### Status Breakdown:
- **Destination: +441134960001**:
  - Status: **PENDING_ACCEPTED**
  - Description: Message sent to the next instance.

- **Destination: +441134960002**:
  - Status: **PENDING_ACCEPTED**
  - Description: Message sent to the next instance.

- **Destination: +441134960003**:
  - Status: **PENDING_ACCEPTED**
  - Description: Message sent to the next instance.

### Next Steps:
Delivery reports will update when the recipient's device or network confirms receipt.