Function handleMessage

packages/client/tests/functional/_utils/qpe-worker.ts:50–78

(port: MessagePort, message: QpeWorkerMessage)

let server: { qpe: Server; net: ServerType } | undefined

async function handleMessage(port: MessagePort, message: QpeWorkerMessage): Promise<void> {
  try {
    let response: QpeWorkerResponse

    switch (message.type) {
      case 'start':
        response = await handleStart(message)
        break

      case 'shutdown':
        response = await handleShutdown()
        break

      default:
        response = {
          type: 'error',
          message: `Unknown message type: ${(message satisfies never as { type: string }).type}`,
        }
        break
    }

    port.postMessage(response)
  } catch (error) {
    port.postMessage({
      type: 'error',
      message: error instanceof Error ? error.message : String(error),
    } satisfies QpeWorkerErrorResponse)
  }
}

async function handleStart(message: QpeWorkerStartMessage): Promise<QpeWorkerReadyResponse> {
  // It should only be imported after initializing OpenTelemetry