feat: link the handler to event

src/handlers/comment/action.ts

@@ -51,11 +51,9 @@ export const handleComment = async (): Promise<void> => {
         const callbackComment = response ?? successComment ?? "";
         if (callbackComment) await callback(issue.number, callbackComment, payload.action, payload.comment);
       } catch (err: unknown) {
-        // Use failureComment for failed command if it is available
-        if (failureComment) {
-          await callback(issue.number, failureComment, payload.action, payload.comment);
+        for (const comment of [failureComment, ErrorDiff(err)]) {
+          if (comment) await callback(issue.number, comment, payload.action, payload.comment);
         }
-        await callback(issue.number, ErrorDiff(err), payload.action, payload.comment);
       }
     } else {
       logger.info(`Skipping for a command: ${command}`);

src/handlers/issue/embeddings.ts

@@ -1,7 +1,29 @@
+import { getAdapters, getBotConfig, getBotContext, getLogger } from "../../bindings";
+import { Payload } from "../../types";
+import { generateEmbeddings } from "../../helpers";
+import { upsertEmbeddings } from "../../adapters/supabase";
+
 /**
  * Generates an embedding vector for the current issue
  */
+export const embeddings = async () => {
+  const { payload: _payload } = getBotContext();
+  const logger = getLogger();
+  const payload = _payload as Payload;
+  const issue = payload.issue;
+
+  if (!issue) {
+    logger.info(`Skip to generate embeddings because of no issue instance`);
+    return;
+  }
+
+  if (!issue.body) {
+    logger.info("Skip to generate embeddings because of empty body");
+    return;
+  }
 
-export const generateEmbeddings = async () => {
-  return;
+  const embeddings = await generateEmbeddings(issue.body);
+  if (embeddings.length > 0) {
+    await upsertEmbeddings(payload.repository.owner.login, payload.repository.name, issue.number, embeddings);
+  }
 };

src/helpers/index.ts

@@ -10,3 +10,4 @@ export * from "./payout";
 export * from "./file";
 export * from "./similarity";
 export * from "./commit";
+export * from "./gpt";