in ktor websockets, am I expected to manage which ...

# ktor

[Fábio Carneiro]

in ktor websockets, am I expected to manage which client I am talking to or the DefaultWebSockerServerSession is already a 1:1 connection between the server and client?

[Joost Klitsie]

I store a list of clients that I am connected to, so if there is an update pushed from somewhere else it dispatches it to those clients that are allowed to receive such information

[Fábio Carneiro]

@Joost Klitsie so that means the answer to my question is no?

how does it know which client to send the message if I call send()? Is it broadcast then?

[Fábio Carneiro]

I'm opening two different connections and they dont receive all the messages

[Joost Klitsie]

well if you have an incoming session it gives you a session

[Joost Klitsie]

so that only counts for that session

[Joost Klitsie]

if you want to send things to that session, you'd have to be able to reference it

[Joost Klitsie]

by for example storing it into a list

[Joost Klitsie]

and then iterate over all your sessions

[Joost Klitsie]

and send out the socket events

[Fábio Carneiro]

right, but I am already in the session context

[Fábio Carneiro]

I have some objects in a higher scope, that are manipulated in the session scope

[Fábio Carneiro]

I wasnted to confirm this session was between 1:1 client and server

[Fábio Carneiro]

because the examples have this for (frame in incoming) {

[Fábio Carneiro]

and for me its odd how this gets executed

[Fábio Carneiro]

ah ok I think I got it. incoming is a receivechannel and what I am basically doing is configuring a callback for every frame I receive

[Joost Klitsie]

I guess you wanna do something like:

webSocket("websocket/path") {
    addActiveSession(this) // whatever you want, just store the session
    incoming.receiveAsFlow().collect { frame ->
        // Handle incoming stuff, or just wait until this is cancelled (aka session ended)
    }
    removeFromActiveSessions(this)
}

[Joost Klitsie]

then if you want to send a message to all your sessions, check where you stored the sessions and on each you can simply call:

sessions.forEach { session ->
    if (session.isActive) {
        connection.outgoing.send(Frame.Binary(true, bytes)) // bytes is in my case a json object converted to byte array
     } else {
         removeFromActiveSessions(session)
     }
}

[Fábio Carneiro]

yes, I am already using flow for the output

[Fábio Carneiro]

but the question was the input

[Fábio Carneiro]

that helps a lot