fix(@astrojs/node): handler should work with `express` (#8176)

2 files changed, 50 insertions, 1 deletions

diff --git a/packages/integrations/node/test/fixtures/node-middleware/src/pages/ssr.ts b/packages/integrations/node/test/fixtures/node-middleware/src/pages/ssr.ts
new file mode 100644
index 000000000..93543190f
--- /dev/null
+++ b/packages/integrations/node/test/fixtures/node-middleware/src/pages/ssr.ts
@@ -0,0 +1,9 @@
+export async function get() {
+	let number = Math.random();
+	return {
+		body: JSON.stringify({
+			number,
+			message: `Here's a random number: ${number}`,
+		}),
+	};
+}
diff --git a/packages/integrations/node/test/node-middleware.test.js b/packages/integrations/node/test/node-middleware.test.js
index d7ba79e4c..009f403c2 100644
--- a/packages/integrations/node/test/node-middleware.test.js
+++ b/packages/integrations/node/test/node-middleware.test.js
@@ -2,6 +2,7 @@ import nodejs from '../dist/index.js';
 import { loadFixture } from './test-utils.js';
 import { expect } from 'chai';
 import * as cheerio from 'cheerio';
+import express from 'express';
 
 /**
  * @typedef {import('../../../astro/test/test-utils').Fixture} Fixture
@@ -14,7 +15,7 @@ async function load() {
 	return mod;
 }
 
-describe('behavior from middleware', () => {
+describe('behavior from middleware, standalone', () => {
 	/** @type {import('./test-utils').Fixture} */
 	let fixture;
 	let server;
@@ -53,3 +54,42 @@ describe('behavior from middleware', () => {
 		});
 	});
 });
+
+describe('behavior from middleware, middleware', () => {
+	/** @type {import('./test-utils').Fixture} */
+	let fixture;
+	let server;
+
+	before(async () => {
+		process.env.ASTRO_NODE_AUTOSTART = 'disabled';
+		process.env.PRERENDER = false;
+		fixture = await loadFixture({
+			root: './fixtures/node-middleware/',
+			output: 'server',
+			adapter: nodejs({ mode: 'middleware' }),
+		});
+		await fixture.build();
+		const { handler } = await load();
+		const app = express();
+		app.use(handler);
+		server = app.listen(8888);
+	});
+
+	after(async () => {
+		server.close();
+		await fixture.clean();
+		delete process.env.PRERENDER;
+	});
+
+	it('when mode is standalone', async () => {
+		const res = await fetch(`http://localhost:8888/ssr`);
+
+		expect(res.status).to.equal(200);
+
+		const html = await res.text();
+		const $ = cheerio.load(html);
+
+		const body = $('body');
+		expect(body.text()).to.contain("Here's a random number");
+	});
+});