MINIFICPP-2669 - Reduce controller service api

Closes #2065

Signed-off-by: Marton Szasz <szaszm@apache.org>

Author: adamdebreceni

CONTROLLERS.md

@@ -209,7 +209,7 @@ In the list below, the names of required properties appear in bold. Any other pr
 | **Max Throughput**    | 1 MB          |                  | Max throughput ( per second ) for these network controllers                           |
 | **Max Payload**       | 1 GB          |                  | Maximum payload for these network controllers                                         |
 | **Verify Interfaces** | true          | true<br/>false   | Verify that interfaces are operational                                                |
-| Default Prioritizer   | false         | true<br/>false   | Sets this controller service as the default prioritizer for all comms                 |
+| Default Prioritizer   | false         | true<br/>false   | DEPRECATED, does not do anything                                                      |
 
 
 ## ODBCService

controller/MiNiFiController.cpp

@@ -30,7 +30,6 @@
 #include "c2/ControllerSocketProtocol.h"
 #include "controllers/SSLContextService.h"
 #include "core/ConfigurationFactory.h"
-#include "minifi-cpp/core/controller/ControllerService.h"
 #include "core/extension/ExtensionManager.h"
 #include "properties/Configure.h"
 #include "range/v3/algorithm/contains.hpp"
@@ -42,8 +41,7 @@ std::shared_ptr<minifi::controllers::SSLContextServiceInterface> getSSLContextSe
   std::shared_ptr<minifi::controllers::SSLContextServiceInterface> secure_context;
   std::string secure_str;
   if (configuration->get(minifi::Configure::nifi_remote_input_secure, secure_str) && minifi::utils::string::toBool(secure_str).value_or(false)) {
-    secure_context = std::make_shared<minifi::controllers::SSLContextService>("ControllerSocketProtocolSSL", configuration);
-    secure_context->onEnable();
+    secure_context = minifi::controllers::SSLContextService::createAndEnable("ControllerSocketProtocolSSL", configuration);
   }
 
   return secure_context;

controller/tests/ControllerTests.cpp

@@ -228,8 +228,7 @@ class ControllerTestFixture {
     configuration_->set(minifi::Configure::nifi_security_client_private_key, (minifi::utils::file::FileUtils::get_executable_dir() / "resources" / "minifi-cpp-flow.key").string());
     configuration_->set(minifi::Configure::nifi_security_client_pass_phrase, "abcdefgh");
     configuration_->set(minifi::Configure::nifi_security_client_ca_certificate, (minifi::utils::file::FileUtils::get_executable_dir() / "resources" / "root-ca.pem").string());
-    ssl_context_service_ = std::make_shared<controllers::SSLContextService>("SSLContextService", configuration_);
-    ssl_context_service_->onEnable();
+    ssl_context_service_ = controllers::SSLContextService::createAndEnable("SSLContextService", configuration_);
     controller_socket_data_.host = "localhost";
     controller_socket_data_.port = 9997;
   }

core-framework/include/core/Resource.h

@@ -30,6 +30,7 @@
 #include "utils/OptionalUtils.h"
 #include "utils/Macro.h"
 #include "core/ProcessorFactoryImpl.h"
+#include "core/controller/ControllerServiceFactoryImpl.h"
 #include "core/ObjectFactory.h"
 #include "minifi-cpp/agent/agent_version.h"
 
@@ -62,6 +63,11 @@ class StaticClassType {
         auto factory = std::unique_ptr<ProcessorFactory>(new ProcessorFactoryImpl<Class>(module_name));
         getClassLoader().registerClass(construction_name, std::move(factory));
       }
