preactjs · JoviDeCroock · May 6, 2024 · Oct 15, 2022 · Oct 16, 2022 · Oct 16, 2022
diff --git a/.changeset/grumpy-kings-flow.md b/.changeset/grumpy-kings-flow.md
@@ -0,0 +1,5 @@
+---
+'preact-render-to-string': minor
+---
+
+Introduce a streaming renderer which can be imported from `preact-render-to-string/stream` and `preact-render-to-string/stream-node`
diff --git a/.changeset/twelve-candles-walk.md b/.changeset/twelve-candles-walk.md
@@ -0,0 +1,5 @@
+---
+"preact-render-to-string": patch
+---
+
+streaming rendering with Suspense boundaries as flush trigger
diff --git a/.gitignore b/.gitignore
@@ -3,4 +3,5 @@
 /npm-debug.log
 .DS_Store
 /src/preact-render-to-string-tests.d.ts
-/benchmarks/.v8.mjs
+/benchmarks/.v8.modern.js
+/demo/node_modules
diff --git a/demo/index.html b/demo/index.html
@@ -0,0 +1,12 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>Vite App</title>
+  </head>
+  <body>
+    <div id="app"><!--app-html--></div>
+    <script type="module" src="/src/entry-client.jsx"></script>
+  </body>
+</html>
diff --git a/demo/package-lock.json b/demo/package-lock.json
diff --git a/demo/package.json b/demo/package.json
@@ -0,0 +1,25 @@
+{
+    "name": "demo",
+    "version": "1.0.0",
+    "description": "",
+    "main": "server.js",
+    "type": "module",
+    "scripts": {
+        "dev": "vite --force",
+        "build": "npm run build:client && npm run build:server",
+        "build:client": "vite build --outDir dist/client",
+        "build:server": "vite build --ssr src/entry-server.jsx --outDir dist/server"
+    },
+    "author": "",
+    "license": "ISC",
+    "devDependencies": {
+        "vite": "^4.1.4"
+    },
+    "dependencies": {
+        "@preact/preset-vite": "^2.8.0",
+        "express": "^4.18.2",
+        "graphql": "^16.6.0",
+        "preact": "^10.21.0",
+        "urql": "latest"
+    }
+}
diff --git a/demo/src/App.jsx b/demo/src/App.jsx
@@ -0,0 +1,41 @@
+import { h } from 'preact';
+import { Suspense, lazy } from 'preact/compat';
+import { Client, Provider, cacheExchange, fetchExchange } from 'urql';
+
+const client = new Client({
+	url: 'https://trygql.formidable.dev/graphql/basic-pokedex',
+	exchanges: [cacheExchange, fetchExchange],
+	suspense: true
+});
+
+export function App({ head }) {
+	const Pokemons = lazy(
+		() =>
+			new Promise((res) => {
+				setTimeout(
+					() => {
+						res(import('./Pokemons.jsx'));
+					},
+					typeof document === 'undefined' ? 500 : 3000
+				);
+			})
+	);
+	return (
+		<html>
+			<head dangerouslySetInnerHTML={{ __html: head }} />
+			<body>
+				<Provider value={client}>
+					<main>
+						<h1>Our Counter application</h1>
+						<Suspense fallback={<p>Loading...</p>}>
+							<Pokemons />
+						</Suspense>
+					</main>
+					{import.meta.env.DEV && (
+						<script type="module" src="/src/entry-client.jsx" />
+					)}
+				</Provider>
+			</body>
+		</html>
+	);
+}
diff --git a/demo/src/Pokemons.jsx b/demo/src/Pokemons.jsx
@@ -0,0 +1,38 @@
+import { gql, useQuery } from 'urql';
+import { h } from 'preact';
+
+const POKEMONS_QUERY = gql`
+	query Pokemons($limit: Int!) {
+		pokemons(limit: $limit) {
+			id
+			name
+		}
+	}
+`;
+
+const Counter = () => {
+	const [result] = useQuery({
+		query: POKEMONS_QUERY,
+		variables: { limit: 10 }
+	});
+
+	const { data, fetching, error } = result;
+	console.log('hydrated!');
+	return (
+		<div>
+			{fetching && <p>Loading...</p>}
+
+			{error && <p>Oh no... {error.message}</p>}
+
+			{data && (
+				<ul>
+					{data.pokemons.map((pokemon) => (
+						<li key={pokemon.id}>{pokemon.name}</li>
+					))}
+				</ul>
+			)}
+		</div>
+	);
+};
+
+export default Counter;
diff --git a/demo/src/entry-client.jsx b/demo/src/entry-client.jsx
@@ -0,0 +1,19 @@
+import { hydrate } from 'preact';
+import { App } from './App';
+
+const config = { attributes: true, childList: true, subtree: true };
+const mut = new MutationObserver((mutationList, observer) => {
+	for (const mutation of mutationList) {
+		if (mutation.type === 'childList') {
+			console.log('A child node has been added or removed.', mutation);
+		} else if (mutation.type === 'attributes') {
+			console.log(
+				`The ${mutation.attributeName} attribute was modified.`,
+				mutation
+			);
+		}
+	}
+});
+mut.observe(document, config);
+
+hydrate(<App />, document);
diff --git a/demo/src/entry-server.jsx b/demo/src/entry-server.jsx
@@ -0,0 +1,25 @@
+import { renderToPipeableStream } from '../../src/stream-node';
+import { App } from './App';
+
+export function render({ res, head }) {
+	res.socket.on('error', (error) => {
+		console.error('Fatal', error);
+	});
+	const { pipe, abort } = renderToPipeableStream(<App head={head} />, {
+		onShellReady() {
+			res.statusCode = 200;
+			res.setHeader('Content-type', 'text/html');
+			pipe(res);
+		},
+		onErrorShell(error) {
+			res.statusCode = 500;
+			res.send(
+				`<!doctype html><p>An error ocurred:</p><pre>${error.message}</pre>`
+			);
+		}
+	});
+
+	// Abandon and switch to client rendering if enough time passes.
+	// Try lowering this to see the client recover.
+	setTimeout(abort, 20000);
+}
diff --git a/demo/vite.config.js b/demo/vite.config.js
@@ -0,0 +1,60 @@
+import { defineConfig } from 'vite';
+import preact from '@preact/preset-vite';
+import path from 'path';
+import { promises as fs } from 'fs';
+
+function ssrPlugin() {
+	return {
+		name: 'ssrPlugin',
+
+		configureServer(server) {
+			server.middlewares.use(async (req, res, next) => {
+				if (req.url !== '/') {
+					return next();
+				}
+
+				const { render } = await server.ssrLoadModule(
+					path.resolve(__dirname, './src/entry-server')
+				);
+
+				// setTimeout(abort, 10000);
+
+				const indexHtml = await fs.readFile(
+					path.resolve(__dirname, './index.html'),
+					'utf-8'
+				);
+
+				const url = new URL('http://localhost:5173/' + req.url);
+				const template = await server.transformIndexHtml(
+					url.toString(),
+					indexHtml
+				);
+
+				const head = template.match(/<head>(.+?)<\/head>/s)[1];
+
+				return render({ res, head });
+			});
+		}
+	};
+}
+
+export default defineConfig({
+	// @ts-ignore
+	ssr: {
+		noExternal: /./
+	},
+	build: {
+		ssrManifest: true,
+		commonjsOptions: {
+			transformMixedEsModules: true
+		}
+	},
+	resolve: {
+		alias: {
+			preact: path.resolve(__dirname, './node_modules/preact'),
+			'preact/compat': path.resolve(__dirname, './node_modules/preact/compat'),
+			'preact/hooks': path.resolve(__dirname, './node_modules/preact/hooks')
+		}
+	},
+	plugins: [ssrPlugin(), preact()]
+});
diff --git a/jsx.d.ts b/jsx.d.ts
@@ -10,7 +10,7 @@ interface Options {
 	skipFalseAttributes?: boolean;
 }
 
-export default function renderToStringPretty(
+export default function render(
 	vnode: VNode,
 	context?: any,
 	options?: Options