chore: 更新 eventRouter 和 messageReply 函數以使用更嚴格的類型定義，並改善事件處理邏輯

Author: c-c-epr

src/eventRouter.ts

@@ -1,13 +1,16 @@
 import { sendMessage, markAsRead, loadStart } from "./utils/eventRoutes";
 import { env } from "cloudflare:workers";
 import { version } from "../package.json";
+import type { webhook } from "@line/bot-sdk";
+import type { Message } from "./types";
 
-export async function eventRouter(event: any, channelAccessToken: string, ctx: ExecutionContext): Promise<any[]> {
+export async function eventRouter(event: webhook.Event, channelAccessToken: string, ctx: ExecutionContext): Promise<Message[]> {
   // Log
   let eventType: string = event.type;
   try {
-    if (["message"].includes(event.type)) {
-      eventType = `${event.type}(${event.message?.type})`;
+    if (event.type === "message") {
+      const msgEvent = event as webhook.MessageEvent;
+      eventType = `${event.type}(${msgEvent.message?.type})`;
     }
   } catch (e) {
     console.error("Failed to determine message event type", { error: e });
@@ -17,16 +20,25 @@ export async function eventRouter(event: any, channelAccessToken: string, ctx: E
 
   switch (event.type) {
     case "message": {
-      ctx.waitUntil(markAsRead(channelAccessToken, event.message.markAsReadToken));
+      const msgEvent = event as webhook.MessageEvent;
+      if (msgEvent.message.markAsReadToken) {
+        ctx.waitUntil(markAsRead(channelAccessToken, msgEvent.message.markAsReadToken));
+      }
+
+      const userId = msgEvent.source && typeof (msgEvent.source as any).userId === "string" ? (msgEvent.source as any).userId : undefined;
 
-      await Promise.race([
-        loadStart(channelAccessToken, event.source.userId, 5),
-        new Promise((resolve) => setTimeout(resolve, 50)), // 最多等 50ms
-      ]);
+      if (userId) {
+        await Promise.race([
+          loadStart(channelAccessToken, userId, 5),
+          new Promise((resolve) => setTimeout(resolve, 50)), // 最多等 50ms
+        ]);
+      } else {
+        await new Promise((resolve) => setTimeout(resolve, 50));
+      }
 
-      switch (event.message.type) {
+      switch (msgEvent.message.type) {
         case "text":
-          switch (event.message.text) {
+          switch (msgEvent.message.text) {
             case "/version":
               const { id: versionId, tag: versionTag, timestamp: versionTimestamp } = env.CF_VERSION_METADATA;
 

src/router.ts

@@ -42,10 +42,10 @@ export async function router(request: Request, env: Env, ctx: ExecutionContext)
   }
   // 解析 JSON body
   const events = body.events || [];
-  for (const event of events as any[]) {
+  for (const event of events) {
     const responses = (await eventRouter(event, channelAccessToken, ctx)) ?? [];
-    if (responses.length > 0) {
-      await sendMessage(channelAccessToken, event.replyToken, responses as any[]);
+    if (responses.length > 0 && "replyToken" in event && typeof event.replyToken === "string") {
+      await sendMessage(channelAccessToken, event.replyToken, responses);
     }
   }
   // 回應 LINE 伺服器

src/types.ts

@@ -0,0 +1,3 @@
+export type TextMessage = { type: "text"; text: string };
+export type ImageMessage = { type: "image"; originalContentUrl: string; previewImageUrl: string };
+export type Message = TextMessage | ImageMessage | { type: string; [key: string]: unknown };

src/utils/eventRoutes/messageReply.ts

@@ -1,4 +1,6 @@
-export async function sendMessage(ChannelAccessToken: string, replyToken: string, messages: any[]) {
+import type { Message } from "../../types";
+
+export async function sendMessage(ChannelAccessToken: string, replyToken: string, messages: Message[]): Promise<unknown> {
   const res = await fetch("https://api.line.me/v2/bot/message/reply", {
     headers: {
       "Content-Type": "application/json",