Start Agent

curl -X POST https://api.gumloop.com/api/v1/start_agent \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -d '{
    "gummie_id": "abc123DEFghiJKL",
    "message": "Summarize the latest sales report and send it to the team Slack channel",
    "user_id": "your_user_id",
    "project_id": "your_project_id"
  }'

import requests
import time

API_KEY = "your_api_key"
BASE_URL = "https://api.gumloop.com/api/v1"
HEADERS = {
    "Content-Type": "application/json",
    "Authorization": f"Bearer {API_KEY}"
}

def send_message(gummie_id: str, message: str, user_id: str, interaction_id: str = None) -> dict:
    """Send a message to an agent, optionally continuing an existing conversation."""
    payload = {
        "gummie_id": gummie_id,
        "message": message,
        "user_id": user_id,
    }
    if interaction_id:
        payload["interaction_id"] = interaction_id

    response = requests.post(f"{BASE_URL}/start_agent", headers=HEADERS, json=payload)
    response.raise_for_status()
    return response.json()

def wait_for_completion(interaction_id: str, user_id: str) -> dict:
    """Poll until the interaction completes or fails."""
    while True:
        response = requests.get(
            f"{BASE_URL}/agent_status/{interaction_id}",
            headers=HEADERS,
            params={"user_id": user_id}
        )
        response.raise_for_status()
        result = response.json()

        if result["state"] == "COMPLETED":
            return result
        elif result["state"] == "FAILED":
            raise RuntimeError(f"Agent failed: {result.get('error_message')}")
        time.sleep(2)

# Turn 1: Start a new conversation
start = send_message(
    gummie_id="abc123DEFghiJKL",
    message="Find all open support tickets from Acme Corp",
    user_id="your_user_id"
)
interaction_id = start["interaction_id"]
result = wait_for_completion(interaction_id, "your_user_id")
print(f"Turn 1: {result['response']}")

# Turn 2: Continue the conversation
send_message(
    gummie_id="abc123DEFghiJKL",
    message="Now draft a summary email to send to the account manager",
    user_id="your_user_id",
    interaction_id=interaction_id  # reuse the same interaction
)
result = wait_for_completion(interaction_id, "your_user_id")
print(f"Turn 2: {result['response']}")

import requests
import time

API_KEY = "your_api_key"
BASE_URL = "https://api.gumloop.com/api/v1"
HEADERS = {
    "Content-Type": "application/json",
    "Authorization": f"Bearer {API_KEY}"
}

def trigger_agent(gummie_id: str, message: str, user_id: str, project_id: str = None) -> dict:
    """
    Trigger a Gumloop agent and wait for the response.

    Args:
        gummie_id: The agent's unique ID
        message: The message to send to the agent
        user_id: Your Gumloop user ID
        project_id: Optional team/workspace ID

    Returns:
        dict with 'response' (agent's text reply) and 'messages' (full conversation)
    """
    # Step 1: Start the agent interaction
    payload = {
        "gummie_id": gummie_id,
        "message": message,
        "user_id": user_id,
    }
    if project_id:
        payload["project_id"] = project_id

    start_response = requests.post(
        f"{BASE_URL}/start_agent",
        headers=HEADERS,
        json=payload
    )
    start_response.raise_for_status()
    interaction_id = start_response.json()["interaction_id"]
    print(f"Started agent interaction: {interaction_id}")

    # Step 2: Poll for completion
    params = {"user_id": user_id}
    if project_id:
        params["project_id"] = project_id

    while True:
        status_response = requests.get(
            f"{BASE_URL}/agent_status/{interaction_id}",
            headers=HEADERS,
            params=params
        )
        status_response.raise_for_status()
        result = status_response.json()

        state = result["state"]
        if state == "COMPLETED":
            print(f"Agent response: {result['response']}")
            return result
        elif state == "FAILED":
            error_msg = result.get("error_message", "Unknown error")
            raise RuntimeError(f"Agent interaction failed: {error_msg}")
        else:
            # Still processing -- wait and poll again
            time.sleep(2)


# Usage
result = trigger_agent(
    gummie_id="abc123DEFghiJKL",
    message="Summarize the Q4 sales report",
    user_id="your_user_id",
    project_id="your_project_id"  # optional
)

print(result["response"])      # The agent's final text response
print(result["messages"])       # Full conversation with tool call details