EaseBG API

{
  "imageUrl": "https://example.com/photo.jpg"
}

# Step 1: Get a presigned upload URL
curl -X POST "https://api.easebg.com/api/v1/app/tasks/uploads/presign" \
  -H "Authorization: Bearer YOUR_JWT_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"fileName": "photo.jpg", "contentType": "image/jpeg"}'

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

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": "https://example.com/photo.jpg",
    "modelVersion": "easebg-2.0",
    "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-2.0",
    "sourceUrl": "https://example.com/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-2.0",
    "sourceUrl": "https://example.com/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"
  }
}

// SSE connection (authenticate via token query parameter)
const eventSource = new EventSource(
  `https://api.easebg.com/api/v1/app/tasks/images/${taskId}/stream?token=${accessToken}`
);

eventSource.addEventListener('progress', (e) => {
  console.log('Progress:', JSON.parse(e.data));
});

eventSource.addEventListener('completed', (e) => {
  console.log('Completed:', JSON.parse(e.data));
  eventSource.close();
});

eventSource.addEventListener('failed', (e) => {
  console.error('Failed:', JSON.parse(e.data));
  eventSource.close();
});

# 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: a1b2c3d4e5f6...
X-EaseBG-Event: task.succeeded

{
  "eventId": "evt_abc123",
  "event": "task.succeeded",
  "taskId": "550e8400-e29b-41d4-a716-446655440000",
  "resultUrl": "https://storage.easebg.com/results/550e8400.png",
  "timestamp": "2025-01-15T10:30:05Z"
}

const crypto = require('crypto');

function verifySignature(payload, signature, secret) {
  const computed = crypto
    .createHmac('sha256', secret)
    .update(payload, 'utf8')
    .digest('hex');
  return crypto.timingSafeEqual(
    Buffer.from(computed, 'hex'),
    Buffer.from(signature, 'hex')
  );
}

// Idempotent handling example
async function handleWebhook(req, res) {
  const { eventId, event, taskId } = req.body;

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

  // Process the event
  await processEvent(event, taskId);

  // Record as processed
  await db.query(
    'INSERT INTO webhook_events (event_id, event_type, task_id) VALUES ($1, $2, $3)',
    [eventId, event, taskId]
  );

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

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

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