working on broadcast

server/src/Main.cpp

@@ -36,7 +36,8 @@ int main()
               .cert_file_name = "misc/cert.pem",
               .passphrase = "1234"})
         .ws<PerSocketData>(
-            "/*", {/* Settings */
+            "/*",
+            {/* Settings */
              .compression = uWS::CompressOptions(uWS::DEDICATED_COMPRESSOR_4KB | uWS::DEDICATED_DECOMPRESSOR),
              .maxPayloadLength = 100 * 1024 * 1024,
              .idleTimeout = 16,
@@ -52,14 +53,20 @@ int main()
                      user_data->created_at = DateTime::now();
 
                      DateTime::outputTime("Client connected at ", user_data->created_at);
+                     if (!ws->subscribe("*"))
+                     {
+                         std::cout << "Failed to subscribe to * channel\n";
+                         ws->close();
+                     }
                  },
              .message =
-                       [](auto *ws, std::string_view message, uWS::OpCode opCode) {
+                 [](uWS::WebSocket<false, true, PerSocketData> *ws, std::string_view message, uWS::OpCode opCode) {
                      /* This is the opposite of what you probably want; compress if message is LARGER than 16 kb
                       * the reason we do the opposite here; compress if SMALLER than 16 kb is to allow for
                       * benchmarking of large message sending without compression */
                      std::cout << "Message received: " << message << std::endl;
-                           ws->send(message, opCode, message.length() < 16 * 1024);
+                     ws->send(message, opCode, false);
+                     ws->publish("*", message, opCode, false);
                  },
              .dropped =
                  [](auto * /*ws*/, std::string_view /*message*/, uWS::OpCode /*opCode*/) {
@@ -80,6 +87,7 @@ int main()
              .close =
                  [](auto * /*ws*/, int /*code*/, std::string_view /*message*/) {
                      /* You may access ws->getUserData() here */
+                     std::cout << "Client disconnected\n";
                  }})
         .listen(9001,
                 [](auto *listen_socket) {