# Send a connection request without a note
curl -X POST \
  "https://api.outx.ai/linkedin-agent/send-connection-request" \
  -H "Content-Type: application/json" \
  -H "x-api-key: YOUR_API_KEY" \
  -d '{
    "profile_urn": "urn:li:fsd_profile:ACoAABCDEF123"
  }'

# Send a connection request with an optional personal note
curl -X POST \
  "https://api.outx.ai/linkedin-agent/send-connection-request" \
  -H "Content-Type: application/json" \
  -H "x-api-key: YOUR_API_KEY" \
  -d '{
    "profile_urn": "urn:li:fsd_profile:ACoAABCDEF123",
    "note": "Hi, I came across your work and would love to connect."
  }'

# Check the result
curl -X GET \
  "https://api.outx.ai/linkedin-agent/get-task-status?api_agent_task_id=TASK_ID" \
  -H "x-api-key: YOUR_API_KEY"

async function sendConnectionRequest(profileUrn, note) {
  const body = { profile_urn: profileUrn };
  if (note) body.note = note;

  const response = await fetch(
    "https://api.outx.ai/linkedin-agent/send-connection-request",
    {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        "x-api-key": "YOUR_API_KEY",
      },
      body: JSON.stringify(body),
    }
  );

  const { api_agent_task_id } = await response.json();

  // Poll for completion
  while (true) {
    const statusRes = await fetch(
      `https://api.outx.ai/linkedin-agent/get-task-status?api_agent_task_id=${api_agent_task_id}`,
      { headers: { "x-api-key": "YOUR_API_KEY" } }
    );

    const result = await statusRes.json();
    if (result.data.status === "completed") {
      return result.data.task_output; // { sent: true }
    }

    await new Promise((r) => setTimeout(r, 5000));
  }
}

// Without a note
const result = await sendConnectionRequest("urn:li:fsd_profile:ACoAABCDEF123");
console.log(result); // { sent: true }

// With an optional personal note
const resultWithNote = await sendConnectionRequest(
  "urn:li:fsd_profile:ACoAABCDEF123",
  "Hi, I came across your work and would love to connect."
);
console.log(resultWithNote); // { sent: true }

import requests
import time

def send_connection_request(profile_urn, note=None):
    headers = {
        "Content-Type": "application/json",
        "x-api-key": "YOUR_API_KEY",
    }

    payload = {"profile_urn": profile_urn}
    if note:
        payload["note"] = note

    response = requests.post(
        "https://api.outx.ai/linkedin-agent/send-connection-request",
        headers=headers,
        json=payload,
    )
    task_id = response.json()["api_agent_task_id"]

    while True:
        result = requests.get(
            "https://api.outx.ai/linkedin-agent/get-task-status",
            headers={"x-api-key": "YOUR_API_KEY"},
            params={"api_agent_task_id": task_id},
        ).json()

        if result["data"]["status"] == "completed":
            return result["data"]["task_output"]  # {"sent": True}

        time.sleep(5)

# Without a note
print(send_connection_request("urn:li:fsd_profile:ACoAABCDEF123"))

# With an optional personal note
print(send_connection_request(
    "urn:li:fsd_profile:ACoAABCDEF123",
    note="Hi, I came across your work and would love to connect.",
))

{
  "success": true,
  "api_agent_task_id": "550e8400-e29b-41d4-a716-446655440000",
  "message": "Send connection request task created successfully"
}