/**
    * 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;
  
  import org.kuali.rice.core.api.util.ClassLoaderUtils;
  import org.kuali.rice.core.impl.resourceloader.ContextClassLoaderProxy;
  import org.kuali.rice.ksb.api.bus.ServiceDefinition;
  import org.kuali.rice.ksb.messaging.bam.BAMServerProxy;
  import org.springframework.aop.framework.ProxyFactory;
  import org.springframework.remoting.httpinvoker.HttpInvokerServiceExporter;
  import org.springframework.remoting.support.RemoteInvocationTraceInterceptor;
  
  import java.util.Arrays;
  import java.util.List;
  
  
  public class KSBHttpInvokerServiceExporter extends HttpInvokerServiceExporter {
  	
  	private List<Class<?>> serviceInterfaces;
  	private ServiceDefinition serviceDefinition;
  	private boolean registerTraceInterceptor = true;
  	
  	public ServiceDefinition getServiceDefinition() {
  		return this.serviceDefinition;
  	}
  
  	public void setServiceDefinition(ServiceDefinition serviceDefinition) {
  		this.serviceDefinition = serviceDefinition;
  	}
  	
  	/**
  	 * @see org.springframework.remoting.support.RemoteExporter#setRegisterTraceInterceptor(boolean)
  	 */
  	@Override
  	public void setRegisterTraceInterceptor(boolean registerTraceInterceptor) {
  	    // HttpInvokerServiceExporter.registerTraceInterceptor is no longer exposed, capture its value if set
  	    this.registerTraceInterceptor = registerTraceInterceptor;
  	    super.setRegisterTraceInterceptor(registerTraceInterceptor);
  	}
  
  	protected Object getProxyForService() {
  		checkService();
  		checkServiceInterface();
  		ProxyFactory proxyFactory = new ProxyFactory();
  		for (Class<?> serviceInterface : getServiceInterfaces()) {
  			proxyFactory.addInterface(serviceInterface);
  		}
  		if (registerTraceInterceptor == true) {
  			proxyFactory.addAdvice(new RemoteInvocationTraceInterceptor(getExporterName()));
  		}
  		ClassLoader classLoader = serviceDefinition.getServiceClassLoader();
  		if (classLoader == null) {
  		    classLoader = ClassLoaderUtils.getDefaultClassLoader();
  		}
  		Object service = ContextClassLoaderProxy.wrap(getService(), classLoader);
  		service = BAMServerProxy.wrap(service, getServiceDefinition());
  		proxyFactory.setTarget(service);
  		return proxyFactory.getProxy(classLoader);
  	}
  
  	@Override
  	protected void checkServiceInterface() throws IllegalArgumentException {
  		if (this.serviceInterfaces == null) {
  		    this.serviceInterfaces = Arrays.asList(ContextClassLoaderProxy.getInterfacesToProxy(getService()));
  		}
  		if (getServiceInterfaces().isEmpty()) {
  			throw new IllegalArgumentException("At least one service interface should be defined.");
  		}
  	}
  	
  	public List<Class<?>> getServiceInterfaces() {
  		return this.serviceInterfaces;
  	}
  
  	public void setServiceInterfaces(List<Class<?>> serviceInterfaces) {
  		this.serviceInterfaces = serviceInterfaces;
  	}
  	
  	public Object getService() {
  		return super.getService();
  	}
  	
  }