forked from community/device-mgt-core
parent
974fc46e54
commit
eeab5b2d40
@ -0,0 +1,89 @@
|
||||
/*
|
||||
* Copyright (c) 2018 - 2024, Entgra (Pvt) Ltd. (http://www.entgra.io) All Rights Reserved.
|
||||
*
|
||||
* Entgra (Pvt) Ltd. 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.
|
||||
*/
|
||||
|
||||
package io.entgra.device.mgt.core.device.mgt.core.internal;
|
||||
|
||||
import com.google.gson.Gson;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.exceptions.MetadataManagementException;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.exceptions.TransactionManagementException;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.metadata.mgt.Metadata;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.metadata.mgt.MetadataManagementService;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.mgt.dao.OperationDAO;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.mgt.dao.OperationManagementDAOException;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.mgt.dao.OperationManagementDAOFactory;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.dto.OperationConfig;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
import org.wso2.carbon.core.ServerStartupObserver;
|
||||
|
||||
public class OperationStartupHandler implements ServerStartupObserver {
|
||||
private static final Log log = LogFactory.getLog(OperationStartupHandler.class);
|
||||
private static final Gson gson = new Gson();
|
||||
private final OperationDAO operationDAO = OperationManagementDAOFactory.getOperationDAO();
|
||||
private static final String OPERATION_CONFIG = "OPERATION_CONFIG";
|
||||
|
||||
@Override
|
||||
public void completingServerStartup() {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void completedServerStartup() {
|
||||
|
||||
MetadataManagementService metadataManagementService = DeviceManagementDataHolder.getInstance().getMetadataManagementService();
|
||||
Metadata metadata;
|
||||
int numOfRecordsUpdated;
|
||||
|
||||
try {
|
||||
metadata = metadataManagementService.retrieveMetadata(OPERATION_CONFIG);
|
||||
if (metadata != null) {
|
||||
OperationConfig operationConfiguration = gson.fromJson(metadata.getMetaValue(), OperationConfig.class);
|
||||
String[] deviceTypes = operationConfiguration.getDeviceTypes();
|
||||
String initialOperationStatus = operationConfiguration.getInitialOperationStatus();
|
||||
String requiredStatusChange = operationConfiguration.getRequiredStatusChange();
|
||||
|
||||
for (String deviceType: deviceTypes) {
|
||||
try {
|
||||
OperationManagementDAOFactory.beginTransaction();
|
||||
try {
|
||||
numOfRecordsUpdated = operationDAO.updateOperationByDeviceTypeAndInitialStatus(deviceType,
|
||||
initialOperationStatus, requiredStatusChange);
|
||||
log.info(numOfRecordsUpdated + " operations updated successfully for the" + deviceType);
|
||||
OperationManagementDAOFactory.commitTransaction();
|
||||
} catch (OperationManagementDAOException e) {
|
||||
OperationManagementDAOFactory.rollbackTransaction();
|
||||
String msg = "Error occurred while updating operation status. DeviceType : " + deviceType + ", " +
|
||||
"Initial operation status: " + initialOperationStatus + ", Required status:" + requiredStatusChange;
|
||||
log.error(msg, e);
|
||||
}
|
||||
} catch (TransactionManagementException e) {
|
||||
String msg = "Transactional error occurred while updating the operation status";
|
||||
log.error(msg, e);
|
||||
} finally {
|
||||
OperationManagementDAOFactory.closeConnection();
|
||||
}
|
||||
}
|
||||
} else {
|
||||
log.info("Operation configuration not provided");
|
||||
}
|
||||
} catch (MetadataManagementException e) {
|
||||
String msg = "Error occurred while retrieving the operation configuration";
|
||||
log.error(msg, e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,124 @@
|
||||
/*
|
||||
* Copyright (c) 2018 - 2024, Entgra (Pvt) Ltd. (http://www.entgra.io) All Rights Reserved.
|
||||
*
|
||||
* Entgra (Pvt) Ltd. 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.
|
||||
*/
|
||||
|
||||
package io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task;
|
||||
|
||||
import com.google.gson.Gson;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.exceptions.MetadataKeyAlreadyExistsException;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.exceptions.MetadataKeyNotFoundException;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.exceptions.MetadataManagementException;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.metadata.mgt.Metadata;
|
||||
import io.entgra.device.mgt.core.device.mgt.common.metadata.mgt.MetadataManagementService;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.internal.DeviceManagementDataHolder;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.dto.OperationConfig;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.exceptions.OperationConfigAlreadyExistsException;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.exceptions.OperationConfigException;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.exceptions.OperationConfigNotFoundException;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
||||
public class OperationConfigurationService {
|
||||
|
||||
private static final Log log = LogFactory.getLog(OperationConfigurationService.class);
|
||||
private static final Gson gson = new Gson();
|
||||
private static final String STRING = "STRING";
|
||||
private static final String OPERATION_CONFIG = "OPERATION_CONFIG";
|
||||
static MetadataManagementService metadataManagementService = DeviceManagementDataHolder.getInstance().getMetadataManagementService();
|
||||
|
||||
|
||||
public static OperationConfig getOperationConfig() throws OperationConfigException {
|
||||
|
||||
Metadata metadata;
|
||||
try {
|
||||
metadata = metadataManagementService.retrieveMetadata(OPERATION_CONFIG);
|
||||
} catch (MetadataManagementException e) {
|
||||
String msg = "Error occurred while retrieving metadata";
|
||||
log.error(msg, e);
|
||||
throw new OperationConfigException(e);
|
||||
}
|
||||
if (metadata != null) {
|
||||
return gson.fromJson(metadata.getMetaValue(), OperationConfig.class);
|
||||
} else {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
public static void addOperationConfiguration(OperationConfig config) throws OperationConfigException,
|
||||
OperationConfigAlreadyExistsException, OperationConfigNotFoundException {
|
||||
|
||||
if (config == null) {
|
||||
String msg = "Operation configuration is not provided";
|
||||
log.error(msg);
|
||||
throw new OperationConfigNotFoundException(msg);
|
||||
}
|
||||
Metadata metadata = new Metadata();
|
||||
metadata.setDataType(STRING);
|
||||
metadata.setMetaKey(OPERATION_CONFIG);
|
||||
metadata.setMetaValue(gson.toJson(config));
|
||||
|
||||
try {
|
||||
metadataManagementService.createMetadata(metadata);
|
||||
} catch (MetadataManagementException e) {
|
||||
String msg = "Error occurred while adding metadata";
|
||||
log.error(msg, e);
|
||||
throw new OperationConfigException(e);
|
||||
} catch (MetadataKeyAlreadyExistsException e) {
|
||||
String msg = "Metadata key already exists";
|
||||
log.error(msg, e);
|
||||
throw new OperationConfigAlreadyExistsException(e);
|
||||
}
|
||||
}
|
||||
|
||||
public static void updateOperationConfiguration(OperationConfig config) throws OperationConfigException, OperationConfigNotFoundException {
|
||||
|
||||
if (config == null) {
|
||||
String msg = "Operation configuration is not provided";
|
||||
log.error(msg);
|
||||
throw new OperationConfigNotFoundException(msg);
|
||||
}
|
||||
|
||||
Metadata metadata = new Metadata();
|
||||
metadata.setDataType(STRING);
|
||||
metadata.setMetaKey(OPERATION_CONFIG);
|
||||
metadata.setMetaValue(gson.toJson(config));
|
||||
|
||||
try {
|
||||
metadataManagementService.updateMetadata(metadata);
|
||||
} catch (MetadataManagementException e) {
|
||||
String msg = "Error occurred while updating metadata";
|
||||
log.error(msg, e);
|
||||
throw new OperationConfigException(e);
|
||||
}
|
||||
}
|
||||
|
||||
public static void deleteOperationConfiguration() throws OperationConfigException, OperationConfigNotFoundException {
|
||||
|
||||
try {
|
||||
metadataManagementService.deleteMetadata(OPERATION_CONFIG);
|
||||
} catch (MetadataManagementException e) {
|
||||
String msg = "Error occurred while deleting metadata";
|
||||
log.error(msg, e);
|
||||
throw new OperationConfigException(e);
|
||||
} catch (MetadataKeyNotFoundException e) {
|
||||
String msg = "Metadata key already exists";
|
||||
log.error(msg, e);
|
||||
throw new OperationConfigNotFoundException(e);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,55 @@
|
||||
/*
|
||||
* Copyright (c) 2018 - 2024, Entgra (Pvt) Ltd. (http://www.entgra.io) All Rights Reserved.
|
||||
*
|
||||
* Entgra (Pvt) Ltd. 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.
|
||||
*/
|
||||
|
||||
package io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.dto;
|
||||
|
||||
/**
|
||||
* DTO for Operation configuration.
|
||||
*/
|
||||
|
||||
public class OperationConfig {
|
||||
|
||||
private String[] deviceTypes;
|
||||
private String initialOperationStatus;
|
||||
private String requiredStatusChange;
|
||||
|
||||
public String[] getDeviceTypes() {
|
||||
return deviceTypes;
|
||||
}
|
||||
|
||||
public void setDeviceTypes(String[] deviceTypes) {
|
||||
this.deviceTypes = deviceTypes;
|
||||
}
|
||||
|
||||
public String getInitialOperationStatus() {
|
||||
return initialOperationStatus;
|
||||
}
|
||||
|
||||
public void setInitialOperationStatus(String initialOperationStatus) {
|
||||
this.initialOperationStatus = initialOperationStatus;
|
||||
}
|
||||
|
||||
public String getRequiredStatusChange() {
|
||||
return requiredStatusChange;
|
||||
}
|
||||
|
||||
public void setRequiredStatusChange(String requiredStatusChange) {
|
||||
this.requiredStatusChange = requiredStatusChange;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,60 @@
|
||||
/*
|
||||
* Copyright (c) 2018 - 2024, Entgra (Pvt) Ltd. (http://www.entgra.io) All Rights Reserved.
|
||||
*
|
||||
* Entgra (Pvt) Ltd. 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.
|
||||
*/
|
||||
|
||||
package io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.exceptions;
|
||||
|
||||
/**
|
||||
* Custom exception class to be used in operation configuration service related functionalities.
|
||||
*/
|
||||
public class OperationConfigAlreadyExistsException extends Exception {
|
||||
|
||||
private static final long serialVersionUID = -1814347544027733436L;
|
||||
private String errorMessage;
|
||||
|
||||
public String getErrorMessage() {
|
||||
return errorMessage;
|
||||
}
|
||||
|
||||
public void setErrorMessage(String errorMessage) {
|
||||
this.errorMessage = errorMessage;
|
||||
}
|
||||
|
||||
public OperationConfigAlreadyExistsException(String msg, Exception nestedEx) {
|
||||
super(msg, nestedEx);
|
||||
setErrorMessage(msg);
|
||||
}
|
||||
|
||||
public OperationConfigAlreadyExistsException(String message, Throwable cause) {
|
||||
super(message, cause);
|
||||
setErrorMessage(message);
|
||||
}
|
||||
|
||||
public OperationConfigAlreadyExistsException(String msg) {
|
||||
super(msg);
|
||||
setErrorMessage(msg);
|
||||
}
|
||||
|
||||
public OperationConfigAlreadyExistsException() {
|
||||
super();
|
||||
}
|
||||
|
||||
public OperationConfigAlreadyExistsException(Throwable cause) {
|
||||
super(cause);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,60 @@
|
||||
/*
|
||||
* Copyright (c) 2018 - 2024, Entgra (Pvt) Ltd. (http://www.entgra.io) All Rights Reserved.
|
||||
*
|
||||
* Entgra (Pvt) Ltd. 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.
|
||||
*/
|
||||
|
||||
package io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.exceptions;
|
||||
|
||||
/**
|
||||
* Custom exception class to be used in operation configuration related functionalities.
|
||||
*/
|
||||
public class OperationConfigException extends Exception {
|
||||
|
||||
private static final long serialVersionUID = -8933146283800122661L;
|
||||
private String errorMessage;
|
||||
|
||||
public String getErrorMessage() {
|
||||
return errorMessage;
|
||||
}
|
||||
|
||||
public void setErrorMessage(String errorMessage) {
|
||||
this.errorMessage = errorMessage;
|
||||
}
|
||||
|
||||
public OperationConfigException(String msg, Exception nestedEx) {
|
||||
super(msg, nestedEx);
|
||||
setErrorMessage(msg);
|
||||
}
|
||||
|
||||
public OperationConfigException(String message, Throwable cause) {
|
||||
super(message, cause);
|
||||
setErrorMessage(message);
|
||||
}
|
||||
|
||||
public OperationConfigException(String msg) {
|
||||
super(msg);
|
||||
setErrorMessage(msg);
|
||||
}
|
||||
|
||||
public OperationConfigException() {
|
||||
super();
|
||||
}
|
||||
|
||||
public OperationConfigException(Throwable cause) {
|
||||
super(cause);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,60 @@
|
||||
/*
|
||||
* Copyright (c) 2018 - 2023, Entgra (Pvt) Ltd. (http://www.entgra.io) All Rights Reserved.
|
||||
*
|
||||
* Entgra (Pvt) Ltd. 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.
|
||||
*/
|
||||
|
||||
package io.entgra.device.mgt.core.device.mgt.core.operation.change.status.task.exceptions;
|
||||
|
||||
/**
|
||||
* Custom exception class to be used in Operation configuration related functionalities.
|
||||
*/
|
||||
public class OperationConfigNotFoundException extends Exception {
|
||||
|
||||
private static final long serialVersionUID = 5260831982626354815L;
|
||||
private String errorMessage;
|
||||
|
||||
public String getErrorMessage() {
|
||||
return errorMessage;
|
||||
}
|
||||
|
||||
public void setErrorMessage(String errorMessage) {
|
||||
this.errorMessage = errorMessage;
|
||||
}
|
||||
|
||||
public OperationConfigNotFoundException(String msg, Exception nestedEx) {
|
||||
super(msg, nestedEx);
|
||||
setErrorMessage(msg);
|
||||
}
|
||||
|
||||
public OperationConfigNotFoundException(String message, Throwable cause) {
|
||||
super(message, cause);
|
||||
setErrorMessage(message);
|
||||
}
|
||||
|
||||
public OperationConfigNotFoundException(String msg) {
|
||||
super(msg);
|
||||
setErrorMessage(msg);
|
||||
}
|
||||
|
||||
public OperationConfigNotFoundException() {
|
||||
super();
|
||||
}
|
||||
|
||||
public OperationConfigNotFoundException(Throwable cause) {
|
||||
super(cause);
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in new issue