thasleem
/
device-mgt-core
forked from community/device-mgt-core
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

CDMF-8 fixes

Browse Source
revert-70aa11f8
harshanL 10 years ago
parent 98ac04479d
commit 1736d5db3e
18 changed files with 658 additions and 590 deletions
Show Stats Download Patch File Download Diff File

24
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/DeviceManager.java
Unescape View File

@ -31,26 +31,28 @@ import java.util.List;
*/ */
public interface DeviceManager { public interface DeviceManager {
public boolean enrollDevice(Device device) throws DeviceManagementException; public boolean enrollDevice(Device device) throws DeviceManagementException;
public boolean modifyEnrollment(Device device) throws DeviceManagementException; public boolean modifyEnrollment(Device device) throws DeviceManagementException;
public boolean disenrollDevice(DeviceIdentifier deviceId) throws DeviceManagementException; public boolean disenrollDevice(DeviceIdentifier deviceId) throws DeviceManagementException;
public boolean isEnrolled(DeviceIdentifier deviceId) throws DeviceManagementException; public boolean isEnrolled(DeviceIdentifier deviceId) throws DeviceManagementException;
public boolean isActive(DeviceIdentifier deviceId) throws DeviceManagementException; public boolean isActive(DeviceIdentifier deviceId) throws DeviceManagementException;
public boolean setActive(DeviceIdentifier deviceId, boolean status) throws DeviceManagementException; public boolean setActive(DeviceIdentifier deviceId, boolean status)
throws DeviceManagementException;
public List<Device> getAllDevices(String type) throws DeviceManagementException; public List<Device> getAllDevices(String type) throws DeviceManagementException;
public Device getDevice(DeviceIdentifier deviceId) throws DeviceManagementException; public Device getDevice(DeviceIdentifier deviceId) throws DeviceManagementException;
public boolean updateDeviceInfo(Device device) throws DeviceManagementException; public boolean updateDeviceInfo(Device device) throws DeviceManagementException;
public boolean setOwnership(DeviceIdentifier deviceId, String ownershipType) throws DeviceManagementException; public boolean setOwnership(DeviceIdentifier deviceId, String ownershipType)
throws DeviceManagementException;
public OperationManager getOperationManager(String type) throws DeviceManagementException; public OperationManager getOperationManager(String type) throws DeviceManagementException;
} }

310
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/DeviceManagerImpl.java
Unescape View File

