Function handleStart

packages/client/tests/functional/_utils/qpe-worker.ts:80–118

(message: QpeWorkerStartMessage)

}

async function handleStart(message: QpeWorkerStartMessage): Promise<QpeWorkerReadyResponse> {
  // It should only be imported after initializing OpenTelemetry
  const { Server, parseSize, parseDuration } = await import('@prisma/query-plan-executor')

  const qpe = await Server.create({
    databaseUrl: message.databaseUrl,
    maxResponseSize: parseSize('128 MiB'),
    queryTimeout: parseDuration('PT30S'),
    maxTransactionTimeout: parseDuration('PT1M'),
    maxTransactionWaitTime: parseDuration('PT1M'),
    perRequestLogContext: {
      logFormat: 'text',
      logLevel: 'warn',
    },
  })

  const hostname = '127.0.0.1'

  const net = serve({
    fetch: qpe.fetch,
    hostname,
    port: 0,
  })

  await events.once(net, 'listening')
  const address = net.address()

  if (address === null) {
    throw new Error('query plan executor server did not start')
  }

  if (typeof address === 'string') {
    throw new Error('query plan executor must be listening on TCP and not Unix socket')
  }

  server = { qpe, net }

  return { type: 'ready', hostname, port: address.port }
}

async function handleShutdown(): Promise<QpeWorkerShutdownResponse> {
  if (server) {