This repository has been archived by the owner on Jun 29, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
add SendMessageToGroupMessageHandler
- Loading branch information
Showing
7 changed files
with
203 additions
and
4 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
50 changes: 50 additions & 0 deletions
50
...geHandlers/messages/sendMessageToGroupMessageHandler/SendMessageToGroupMessageHandler.cpp
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,50 @@ | ||
| #include "SendMessageToGroupMessageHandler.h" | ||
|
|
||
| #include <loguru.hpp> | ||
| #include <nlohmann/json.hpp> | ||
| #include <regex> | ||
|
|
||
| namespace server::api | ||
| { | ||
| SendMessageToGroupMessageHandler::SendMessageToGroupMessageHandler( | ||
| std::shared_ptr<application::TokenService> tokenServiceInit, | ||
| std::unique_ptr<application::CreateGroupMessageCommandHandler> createGroupMessageCommandHandlerInit) | ||
| : tokenService{std::move(tokenServiceInit)}, | ||
| createGroupMessageCommandHandler{std::move(createGroupMessageCommandHandlerInit)} | ||
| { | ||
| } | ||
|
|
||
| common::messages::Message | ||
| SendMessageToGroupMessageHandler::handleMessage(const common::messages::Message& message) const | ||
| { | ||
| try | ||
| { | ||
| auto payloadJson = nlohmann::json::parse(static_cast<std::string>(message.payload)); | ||
|
|
||
| auto token = payloadJson["token"].get<std::string>(); | ||
| auto groupId = payloadJson["data"]["groupId"].get<std::string>(); | ||
| auto text = payloadJson["data"]["text"].get<std::string>(); | ||
|
|
||
| auto [senderId] = tokenService->verifyToken(token); | ||
|
|
||
| auto [newMessage] = createGroupMessageCommandHandler->execute({text, senderId, groupId}); | ||
|
|
||
| nlohmann::json responsePayload; | ||
|
|
||
| responsePayload["data"]["message"] = { | ||
| {"id", newMessage.getId()}, | ||
| {"text", newMessage.getContent()}, | ||
| {"senderName", newMessage.getSender()->getNickname()}, | ||
| {"sentAt", newMessage.getCreatedAt()}, | ||
| }; | ||
|
|
||
| return {common::messages::MessageId::SendPrivateMessageResponse, common::bytes::Bytes{responsePayload.dump()}}; | ||
| } | ||
| catch (const std::exception& e) | ||
| { | ||
| nlohmann::json responsePayload{{"error", e.what()}}; | ||
|
|
||
| return {common::messages::MessageId::SendPrivateMessageResponse, common::bytes::Bytes{responsePayload.dump()}}; | ||
| } | ||
| } | ||
| } |
24 changes: 24 additions & 0 deletions
24
...sageHandlers/messages/sendMessageToGroupMessageHandler/SendMessageToGroupMessageHandler.h
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,24 @@ | ||
| #pragma once | ||
|
|
||
| #include <memory> | ||
|
|
||
| #include "../../MessageHandler.h" | ||
| #include "server/application/commandHandlers/message/createGroupMessageCommandHandler/CreateGroupMessageCommandHandler.h" | ||
| #include "server/application/services/tokenService/TokenService.h" | ||
|
|
||
| namespace server::api | ||
| { | ||
| class SendMessageToGroupMessageHandler : public MessageHandler | ||
| { | ||
| public: | ||
| SendMessageToGroupMessageHandler( | ||
| std::shared_ptr<application::TokenService> tokenService, | ||
| std::unique_ptr<application::CreateGroupMessageCommandHandler> createGroupMessageCommandHandler); | ||
|
|
||
| common::messages::Message handleMessage(const common::messages::Message& message) const override; | ||
|
|
||
| private: | ||
| std::shared_ptr<application::TokenService> tokenService; | ||
| std::unique_ptr<application::CreateGroupMessageCommandHandler> createGroupMessageCommandHandler; | ||
| }; | ||
| } |
113 changes: 113 additions & 0 deletions
113
...ndlers/messages/sendMessageToGroupMessageHandler/SendMessageToGroupMessageHandlerTest.cpp
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,113 @@ | ||
| #include "SendMessageToGroupMessageHandler.h" | ||
|
|
||
| #include <gtest/gtest.h> | ||
|
|
||
| #include "server/application/commandHandlers/message/createGroupMessageCommandHandler/CreateGroupMessageCommandHandlerMock.h" | ||
| #include "server/application/services/tokenService/TokenServiceMock.h" | ||
|
|
||
| #include "faker-cxx/String.h" | ||
| #include "nlohmann/json.hpp" | ||
| #include "server/tests/factories/groupTestFactory/GroupTestFactory.h" | ||
| #include "server/tests/factories/messageTestFactory/MessageTestFactory.h" | ||
| #include "server/tests/factories/userTestFactory/UserTestFactory.h" | ||
|
|
||
| using namespace server::api; | ||
| using namespace ::testing; | ||
|
|
||
| namespace | ||
| { | ||
| const auto invalidTokenError = std::runtime_error{"invalidToken"}; | ||
| const auto invalidTokenMessageResponse = common::messages::Message{ | ||
| common::messages::MessageId::SendPrivateMessageResponse, common::bytes::Bytes{R"({"error":"invalidToken"})"}}; | ||
|
|
||
| const auto createChannelMessageCommandHandlerError = std::runtime_error{"createGroupMessageCommandHandlerError"}; | ||
| const auto createChannelMessageCommandHandlerErrorMessageResponse = | ||
| common::messages::Message{common::messages::MessageId::SendPrivateMessageResponse, | ||
| common::bytes::Bytes{R"({"error":"createGroupMessageCommandHandlerError"})"}}; | ||
| } | ||
|
|
||
| class SendMessageToGroupMessageHandlerTest : public Test | ||
| { | ||
| public: | ||
| server::tests::UserTestFactory userTestFactory; | ||
| server::tests::GroupTestFactory groupTestFactory; | ||
| server::tests::MessageTestFactory messageTestFactory; | ||
|
|
||
| std::string token = faker::String::alphanumeric(40); | ||
| const std::shared_ptr<server::domain::User> messageSender = userTestFactory.createDomainUser(); | ||
| server::application::VerifyTokenResult verifyTokenResult{messageSender->getId()}; | ||
|
|
||
| const std::shared_ptr<server::domain::Group> messageGroup = groupTestFactory.createDomainGroup(); | ||
| const std::shared_ptr<server::domain::Message> message = | ||
| messageTestFactory.createDomainMessage(messageSender, nullptr, messageGroup); | ||
| nlohmann::json validPayloadJson{ | ||
| {"data", nlohmann::json{{"groupId", messageGroup->getId()}, {"text", message->getContent()}}}, | ||
| {"token", token}}; | ||
| common::bytes::Bytes validPayload{validPayloadJson.dump()}; | ||
| common::messages::Message validMessage{common::messages::MessageId::SendPrivateMessage, validPayload}; | ||
|
|
||
| std::shared_ptr<server::application::TokenServiceMock> tokenServiceMock = | ||
| std::make_shared<StrictMock<server::application::TokenServiceMock>>(); | ||
|
|
||
| std::unique_ptr<server::application::CreateGroupMessageCommandHandlerMock> | ||
| createGroupMessageCommandHandlerMockInit = | ||
| std::make_unique<StrictMock<server::application::CreateGroupMessageCommandHandlerMock>>(); | ||
|
|
||
| server::application::CreateGroupMessageCommandHandlerMock* createGroupMessageCommandHandlerMock = | ||
| createGroupMessageCommandHandlerMockInit.get(); | ||
|
|
||
| SendMessageToGroupMessageHandler sendMessageToGroupMessageHandler{ | ||
| tokenServiceMock, std::move(createGroupMessageCommandHandlerMockInit)}; | ||
| }; | ||
|
|
||
| TEST_F(SendMessageToGroupMessageHandlerTest, handleValidSendChannelMessage) | ||
| { | ||
| const auto validCommandHandlerResponse = server::application::CreateGroupMessageCommandHandlerResult{*message}; | ||
| const auto validCommandHandlerResponseJson = nlohmann::json{{"data", | ||
| {{"message", | ||
| {{"id", message->getId()}, | ||
| {"text", message->getContent()}, | ||
| {"senderName", messageSender->getNickname()}, | ||
| {"sentAt", message->getCreatedAt()}}}}}}; | ||
| auto commandPayload = server::application::CreateGroupMessageCommandHandlerPayload{ | ||
| message->getContent(), messageSender->getId(), messageGroup->getId()}; | ||
| nlohmann::json validPayloadJson{ | ||
| {"data", nlohmann::json{{"groupId", messageGroup->getId()}, {"text", message->getContent()}}}, | ||
| {"token", token}}; | ||
| common::bytes::Bytes validPayload{validPayloadJson.dump()}; | ||
| common::messages::Message validMessage{common::messages::MessageId::SendPrivateMessage, validPayload}; | ||
|
|
||
| const auto validMessageResponse = | ||
| common::messages::Message{common::messages::MessageId::SendPrivateMessageResponse, | ||
| common::bytes::Bytes{validCommandHandlerResponseJson.dump()}}; | ||
|
|
||
| EXPECT_CALL(*tokenServiceMock, verifyToken(token)).WillOnce(Return(verifyTokenResult)); | ||
| EXPECT_CALL(*createGroupMessageCommandHandlerMock, execute(commandPayload)) | ||
| .WillOnce(Return(validCommandHandlerResponse)); | ||
|
|
||
| auto responseMessage = sendMessageToGroupMessageHandler.handleMessage(validMessage); | ||
|
|
||
| EXPECT_EQ(responseMessage, validMessageResponse); | ||
| } | ||
|
|
||
| TEST_F(SendMessageToGroupMessageHandlerTest, handleSendChannelMessageWithInvalidToken) | ||
| { | ||
| EXPECT_CALL(*tokenServiceMock, verifyToken(token)).WillOnce(Throw(invalidTokenError)); | ||
|
|
||
| auto responseMessage = sendMessageToGroupMessageHandler.handleMessage(validMessage); | ||
|
|
||
| EXPECT_EQ(responseMessage, invalidTokenMessageResponse); | ||
| } | ||
|
|
||
| TEST_F(SendMessageToGroupMessageHandlerTest, handleSendChannelMessageWithCreateChannelMessageCommandHandlerError) | ||
| { | ||
| EXPECT_CALL(*tokenServiceMock, verifyToken(token)).WillOnce(Return(verifyTokenResult)); | ||
| auto commandPayload = server::application::CreateGroupMessageCommandHandlerPayload{ | ||
| message->getContent(), messageSender->getId(), messageGroup->getId()}; | ||
| EXPECT_CALL(*createGroupMessageCommandHandlerMock, execute(commandPayload)) | ||
| .WillOnce(Throw(createChannelMessageCommandHandlerError)); | ||
|
|
||
| auto responseMessage = sendMessageToGroupMessageHandler.handleMessage(validMessage); | ||
|
|
||
| EXPECT_EQ(responseMessage, createChannelMessageCommandHandlerErrorMessageResponse); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters