const UseDropTrail = require('usedroptrail');
const usedroptrail = new UseDropTrail({
  apiKey: 'YOUR_API_KEY'
});

const deliveryRequest = await usedroptrail.deliveryRequests.create({
  orderId: '123456',
  pickupAddress: '123 Main St, Anytown, USA',
  deliveryAddress: '456 Elm St, Anytown, USA',
  pickupTime: '2024-01-01T10:00:00Z',
  deliveryTime: '2024-01-01T12:00:00Z'
});

const deliveryStatus = await usedroptrail.deliveryRequests.get(deliveryRequest.id);
console.log(deliveryStatus);

const deliveryNotification = await usedroptrail.deliveryRequests.update(deliveryRequest.id, {
  status: 'delivered'
});
console.log(deliveryNotification);

app.post('/webhooks/usedroptrail', async (req, res) => {
  const event = req.body;

  switch (event.type) {
    case 'delivery.accepted':
      await handleDeliveryAccepted(event.data);
      break;
    case 'delivery.in_transit':
      await handleDeliveryInTransit(event.data);
      break;
    case 'delivery.completed':
      await handleDeliveryCompleted(event.data);
      break;
    case 'delivery.cancelled':
      await handleDeliveryCancelled(event.data);
      break;
  }

  res.status(200).send('Webhook received');
});

try {
  const deliveryRequest = await createDeliveryFromOrder(order);
} catch (error) {
  if (error.code === 'INVALID_ADDRESS') {
    // Validate and clean up address
    const correctedAddress = await validateAddress(order.shipping_address);
    // Retry with corrected address
    return createDeliveryFromOrder({ ...order, shipping_address: correctedAddress });
  }
  // Handle other errors
}

function setupDeliveryTrackingWithRetry(deliveryRequestId, maxRetries = 3) {
  let retries = 0;
  
  function connect() {
    const ws = droptrail.tracking.connect(deliveryRequestId);
    
    ws.on('error', (error) => {
      console.error('Tracking connection error:', error);
      if (retries < maxRetries) {
        retries++;
        setTimeout(connect, 5000 * retries);
      }
    });
    
    return ws;
  }
  
  return connect();
}