[Feat] Add line bot webhook. (#89)

Add a web hook for the line bot, and pass testing data for now.


### Related Issue
- #87

lib/config.ts

@@ -1,7 +1,6 @@
 import { process591QueryUrl } from "./591House/utils";
 
 const apiSecret = process.env.ZUZUGO_API_SECRET;
-
 const tokenLine = process.env.LINE_API_TOKEN;
 
 // const isSubwayStationFilterEnabled = process.env.ENABLE_SUBWAY_STATION_FILTER === "true";
@@ -34,4 +33,9 @@ export const config = {
   tokenLine,
   production: process.env.NODE_ENV === "production",
   cronEnabled: process.env.DISABLE_CRON !== "true",
+
+  line: {
+    LINE_ACCESS_TOKEN: process.env.LINE_ACCESS_TOKEN,
+    LINE_CHANNEL_SECRET: process.env.LINE_CHANNEL_SECRET
+  }
 };

lib/notification/lineBot.ts

@@ -0,0 +1,19 @@
+import { Client, TextMessage } from '@line/bot-sdk';
+
+import { config } from 'lib/config'
+// set Channel Access Token and Channel Secret for Line Bot 
+const client = new Client({
+  channelAccessToken: config.line.LINE_ACCESS_TOKEN || '',
+  channelSecret: config.line.LINE_CHANNEL_SECRET,
+});
+
+// @todo: pass rent data from api.
+const message: TextMessage = {
+  type: 'text',
+  text: 'Zuzugo got a new house!',
+};
+
+// @todo: get groupId from database.
+export default async function sendLineBotMessage(groupId: string) {
+  await client.pushMessage(groupId, message)
+}

package.json

@@ -15,6 +15,7 @@
   },
   "dependencies": {
     "@next-auth/prisma-adapter": "^1.0.5",
+    "@line/bot-sdk": "^7.5.2",
     "@next/font": "13.1.6",
     "@prisma/client": "^4.10.1",
     "@seratch_/bolt-http-runner": "^1.0.3",
@@ -66,4 +67,4 @@
   "engines": {
     "node": ">=18.12"
   }
-}
+}

pages/api/line/events.ts

@@ -0,0 +1,35 @@
+import { WebhookEvent, User, Group, Room } from "@line/bot-sdk";
+import type { NextApiRequest, NextApiResponse } from "next";
+
+import sendLineBotMessage from 'lib/notification/lineBot'
+
+
+export default async function handler(req: NextApiRequest, res: NextApiResponse) {
+
+  if (req.method !== "POST") {
+    res.status(405).json({ error: "Sorry! This endpoint does not accept your requests." });
+    return;
+  }
+
+  const events: WebhookEvent[] = req.body.events;
+  const [firstEvent] = events;
+
+  if (firstEvent.type === 'join') {
+    const {
+      userId = '',
+      groupId = '',
+      roomId = '',
+      // @todo: save chatType to database.
+      // type: chatType,
+    } = firstEvent.source as User & Group & Room;
+
+    const chatId = userId || groupId || roomId;
+    try {
+      await sendLineBotMessage(chatId)
+    } catch (e) {
+      console.error(e)
+    }
+  }
+
+  res.send(200)
+}