/*

  * Copyright 2006-2011 The Kuali Foundation

  *

  * Licensed under the Educational Community 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.opensource.org/licenses/ecl2.php

  *

  * 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.kuali.rice.kew.resourceloader;

 import javax.xml.namespace.QName;

 import org.apache.commons.lang.StringUtils;

 import org.kuali.rice.core.api.config.CoreConfigHelper;

 import org.kuali.rice.core.api.config.property.ConfigContext;

 import org.kuali.rice.core.api.reflect.ObjectDefinition;

 import org.kuali.rice.core.api.resourceloader.ServiceLocator;

 import org.kuali.rice.core.impl.resourceloader.BaseWrappingResourceLoader;

 import org.kuali.rice.kew.plugin.PluginRegistry;

 import org.kuali.rice.kew.service.KEWServiceLocator;

 import org.kuali.rice.kew.util.KEWConstants;

 /**

  * A resource loader which is responsible for loading resources from the Workflow ConfigContext.

  *

  * @author Kuali Rice Team (rice.collab@kuali.org)

  */

 public class CoreResourceLoader extends BaseWrappingResourceLoader {

         public static final QName NAME = new QName(CoreConfigHelper.getApplicationId(), "KEW_SPRING+PLUGIN_REGISTRY_CONTAINER_RESOURCE_LOADER");

         private final PluginRegistry registry;

         public CoreResourceLoader(ServiceLocator serviceLocator, PluginRegistry registry) {

                 super(CoreResourceLoader.NAME, serviceLocator);

                 this.registry = registry;

         }

         /**

          * Overrides the standard getService method to looks for the service in the plugin if it can't find it in the core.

          */

         public Object getService(QName serviceName) {

                 if (isRemoteService(serviceName)) {

                         return null;

                 }

                 Object service = super.getService(serviceName);

                 if (service == null && getRegistry() != null) {

                     service = getRegistry().getService(serviceName);

                 }

                 return service;

         }

         @Override

         public Object getObject(ObjectDefinition objectDefinition) {

             Object object = super.getObject(objectDefinition);

             if (object == null && getRegistry() != null) {

                 object = getRegistry().getObject(objectDefinition);

             }

             return object;

         }

         @Override

         protected boolean shouldWrapService(QName serviceName, Object service) {

                 // transaction template is not wrappable because it does not implement an interface

                 if (serviceName.getLocalPart().equals("transactionTemplate")) {

                         return false;

                 }

                 return super.shouldWrapService(serviceName, service);

         }

         @Override

         public void stop() throws Exception {

                 if (getRegistry() != null) {

                         registry.stop();

                 }

                 super.stop();

         }

         /**

          * Returns true if the given service name is one which should be loaded from the service bus.  This is used

          * primarily for embedded clients that want to reference the workgroup and user services on a standalone

          * server.

          */

         protected boolean isRemoteService(QName serviceName) {

             return (useRemoteEmailServices() &&

                             serviceName.getLocalPart().equals(KEWServiceLocator.IMMEDIATE_EMAIL_REMINDER_SERVICE));

         }

         protected boolean useRemoteEmailServices() {

             String useRemoteEmailServicesValue = ConfigContext.getCurrentContextConfig().getProperty(KEWConstants.USE_REMOTE_EMAIL_SERVICES);

             if (!StringUtils.isBlank(useRemoteEmailServicesValue)) {

                 return new Boolean(useRemoteEmailServicesValue.trim());

             }

             return false;

         }

         public PluginRegistry getRegistry() {

                 return registry;

         }

 }