Create Wastes (v2)

curl -i -X POST "https://api.dcycle.io/v2/wastes" \
  -H "x-api-key: ${DCYCLE_API_KEY}" \
  -H "x-organization-id: ${DCYCLE_ORG_ID}" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: $(uuidgen)" \
  -d '{
    "records": [
      {
        "client_row_id": "ALB-2026-09-0001",
        "facility_percentages": [{ "facility_id": "660e8400-e29b-41d4-a716-446655440000", "percentage": 1 }],
        "identification_name": "ALB-2026-09-0001",
        "start_date": "2026-09-01",
        "end_date": "2026-09-30",
        "base_quantity": 1250.5,
        "unit_id": "61743a63-ff70-459c-9567-5eee8f7dfd5c",
        "waste_ler_code_id": "33d3e986-2e02-4aaa-8be0-708c143c02d9",
        "waste_rd_code_id": "6617caab-9db0-40df-8716-54d8c94e8056",
        "provider_name": "Ecoveza S.L.",
        "total_km_to_waste_center": 42
      },
      {
        "client_row_id": "ALB-2026-09-0002",
        "facility_percentages": [{ "facility_id": "660e8400-e29b-41d4-a716-446655440000", "percentage": 1 }],
        "identification_name": "ALB-2026-09-0002",
        "start_date": "2026-09-01",
        "end_date": "2026-09-30",
        "base_quantity": 380,
        "unit_id": "61743a63-ff70-459c-9567-5eee8f7dfd5c",
        "description": "Mezcla de envases ligeros"
      }
    ]
  }'

# Then poll the job from the Location header
curl "https://api.dcycle.io/v2/ingest-jobs/2d4b90c1-7c1e-4b6f-9a55-3f2b8e61d0aa" \
  -H "x-api-key: ${DCYCLE_API_KEY}" \
  -H "x-organization-id: ${DCYCLE_ORG_ID}"

import os
import time
import uuid

import requests

BASE_URL = "https://api.dcycle.io"
HEADERS = {
    "x-api-key": os.environ["DCYCLE_API_KEY"],
    "x-organization-id": os.environ["DCYCLE_ORG_ID"],
}

records = [
    {
        "client_row_id": "ALB-2026-09-0001",
        "facility_percentages": [{"facility_id": "660e8400-e29b-41d4-a716-446655440000", "percentage": 1}],
        "identification_name": "ALB-2026-09-0001",
        "start_date": "2026-09-01",
        "end_date": "2026-09-30",
        "base_quantity": 1250.5,
        "unit_id": "61743a63-ff70-459c-9567-5eee8f7dfd5c",
        "waste_ler_code_id": "33d3e986-2e02-4aaa-8be0-708c143c02d9",
    },
]

# One key per batch: reuse it only to retry this same batch.
idempotency_key = str(uuid.uuid4())
response = requests.post(
    f"{BASE_URL}/v2/wastes",
    headers={**HEADERS, "Idempotency-Key": idempotency_key},
    json={"records": records},
    timeout=60,
)

if response.status_code == 422 and response.json().get("code") == "BULK_RECORDS_REJECTED":
    for rejection in response.json()["errors"]:
        print(rejection["source_row_index"], rejection["client_row_id"], rejection["error_code"], rejection["error_params"])
    raise SystemExit("Fix the listed records and resend the whole batch")
response.raise_for_status()

job_url = BASE_URL + response.headers["Location"]
while True:
    job = requests.get(job_url, headers=HEADERS, timeout=30).json()
    print(f"{job['status']}: {job['chunks_done']}/{job['chunks_total']} chunks")
    if job["status"] != "processing":
        break
    time.sleep(10)

if job["status"] == "completed_with_errors":
    page = 1
    while True:  # up to 5,000 records: read every page of failures
        failed = requests.get(
            f"{job_url}/items",
            headers=HEADERS,
            params={"status": "failed", "size": 500, "page": page},
            timeout=30,
        ).json()
        for item in failed["items"]:
            print("calculation failed:", item["client_row_id"], item["error_code"])
        if page * failed["size"] >= failed["total"]:
            break
        page += 1

const axios = require('axios');
const { randomUUID } = require('crypto');

const api = axios.create({
  baseURL: 'https://api.dcycle.io',
  headers: {
    'x-api-key': process.env.DCYCLE_API_KEY,
    'x-organization-id': process.env.DCYCLE_ORG_ID,
  },
});

async function createWastes(records) {
  let response;
  try {
    response = await api.post('/v2/wastes', { records }, {
      headers: { 'Idempotency-Key': randomUUID() },
    });
  } catch (error) {
    const body = error.response && error.response.data;
    if (body && body.code === 'BULK_RECORDS_REJECTED') {
      body.errors.forEach(r =>
        console.log(r.source_row_index, r.client_row_id, r.error_code, r.error_params));
    }
    throw error;
  }

  const jobPath = response.headers.location;
  let job = response.data;
  while (job.status === 'processing') {
    await new Promise(resolve => setTimeout(resolve, 10000));
    job = (await api.get(jobPath)).data;
    console.log(`${job.status}: ${job.chunks_done}/${job.chunks_total} chunks`);
  }
  return job;
}