Function createViteNodeSocketServer

packages/vite/src/plugins/vite-node.ts:342–524

(nuxt: Nuxt, ssrServer: ViteDevServer, clientServer: ViteDevServer, invalidates: Set<string>, collectInvalidatedSsrModules: () => void, config: ViteNodeServerOptions)

}

function createViteNodeSocketServer (nuxt: Nuxt, ssrServer: ViteDevServer, clientServer: ViteDevServer, invalidates: Set<string>, collectInvalidatedSsrModules: () => void, config: ViteNodeServerOptions) {
  const server = net.createServer((socket) => {
    const INITIAL_BUFFER_SIZE = 64 * 1024 // 64kB
    const MAX_BUFFER_SIZE = 1024 * 1024 * 1024 // 1GB

    let buffer = Buffer.alloc(INITIAL_BUFFER_SIZE)
    let writeOffset = 0
    let readOffset = 0

    // Optimize socket settings for performance
    socket.setNoDelay(true)
    socket.setKeepAlive(true, 0)

    async function processMessage (request: ViteNodeRequest) {
      try {
        switch (request.type) {
          case 'manifest': {
            const manifestData = getManifest(nuxt, ssrServer, resolveClientEntry(clientServer.config))
            sendResponse<typeof request.type>(socket, request.id, manifestData)
            return
          }
          case 'invalidates': {
            collectInvalidatedSsrModules()
            const responsePayload = Array.from(invalidates)
            invalidates.clear()
            sendResponse<typeof request.type>(socket, request.id, responsePayload)
            return
          }
          case 'resolve': {
            const { id: resolveId, importer } = request.payload
            if (!resolveId) {
              throw { status: 400, message: 'Missing id for resolve' } satisfies ErrorPartial
            }
            const ssrNode = nuxt.options.experimental.viteEnvironmentApi
              ? ssrServer.environments.ssr.pluginContainer
              : getNode(ssrServer)
            const resolvedResult = await ssrNode.resolveId(resolveId, importer).catch(() => null)
            sendResponse<typeof request.type>(socket, request.id, resolvedResult)
            return
          }
          case 'module': {
            if (request.payload.moduleId === '/') {
              throw { status: 400, message: 'Invalid moduleId' } satisfies ErrorPartial
            }
            const ssrNode = nuxt.options.experimental.viteEnvironmentApi
              ? ssrServer.environments.ssr
              : getNode(ssrServer)
            const response = await ssrNode.fetchModule(request.payload.moduleId)
              .catch(async (err) => {
                const errorData: Record<string, any> = {
                  code: 'VITE_ERROR',
                  id: request.payload.moduleId,
                  stack: err.stack || '',
                  message: err.message || '',
                }
                if (err.frame) { errorData.frame = err.frame }

                if (!errorData.frame && err.code === 'PARSE_ERROR') {