@ -38,149 +38,169 @@ import java.util.List;
public class DeviceManagerImpl implements DeviceManager { public class DeviceManagerImpl implements DeviceManager {
private static Log log = LogFactory.getLog(DeviceManagerImpl.class); private static Log log = LogFactory.getLog(DeviceManagerImpl.class);
private DeviceDAO deviceDAO; private DeviceDAO deviceDAO;
private DeviceTypeDAO deviceTypeDAO; private DeviceTypeDAO deviceTypeDAO;
private DeviceManagementConfig config; private DeviceManagementConfig config;
private DeviceManagementRepository pluginRepository; private DeviceManagementRepository pluginRepository;
public DeviceManagerImpl(DeviceManagementConfig config, DeviceManagementRepository pluginRepository) { public DeviceManagerImpl(DeviceManagementConfig config,
this.config = config; DeviceManagementRepository pluginRepository) {
this.pluginRepository = pluginRepository; this.config = config;
this.deviceDAO = DeviceManagementDAOFactory.getDeviceDAO(); this.pluginRepository = pluginRepository;
this.deviceTypeDAO = DeviceManagementDAOFactory.getDeviceTypeDAO(); this.deviceDAO = DeviceManagementDAOFactory.getDeviceDAO();
} this.deviceTypeDAO = DeviceManagementDAOFactory.getDeviceTypeDAO();
}
@Override
public boolean enrollDevice(Device device) throws DeviceManagementException { @Override
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(device.getType()); public boolean enrollDevice(Device device) throws DeviceManagementException {
boolean status = dms.enrollDevice(device); DeviceManagerService dms =
try { this.getPluginRepository().getDeviceManagementProvider(device.getType());
org.wso2.carbon.device.mgt.core.dto.Device deviceDto = DeviceManagementDAOUtil.convertDevice(device); boolean status = dms.enrollDevice(device);
Integer deviceTypeId = this.getDeviceTypeDAO().getDeviceTypeIdByDeviceTypeName(device.getType()); try {
deviceDto.setStatus(Status.ACTIVE); org.wso2.carbon.device.mgt.core.dto.Device deviceDto =
deviceDto.setDeviceTypeId(deviceTypeId); DeviceManagementDAOUtil.convertDevice(device);
this.getDeviceDAO().addDevice(deviceDto); Integer deviceTypeId =
} catch (DeviceManagementDAOException e) { this.getDeviceTypeDAO().getDeviceTypeIdByDeviceTypeName(device.getType());
throw new DeviceManagementException("Error occurred while enrolling the device '" + device.getId() + "'", deviceDto.setStatus(Status.ACTIVE);
e); deviceDto.setDeviceTypeId(deviceTypeId);
} this.getDeviceDAO().addDevice(deviceDto);
return status; } catch (DeviceManagementDAOException e) {
} throw new DeviceManagementException(
"Error occurred while enrolling the device '" + device.getId() + "'",
@Override e);
public boolean modifyEnrollment(Device device) throws DeviceManagementException { }
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(device.getType()); return status;
boolean status = dms.modifyEnrollment(device); }
try {
this.getDeviceDAO().updateDevice(DeviceManagementDAOUtil.convertDevice(device)); @Override
} catch (DeviceManagementDAOException e) { public boolean modifyEnrollment(Device device) throws DeviceManagementException {
throw new DeviceManagementException("Error occurred while modifying the device '" + device.getId() + "'", DeviceManagerService dms =
e); this.getPluginRepository().getDeviceManagementProvider(device.getType());
} boolean status = dms.modifyEnrollment(device);
return status; try {
} this.getDeviceDAO().updateDevice(DeviceManagementDAOUtil.convertDevice(device));
} catch (DeviceManagementDAOException e) {
@Override throw new DeviceManagementException(
public boolean disenrollDevice(DeviceIdentifier deviceId) throws DeviceManagementException { "Error occurred while modifying the device '" + device.getId() + "'",
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(deviceId.getType()); e);
return dms.disenrollDevice(deviceId); }
} return status;
}
@Override
public boolean isEnrolled(DeviceIdentifier deviceId) throws DeviceManagementException { @Override
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(deviceId.getType()); public boolean disenrollDevice(DeviceIdentifier deviceId) throws DeviceManagementException {
return dms.isEnrolled(deviceId); DeviceManagerService dms =
} this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
return dms.disenrollDevice(deviceId);
@Override }
public boolean isActive(DeviceIdentifier deviceId) throws DeviceManagementException {
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(deviceId.getType()); @Override
return dms.isActive(deviceId); public boolean isEnrolled(DeviceIdentifier deviceId) throws DeviceManagementException {
} DeviceManagerService dms =
this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
@Override return dms.isEnrolled(deviceId);
public boolean setActive(DeviceIdentifier deviceId, boolean status) throws DeviceManagementException { }
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
return dms.setActive(deviceId, status); @Override
} public boolean isActive(DeviceIdentifier deviceId) throws DeviceManagementException {
DeviceManagerService dms =
@Override this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
public List<Device> getAllDevices(String type) throws DeviceManagementException { return dms.isActive(deviceId);
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(type); }
List<Device> devicesList = new ArrayList<Device>();
try { @Override
Integer deviceTypeId = this.getDeviceTypeDAO().getDeviceTypeIdByDeviceTypeName(type); public boolean setActive(DeviceIdentifier deviceId, boolean status)
List<org.wso2.carbon.device.mgt.core.dto.Device> devices = this.getDeviceDAO().getDevices(deviceTypeId); throws DeviceManagementException {
DeviceManagerService dms =
for (org.wso2.carbon.device.mgt.core.dto.Device device : devices) { this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
DeviceType deviceType = this.deviceTypeDAO.getDeviceType(device.getDeviceTypeId()); return dms.setActive(deviceId, status);
Device convertedDevice = DeviceManagementDAOUtil.convertDevice(device, deviceType); }
DeviceIdentifier deviceIdentifier = DeviceManagementDAOUtil.createDeviceIdentifier(device, deviceType);
Device dmsDevice = dms.getDevice(deviceIdentifier); @Override
if (dmsDevice != null) { public List<Device> getAllDevices(String type) throws DeviceManagementException {
convertedDevice.setProperties(dmsDevice.getProperties()); DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(type);
convertedDevice.setFeatures(dmsDevice.getFeatures()); List<Device> devicesList = new ArrayList<Device>();
} try {
devicesList.add(convertedDevice); Integer deviceTypeId = this.getDeviceTypeDAO().getDeviceTypeIdByDeviceTypeName(type);
} List<org.wso2.carbon.device.mgt.core.dto.Device> devices =
} catch (DeviceManagementDAOException e) { this.getDeviceDAO().getDevices(deviceTypeId);
throw new DeviceManagementException("Error occurred while obtaining the device for type '" + type + "'", e);
} for (org.wso2.carbon.device.mgt.core.dto.Device device : devices) {
return devicesList; DeviceType deviceType = this.deviceTypeDAO.getDeviceType(device.getDeviceTypeId());
} Device convertedDevice = DeviceManagementDAOUtil.convertDevice(device, deviceType);
DeviceIdentifier deviceIdentifier =
@Override DeviceManagementDAOUtil.createDeviceIdentifier(device, deviceType);
public Device getDevice(DeviceIdentifier deviceId) throws DeviceManagementException { Device dmsDevice = dms.getDevice(deviceIdentifier);
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(deviceId.getType()); if (dmsDevice != null) {
Device convertedDevice = null; convertedDevice.setProperties(dmsDevice.getProperties());
try { convertedDevice.setFeatures(dmsDevice.getFeatures());
Integer deviceTypeId = this.getDeviceTypeDAO().getDeviceTypeIdByDeviceTypeName(deviceId.getType()); }
org.wso2.carbon.device.mgt.core.dto.Device device = devicesList.add(convertedDevice);
this.getDeviceDAO().getDeviceByDeviceIdentifier(deviceTypeId, deviceId.getId()); }
if (device != null) { } catch (DeviceManagementDAOException e) {
convertedDevice = DeviceManagementDAOUtil throw new DeviceManagementException(
.convertDevice(device, this.getDeviceTypeDAO().getDeviceType(deviceTypeId)); "Error occurred while obtaining the device for type '" + type + "'", e);
Device dmsDevice = dms.getDevice(deviceId); }
if (dmsDevice != null) { return devicesList;
convertedDevice.setProperties(dmsDevice.getProperties()); }
convertedDevice.setFeatures(dmsDevice.getFeatures());
} @Override
} public Device getDevice(DeviceIdentifier deviceId) throws DeviceManagementException {
} catch (DeviceManagementDAOException e) { DeviceManagerService dms =
throw new DeviceManagementException( this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
"Error occurred while obtaining the device for id '" + deviceId.getId() + "'", e); Device convertedDevice = null;
} try {
return convertedDevice; Integer deviceTypeId =
} this.getDeviceTypeDAO().getDeviceTypeIdByDeviceTypeName(deviceId.getType());
org.wso2.carbon.device.mgt.core.dto.Device device =
@Override this.getDeviceDAO().getDeviceByDeviceIdentifier(deviceTypeId, deviceId.getId());
public boolean updateDeviceInfo(Device device) throws DeviceManagementException { if (device != null) {
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(device.getType()); convertedDevice = DeviceManagementDAOUtil
return dms.updateDeviceInfo(device); .convertDevice(device, this.getDeviceTypeDAO().getDeviceType(deviceTypeId));
} Device dmsDevice = dms.getDevice(deviceId);
if (dmsDevice != null) {
@Override convertedDevice.setProperties(dmsDevice.getProperties());
public boolean setOwnership(DeviceIdentifier deviceId, String ownershipType) convertedDevice.setFeatures(dmsDevice.getFeatures());
throws DeviceManagementException { }
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(deviceId.getType()); }
return dms.setOwnership(deviceId, ownershipType); } catch (DeviceManagementDAOException e) {
} throw new DeviceManagementException(
"Error occurred while obtaining the device for id '" + deviceId.getId() + "'",
public OperationManager getOperationManager(String type) throws DeviceManagementException { e);
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(type); }
return dms.getOperationManager(); return convertedDevice;
} }
public DeviceDAO getDeviceDAO() { @Override
return deviceDAO; public boolean updateDeviceInfo(Device device) throws DeviceManagementException {
} DeviceManagerService dms =
this.getPluginRepository().getDeviceManagementProvider(device.getType());
public DeviceTypeDAO getDeviceTypeDAO() { return dms.updateDeviceInfo(device);
return deviceTypeDAO; }
}
@Override
public DeviceManagementRepository getPluginRepository() { public boolean setOwnership(DeviceIdentifier deviceId, String ownershipType)
return pluginRepository; throws DeviceManagementException {
} DeviceManagerService dms =
this.getPluginRepository().getDeviceManagementProvider(deviceId.getType());
return dms.setOwnership(deviceId, ownershipType);
}
public OperationManager getOperationManager(String type) throws DeviceManagementException {
DeviceManagerService dms = this.getPluginRepository().getDeviceManagementProvider(type);
return dms.getOperationManager();
}
public DeviceDAO getDeviceDAO() {
return deviceDAO;
}
public DeviceTypeDAO getDeviceTypeDAO() {
return deviceTypeDAO;
}
public DeviceManagementRepository getPluginRepository() {
return pluginRepository;
}
} }

61
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceConfigurationManager.java
Unescape View File

