How to get a list of opened sessions ?

[jagernicolas]

Hi,
I'd like to send messages from the server to every client connected (using websocket). I don't see how to do that. I was expecting to find a list with all the sessions opened.

there is a way to send messages to each client from the server (using websocket) ?

thx

[IronsDu]

@jagernicolas
Hi, see here:

brynet/examples/HttpServer.cpp

Lines 40 to 53 in 4879414

	auto wsEnterCallback = [](const HttpSession::Ptr& httpSession,
	WebSocketFormat::WebSocketFrameType opcode,
	const std::string& payload) {
	std::cout << "frame enter of type:" << int(opcode) << std::endl;
	std::cout << "payload is:" << payload << std::endl;
	// echo frame
	auto frame = std::make_shared<std::string>();
	WebSocketFormat::wsFrameBuild(payload.c_str(),
	payload.size(),
	*frame,
	WebSocketFormat::WebSocketFrameType::TEXT_FRAME,
	true,
	false);
	httpSession->send(frame);

When session enter, We can push HttpSession::Ptr into session list(need mutex).

And, we can use HttpSessionHandlers::setClosedCallback for remove session from session list, like this:

brynet/examples/HttpServer.cpp

Lines 69 to 71 in 4879414

	.configureEnterCallback([httpEnterCallback, wsEnterCallback](const HttpSession::Ptr& httpSession, HttpSessionHandlers& handlers) {
	handlers.setHttpCallback(httpEnterCallback);
	handlers.setWSCallback(wsEnterCallback);

[IronsDu]

also add some code in this:

brynet/examples/BenchWebsocket.cpp

Lines 56 to 82 in 4879414

	auto enterCallback = [host](const HttpSession::Ptr& httpSession, HttpSessionHandlers& handlers) {
	HttpRequest request;
	request.setMethod(HttpRequest::HTTP_METHOD::HTTP_METHOD_GET);
	request.setUrl("/ws");
	request.addHeadValue("Host", host);
	request.addHeadValue("Upgrade", "websocket");
	request.addHeadValue("Connection", "Upgrade");
	request.addHeadValue("Sec-WebSocket-Key", "dGhlIHNhbXBsZSBub25jZQ==");
	request.addHeadValue("Sec-WebSocket-Version", "13");
	std::string requestStr = request.getResult();
	httpSession->send(requestStr.c_str(), requestStr.size());
	handlers.setWSConnected([](const HttpSession::Ptr& session, const HTTPParser&) {
	for (int i = 0; i < 200; i++)
	{
	sendPacket(session, "hello, world!", 13);
	}
	});
	handlers.setWSCallback([](const HttpSession::Ptr& session,
	WebSocketFormat::WebSocketFrameType, const std::string& payload) {
	std::cout << payload << std::endl;
	sendPacket(session, "hello, world!", 13);
	count += 1;
	});
	};

[jagernicolas]

Hi @IronsDu ,
I was exactly doing that... however here my mistake,
std::list<HttpSession::Ptr&> list;
instead of
std::list<HttpSession::Ptr> list;

auto wsEnterCallback = [&list](const HttpSession::Ptr& httpSession, 
         WebSocketFormat::WebSocketFrameType opcode, 
         const std::string& payload) { 
             std::cout << "frame enter of type:" << int(opcode) << std::endl; 
             std::cout << "payload is:" << payload << std::endl; 
             // echo frame 

             liste.push_back(session); // TODO: add mutex

             auto frame = std::make_shared<std::string>(); 
             WebSocketFormat::wsFrameBuild(payload.c_str(), 
                 payload.size(), 
                 *frame, 
                 WebSocketFormat::WebSocketFrameType::TEXT_FRAME, 
                 true, 
                 false); 
             httpSession->send(frame); 

I will make a short example, would you me to share it with you ? I could make a PR when it's done (today or tomorrow)

[jagernicolas]

nevermind, I just saw that your example BenchWebsocket.cpp show that.

thx @IronsDu for your quick support!

[IronsDu]

Thank you. You can make a PR for this example.