ERROR CREATING WsLink

[DylanDaCosta23]

I have these errors... can someone help me ?

WebSocket connection to 'ws://localhost:5000/graphql-private' failed:

Error in subscription Error: Socket closed

With the library subscriptions-transport-ws was working, but when I migrate to this llibrary, it gives me error

[enisdenjo]

Can you share the error?

The server very likely does not support the new GraphQL over WebSocket protocol and graphql-ws is not backwards compatible.

[enisdenjo]

Those dont tell me much. I need the full error - specifically the WebSocket close code and reason.

[DylanDaCosta23]

I only have this information

[enisdenjo]

That doesn't tell me much either. I suspect it's the server not supporting graphql-ws. What server do you use? Which WS library there?

[DylanDaCosta23]

This is the code on the backend:
With the other library it works... maybe it is not compatible with the new one as you said.

module MyProject.API.HotChocolateExtensions.Subscriptions


open System
open System.IdentityModel.Tokens.Jwt
open MyProject.Users.Authorization.Interfaces.Entities
open MyProject.Users.Authorization.Interfaces.Services
open FSharp.Control

open HotChocolate.AspNetCore
open HotChocolate.AspNetCore.Subscriptions
open Microsoft.AspNetCore.Http
open Microsoft.Extensions.Logging
open Microsoft.IdentityModel.Logging
open Microsoft.IdentityModel.Protocols
open Microsoft.IdentityModel.Protocols.OpenIdConnect
open Microsoft.IdentityModel.Tokens

open MyProject.API.HotChocolateExtensions.HttpContext

let private jwtValidated = "__is_jwt_validated__"

[<Sealed>]
type SubscriptionAuthorizationProvider(httpContextAccessor: IHttpContextAccessor) =
    member this.IsJwtValidated() =
        let isValidS = httpContextAccessor.HttpContext |> getRequestParameter jwtValidated

        match Boolean.TryParse isValidS with
        | true, isValid -> isValid
        | _ -> false

/// Subscription authentication and setting of necessary data to request
type SubscriptionSocketSessionInterceptor
    (logger: ILogger<SubscriptionSocketSessionInterceptor>, jwtValidation: IJwtValidationService) =

    //NOTE: always the same instance is reused

    let bearer = "Bearer "

    let removeBearer (jwt: string) =
        if jwt.StartsWith(bearer) then
            jwt.Substring(bearer.Length)
        else
            jwt

    interface ISocketSessionInterceptor with

        member this.OnCloseAsync(connection, cancellationToken) =
            task {
                logger.LogDebug "SubscriptionSocketSessionInterceptor.OnCloseAsync"
                ()
            }
            |> ValueTask.ofTask
            |> ValueTask.ignore

        member this.OnConnectAsync(connection, message, cancellationToken) =
            task {
                try
                    //NOTE: debug only, in case of problems. see https://stackoverflow.com/questions/53255246/identity-server-4-idx10630-pii-is-hidden
                    //IdentityModelEventSource.ShowPII <- true

                    logger.LogDebug(
                        "OnConnectAsync, UserHostAddress = {remoteIp}:{remotePort}",
                        connection.HttpContext.Connection.RemoteIpAddress,
                        connection.HttpContext.Connection.RemotePort
                    )

                    let payloadOpt = message.Payload |> Option.ofObj

                    let payload =
                        match payloadOpt with
                        | None -> failwithf "No Payload received, please send authorization params"
                        | Some payloadDict -> payloadDict


                    let jwt =
                        match payload.TryGetValue "authorization" with
                        | false, _ -> failwithf "No `authorization` received"
                        | true, jwt -> string jwt

                    //authorize - check that the token is valid
                    do!
                        ValidateJwtTokenRequest(Jwt = (jwt |> removeBearer))
                        |> jwtValidation.ValidateJwtTokenAsync

                    connection.HttpContext.Request.Headers.Authorization <- jwt
                    connection.HttpContext.Items[jwtValidated] <- "true"

                    //set x-tenant-id, x-selected-language and other payload data if sent
                    payload |> Seq.iter (fun x -> connection.HttpContext.Items[x.Key] <- x.Value)

                    return ConnectionStatus.Accept()
                with ex ->
                    printfn $"Error connecting: %A{ex}"
                    return ConnectionStatus.Reject(ex |> string)
            }
            |> ValueTask.ofTask

        member this.OnRequestAsync(connection, requestBuilder, cancellationToken) =
            task {
                logger.LogDebug "SubscriptionSocketSessionInterceptor.OnRequestAsync"
                ()
            }
            |> ValueTask.ofTask
            |> ValueTask.ignore

[enisdenjo]

HotChocolate does support graphql-ws. There must be something wrong with the server (the errors you share are not insightful and I don't know C#, so I cannot help you there, sorry).