Merge pull request #22 from snandasena/dev

Improved

Author: snandasena

app/CMakeLists.txt

@@ -7,4 +7,5 @@ add_subdirectory(common)
 add_subdirectory(interfaces)
 add_subdirectory(parsers)
 add_subdirectory(configs)
-add_subdirectory(auth)
+add_subdirectory(auth)
+add_subdirectory(servers)

app/servers/CMakeLists.txt

@@ -0,0 +1,39 @@
+project(Servers)
+
+
+find_package(Boost COMPONENTS system REQUIRED)
+
+include_directories(${Boost_INCLUDE_DIRS})
+
+set(HEADERS
+        ${PROJECT_SOURCE_DIR}/interfaces/services/ITaxServiceFactory.h
+        ${PROJECT_SOURCE_DIR}/interfaces/services/ITaxService.h
+        ${PROJECT_SOURCE_DIR}/include/servers/ReportSession.h
+        )
+
+set(SOURCES
+        ${PROJECT_SOURCE_DIR}/src/ReportSession.cpp
+        ${PROJECT_SOURCE_DIR}/include/servers/Server.h
+        ${PROJECT_SOURCE_DIR}/src/Server.cpp
+        )
+
+add_library(${PROJECT_NAME} STATIC ${SOURCES} ${HEADERS})
+
+set(COMON_LINK_LIBS
+        ${PROJECT_NAME}
+        ${Boost_SYSTEM_LIBRARY}
+        Common
+        Interfaces
+        pthread
+        )
+
+if (WIN32)
+    target_link_libraries(${COMON_LINK_LIBS} ws2_32)
+else ()
+    target_link_libraries(${COMON_LINK_LIBS})
+endif (WIN32)
+
+target_include_directories(${PROJECT_NAME} PUBLIC
+        ${PROJECT_SOURCE_DIR}/include
+        ${PROJECT_SOURCE_DIR}/interfaces
+        )

app/servers/include/servers/ReportSession.h

@@ -0,0 +1,53 @@
+//
+// Created by sajith on 6/28/22.
+//
+
+#ifndef DESIGN_PATTERNS_REPORTSESSION_H
+#define DESIGN_PATTERNS_REPORTSESSION_H
+
+#include <boost/asio.hpp>
+#include <memory>
+#include <optional>
+
+#include "auth/IAuthentication.h"
+#include "parsers/ICredentialsParser.h"
+#include "services/ITaxServiceFactory.h"
+
+using boost::asio::ip::tcp;
+
+namespace types
+{
+    struct User;
+}
+
+namespace servers
+{
+    class ReportSession
+    {
+    public:
+
+        ReportSession(tcp::socket, const auth::IAuthentication &, const parsers::ICredentialsParser&,
+                      const services::ITaxServiceFactory &);
+
+        void start();
+
+        void stop();
+
+    private:
+
+        std::optional<types::User> loginUser();
+
+        static constexpr auto MAX_LENGTH = 1024;
+
+        tcp::socket sock;
+        char data[MAX_LENGTH];
+
+        const auth::IAuthentication &authManager;
+        const parsers::ICredentialsParser &parser;
+        const services::ITaxServiceFactory &taxServiceFactory;
+
+    };
+}
+
+
+#endif //DESIGN_PATTERNS_REPORTSESSION_H

app/servers/include/servers/Server.h

@@ -0,0 +1,8 @@
+//
+// Created by sajith on 6/28/22.
+//
+
+#ifndef DESIGN_PATTERNS_SERVER_H
+#define DESIGN_PATTERNS_SERVER_H
+
+#endif //DESIGN_PATTERNS_SERVER_H

app/servers/interfaces/services/ITaxService.h

