|
| 1 | +import type { IncomingMessage, Server as NodeHttpServer, ServerResponse } from 'node:http' |
| 2 | +import type { Http2SecureServer } from 'node:http2' |
| 3 | +import type { ViteDevServer } from 'vite' |
| 4 | +import { mkdtempSync } from 'node:fs' |
| 5 | +import { createServer } from 'node:http' |
| 6 | +import { createSecureServer } from 'node:http2' |
| 7 | +import { tmpdir } from 'node:os' |
| 8 | +import { join } from 'node:path' |
| 9 | +import { getPort } from 'get-port-please' |
| 10 | +import { afterEach, describe, expect, it } from 'vitest' |
| 11 | +import { viteDevframeHub } from '../src/hub' |
| 12 | + |
| 13 | +type ConnectMiddleware = (req: IncomingMessage, res: ServerResponse, next: () => void) => void |
| 14 | + |
| 15 | +/** |
| 16 | + * Vite on `server.https` hands plugins an `Http2SecureServer` (with |
| 17 | + * `allowHTTP1`), which is not a `node:http` `Server`. Requests are served |
| 18 | + * here over a plain HTTP server running the same middleware stack, so the |
| 19 | + * test needs no certificate. |
| 20 | + */ |
| 21 | +function fakeHttpsViteServer() { |
| 22 | + const stack: ConnectMiddleware[] = [] |
| 23 | + const requestServer: NodeHttpServer = createServer((req, res) => { |
| 24 | + let i = 0 |
| 25 | + const next = (): void => { |
| 26 | + const handler = stack[i++] |
| 27 | + if (!handler) { |
| 28 | + res.statusCode = 404 |
| 29 | + res.end() |
| 30 | + return |
| 31 | + } |
| 32 | + handler(req, res, next) |
| 33 | + } |
| 34 | + next() |
| 35 | + }) |
| 36 | + const httpServer: Http2SecureServer = createSecureServer({ allowHTTP1: true }) |
| 37 | + const server = { |
| 38 | + httpServer, |
| 39 | + resolvedUrls: null, |
| 40 | + middlewares: { use: (handler: ConnectMiddleware) => stack.push(handler) }, |
| 41 | + } |
| 42 | + return { server, httpServer, requestServer } |
| 43 | +} |
| 44 | + |
| 45 | +describe('viteDevframeHub', () => { |
| 46 | + let cleanup: (() => Promise<void>) | undefined |
| 47 | + |
| 48 | + afterEach(async () => { |
| 49 | + await cleanup?.() |
| 50 | + cleanup = undefined |
| 51 | + }) |
| 52 | + |
| 53 | + it('shares an https (http2) dev server for the WebSocket upgrade', async () => { |
| 54 | + const host = '127.0.0.1' |
| 55 | + const port = await getPort({ port: 19800, host }) |
| 56 | + const { server, httpServer, requestServer } = fakeHttpsViteServer() |
| 57 | + await new Promise<void>(resolve => requestServer.listen(port, host, resolve)) |
| 58 | + |
| 59 | + const plugin = viteDevframeHub({ |
| 60 | + ui: false, |
| 61 | + auth: false, |
| 62 | + quiet: true, |
| 63 | + cwd: mkdtempSync(join(tmpdir(), 'devframe-vite-hub-')), |
| 64 | + }) |
| 65 | + cleanup = async () => { |
| 66 | + httpServer.emit('close') |
| 67 | + await (plugin.closeBundle as () => Promise<void>)() |
| 68 | + requestServer.close() |
| 69 | + requestServer.closeAllConnections() |
| 70 | + } |
| 71 | + await (plugin.configureServer as (s: ViteDevServer) => Promise<void>)(server as any) |
| 72 | + |
| 73 | + const res = await fetch(`http://${host}:${port}/__devframes/__connection.json`) |
| 74 | + const meta = await res.json() as { websocket?: unknown } |
| 75 | + expect(meta.websocket).toEqual({ path: '/__devframes/__ws' }) |
| 76 | + expect(httpServer.listenerCount('upgrade')).toBe(1) |
| 77 | + }) |
| 78 | +}) |
0 commit comments