Aanufriev

.gitignore

@@ -0,0 +1,46 @@
+# Prerequisites
+*.d
+
+# Object files
+*.o
+*.ko
+*.obj
+*.elf
+
+# Linker output
+*.ilk
+*.map
+*.exp
+
+# Precompiled Headers
+*.gch
+*.pch
+
+# Executables
+*.exe
+*.out
+*.app
+*.i*86
+*.x86_64
+*.hex
+
+# Debug files
+*.dSYM/
+*.su
+*.idb
+*.pdb
+
+# Kernel Module Compile Results
+*.mod*
+*.cmd
+.tmp_versions/
+modules.order
+Module.symvers
+Mkfile.old
+dkms.conf
+
+# macOS files
+.DS_Store
+
+# build folder
+/build

CMakeLists.txt

@@ -1,17 +1,29 @@
-cmake_minimum_required(VERSION 3.11)
+cmake_minimum_required(VERSION 3.13)
+project(TextShareServer)
 
-project(CodeShare)
-
-set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -Wall -Wextra -Werror=pedantic")
-set(CMAKE_C_STANDARD 99)
+set(CMAKE_CXX_STANDARD 11)
+set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++11 -pthread")
 
 include_directories(project/headers)
 
-enable_testing()
+set(SOURCE_DIR project/src/)
+
+set(LIB_SOURCE_FILES
+    ${SOURCE_DIR}Server.cpp
+    ${SOURCE_DIR}Connection.cpp
+    ${SOURCE_DIR}RequestHandler.cpp
+)
+
+add_library(project_lib STATIC ${LIB_SOURCE_FILES})
+
+add_definitions(-DBOOST_ERROR_CODE_HEADER_ONLY)
+add_executable(TextShareServer ${SOURCE_DIR}main.cpp)
+
+find_package(Boost 1.72.0 COMPONENTS system)
+if(Boost_FOUND)
+    include_directories(${Boost_INCLUDE_DIRS}) 
+endif()
 
-add_executable(CodeShare project/src/main.cpp
-        project/src/ChatRoom.cpp project/headers/ChatRoom.h
-        project/src/RoomManager.cpp project/headers/RoomManager.h
-        project/src/MongoConnector.cpp project/headers/MongoConnector.h)
+target_link_libraries(TextShareServer project_lib ${Boost_LIBRARIES})
 
 add_subdirectory(project/tests)

project/headers/Connection.h

@@ -0,0 +1,60 @@
+#ifndef PROJECT_INCLUDE_CONNECTION_H_
+#define PROJECT_INCLUDE_CONNECTION_H_
+
+template<class RoomSchedulerType>
+class RequestHandler;
+
+class RoomScheduler;
+
+#include <iostream>
+#include <utility>
+#include <queue>
+#include <boost/asio.hpp>
+#include <boost/filesystem.hpp>
+
+#include "json.hpp"
+#include "MsgContext.h"
+#include "ConnectionManager.h"
+#include "RequestHandler.h"
+
+using boost::asio::ip::tcp;
+using json = nlohmann::json;
+typedef std::pair<int,int> symbolId;
+
+class Connection : public std::enable_shared_from_this<Connection> {
+public:
+    explicit Connection(tcp::socket socket);
+
+    int getId() const;
+
+    void setRoomId(int id);
+
+    int getRoomId() const;
+
+    void start(int editorId);
+
+    void stop();
+
+    void deliver(const MsgContext& msg);
+
+private:
+    int id;
+    int roomId;
+    tcp::socket socket;
+    MsgContext messageBuffer;
+    std::queue<MsgContext> messageQueue;
+    std::string messageBody;
+    std::shared_ptr<RequestHandler<RoomScheduler>> requestHandler;
+
+    virtual void readHeader();
+
+    virtual void readBody();
+
+    virtual void writeClient();
+
+    void sendMsg(const std::string& response);
+
+    void sendMsgAll(const std::string& response, const int& clientId);
+};
+
+#endif  //  PROJECT_INCLUDE_CONNECTION_H_

project/headers/ConnectionManager.h

@@ -0,0 +1,65 @@
+#ifndef PROJECT_INCLUDE_CONNECTION_MANAGER_H_
+#define PROJECT_INCLUDE_CONNECTION_MANAGER_H_
+
+#include <iostream>
+#include <set>
+
+#include "MsgContext.h"
+#include "Connection.h"
+
+template<class ConnectionType>
+class ConnectionManager {
+public:
+    static ConnectionManager& getInstance() {
+        static ConnectionManager instance;
+        return instance;
+    }
+
+    void start(std::shared_ptr<ConnectionType> connection, int clientId);
+
+    void stop(std::shared_ptr<ConnectionType> connection);
+
+    void stopAll();
+
+    void sendMsgAllExceptMe(MsgContext message, int clientId);
+
+    ConnectionManager(ConnectionManager const&) = delete;
+
+    void operator=(ConnectionManager const&) = delete;
+private:
+    ConnectionManager() = default;
+    std::set<std::shared_ptr<ConnectionType>> connections;
+};
+
+template<class ConnectionType>
+void ConnectionManager<ConnectionType>::start(std::shared_ptr<ConnectionType> connection, int clientId) {
+    std::cout << "start in ConManager" << std::endl;
+    connections.insert(connection);
+    connection->start(clientId);
+}
+
+template<class ConnectionType>
+void ConnectionManager<ConnectionType>::stop(std::shared_ptr<ConnectionType> connection) {
+    connection->stop();
+    connections.erase(connection);
+}
+
+template<class ConnectionType>
+void ConnectionManager<ConnectionType>::stopAll() {
+    for (auto connection : connections) {
+        connection->stop();
+    }
+    connections.clear();
+}
+
+template<class ConnectionType>
+void ConnectionManager<ConnectionType>::sendMsgAllExceptMe(MsgContext message, int clientId) {
+    for (const auto& connection: connections) {
+        if (connection->getId() == clientId) {
+            continue;
+        }
+        connection->deliver(message);
+    }
+}
+
+#endif  //  PROJECT_INCLUDE_CONNECTION_MANAGER_H_