x

apps/backend/package.json

@@ -12,11 +12,12 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "@homaroma/types": "*",
     "@elysiajs/cors": "^1.2.2",
     "@elysiajs/jwt": "^1.4.1",
     "@elysiajs/static": "^1.4.7",
     "@elysiajs/swagger": "^1.2.1",
+    "@homaroma/types": "*",
+    "@line/bot-sdk": "^11.0.1",
     "@prisma/adapter-pg": "^7.6.0",
     "@prisma/client": "^7.6.0",
     "bcryptjs": "^3.0.3",

apps/backend/src/index.ts

@@ -23,6 +23,7 @@ import { promotionsRoute } from "./routes/promotions";
 import { pagesRoute } from "./routes/pages";
 import { paymentsRoute } from "./routes/payments";
 import { profileRoute } from "./routes/profile";
+import { lineRoutes } from "./routes/line";
 const PORT = process.env.PORT ? parseInt(process.env.PORT) : 3051;
 const CORS_ORIGIN = process.env.CORS_ORIGIN || "http://localhost:5173";
 const JWT_SECRET = process.env.JWT_SECRET || "homaroma_secret_2026_scent";
@@ -88,7 +89,7 @@ const app = new Elysia()
     return file;
   })
   .group("/api", (app) =>
-    app.use(authRoute).use(categoriesRoute).use(productsRoute).use(uploadRoute).use(heroRoute).use(ordersRoute).use(settingsRoute).use(articlesRoute).use(tiktokRoute).use(rawMaterialsRoute).use(shopeeRoute).use(tiktokOrderRoute).use(lazadaOrderRoute).use(customersRoute).use(couponsRoute).use(reviewsRoute).use(promotionsRoute).use(pagesRoute).use(paymentsRoute).use(profileRoute)
+    app.use(authRoute).use(categoriesRoute).use(productsRoute).use(uploadRoute).use(heroRoute).use(ordersRoute).use(settingsRoute).use(articlesRoute).use(tiktokRoute).use(rawMaterialsRoute).use(shopeeRoute).use(tiktokOrderRoute).use(lazadaOrderRoute).use(customersRoute).use(couponsRoute).use(reviewsRoute).use(promotionsRoute).use(pagesRoute).use(paymentsRoute).use(profileRoute).use(lineRoutes)
   )
   .listen({ port: PORT, hostname: "0.0.0.0" });
 

apps/backend/src/lib/lineClient.ts

@@ -0,0 +1,13 @@
+import * as line from '@line/bot-sdk';
+
+const channelAccessToken = process.env.LINE_CHANNEL_ACCESS_TOKEN || '';
+const channelSecret = process.env.LINE_CHANNEL_SECRET || '';
+
+export const lineConfig = {
+  channelAccessToken,
+  channelSecret,
+};
+
+export const lineClient = new line.messagingApi.MessagingApiClient({
+  channelAccessToken,
+});

apps/backend/src/routes/line.ts

@@ -0,0 +1,49 @@
+import { Elysia } from 'elysia';
+import * as line from '@line/bot-sdk';
+import { lineConfig, lineClient } from '../lib/lineClient';
+import crypto from 'crypto';
+
+export const lineRoutes = new Elysia({ prefix: '/line' })
+  .post('/webhook', async ({ request, body, set }) => {
+    // 1. Verify Signature
+    const signature = request.headers.get('x-line-signature');
+    if (!signature) {
+      set.status = 400;
+      return { error: 'Missing Signature' };
+    }
+    
+    // get raw body string
+    const rawBody = await request.clone().text();
+
+    const hash = crypto
+      .createHmac('SHA256', lineConfig.channelSecret)
+      .update(rawBody)
+      .digest('base64');
+
+    if (hash !== signature) {
+      set.status = 401;
+      return { error: 'Invalid Signature' };
+    }
+
+    try {
+      const events: line.WebhookEvent[] = (body as any).events || [];
+      
+      for (const event of events) {
+        if (event.type === 'message' && event.message.type === 'text') {
+          // Simple echo bot for now
+          await lineClient.replyMessage({
+            replyToken: event.replyToken,
+            messages: [{
+              type: 'text',
+              text: `คุณส่งข้อความว่า: ${event.message.text}`
+            }]
+          });
+        }
+      }
+      return { success: true };
+    } catch (err) {
+      console.error('[LINE Webhook] Error:', err);
+      set.status = 500;
+      return { error: 'Webhook processing failed' };
+    }
+  });