fix: tests

src/adapters/index.ts

@@ -5,13 +5,13 @@ import { SuperSupabase } from "./supabase/helpers/supabase";
 import { Embedding as VoyageEmbedding } from "./voyage/helpers/embedding";
 import { SuperVoyage } from "./voyage/helpers/voyage";
 import { VoyageAIClient } from "voyageai";
-import { Issues } from "./supabase/helpers/issues";
+import { Issue } from "./supabase/helpers/issues";
 
 export function createAdapters(supabaseClient: SupabaseClient, voyage: VoyageAIClient, context: Context) {
   return {
     supabase: {
       comment: new Comment(supabaseClient, context),
-      issue: new Issues(supabaseClient, context),
+      issue: new Issue(supabaseClient, context),
       super: new SuperSupabase(supabaseClient, context),
     },
     voyage: {

src/adapters/supabase/helpers/issues.ts

@@ -26,11 +26,41 @@ interface IssueData {
   isPrivate: boolean;
 }
 
+interface FindSimilarIssuesParams {
+  markdown: string;
+  currentId: string;
+  threshold: number;
+}
+
 export class Issue extends SuperSupabase {
   constructor(supabase: SupabaseClient, context: Context) {
     super(supabase, context);
   }
 
+  async findSimilarIssues(params: FindSimilarIssuesParams): Promise<IssueSimilaritySearchResult[]> {
+    const { markdown, currentId, threshold } = params;
+    const embedding = await this.context.adapters.voyage.embedding.createEmbedding(markdown);
+    const { data, error } = await this.supabase.rpc("match_issues", {
+      query_embedding: embedding,
+      match_threshold: threshold,
+      current_id: currentId,
+    });
+
+    if (error) {
+      this.context.logger.error("Error finding similar issues", {
+        Error: error,
+        params,
+      });
+      return [];
+    }
+
+    return data.map((item: IssueSimilaritySearchResult) => ({
+      id: item.id,
+      issue_id: item.id,
+      similarity: item.similarity,
+    }));
+  }
+
   async createIssue(issueData: IssueData) {
     const { isPrivate } = issueData;
     //First Check if the issue already exists