aboutsummaryrefslogtreecommitdiff
path: root/packages/integrations/node/src/standalone.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/integrations/node/src/standalone.ts')
-rw-r--r--packages/integrations/node/src/standalone.ts93
1 files changed, 93 insertions, 0 deletions
diff --git a/packages/integrations/node/src/standalone.ts b/packages/integrations/node/src/standalone.ts
new file mode 100644
index 000000000..8ae10a9ba
--- /dev/null
+++ b/packages/integrations/node/src/standalone.ts
@@ -0,0 +1,93 @@
+import fs from 'node:fs';
+import http from 'node:http';
+import https from 'node:https';
+import type { PreviewServer } from 'astro';
+import type { NodeApp } from 'astro/app/node';
+import enableDestroy from 'server-destroy';
+import { logListeningOn } from './log-listening-on.js';
+import { createAppHandler } from './serve-app.js';
+import { createStaticHandler } from './serve-static.js';
+import type { Options } from './types.js';
+
+// Used to get Host Value at Runtime
+export const hostOptions = (host: Options['host']): string => {
+ if (typeof host === 'boolean') {
+ return host ? '0.0.0.0' : 'localhost';
+ }
+ return host;
+};
+
+export default function standalone(app: NodeApp, options: Options) {
+ const port = process.env.PORT ? Number(process.env.PORT) : options.port ?? 8080;
+ const host = process.env.HOST ?? hostOptions(options.host);
+ const handler = createStandaloneHandler(app, options);
+ const server = createServer(handler, host, port);
+ server.server.listen(port, host);
+ if (process.env.ASTRO_NODE_LOGGING !== 'disabled') {
+ logListeningOn(app.getAdapterLogger(), server.server, options);
+ }
+ return {
+ server,
+ done: server.closed(),
+ };
+}
+
+// also used by server entrypoint
+export function createStandaloneHandler(app: NodeApp, options: Options) {
+ const appHandler = createAppHandler(app);
+ const staticHandler = createStaticHandler(app, options);
+ return (req: http.IncomingMessage, res: http.ServerResponse) => {
+ try {
+ // validate request path
+ // biome-ignore lint/style/noNonNullAssertion: <explanation>
+ decodeURI(req.url!);
+ } catch {
+ res.writeHead(400);
+ res.end('Bad request.');
+ return;
+ }
+ staticHandler(req, res, () => appHandler(req, res));
+ };
+}
+
+// also used by preview entrypoint
+export function createServer(listener: http.RequestListener, host: string, port: number) {
+ let httpServer: http.Server | https.Server;
+
+ if (process.env.SERVER_CERT_PATH && process.env.SERVER_KEY_PATH) {
+ httpServer = https.createServer(
+ {
+ key: fs.readFileSync(process.env.SERVER_KEY_PATH),
+ cert: fs.readFileSync(process.env.SERVER_CERT_PATH),
+ },
+ listener
+ );
+ } else {
+ httpServer = http.createServer(listener);
+ }
+ enableDestroy(httpServer);
+
+ // Resolves once the server is closed
+ const closed = new Promise<void>((resolve, reject) => {
+ httpServer.addListener('close', resolve);
+ httpServer.addListener('error', reject);
+ });
+
+ const previewable = {
+ host,
+ port,
+ closed() {
+ return closed;
+ },
+ async stop() {
+ await new Promise((resolve, reject) => {
+ httpServer.destroy((err) => (err ? reject(err) : resolve(undefined)));
+ });
+ },
+ } satisfies PreviewServer;
+
+ return {
+ server: httpServer,
+ ...previewable,
+ };
+}