feat: add @mx-space/webhook dependency and update revalidate time

Signed-off-by: Innei <[email protected]>

Author: Innei

package.json

@@ -88,6 +88,7 @@
     "@iconify/tailwind": "0.1.4",
     "@innei/eslint-config-react-ts": "0.12.0",
     "@innei/prettier": "0.12.0",
+    "@mx-space/webhook": "0.2.2",
     "@next/bundle-analyzer": "14.0.4",
     "@tailwindcss/typography": "0.5.10",
     "@types/js-cookie": "3.0.6",

pnpm-lock.yaml

@@ -0,0 +1,54 @@
+import { revalidateTag } from 'next/cache'
+import type { RequestWithJSONBody } from '@mx-space/webhook'
+import type { NextRequest } from 'next/server'
+
+import {
+  BusinessEvents,
+  InvalidSignatureError,
+  readDataFromRequest,
+} from '@mx-space/webhook'
+
+import { NextServerResponse } from '~/lib/edge-function.server'
+
+// export const runtime = 'edge'
+export const POST = async (nextreq: NextRequest) => {
+  const secret = process.env.WEBHOOK_SECRET
+  const res = new NextServerResponse()
+  if (!secret) return res.status(500).send('WEBHOOK_SECRET is not set')
+  const req: RequestWithJSONBody = nextreq.clone() as any
+  const headers = {} as Record<string, string>
+  for (const [key, value] of req.headers.entries()) {
+    headers[key] = value
+  }
+
+  try {
+    const { type } = await readDataFromRequest({
+      req: {
+        ...req,
+        headers: headers as any,
+        body: await req.json(),
+      } as any,
+      secret,
+    })
+
+    switch (type) {
+      case 'health-check': {
+        return res.status(200).send('OK')
+      }
+      case BusinessEvents.NOTE_CREATE:
+      case BusinessEvents.NOTE_UPDATE: {
+        revalidateTag('note')
+        return res.status(200).send('OK')
+      }
+    }
+  } catch (err) {
+    if (err instanceof InvalidSignatureError) {
+      return res.status(400).send(err.message)
+    } else {
+      console.error(err)
+      return res
+        .status(500)
+        .send('An error occurred while processing the request')
+    }
+  }
+}

src/app/api/webhook/route.ts

@@ -5,12 +5,11 @@ import { apiClient } from '~/lib/request'
 
 import Redirect from './redirect'
 
-export const revalidate = 60
-
 export default async function Page() {
   const data = await fetch(apiClient.note.proxy.latest.toString(true), {
     next: {
-      revalidate: 30,
+      revalidate: 60 * 60,
+      tags: ['note'],
     },
   })
     .then((res) => res.json() as Promise<NoteWrappedPayload>)

src/app/notes/page.tsx

@@ -182,7 +182,6 @@ const SubmitButton = () => {
       const commentDto: CommentDto = { text, author, mail, avatar, source, url }
 
       if (isLogged) {
-        delete commentDto.source
         delete commentDto.avatar
       }
 
@@ -200,6 +199,7 @@ const SubmitButton = () => {
             .post<CommentModel>({
               data: {
                 text,
+                source,
               },
             })
             .then(wrappedCompletedCallback)
@@ -218,7 +218,7 @@ const SubmitButton = () => {
         return apiClient.comment.proxy.master
           .comment(refId)
           .post<CommentModel>({
-            data: { text },
+            data: { text, source },
           })
           .then(async (res) => {
             if (syncToRecently)
@@ -253,8 +253,8 @@ const SubmitButton = () => {
       const toastCopy = isLogged
         ? '发表成功啦~'
         : isReply
-        ? '感谢你的回复！'
-        : '感谢你的评论！'
+          ? '感谢你的回复！'
+          : '感谢你的评论！'
 
       const commentListQueryKey = buildQueryKey(originalRefId)