failed to get reader: use of closed network connection

[srinivasan-getstan]

When ever first user tries to send message after the second user is joined. I'm getting error message failed to get reader: use of closed network connection

Find the code snippet below:

package websocket

import (
    "club-service/config"

    "club-service/internal/logger"
    "club-service/internal/middleware"

    "club-service/src/api/addClubUsers"
    "club-service/src/api/clubCategories"
    "club-service/src/api/createClub"
    "club-service/src/api/deleteClub"
    "club-service/src/api/editClub"
    "club-service/src/api/getClubs"
    firestore "club-service/src/fireStore"
    "club-service/src/utils"
    "club-service/src/wsMsgReader"
    "fmt"
    "net/http"

    "github.com/google/uuid"
    _websocket "nhooyr.io/websocket"
)

func InitiateSocketServer() {

    http.HandleFunc("/ws", WsHandler)
    logger.Log.Infof(`Initializing the Websocket server in PORT : %s`, config.EnvValues.SERVER_PORT)
    if err := http.ListenAndServe(fmt.Sprintf(":%s", config.EnvValues.SERVER_PORT), nil); err != nil {
        logger.Log.Fatalf(`failed to initialize the server.... %s`, err)
    }
}

func heathCheck(w http.ResponseWriter, r *http.Request) {
    w.WriteHeader(http.StatusOK)
    fmt.Fprintf(w, "Healthy!")
}

func WsHandler(w http.ResponseWriter, r *http.Request) {
    requestId, _ := uuid.NewUUID()
    log := logger.Log.WithFields(map[string]interface{}{
        "EVENT":      "WEBSOCKET_HANDLER",
        "REQUEST_ID": requestId,
    })

    wsConn, err := _websocket.Accept(w, r, nil)
    if err != nil {
        log.Errorf("Error accepting WebSocket connection: %v", err)
        return
    }

    queryValues := r.URL.Query()
    userId := utils.StringToInt32(queryValues.Get("userId"))
    clubId := queryValues.Get("clubId")
    log.Infof("Client connected to websocket : CLUB_ID : %s : USER_ID : %d", clubId, userId)

    wsMsgReader.WsReader(r.Context(), wsConn)

    logger.Log.Infof("Client disconnected : %d ", userId)
}

--------- WsReader -----------

package wsMsgReader

import (
    "club-service/internal/logger"
    "club-service/src/event"
    "club-service/src/eventSchemaHandler"
    "context"

    flatbuffers "github.com/google/flatbuffers/go"
    _websocket "nhooyr.io/websocket"
)

func WsReader(requestCtx context.Context, wsConn *_websocket.Conn) {
    for {
        // var msg string
        // if err := wsjson.Read(requestCtx, wsConn, &msg); err != nil {
        //  fmt.Printf("failed to read message: %v\n", err)
        //  break
        // }
        // fmt.Printf("received message: %s\n", msg)

        _, buff, err := wsConn.Read(requestCtx)
        if err != nil {
            logger.Log.Infof(`error ----> : %s`, err)
            break
        }
        data := eventSchemaHandler.GetRootAsEventWrapper(buff, 0)
        logger.Log.Infof("Received Event : %s\n", data.Event())
        unionTable := new(flatbuffers.Table)
        data.Payload(unionTable)
        event.SerializeEvents(string(data.ClubId()), string(data.Event()), unionTable, wsConn)
    }
}

[srinivasan-getstan]

Can someone help me

[nhooyr]

Most likely in your client code, nothing there stands out to me.

[nhooyr]

Going to close for now. Feel free to reopen if there's additional information.