From 5727886ea120799650e3e047ff2b192e346d368e Mon Sep 17 00:00:00 2001 From: ayyoob Date: Sun, 9 Oct 2016 03:16:02 +0530 Subject: [PATCH] few changes after apimgt integration --- .../ApiApplicationRegistrationService.java | 5 +- .../publisher/APIPublisherServiceImpl.java | 21 ++- .../publisher/APIPublisherStartupHandler.java | 72 +++++--- .../webapp/publisher/APIPublisherUtil.java | 45 +---- .../webapp/publisher/WebappPublisherUtil.java | 41 ----- .../config/WebappPublisherConfig.java | 10 + .../APIPublisherLifecycleListener.java | 132 ++++++------- .../api/ActivityInfoProviderService.java | 2 +- .../api/ConfigurationManagementService.java | 2 +- .../mgt/jaxrs/service/api/Dashboard.java | 4 +- .../service/api/DeviceManagementService.java | 2 +- .../api/DeviceTypeManagementService.java | 4 +- .../service/api/GroupManagementService.java | 2 +- .../api/NotificationManagementService.java | 4 +- .../service/api/PolicyManagementService.java | 4 +- .../service/api/RoleManagementService.java | 2 +- .../service/api/UserManagementService.java | 2 +- .../ApplicationManagementAdminService.java | 2 +- .../admin/DeviceManagementAdminService.java | 4 +- .../admin/GroupManagementAdminService.java | 2 +- .../api/admin/UserManagementAdminService.java | 2 +- .../internal/DeviceManagementDataHolder.java | 8 - .../DeviceManagementServiceComponent.java | 16 -- .../scope/mgt/ScopeManagementServiceImpl.java | 173 ------------------ .../scope/mgt/dao/ScopeManagementDAO.java | 64 ------- .../mgt/dao/ScopeManagementDAOException.java | 57 ------ .../mgt/dao/ScopeManagementDAOFactory.java | 139 -------------- .../scope/mgt/dao/ScopeManagementDAOUtil.java | 57 ------ .../mgt/dao/impl/ScopeManagementDAOImpl.java | 148 --------------- .../grant/ExtendedPasswordGrantHandler.java | 32 ++++ .../conf/webapp-publisher-config.xml | 4 + 31 files changed, 190 insertions(+), 872 deletions(-) delete mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/ScopeManagementServiceImpl.java delete mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAO.java delete mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOException.java delete mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOFactory.java delete mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOUtil.java delete mode 100644 components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/impl/ScopeManagementDAOImpl.java create mode 100644 components/identity-extensions/org.wso2.carbon.device.mgt.oauth.extensions/src/main/java/org/wso2/carbon/device/mgt/oauth/extensions/handlers/grant/ExtendedPasswordGrantHandler.java diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.application.extension.api/src/main/java/org/wso2/carbon/apimgt/application/extension/api/ApiApplicationRegistrationService.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.application.extension.api/src/main/java/org/wso2/carbon/apimgt/application/extension/api/ApiApplicationRegistrationService.java index 8e2843cdc3..5f122b593a 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.application.extension.api/src/main/java/org/wso2/carbon/apimgt/application/extension/api/ApiApplicationRegistrationService.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.application.extension.api/src/main/java/org/wso2/carbon/apimgt/application/extension/api/ApiApplicationRegistrationService.java @@ -18,7 +18,6 @@ package org.wso2.carbon.apimgt.application.extension.api; -import org.wso2.carbon.apimgt.annotations.api.API; import org.wso2.carbon.apimgt.application.extension.api.util.RegistrationProfile; import javax.ws.rs.*; @@ -28,9 +27,7 @@ import javax.ws.rs.core.Response; /** * This is the application registration service that exposed for apimApplicationRegistration */ -@API(name = "API Registration Service", version = "1.0.0", - context = "api-application-registration", - tags = {"devicemgt_admin"}) + public interface ApiApplicationRegistrationService { /** diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherServiceImpl.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherServiceImpl.java index ca12f79a5b..874bf1b726 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherServiceImpl.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherServiceImpl.java @@ -30,6 +30,7 @@ import org.wso2.carbon.apimgt.api.APIProvider; import org.wso2.carbon.apimgt.api.FaultGatewaysException; import org.wso2.carbon.apimgt.api.model.*; import org.wso2.carbon.apimgt.impl.APIManagerFactory; +import org.wso2.carbon.apimgt.webapp.publisher.config.WebappPublisherConfig; import org.wso2.carbon.apimgt.webapp.publisher.internal.APIPublisherDataHolder; import org.wso2.carbon.context.PrivilegedCarbonContext; import org.wso2.carbon.governance.lcm.util.CommonUtil; @@ -78,15 +79,17 @@ public class APIPublisherServiceImpl implements APIPublisherService { + api.getId().getVersion() + "'"); } } else { - if (provider.getAPI(api.getId()).getStatus() == APIStatus.CREATED) { - provider.changeLifeCycleStatus(api.getId(), PUBLISH_ACTION); - } - api.setStatus(APIStatus.PUBLISHED); - provider.updateAPI(api); - if (log.isDebugEnabled()) { - log.debug("An API already exists with the name '" + api.getId().getApiName() + - "', context '" + api.getContext() + "' and version '" - + api.getId().getVersion() + "'. Thus, the API config is updated"); + if (WebappPublisherConfig.getInstance().isEnabledUpdateApi()) { + if (provider.getAPI(api.getId()).getStatus() == APIStatus.CREATED) { + provider.changeLifeCycleStatus(api.getId(), PUBLISH_ACTION); + } + api.setStatus(APIStatus.PUBLISHED); + provider.updateAPI(api); + if (log.isDebugEnabled()) { + log.debug("An API already exists with the name '" + api.getId().getApiName() + + "', context '" + api.getContext() + "' and version '" + + api.getId().getVersion() + "'. Thus, the API config is updated"); + } } } provider.saveSwagger20Definition(api.getId(), createSwaggerDefinition(api)); diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherStartupHandler.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherStartupHandler.java index ea5e524fc3..df9102e351 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherStartupHandler.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherStartupHandler.java @@ -32,6 +32,7 @@ public class APIPublisherStartupHandler implements ServerStartupObserver { private static final Log log = LogFactory.getLog(APIPublisherStartupHandler.class); private static int retryTime = 2000; private static final int CONNECTION_RETRY_FACTOR = 2; + private static final int MAX_RETRY_COUNT = 5; private static Stack failedAPIsStack = new Stack<>(); private static Stack currentAPIsStack; @@ -44,33 +45,49 @@ public class APIPublisherStartupHandler implements ServerStartupObserver { @Override public void completedServerStartup() { -// APIPublisherDataHolder.getInstance().setServerStarted(true); -// currentAPIsStack = APIPublisherDataHolder.getInstance().getUnpublishedApis(); -// Thread t = new Thread(new Runnable() { -// @Override -// public void run() { -// if (log.isDebugEnabled()) { -// log.debug("Server has just started, hence started publishing unpublished APIs"); -// log.debug("Total number of unpublished APIs: " -// + APIPublisherDataHolder.getInstance().getUnpublishedApis().size()); -// } -// publisher = APIPublisherDataHolder.getInstance().getApiPublisherService(); -// while (!failedAPIsStack.isEmpty() || !currentAPIsStack.isEmpty()) { -// try { -// retryTime = retryTime * CONNECTION_RETRY_FACTOR; -// Thread.sleep(retryTime); -// } catch (InterruptedException te) { -// log.error("Error occurred while sleeping", te); -// } -// if (!APIPublisherDataHolder.getInstance().getUnpublishedApis().isEmpty()) { -// publishAPIs(currentAPIsStack, failedAPIsStack); -// } else { -// publishAPIs(failedAPIsStack, currentAPIsStack); -// } -// } -// } -// }); -// t.start(); + APIPublisherDataHolder.getInstance().setServerStarted(true); + currentAPIsStack = APIPublisherDataHolder.getInstance().getUnpublishedApis(); + Thread t = new Thread(new Runnable() { + @Override + public void run() { + if (log.isDebugEnabled()) { + log.debug("Server has just started, hence started publishing unpublished APIs"); + log.debug("Total number of unpublished APIs: " + + APIPublisherDataHolder.getInstance().getUnpublishedApis().size()); + } + publisher = APIPublisherDataHolder.getInstance().getApiPublisherService(); + int retryCount = 0; + while (retryCount < MAX_RETRY_COUNT && (!failedAPIsStack.isEmpty() || !currentAPIsStack.isEmpty())) { + try { + retryTime = retryTime * CONNECTION_RETRY_FACTOR; + Thread.sleep(retryTime); + } catch (InterruptedException te) { + //do nothing. + } + Stack failedApis; + if (!APIPublisherDataHolder.getInstance().getUnpublishedApis().isEmpty()) { + publishAPIs(currentAPIsStack, failedAPIsStack); + failedApis = failedAPIsStack; + } else { + publishAPIs(failedAPIsStack, currentAPIsStack); + failedApis = currentAPIsStack; + } + retryCount++; + if (retryCount == MAX_RETRY_COUNT && !failedApis.isEmpty()) { + StringBuilder error = new StringBuilder(); + error.append("Error occurred while publishing API ['"); + while (!failedApis.isEmpty()) { + API api = failedApis.pop(); + error.append(api.getId().getApiName() + ","); + } + error.append("']"); + log.error(error.toString()); + } + } + + } + }); + t.start(); } private void publishAPIs(Stack apis, Stack failedStack) { @@ -79,7 +96,6 @@ public class APIPublisherStartupHandler implements ServerStartupObserver { try { publisher.publishAPI(api); } catch (Exception e) { - log.error("Error occurred while publishing API '" + api.getId().getApiName() + "'"); failedStack.push(api); } } diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherUtil.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherUtil.java index 3e46d4182f..07452e5a0e 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherUtil.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/APIPublisherUtil.java @@ -24,15 +24,12 @@ import org.wso2.carbon.apimgt.api.APIManagementException; import org.wso2.carbon.apimgt.api.APIProvider; import org.wso2.carbon.apimgt.api.model.*; import org.wso2.carbon.apimgt.impl.APIConstants; +import org.wso2.carbon.apimgt.impl.utils.APIUtil; import org.wso2.carbon.apimgt.webapp.publisher.config.APIResource; import org.wso2.carbon.apimgt.webapp.publisher.config.APIResourceConfiguration; import org.wso2.carbon.apimgt.webapp.publisher.config.WebappPublisherConfig; import org.wso2.carbon.base.MultitenantConstants; import org.wso2.carbon.core.util.Utils; -import org.wso2.carbon.device.mgt.common.scope.mgt.ScopeManagementException; -import org.wso2.carbon.device.mgt.common.scope.mgt.ScopeManagementService; -import org.wso2.carbon.user.api.UserRealm; -import org.wso2.carbon.user.api.UserStoreException; import javax.servlet.ServletContext; import java.util.*; @@ -117,8 +114,6 @@ public class APIPublisherUtil { // adding scopes to the api Set uriTemplates = config.getUriTemplates(); Map apiScopes = new HashMap<>(); - Scope existingScope; - String existingPermissions; if (uriTemplates != null) { // this creates distinct scopes list for (URITemplate template : uriTemplates) { @@ -130,13 +125,6 @@ public class APIPublisherUtil { } } Set scopes = new HashSet<>(apiScopes.values()); - // adding existing persisted roles to the scopes - try { - setExistingRoles(scopes); - } catch (ScopeManagementException | UserStoreException e) { - throw new APIManagementException("Error occurred while retrieving roles for the existing scopes"); - } - // set current scopes to API api.setScopes(scopes); @@ -152,6 +140,7 @@ public class APIPublisherUtil { } api.setUriTemplates(uriTemplates); } + api.setCorsConfiguration(APIUtil.getDefaultCorsConfiguration()); return api; } @@ -324,34 +313,4 @@ public class APIPublisherUtil { return apiConfig; } - /** - * This method is used to set the existing roles of the given scope. - * - * @param scopes List of scopes. - * @throws ScopeManagementException - */ - private static void setExistingRoles(Set scopes) throws ScopeManagementException, UserStoreException { - String scopeKey; - String roles; - ScopeManagementService scopeManagementService = WebappPublisherUtil.getScopeManagementService(); - UserRealm userRealm = WebappPublisherUtil.getUserRealm(); - - if (scopeManagementService == null) { - throw new ScopeManagementException("Error occurred while initializing scope management service"); - } else if (userRealm == null) { - throw new UserStoreException("Error occurred while initializing realm service"); - } else { - String adminRole = userRealm.getRealmConfiguration().getAdminRoleName(); - for (Scope scope : scopes) { - scopeKey = scope.getKey(); - roles = scopeManagementService.getRolesOfScope(scopeKey); - if (roles == null) { - roles = adminRole; - } - scope.setRoles(roles); - - } - } - } - } diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/WebappPublisherUtil.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/WebappPublisherUtil.java index ca2f0cba13..17e2edb9a8 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/WebappPublisherUtil.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/WebappPublisherUtil.java @@ -18,16 +18,7 @@ package org.wso2.carbon.apimgt.webapp.publisher; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.w3c.dom.Document; -import org.wso2.carbon.context.CarbonContext; -import org.wso2.carbon.context.PrivilegedCarbonContext; -import org.wso2.carbon.device.mgt.common.scope.mgt.ScopeManagementService; -import org.wso2.carbon.user.api.UserRealm; -import org.wso2.carbon.user.api.UserStoreException; -import org.wso2.carbon.user.api.UserStoreManager; -import org.wso2.carbon.user.core.service.RealmService; import javax.xml.XMLConstants; import javax.xml.parsers.DocumentBuilder; @@ -40,10 +31,6 @@ import java.io.File; */ public class WebappPublisherUtil { - private static Log log = LogFactory.getLog(WebappPublisherUtil.class); - private static final int CARBON_SUPER = -1234; - - public static Document convertToDocument(File file) throws WebappPublisherConfigurationFailedException { DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); factory.setNamespaceAware(true); @@ -57,32 +44,4 @@ public class WebappPublisherUtil { } } - public static ScopeManagementService getScopeManagementService() { - PrivilegedCarbonContext ctx = PrivilegedCarbonContext.getThreadLocalCarbonContext(); - ScopeManagementService scopeManagementService = - (ScopeManagementService) ctx.getOSGiService(ScopeManagementService.class, null); - if (scopeManagementService == null) { - String msg = "Scope Management Service has not been initialized."; - log.error(msg); - throw new IllegalStateException(msg); - } - return scopeManagementService; - } - - /** - * Getting the current tenant's user realm - */ - public static UserRealm getUserRealm() throws UserStoreException { - RealmService realmService; - UserRealm realm; - PrivilegedCarbonContext ctx = PrivilegedCarbonContext.getThreadLocalCarbonContext(); - realmService = (RealmService) ctx.getOSGiService(RealmService.class, null); - - if (realmService == null) { - throw new IllegalStateException("Realm service not initialized"); - } - realm = realmService.getTenantUserRealm(CARBON_SUPER); - return realm; - } - } diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/config/WebappPublisherConfig.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/config/WebappPublisherConfig.java index 902d4838db..77a05a744f 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/config/WebappPublisherConfig.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/config/WebappPublisherConfig.java @@ -40,6 +40,7 @@ public class WebappPublisherConfig { private String host; private boolean isPublished; + private boolean isEnabledUpdateApi; private Profiles profiles; private static WebappPublisherConfig config; @@ -77,6 +78,15 @@ public class WebappPublisherConfig { return profiles; } + @XmlElement(name = "EnabledUpdateApi", required = true) + public boolean isEnabledUpdateApi() { + return isEnabledUpdateApi; + } + + public void setEnableUpdateApi(boolean isEnabledUpdateApi) { + this.isEnabledUpdateApi = isEnabledUpdateApi; + } + public void setPublished(boolean published) { isPublished = published; } diff --git a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/lifecycle/listener/APIPublisherLifecycleListener.java b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/lifecycle/listener/APIPublisherLifecycleListener.java index 11e991f349..d2932f994e 100644 --- a/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/lifecycle/listener/APIPublisherLifecycleListener.java +++ b/components/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher/src/main/java/org/wso2/carbon/apimgt/webapp/publisher/lifecycle/listener/APIPublisherLifecycleListener.java @@ -49,72 +49,72 @@ public class APIPublisherLifecycleListener implements LifecycleListener { @Override public void lifecycleEvent(LifecycleEvent lifecycleEvent) { -// if (Lifecycle.AFTER_START_EVENT.equals(lifecycleEvent.getType()) && WebappPublisherConfig.getInstance() -// .isPublished()) { -// StandardContext context = (StandardContext) lifecycleEvent.getLifecycle(); -// ServletContext servletContext = context.getServletContext(); -// String param = servletContext.getInitParameter(PARAM_MANAGED_API_ENABLED); -// boolean isManagedApi = (param != null && !param.isEmpty()) && Boolean.parseBoolean(param); -// -// String profile = System.getProperty(PROPERTY_PROFILE); -// -// if (WebappPublisherConfig.getInstance().getProfiles().getProfile().contains(profile.toLowerCase()) -// && isManagedApi) { -// try { -// AnnotationProcessor annotationProcessor = new AnnotationProcessor(context); -// Set annotatedAPIClasses = annotationProcessor. -// scanStandardContext(org.wso2.carbon.apimgt.annotations.api.API.class.getName()); -// -// List apiDefinitions = annotationProcessor.extractAPIInfo(servletContext, -// annotatedAPIClasses); -// -// for (APIResourceConfiguration apiDefinition : apiDefinitions) { -// -// APIConfig apiConfig = APIPublisherUtil.buildApiConfig(servletContext, apiDefinition); -// -// try { -// int tenantId = APIPublisherDataHolder.getInstance().getTenantManager(). -// getTenantId(apiConfig.getTenantDomain()); -// -// boolean isTenantActive = APIPublisherDataHolder.getInstance(). -// getTenantManager().isTenantActive(tenantId); -// -// if (isTenantActive) { -// apiConfig.init(); -// API api = APIPublisherUtil.getAPI(apiConfig); -// boolean isServerStarted = APIPublisherDataHolder.getInstance().isServerStarted(); -// if (isServerStarted) { -// APIPublisherService apiPublisherService = -// APIPublisherDataHolder.getInstance().getApiPublisherService(); -// if (apiPublisherService == null) { -// throw new IllegalStateException( -// "API Publisher service is not initialized properly"); -// } -// apiPublisherService.publishAPI(api); -// } else { -// if (log.isDebugEnabled()) { -// log.debug("Server has not started yet. Hence adding API '" + -// api.getId().getApiName() + "' to the queue"); -// } -// APIPublisherDataHolder.getInstance().getUnpublishedApis().push(api); -// } -// } else { -// log.error("No tenant [" + apiConfig.getTenantDomain() + "] " + -// "found when publishing the Web app"); -// } -// } catch (Throwable e) { -// log.error("Error occurred while publishing API '" + apiConfig.getName() + -// "' with the context '" + apiConfig.getContext() + -// "' and version '" + apiConfig.getVersion() + "'", e); -// } -// } -// } catch (IOException e) { -// log.error("Error encountered while discovering annotated classes", e); -// } catch (ClassNotFoundException e) { -// log.error("Error while scanning class for annotations", e); -// } -// } -// } + if (Lifecycle.AFTER_START_EVENT.equals(lifecycleEvent.getType()) && WebappPublisherConfig.getInstance() + .isPublished()) { + StandardContext context = (StandardContext) lifecycleEvent.getLifecycle(); + ServletContext servletContext = context.getServletContext(); + String param = servletContext.getInitParameter(PARAM_MANAGED_API_ENABLED); + boolean isManagedApi = (param != null && !param.isEmpty()) && Boolean.parseBoolean(param); + + String profile = System.getProperty(PROPERTY_PROFILE); + + if (WebappPublisherConfig.getInstance().getProfiles().getProfile().contains(profile.toLowerCase()) + && isManagedApi) { + try { + AnnotationProcessor annotationProcessor = new AnnotationProcessor(context); + Set annotatedAPIClasses = annotationProcessor. + scanStandardContext(org.wso2.carbon.apimgt.annotations.api.API.class.getName()); + + List apiDefinitions = annotationProcessor.extractAPIInfo(servletContext, + annotatedAPIClasses); + + for (APIResourceConfiguration apiDefinition : apiDefinitions) { + + APIConfig apiConfig = APIPublisherUtil.buildApiConfig(servletContext, apiDefinition); + + try { + int tenantId = APIPublisherDataHolder.getInstance().getTenantManager(). + getTenantId(apiConfig.getTenantDomain()); + + boolean isTenantActive = APIPublisherDataHolder.getInstance(). + getTenantManager().isTenantActive(tenantId); + + if (isTenantActive) { + apiConfig.init(); + API api = APIPublisherUtil.getAPI(apiConfig); + boolean isServerStarted = APIPublisherDataHolder.getInstance().isServerStarted(); + if (isServerStarted) { + APIPublisherService apiPublisherService = + APIPublisherDataHolder.getInstance().getApiPublisherService(); + if (apiPublisherService == null) { + throw new IllegalStateException( + "API Publisher service is not initialized properly"); + } + apiPublisherService.publishAPI(api); + } else { + if (log.isDebugEnabled()) { + log.debug("Server has not started yet. Hence adding API '" + + api.getId().getApiName() + "' to the queue"); + } + APIPublisherDataHolder.getInstance().getUnpublishedApis().push(api); + } + } else { + log.error("No tenant [" + apiConfig.getTenantDomain() + "] " + + "found when publishing the Web app"); + } + } catch (Throwable e) { + log.error("Error occurred while publishing API '" + apiConfig.getName() + + "' with the context '" + apiConfig.getContext() + + "' and version '" + apiConfig.getVersion() + "'", e); + } + } + } catch (IOException e) { + log.error("Error encountered while discovering annotated classes", e); + } catch (ClassNotFoundException e) { + log.error("Error while scanning class for annotations", e); + } + } + } } //TODO : Need to implemented, to merge API Definitions in cases where implementation of an API Lies in two classes diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ActivityInfoProviderService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ActivityInfoProviderService.java index d048ea75fd..6dd545899a 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ActivityInfoProviderService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ActivityInfoProviderService.java @@ -33,7 +33,7 @@ import javax.ws.rs.core.Response; /** * Activity related REST-API implementation. */ -@API(name = "Activity Info Provider", version = "1.0.0", context = "/api/device-mgt/v1.0/activities", tags = {"devicemgt_admin"}) +@API(name = "ActivityInfoProvider", version = "1.0.0", context = "/api/device-mgt/v1.0/activities", tags = {"device_management"}) @Path("/activities") @Api(value = "Activity Info Provider", description = "Activity related information manipulation. For example operation details " + diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ConfigurationManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ConfigurationManagementService.java index f33b4041fd..79ed861d53 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ConfigurationManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/ConfigurationManagementService.java @@ -31,7 +31,7 @@ import javax.ws.rs.core.Response; /** * General Tenant Configuration REST-API. */ -@API(name = "Configuration Management", version = "1.0.0", context = "/api/device-mgt/v1.0/configuration", tags = {"devicemgt_admin"}) +@API(name = "ConfigurationManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/configuration", tags = {"device_management"}) @Path("/configuration") @Api(value = "Configuration Management", description = "The general platform configuration management capabilities are exposed " + diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/Dashboard.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/Dashboard.java index 0c4fd54ea2..a3a72f6acd 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/Dashboard.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/Dashboard.java @@ -30,8 +30,8 @@ import javax.ws.rs.core.Response; /** * Device Analytics Dashboard related REST-APIs. This can be used to obtain device related analytics. */ -@API(name = "Device Analytics Dashboard", - version = "1.0.0", context = "/api/device-mgt/v1.0/dashboard", tags = {"devicemgt_admin"}) +@API(name = "DeviceAnalyticsDashboard", + version = "1.0.0", context = "/api/device-mgt/v1.0/dashboard", tags = {"device_management"}) @Path("/dashboard") @Api(value = "Device Analytics Dashboard", diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceManagementService.java index b185bd368d..bb31cd0e4d 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceManagementService.java @@ -39,7 +39,7 @@ import javax.ws.rs.core.Response; /** * Device related REST-API. This can be used to manipulated device related details. */ -@API(name = "Device Management", version = "1.0.0", context = "/api/device-mgt/v1.0/devices", tags = {"devicemgt_admin"}) +@API(name = "DeviceManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/devices", tags = {"device_management"}) @Path("/devices") @Api(value = "Device Management", description = "This API carries all device management related operations " + diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceTypeManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceTypeManagementService.java index 8aa54a5378..6b79aa6c84 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceTypeManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/DeviceTypeManagementService.java @@ -39,8 +39,8 @@ import javax.ws.rs.Produces; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; -@API(name = "Device Type Management", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/device-types", - tags = {"devicemgt_admin"}) +@API(name = "DeviceTypeManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/device-types", + tags = {"device_management"}) @Path("/device-types") @Api(value = "Device Type Management", description = "This API corresponds to all tasks related to device " + diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/GroupManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/GroupManagementService.java index f21d1c9a4b..a03d2b891c 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/GroupManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/GroupManagementService.java @@ -35,7 +35,7 @@ import javax.ws.rs.QueryParam; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; -@API(name = "Group Management", version = "1.0.0", context = "/api/device-mgt/v1.0/groups", tags = {"devicemgt_admin"}) +@API(name = "GroupManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/groups", tags = {"device_management"}) @Path("/groups") @Produces(MediaType.APPLICATION_JSON) diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/NotificationManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/NotificationManagementService.java index e0a2a3b1f7..7d27488483 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/NotificationManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/NotificationManagementService.java @@ -35,8 +35,8 @@ import javax.ws.rs.core.Response; /** * Notifications related REST-API. */ -@API(name = "Device Notification Management", version = "1.0.0", context = "/api/device-mgt/v1.0/notifications", - tags = {"devicemgt_admin"}) +@API(name = "DeviceNotificationManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/notifications", + tags = {"device_management"}) @Api(value = "Device Notification Management", description = "Device notification related operations can be found here.") @Path("/notifications") @Produces(MediaType.APPLICATION_JSON) diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/PolicyManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/PolicyManagementService.java index 70edb9126f..8bee52deb8 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/PolicyManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/PolicyManagementService.java @@ -37,8 +37,8 @@ import java.util.List; * Policy related REST-API. This can be used to manipulated policies and associate them with devices, users, roles, * groups. */ -@API(name = "Device Policy Management", version = "1.0.0", context = "/api/device-mgt/v1.0/policies", - tags = {"devicemgt_admin"}) +@API(name = "DevicePolicyManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/policies", + tags = {"device_management"}) @Api(value = "Device Policy Management", description = "This API carries all the necessary functionalities " + "around device policy management") diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/RoleManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/RoleManagementService.java index 0a9b5e8056..79c3946130 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/RoleManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/RoleManagementService.java @@ -32,7 +32,7 @@ import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; import java.util.List; -@API(name = "Role Management", version = "1.0.0", context = "/api/device-mgt/v1.0/roles", tags = {"devicemgt_admin"}) +@API(name = "RoleManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/roles", tags = {"device_management"}) @Path("/roles") @Api(value = "Role Management", description = "Role management related operations can be found here.") diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/UserManagementService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/UserManagementService.java index 1a5e3440ef..b98c147446 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/UserManagementService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/UserManagementService.java @@ -29,7 +29,7 @@ import javax.ws.rs.core.Response; import java.util.List; -@API(name = "User Management", version = "1.0.0", context = "/api/device-mgt/v1.0/users", tags = {"devicemgt_admin"}) +@API(name = "UserManagement", version = "1.0.0", context = "/api/device-mgt/v1.0/users", tags = {"device_management"}) @Path("/users") @Api(value = "User Management", description = "User management related operations can be found here.") diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/ApplicationManagementAdminService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/ApplicationManagementAdminService.java index fb7acdb95b..ed4ce0d8e7 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/ApplicationManagementAdminService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/ApplicationManagementAdminService.java @@ -33,7 +33,7 @@ import javax.ws.rs.Produces; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; -@API(name = "Application Management Admin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/applications", tags = {"devicemgt_admin"}) +@API(name = "ApplicationManagementAdmin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/applications", tags = {"device_management"}) @Path("/admin/applications") @Api(value = "Application Management Administrative Service", description = "This an API intended to be used by " + diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/DeviceManagementAdminService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/DeviceManagementAdminService.java index 1f4e059375..3c4f57df81 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/DeviceManagementAdminService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/DeviceManagementAdminService.java @@ -29,8 +29,8 @@ import javax.ws.rs.*; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; -@API(name = "Device Management Admin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/devices", - tags = {"devicemgt_admin"}) +@API(name = "DeviceManagementAdmin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/devices", + tags = {"device_management"}) @Path("/admin/devices") @Api(value = "Device Management Administrative Service", description = "This an API intended to be used by " + "'internal' components to log in as an admin user and do a selected number of operations. " + diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/GroupManagementAdminService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/GroupManagementAdminService.java index 885005944a..7448d94606 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/GroupManagementAdminService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/GroupManagementAdminService.java @@ -37,7 +37,7 @@ import javax.ws.rs.QueryParam; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; -@API(name = "Group Management Admin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/groups", tags = {"devicemgt_admin"}) +@API(name = "GroupManagementAdmin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/groups", tags = {"device_management"}) @Path("/admin/groups") @Produces(MediaType.APPLICATION_JSON) diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/UserManagementAdminService.java b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/UserManagementAdminService.java index 026910d8e2..65a7c8f64e 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/UserManagementAdminService.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/admin/UserManagementAdminService.java @@ -30,7 +30,7 @@ import javax.ws.rs.*; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; -@API(name = "User Management Admin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/users", tags = {"devicemgt_admin"}) +@API(name = "UserManagementAdmin", version = "1.0.0", context = "/api/device-mgt/v1.0/admin/users", tags = {"device_management"}) @Path("/admin/users") @Produces(MediaType.APPLICATION_JSON) diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementDataHolder.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementDataHolder.java index 7f5f5f5e97..ea50220644 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementDataHolder.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementDataHolder.java @@ -57,14 +57,6 @@ public class DeviceManagementDataHolder { private EmailSenderService emailSenderService; private PushNotificationProviderRepository pushNotificationProviderRepository; - public APIManagerConfiguration getApiManagerConfiguration() { - return apiManagerConfiguration; - } - - public void setApiManagerConfiguration(APIManagerConfiguration apiManagerConfiguration) { - this.apiManagerConfiguration = apiManagerConfiguration; - } - private APIManagerConfiguration apiManagerConfiguration; private DeviceManagementDataHolder() {} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementServiceComponent.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementServiceComponent.java index f871964569..7e1c95efda 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementServiceComponent.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/internal/DeviceManagementServiceComponent.java @@ -21,7 +21,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.osgi.framework.BundleContext; import org.osgi.service.component.ComponentContext; -import org.wso2.carbon.apimgt.impl.APIManagerConfiguration; import org.wso2.carbon.apimgt.impl.APIManagerConfigurationService; import org.wso2.carbon.device.mgt.common.DeviceManagementException; import org.wso2.carbon.device.mgt.common.app.mgt.ApplicationManagementException; @@ -33,7 +32,6 @@ import org.wso2.carbon.device.mgt.common.operation.mgt.OperationManager; import org.wso2.carbon.device.mgt.common.permission.mgt.PermissionManagerService; import org.wso2.carbon.device.mgt.common.spi.DeviceManagementService; import org.wso2.carbon.device.mgt.core.DeviceManagementConstants; -import org.wso2.carbon.device.mgt.core.DeviceManagementPluginRepository; import org.wso2.carbon.device.mgt.core.app.mgt.ApplicationManagementProviderService; import org.wso2.carbon.device.mgt.core.app.mgt.ApplicationManagerProviderServiceImpl; import org.wso2.carbon.device.mgt.core.app.mgt.config.AppManagementConfig; @@ -51,7 +49,6 @@ import org.wso2.carbon.device.mgt.core.operation.mgt.OperationManagerImpl; import org.wso2.carbon.device.mgt.core.operation.mgt.dao.OperationManagementDAOFactory; import org.wso2.carbon.device.mgt.core.permission.mgt.PermissionManagerServiceImpl; import org.wso2.carbon.device.mgt.core.push.notification.mgt.PushNotificationProviderRepository; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAOFactory; import org.wso2.carbon.device.mgt.core.service.DeviceManagementProviderService; import org.wso2.carbon.device.mgt.core.service.DeviceManagementProviderServiceImpl; import org.wso2.carbon.device.mgt.core.service.GroupManagementProviderService; @@ -61,10 +58,8 @@ import org.wso2.carbon.email.sender.core.service.EmailSenderService; import org.wso2.carbon.ndatasource.core.DataSourceService; import org.wso2.carbon.registry.core.service.RegistryService; import org.wso2.carbon.user.core.service.RealmService; -import org.wso2.carbon.utils.CarbonUtils; import org.wso2.carbon.utils.ConfigurationContextService; -import java.io.File; import java.util.ArrayList; import java.util.List; @@ -120,10 +115,6 @@ public class DeviceManagementServiceComponent { private static List listeners = new ArrayList<>(); private static List deviceManagers = new ArrayList<>(); private static List startupListeners = new ArrayList<>(); - private DeviceManagementPluginRepository pluginRepository = new DeviceManagementPluginRepository(); - private static final String APIM_CONFIGURATION_PATH = CarbonUtils.getCarbonHome() + File.separator + "repository" + - File.separator + "conf" + File.separator + "api-manager.xml"; - private static final String DATA_SOURCE_NAME = "DataSourceName"; public static void registerPluginInitializationListener(PluginInitializationListener listener) { synchronized (LOCK) { @@ -157,18 +148,11 @@ public class DeviceManagementServiceComponent { DataSourceConfig dsConfig = config.getDeviceManagementConfigRepository().getDataSourceConfig(); - APIManagerConfiguration apiManagerConfiguration = new APIManagerConfiguration(); - apiManagerConfiguration.load(APIM_CONFIGURATION_PATH); - DeviceManagementDataHolder.getInstance().setApiManagerConfiguration(apiManagerConfiguration); - DeviceManagementDAOFactory.init(dsConfig); GroupManagementDAOFactory.init(dsConfig); NotificationManagementDAOFactory.init(dsConfig); OperationManagementDAOFactory.init(dsConfig); - String apiManagerDataSource = apiManagerConfiguration.getFirstProperty(DATA_SOURCE_NAME); - ScopeManagementDAOFactory.init(apiManagerDataSource); - /* Initialize Operation Manager */ this.initOperationsManager(); diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/ScopeManagementServiceImpl.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/ScopeManagementServiceImpl.java deleted file mode 100644 index e476fc5cad..0000000000 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/ScopeManagementServiceImpl.java +++ /dev/null @@ -1,173 +0,0 @@ -/* -* Copyright (c) 2016 WSO2 Inc. (http://www.wso2.org) All Rights Reserved. -* -* WSO2 Inc. 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 org.wso2.carbon.device.mgt.core.scope.mgt; - -import org.apache.commons.lang.StringUtils; -import org.wso2.carbon.apimgt.api.model.Scope; -import org.wso2.carbon.device.mgt.common.TransactionManagementException; -import org.wso2.carbon.device.mgt.common.scope.mgt.ScopeManagementException; -import org.wso2.carbon.device.mgt.common.scope.mgt.ScopeManagementService; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAO; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAOException; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAOFactory; - -import java.lang.annotation.Inherited; -import java.sql.SQLException; -import java.util.ArrayList; -import java.util.List; - -/** - * This is an implementation of a Scope Management Service. - */ -public class ScopeManagementServiceImpl implements ScopeManagementService { - - private ScopeManagementDAO scopeManagementDAO; - - public ScopeManagementServiceImpl() { - this.scopeManagementDAO = ScopeManagementDAOFactory.getScopeManagementDAO(); - } - - @Override - public void updateScopes(List scopes) throws ScopeManagementException { - try { - ScopeManagementDAOFactory.beginTransaction(); - scopeManagementDAO.updateScopes(scopes); - ScopeManagementDAOFactory.commitTransaction(); - } catch (TransactionManagementException e) { - ScopeManagementDAOFactory.rollbackTransaction(); - throw new ScopeManagementException("Transactional error occurred while adding the scopes.", e); - } catch (ScopeManagementDAOException e) { - ScopeManagementDAOFactory.rollbackTransaction(); - throw new ScopeManagementException("Error occurred while adding the scopes to database.", e); - } finally { - ScopeManagementDAOFactory.closeConnection(); - } - } - - @Override - public void updateScopes(List scopeKeys, String roleName) throws ScopeManagementException { - List scopes = new ArrayList<>(); - try { - List allScopes = this.getAllScopes(); - for (Scope scope : allScopes) { - for (String key : scopeKeys) { - if (scope.getKey().equals(key)) { - scope.setRoles(scope.getRoles() + "," + roleName); - scopes.add(scope); - } - } - } - ScopeManagementDAOFactory.beginTransaction(); - scopeManagementDAO.updateScopes(scopes); - ScopeManagementDAOFactory.commitTransaction(); - } catch (TransactionManagementException e) { - ScopeManagementDAOFactory.rollbackTransaction(); - throw new ScopeManagementException("Transactional error occurred while adding the scopes.", e); - } catch (ScopeManagementDAOException e) { - ScopeManagementDAOFactory.rollbackTransaction(); - throw new ScopeManagementException("Error occurred while adding the scopes to database.", e); - } finally { - ScopeManagementDAOFactory.closeConnection(); - } - } - - @Override - public List getAllScopes() throws ScopeManagementException { - List scopes = new ArrayList<>(); - try { - ScopeManagementDAOFactory.openConnection(); - scopes = scopeManagementDAO.getAllScopes(); - } catch (SQLException e) { - throw new ScopeManagementException("SQL error occurred while retrieving scopes from database.", e); - } catch (ScopeManagementDAOException e) { - throw new ScopeManagementException("Error occurred while retrieving scopes from database.", e); - } finally { - ScopeManagementDAOFactory.closeConnection(); - } - return scopes; - } - - @Override - public String getRolesOfScope(String scopeKey) throws ScopeManagementException { - String roles; - if (scopeKey == null || scopeKey.isEmpty()) { - throw new ScopeManagementException("Scope key is null or empty"); - } - try { - ScopeManagementDAOFactory.openConnection(); - roles = scopeManagementDAO.getRolesOfScope(scopeKey); - } catch (SQLException e) { - throw new ScopeManagementException("SQL error occurred while retrieving roles of scope from database.", e); - } catch (ScopeManagementDAOException e) { - throw new ScopeManagementException("Error occurred while retrieving roles of scope from database.", e); - } finally { - ScopeManagementDAOFactory.closeConnection(); - } - return roles; - } - - @Override - public List getScopesOfRole(String roleName) throws ScopeManagementException { - if (roleName == null || roleName.isEmpty()) { - throw new ScopeManagementException("Role name is null or empty"); - } - List filteredScopes = new ArrayList<>(); - try { - ScopeManagementDAOFactory.openConnection(); - List allScopes = scopeManagementDAO.getScopesHavingRole(roleName); - - String roles[]; - for (Scope scope : allScopes) { - roles = scope.getRoles().split(","); - for (String role : roles) { - if (roleName.equals(role.trim())) { - filteredScopes.add(scope); - } - } - } - } catch (SQLException e) { - throw new ScopeManagementException("SQL error occurred while retrieving scopes of role from database.", e); - } catch (ScopeManagementDAOException e) { - throw new ScopeManagementException("Error occurred while retrieving scopes of role from database.", e); - } finally { - ScopeManagementDAOFactory.closeConnection(); - } - return filteredScopes; - } - - @Override - public void removeScopes(String roleName) throws ScopeManagementException { - - List scopes = this.getScopesOfRole(roleName); - String roles[]; - ArrayList filteredRoles = new ArrayList<>(); - for (Scope scope : scopes) { - roles = scope.getRoles().split(","); - for (String role : roles) { - if (!roleName.equals(role.trim())) { - filteredRoles.add(role); - } - } - scope.setRoles(StringUtils.join(filteredRoles, ",")); - filteredRoles.clear(); - } - this.updateScopes(scopes); - } - -} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAO.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAO.java deleted file mode 100644 index b15efcc2e7..0000000000 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAO.java +++ /dev/null @@ -1,64 +0,0 @@ -/* -* Copyright (c) 2016 WSO2 Inc. (http://www.wso2.org) All Rights Reserved. -* -* WSO2 Inc. 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 org.wso2.carbon.device.mgt.core.scope.mgt.dao; - -import org.wso2.carbon.apimgt.api.model.Scope; - -import java.util.List; - -/** - * This interface contains the basic database operations related to scope management. - */ -public interface ScopeManagementDAO { - - /** - * This method is used to update the list of scopes. - * - * @param scopes List of scopes to be updated. - * @throws ScopeManagementDAOException - */ - void updateScopes(List scopes) throws ScopeManagementDAOException; - - /** - * This method is used to retrieve all the scopes. - * - * @return List of scopes. - * @throws ScopeManagementDAOException - */ - List getAllScopes() throws ScopeManagementDAOException; - - /** - * This method is to retrieve the roles of the given scope - * @param scopeKey key of the scope - * @return List of roles - * @throws ScopeManagementDAOException - */ - String getRolesOfScope(String scopeKey) throws ScopeManagementDAOException; - - /** - * This method is to retrieve all the scopes of the given role name. - * Thus it returns the scopes even if the part of the given name is matched. - * - * @param roleName Role name - * @return List of scopes - * @throws ScopeManagementDAOException - */ - List getScopesHavingRole(String roleName) throws ScopeManagementDAOException; - -} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOException.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOException.java deleted file mode 100644 index 61ea7de2e2..0000000000 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOException.java +++ /dev/null @@ -1,57 +0,0 @@ -/* -* Copyright (c) 2016 WSO2 Inc. (http://www.wso2.org) All Rights Reserved. -* -* WSO2 Inc. 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 org.wso2.carbon.device.mgt.core.scope.mgt.dao; - -public class ScopeManagementDAOException extends Exception { - - private static final long serialVersionUID = -315127931137771199L; - - private String errorMessage; - - public String getErrorMessage() { - return errorMessage; - } - - public void setErrorMessage(String errorMessage) { - this.errorMessage = errorMessage; - } - - public ScopeManagementDAOException(String msg, Exception nestedEx) { - super(msg, nestedEx); - setErrorMessage(msg); - } - - public ScopeManagementDAOException(String message, Throwable cause) { - super(message, cause); - setErrorMessage(message); - } - - public ScopeManagementDAOException(String msg) { - super(msg); - setErrorMessage(msg); - } - - public ScopeManagementDAOException() { - super(); - } - - public ScopeManagementDAOException(Throwable cause) { - super(cause); - } - -} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOFactory.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOFactory.java deleted file mode 100644 index cb53d76f29..0000000000 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOFactory.java +++ /dev/null @@ -1,139 +0,0 @@ -/* - * Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. - * - * WSO2 Inc. 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 org.wso2.carbon.device.mgt.core.scope.mgt.dao; - - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.wso2.carbon.device.mgt.common.IllegalTransactionStateException; -import org.wso2.carbon.device.mgt.common.TransactionManagementException; -import org.wso2.carbon.device.mgt.core.dao.util.DeviceManagementDAOUtil; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.impl.ScopeManagementDAOImpl; - -import javax.sql.DataSource; -import java.sql.Connection; -import java.sql.SQLException; - -public class ScopeManagementDAOFactory { - - private static final Log log = LogFactory.getLog(ScopeManagementDAOFactory.class); - private static DataSource dataSource; - private static String databaseEngine; - private static ThreadLocal currentConnection = new ThreadLocal(); - - public static ScopeManagementDAO getScopeManagementDAO() { - return new ScopeManagementDAOImpl(); - } - - public static void init(String dataSourceName) { - dataSource = resolveDataSource(dataSourceName); - try { - databaseEngine = dataSource.getConnection().getMetaData().getDatabaseProductName(); - } catch (SQLException e) { - log.error("Error occurred while retrieving config.datasource connection", e); - } - } - - public static void beginTransaction() throws TransactionManagementException { - try { - Connection conn = dataSource.getConnection(); - conn.setAutoCommit(false); - currentConnection.set(conn); - } catch (SQLException e) { - throw new TransactionManagementException( - "Error occurred while retrieving config.datasource connection", e); - } - } - - public static void openConnection() throws SQLException { - currentConnection.set(dataSource.getConnection()); - } - - public static Connection getConnection() throws SQLException { - if (currentConnection.get() == null) { - throw new IllegalTransactionStateException("No connection is associated with the current transaction. " + - "This might have ideally caused by not properly initiating the transaction via " + - "'beginTransaction'/'openConnection' methods"); - } - return currentConnection.get(); - } - - public static void closeConnection() { - Connection con = currentConnection.get(); - if (con != null) { - try { - con.close(); - } catch (SQLException e) { - log.error("Error occurred while close the connection"); - } - currentConnection.remove(); - } - } - - public static void commitTransaction() { - try { - Connection conn = currentConnection.get(); - if (conn != null) { - conn.commit(); - } else { - if (log.isDebugEnabled()) { - log.debug("Datasource connection associated with the current thread is null, hence commit " + - "has not been attempted"); - } - } - } catch (SQLException e) { - log.error("Error occurred while committing the transaction", e); - } - } - - public static void rollbackTransaction() { - try { - Connection conn = currentConnection.get(); - if (conn != null) { - conn.rollback(); - } else { - if (log.isDebugEnabled()) { - log.debug("Datasource connection associated with the current thread is null, hence rollback " + - "has not been attempted"); - } - } - } catch (SQLException e) { - log.error("Error occurred while roll-backing the transaction", e); - } - } - - /** - * Resolve data source from the data source name. - * - * @param dataSourceName data source name - * @return data source resolved from the data source definition - */ - private static DataSource resolveDataSource(String dataSourceName) { - DataSource dataSource; - if (dataSourceName == null || dataSourceName.isEmpty()) { - throw new RuntimeException("Scope Management Repository data source configuration is null and " + - "thus, is not initialized"); - } - if (log.isDebugEnabled()) { - log.debug("Initializing Scope Management Repository data source using the JNDI Lookup Definition"); - } - dataSource = DeviceManagementDAOUtil.lookupDataSource(dataSourceName, null); - return dataSource; - } - -} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOUtil.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOUtil.java deleted file mode 100644 index 570b4ce07d..0000000000 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/ScopeManagementDAOUtil.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. - * - * WSO2 Inc. 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 org.wso2.carbon.device.mgt.core.scope.mgt.dao; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; - -import java.sql.ResultSet; -import java.sql.SQLException; -import java.sql.Statement; - -public class ScopeManagementDAOUtil { - - private static final Log log = LogFactory.getLog(ScopeManagementDAOUtil.class); - - public static void cleanupResources(Statement stmt, ResultSet rs) { - if (rs != null) { - try { - rs.close(); - } catch (SQLException e) { - log.warn("Error occurred while closing the result set", e); - } - } - if (stmt != null) { - try { - stmt.close(); - } catch (SQLException e) { - log.warn("Error occurred while closing the statement", e); - } - } - } - public static void cleanupResources(Statement stmt) { - if (stmt != null) { - try { - stmt.close(); - } catch (SQLException e) { - log.warn("Error occurred while closing the statement", e); - } - } - } -} diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/impl/ScopeManagementDAOImpl.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/impl/ScopeManagementDAOImpl.java deleted file mode 100644 index 676da007d3..0000000000 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/scope/mgt/dao/impl/ScopeManagementDAOImpl.java +++ /dev/null @@ -1,148 +0,0 @@ -/* -* Copyright (c) 2016 WSO2 Inc. (http://www.wso2.org) All Rights Reserved. -* -* WSO2 Inc. 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 org.wso2.carbon.device.mgt.core.scope.mgt.dao.impl; - -import org.wso2.carbon.apimgt.api.model.Scope; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAO; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAOException; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAOFactory; -import org.wso2.carbon.device.mgt.core.scope.mgt.dao.ScopeManagementDAOUtil; - -import java.sql.Connection; -import java.sql.PreparedStatement; -import java.sql.ResultSet; -import java.sql.SQLException; -import java.util.ArrayList; -import java.util.List; - -public class ScopeManagementDAOImpl implements ScopeManagementDAO { - - @Override - public void updateScopes(List scopes) throws ScopeManagementDAOException { - Connection conn; - PreparedStatement stmt = null; - ResultSet rs = null; - - try { - conn = this.getConnection(); - String sql = "UPDATE IDN_OAUTH2_SCOPE SET ROLES=? WHERE SCOPE_KEY=?"; - stmt = conn.prepareStatement(sql); - - // creating a batch request - for (Scope scope : scopes) { - stmt.setString(1, scope.getRoles()); - stmt.setString(2, scope.getKey()); - stmt.addBatch(); - } - stmt.executeBatch(); - } catch (SQLException e) { - throw new ScopeManagementDAOException("Error occurred while updating the details of the scopes.", e); - } finally { - ScopeManagementDAOUtil.cleanupResources(stmt, rs); - } - - } - - - public List getAllScopes() throws ScopeManagementDAOException { - Connection conn; - PreparedStatement stmt = null; - ResultSet rs = null; - List scopes; - - try { - conn = this.getConnection(); - String sql = "SELECT * FROM IDN_OAUTH2_SCOPE"; - stmt = conn.prepareStatement(sql); - rs = stmt.executeQuery(); - scopes = this.getScopesFromResultSet(rs); - return scopes; - } catch (SQLException e) { - throw new ScopeManagementDAOException("Error occurred while fetching the details of the scopes.", e); - } finally { - ScopeManagementDAOUtil.cleanupResources(stmt, rs); - } - } - - @Override - public String getRolesOfScope(String scopeKey) throws ScopeManagementDAOException { - Connection conn; - PreparedStatement stmt = null; - ResultSet rs = null; - String roles = null; - - try { - conn = this.getConnection(); - String sql = "SELECT ROLES FROM IDN_OAUTH2_SCOPE WHERE SCOPE_KEY = ?"; - stmt = conn.prepareStatement(sql); - stmt.setString(1, scopeKey); - rs = stmt.executeQuery(); - - if (rs.next()) { - roles = rs.getString("ROLES"); - } - return roles; - } catch (SQLException e) { - throw new ScopeManagementDAOException("Error occurred while fetching the details of the scopes.", e); - } finally { - ScopeManagementDAOUtil.cleanupResources(stmt, rs); - } - } - - @Override - public List getScopesHavingRole(String roleName) throws ScopeManagementDAOException { - Connection conn; - PreparedStatement stmt = null; - ResultSet rs = null; - List scopes; - - try { - conn = this.getConnection(); - String sql = "SELECT * FROM IDN_OAUTH2_SCOPE WHERE ROLES LIKE ?"; - stmt = conn.prepareStatement(sql); - stmt.setString(1, "%" + roleName + "%"); - rs = stmt.executeQuery(); - scopes = this.getScopesFromResultSet(rs); - return scopes; - } catch (SQLException e) { - throw new ScopeManagementDAOException("Error occurred while fetching the details of the scopes.", e); - } finally { - ScopeManagementDAOUtil.cleanupResources(stmt, rs); - } - } - - private Connection getConnection() throws SQLException { - return ScopeManagementDAOFactory.getConnection(); - } - - private List getScopesFromResultSet(ResultSet rs) throws SQLException { - List scopes = new ArrayList<>(); - Scope scope; - while (rs.next()) { - scope = new Scope(); - scope.setKey(rs.getString("SCOPE_KEY")); - scope.setName(rs.getString("NAME")); - scope.setDescription(rs.getString("DESCRIPTION")); - scope.setRoles(rs.getString("ROLES")); - scopes.add(scope); - } - return scopes; - } - -} diff --git a/components/identity-extensions/org.wso2.carbon.device.mgt.oauth.extensions/src/main/java/org/wso2/carbon/device/mgt/oauth/extensions/handlers/grant/ExtendedPasswordGrantHandler.java b/components/identity-extensions/org.wso2.carbon.device.mgt.oauth.extensions/src/main/java/org/wso2/carbon/device/mgt/oauth/extensions/handlers/grant/ExtendedPasswordGrantHandler.java new file mode 100644 index 0000000000..8a5be8bc8d --- /dev/null +++ b/components/identity-extensions/org.wso2.carbon.device.mgt.oauth.extensions/src/main/java/org/wso2/carbon/device/mgt/oauth/extensions/handlers/grant/ExtendedPasswordGrantHandler.java @@ -0,0 +1,32 @@ +/* + * Copyright (c) 2016, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. + * + * WSO2 Inc. 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 org.wso2.carbon.device.mgt.oauth.extensions.handlers.grant; + +import org.wso2.carbon.device.mgt.oauth.extensions.OAuthExtUtils; +import org.wso2.carbon.identity.oauth2.token.OAuthTokenReqMessageContext; + +@SuppressWarnings("unused") +public class ExtendedPasswordGrantHandler extends org.wso2.carbon.apimgt.keymgt.handlers.ExtendedPasswordGrantHandler { + + @Override + public boolean validateScope(OAuthTokenReqMessageContext tokReqMsgCtx) { + return OAuthExtUtils.setScopes(tokReqMsgCtx); + } + +} diff --git a/features/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher.feature/src/main/resources/conf/webapp-publisher-config.xml b/features/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher.feature/src/main/resources/conf/webapp-publisher-config.xml index bae1565071..11a76f8739 100644 --- a/features/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher.feature/src/main/resources/conf/webapp-publisher-config.xml +++ b/features/apimgt-extensions/org.wso2.carbon.apimgt.webapp.publisher.feature/src/main/resources/conf/webapp-publisher-config.xml @@ -28,6 +28,10 @@ true + + + true + default