+    } else if constexpr (Type == ResourceType::ControllerService) {
+      for (const auto& construction_name : construction_names_) {
+        auto factory = std::unique_ptr<controller::ControllerServiceFactory>(new controller::ControllerServiceFactoryImpl<Class>(module_name));
+        getClassLoader().registerClass(construction_name, std::move(factory));
+      }
     } else {
       for (const auto& construction_name : construction_names_) {
         auto factory = std::unique_ptr<ObjectFactory>(new DefaultObjectFactory<Class>(module_name));

core-framework/include/core/controller/ControllerService.h

@@ -0,0 +1,114 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 <memory>
+#include <string>
+#include <utility>
+#include <vector>
+
+#include "minifi-cpp/properties/Configure.h"
+#include "core/Core.h"
+#include "core/ConfigurableComponentImpl.h"
+#include "core/Connectable.h"
+#include "minifi-cpp/core/controller/ControllerServiceApi.h"
+#include "minifi-cpp/core/controller/ControllerServiceHandle.h"
+#include "minifi-cpp/core/ControllerServiceApiDefinition.h"
+#include "minifi-cpp/core/controller/ControllerServiceMetadata.h"
+
+#define ADD_COMMON_VIRTUAL_FUNCTIONS_FOR_CONTROLLER_SERVICES \
+  bool supportsDynamicProperties() const override { return SupportsDynamicProperties; }
+
+namespace org::apache::nifi::minifi::core::controller {
+
+class ControllerServiceBase : public ControllerServiceApi {
+ public:
+  explicit ControllerServiceBase(ControllerServiceMetadata metadata)
+      : name_(std::move(metadata.name)),
+        uuid_(metadata.uuid),
+        logger_(std::move(metadata.logger)) {}
+
+  virtual void initialize() = 0;
+
+  void initialize(ControllerServiceDescriptor& descriptor) final {
+    gsl_Expects(!descriptor_);
+    descriptor_ = &descriptor;
+    auto guard = gsl::finally([&] {descriptor_ = nullptr;});
+    initialize();
+  }
+
+  void setSupportedProperties(std::span<const PropertyReference> properties) {
+    gsl_Expects(descriptor_);
+    descriptor_->setSupportedProperties(properties);
+  }
+
+  ControllerServiceBase(const ControllerServiceBase&) = delete;
+  ControllerServiceBase(ControllerServiceBase&&) = delete;
+  ControllerServiceBase& operator=(const ControllerServiceBase&) = delete;
+  ControllerServiceBase& operator=(ControllerServiceBase&&) = delete;
+
+  ~ControllerServiceBase() noexcept override = default;
+
+  virtual void onEnable() = 0;
+
+  void onEnable(ControllerServiceContext& context, const std::shared_ptr<Configure>& configuration, const std::vector<std::shared_ptr<ControllerServiceHandle>>& linked_services) final {
+    configuration_ = configuration;
+    linked_services_ = linked_services;
+    gsl_Expects(!context_);
+    context_ = &context;
+    auto guard = gsl::finally([&] {context_ = nullptr;});
+    onEnable();
+  }
+
+  [[nodiscard]] nonstd::expected<std::string, std::error_code> getProperty(std::string_view name) const {
+    gsl_Expects(context_);
+    return context_->getProperty(name);
+  }
+
+  [[nodiscard]] nonstd::expected<std::vector<std::string>, std::error_code> getAllPropertyValues(std::string_view name) const {
+    gsl_Expects(context_);
+    return context_->getAllPropertyValues(name);
+  }
+
+  void notifyStop() override {}
+
+  std::string getName() const {
+    return name_;
+  }
+
+  utils::Identifier getUUID() const {
+    return uuid_;
+  }
+
+
+  static constexpr auto ImplementsApis = std::array<ControllerServiceApiDefinition, 0>{};
+
+ protected:
+  std::string name_;
+  utils::Identifier uuid_;
+  std::vector<std::shared_ptr<controller::ControllerServiceHandle> > linked_services_;
+  std::shared_ptr<Configure> configuration_;
+  // valid during initialize, sink for supported properties
+  ControllerServiceDescriptor* descriptor_{nullptr};
+  // valid during onEnable, provides property access
+  ControllerServiceContext* context_{nullptr};
+
+  std::shared_ptr<core::logging::Logger> logger_;
+};
+
+}  // namespace org::apache::nifi::minifi::core::controller

core-framework/include/core/controller/ControllerServiceBase.h

@@ -1,5 +1,4 @@
 /**
- *
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
@@ -15,40 +14,44 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 #pragma once
 
-#include <memory>
 #include <string>
+#include <memory>
 #include <utility>
-#include <vector>
-
-#include "minifi-cpp/properties/Configure.h"
-#include "minifi-cpp/core/ConfigurableComponent.h"
-#include "minifi-cpp/core/Connectable.h"
+#include "core/ClassName.h"
+#include "minifi-cpp/core/controller/ControllerServiceFactory.h"
 
 namespace org::apache::nifi::minifi::core::controller {
 
-enum ControllerServiceState {
-  DISABLED,
-  DISABLING,
-  ENABLING,
-  ENABLED
-};
-
-/**
- * Controller Service base class that contains some pure virtual methods.
- *
- * Design: OnEnable is executed when the controller service is being enabled.
- * Note that keeping state here must be protected  in this function.
- */
-class ControllerService : public virtual ConfigurableComponent, public virtual Connectable {
+template<class T>
+class ControllerServiceFactoryImpl : public ControllerServiceFactory {
  public:
-  virtual void setConfiguration(const std::shared_ptr<Configure> &configuration) = 0;
-  virtual ControllerServiceState getState() const = 0;
-  virtual void onEnable() = 0;
-  virtual void notifyStop() = 0;
-  virtual void setState(ControllerServiceState state) = 0;
-  virtual void setLinkedControllerServices(const std::vector<std::shared_ptr<controller::ControllerService>> &services) = 0;
+  ControllerServiceFactoryImpl()
+      : class_name_(core::className<T>()) {
+  }
+
+  explicit ControllerServiceFactoryImpl(std::string group_name)
+      : group_name_(std::move(group_name)),
+        class_name_(core::className<T>()) {
+  }
+
+  std::string getGroupName() const override {
+    return group_name_;
+  }
+
+  std::unique_ptr<ControllerServiceApi> create(ControllerServiceMetadata metadata) override {
+    return std::make_unique<T>(metadata);
+  }
+
+  std::string getClassName() const override {
+    return std::string{class_name_};
+  }
+
+ protected:
+  std::string group_name_;
+  std::string_view class_name_;
 };
 
 }  // namespace org::apache::nifi::minifi::core::controller

…-cpp/core/controller/ControllerService.h …ontroller/ControllerServiceFactoryImpl.hminifi-api/include/minifi-cpp/core/controller/ControllerService.h renamed to core-framework/include/core/controller/ControllerServiceFactoryImpl.h minifi-api/include/minifi-cpp/core/controller/ControllerService.h renamed to core-framework/include/core/controller/ControllerServiceFactoryImpl.h

@@ -45,6 +45,7 @@
 #include "minifi-cpp/core/logging/Logger.h"
 #include "core/logging/LoggerFactory.h"
 #include "minifi-cpp/controllers/SSLContextServiceInterface.h"
+#include "minifi-cpp/core/PropertyDefinition.h"
 #include "utils/ByteArrayCallback.h"
 
 namespace org::apache::nifi::minifi::http {