Function newInProcessClient

pkg/mcp/protocol_test.go:26–54

(t *testing.T)

)

func newInProcessClient(t *testing.T) *client.Client {
	t.Helper()
	cfg := DefaultConfig()
	srv := New(cfg)

	c, err := client.NewInProcessClient(srv.mcpSrv)
	if err != nil {
		t.Fatalf("NewInProcessClient: %v", err)
	}

	ctx := context.Background()
	if err := c.Start(ctx); err != nil {
		t.Fatalf("client.Start: %v", err)
	}

	initReq := mcpmcp.InitializeRequest{}
	initReq.Params.ProtocolVersion = mcpmcp.LATEST_PROTOCOL_VERSION
	initReq.Params.ClientInfo = mcpmcp.Implementation{
		Name:    "gosqlx-test-client",
		Version: "0.0.1",
	}
	_, err = c.Initialize(ctx, initReq)
	if err != nil {
		t.Fatalf("client.Initialize: %v", err)
	}

	t.Cleanup(func() { _ = c.Close() })
	return c
}

func extractProtocolResult(t *testing.T, res *mcpmcp.CallToolResult) map[string]any {
	t.Helper()