Add Tenanted Device Task Configurations

This allowing users to configure task frequencies independently for each tenant.

+            String deviceType = entry.getKey();
+            int frequency = entry.getValue();
+            // Create a JsonObject for the current device type
+            JsonObject deviceObject = new JsonObject();

+
+    private static final Log log = LogFactory.getLog(DeviceTaskConfigurationServiceImpl.class);
+
+    private final MetadataDAO metadataDAO;

+            DeviceManagementProviderService dms = DeviceManagementDataHolder.getInstance().getDeviceManagementProvider();
+            List<DeviceType> deviceTypes = dms.getDeviceTypes();
+            for (DeviceType deviceType : deviceTypes) {
+                deviceFrequencies.put(deviceType.getName(), getDefaultTaskFrequency(dms, deviceType.getName()));

+    }
+
+    @Override
+    public void completedServerStartup() {

+        this.metadataDAO = MetadataManagementDAOFactory.getMetadataDAO();
+    }
+
+    private void addMetadataEntry(int tenantId, Metadata metadata, String key) throws MetadataManagementDAOException {

+        metadata.setMetaValue(jsonObject.toString());
+        return metadata;
+    }
+

+    }
+
+
+    private int getDefaultTaskFrequency(DeviceManagementProviderService dms, String deviceType) {

+
+
+    private int getDefaultTaskFrequency(DeviceManagementProviderService dms, String deviceType) {
+        OperationMonitoringTaskConfig operationMonitoringTaskConfig = dms.getDeviceMonitoringConfig(deviceType);

+            for (DeviceType deviceType : deviceTypes) {
+                deviceFrequencies.put(deviceType.getName(), frequency);
+            }
+            MetadataManagementDAOFactory.beginTransaction();

+                // Retrieve the frequency for the given device type
+                return deviceFrequencyMap.get(deviceType).getFrequency();
+            } else {
+                throw new MetadataManagementException("Device type not found: " + deviceType);

+    }
+
+    @Override
+    public void completedServerStartup() {

+                            }
+                        }
+                    } catch (MetadataManagementException e) {
+                        String msg = "Error occurred while adding default task frequency metadata entry.";

             log.error("Error occurred while trying to get the available tenants " +
                     "from device manager provider service.", e);
+        } catch (MetadataManagementException e) {
+            String msg = "Error occurred while getting task frequency metadata entry.";

             log.error("Error occurred while trying to add the operations to " +
                       "device to retrieve device details.", e);
+        } catch (MetadataManagementException e) {
+            String msg = "Error occurred while getting task frequency metadata entry.";

+                    }
+                    try {
+                        deviceTaskConfigurationService.addDefaultTaskFrequency(MultitenantConstants.SUPER_TENANT_ID);
+                        Tenant[] tenantArray = realmService.getTenantManager().getAllTenants();

                     getDeviceTaskManagerService();
             OperationMonitoringTaskConfig operationMonitoringTaskConfig = deviceManagementService.
                     getOperationMonitoringConfig();
+            TaskManagementService taskManagementService= DeviceManagementDataHolder.getInstance().getTaskManagementService();

         }
     }
 
+    private void startTasksForTenant(Map<String, OperationMonitoringTaskConfig> deviceConfigMap,DeviceTaskManagerService deviceTaskManagerService) throws DeviceMgtTaskException {

+
+    private final MetadataManagementService metadataManagementService;
+
+    private static DeviceTaskConfigurationServiceImpl instance;

      */
-    void updateTask(String deviceType, OperationMonitoringTaskConfig operationMonitoringTaskConfig)
-            throws DeviceMgtTaskException;
+    void updateTask(int taskId,DeviceTaskManagerWrapper deviceTaskManagerWrapper)

+            try {
+                PrivilegedCarbonContext.startTenantFlow();
+                PrivilegedCarbonContext.getThreadLocalCarbonContext().setTenantId(tenantId, true);
+                this.executeTask(operationMonitoringTaskConfig, startupOperationConfig, Utils.getTenantedTaskFrequency(tenantId, deviceType));

+    public boolean isTaskExist(String taskName) throws TaskManagementException {
+        int tenantId = PrivilegedCarbonContext.getThreadLocalCarbonContext().getTenantId();
+        try {
+            TaskManagementDAOFactory.beginTransaction();

+            log.error(msg, e);
+            throw new TenantMgtException(msg, e);
+        } catch (DeviceManagementException e) {
+            throw new TenantMgtException("Error occurred while getting DeviceManagementService", e);