@@ -0,0 +1,26 @@
+//
+// Created by sajith on 6/28/22.
+//
+
+#ifndef DESIGN_PATTERNS_ITAXSERVICE_H
+#define DESIGN_PATTERNS_ITAXSERVICE_H
+
+#include <string>
+#include <string_view>
+
+#include "types/ReportFormat.h"
+
+namespace services
+{
+    using ReportStatus = std::string;
+
+    class ITaxService
+    {
+    public:
+
+        virtual ~ITaxService() = default;
+
+        virtual ReportStatus onReportRequest(const std::string &) = 0;
+    };
+}
+#endif //DESIGN_PATTERNS_ITAXSERVICE_H

app/servers/interfaces/services/ITaxServiceFactory.h

@@ -0,0 +1,26 @@
+//
+// Created by sajith on 6/28/22.
+//
+
+#ifndef DESIGN_PATTERNS_ITAXSERVICEFACTORY_H
+#define DESIGN_PATTERNS_ITAXSERVICEFACTORY_H
+
+#include <memory>
+#include "ITaxService.h"
+#include "types/ReportFormat.h"
+#include "types/User.h"
+
+
+namespace services
+{
+    class ITaxServiceFactory
+    {
+    public:
+
+        virtual ~ITaxServiceFactory() = default;
+
+        virtual std::unique_ptr<ITaxService> create(const types::User &) const = 0;
+    };
+}
+
+#endif //DESIGN_PATTERNS_ITAXSERVICEFACTORY_H

app/servers/src/ReportSession.cpp

@@ -0,0 +1,91 @@
+//
+// Created by sajith on 6/28/22.
+//
+
+
+#include "servers/ReportSession.h"
+
+#include <iostream>
+#include <stdexcept>
+
+#include "constants/Constants.h"
+#include "types/User.h"
+
+namespace
+{
+    std::size_t read(tcp::socket &sock, char *buff, const std::size_t n)
+    {
+        boost::system::error_code error;
+        const auto readLength = sock.read_some(boost::asio::buffer(buff, n), error);
+        std::cout << "Received " << readLength << " bytes\n";
+
+        if (error == boost::asio::error::eof)
+        {
+            return 0;
+        }
+        else if (error)
+        {
+            throw boost::system::system_error{error};
+        }
+        return readLength;
+    }
+}
+
+
+namespace servers
+{
+    ReportSession::ReportSession(tcp::socket sk, const auth::IAuthentication &aManager,
+                                 const parsers::ICredentialsParser &pser,
+                                 const services::ITaxServiceFactory &tSF) : sock{std::move(sk)}, authManager{aManager},
+                                                                            parser{pser}, taxServiceFactory{tSF}
+    {}
+
+    std::optional<types::User> ReportSession::loginUser()
+    {
+        if (const auto length = read(sock, data, MAX_LENGTH))
+        {
+            const auto user = parser.parseCredentials({data, length});
+            if (user && authManager.authenticate(user->login, user->password))
+            {
+                return user;
+            }
+        }
+        return std::nullopt;
+    }
+
+    void ReportSession::start() try
+    {
+        if (const auto user = loginUser())
+        {
+            boost::asio::write(sock, boost::asio::buffer(constants::OK.data(), constants::OK.size()));
+
+            for (auto taxService = taxServiceFactory.create(*user);;)
+            {
+                if (const auto length = read(sock, data, MAX_LENGTH))
+                {
+                    const auto response = taxService->onReportRequest({data, length});
+                    boost::asio::write(sock, boost::asio::buffer(response.data(), response.size()));
+                }
+                else
+                {
+                    stop();
+                }
+            }
+        }
+        else
+        {
+            boost::asio::write(sock, boost::asio::buffer(constants::NOK.data(), constants::NOK.size()));
+            stop();
+            std::cerr << __FILE__ << " Failed to login a user for tax reporting\n";
+        }
+    }catch (const std::exception &e)
+    {
+        std::cerr<<__FILE__<<' '<< __LINE__ <<' '<<e.what()<<'\n';
+    }
+
+
+    void ReportSession::stop()
+    {
+
+    }
+}

app/servers/src/Server.cpp

@@ -0,0 +1,3 @@
+//
+// Created by sajith on 6/28/22.
+//