fix(tools): implement fileSystem Open for ConcurrentFS and fix test cases

pkg/tools/filesystem.go

@@ -842,3 +842,10 @@ func (c *ConcurrentFS) ReadDir(path string) ([]os.DirEntry, error) {
 	// Directories rarely suffer from single-file corruption, but we delegate anyway.
 	return c.baseFS.ReadDir(path)
 }
+
+func (c *ConcurrentFS) Open(path string) (fs.File, error) {
+	lock := getPathLock(path)
+	lock.RLock()
+	defer lock.RUnlock()
+	return c.baseFS.Open(path)
+}

pkg/tools/filesystem_test.go

@@ -533,7 +533,7 @@ func TestConcurrentFS_RaceCondition(t *testing.T) {
 
 func TestConcurrencyUpgradeable(t *testing.T) {
 	// Verify that ReadFileTool implements the interface and upgrades correctly
-	readTool := NewReadFileTool("", false)
+	readTool := NewReadFileTool("", false, MaxReadFileSize)
 	upgradable, ok := interface{}(readTool).(ConcurrencyUpgradeable)
 	assert.True(t, ok, "ReadFileTool should implement ConcurrencyUpgradeable")
 

pkg/tools/team_test.go

@@ -11,7 +11,7 @@ func TestUpgradeRegistryForConcurrency(t *testing.T) {
 	original := NewToolRegistry()
 
 	// Register a mix of tools: some upgradeable, some not
-	readTool := NewReadFileTool("", false)
+	readTool := NewReadFileTool("", false, MaxReadFileSize)
 	listTool := NewListDirTool("", false) // Not upgradeable
 	writeTool := NewWriteFileTool("", false)