fixed test cases for windows

Author: PaperBoardOfficial

src/services/code-index/vector-store/__tests__/libsql-client.spec.ts

@@ -23,8 +23,31 @@ describe("LibSQLVectorStore", () => {
 
 	afterAll(async () => {
 		await vectorStore.deleteCollection()
-		if (fs.existsSync(testBasePath)) {
-			fs.rmSync(testBasePath, { recursive: true, force: true })
+		await vectorStore.close()
+
+		// On Windows, file handles might not be released immediately.
+		// Retry fs.rmSync a few times with a delay.
+		let attempts = 0
+		const maxAttempts = 5
+		const delayMs = 200
+
+		while (attempts < maxAttempts) {
+			try {
+				if (fs.existsSync(testBasePath)) {
+					fs.rmSync(testBasePath, { recursive: true, force: true })
+				}
+				break
+			} catch (error: any) {
+				if (error.code === "EBUSY" || error.code === "EPERM") {
+					attempts++
+					console.warn(
+						`Attempt ${attempts} to remove ${testBasePath} failed due to file lock. Retrying in ${delayMs}ms...`,
+					)
+					await new Promise((resolve) => setTimeout(resolve, delayMs))
+				} else {
+					throw error
+				}
+			}
 		}
 	})
 

src/services/code-index/vector-store/libsql-client.ts

@@ -210,6 +210,7 @@ export class LibSQLVectorStore implements IVectorStore {
 		await this.executeWriteOperationWithRetry(async () => {
 			const statements = points.map((point) => {
 				const vectorStr = JSON.stringify(point.vector)
+				const normalizedFilePath = path.normalize(point.payload.filePath)
 				return {
 					sql: `
 						INSERT INTO ${this.tableName} (id, vector, filePath, codeChunk, startLine, endLine)
@@ -224,12 +225,12 @@ export class LibSQLVectorStore implements IVectorStore {
 					args: [
 						point.id,
 						vectorStr,
-						point.payload.filePath,
+						normalizedFilePath,
 						point.payload.codeChunk,
 						point.payload.startLine,
 						point.payload.endLine,
 						vectorStr,
-						point.payload.filePath,
+						normalizedFilePath,
 						point.payload.codeChunk,
 						point.payload.startLine,
 						point.payload.endLine,
@@ -390,4 +391,17 @@ export class LibSQLVectorStore implements IVectorStore {
 	public async collectionExists(): Promise<boolean> {
 		return this.tableExists()
 	}
+
+	public async close(): Promise<void> {
+		if (this.client) {
+			try {
+				await this.client.close()
+				this.client = null
+				console.log("LibSQL client closed.")
+			} catch (error) {
+				console.error("Failed to close LibSQL client:", error)
+				throw error
+			}
+		}
+	}
 }