Shipping integration

async function getShippingRates(params: {
  fromCep: string;
  toCep: string;
  weight: number;
  dimensions: { width: number; height: number; length: number };
}) {
  const response = await melhorEnvio.post('/shipment/calculate', {
    from: { postal_code: params.fromCep },
    to: { postal_code: params.toCep },
    package: {
      weight: params.weight,
      width: params.dimensions.width,
      height: params.dimensions.height,
      length: params.dimensions.length,
    },
  });

  return response.data.map(rate => ({
    carrier: rate.company.name,
    service: rate.name,
    price: rate.price,
    deliveryDays: rate.delivery_time,
  }));
}

async function createShippingLabel(order: Order, carrier: string) {
  const shipment = await melhorEnvio.post('/shipment/generate', {
    service: carrier,
    from: order.seller.address,
    to: order.buyer.address,
    package: order.packageInfo,
    invoice: {
      key: order.invoiceKey, // Nota fiscal
    },
  });

  await db.update(orders)
    .set({
      trackingCode: shipment.tracking,
      labelUrl: shipment.label_url,
    })
    .where(eq(orders.id, order.id));

  return shipment;
}

async function handleTrackingWebhook(payload: TrackingEvent) {
  const order = await getOrderByTracking(payload.tracking_code);

  await db.insert(trackingEvents).values({
    orderId: order.id,
    status: payload.status,
    description: payload.description,
    location: payload.location,
    timestamp: payload.timestamp,
  });

  // Notify buyer
  await sendPushNotification(order.buyerId, {
    title: 'Shipping Update',
    body: payload.description,
  });

  // Update order status
  if (payload.status === 'delivered') {
    await db.update(orders)
      .set({ status: 'delivered', deliveredAt: new Date() })
      .where(eq(orders.id, order.id));
  }
}