Product Delivery to DSPs

// Get all deliveries
const response = await fetch(`https://api.royalti.io/product/${productId}/deliveries`, {
  headers: { 'Authorization': `Bearer ${API_TOKEN}` }
});

const { data } = await response.json();

// Check delivery logs
data.forEach(delivery => {
  console.log(`\nDelivery ${delivery.id}:`);
  console.log(`  Provider: ${delivery.providerName}`);
  console.log(`  Status: ${delivery.status}`);
  console.log(`  Progress: ${delivery.progress}%`);
  console.log(`  Attempts: ${delivery.attemptCount}/${delivery.maxAttempts}`);

  if (delivery.deliveryLog) {
    console.log('  Recent events:');
    delivery.deliveryLog.slice(-3).forEach(log => {
      console.log(`    - ${log.event} (${log.status})`);
    });
  }
});

# Get all deliveries
response = requests.get(
    f'https://api.royalti.io/product/{product_id}/deliveries',
    headers={'Authorization': f'Bearer {API_TOKEN}'}
)

deliveries = response.json()['data']

# Check delivery logs
for delivery in deliveries:
    print(f"\nDelivery {delivery['id']}:")
    print(f"  Provider: {delivery['providerName']}")
    print(f"  Status: {delivery['status']}")
    print(f"  Progress: {delivery['progress']}%")
    print(f"  Attempts: {delivery['attemptCount']}/{delivery['maxAttempts']}")

    if delivery.get('deliveryLog'):
        print("  Recent events:")
        for log in delivery['deliveryLog'][-3:]:
            print(f"    - {log['event']} ({log['status']})")

const retry = await fetch(
  `https://api.royalti.io/product/${productId}/deliveries/${deliveryId}/retry`,
  {
    method: 'PUT',
    headers: { 'Authorization': `Bearer ${API_TOKEN}` }
  }
);

if (retry.ok) {
  const { data } = await retry.json();
  console.log(`Retry initiated. Attempt ${data.attemptCount}/${data.maxAttempts}`);
}

response = requests.put(
    f'https://api.royalti.io/product/{product_id}/deliveries/{delivery_id}/retry',
    headers={'Authorization': f'Bearer {API_TOKEN}'}
)

if response.ok:
    data = response.json()['data']
    print(f"Retry initiated. Attempt {data['attemptCount']}/{data['maxAttempts']}")

const cancel = await fetch(
  `https://api.royalti.io/product/${productId}/deliveries/${deliveryId}`,
  {
    method: 'DELETE',
    headers: {
      'Authorization': `Bearer ${API_TOKEN}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      reason: 'Product metadata needs updating'
    })
  }
);

const { data } = await cancel.json();
console.log(`Delivery cancelled: ${data.status}`);

response = requests.delete(
    f'https://api.royalti.io/product/{product_id}/deliveries/{delivery_id}',
    headers={
        'Authorization': f'Bearer {API_TOKEN}',
        'Content-Type': 'application/json'
    },
    json={'reason': 'Product metadata needs updating'}
)

data = response.json()['data']
print(f"Delivery cancelled: {data['status']}")

const batch = await fetch('https://api.royalti.io/product/batch-delivery', {
  method: 'POST',
  headers: {
    'Authorization': `Bearer ${API_TOKEN}`,
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    productIds: ['prod-123', 'prod-456', 'prod-789'],
    provider: 'spotify-ddex-sftp',
    priority: 'normal',
    settings: {
      releaseType: 'Album'
    }
  })
});

const { data } = await batch.json();
console.log(`Batch ${data.batchId}: ${data.successfulDeliveries}/${data.totalProducts} successful`);

response = requests.post(
    'https://api.royalti.io/product/batch-delivery',
    headers={
        'Authorization': f'Bearer {API_TOKEN}',
        'Content-Type': 'application/json'
    },
    json={
        'productIds': ['prod-123', 'prod-456', 'prod-789'],
        'provider': 'spotify-ddex-sftp',
        'priority': 'normal',
        'settings': {
            'releaseType': 'Album'
        }
    }
)

data = response.json()['data']
print(f"Batch {data['batchId']}: {data['successfulDeliveries']}/{data['totalProducts']} successful")

import requests
import time

def deliver_product(product_id, providers):
    base_url = 'https://api.royalti.io'
    headers = {
        'Authorization': f'Bearer {API_TOKEN}',
        'Content-Type': 'application/json'
    }

    try:
        # Step 1: Validate
        print('Validating product...')
        validation = requests.post(
            f'{base_url}/product/{product_id}/deliveries/validate',
            headers=headers,
            json={'providers': providers}
        )
        validation.raise_for_status()

        if not all(v['isValid'] for v in validation.json()['data']['validations']):
            print(f'Validation failed: {validation.json()}')
            return

        # Step 2: Deliver
        print('Initiating delivery...')
        delivery = requests.post(
            f'{base_url}/product/{product_id}/deliveries',
            headers=headers,
            json={'providers': providers, 'autoDeliver': True}
        )
        delivery.raise_for_status()

        delivery_ids = [d['deliveryId'] for d in delivery.json()['data']['deliveries']]
        print(f'Deliveries initiated: {delivery_ids}')

        # Step 3: Monitor
        print('Monitoring delivery status...')
        for delivery_id in delivery_ids:
            monitor_delivery(product_id, delivery_id, headers, base_url)

    except requests.exceptions.RequestException as error:
        print(f'Delivery error: {error.response.json() if error.response else str(error)}')

def monitor_delivery(product_id, delivery_id, headers, base_url):
    attempts = 0
    max_attempts = 60  # 5 minutes with 5-second intervals

    while attempts < max_attempts:
        response = requests.get(
            f'{base_url}/product/{product_id}/deliveries/{delivery_id}',
            headers=headers
        )
        response.raise_for_status()

        data = response.json()['data']
        status = data['status']
        progress = data['progress']

        print(f"Delivery {delivery_id}: {status} ({progress}%)")

        if status == 'delivered':
            print('Delivery completed successfully!')
            return

        if status in ['failed', 'error', 'rejected']:
            print(f'Delivery failed: {data}')
            return

        time.sleep(5)
        attempts += 1

    print('Monitoring timeout reached')

# Usage
deliver_product('prod-123', ['spotify-ddex-sftp', 'apple-ddex-api'])