Returns & Refund (RMA)

import { createServices } from "commercio";

const services = createServices();

// Assume we have a completed order with ID 'orderId' and customer 'customerId'
// The order contained 5x laptop and 10x charger

// Customer wants to return 2 defective laptops
const rma = await services.rmaService.createRma(
  orderId,
  customerId,
  [
    {
      productId: laptopId,
      quantity: 2,
      reason: "DEFECTIVE",
      notes: "Screen flickering on both units after 2 weeks",
    },
  ],
  { notes: "Customer reported via email on 2026-04-10" }
);

console.log(`RMA ${rma.id} created`);
console.log(`Status: ${rma.status}`);          // REQUESTED
console.log(`Items: ${rma.items.length}`);      // 1
console.log(`Return qty: ${rma.items[0].quantity}`); // 2

// Audit the RMA request
await services.auditLogService.log("RMA", rma.id, "CREATE", {
  actor: customerId,
  newValues: {
    orderId,
    reason: "DEFECTIVE",
    quantity: 2,
  },
});

// Support agent reviews the RMA
const pending = await services.rmaService.getRmasByStatus("REQUESTED");
console.log(`${pending.length} RMAs awaiting review`);

// Look up the original order to verify the claim
const order = await services.orderService.getOrderById(orderId);
const laptopItem = order.items.find(i => i.productId === laptopId);
console.log(`Original order had ${laptopItem?.quantity} laptops`);

// Approve the RMA
const approved = await services.rmaService.approveRma(rma.id,
  "Approved: defective units within warranty period"
);
console.log(`RMA status: ${approved.status}`); // APPROVED

// Provide return shipping label tracking number
await services.rmaService.setTrackingNumber(rma.id, "DHL-RET-9876543210");

await services.auditLogService.log("RMA", rma.id, "STATUS_CHANGE", {
  actor: "support@company.de",
  oldValues: { status: "REQUESTED" },
  newValues: { status: "APPROVED" },
});

// Warehouse receives the returned items
const received = await services.rmaService.receiveRma(rma.id, warehouseId);
console.log(`RMA status: ${received.status}`); // RECEIVED
// This automatically creates RETURN inventory transactions

// Verify stock was updated
const stock = await services.stockService.getStock(laptopId, warehouseId);
console.log(`Laptop stock after return: ${stock?.quantity}`); // increased by 2

// Update serial number status for the returned units
// Look up which serial numbers were assigned to this order
const orderSerials = await services.batchTrackingService.getSerialNumbersByProduct(laptopId);
const soldToOrder = orderSerials.filter(sn => sn.orderId === orderId && sn.status === "SOLD");

// Mark 2 returned units
for (let i = 0; i < 2 && i < soldToOrder.length; i++) {
  await services.batchTrackingService.markReturned(soldToOrder[i].id);
  console.log(`Serial ${soldToOrder[i].serialNumber} marked as RETURNED`);
}

// One unit is defective beyond repair
await services.batchTrackingService.markDefective(soldToOrder[0].id);
console.log(`Serial ${soldToOrder[0].serialNumber} marked as DEFECTIVE`);

// Full traceability
const trace = await services.batchTrackingService.getTraceability(
  soldToOrder[0].serialNumber
);
console.log("\nTraceability report:");
console.log(`  Serial: ${trace.serialNumber.serialNumber}`);
console.log(`  Status: ${trace.serialNumber.status}`);
console.log(`  Batch: ${trace.batch?.batchNumber}`);
console.log(`  Order: ${trace.orderId}`);

// Calculate refund amount based on original order prices
const refundAmount = 2 * laptopItem!.unitPrice; // 2 units * unit price

// Process refund on the RMA
const refunded = await services.rmaService.refundRma(rma.id, refundAmount);
console.log(`Refund amount: ${refunded.refundAmount} cents`);

// Create a refund payment record
const originalPayments = await services.paymentService.getPaymentsByOrder(orderId);
const originalPayment = originalPayments.find(p => p.status === "COMPLETED");

if (originalPayment) {
  await services.paymentService.refundPayment(originalPayment.id, refundAmount);
  console.log("Partial refund processed on original payment");
}

// Emit webhook for external accounting
await services.webhookService.emit("PAYMENT_REFUNDED", {
  orderId,
  rmaId: rma.id,
  refundAmount,
  reason: "DEFECTIVE",
});

// Close the RMA
const closed = await services.rmaService.closeRma(rma.id);
console.log(`RMA status: ${closed.status}`); // CLOSED

// Final audit
await services.auditLogService.log("RMA", rma.id, "STATUS_CHANGE", {
  actor: "finance@company.de",
  oldValues: { status: "REFUNDED" },
  newValues: { status: "CLOSED", refundAmount },
});