From 72baa17f792a1e4b5cb562989efd98fe06f50eaf Mon Sep 17 00:00:00 2001 From: LucioDonda Date: Tue, 10 Dec 2024 20:37:40 +0000 Subject: [PATCH] fix: clang format correction --- .../include/configuration_parser.hpp | 4 ++-- src/agent/multitype_queue/include/imultitype_queue.hpp | 10 ++++++---- src/agent/multitype_queue/include/persistence.hpp | 9 ++++----- src/agent/multitype_queue/src/multitype_queue.cpp | 4 ++-- src/agent/multitype_queue/src/sqlitestorage.hpp | 2 +- src/agent/tests/message_queue_utils_test.cpp | 1 - 6 files changed, 15 insertions(+), 15 deletions(-) diff --git a/src/agent/configuration_parser/include/configuration_parser.hpp b/src/agent/configuration_parser/include/configuration_parser.hpp index 02f8cbedc7..97779d8ebf 100644 --- a/src/agent/configuration_parser/include/configuration_parser.hpp +++ b/src/agent/configuration_parser/include/configuration_parser.hpp @@ -56,8 +56,8 @@ namespace configuration /// @return The corresponding size_t value. /// @throws std::invalid_argument if the string does not represent a valid size unit. /// @details This function parses a string representing a size unit and returns the equivalent size_t - /// value. The size unit can be expressed in Bytes (e.g. "1B"), Mega bytes (e.g. "1M" or "1MB"), kilo bytes (e.g. - /// "1K" or "1KB"). If no unit is specified, the value is assumed to be in Bytes + /// value. The size unit can be expressed in Bytes (e.g. "1B"), Mega bytes (e.g. "1M" or "1MB"), kilo bytes + /// (e.g. "1K" or "1KB"). If no unit is specified, the value is assumed to be in Bytes std::size_t ParseSizeUnit(const std::string& option) const; public: diff --git a/src/agent/multitype_queue/include/imultitype_queue.hpp b/src/agent/multitype_queue/include/imultitype_queue.hpp index 5bc27b16d9..44b5f78119 100644 --- a/src/agent/multitype_queue/include/imultitype_queue.hpp +++ b/src/agent/multitype_queue/include/imultitype_queue.hpp @@ -7,6 +7,7 @@ #include #include #include + /** * @brief Interface for a multi-type message queue. * @@ -66,10 +67,11 @@ class IMultiTypeQueue * @param moduleType The type of the module requesting the messages. * @return boost::asio::awaitable> Awaitable object representing the next N messages. */ - virtual boost::asio::awaitable> getNextNAwaitable(MessageType type, - std::variant messageQuantity, - const std::string moduleName = "", - const std::string moduleType = "") = 0; + virtual boost::asio::awaitable> + getNextNAwaitable(MessageType type, + std::variant messageQuantity, + const std::string moduleName = "", + const std::string moduleType = "") = 0; /** * @brief Retrieves the next N messages from the queue. diff --git a/src/agent/multitype_queue/include/persistence.hpp b/src/agent/multitype_queue/include/persistence.hpp index 0ca2e7b8fc..213039d2ab 100644 --- a/src/agent/multitype_queue/include/persistence.hpp +++ b/src/agent/multitype_queue/include/persistence.hpp @@ -3,8 +3,8 @@ #include #include -#include #include +#include /** * @brief Interface for persistence storage. @@ -91,7 +91,6 @@ class Persistence */ virtual int GetElementCount(const std::string& queueName, const std::string& moduleName = "") = 0; - /** * @brief Get the bytes occupied by elements stored in the specified queue. * @@ -110,7 +109,7 @@ class Persistence * @return nlohmann::json The retrieved JSON messages. */ virtual nlohmann::json RetrieveBySize(size_t n, - const std::string& queueName, - const std::string& moduleName = "", - const std::string& moduleType = "") = 0; + const std::string& queueName, + const std::string& moduleName = "", + const std::string& moduleType = "") = 0; }; diff --git a/src/agent/multitype_queue/src/multitype_queue.cpp b/src/agent/multitype_queue/src/multitype_queue.cpp index 1904ac5b03..9e2447d2f2 100644 --- a/src/agent/multitype_queue/src/multitype_queue.cpp +++ b/src/agent/multitype_queue/src/multitype_queue.cpp @@ -209,8 +209,8 @@ std::vector MultiTypeQueue::getNextN(MessageType type, sizeRequested = availableSize; } LogInfo("Requesting {}B of {}B", sizeRequested, availableSize); - arrayData = m_persistenceDest->RetrieveBySize( - sizeRequested, m_mapMessageTypeName.at(type), moduleName, moduleType); + arrayData = + m_persistenceDest->RetrieveBySize(sizeRequested, m_mapMessageTypeName.at(type), moduleName, moduleType); } else { diff --git a/src/agent/multitype_queue/src/sqlitestorage.hpp b/src/agent/multitype_queue/src/sqlitestorage.hpp index a379f1f692..bbb7817548 100644 --- a/src/agent/multitype_queue/src/sqlitestorage.hpp +++ b/src/agent/multitype_queue/src/sqlitestorage.hpp @@ -164,7 +164,7 @@ class SQLiteStorage : public Persistence /** * @brief Intermediate function for processing Retrieve queries. - */ + */ nlohmann::json ProcessRequest(SQLite::Statement& sqlStatementQuery, size_t maxSize = 0); /** diff --git a/src/agent/tests/message_queue_utils_test.cpp b/src/agent/tests/message_queue_utils_test.cpp index 0f3fb06d1a..cb731a0f14 100644 --- a/src/agent/tests/message_queue_utils_test.cpp +++ b/src/agent/tests/message_queue_utils_test.cpp @@ -88,7 +88,6 @@ TEST_F(MessageQueueUtilsTest, GetMessagesFromQueueMetadataTest) nlohmann::json metadata; metadata["agent"] = "test"; - // NOLINTBEGIN(cppcoreguidelines-avoid-capturing-lambda-coroutines) EXPECT_CALL(*mockQueue, getNextNAwaitable(MessageType::STATELESS, MinMessagesSize, "", "")) .WillOnce([&testMessages]() -> boost::asio::awaitable> { co_return testMessages; });