Function createMCPServerForRepositoryTest

cmd/container-use/stdio_test.go:202–243

createMCPServerForRepositoryTest creates an MCP server process for repository contention testing

(t *testing.T, i int, repoDir, configDir string, singleTenant bool)

// createMCPServerForRepositoryTest creates an MCP server process for repository contention testing
func createMCPServerForRepositoryTest(t *testing.T, i int, repoDir, configDir string, singleTenant bool) *MCPServerProcess {
	ctx := context.Background()
	containerUseBinary := getContainerUseBinary(t)

	var cmd *exec.Cmd
	var clientArgs []string
	if singleTenant {
		cmd = exec.CommandContext(ctx, containerUseBinary, "stdio", "--single-tenant")
		clientArgs = []string{"stdio", "--single-tenant"}
	} else {
		cmd = exec.CommandContext(ctx, containerUseBinary, "stdio")
		clientArgs = []string{"stdio"}
	}

	cmd.Dir = repoDir
	cmd.Env = append(os.Environ(), fmt.Sprintf("CONTAINER_USE_CONFIG_DIR=%s", configDir))

	mcpClient, err := client.NewStdioMCPClient(containerUseBinary, cmd.Env, clientArgs...)
	require.NoError(t, err)

	initRequest := mcp.InitializeRequest{}
	initRequest.Params.ProtocolVersion = mcp.LATEST_PROTOCOL_VERSION
	initRequest.Params.ClientInfo = mcp.Implementation{
		Name:    fmt.Sprintf("Repository Test Client %d", i),
		Version: "1.0.0",
	}
	initRequest.Params.Capabilities = mcp.ClientCapabilities{}

	serverInfo, err := mcpClient.Initialize(ctx, initRequest)
	require.NoError(t, err)

	server := &MCPServerProcess{
		cmd:        cmd,
		client:     mcpClient,
		repoDir:    repoDir,
		configDir:  configDir,
		serverInfo: serverInfo,
		t:          t,
	}

	return server
}

// runRepositoryContentionTest runs the core repository contention test logic
func runRepositoryContentionTest(t *testing.T, servers []*MCPServerProcess, testPrefix string) {