Add load/save config for fbs

openDAQ · Nov 19, 2024 · 45eb97d · 45eb97d
1 parent 8665e6c
commit 45eb97d
Show file tree

Hide file tree

Showing 6 changed files with 73 additions and 8 deletions.
diff --git a/asam_cmp_capture_module/src/capture_module.cpp b/asam_cmp_capture_module/src/capture_module.cpp
@@ -18,8 +18,8 @@ DictPtr<IString, IFunctionBlockType> CaptureModule::onGetAvailableFunctionBlockT
 {
     auto types = Dict<IString, IFunctionBlockType>();
 
-    auto typeStatistics = CaptureModuleFb::CreateType();
-    types.set(typeStatistics.getId(), typeStatistics);
+    auto typeCaptureModule = CaptureModuleFb::CreateType();
+    types.set(typeCaptureModule.getId(), typeCaptureModule);
 
     return types;
 }

diff --git a/asam_cmp_common_lib/include/asam_cmp_common_lib/capture_common_fb.h b/asam_cmp_common_lib/include/asam_cmp_common_lib/capture_common_fb.h
@@ -34,6 +34,9 @@ class CaptureCommonFbImpl : public FunctionBlockImpl<IFunctionBlock, Interfaces.
 
     static FunctionBlockTypePtr CreateType();
 
+    DictPtr<IString, IFunctionBlockType> onGetAvailableFunctionBlockTypes() override;
+    FunctionBlockPtr onAddFunctionBlock(const StringPtr& typeId, const PropertyObjectPtr& config) override;
+
 protected:
     void initDeviceInfoProperties(bool readOnly);
     template <class Impl, typename... Params>
@@ -155,9 +158,8 @@ FunctionBlockPtr CaptureCommonFbImpl<Interfaces...>::addInterfaceWithParams(uint
     StringPtr fbId = fmt::format("Interface_{}", createdInterfaces++);
     auto newFb = createWithImplementation<IFunctionBlock, Impl>(this->context, this->functionBlocks, fbId, init, std::forward<Params>(params)...);
     newFb.setName(fbName);
-    this->functionBlocks.addItem(newFb);
     interfaceIdManager.addId(interfaceId);
-
+    addNestedFunctionBlock(newFb);
     return newFb;
 }
 
@@ -248,4 +250,24 @@ void CaptureCommonFbImpl<Interfaces...>::propertyChangedIfNotUpdating()
         needsPropertyChanged = true;
 }
 
+template <typename... Interfaces>
+DictPtr<IString, IFunctionBlockType> CaptureCommonFbImpl<Interfaces...>::onGetAvailableFunctionBlockTypes()
+{
+    auto type = InterfaceCommonFb::CreateType();
+    return Dict<IString, IFunctionBlockType>({{type.getId(), type}});
+}
+
+template <typename... Interfaces>
+FunctionBlockPtr CaptureCommonFbImpl<Interfaces...>::onAddFunctionBlock(const StringPtr& typeId, const PropertyObjectPtr& config)
+{
+    if (typeId == InterfaceCommonFb::CreateType().getId())
+    {
+        addInterface();
+        auto interfaceFb = this->functionBlocks.getItems().getItemAt(this->functionBlocks.getItems().getCount() - 1);
+        return interfaceFb;
+    }
+
+    throw NotFoundException("Function block not found");
+}
+
 END_NAMESPACE_ASAM_CMP_COMMON
diff --git a/asam_cmp_common_lib/include/asam_cmp_common_lib/interface_common_fb.h b/asam_cmp_common_lib/include/asam_cmp_common_lib/interface_common_fb.h
@@ -44,6 +44,8 @@ class InterfaceCommonFb : public FunctionBlock
     ~InterfaceCommonFb() override = default;
     static FunctionBlockTypePtr CreateType();
 
+    DictPtr<IString, IFunctionBlockType> onGetAvailableFunctionBlockTypes() override;
+    FunctionBlockPtr onAddFunctionBlock(const StringPtr& typeId, const PropertyObjectPtr& config) override;
 protected:
     template <class Impl, typename... Params>
     FunctionBlockPtr addStreamWithParams(uint8_t streamId, Params&&... params);
@@ -94,9 +96,8 @@ FunctionBlockPtr InterfaceCommonFb::addStreamWithParams(uint8_t streamId, Params
     StringPtr fbId = fmt::format("Stream_{}", createdStreams++);
     auto newFb = createWithImplementation<IFunctionBlock, Impl>(context, functionBlocks, fbId, init, std::forward<Params>(params)...);
     newFb.setName(fbName);
-    functionBlocks.addItem(newFb);
     streamIdManager.addId(streamId);
-
+    addNestedFunctionBlock(newFb);
     return newFb;
 }
 

