How to fix P6002: The provided data could not be serialized (Pulse) in Prisma

const prisma = new PrismaClient({
  log: [
    { level: 'query', emit: 'event' },
    { level: 'error', emit: 'stdout' },
  ],
});

prisma.$on('query', (e) => {
  console.log('Query: ' + e.query);
  console.log('Duration: ' + e.duration + 'ms');
});

model User {
  id        BigInt    @id @default(autoincrement())
  email     String    @unique
  score     BigInt
  createdAt DateTime  @default(now())
}

const subscription = await prisma.user.subscribe({
  create: { after: true },
});

for await (const event of subscription) {
  // Manually convert BigInt to String for transmission
  const data = {
    ...event.after,
    id: event.after?.id?.toString(),
    score: event.after?.score?.toString(),
  };
  console.log('User change:', data);
}

import Decimal from '@prisma/client/runtime/library';

model Product {
  id    String   @id @default(cuid())
  name  String
  price Decimal  @db.Decimal(10, 2)
}

const subscription = await prisma.product.subscribe({
  create: { after: true },
  update: { after: true }
});

for await (const event of subscription) {
  // Convert Decimal to string for serialization
  const serializedData = {
    ...event.after,
    price: event.after?.price?.toString(),
  };
  console.log('Product change:', serializedData);
}

// Instead of subscribing to entire record, subscribe to specific fields
const subscription = await prisma.user.subscribe({
  create: {
    after: true,
    // Pulse doesn't support field-level filtering yet, so filter in application
  }
});

for await (const event of subscription) {
  // Filter out problematic fields before processing
  const { problematicBigIntField, complexJSON, ...cleanData } = event.after || {};

  // Process only serializable data
  console.log('Clean data:', cleanData);

  // Handle excluded fields separately if needed
  if (problematicBigIntField) {
    console.log('BigInt field:', problematicBigIntField.toString());
  }
}

// ❌ Problematic types
model BadExample {
  id      BigInt    @id  // Not serializable
  price   Decimal   @db.Decimal(10, 2)  // Not serializable
  data    Bytes     // Not serializable
  updated DateTime  // Tricky to serialize
}

// ✅ JSON-serializable alternatives
model GoodExample {
  id         String    @id @default(cuid())  // String is always safe
  price      String    @db.VarChar(20)       // String representation
  data       String    // Base64 or hex encoded
  updated    Int       // Unix timestamp (number)
  createdAt  String    @db.DateTime          // ISO string if needed separately
}