How to fix P6009: The stream was closed due to an error in Prisma

# Test WebSocket connectivity
curl -v --include --no-buffer   --header "Connection: Upgrade"   --header "Upgrade: websocket"   --header "Sec-WebSocket-Key: SGVsbG8sIHdvcmxkIQ=="   --header "Sec-WebSocket-Version: 13"   https://pulse.prisma.io/ws

# Monitor network stability
ping pulse.prisma.io
traceroute pulse.prisma.io

# Check for packet loss
mtr --report pulse.prisma.io

// In your Prisma client configuration
import { PrismaClient } from '@prisma/client'

const prisma = new PrismaClient({
  // Adjust Pulse connection settings
  datasources: {
    db: {
      url: process.env.DATABASE_URL,
    },
  },
  // Optional: Configure Pulse-specific settings
  // pulse: {
  //   timeout: 30000, // 30 seconds
  //   keepalive: 15000, // 15 seconds
  //   reconnect: {
  //     attempts: 5,
  //     factor: 1.5,
  //     minTimeout: 1000,
  //     maxTimeout: 30000
  //   }
  // }
})

// Or via environment variables
// PRISMA_PULSE_TIMEOUT=30000
// PRISMA_PULSE_KEEPALIVE=15000

import { PrismaClient } from '@prisma/client'

const prisma = new PrismaClient()

async function createResilientSubscription() {
  let retryCount = 0
  const maxRetries = 3

  async function subscribeWithRetry() {
    try {
      const subscription = prisma.user.subscribe({
        create: {},
      })

      // Handle stream closure
      subscription.on('close', (reason) => {
        console.log('Stream closed: ' + reason)
        if (retryCount < maxRetries) {
          retryCount++
          console.log('Retrying connection (attempt ' + retryCount + ')...')
          setTimeout(subscribeWithRetry, 1000 * retryCount) // Exponential backoff
        }
      })

      // Handle errors
      subscription.on('error', (error) => {
        console.error('Stream error:', error)
        if (error.code === 'P6009') {
          console.log('Stream closed error detected, will attempt reconnect')
        }
      })

      return subscription
    } catch (error) {
      console.error('Subscription failed:', error)
      throw error
    }
  }

  return subscribeWithRetry()
}

// Usage
const subscription = await createResilientSubscription()

# Check Prisma Pulse service status
npx prisma pulse status

# Monitor your application's resource usage
# Memory usage
free -h

# CPU usage
top -b -n 1 | grep -E "(PID|prisma|node)"

# Network connections
ss -tunap | grep -E "(pulse|prisma)"

# Check for Pulse service announcements
# Visit: https://status.prisma.io

// Instead of subscribing to all changes:
const heavySubscription = prisma.user.subscribe({
  create: {},
  update: {},
  delete: {},
})

// Use more targeted subscriptions:
const optimizedSubscription = prisma.user.subscribe({
  create: {
    // Only specific fields
    select: {
      id: true,
      name: true,
      email: true,
    },
    // With filters
    where: {
      active: true,
    },
  },
})

// Implement pagination for large result sets
const paginatedQuery = prisma.user.findMany({
  take: 100, // Limit results
  skip: 0,
  orderBy: { createdAt: 'desc' },
})

// Use polling instead of streaming for less critical data
async function pollForChanges() {
  setInterval(async () => {
    const recentUsers = await prisma.user.findMany({
      where: {
        createdAt: {
          gt: new Date(Date.now() - 5 * 60 * 1000), // Last 5 minutes
        },
      },
      take: 50,
    })
    // Process changes
  }, 30000) // Every 30 seconds
}

# Update Prisma packages
npm update @prisma/client @prisma/engines prisma

# Check for known fixes in release notes
# Visit: https://github.com/prisma/prisma/releases

# Regenerate Prisma client
npx prisma generate

class ResilientRealTimeService {
  private isStreaming = false
  private fallbackPolling = false

  async startRealTimeUpdates() {
    try {
      // Attempt streaming first
      await this.startStreaming()
      this.isStreaming = true
      this.fallbackPolling = false
    } catch (error) {
      if (error.code === 'P6009' || error.code === 'P6001') {
        console.log('Streaming failed, falling back to polling')
        this.isStreaming = false
        this.fallbackPolling = true
        this.startPolling()
      }
    }
  }

  private async startStreaming() {
    // Streaming implementation
  }

  private startPolling() {
    // Polling implementation as fallback
  }
}