diff --git a/asam_cmp_common_lib/src/interface_common_fb.cpp b/asam_cmp_common_lib/src/interface_common_fb.cpp
@@ -151,4 +151,23 @@ void InterfaceCommonFb::propertyChangedIfNotUpdating()
         needsPropertyChanged = true;
 }
 
+
+DictPtr<IString, IFunctionBlockType> InterfaceCommonFb::onGetAvailableFunctionBlockTypes()
+{
+    auto type = StreamCommonFb::CreateType();
+    return Dict<IString, IFunctionBlockType>({{type.getId(), type}});
+}
+
+FunctionBlockPtr InterfaceCommonFb::onAddFunctionBlock(const StringPtr& typeId, const PropertyObjectPtr& config)
+{
+    if (typeId == StreamCommonFb::CreateType().getId())
+    {
+        addStream();
+        auto streamFb = this->functionBlocks.getItems().getItemAt(this->functionBlocks.getItems().getCount() - 1);
+        return streamFb;
+    }
+
+    throw NotFoundException("Function block not found");
+}
+
 END_NAMESPACE_ASAM_CMP_COMMON
diff --git a/asam_cmp_data_sink/include/asam_cmp_data_sink/data_sink_fb.h b/asam_cmp_data_sink/include/asam_cmp_data_sink/data_sink_fb.h
@@ -38,6 +38,9 @@ class DataSinkFb final : public FunctionBlock
 
     static FunctionBlockTypePtr CreateType();
 
+    DictPtr<IString, IFunctionBlockType> onGetAvailableFunctionBlockTypes() override;
+    FunctionBlockPtr onAddFunctionBlock(const StringPtr& typeId, const PropertyObjectPtr& config) override;
+
 private:
     void initProperties();
     void addCaptureModuleFromStatus(int index);

diff --git a/asam_cmp_data_sink/src/data_sink_fb.cpp b/asam_cmp_data_sink/src/data_sink_fb.cpp
@@ -33,7 +33,8 @@ void DataSinkFb::addCaptureModuleFromStatus(int index)
     const StringPtr fbId = getFbId(captureModuleId);
     const auto newFb = createWithImplementation<IFunctionBlock, CaptureFb>(
         context, functionBlocks, fbId, dataPacketsPublisher, capturePacketsPublisher, std::move(deviceStatus));
-    functionBlocks.addItem(newFb);
+    //functionBlocks.addItem(newFb);
+    addNestedFunctionBlock(newFb);
     ++captureModuleId;
 }
 
@@ -44,7 +45,8 @@ void DataSinkFb::addCaptureModuleEmpty()
     const StringPtr fbId = getFbId(captureModuleId);
     const auto newFb =
         createWithImplementation<IFunctionBlock, CaptureFb>(context, functionBlocks, fbId, dataPacketsPublisher, capturePacketsPublisher);
-    functionBlocks.addItem(newFb);
+    //functionBlocks.addItem(newFb);
+    addNestedFunctionBlock(newFb);
     capturePacketsPublisher.subscribe(newFb.getPropertyValue("DeviceId"), newFb.as<IAsamCmpPacketsSubscriber>(true));
     ++captureModuleId;
 }
@@ -100,4 +102,22 @@ void DataSinkFb::initProperties()
     objPtr.asPtr<IPropertyObjectProtected>().setProtectedPropertyValue(propName, proc);
 }
 
+DictPtr<IString, IFunctionBlockType> DataSinkFb::onGetAvailableFunctionBlockTypes()
+{
+    auto type = CaptureFb::CreateType();
+    return Dict<IString, IFunctionBlockType>({{type.getId(), type}});
+}
+
+FunctionBlockPtr DataSinkFb::onAddFunctionBlock(const StringPtr& typeId, const PropertyObjectPtr& config)
+{
+    if (typeId == CaptureFb::CreateType().getId())
+    {
+        addCaptureModuleEmpty();
+        auto captureFb = this->functionBlocks.getItems().getItemAt(this->functionBlocks.getItems().getCount() - 1);
+        return captureFb;
+    }
+
+    throw NotFoundException("Function block not found");
+}
+
 END_NAMESPACE_ASAM_CMP_DATA_SINK_MODULE