@ -30,45 +30,46 @@ import javax.xml.bind.Unmarshaller;
import java.io.File; import java.io.File;
/** /**
* Class responsible for the cdm manager configuration initialization * Class responsible for the cdm manager configuration initialization.
*/ */
public class DeviceConfigurationManager { public class DeviceConfigurationManager {
private DeviceManagementConfig currentDeviceConfig; private DeviceManagementConfig currentDeviceConfig;
private static DeviceConfigurationManager deviceConfigManager; private static DeviceConfigurationManager deviceConfigManager;
private static final String deviceMgtConfigXMLPath = CarbonUtils.getCarbonConfigDirPath() + File.separator + private static final String deviceMgtConfigXMLPath =
DeviceManagementConstants.DataSourceProperties.DEVICE_CONFIG_XML_NAME; CarbonUtils.getCarbonConfigDirPath() + File.separator +
DeviceManagementConstants.DataSourceProperties.DEVICE_CONFIG_XML_NAME;
public static DeviceConfigurationManager getInstance() { public static DeviceConfigurationManager getInstance() {
if (deviceConfigManager == null) { if (deviceConfigManager == null) {
synchronized (DeviceConfigurationManager.class) { synchronized (DeviceConfigurationManager.class) {
if (deviceConfigManager == null) { if (deviceConfigManager == null) {
deviceConfigManager = new DeviceConfigurationManager(); deviceConfigManager = new DeviceConfigurationManager();
} }
} }
} }
return deviceConfigManager; return deviceConfigManager;
} }
public synchronized void initConfig() throws DeviceManagementException { public synchronized void initConfig() throws DeviceManagementException {
//catch generic exception.if any exception occurs wrap and throw DeviceManagementException //catch generic exception.if any exception occurs wrap and throw DeviceManagementException
try { try {
File deviceMgtConfig = new File(deviceMgtConfigXMLPath); File deviceMgtConfig = new File(deviceMgtConfigXMLPath);
Document doc = DeviceManagerUtil.convertToDocument(deviceMgtConfig); Document doc = DeviceManagerUtil.convertToDocument(deviceMgtConfig);
/* Un-marshaling Device Management configuration */ /* Un-marshaling Device Management configuration */
JAXBContext cdmContext = JAXBContext.newInstance(DeviceManagementConfig.class); JAXBContext cdmContext = JAXBContext.newInstance(DeviceManagementConfig.class);
Unmarshaller unmarshaller = cdmContext.createUnmarshaller(); Unmarshaller unmarshaller = cdmContext.createUnmarshaller();
this.currentDeviceConfig = (DeviceManagementConfig) unmarshaller.unmarshal(doc); this.currentDeviceConfig = (DeviceManagementConfig) unmarshaller.unmarshal(doc);
} catch (Exception e) { } catch (Exception e) {
throw new DeviceManagementException("Error occurred while initializing RSS config", e); throw new DeviceManagementException("Error occurred while initializing RSS config", e);
} }
} }
public DeviceManagementConfig getDeviceManagementConfig() { public DeviceManagementConfig getDeviceManagementConfig() {
return currentDeviceConfig; return currentDeviceConfig;
} }
} }

2
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/DeviceManagementRepository.java
Unescape View File

