diff options
author | 2024-03-18 14:15:46 +0000 | |
---|---|---|
committer | 2024-03-18 14:15:46 +0000 | |
commit | ef6d0acd3196f7f42b84343297d72541a10f7328 (patch) | |
tree | 272545dd8e1abe6a2de6d1c008e7e3928a5e6006 | |
parent | 29d29e8d006cc977ae11264309b8305782ee9375 (diff) | |
download | astro-ef6d0acd3196f7f42b84343297d72541a10f7328.tar.gz astro-ef6d0acd3196f7f42b84343297d72541a10f7328.tar.zst astro-ef6d0acd3196f7f42b84343297d72541a10f7328.zip |
[ci] format
-rw-r--r-- | packages/integrations/node/src/serve-app.ts | 14 | ||||
-rw-r--r-- | packages/integrations/node/test/errors.test.js | 18 |
2 files changed, 17 insertions, 15 deletions
diff --git a/packages/integrations/node/src/serve-app.ts b/packages/integrations/node/src/serve-app.ts index ac5af3add..10b30d457 100644 --- a/packages/integrations/node/src/serve-app.ts +++ b/packages/integrations/node/src/serve-app.ts @@ -14,7 +14,7 @@ export function createAppHandler(app: NodeApp): RequestHandler { */ const als = new AsyncLocalStorage<string>(); const logger = app.getAdapterLogger(); - process.on('unhandledRejection', reason => { + process.on('unhandledRejection', (reason) => { const requestUrl = als.getStore(); logger.error(`Unhandled rejection while rendering ${requestUrl}`); console.error(reason); @@ -32,11 +32,13 @@ export function createAppHandler(app: NodeApp): RequestHandler { const routeData = app.match(request); if (routeData) { - const response = await als.run(request.url, () => app.render(request, { - addCookieHeader: true, - locals, - routeData, - })); + const response = await als.run(request.url, () => + app.render(request, { + addCookieHeader: true, + locals, + routeData, + }) + ); await NodeApp.writeResponse(response, res); } else if (next) { return next(); diff --git a/packages/integrations/node/test/errors.test.js b/packages/integrations/node/test/errors.test.js index 1e435ddd7..a74751267 100644 --- a/packages/integrations/node/test/errors.test.js +++ b/packages/integrations/node/test/errors.test.js @@ -1,11 +1,11 @@ -import { spawn } from 'node:child_process'; -import { Worker } from 'node:worker_threads'; import assert from 'node:assert/strict'; +import { spawn } from 'node:child_process'; import { after, before, describe, it } from 'node:test'; +import { fileURLToPath } from 'node:url'; +import { Worker } from 'node:worker_threads'; import * as cheerio from 'cheerio'; import nodejs from '../dist/index.js'; import { loadFixture } from './test-utils.js'; -import { fileURLToPath } from 'node:url'; describe('Errors', () => { /** @type {import('./test-utils.js').Fixture} */ @@ -33,17 +33,17 @@ describe('Errors', () => { // this test needs to happen in a worker because node test runner adds a listener for unhandled rejections in the main thread const worker = new Worker('./test/fixtures/errors/dist/server/entry.mjs', { type: 'module', - env: { ASTRO_NODE_LOGGING: 'enabled' } + env: { ASTRO_NODE_LOGGING: 'enabled' }, }); - + await new Promise((resolve, reject) => { - worker.stdout.on('data', data => { - setTimeout(() => reject("Server took too long to start"), 1000); + worker.stdout.on('data', (data) => { + setTimeout(() => reject('Server took too long to start'), 1000); if (data.toString().includes('Server listening on http://localhost:4321')) resolve(); }); }); - - await fetch("http://localhost:4321/offshoot-promise-rejection"); + + await fetch('http://localhost:4321/offshoot-promise-rejection'); // if there was a crash, it becomes an error here await worker.terminate(); |