const REDACT_FIELDS = new Set([
  'email', 'phone', 'contact_name', 'street_address',
  'tax_id', 'bank_account', 'credit_card',
]);

function redactPII(obj: any, depth = 0): any {
  if (depth > 10 || !obj || typeof obj !== 'object') return obj;
  const result: any = Array.isArray(obj) ? [] : {};
  for (const [key, value] of Object.entries(obj)) {
    if (REDACT_FIELDS.has(key)) {
      result[key] = '***REDACTED***';
    } else if (typeof value === 'object') {
      result[key] = redactPII(value, depth + 1);
    } else {
      result[key] = value;
    }
  }
  return result;
}

// Usage in logging
logger.info({ shipment: redactPII(shipmentData) }, 'Shipment processed');

// Automated cleanup based on retention policy
const RETENTION = {
  shipments: 365,        // 1 year after delivery
  purchase_orders: 730,  // 2 years (tax/audit requirements)
  invoices: 2555,        // 7 years (financial regulations)
  webhookLogs: 90,       // 90 days
  apiLogs: 30,           // 30 days
};

async function enforceRetention() {
  for (const [table, days] of Object.entries(RETENTION)) {
    const cutoff = new Date(Date.now() - days * 24 * 60 * 60 * 1000);
    const deleted = await db.$executeRaw`
      DELETE FROM ${table} WHERE created_at < ${cutoff} AND status = 'delivered'
    `;
    logger.info({ table, deleted, cutoffDate: cutoff }, 'Retention cleanup');
  }
}

async function handleDeletionRequest(contactEmail: string) {
  // Find all shipments associated with this contact
  const shipments = await db.shipments.findMany({
    where: { OR: [{ shipperEmail: contactEmail }, { consigneeEmail: contactEmail }] },
  });

  for (const shipment of shipments) {
    // Redact PII but keep shipment record for business continuity
    await db.shipments.update({
      where: { id: shipment.id },
      data: {
        shipperName: '[REDACTED]',
        shipperEmail: '[REDACTED]',
        consigneeName: '[REDACTED]',
        consigneeEmail: '[REDACTED]',
        streetAddress: '[REDACTED]',
        redactedAt: new Date(),
      },
    });
  }

  logger.info({ email: '[REDACTED]', count: shipments.length }, 'GDPR deletion processed');
}