@ -22,7 +22,7 @@ import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement; import javax.xml.bind.annotation.XmlRootElement;
/** /**
* Class for holding management repository data * Class for holding management repository data.
*/ */
@XmlRootElement(name = "ManagementRepository") @XmlRootElement(name = "ManagementRepository")
public class DeviceManagementRepository { public class DeviceManagementRepository {

60
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/LicenseConfigurationManager.java
Unescape View File

@ -32,42 +32,42 @@ import java.io.File;
public class LicenseConfigurationManager { public class LicenseConfigurationManager {
private LicenseManagementConfig licenseMgtConfig; private LicenseManagementConfig licenseMgtConfig;
private static LicenseConfigurationManager licenseConfigManager; private static LicenseConfigurationManager licenseConfigManager;
private static final String licenseMgtConfigXMLPath = CarbonUtils.getCarbonConfigDirPath() + File.separator + private static final String licenseMgtConfigXMLPath =
DeviceManagementConstants.Common.DEFAULT_LICENSE_CONFIG_XML_NAME; CarbonUtils.getCarbonConfigDirPath() + File.separator +
DeviceManagementConstants.Common.DEFAULT_LICENSE_CONFIG_XML_NAME;
public static LicenseConfigurationManager getInstance() { public static LicenseConfigurationManager getInstance() {
if (licenseConfigManager == null) { if (licenseConfigManager == null) {
synchronized (LicenseConfigurationManager.class) { synchronized (LicenseConfigurationManager.class) {
if (licenseConfigManager == null) { if (licenseConfigManager == null) {
licenseConfigManager = new LicenseConfigurationManager(); licenseConfigManager = new LicenseConfigurationManager();
} }
} }
} }
return licenseConfigManager; return licenseConfigManager;
} }
public synchronized void initConfig() throws LicenseManagementException { public synchronized void initConfig() throws LicenseManagementException {
//catch generic exception.if any exception occurs wrap and throw LicenseManagementException //catch generic exception.if any exception occurs wrap and throw LicenseManagementException
try { try {
File licenseMgtConfig = new File(licenseMgtConfigXMLPath); File licenseMgtConfig = new File(licenseMgtConfigXMLPath);
Document doc = DeviceManagerUtil.convertToDocument(licenseMgtConfig); Document doc = DeviceManagerUtil.convertToDocument(licenseMgtConfig);
/* Un-marshaling License Management configuration */ /* Un-marshaling License Management configuration */
JAXBContext cdmContext = JAXBContext.newInstance(LicenseManagementConfig.class); JAXBContext cdmContext = JAXBContext.newInstance(LicenseManagementConfig.class);
Unmarshaller unmarshaller = cdmContext.createUnmarshaller(); Unmarshaller unmarshaller = cdmContext.createUnmarshaller();
this.licenseMgtConfig = (LicenseManagementConfig) unmarshaller.unmarshal(doc); this.licenseMgtConfig = (LicenseManagementConfig) unmarshaller.unmarshal(doc);
} catch (Exception e) { } catch (Exception e) {
throw new LicenseManagementException("Error occurred while initializing RSS config", e); throw new LicenseManagementException("Error occurred while initializing RSS config", e);
} }
} }
public LicenseManagementConfig getLicenseMgtConfig() {
return licenseMgtConfig;
}
public LicenseManagementConfig getLicenseMgtConfig() {
return licenseMgtConfig;
}
} }

3
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/datasource/DataSourceConfig.java
Unescape View File

@ -21,7 +21,8 @@ import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement; import javax.xml.bind.annotation.XmlRootElement;
/** /**
* Class for holding data source configuration in malformed-cdm-config-no-mgt-repo.xml at parsing with JAXB * Class for holding data source configuration in malformed-cdm-config-no-mgt-repo.xml at parsing
* with JAXB.
*/ */
@XmlRootElement(name = "DataSourceConfiguration") @XmlRootElement(name = "DataSourceConfiguration")
public class DataSourceConfig { public class DataSourceConfig {

2
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/config/datasource/JNDILookupDefinition.java
Unescape View File

@ -22,7 +22,7 @@ import javax.xml.bind.annotation.*;
import java.util.List; import java.util.List;
/** /**
* Class for hold JndiLookupDefinition of rss-manager.xml at parsing with JAXB * Class for hold JndiLookupDefinition of rss-manager.xml at parsing with JAXB.
*/ */
@XmlRootElement(name = "JndiLookupDefinition") @XmlRootElement(name = "JndiLookupDefinition")
public class JNDILookupDefinition { public class JNDILookupDefinition {

5
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/dao/DeviceDAO.java
Unescape View File

@ -24,7 +24,7 @@ import org.wso2.carbon.device.mgt.core.dto.Status;
import java.util.List; import java.util.List;
/** /**
* This class represents the key operations associated with persisting device related information * This class represents the key operations associated with persisting device related information.
*/ */
public interface DeviceDAO { public interface DeviceDAO {
@ -44,7 +44,8 @@ public interface DeviceDAO {
* @return the Device object which matches given data * @return the Device object which matches given data
* @throws DeviceManagementDAOException * @throws DeviceManagementDAOException
*/ */
Device getDeviceByDeviceIdentifier(Integer type, String identifier) throws DeviceManagementDAOException; Device getDeviceByDeviceIdentifier(Integer type, String identifier)
throws DeviceManagementDAOException;
List<Device> getDevices() throws DeviceManagementDAOException; List<Device> getDevices() throws DeviceManagementDAOException;

2
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/dao/DeviceManagementDAOException.java
Unescape View File

@ -19,7 +19,7 @@
package org.wso2.carbon.device.mgt.core.dao; package org.wso2.carbon.device.mgt.core.dao;
/** /**
* Custom exception class for data access related exceptions * Custom exception class for data access related exceptions.
*/ */
public class DeviceManagementDAOException extends Exception { public class DeviceManagementDAOException extends Exception {

101
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/dao/DeviceManagementDAOFactory.java
Unescape View File

@ -25,64 +25,69 @@ import org.wso2.carbon.device.mgt.core.config.datasource.JNDILookupDefinition;
import org.wso2.carbon.device.mgt.core.dao.impl.DeviceDAOImpl; import org.wso2.carbon.device.mgt.core.dao.impl.DeviceDAOImpl;
import org.wso2.carbon.device.mgt.core.dao.impl.DeviceTypeDAOImpl; import org.wso2.carbon.device.mgt.core.dao.impl.DeviceTypeDAOImpl;
import org.wso2.carbon.device.mgt.core.dao.util.DeviceManagementDAOUtil; import org.wso2.carbon.device.mgt.core.dao.util.DeviceManagementDAOUtil;
import javax.sql.DataSource; import javax.sql.DataSource;
import java.util.Hashtable; import java.util.Hashtable;
import java.util.List; import java.util.List;
public class DeviceManagementDAOFactory { public class DeviceManagementDAOFactory {
private static DataSource dataSource; private static DataSource dataSource;
private static final Log log = LogFactory.getLog(DeviceManagementDAOFactory.class); private static final Log log = LogFactory.getLog(DeviceManagementDAOFactory.class);
public static DeviceDAO getDeviceDAO() { public static DeviceDAO getDeviceDAO() {
return new DeviceDAOImpl(dataSource); return new DeviceDAOImpl(dataSource);
} }
public static DeviceTypeDAO getDeviceTypeDAO() { public static DeviceTypeDAO getDeviceTypeDAO() {
return new DeviceTypeDAOImpl(dataSource); return new DeviceTypeDAOImpl(dataSource);
} }
public static void init(DataSourceConfig config) { public static void init(DataSourceConfig config) {
dataSource = resolveDataSource(config); dataSource = resolveDataSource(config);
} }
public static void init(DataSource dtSource) { public static void init(DataSource dtSource) {
dataSource = dtSource; dataSource = dtSource;
} }
/** /**
* Resolve data source from the data source definition * Resolve data source from the data source definition
* *
* @param config data source configuration * @param config data source configuration
* @return data source resolved from the data source definition * @return data source resolved from the data source definition
*/ */
private static DataSource resolveDataSource(DataSourceConfig config) { private static DataSource resolveDataSource(DataSourceConfig config) {
DataSource dataSource = null; DataSource dataSource = null;
if (config == null) { if (config == null) {
throw new RuntimeException("Device Management Repository data source configuration " + "is null and " + throw new RuntimeException(
"thus, is not initialized"); "Device Management Repository data source configuration " + "is null and " +
} "thus, is not initialized");
JNDILookupDefinition jndiConfig = config.getJndiLookupDefinition(); }
if (jndiConfig != null) { JNDILookupDefinition jndiConfig = config.getJndiLookupDefinition();
if (log.isDebugEnabled()) { if (jndiConfig != null) {
log.debug("Initializing Device Management Repository data source using the JNDI " + if (log.isDebugEnabled()) {
"Lookup Definition"); log.debug("Initializing Device Management Repository data source using the JNDI " +
} "Lookup Definition");
List<JNDILookupDefinition.JNDIProperty> jndiPropertyList = jndiConfig.getJndiProperties(); }
if (jndiPropertyList != null) { List<JNDILookupDefinition.JNDIProperty> jndiPropertyList =
Hashtable<Object, Object> jndiProperties = new Hashtable<Object, Object>(); jndiConfig.getJndiProperties();
for (JNDILookupDefinition.JNDIProperty prop : jndiPropertyList) { if (jndiPropertyList != null) {
jndiProperties.put(prop.getName(), prop.getValue()); Hashtable<Object, Object> jndiProperties = new Hashtable<Object, Object>();
} for (JNDILookupDefinition.JNDIProperty prop : jndiPropertyList) {
dataSource = DeviceManagementDAOUtil.lookupDataSource(jndiConfig.getJndiName(), jndiProperties); jndiProperties.put(prop.getName(), prop.getValue());
} else { }
dataSource = DeviceManagementDAOUtil.lookupDataSource(jndiConfig.getJndiName(), null); dataSource = DeviceManagementDAOUtil
} .lookupDataSource(jndiConfig.getJndiName(), jndiProperties);
} } else {
return dataSource; dataSource =
} DeviceManagementDAOUtil.lookupDataSource(jndiConfig.getJndiName(), null);
}
}
return dataSource;
}
public static DataSource getDataSource() { public static DataSource getDataSource() {
return dataSource; return dataSource;
} }
} }

15
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/dao/DeviceTypeDAO.java
Unescape View File

@ -22,20 +22,21 @@ import org.wso2.carbon.device.mgt.core.dto.DeviceType;
import java.util.List; import java.util.List;
/** /**
* This class represents the key operations associated with persisting device type related information * This class represents the key operations associated with persisting device type related
* information.
*/ */
public interface DeviceTypeDAO { public interface DeviceTypeDAO {
void addDeviceType(DeviceType deviceType) throws DeviceManagementDAOException; void addDeviceType(DeviceType deviceType) throws DeviceManagementDAOException;
void updateDeviceType(DeviceType deviceType) throws DeviceManagementDAOException; void updateDeviceType(DeviceType deviceType) throws DeviceManagementDAOException;
List<DeviceType> getDeviceTypes() throws DeviceManagementDAOException; List<DeviceType> getDeviceTypes() throws DeviceManagementDAOException;
DeviceType getDeviceType(Integer id) throws DeviceManagementDAOException; DeviceType getDeviceType(Integer id) throws DeviceManagementDAOException;
Integer getDeviceTypeIdByDeviceTypeName(String type) throws DeviceManagementDAOException; Integer getDeviceTypeIdByDeviceTypeName(String type) throws DeviceManagementDAOException;
void removeDeviceType(DeviceType deviceType) throws DeviceManagementDAOException; void removeDeviceType(DeviceType deviceType) throws DeviceManagementDAOException;
} }

39
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/dao/impl/DeviceDAOImpl.java
Unescape View File

@ -44,15 +44,16 @@ public class DeviceDAOImpl implements DeviceDAO {
this.dataSource = dataSource; this.dataSource = dataSource;
} }
@Override public void addDevice(Device device) throws DeviceManagementDAOException { @Override
public void addDevice(Device device) throws DeviceManagementDAOException {
Connection conn = null; Connection conn = null;
PreparedStatement stmt = null; PreparedStatement stmt = null;
try { try {
conn = this.getConnection(); conn = this.getConnection();
String createDBQuery = String createDBQuery =
"INSERT INTO DM_DEVICE(DESCRIPTION, NAME, DATE_OF_ENROLLMENT, DATE_OF_LAST_UPDATE, OWNERSHIP," + "INSERT INTO DM_DEVICE(DESCRIPTION, NAME, DATE_OF_ENROLLMENT, DATE_OF_LAST_UPDATE, " +
"STATUS, DEVICE_TYPE_ID, DEVICE_IDENTIFICATION, OWNER, TENANT_ID) VALUES " + "OWNERSHIP, STATUS, DEVICE_TYPE_ID, DEVICE_IDENTIFICATION, OWNER, TENANT_ID) " +
"(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
stmt = conn.prepareStatement(createDBQuery); stmt = conn.prepareStatement(createDBQuery);
stmt.setString(1, device.getDescription()); stmt.setString(1, device.getDescription());
@ -75,23 +76,29 @@ public class DeviceDAOImpl implements DeviceDAO {
} }
} }
@Override public void updateDevice(Device device) throws DeviceManagementDAOException { @Override
public void updateDevice(Device device) throws DeviceManagementDAOException {
} }
@Override public void updateDeviceStatus(Long deviceId, Status status) throws DeviceManagementDAOException { @Override
public void updateDeviceStatus(Long deviceId, Status status)
throws DeviceManagementDAOException {
} }
@Override public void deleteDevice(Long deviceId) throws DeviceManagementDAOException { @Override
public void deleteDevice(Long deviceId) throws DeviceManagementDAOException {
} }
@Override public Device getDeviceByDeviceId(Long deviceId) throws DeviceManagementDAOException { @Override
public Device getDeviceByDeviceId(Long deviceId) throws DeviceManagementDAOException {
return null; return null;
} }
@Override public Device getDeviceByDeviceIdentifier(Integer type, String identifier) @Override
public Device getDeviceByDeviceIdentifier(Integer type, String identifier)
throws DeviceManagementDAOException { throws DeviceManagementDAOException {
Connection conn = null; Connection conn = null;
PreparedStatement stmt = null; PreparedStatement stmt = null;
@ -102,7 +109,8 @@ public class DeviceDAOImpl implements DeviceDAO {
String selectDBQueryForType = "SELECT ID, DESCRIPTION, NAME, DATE_OF_ENROLLMENT, " + String selectDBQueryForType = "SELECT ID, DESCRIPTION, NAME, DATE_OF_ENROLLMENT, " +
"DATE_OF_LAST_UPDATE, OWNERSHIP, STATUS, DEVICE_TYPE_ID, " + "DATE_OF_LAST_UPDATE, OWNERSHIP, STATUS, DEVICE_TYPE_ID, " +
"DEVICE_IDENTIFICATION, OWNER, TENANT_ID FROM DM_DEVICE " + "DEVICE_IDENTIFICATION, OWNER, TENANT_ID FROM DM_DEVICE " +
"WHERE DM_DEVICE.DEVICE_TYPE_ID=? AND DM_DEVICE.DEVICE_IDENTIFICATION=?"; "WHERE DM_DEVICE.DEVICE_TYPE_ID=? AND " +
"DM_DEVICE.DEVICE_IDENTIFICATION=?";
stmt = conn.prepareStatement(selectDBQueryForType); stmt = conn.prepareStatement(selectDBQueryForType);
stmt.setInt(1, type); stmt.setInt(1, type);
stmt.setString(2, identifier); stmt.setString(2, identifier);
@ -132,11 +140,13 @@ public class DeviceDAOImpl implements DeviceDAO {
return device; return device;
} }
@Override public List<Device> getDevices() throws DeviceManagementDAOException { @Override
public List<Device> getDevices() throws DeviceManagementDAOException {
return null; return null;
} }
@Override public List<Device> getDevices(Integer type) throws DeviceManagementDAOException { @Override
public List<Device> getDevices(Integer type) throws DeviceManagementDAOException {
Connection conn = null; Connection conn = null;
PreparedStatement stmt = null; PreparedStatement stmt = null;
ResultSet resultSet = null; ResultSet resultSet = null;
@ -181,8 +191,9 @@ public class DeviceDAOImpl implements DeviceDAO {
try { try {
return dataSource.getConnection(); return dataSource.getConnection();
} catch (SQLException e) { } catch (SQLException e) {
throw new DeviceManagementDAOException("Error occurred while obtaining a connection from the device " + throw new DeviceManagementDAOException(
"management metadata repository datasource", e); "Error occurred while obtaining a connection from the device " +
"management metadata repository datasource", e);
} }
} }

223
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/dao/util/DeviceManagementDAOUtil.java
Unescape View File

@ -40,121 +40,124 @@ import java.util.Hashtable;
public final class DeviceManagementDAOUtil { public final class DeviceManagementDAOUtil {
private static final Log log = LogFactory.getLog(DeviceManagementDAOUtil.class); private static final Log log = LogFactory.getLog(DeviceManagementDAOUtil.class);
public static void cleanupResources(Connection conn, PreparedStatement stmt, ResultSet rs) { public static void cleanupResources(Connection conn, PreparedStatement stmt, ResultSet rs) {
if (rs != null) { if (rs != null) {
try { try {
rs.close(); rs.close();
} catch (SQLException e) { } catch (SQLException e) {
log.warn("Error occurred while closing result set", e); log.warn("Error occurred while closing result set", e);
} }
} }
if (stmt != null) { if (stmt != null) {
try { try {
stmt.close(); stmt.close();
} catch (SQLException e) { } catch (SQLException e) {
log.warn("Error occurred while closing prepared statement", e); log.warn("Error occurred while closing prepared statement", e);
} }
} }
if (conn != null) { if (conn != null) {
try { try {
conn.close(); conn.close();
} catch (SQLException e) { } catch (SQLException e) {
log.warn("Error occurred while closing database connection", e); log.warn("Error occurred while closing database connection", e);
} }
} }
} }
/** /**
* Get id of the current tenant. * Get id of the current tenant.
* *
* @return tenant id * @return tenant id
* @throws DeviceManagementDAOException if an error is observed when getting tenant id * @throws DeviceManagementDAOException if an error is observed when getting tenant id
*/ */
public static int getTenantId() throws DeviceManagementDAOException { public static int getTenantId() throws DeviceManagementDAOException {
CarbonContext context = CarbonContext.getThreadLocalCarbonContext(); CarbonContext context = CarbonContext.getThreadLocalCarbonContext();
int tenantId = context.getTenantId(); int tenantId = context.getTenantId();
if (tenantId != MultitenantConstants.INVALID_TENANT_ID) { if (tenantId != MultitenantConstants.INVALID_TENANT_ID) {
return tenantId; return tenantId;
} }
String tenantDomain = context.getTenantDomain(); String tenantDomain = context.getTenantDomain();
if (tenantDomain == null) { if (tenantDomain == null) {
String msg = "Tenant domain is not properly set and thus, is null"; String msg = "Tenant domain is not properly set and thus, is null";
throw new DeviceManagementDAOException(msg); throw new DeviceManagementDAOException(msg);
} }
TenantManager tenantManager = DeviceManagementDataHolder.getInstance().getTenantManager(); TenantManager tenantManager = DeviceManagementDataHolder.getInstance().getTenantManager();
try { try {
tenantId = tenantManager.getTenantId(tenantDomain); tenantId = tenantManager.getTenantId(tenantDomain);
} catch (UserStoreException e) { } catch (UserStoreException e) {
String msg = "Error occurred while retrieving id from the domain of tenant " + tenantDomain; String msg =
throw new DeviceManagementDAOException(msg); "Error occurred while retrieving id from the domain of tenant " + tenantDomain;
} throw new DeviceManagementDAOException(msg);
return tenantId; }
} return tenantId;
}
public static DataSource lookupDataSource(String dataSourceName, final Hashtable<Object, Object> jndiProperties) { public static DataSource lookupDataSource(String dataSourceName,
try { final Hashtable<Object, Object> jndiProperties) {
if (jndiProperties == null || jndiProperties.isEmpty()) { try {
return (DataSource) InitialContext.doLookup(dataSourceName); if (jndiProperties == null || jndiProperties.isEmpty()) {
} return (DataSource) InitialContext.doLookup(dataSourceName);
final InitialContext context = new InitialContext(jndiProperties); }
return (DataSource) context.lookup(dataSourceName); final InitialContext context = new InitialContext(jndiProperties);
} catch (Exception e) { return (DataSource) context.lookup(dataSourceName);
throw new RuntimeException("Error in looking up data source: " + e.getMessage(), e); } catch (Exception e) {
} throw new RuntimeException("Error in looking up data source: " + e.getMessage(), e);
} }
}
/** /**
* @param device - The DTO device object. * @param device - The DTO device object.
* @param deviceType - The DeviceType object associated with the device * @param deviceType - The DeviceType object associated with the device
* @return A Business Object. * @return A Business Object.
*/ */
public static org.wso2.carbon.device.mgt.common.Device convertDevice(Device device, DeviceType deviceType){ public static org.wso2.carbon.device.mgt.common.Device convertDevice(Device device,
org.wso2.carbon.device.mgt.common.Device deviceBO = DeviceType deviceType) {
new org.wso2.carbon.device.mgt.common.Device(); org.wso2.carbon.device.mgt.common.Device deviceBO =
deviceBO.setDateOfEnrolment(device.getDateOfEnrollment()); new org.wso2.carbon.device.mgt.common.Device();
deviceBO.setDateOfLastUpdate(device.getDateOfLastUpdate()); deviceBO.setDateOfEnrolment(device.getDateOfEnrollment());
deviceBO.setDescription(device.getDescription()); deviceBO.setDateOfLastUpdate(device.getDateOfLastUpdate());
deviceBO.setDeviceIdentifier(device.getDeviceIdentificationId()); deviceBO.setDescription(device.getDescription());
deviceBO.setDeviceTypeId(device.getDeviceTypeId()); deviceBO.setDeviceIdentifier(device.getDeviceIdentificationId());
deviceBO.setType(deviceType.getName()); deviceBO.setDeviceTypeId(device.getDeviceTypeId());
deviceBO.setName(device.getName()); deviceBO.setType(deviceType.getName());
deviceBO.setId(device.getId()); deviceBO.setName(device.getName());
deviceBO.setOwner(device.getOwnerId()); deviceBO.setId(device.getId());
deviceBO.setOwnership(device.getOwnerShip()); deviceBO.setOwner(device.getOwnerId());
if (device.getStatus() == Status.ACTIVE) { deviceBO.setOwnership(device.getOwnerShip());
deviceBO.setStatus(true); if (device.getStatus() == Status.ACTIVE) {
} else if (device.getStatus() == Status.INACTIVE) { deviceBO.setStatus(true);
deviceBO.setStatus(false); } else if (device.getStatus() == Status.INACTIVE) {
} deviceBO.setStatus(false);
return deviceBO; }
} return deviceBO;
}
public static Device convertDevice(org.wso2.carbon.device.mgt.common.Device public static Device convertDevice(org.wso2.carbon.device.mgt.common.Device
device) throws DeviceManagementDAOException { device) throws DeviceManagementDAOException {
Device deviceBO = new Device(); Device deviceBO = new Device();
deviceBO.setDescription(device.getDescription()); deviceBO.setDescription(device.getDescription());
deviceBO.setName(device.getName()); deviceBO.setName(device.getName());
deviceBO.setDateOfEnrollment(device.getDateOfEnrolment()); deviceBO.setDateOfEnrollment(device.getDateOfEnrolment());
deviceBO.setDateOfLastUpdate(device.getDateOfLastUpdate()); deviceBO.setDateOfLastUpdate(device.getDateOfLastUpdate());
if (!device.isStatus()){ if (!device.isStatus()) {
deviceBO.setStatus(Status.INACTIVE); deviceBO.setStatus(Status.INACTIVE);
}else{ } else {
deviceBO.setStatus(Status.ACTIVE); deviceBO.setStatus(Status.ACTIVE);
} }
deviceBO.setOwnerId(device.getOwner()); deviceBO.setOwnerId(device.getOwner());
deviceBO.setOwnerShip(device.getOwnership()); deviceBO.setOwnerShip(device.getOwnership());
deviceBO.setTenantId(DeviceManagementDAOUtil.getTenantId()); deviceBO.setTenantId(DeviceManagementDAOUtil.getTenantId());
deviceBO.setDeviceIdentificationId(device.getDeviceIdentifier()); deviceBO.setDeviceIdentificationId(device.getDeviceIdentifier());
return deviceBO; return deviceBO;
} }
public static DeviceIdentifier createDeviceIdentifier(Device device, DeviceType deviceType) { public static DeviceIdentifier createDeviceIdentifier(Device device, DeviceType deviceType) {
DeviceIdentifier deviceIdentifier = new DeviceIdentifier(); DeviceIdentifier deviceIdentifier = new DeviceIdentifier();
deviceIdentifier.setType(deviceType.getName()); deviceIdentifier.setType(deviceType.getName());
deviceIdentifier.setId(device.getDeviceIdentificationId()); deviceIdentifier.setId(device.getDeviceIdentificationId());
return deviceIdentifier; return deviceIdentifier;
} }
} }

215
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementServiceComponent.java
Unescape View File

@ -52,112 +52,123 @@ import org.wso2.carbon.user.core.service.RealmService;
*/ */
public class DeviceManagementServiceComponent { public class DeviceManagementServiceComponent {
private static Log log = LogFactory.getLog(DeviceManagementServiceComponent.class); private static Log log = LogFactory.getLog(DeviceManagementServiceComponent.class);
private DeviceManagementRepository pluginRepository = new DeviceManagementRepository(); private DeviceManagementRepository pluginRepository = new DeviceManagementRepository();
protected void activate(ComponentContext componentContext) { protected void activate(ComponentContext componentContext) {
try { try {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("Initializing device management core bundle"); log.debug("Initializing device management core bundle");
} }
/* Initializing Device Management Configuration */ /* Initializing Device Management Configuration */
DeviceConfigurationManager.getInstance().initConfig(); DeviceConfigurationManager.getInstance().initConfig();
DeviceManagementConfig config = DeviceConfigurationManager.getInstance().getDeviceManagementConfig(); DeviceManagementConfig config =
DeviceConfigurationManager.getInstance().getDeviceManagementConfig();
DataSourceConfig dsConfig = config.getDeviceMgtRepository().getDataSourceConfig(); DataSourceConfig dsConfig = config.getDeviceMgtRepository().getDataSourceConfig();
DeviceManagementDAOFactory.init(dsConfig); DeviceManagementDAOFactory.init(dsConfig);
DeviceManager deviceManager = new DeviceManagerImpl(config, this.getPluginRepository()); DeviceManager deviceManager = new DeviceManagerImpl(config, this.getPluginRepository());
DeviceManagementDataHolder.getInstance().setDeviceManager(deviceManager); DeviceManagementDataHolder.getInstance().setDeviceManager(deviceManager);
/* If -Dsetup option enabled then create device management database schema */ /* If -Dsetup option enabled then create device management database schema */
String setupOption = System.getProperty(DeviceManagementConstants.Common.PROPERTY_SETUP); String setupOption =
if (setupOption != null) { System.getProperty(DeviceManagementConstants.Common.PROPERTY_SETUP);
if (log.isDebugEnabled()) { if (setupOption != null) {
log.debug("-Dsetup is enabled. Device management repository schema initialization is about " + if (log.isDebugEnabled()) {
"to begin"); log.debug(
} "-Dsetup is enabled. Device management repository schema initialization " +
this.setupDeviceManagementSchema(dsConfig); "is about to begin");
} }
this.setupDeviceManagementSchema(dsConfig);
if (log.isDebugEnabled()) { }
log.debug("Registering OSGi service DeviceManagementService");
} if (log.isDebugEnabled()) {
BundleContext bundleContext = componentContext.getBundleContext(); log.debug("Registering OSGi service DeviceManagementService");
bundleContext.registerService(DeviceManagementService.class.getName(), }
new DeviceManagementService(), null); BundleContext bundleContext = componentContext.getBundleContext();
if (log.isDebugEnabled()) { bundleContext.registerService(DeviceManagementService.class.getName(),
log.debug("Device management core bundle has been successfully initialized"); new DeviceManagementService(), null);
} if (log.isDebugEnabled()) {
} catch (Throwable e) { log.debug("Device management core bundle has been successfully initialized");
String msg = "Error occurred while initializing device management core bundle"; }
log.error(msg, e); } catch (Throwable e) {
} String msg = "Error occurred while initializing device management core bundle";
} log.error(msg, e);
}
private void setupDeviceManagementSchema(DataSourceConfig config) throws DeviceManagementException { }
DeviceManagementSchemaInitializer initializer = new DeviceManagementSchemaInitializer(config);
log.info("Initializing device management repository database schema"); private void setupDeviceManagementSchema(DataSourceConfig config)
throws DeviceManagementException {
try { DeviceManagementSchemaInitializer initializer =
initializer.createRegistryDatabase(); new DeviceManagementSchemaInitializer(config);
} catch (Exception e) { log.info("Initializing device management repository database schema");
throw new DeviceManagementException("Error occurred while initializing Device Management " +
"database schema", e); try {
} initializer.createRegistryDatabase();
if (log.isDebugEnabled()) { } catch (Exception e) {
log.debug("Device management metadata repository schema has been successfully initialized"); throw new DeviceManagementException(
} "Error occurred while initializing Device Management " +
} "database schema", e);
}
/** if (log.isDebugEnabled()) {
* Sets Device Manager service. log.debug(
* @param deviceManagerService An instance of DeviceManagerService "Device management metadata repository schema has been successfully initialized");
*/ }
protected void setDeviceManagerService(DeviceManagerService deviceManagerService) { }
if (log.isDebugEnabled()) {
log.debug("Setting Device Management Service Provider : '" + /**
deviceManagerService.getProviderType() + "'"); * Sets Device Manager service.
} *
this.getPluginRepository().addDeviceManagementProvider(deviceManagerService); * @param deviceManagerService An instance of DeviceManagerService
} */
protected void setDeviceManagerService(DeviceManagerService deviceManagerService) {
/** if (log.isDebugEnabled()) {
* Unsets Device Management service. log.debug("Setting Device Management Service Provider : '" +
* @param deviceManagerService An Instance of DeviceManagerService deviceManagerService.getProviderType() + "'");
*/ }
protected void unsetDeviceManagerService(DeviceManagerService deviceManagerService) { this.getPluginRepository().addDeviceManagementProvider(deviceManagerService);
if (log.isDebugEnabled()) { }
log.debug("Unsetting Device Management Service Provider : '" +
deviceManagerService.getProviderType() + "'"); /**
} * Unsets Device Management service.
this.getPluginRepository().removeDeviceManagementProvider(deviceManagerService); *
} * @param deviceManagerService An Instance of DeviceManagerService
*/
/** protected void unsetDeviceManagerService(DeviceManagerService deviceManagerService) {
* Sets Realm Service. if (log.isDebugEnabled()) {
* @param realmService An instance of RealmService log.debug("Unsetting Device Management Service Provider : '" +
*/ deviceManagerService.getProviderType() + "'");
protected void setRealmService(RealmService realmService) { }
if (log.isDebugEnabled()) { this.getPluginRepository().removeDeviceManagementProvider(deviceManagerService);
log.debug("Setting Realm Service"); }
}
DeviceManagementDataHolder.getInstance().setRealmService(realmService); /**
} * Sets Realm Service.
*
/** * @param realmService An instance of RealmService
* Unsets Realm Service. */
* @param realmService An instance of RealmService protected void setRealmService(RealmService realmService) {
*/ if (log.isDebugEnabled()) {
protected void unsetRealmService(RealmService realmService) { log.debug("Setting Realm Service");
if (log.isDebugEnabled()) { }
log.debug("Unsetting Realm Service"); DeviceManagementDataHolder.getInstance().setRealmService(realmService);
} }
DeviceManagementDataHolder.getInstance().setRealmService(null);
} /**
* Unsets Realm Service.
private DeviceManagementRepository getPluginRepository() { *
return pluginRepository; * @param realmService An instance of RealmService
} */
protected void unsetRealmService(RealmService realmService) {
if (log.isDebugEnabled()) {
log.debug("Unsetting Realm Service");
}
DeviceManagementDataHolder.getInstance().setRealmService(null);
}
private DeviceManagementRepository getPluginRepository() {
return pluginRepository;
}
} }

125
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/service/DeviceManagementService.java
Unescape View File

@ -28,66 +28,69 @@ import java.util.List;
public class DeviceManagementService implements DeviceManager { public class DeviceManagementService implements DeviceManager {
@Override @Override
public boolean enrollDevice(Device device) throws DeviceManagementException { public boolean enrollDevice(Device device) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().enrollDevice(device); return DeviceManagementDataHolder.getInstance().getDeviceManager().enrollDevice(device);
} }
@Override @Override
public boolean modifyEnrollment(Device device) throws DeviceManagementException { public boolean modifyEnrollment(Device device) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().modifyEnrollment(device); return DeviceManagementDataHolder.getInstance().getDeviceManager().modifyEnrollment(device);
} }
@Override @Override
public boolean disenrollDevice(DeviceIdentifier deviceId) throws DeviceManagementException { public boolean disenrollDevice(DeviceIdentifier deviceId) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager() return DeviceManagementDataHolder.getInstance().getDeviceManager()
.disenrollDevice(deviceId); .disenrollDevice(deviceId);
} }
@Override @Override
public boolean isEnrolled(DeviceIdentifier deviceId) throws DeviceManagementException { public boolean isEnrolled(DeviceIdentifier deviceId) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().isEnrolled(deviceId); return DeviceManagementDataHolder.getInstance().getDeviceManager().isEnrolled(deviceId);
} }
@Override @Override
public boolean isActive(DeviceIdentifier deviceId) throws DeviceManagementException { public boolean isActive(DeviceIdentifier deviceId) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().isActive(deviceId); return DeviceManagementDataHolder.getInstance().getDeviceManager().isActive(deviceId);
} }
@Override @Override
public boolean setActive(DeviceIdentifier deviceId, boolean status) throws DeviceManagementException { public boolean setActive(DeviceIdentifier deviceId, boolean status)
return DeviceManagementDataHolder.getInstance().getDeviceManager().setActive(deviceId, status); throws DeviceManagementException {
} return DeviceManagementDataHolder.getInstance().getDeviceManager()
.setActive(deviceId, status);
@Override }
public List<Device> getAllDevices(String type) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().getAllDevices(type); @Override
} public List<Device> getAllDevices(String type) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().getAllDevices(type);
@Override }
public org.wso2.carbon.device.mgt.common.Device getDevice(DeviceIdentifier deviceId)
throws DeviceManagementException { @Override
public org.wso2.carbon.device.mgt.common.Device getDevice(DeviceIdentifier deviceId)
Device device = DeviceManagementDataHolder.getInstance().getDeviceManager().getDevice(deviceId); throws DeviceManagementException {
return device;
} Device device =
DeviceManagementDataHolder.getInstance().getDeviceManager().getDevice(deviceId);
@Override return device;
public boolean updateDeviceInfo(Device device) throws DeviceManagementException { }
return DeviceManagementDataHolder.getInstance().getDeviceManager().updateDeviceInfo(device);
} @Override
public boolean updateDeviceInfo(Device device) throws DeviceManagementException {
@Override return DeviceManagementDataHolder.getInstance().getDeviceManager().updateDeviceInfo(device);
public boolean setOwnership(DeviceIdentifier deviceId, String ownershipType) }
throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager() @Override
.setOwnership(deviceId, ownershipType); public boolean setOwnership(DeviceIdentifier deviceId, String ownershipType)
} throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager()
@Override .setOwnership(deviceId, ownershipType);
public OperationManager getOperationManager(String type) throws DeviceManagementException { }
return DeviceManagementDataHolder.getInstance().getDeviceManager().
getOperationManager(type); @Override
} public OperationManager getOperationManager(String type) throws DeviceManagementException {
return DeviceManagementDataHolder.getInstance().getDeviceManager().
getOperationManager(type);
}
} }

10
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/service/LicenseManagementService.java
Unescape View File

@ -27,8 +27,10 @@ import org.wso2.carbon.device.mgt.core.internal.LicenseManagementDataHolder;
public class LicenseManagementService implements LicenseManager { public class LicenseManagementService implements LicenseManager {
@Override @Override
public License getLicense(String deviceType, String languageCode) throws LicenseManagementException { public License getLicense(String deviceType, String languageCode)
return LicenseManagementDataHolder.getInstance().getLicenseManager().getLicense(deviceType, languageCode); throws LicenseManagementException {
} return LicenseManagementDataHolder.getInstance().getLicenseManager()
.getLicense(deviceType, languageCode);
}
} }

31
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/util/DeviceManagementSchemaInitializer.java
Unescape View File

@ -29,20 +29,21 @@ import java.io.File;
public final class DeviceManagementSchemaInitializer extends DatabaseCreator { public final class DeviceManagementSchemaInitializer extends DatabaseCreator {
private static final Log log = LogFactory.getLog(DeviceManagementSchemaInitializer.class); private static final Log log = LogFactory.getLog(DeviceManagementSchemaInitializer.class);
private static final String setupSQLScriptBaseLocation = private static final String setupSQLScriptBaseLocation =
CarbonUtils.getCarbonHome() + File.separator + "dbscripts" + File.separator + "cdm" + File.separator; CarbonUtils.getCarbonHome() + File.separator + "dbscripts" + File.separator + "cdm" +
File.separator;
public DeviceManagementSchemaInitializer(DataSourceConfig config) {
super(DeviceManagerUtil.resolveDataSource(config)); public DeviceManagementSchemaInitializer(DataSourceConfig config) {
} super(DeviceManagerUtil.resolveDataSource(config));
}
protected String getDbScriptLocation(String databaseType) {
String scriptName = databaseType + ".sql"; protected String getDbScriptLocation(String databaseType) {
if (log.isDebugEnabled()) { String scriptName = databaseType + ".sql";
log.debug("Loading database script from :" + scriptName); if (log.isDebugEnabled()) {
} log.debug("Loading database script from :" + scriptName);
return setupSQLScriptBaseLocation.replaceFirst("DBTYPE", databaseType) + scriptName; }
} return setupSQLScriptBaseLocation.replaceFirst("DBTYPE", databaseType) + scriptName;
}
} }

20
components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/util/DeviceManagerUtil.java
Unescape View File

@ -50,8 +50,9 @@ public final class DeviceManagerUtil {
DocumentBuilder docBuilder = factory.newDocumentBuilder(); DocumentBuilder docBuilder = factory.newDocumentBuilder();
return docBuilder.parse(file); return docBuilder.parse(file);
} catch (Exception e) { } catch (Exception e) {
throw new DeviceManagementException("Error occurred while parsing file, while converting " + throw new DeviceManagementException(
"to a org.w3c.dom.Document : " + e.getMessage(), e); "Error occurred while parsing file, while converting " +
"to a org.w3c.dom.Document : " + e.getMessage(), e);
} }
} }
@ -65,23 +66,28 @@ public final class DeviceManagerUtil {
DataSource dataSource = null; DataSource dataSource = null;
if (config == null) { if (config == null) {
throw new RuntimeException( throw new RuntimeException(
"Device Management Repository data source configuration " + "is null and thus, is not initialized"); "Device Management Repository data source configuration " +
"is null and thus, is not initialized");
} }
JNDILookupDefinition jndiConfig = config.getJndiLookupDefinition(); JNDILookupDefinition jndiConfig = config.getJndiLookupDefinition();
if (jndiConfig != null) { if (jndiConfig != null) {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug( log.debug(
"Initializing Device Management Repository data source using the JNDI " + "Lookup Definition"); "Initializing Device Management Repository data source using the JNDI " +
"Lookup Definition");
} }
List<JNDILookupDefinition.JNDIProperty> jndiPropertyList = jndiConfig.getJndiProperties(); List<JNDILookupDefinition.JNDIProperty> jndiPropertyList =
jndiConfig.getJndiProperties();
if (jndiPropertyList != null) { if (jndiPropertyList != null) {
Hashtable<Object, Object> jndiProperties = new Hashtable<Object, Object>(); Hashtable<Object, Object> jndiProperties = new Hashtable<Object, Object>();
for (JNDILookupDefinition.JNDIProperty prop : jndiPropertyList) { for (JNDILookupDefinition.JNDIProperty prop : jndiPropertyList) {
jndiProperties.put(prop.getName(), prop.getValue()); jndiProperties.put(prop.getName(), prop.getValue());
} }
dataSource = DeviceManagementDAOUtil.lookupDataSource(jndiConfig.getJndiName(), jndiProperties); dataSource = DeviceManagementDAOUtil
.lookupDataSource(jndiConfig.getJndiName(), jndiProperties);
} else { } else {
dataSource = DeviceManagementDAOUtil.lookupDataSource(jndiConfig.getJndiName(), null); dataSource =
DeviceManagementDAOUtil.lookupDataSource(jndiConfig.getJndiName(), null);
} }
} }
return dataSource; return dataSource;

Write Preview
Loading…
Cancel
Save