Delivery Logs API

{
  "metadata": {
    "timestamp": "2025-01-15T12:00:00Z",
    "query": {
      "webhookId": "wh_abc123",
      "page": 1,
      "perPage": 50
    }
  },
  "result": [
    {
      "deliveryId": "del_xyz789",
      "webhookId": "wh_abc123",
      "workOrderId": 12345,
      "eventName": "workorder.status.published",
      "deliveryStatus": 200,
      "deliveryAttempt": 1,
      "createdAt": "2025-01-15T11:59:00Z"
    }
  ]
}

curl -X GET https://api-sandbox.fndev.net/api/v1/webhooks/delivery-logs/del_xyz789 \
  -H "Authorization: Bearer YOUR_ACCESS_TOKEN"

{
  "metadata": {
    "timestamp": "2025-01-15T12:00:00Z"
  },
  "result": {
    "deliveryId": "del_xyz789",
    "webhookId": "wh_abc123",
    "eventName": "workorder.status.published",
    "deliveryStatus": 200,
    "deliveryAttempt": 1,
    "createdAt": "2025-01-15T11:59:00Z",
    "delivery_log": "https://s3.amazonaws.com/fn-logs/del_xyz789?AWSAccessKeyId=...&Expires=1642252800&Signature=..."
  }
}

curl -X PATCH https://api-sandbox.fndev.net/api/v1/webhooks/delivery-logs/del_xyz789/retry \
  -H "Authorization: Bearer YOUR_ACCESS_TOKEN"

{
  "metadata": {
    "timestamp": "2025-01-15T12:00:00Z"
  },
  "result": {
    "job_id": "job_abc123"
  }
}

class DeliveryLogMonitor {
  constructor(accessToken) {
    this.accessToken = accessToken;
    this.baseUrl = 'https://api-sandbox.fndev.net';
  }

  async getLogs(filters = {}) {
    const params = new URLSearchParams(filters);
    const response = await fetch(
      `${this.baseUrl}/api/v1/webhooks/delivery-logs?${params}`,
      {
        headers: { 'Authorization': `Bearer ${this.accessToken}` }
      }
    );
    return await response.json();
  }

  async getDeliveryDetails(deliveryId) {
    const response = await fetch(
      `${this.baseUrl}/api/v1/webhooks/delivery-logs/${deliveryId}`,
      {
        headers: { 'Authorization': `Bearer ${this.accessToken}` }
      }
    );
    return await response.json();
  }

  async retryDelivery(deliveryId) {
    const response = await fetch(
      `${this.baseUrl}/api/v1/webhooks/delivery-logs/${deliveryId}/retry`,
      {
        method: 'PATCH',
        headers: { 'Authorization': `Bearer ${this.accessToken}` }
      }
    );
    return await response.json();
  }

  async getFailedDeliveries(webhookId, hours = 24) {
    const since = new Date(Date.now() - hours * 60 * 60 * 1000).toISOString();

    const logs = await this.getLogs({
      webhookId,
      sortBy: 'createdAt',
      sortDirection: 'DESC'
    });

    return logs.result.filter(log =>
      log.deliveryStatus >= 400 &&
      new Date(log.createdAt) >= new Date(since)
    );
  }

  async retryAllFailed(webhookId) {
    const failed = await this.getFailedDeliveries(webhookId);

    const results = [];
    for (const log of failed) {
      try {
        const result = await this.retryDelivery(log.deliveryId);
        results.push({ deliveryId: log.deliveryId, success: true, jobId: result.result.job_id });
      } catch (error) {
        results.push({ deliveryId: log.deliveryId, success: false, error: error.message });
      }
    }

    return results;
  }
}

// Usage
const monitor = new DeliveryLogMonitor(accessToken);

// Get failed deliveries
const failed = await monitor.getFailedDeliveries('wh_abc123', 24);
console.log(`${failed.length} failed deliveries in last 24 hours`);

// Retry all failed
const results = await monitor.retryAllFailed('wh_abc123');
console.log(`Retried ${results.length} deliveries`);