Refactor: break up event_service_manager.hpp
'class Subscription' can be extracted into a separate file.
No changes have been made to the code.
Tested:
- Using Redfish Event Listener, test subscriptions and eventing.
- Redfish Service Validator passes
Change-Id: Id0076ef617e36cbb85629a386a4511a4fdb5e4da
Signed-off-by: Alexander Hansen <alexander.hansen@9elements.com>
diff --git a/redfish-core/include/subscription.hpp b/redfish-core/include/subscription.hpp
new file mode 100644
index 0000000..62f7826
--- /dev/null
+++ b/redfish-core/include/subscription.hpp
@@ -0,0 +1,93 @@
+/*
+Copyright (c) 2020 Intel Corporation
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+#pragma once
+#include "event_logs_object_type.hpp"
+#include "event_service_store.hpp"
+#include "filter_expr_parser_ast.hpp"
+#include "metric_report.hpp"
+#include "server_sent_event.hpp"
+
+#include <boost/asio/io_context.hpp>
+#include <boost/url/url_view_base.hpp>
+
+#include <memory>
+#include <string>
+
+namespace redfish
+{
+
+static constexpr const char* subscriptionTypeSSE = "SSE";
+
+static constexpr const uint8_t maxNoOfSubscriptions = 20;
+static constexpr const uint8_t maxNoOfSSESubscriptions = 10;
+
+class Subscription : public std::enable_shared_from_this<Subscription>
+{
+ public:
+ Subscription(const Subscription&) = delete;
+ Subscription& operator=(const Subscription&) = delete;
+ Subscription(Subscription&&) = delete;
+ Subscription& operator=(Subscription&&) = delete;
+
+ Subscription(std::shared_ptr<persistent_data::UserSubscription> userSubIn,
+ const boost::urls::url_view_base& url,
+ boost::asio::io_context& ioc);
+
+ explicit Subscription(crow::sse_socket::Connection& connIn);
+
+ ~Subscription() = default;
+
+ // callback for subscription sendData
+ void resHandler(const std::shared_ptr<Subscription>& /*unused*/,
+ const crow::Response& res);
+
+ bool sendEventToSubscriber(std::string&& msg);
+
+ bool sendTestEventLog();
+
+ void filterAndSendEventLogs(
+ const std::vector<EventLogObjectsType>& eventRecords);
+
+ void filterAndSendReports(const std::string& reportId,
+ const telemetry::TimestampReadings& var);
+
+ void updateRetryConfig(uint32_t retryAttempts,
+ uint32_t retryTimeoutInterval);
+
+ uint64_t getEventSeqNum() const;
+
+ bool matchSseId(const crow::sse_socket::Connection& thisConn);
+
+ // Check used to indicate what response codes are valid as part of our retry
+ // policy. 2XX is considered acceptable
+ static boost::system::error_code retryRespHandler(unsigned int respCode);
+
+ std::shared_ptr<persistent_data::UserSubscription> userSub;
+ std::function<void()> deleter;
+
+ private:
+ uint64_t eventSeqNum = 1;
+ boost::urls::url host;
+ std::shared_ptr<crow::ConnectionPolicy> policy;
+ crow::sse_socket::Connection* sseConn = nullptr;
+
+ std::optional<crow::HttpClient> client;
+
+ public:
+ std::optional<filter_ast::LogicalAnd> filter;
+};
+
+} // namespace redfish