CRM Integration

app.post("/webhooks/talkpilot", async (req, res) => {
  const { call } = req.body;

  // Create a CRM record
  await crm.createActivity({
    customerPhone: call.phone_number,
    customerName: call.customer_name,
    subject: call.customer_request,
    notes: call.call_summary,
    duration: call.duration,
    success: call.general_success,
    recordingUrl: null, // Use the API to get the audio URL if needed
    date: call.created_at,
  });

  res.json({ received: true });
});

import requests
from datetime import datetime, timedelta

BASE_URL = "https://api.talkpilot.io/v1"
API_KEY = "tp_live_YOUR_KEY"
HEADERS = {"X-API-Key": API_KEY}

def sync_new_calls(agent_id, since):
    """Fetch all calls since the last sync."""
    calls = []
    page = 1

    while True:
        resp = requests.get(
            f"{BASE_URL}/agents/{agent_id}/calls",
            headers=HEADERS,
            params={"from": since, "page": page, "limit": 100},
        )
        data = resp.json()
        calls.extend(data["data"])

        if page >= data["pagination"]["pages"]:
            break
        page += 1

    return calls

# Run every 15 minutes
last_sync = (datetime.utcnow() - timedelta(minutes=15)).isoformat() + "Z"
new_calls = sync_new_calls("your-agent-id", last_sync)

for call in new_calls:
    crm.create_or_update_record(call)

// Run on a schedule (every 5 minutes)
async function syncEmployeeStatus() {
  // Fetch current status from HR system
  const hrEmployees = await hr.getEmployees();

  // Fetch TalkPilot employees
  const { data: tpEmployees } = await talkpilot(`/agents/${AGENT_ID}/employees`);

  for (const hrEmp of hrEmployees) {
    const match = tpEmployees.find(e => e.email === hrEmp.email);
    if (!match) continue;

    // Map HR status to TalkPilot status
    const tpStatus = mapStatus(hrEmp.status); // e.g., "vacation" → "urlaub"

    if (match.status !== tpStatus) {
      await talkpilot(`/agents/${AGENT_ID}/employees/${match.id}`, {
        method: "PATCH",
        body: JSON.stringify({ status: tpStatus }),
      });
      console.log(`Updated ${match.name}: ${match.status} → ${tpStatus}`);
    }
  }
}

function mapStatus(hrStatus) {
  const map = {
    "active": "anwesend",
    "vacation": "urlaub",
    "sick": "krank",
    "training": "weiterbildung",
    "on_call": "notdienst",
  };
  return map[hrStatus] || "anwesend";
}

// Replace all slots from external system
async function syncForwardingSlots() {
  const departments = await crm.getDepartments();

  const slots = departments.map((dept, index) => ({
    slotnummer: String(index + 1).padStart(2, "0"),
    cases: dept.topics.join(", "),
    slot_belegung: dept.managerName,
    prioritaet_1: dept.primaryPhone,
    prioritaet_2: dept.backupPhone || null,
  }));

  await talkpilot(`/agents/${AGENT_ID}/forwarding-slots`, {
    method: "PUT",
    body: JSON.stringify({ slots }),
  });
}