/**
    * Copyright 2005-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.ksb.messaging.serviceexporters;
  
  import java.util.List;
  
  import org.apache.cxf.Bus;
  import org.apache.cxf.binding.BindingFactoryManager;
  import org.apache.cxf.endpoint.ServerRegistry;
  import org.apache.cxf.interceptor.LoggingInInterceptor;
  import org.apache.cxf.interceptor.LoggingOutInterceptor;
  import org.apache.cxf.jaxrs.JAXRSBindingFactory;
  import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
  import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
  import org.apache.log4j.Logger;
  import org.kuali.rice.core.api.exception.RiceRuntimeException;
  import org.kuali.rice.ksb.api.bus.ServiceDefinition;
  import org.kuali.rice.ksb.api.bus.support.RestServiceDefinition;
  
  
  /**
   * ServiceExporter for RESTful services.  This class handles the service binding and exposure via CXF.
   * @author Kuali Rice Team (rice.collab@kuali.org)
   */
  public class RESTServiceExporter extends AbstractWebServiceExporter implements ServiceExporter {
  
  	private static final Logger LOG = Logger.getLogger(RESTServiceExporter.class);
  
  	public RESTServiceExporter(RestServiceDefinition serviceDefinition, Bus cxfBus, ServerRegistry cxfServerRegistry) {
  		super(serviceDefinition, cxfBus, cxfServerRegistry);
  	}
  
  	/**
  	 * This publishes the cxf service onto the cxf bus.
  	 *
  	 * @param serviceImpl
  	 * @throws Exception
  	 */
  	@Override
  	public void publishService(ServiceDefinition serviceDefinition, Object serviceImpl, String address) {
  		RestServiceDefinition restServiceDef = (RestServiceDefinition)serviceDefinition;
  
  		LOG.info("Creating JAXRSService " + restServiceDef.getServiceName());
  		JAXRSServerFactoryBean svrFactory = new JAXRSServerFactoryBean();
          svrFactory.setBus(getCXFBus());
  
          List<Object> resources = restServiceDef.getResources();
          if (resources != null && !resources.isEmpty()) {
          	svrFactory.setServiceBeans(resources);
          } else {
          	try {
          		Class<?> resourceClass = this.getClass().getClassLoader().loadClass(restServiceDef.getResourceClass());
          		svrFactory.setResourceClasses(resourceClass);
          		svrFactory.setResourceProvider(resourceClass, new SingletonResourceProvider(serviceImpl));
          	} catch (ClassNotFoundException e) {
          		throw new RiceRuntimeException("Failed to publish the service because resource class could not be loaded: " + restServiceDef.getResourceClass(), e);
          	}
          }
  
          svrFactory.setServiceName(restServiceDef.getServiceName());
          svrFactory.setAddress(address);
          svrFactory.setExtensionMappings(restServiceDef.getExtensionMappings());
          svrFactory.setLanguageMappings(restServiceDef.getLanguageMappings());
  
          List<Object> providers = restServiceDef.getProviders();
          if (providers != null) {
          	svrFactory.setProviders(providers);
          }
  
          BindingFactoryManager bindingFactoryManager = getCXFBus().getExtension(BindingFactoryManager.class);
          JAXRSBindingFactory bindingFactory = new JAXRSBindingFactory();
          bindingFactory.setBus(getCXFBus());
          bindingFactoryManager.registerBindingFactory(JAXRSBindingFactory.JAXRS_BINDING_ID, bindingFactory);
  
  		//Set logging interceptors
          if (LOG.isDebugEnabled()) {
          	svrFactory.getInInterceptors().add(new LoggingInInterceptor());
          }
  //        svrFactory.getInInterceptors().add(new RESTConnector.VerifyingInInterceptor());
          if (LOG.isDebugEnabled()) {
          	svrFactory.getOutInterceptors().add(new LoggingOutInterceptor());
          }
  //		svrFactory.getOutInterceptors().add(new RESTConnector.SigningOutInterceptor());
  
          svrFactory.setPublishedEndpointUrl(restServiceDef.getEndpointUrl().toExternalForm());
  		svrFactory.create();
 	}
 
 }