Merge branch 'feature/233-implement-openrouter' of https://github.com/landamessenger/git-board-flow into feature/233-implement-openrouter

Author: efraespada

dist/index.js

@@ -131792,6 +131792,24 @@ class SupabaseRepository {
                 throw error;
             }
         };
+        this.removeChunksByShasum = async (owner, repository, branch, shasum) => {
+            try {
+                const { error } = await this.supabase
+                    .from(this.CHUNKS_TABLE)
+                    .delete()
+                    .eq('owner', owner)
+                    .eq('repository', repository)
+                    .eq('branch', branch)
+                    .eq('shasum', shasum);
+                if (error) {
+                    throw error;
+                }
+            }
+            catch (error) {
+                (0, logger_1.logError)(`Error removing chunks by shasum: ${JSON.stringify(error, null, 2)}`);
+                throw error;
+            }
+        };
         this.getChunkedFileByShasum = async (owner, repository, branch, type, shasum) => {
             try {
                 const { data, error } = await this.supabase
@@ -135715,6 +135733,8 @@ class VectorActionUseCase {
                 }
                 else if (remoteChunkedFiles.length > 0 && remoteChunkedFiles.length !== chunkedFile.chunks.length) {
                     (0, logger_1.logDebugInfo)(`📦 ❌ Chunk has a different number of chunks in Supabase: [${chunkedFile.path}] [${chunkedFile.index}]`, true);
+                    await supabaseRepository.removeChunksByShasum(param.owner, param.repo, param.commit.branch, chunkedFile.shasum);
+                    (0, logger_1.logDebugInfo)(`📦 🗑️ Chunks removed from Supabase: [${chunkedFile.path}] [${chunkedFile.index}]`, true);
                 }
                 (0, logger_1.logSingleLine)(`🟡 ${i + 1}/${totalFiles} (${progress.toFixed(1)}%) - Estimated time remaining: ${Math.ceil(remainingTime)} seconds | Vectorizing [${chunkedFile.path}]`);
                 const embeddings = await this.dockerRepository.getEmbedding(param, chunkedFile.chunks.map(chunk => [chunkedFile.type === 'block' ? this.CODE_INSTRUCTION_BLOCK : this.CODE_INSTRUCTION_LINE, chunk]));

dist/src/data/repository/supabase_repository.d.ts

@@ -8,6 +8,7 @@ export declare class SupabaseRepository {
     private supabase;
     constructor(config: SupabaseConfig);
     setChunkedFile: (owner: string, repository: string, branch: string, chunkedFile: ChunkedFile) => Promise<void>;
+    removeChunksByShasum: (owner: string, repository: string, branch: string, shasum: string) => Promise<void>;
     getChunkedFileByShasum: (owner: string, repository: string, branch: string, type: string, shasum: string) => Promise<ChunkedFileChunk[]>;
     getChunks: (owner: string, repository: string, branch: string, path: string, type: string, index: number) => Promise<ChunkedFileChunk[]>;
     getChunksByShasum: (owner: string, repository: string, branch: string, shasum: string) => Promise<ChunkedFileChunk[]>;

dist/src/data/repository/supabase_repository.js

@@ -39,6 +39,24 @@ class SupabaseRepository {
                 throw error;
             }
         };
+        this.removeChunksByShasum = async (owner, repository, branch, shasum) => {
+            try {
+                const { error } = await this.supabase
+                    .from(this.CHUNKS_TABLE)
+                    .delete()
+                    .eq('owner', owner)
+                    .eq('repository', repository)
+                    .eq('branch', branch)
+                    .eq('shasum', shasum);
+                if (error) {
+                    throw error;
+                }
+            }
+            catch (error) {
+                (0, logger_1.logError)(`Error removing chunks by shasum: ${JSON.stringify(error, null, 2)}`);
+                throw error;
+            }
+        };
         this.getChunkedFileByShasum = async (owner, repository, branch, type, shasum) => {
             try {
                 const { data, error } = await this.supabase

dist/src/usecase/vector_action_use_case.js

@@ -68,6 +68,8 @@ class VectorActionUseCase {
                 }
                 else if (remoteChunkedFiles.length > 0 && remoteChunkedFiles.length !== chunkedFile.chunks.length) {
                     (0, logger_1.logDebugInfo)(`📦 ❌ Chunk has a different number of chunks in Supabase: [${chunkedFile.path}] [${chunkedFile.index}]`, true);
+                    await supabaseRepository.removeChunksByShasum(param.owner, param.repo, param.commit.branch, chunkedFile.shasum);
+                    (0, logger_1.logDebugInfo)(`📦 🗑️ Chunks removed from Supabase: [${chunkedFile.path}] [${chunkedFile.index}]`, true);
                 }
                 (0, logger_1.logSingleLine)(`🟡 ${i + 1}/${totalFiles} (${progress.toFixed(1)}%) - Estimated time remaining: ${Math.ceil(remainingTime)} seconds | Vectorizing [${chunkedFile.path}]`);
                 const embeddings = await this.dockerRepository.getEmbedding(param, chunkedFile.chunks.map(chunk => [chunkedFile.type === 'block' ? this.CODE_INSTRUCTION_BLOCK : this.CODE_INSTRUCTION_LINE, chunk]));