From 39e3b0df7f08912f38540f430b4bb4a3ba3b50f8 Mon Sep 17 00:00:00 2001
From: talksik <patel.arjun50@gmail.com>
Date: Sat, 27 Jan 2024 14:51:20 -0800
Subject: [PATCH] clean

---
 ' | 118 --------------------------------------------------------------
 1 file changed, 118 deletions(-)
 delete mode 100644 '

diff --git a/' b/'
deleted file mode 100644
index 5125314..0000000
--- a/'
+++ /dev/null
@@ -1,118 +0,0 @@
-#include "include/DateTime.hpp"
-#include <MessageCache.hpp>
-#include <chrono>
-#include <ctime>
-#include <iomanip>
-#include <iostream>
-#include <memory>
-#include <uWebSockets/App.h>
-#include <uWebSockets/WebSocket.h>
-
-struct PerSocketData
-{
-    std::chrono::system_clock::time_point created_at;
-    std::string remote_addr;
-};
-
-std::string full_message(PerSocketData &user_data, std::string_view message)
-{
-    std::cout << user_data.remote_addr << ": " << message << std::endl;
-    std::stringstream ss;
-    ss << user_data.remote_addr << ": " << message;
-    return ss.str();
-}
-
-int main()
-{
-    std::cout << "Welcome to the homechat server!\n";
-
-    std::mutex message_cache_mutex;
-    std::unique_ptr<MessageCache> message_cache = std::make_unique<MessageCache>();
-
-    /* Keep in mind that uWS::SSLApp({options}) is the same as uWS::App() when compiled without SSL support.
-     * You may swap to using uWS:App() if you don't need SSL */
-    uWS::App({/* There are example certificates in uWebSockets.js repo */
-              .key_file_name = "misc/key.pem",
-              .cert_file_name = "misc/cert.pem",
-              .passphrase = "1234"})
-        .ws<PerSocketData>(
-            "/*",
-            {/* Settings */
-             .compression = uWS::CompressOptions(uWS::DEDICATED_COMPRESSOR_4KB | uWS::DEDICATED_DECOMPRESSOR),
-             .maxPayloadLength = 100 * 1024 * 1024,
-             .idleTimeout = 16,
-             .maxBackpressure = 100 * 1024 * 1024,
-             .closeOnBackpressureLimit = false,
-             .resetIdleTimeoutOnSend = false,
-             .sendPingsAutomatically = true,
-             /* Handlers */
-             .upgrade = nullptr,
-             .open =
-                 [&](uWS::WebSocket<false, true, PerSocketData> *ws) {
-                     auto user_data = ws->getUserData();
-                     user_data->created_at = DateTime::now();
-                     user_data->remote_addr = ws->getRemoteAddressAsText();
-
-                     DateTime::outputTime("Client connected at ", user_data->created_at);
-                     if (!ws->subscribe("*", true))
-                     {
-                         std::cout << "Failed to subscribe to * channel\n";
-                         ws->close();
-                     }
-
-                     std::lock_guard<std::mutex> lock(message_cache_mutex);
-                     auto messages = message_cache->last_ten_messages();
-                     ws->send(std::string("Welcome to the homechat server! Here are the last 10 messages: \n"),
-                              uWS::OpCode::TEXT, false);
-                     for (auto &message : messages)
-                     {
-                         ws->send(full_message(*user_data, message), uWS::OpCode::TEXT, false);
-                     }
-                 },
-             .message =
-                 [&](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, false);
-                     ws->publish("*", message, opCode, false);
-
-                     std::lock_guard<std::mutex> lock(message_cache_mutex);
-                     if (!message_cache->add_message(std::string(message)))
-                     {
-                         std::cerr << "Failed to add message to cache" << std::endl;
-                     }
-                 },
-             .dropped =
-                 [](auto * /*ws*/, std::string_view /*message*/, uWS::OpCode /*opCode*/) {
-                     /* A message was dropped due to set maxBackpressure and closeOnBackpressureLimit limit */
-                 },
-             .drain =
-                 [](auto * /*ws*/) {
-                     /* Check ws->getBufferedAmount() here */
-                 },
-             .ping =
-                 [](auto * /*ws*/, std::string_view) {
-                     /* Not implemented yet */
-                 },
-             .pong =
-                 [](auto * /*ws*/, std::string_view) {
-                     /* Not implemented yet */
-                 },
-             .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) {
-                    if (listen_socket)
-                    {
-                        std::cout << "Listening on port " << 9001 << std::endl;
-                    }
-                })
-        .run();
-
-    return 0;
-}