[engine/AI] 현재 author가 작성한 커밋이 있다면 최신 10개 커밋 요약하기

packages/analysis-engine/src/index.ts

@@ -7,7 +7,7 @@ import { buildCSMDict } from "./csm";
 import getCommitRaws from "./parser";
 import { PluginOctokit } from "./pluginOctokit";
 import { buildStemDict } from "./stem";
-import { getSummary } from "./summary";
+import { getCurrentUserCommitSummary, getLatestCommitSummary } from "./summary";
 
 type AnalysisEngineArgs = {
   isDebugMode?: boolean;
@@ -75,9 +75,11 @@ export class AnalysisEngine {
     if (this.isDebugMode) console.log("stemDict: ", stemDict);
     const csmDict = buildCSMDict(commitDict, stemDict, this.baseBranchName, pullRequests);
     if (this.isDebugMode) console.log("csmDict: ", csmDict);
-    const nodes = stemDict.get(this.baseBranchName)?.nodes?.map(({commit}) => commit);
-    const geminiCommitSummary = await getSummary(nodes ? nodes?.slice(-10) : []);
-    if (this.isDebugMode) console.log("GeminiCommitSummary: ", geminiCommitSummary);
+    const latestCommitSummary = await getLatestCommitSummary(stemDict, this.baseBranchName);
+    if (this.isDebugMode) console.log("latestCommitSummary: ", latestCommitSummary);
+
+    const currentUserCommitSummary = await getCurrentUserCommitSummary(stemDict, this.baseBranchName, this.octokit);
+    if (this.isDebugMode) console.log("currentUserCommitSummary: ", currentUserCommitSummary);
 
     return {
       isPRSuccess,

packages/analysis-engine/src/summary.ts

@@ -1,19 +1,21 @@
-import type { CommitRaw } from "./types";
+import type PluginOctokit from "./pluginOctokit";
+import type { CommitRaw, StemDict } from "./types";
 
-const apiKey = process.env.GEMENI_API_KEY || '';
+const apiKey = process.env.GEMENI_API_KEY || "";
 const apiUrl = "https://generativelanguage.googleapis.com/v1beta/models/gemini-1.5-flash-latest:generateContent?key=";
 
 export async function getSummary(csmNodes: CommitRaw[]) {
-  const commitMessages = csmNodes.map((csmNode) => csmNode.message.split('\n')[0]).join(', ');
+  const commitMessages = csmNodes.map((csmNode) => csmNode.message.split("\n")[0]).join(", ");
 
+  console.log("commitMessages: ", commitMessages);
   try {
     const response = await fetch(apiUrl + apiKey, {
       method: "POST",
       headers: {
         "Content-Type": "application/json",
       },
       body: JSON.stringify({
-        contents: [{parts: [{text: `${prompt} \n${commitMessages}`}]}],
+        contents: [{ parts: [{ text: `${prompt} \n${commitMessages}` }] }],
       }),
     });
 
@@ -29,6 +31,30 @@ export async function getSummary(csmNodes: CommitRaw[]) {
   }
 }
 
+export async function getLatestCommitSummary(stemDict: StemDict, baseBranchName: string) {
+  const nodes = stemDict
+    .get(baseBranchName)
+    ?.nodes?.map(({ commit }) => commit)
+    .filter(({ message }) => !message.includes("Merge branch") && !message.includes("Merge pull request"));
+
+  return await getSummary(nodes ? nodes?.slice(-10) : []);
+}
+
+export async function getCurrentUserCommitSummary(stemDict: StemDict, baseBranchName: string, octokit: PluginOctokit) {
+  const { data } = await octokit.rest.users.getAuthenticated();
+  const currentUserNodes = stemDict
+    .get(baseBranchName)
+    ?.nodes?.filter(
+      ({ commit: { author, message } }) =>
+        (author.name === data.login || author.name === data.name) &&
+        !message.includes("Merge branch") &&
+        !message.includes("Merge pull request")
+    )
+    ?.map(({ commit }) => commit);
+
+  return await getSummary(currentUserNodes ? currentUserNodes?.slice(-10) : []);
+}
+
 const prompt = `Proceed with the task of summarising the contents of the commit message provided.
 
 Procedure:
@@ -53,4 +79,4 @@ Output format:
 - {prefix (if any)}:{commit summary3}
 ‘’
 
-Commits:`
+Commits:`;