Code Examples

curl https://dev.nutalk.ai/v1/agents \
  -H "Authorization: Bearer sk_xxx_xxx" \
  -w "\nHTTP Status: %{http_code}\n"
 
# Success: HTTP Status: 200
# Invalid key: HTTP Status: 401

const API_KEY = "sk_xxx_xxx";
const BASE_URL = "https://dev.nutalk.ai/v1";
 
const contacts = [
  { phone: "+15551234567", name: "John Smith", tags: ["lead"] },
  { phone: "+15559876543", name: "Jane Doe", tags: ["lead"] },
  { phone: "+15555555555", name: "Bob Wilson", tags: ["lead"] },
];
 
async function importContacts() {
  const results = await Promise.all(
    contacts.map(async (contact) => {
      const response = await fetch(`${BASE_URL}/contacts`, {
        method: "POST",
        headers: {
          "Authorization": `Bearer ${API_KEY}`,
          "Content-Type": "application/json",
        },
        body: JSON.stringify(contact),
      });
      return response.json();
    })
  );
 
  console.log(`Imported ${results.length} contacts`);
  return results;
}
 
importContacts();

const fs = require("fs");
 
const API_KEY = "sk_xxx_xxx";
const BASE_URL = "https://dev.nutalk.ai/v1";
 
async function exportCalls(campaignId) {
  const response = await fetch(
    `${BASE_URL}/calls?campaign_id=${campaignId}&limit=100`,
    {
      headers: { "Authorization": `Bearer ${API_KEY}` },
    }
  );
 
  const { data } = await response.json();
 
  // Convert to CSV
  const headers = "id,contact_name,phone,status,duration,outcome,created_at\n";
  const rows = data.map(call =>
    `${call.id},${call.contact_name},${call.contact_phone},${call.status},${call.duration},${call.outcome},${call.created_at}`
  ).join("\n");
 
  fs.writeFileSync("calls-export.csv", headers + rows);
  console.log(`Exported ${data.length} calls to calls-export.csv`);
}
 
exportCalls("camp_xyz123");

const express = require("express");
const crypto = require("crypto");
 
const app = express();
const WEBHOOK_SECRET = process.env.NUTALK_WEBHOOK_SECRET;
 
// Verify webhook signature
function verifySignature(payload, signature) {
  const expected = crypto
    .createHmac("sha256", WEBHOOK_SECRET)
    .update(payload)
    .digest("hex");
  return crypto.timingSafeEqual(
    Buffer.from(signature),
    Buffer.from(expected)
  );
}
 
app.post("/webhooks/nutalk", express.raw({ type: "application/json" }), (req, res) => {
  const signature = req.headers["x-nutalk-signature"];
 
  if (!verifySignature(req.body, signature)) {
    return res.status(401).send("Invalid signature");
  }
 
  const event = JSON.parse(req.body);
 
  switch (event.event) {
    case "call.completed":
      console.log("Call completed:", event.data.call_id);
      // Handle completed call
      break;
 
    case "call.goal_reached":
      console.log("Goal reached:", event.data.goal);
      // Handle goal reached - maybe notify sales team
      break;
 
    case "campaign.completed":
      console.log("Campaign finished:", event.data.campaign_id);
      // Handle campaign completion
      break;
  }
 
  res.status(200).send("OK");
});
 
app.listen(3000);

from flask import Flask, request, jsonify
import hmac
import hashlib
import os
 
app = Flask(__name__)
WEBHOOK_SECRET = os.environ.get("NUTALK_WEBHOOK_SECRET")
 
def verify_signature(payload, signature):
    expected = hmac.new(
        WEBHOOK_SECRET.encode(),
        payload,
        hashlib.sha256
    ).hexdigest()
    return hmac.compare_digest(signature, expected)
 
@app.route("/webhooks/nutalk", methods=["POST"])
def handle_webhook():
    signature = request.headers.get("X-Nutalk-Signature")
 
    if not verify_signature(request.data, signature):
        return jsonify({"error": "Invalid signature"}), 401
 
    event = request.json
    event_type = event.get("event")
    data = event.get("data")
 
    if event_type == "call.completed":
        print(f"Call completed: {data['call_id']}")
        # Handle completed call
 
    elif event_type == "call.goal_reached":
        print(f"Goal reached: {data['goal']}")
        # Handle goal reached
 
    elif event_type == "campaign.completed":
        print(f"Campaign finished: {data['campaign_id']}")
        # Handle campaign completion
 
    return jsonify({"status": "ok"}), 200
 
if __name__ == "__main__":
    app.run(port=3000)