Async Classification & Webhooks

# Poll until status is "completed" or "failed"
while true; do
  RESULT=$(curl -s https://api.tarifflens.ai/api/v1/classifications/clf_def456 \
    -H "Authorization: Bearer tlk_live_xxxxx")

  STATUS=$(echo "$RESULT" | jq -r '.status')
  echo "Status: $STATUS"

  if [ "$STATUS" = "completed" ] || [ "$STATUS" = "failed" ]; then
    echo "$RESULT" | jq .
    break
  fi

  sleep 5
done

async function pollClassification(id: string, apiKey: string) {
  const baseUrl = "https://api.tarifflens.ai";
  const maxWait = 5 * 60 * 1000; // 5 minute timeout
  const start = Date.now();

  while (Date.now() - start < maxWait) {
    const res = await fetch(`${baseUrl}/api/v1/classifications/${id}`, {
      headers: { Authorization: `Bearer ${apiKey}` },
    });
    const data = await res.json();

    if (data.status === "completed" || data.status === "failed") {
      return data;
    }

    // Adaptive interval: 5s for first 30s, then 10s
    const elapsed = Date.now() - start;
    const delay = elapsed < 30_000 ? 5_000 : 10_000;
    await new Promise((r) => setTimeout(r, delay));
  }

  throw new Error("Classification timed out");
}

{
  "id": "clf_def456",
  "status": "completed",
  "schedule": "US-HTS",
  "created_at": "2026-01-08T10:30:00Z",
  "completed_at": "2026-01-08T10:31:02Z",
  "product": {
    "name": "Industrial Servo Motor",
    "description": "Brushless AC servo motor, 2.5kW, 3000 RPM, with integrated encoder",
    "identifier": "SKU-12345",
    "country_of_origin": "DE"
  },
  "result": {
    "hts_code": "8501524000",
    "hts_description": "AC motors, multi-phase: exceeding 750 W but not exceeding 75 kW",
    "supporting_rulings": ["NY N123456", "HQ H987654"],
    "reasoning": "Classified as AC servo motor exceeding 750W based on product specifications and CBP ruling precedent."
  },
  "usage": {
    "credits_consumed": 1,
    "processing_time_ms": 62000
  }
}

curl -X PUT https://api.tarifflens.ai/api/v1/webhooks \
  -H "Authorization: Bearer tlk_live_xxxxx" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://your-app.com/webhooks/tarifflens",
    "secret": "whsec_your_signing_secret",
    "event_types": ["classification.completed"],
    "enabled": true
  }'

curl -X POST https://api.tarifflens.ai/api/v1/products/classify \
  -H "Authorization: Bearer tlk_live_xxxxx" \
  -H "Content-Type: application/json" \
  -d '{
    "product": {
      "name": "Industrial Servo Motor",
      "description": "Brushless AC servo motor, 2.5kW"
    },
    "schedules": ["US-HTS"],
    "options": {
      "webhook_url": "https://your-app.com/webhooks/tarifflens"
    }
  }'

Content-Type: application/json
X-TariffLens-Event: classification.completed
X-TariffLens-Delivery-ID: dlv_abc123  # Unique per delivery (use for idempotency)
X-Webhook-Secret: whsec_your_signing_secret  # If configured

{
  "event": "classification.completed",
  "timestamp": "2026-01-08T10:31:02Z",
  "data": {
    "id": "clf_def456",
    "status": "completed",
    "schedule": "US-HTS",
    "product": {
      "name": "Industrial Servo Motor",
      "identifier": "SKU-12345"
    },
    "result": {
      "hts_code": "8501524000",
      "hts_description": "AC motors, multi-phase: exceeding 750 W but not exceeding 75 kW",
      "supporting_rulings": ["NY N123456", "HQ H987654"],
      "reasoning": "Classified as AC servo motor exceeding 750W based on product specifications and CBP ruling precedent."
    }
  }
}

import express from "express";

const app = express();
app.use(express.json());

app.post("/webhooks/tarifflens", (req, res) => {
  const event = req.headers["x-tarifflens-event"];
  const deliveryId = req.headers["x-tarifflens-delivery-id"];
  const secret = req.headers["x-webhook-secret"];

  // Verify the secret matches your configured value
  if (secret !== process.env.WEBHOOK_SECRET) {
    return res.status(401).send("Invalid secret");
  }

  // Deduplicate using delivery ID
  // (store processed delivery IDs to handle retries)

  const { data } = req.body;

  if (event === "classification.completed") {
    console.log(`Classification ${data.id} completed:`);
    console.log(`  HTS: ${data.result.hts_code}`);
    console.log(`  Reasoning: ${data.result.reasoning}`);
    console.log(`  Product: ${data.product.identifier}`);

    // Update your database, notify users, etc.
  }

  // Respond quickly with 2xx — process asynchronously if needed
  res.status(200).send("OK");
});