ADD: checkItems function with checkMamul and push message to client

@@ -10,7 +10,7 @@ const db = require("../../apis/database");
 // database.getAllUsers = async function()
 // database.getAllUsers = async function()
 // database.getAllKeywords = async function()
 // database.getAllKeywords = async function()
 
 
-const checkMamul = (client) => {
+const multiCheckMamul = (client) => {
   db.getAllKeywords().then((keywords) => {
   db.getAllKeywords().then((keywords) => {
     for (let i = 0, pending = Promise.resolve(); i < keywords.length; i++) {
     for (let i = 0, pending = Promise.resolve(); i < keywords.length; i++) {
       pending = db.getUsersByKeyword(keywords[i]).then((userIds) => {
       pending = db.getUsersByKeyword(keywords[i]).then((userIds) => {
@@ -22,4 +22,14 @@ const checkMamul = (client) => {
   });
   });
 };
 };
 
 
-module.exports = { checkMamul };
+const checkMamul = (client, userId) => {
+  db.getKeywordsByUserId(userId).then((keywords) => {
+    for (let i = 0, pending = Promise.resolve(); i< keywords.length; i++) {
+      pending = marketMultiSearch(keywords[i]).then((res) => {
+        client.pushMessage(userId, setCarouselMessage(res));
+      });
+    };
+  });
+};
+
+module.exports = { multiCheckMamul, checkMamul };

@@ -18,7 +18,7 @@ const fs = require("fs");
 // Cron for Mamul Notification
 // Cron for Mamul Notification
 const schedule = require("node-schedule");
 const schedule = require("node-schedule");
 const job = schedule.scheduleJob("0 */1 * * *", () => {
 const job = schedule.scheduleJob("0 */1 * * *", () => {
-  checkMamul(client);
+    multiCheckMamul(client);
 });
 });
 
 
 // Database APIs
 // Database APIs
@@ -39,7 +39,8 @@ const config = {
 };
 };
 
 
 // Cron for Mamul Notification
 // Cron for Mamul Notification
-const { checkMamul } = require("./checkMamul/checkMamul");
+const { multiCheckMamul, checkMamul } = require("./checkMamul/checkMamul");
+
 
 
 // Line chat bot client & event
 // Line chat bot client & event
 const client = new line.Client(config);
 const client = new line.Client(config);
@@ -71,18 +72,7 @@ function handleEvent(event) {
         }
         }
       } else if (event.postback.data == "checkItems") {
       } else if (event.postback.data == "checkItems") {
         return Promise.resolve(
         return Promise.resolve(
-          client.replyMessage(event.replyToken, {
-            type: "flex",
-            altText: "등록된 매물",
-            contents: setFlexMessage(
-              "daangn",
-              "RTX 3080",
-              "1000000",
-              "https://dnvefa72aowie.cloudfront.net/origin/article/202205/94cdd237258671d5806a70f64ab2b3c7dcd790da0384b394ef5809fe10c08ced.webp?q=95&s=1440x1440&t=inside",
-              "https://www.daangn.com/articles/403755360",
-              "채굴X, 흡연X, 반려동물X 입니다.\n직거래 희망하며, 쿨거래시 네고 1만원 가능합니다."
-            ),
-          })
+            checkMamul(client, event.source.userId),
         );
         );
       }
       }
     }
     }