more test fixes...

Author: vexxvakan

test/integration/api/cache-status.integration.test.ts

@@ -5,10 +5,16 @@ import { join } from "node:path"
 import { createDocsFetcher } from "../../../src/docs-fetcher.js"
 
 describe("Cache Status Tracking", () => {
-	const testDbPath = join(tmpdir(), `test-cache-status-${Date.now()}.db`)
+	let testDbPath: string
 	let fetcher: ReturnType<typeof createDocsFetcher>
 
 	beforeEach(() => {
+		// Create unique database path for each test to avoid conflicts
+		testDbPath = join(
+			tmpdir(),
+			`test-cache-status-${Date.now()}-${Math.random().toString(36).substring(2, 9)}.db`
+		)
+
 		// Create fetcher with persistent database for testing
 		fetcher = createDocsFetcher({
 			dbPath: testDbPath,
@@ -47,7 +53,7 @@ describe("Cache Status Tracking", () => {
 		expect(result.fromCache).toBe(false)
 		expect(result.data).toBeDefined()
 		expect(result.data.root).toBeDefined() // Basic validation of rustdoc JSON structure
-	})
+	}, 10000)
 
 	it("should return fromCache: true on subsequent fetch", async () => {
 		// First fetch - should hit the network
@@ -60,7 +66,7 @@ describe("Cache Status Tracking", () => {
 
 		// Data should be identical
 		expect(secondResult.data).toEqual(firstResult.data)
-	})
+	}, 10000)
 
 	it("should persist cache across fetcher instances", async () => {
 		// First fetcher instance
@@ -81,7 +87,7 @@ describe("Cache Status Tracking", () => {
 		expect(result2.data).toEqual(result1.data)
 
 		fetcher2.close()
-	})
+	}, 10000)
 
 	it("should handle different versions separately", async () => {
 		// Fetch latest version
@@ -99,7 +105,7 @@ describe("Cache Status Tracking", () => {
 		// Fetch the specific version again - should also be cached
 		const versionAgain = await fetcher.fetchCrateJson("tinc", "0.1.6")
 		expect(versionAgain.fromCache).toBe(true)
-	})
+	}, 15000)
 
 	it("should track cache misses for non-existent crates", async () => {
 		try {
@@ -118,7 +124,7 @@ describe("Cache Status Tracking", () => {
 				expect(secondError).toBeDefined()
 			}
 		}
-	})
+	}, 10000)
 
 	it("should work with in-memory cache", async () => {
 		// Create fetcher with in-memory cache
@@ -135,7 +141,7 @@ describe("Cache Status Tracking", () => {
 		expect(secondResult.fromCache).toBe(true)
 
 		memoryFetcher.close()
-	})
+	}, 10000)
 
 	it("should respect cache TTL", async () => {
 		// Create fetcher with very short TTL
@@ -162,5 +168,5 @@ describe("Cache Status Tracking", () => {
 			await new Promise((resolve) => setTimeout(resolve, 100))
 		}
 		rmSync(join(tmpdir(), `test-ttl-${Date.now()}.db`), { force: true })
-	})
+	}, 10000)
 })

test/integration/e2e/full-flow.integration.test.ts

@@ -44,12 +44,12 @@ describe("Integration Tests", () => {
 				throw error
 			}
 		}
-	})
+	}, 10000)
 
 	it("should handle crates without JSON docs gracefully", () => {
 		// Try an old version that likely doesn't have JSON docs
 		expect(fetcher.fetchCrateJson("tinc", "0.1.0")).rejects.toThrow(/not found|404/)
-	})
+	}, 10000)
 
 	it("should validate URL construction", async () => {
 		// Mock a quick test without actual network call
@@ -70,5 +70,5 @@ describe("Integration Tests", () => {
 		)
 
 		global.fetch = originalFetch
-	})
+	}, 10000)
 })

test/integration/test-resources.ts

@@ -33,14 +33,19 @@ const testResources = async (options: TestOptions): Promise<void> => {
 
 				// Test 2: Add some data to cache
 				console.log("\n🔄 Test 2: Populate cache with test data...")
-				const addResult = await callTool(server, "lookup_crate_docs", { crateName: "tinc", version: "0.1.6" }, 3)
+				const addResult = await callTool(
+					server,
+					"lookup_crate_docs",
+					{ crateName: "tinc", version: "0.1.6" },
+					3
+				)
 				if (addResult.result?.isError) {
 					throw new Error(`Failed to add tinc to cache: ${addResult.result.content[0].text}`)
 				}
 				console.log("✅ Added tinc to cache")
-				
+
 				// Small delay to ensure cache write completes
-				await new Promise(resolve => setTimeout(resolve, 100))
+				await new Promise((resolve) => setTimeout(resolve, 100))
 
 				// Test 3: Read cache statistics
 				console.log("\n📊 Test 3: Read cache statistics...")
@@ -57,12 +62,16 @@ const testResources = async (options: TestOptions): Promise<void> => {
 
 				// Test 4: Read cache entries
 				console.log("\n📚 Test 4: Read cache entries...")
-				const entriesContent = await readResource(server, "cache://entries?limit=10&offset=0", 5)
-				
+				const entriesContent = await readResource(
+					server,
+					"cache://entries?limit=10&offset=0",
+					5
+				)
+
 				if (!entriesContent) {
 					throw new Error("No content returned from cache entries resource")
 				}
-				
+
 				let entries: any
 				try {
 					entries = JSON.parse(entriesContent)
@@ -120,8 +129,14 @@ const testResources = async (options: TestOptions): Promise<void> => {
 				const sqlResult = JSON.parse(sqlContent)
 
 				const expectedCount = 1 + successCount // 1 from tinc + successCount from pagination test
-				if (!Array.isArray(sqlResult) || sqlResult.length === 0 || sqlResult[0].count !== expectedCount) {
-					throw new Error(`Expected ${expectedCount} cache entries, got ${sqlResult?.[0]?.count}`)
+				if (
+					!Array.isArray(sqlResult) ||
+					sqlResult.length === 0 ||
+					sqlResult[0].count !== expectedCount
+				) {
+					throw new Error(
+						`Expected ${expectedCount} cache entries, got ${sqlResult?.[0]?.count}`
+					)
 				}
 				console.log("✅ SQL query executed successfully")
 
@@ -138,7 +153,11 @@ const testResources = async (options: TestOptions): Promise<void> => {
 
 				// The server returns a successful response with an error message in the content
 				const dangerousContent = dangerousResponse.result?.contents?.[0]?.text || ""
-				assertContains(dangerousContent, "Only SELECT queries are allowed", "Should reject non-SELECT query")
+				assertContains(
+					dangerousContent,
+					"Only SELECT queries are allowed",
+					"Should reject non-SELECT query"
+				)
 				console.log("✅ Correctly rejected non-SELECT query")
 
 				console.log("\n✅ All resources tests passed")