EaseBG API

# Step 1: Get a presigned upload URL (developer API, API Key auth)
curl -X POST "https://api.easebg.com/api/v1/open/developer/uploads/presign" \
  -H "X-API-Key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"fileName": "photo.jpg", "contentType": "image/jpeg", "fileSize": 204800}'

# Step 2: Upload the file using the returned uploadUrl
curl -X PUT "RETURNED_UPLOAD_URL" \
  -H "Content-Type: image/jpeg" \
  --data-binary @photo.jpg

# objectKey is now ready: use it as imageUrl when creating a task

# Step 1: Get a pre-signed upload URL
curl -X POST "https://api.easebg.com/api/v1/open/developer/uploads/presign" \
  -H "X-API-Key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{ "fileName": "photo.jpg", "contentType": "image/jpeg", "fileSize": 204800 }'
# → { "data": { "uploadUrl": "...", "objectKey": "private-uploads/2026/...", "method": "PUT", ... } }

# Step 2: Upload the file directly (PUT to uploadUrl)

# Step 3: Create a task with the objectKey
curl -X POST "https://api.easebg.com/api/v1/open/developer/tasks" \
  -H "X-API-Key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "imageUrl": "private-uploads/2026/08/550e8400-photo.jpg",
    "modelVersion": "easebg-v2",
    "callbackUrl": "https://your-app.com/webhooks/easebg"
  }'

curl "https://api.easebg.com/api/v1/open/developer/tasks/TASK_ID" \
  -H "X-API-Key: YOUR_API_KEY"

{
  "request_id": "req_abc123",
  "data": {
    "id": "550e8400-e29b-41d4-a716-446655440000",
    "status": "processing",
    "modelVersion": "easebg-v2",
    "sourceUrl": "private-uploads/2026/08/550e8400-photo.jpg",
    "resultUrl": null,
    "createdAt": "2025-01-15T10:30:00Z",
    "completedAt": null
  }
}

{
  "request_id": "req_abc123",
  "data": {
    "id": "550e8400-e29b-41d4-a716-446655440000",
    "status": "succeeded",
    "modelVersion": "easebg-v2",
    "sourceUrl": "private-uploads/2026/08/550e8400-photo.jpg",
    "resultUrl": "https://storage.easebg.com/results/550e8400.png",
    "durationMs": 1200,
    "createdAt": "2025-01-15T10:30:00Z",
    "completedAt": "2025-01-15T10:30:01.2Z"
  }
}

// Poll task event history (JWT auth via Authorization header)
async function pollTaskEvents(taskId, accessToken, intervalMs = 2000) {
  const seen = new Set();
  const timer = setInterval(async () => {
    const res = await fetch(
      `https://api.easebg.com/api/v1/app/tasks/images/${taskId}/events`,
      { headers: { Authorization: `Bearer ${accessToken}` } }
    );
    const { data: events } = await res.json();
    for (const ev of events) {
      if (!seen.has(ev.id)) {
        seen.add(ev.id);
        console.log('Event:', ev.event_type, ev.event_payload);
        if (ev.event_type === 'succeeded' || ev.event_type === 'failed' || ev.event_type === 'canceled' || ev.event_type === 'dead_letter' || ev.event_type === 'dead_lettered') {
          clearInterval(timer);
        }
      }
    }
  }, intervalMs);
}

# Download the result image
curl -o result.png "https://storage.easebg.com/results/550e8400.png"

curl "https://api.easebg.com/api/v1/app/tasks/images/TASK_ID/download" \
  -H "Authorization: Bearer YOUR_JWT_TOKEN"

POST /your-webhook-endpoint HTTP/1.1
Host: your-app.com
Content-Type: application/json
X-EaseBG-Signature: t=1736937005,v1=a1b2c3d4e5f6...

{
  "event": "task.succeeded",
  "task_id": "550e8400-e29b-41d4-a716-446655440000",
  "message": "Task completed successfully"
}

const crypto = require('crypto');

// header: 't=1736937005,v1=a1b2c3d4...'
function verifySignature(rawBody, header, secret) {
  if (!header) return false; // header absent -> reject, don't throw
  const match = /^t=(\d+),v1=([a-f0-9]+)$/.exec(header);
  if (!match) return false;
  const [, timestamp, signature] = match;
  const computed = crypto
    .createHmac('sha256', secret)
    .update(`${timestamp}.${rawBody}`, 'utf8')
    .digest('hex');
  const computedBuffer = Buffer.from(computed, 'hex');
  const signatureBuffer = Buffer.from(signature, 'hex');
  // timingSafeEqual throws RangeError when buffer lengths differ, so guard first
  if (computedBuffer.length !== signatureBuffer.length) return false;
  return crypto.timingSafeEqual(computedBuffer, signatureBuffer);
}

{
  "event": "test.webhook",
  "timestamp": "2025-01-15T10:30:05.000Z",
  "data": {
    "message": "This is a test webhook event from EaseBG v2 developer center.",
    "endpoint_id": "your-endpoint-id"
  }
}

// Idempotent handling example
async function handleWebhook(req, res) {
  const { event, task_id, order_id } = req.body;
  // Use event type + business ID as the idempotency key (payload has no global event ID)
  const eventKey = `${event}:${task_id || order_id || ''}`;

  // Check if event was already processed
  const exists = await db.query(
    'SELECT 1 FROM processed_webhook_events WHERE event_key = $1',
    [eventKey]
  );
  if (exists) {
    return res.status(200).json({ ok: true, message: 'already processed' });
  }

  // Process the event
  await processEvent(event, task_id || order_id);

  // Record as processed
  await db.query(
    'INSERT INTO processed_webhook_events (event_key, event_type) VALUES ($1, $2)',
    [eventKey, event]
  );

  res.status(200).json({ ok: true });
}

{
  "request_id": "req_abc123",
  "error": {
    "code": "DEVELOPER_TASK_NOT_FOUND",
    "message": "Task not found",
    "details": {}
  }
}

X-RateLimit-Limit: 1200
X-RateLimit-Remaining: 0
X-RateLimit-Reset: 1736940660
Retry-After: 60