8000 feat: logs regeneration event for debugging · doctify/serverless-next.js@a1b963d · GitHub
[go: up one dir, main page]
Skip to content

Commit a1b963d

Browse files
author
RomanBobrovskiy
committed
feat: logs regeneration event for debugging
1 parent c687593 commit a1b963d

File tree

2 files changed

+46
-44
lines changed

2 files changed

+46
-44
lines changed

‎packages/libs/lambda-at-edge/src/regeneration-handler.ts

Lines changed: 44 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -10,56 +10,56 @@ import { renderPageToHtml } from "@sls-next/core";
1010
import { s3DeletePage } from "./s3/s3DeletePage";
1111

1212
export const handler = async (event: AWSLambda.SQSEvent): Promise<void> => {
13-
await Promise.all(
14-
event.Records.map(async (record) => {
15-
const regenerationEvent: RegenerationEvent = JSON.parse(record.body);
13+
console.log(JSON.stringify(event), "REGENERATION EVENT");
1614

17-
const manifest: OriginRequestDefaultHandlerManifest = Manifest;
18-
const { req, res } = lambdaAtEdgeCompat(
19-
{ request: regenerationEvent.cloudFrontEventRequest },
20-
{ enableHTTPCompression: manifest.enableHTTPCompression }
21-
);
15+
for (const record of event.Records) {
16+
const regenerationEvent: RegenerationEvent = JSON.parse(record.body);
2217

23-
// eslint-disable-next-line @typescript-eslint/no-var-requires
24-
const page = require(`./${regenerationEvent.pagePath}`);
18+
const manifest: OriginRequestDefaultHandlerManifest = Manifest;
19+
const { req, res } = lambdaAtEdgeCompat(
20+
{ request: regenerationEvent.cloudFrontEventRequest },
21+
{ enableHTTPCompression: manifest.enableHTTPCompression }
22+
);
2523

26-
const { renderOpts, html } = await renderPageToHtml(
27-
page,
28-
req,
29-
res,
30-
"passthrough"
31-
);
24+
// eslint-disable-next-line @typescript-eslint/no-var-requires
25+
const page = require(`./${regenerationEvent.pagePath}`);
3226

33-
const normalizedUri = decodeURI(regenerationEvent.pageS3Path)
34-
.replace(`static-pages/${manifest.buildId}`, "")
35-
.replace(/.js$/, "");
27+
const { renderOpts, html } = await renderPageToHtml(
28+
page,
29+
req,
30+
res,
31+
"passthrough"
32+
);
3633

37-
if (renderOpts.isNotFound) {
38-
try {
39-
await s3DeletePage({
40-
uri: normalizedUri,
41-
basePath: regenerationEvent.basePath,
42-
bucketName: regenerationEvent.bucketName,
43-
buildId: manifest.buildId,
44-
region: regenerationEvent.region
45-
});
46-
} catch (e) {
47-
console.error("Error deleting page from S3", e);
48-
}
34+
const normalizedUri = decodeURI(regenerationEvent.pageS3Path)
35+
.replace(`static-pages/${manifest.buildId}`, "")
36+
.replace(/.js$/, "");
4937

50-
return;
38+
if (renderOpts.isNotFound) {
39+
try {
40+
await s3DeletePage({
41+
uri: normalizedUri,
42+
basePath: regenerationEvent.basePath,
43+
bucketName: regenerationEvent.bucketName,
44+
buildId: manifest.buildId,
45+
region: regenerationEvent.region
46+
});
47+
} catch (e) {
48+
console.error("Error deleting page from S3", e);
5149
}
5250

53-
await s3StorePage({
54-
html,
55-
uri: normalizedUri,
56-
basePath: regenerationEvent.basePath,
57-
bucketName: regenerationEvent.bucketName,
58-
buildId: manifest.buildId,
59-
pageData: renderOpts.pageData,
60-
region: regenerationEvent.region,
61-
revalidate: renderOpts.revalidate as number
62-
});
63-
})
64-
);
51+
return;
52+
}
53+
54+
await s3StorePage({
55+
html,
56+
uri: normalizedUri,
57+
basePath: regenerationEvent.basePath,
58+
bucketName: regenerationEvent.bucketName,
59+
buildId: manifest.buildId,
60+
pageData: renderOpts.pageData,
61+
region: regenerationEvent.region,
62+
revalidate: renderOpts.revalidate as number
63+
});
64+
}
6565
};

‎packages/libs/lambda/src/handlers/default-handler.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,8 @@ export const handleRequest = async (
7575
* @param event
7676
*/
7777
export const handleRegeneration = async (event: SQSEvent): Promise<void> => {
78+
console.log(JSON.stringify(event), "REGENERATION EVENT");
79+
7880
await Promise.all(
7981
event.Records.map(async (record) => {
8082
const regenerationEvent: RegenerationEvent = JSON.parse(record.body);

0 commit comments

Comments
 (0)
0