chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/impl/webservices/CmisWebServicesServlet.java - chemistry-opencmis - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF 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.apache.chemistry.opencmis.server.impl.webservices;

 import java.io.IOException;
 import java.io.InputStream;
 import java.io.PrintWriter;
 import java.util.HashMap;
 import java.util.Locale;
 import java.util.Map;
 import java.util.regex.Pattern;

 import javax.servlet.ServletConfig;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import javax.xml.ws.Endpoint;
 import javax.xml.ws.soap.SOAPBinding;
 import javax.xml.ws.spi.Provider;

 import org.apache.chemistry.opencmis.commons.enums.CmisVersion;
 import org.apache.chemistry.opencmis.commons.exceptions.CmisRuntimeException;
 import org.apache.chemistry.opencmis.commons.impl.IOUtils;
 import org.apache.chemistry.opencmis.commons.impl.UrlBuilder;
 import org.apache.chemistry.opencmis.commons.server.CmisServiceFactory;
 import org.apache.chemistry.opencmis.server.impl.CmisRepositoryContextListener;
 import org.apache.chemistry.opencmis.server.shared.AbstractCmisHttpServlet;
 import org.apache.chemistry.opencmis.server.shared.CallContextHandler;
 import org.apache.chemistry.opencmis.server.shared.CsrfManager;
 import org.apache.chemistry.opencmis.server.shared.Dispatcher;
 import org.apache.commons.text.StringEscapeUtils;
 import org.apache.cxf.Bus;
 import org.apache.cxf.BusFactory;
 import org.apache.cxf.transport.servlet.CXFNonSpringServlet;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

 /**
  * CMIS Web Services servlet.
  */
 public class CmisWebServicesServlet extends CXFNonSpringServlet {

     public static final String PARAM_CMIS_VERSION = "cmisVersion";
     public static final String CMIS_VERSION = "org.apache.chemistry.opencmis.cmisVersion";
     public static final String CSRF_MANAGER = "org.apache.chemistry.opencmis.csrfManager";

     private static final long serialVersionUID = 1L;

     private static final Logger LOG = LoggerFactory.getLogger(CmisWebServicesServlet.class.getName());

     private static final int MAX_SOAP_SIZE = 10 * 1024 * 1024;

     private static final String CMIS10_PATH = "/WEB-INF/cmis10/";
     private static final String CMIS11_PATH = "/WEB-INF/cmis11/";

     private static final Pattern BASE_PATTERN = Pattern.compile("<%cmisbase%>");
     private static final Pattern CORE_PATTERN = Pattern.compile("<%cmiscore%>");
     private static final Pattern MSG_PATTERN = Pattern.compile("<%cmismsg%>");

     private CmisVersion cmisVersion;

     private Map<String, String> docs;

     private CallContextHandler callContextHandler;
     private CsrfManager csrfManager;

     @Override
     public void init(ServletConfig config) throws ServletException {

         // get CMIS version
         String cmisVersionStr = config.getInitParameter(PARAM_CMIS_VERSION);
         if (cmisVersionStr != null) {
             try {
                 cmisVersion = CmisVersion.fromValue(cmisVersionStr);
             } catch (IllegalArgumentException e) {
                 LOG.warn("CMIS version is invalid! Setting it to CMIS 1.0.");
                 cmisVersion = CmisVersion.CMIS_1_0;
             }
         } else {
             LOG.warn("CMIS version is not defined! Setting it to CMIS 1.0.");
             cmisVersion = CmisVersion.CMIS_1_0;
         }

         // initialize the call context handler
         callContextHandler = AbstractCmisHttpServlet.loadCallContextHandler(config);

         // set up WSDL and XSD documents
         docs = new HashMap<String, String>();

         String path = (cmisVersion == CmisVersion.CMIS_1_0 ? CMIS10_PATH : CMIS11_PATH);

         docs.put("wsdl", readFile(config, path + "CMISWS-Service.wsdl.template"));
         docs.put("core", readFile(config, path + "CMIS-Core.xsd.template"));
         docs.put("msg", readFile(config, path + "CMIS-Messaging.xsd.template"));

         // set up CSRF manager
         csrfManager = new CsrfManager(config);

         super.init(config);
     }

     /**
      * Returns the {@code CallContextHandler}.
      *
      * @return the {@code CallContextHandler} or {@code null} if it is not
      *         configured
      */
     protected CallContextHandler getCallContextHandler() {
         return callContextHandler;
     }

     private String readFile(ServletConfig config, String path) throws ServletException {
         InputStream stream = config.getServletContext().getResourceAsStream(path);
         if (stream == null) {
             throw new ServletException("Cannot find file '" + path + "'!");
         }

         try {
             return IOUtils.readAllLines(stream, 100000);
         } catch (IOException e) {
             throw new ServletException("Cannot read file '" + path + "': " + e.getMessage(), e);
         } finally {
             IOUtils.closeQuietly(stream);
         }
     }

     @Override
     public void handleRequest(HttpServletRequest request, HttpServletResponse response) throws ServletException {
         // set CMIS version and CSRF Manager
         request.setAttribute(CMIS_VERSION, cmisVersion);
         request.setAttribute(CSRF_MANAGER, csrfManager);

         try {
             // handle GET requests
             if (request.getMethod().equals("GET")) {
                 UrlBuilder baseUrl = compileBaseUrl(request, response);

                 String queryString = request.getQueryString();
                 if (queryString != null) {
                     String doc = docs.get(queryString.toLowerCase(Locale.ENGLISH));
                     if (doc != null) {
                         printXml(request, response, doc, baseUrl);
                         return;
                     }
                 }

                 printPage(request, response, baseUrl);
                 return;
             }

             // handle other non-POST requests
             if (!request.getMethod().equals("POST")) {
                 printError(request, response, "Not a HTTP POST request.");
                 return;
             }

             // handle POST requests
             ProtectionRequestWrapper requestWrapper = null;
             try {
                 requestWrapper = new ProtectionRequestWrapper(request, MAX_SOAP_SIZE);
             } catch (ServletException e) {
                 printError(request, response, "The request is not MTOM encoded.");
                 return;
             }

             super.handleRequest(requestWrapper, response);
         } catch (IOException ioe) {
             throw new ServletException(ioe);
         }
     }

     private void printXml(HttpServletRequest request, HttpServletResponse response, String doc, UrlBuilder baseUrl)
             throws ServletException, IOException {
         response.setStatus(HttpServletResponse.SC_OK);
         response.setContentType("text/xml");
         response.setCharacterEncoding(IOUtils.UTF8);

         String respDoc = doc;
         respDoc = BASE_PATTERN.matcher(respDoc).replaceAll(baseUrl.toString());
         respDoc = CORE_PATTERN.matcher(respDoc).replaceAll(
                 (new UrlBuilder(baseUrl)).addPath("cmis").addParameter("core").toString());
         respDoc = MSG_PATTERN.matcher(respDoc).replaceAll(
                 (new UrlBuilder(baseUrl)).addPath("cmis").addParameter("msg").toString());

         PrintWriter pw = response.getWriter();
         pw.print(respDoc);
         pw.flush();
     }

     private void printPage(HttpServletRequest request, HttpServletResponse response, UrlBuilder baseUrl)
             throws ServletException, IOException {
         response.setStatus(HttpServletResponse.SC_OK);
         response.setContentType("text/html");
         response.setCharacterEncoding(IOUtils.UTF8);

         String urlEscaped = StringEscapeUtils.escapeHtml4((new UrlBuilder(baseUrl)).addPath("cmis")
                 .addParameter("wsdl").toString());

         PrintWriter pw = response.getWriter();

         pw.print("<html><head><title>Apache Chemistry OpenCMIS - CMIS "
                 + cmisVersion.value()
                 + " Web Services</title>"
                 + "<style><!--H1 {font-size:24px;line-height:normal;font-weight:bold;background-color:#f0f0f0;color:#003366;border-bottom:1px solid #3c78b5;padding:2px;} "
                 + "BODY {font-family:Verdana,arial,sans-serif;color:black;font-size:14px;} "
                 + "HR {color:#3c78b5;height:1px;}--></style></head><body>");
         pw.print("<h1>CMIS " + cmisVersion.value() + " Web Services</h1>");
         pw.print("<p>CMIS WSDL for all services: <a href=\"" + urlEscaped + "\">" + urlEscaped + "</a></p>");

         pw.print("</body></html>");
         pw.flush();
     }

     protected void printError(HttpServletRequest request, HttpServletResponse response, String message)
             throws IOException {
         response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
         response.setContentType("text/xml");
         response.setCharacterEncoding(IOUtils.UTF8);

         PrintWriter pw = response.getWriter();

         String messageEscaped = StringEscapeUtils.escapeXml10(message);

         pw.println("<?xml version='1.0' encoding='UTF-8'?>");
         pw.println("<S:Envelope xmlns:S=\"http://schemas.xmlsoap.org/soap/envelope/\">");
         pw.println("<S:Body>");
         pw.println("<S:Fault>");
         pw.println("<faultcode>S:Client</faultcode>");
         pw.println("<faultstring>" + messageEscaped + "</faultstring>");
         pw.println("<detail>");
         pw.println("<cmisFault xmlns=\"http://docs.oasis-open.org/ns/cmis/messaging/200908/\">");
         pw.println("<type>runtime</type>");
         pw.println("<code>0</code>");
         pw.println("<message>" + messageEscaped + "</message>");
         pw.println("</cmisFault>");
         pw.println("</detail>");
         pw.println("</S:Fault>");
         pw.println("</S:Body>");
         pw.println("</S:Envelope>");

         pw.flush();
     }

     private UrlBuilder compileBaseUrl(HttpServletRequest request, HttpServletResponse response) {
         UrlBuilder result;

         String baseUrl = (String) request.getAttribute(Dispatcher.BASE_URL_ATTRIBUTE);
         if (baseUrl != null) {
             result = new UrlBuilder(baseUrl);
         } else {
             result = new UrlBuilder(request.getScheme(), request.getServerName(), request.getServerPort(), null);
             result.addPath(request.getContextPath());
             result.addPath(request.getServletPath());
         }

         return result;
     }

     @Override
     protected void loadBus(ServletConfig servletConfig) {
         super.loadBus(servletConfig);

         CmisServiceFactory factory = CmisRepositoryContextListener.getServiceFactory(servletConfig.getServletContext());

         if (factory == null) {
             throw new CmisRuntimeException("Service factory not available! Configuration problem?");
         }

         Bus bus = getBus();
         BusFactory.setDefaultBus(bus);

         if (factory.getTempDirectory() != null) {
             bus.setProperty("bus.io.CachedOutputStream.OutputDirectory", factory.getTempDirectory().getAbsolutePath());
         }
         if (factory.getMemoryThreshold() >= 0) {
             bus.setProperty("bus.io.CachedOutputStream.Threshold", String.valueOf(factory.getMemoryThreshold()));
         }
         bus.setProperty("bus.io.CachedOutputStream.MaxSize", "-1");
         if (factory.encryptTempFiles()) {
             bus.setProperty("bus.io.CachedOutputStream.CipherTransformation", "AES/CTR/PKCS5Padding");
         }

         configureInterceptors(bus);

         if (cmisVersion == CmisVersion.CMIS_1_0) {
             publish("/RepositoryService", new RepositoryService10());
             publish("/NavigationService", new NavigationService());
             publish("/ObjectService", new ObjectService10());
             publish("/VersioningService", new VersioningService());
             publish("/RelationshipService", new RelationshipService());
             publish("/DiscoveryService", new DiscoveryService());
             publish("/MultiFilingService", new MultiFilingService());
             publish("/ACLService", new AclService());
             publish("/PolicyService", new PolicyService());
         } else {
             publish("/RepositoryService", new RepositoryService());
             publish("/NavigationService", new NavigationService());
             publish("/ObjectService", new ObjectService());
             publish("/VersioningService", new VersioningService());
             publish("/RelationshipService", new RelationshipService());
             publish("/DiscoveryService", new DiscoveryService());
             publish("/MultiFilingService", new MultiFilingService());
             publish("/ACLService", new AclService());
             publish("/PolicyService", new PolicyService());
         }
     }

     /**
      * Adds and configures interceptors for OpenCMIS.
      *
      * Override this method to add more interceptors.
      */
     protected void configureInterceptors(Bus bus) {
         bus.getInInterceptors().add(new SoapActionRemoveInterceptor());
         bus.getInInterceptors().add(new CallContextHandlerInterceptor(getCallContextHandler()));
         bus.getInInterceptors().add(new UsernameTokenInterceptor());
     }

     private Endpoint publish(String address, Object implementor) {
         Provider provider = Provider.provider();
         if (provider.getClass().getName().startsWith("weblogic.")) {
             // workaround for WebLogic
             address = address + "/";
         }

         Endpoint endpoint = Endpoint.publish(address, implementor);
         SOAPBinding binding = (SOAPBinding) endpoint.getBinding();
         binding.setMTOMEnabled(true);

         return endpoint;
     }
 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF 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.apache.chemistry.opencmis.server.impl.webservices;

	import java.io.IOException;
	import java.io.InputStream;
	import java.io.PrintWriter;
	import java.util.HashMap;
	import java.util.Locale;
	import java.util.Map;
	import java.util.regex.Pattern;

	import javax.servlet.ServletConfig;
	import javax.servlet.ServletException;
	import javax.servlet.http.HttpServletRequest;
	import javax.servlet.http.HttpServletResponse;
	import javax.xml.ws.Endpoint;
	import javax.xml.ws.soap.SOAPBinding;
	import javax.xml.ws.spi.Provider;

	import org.apache.chemistry.opencmis.commons.enums.CmisVersion;
	import org.apache.chemistry.opencmis.commons.exceptions.CmisRuntimeException;
	import org.apache.chemistry.opencmis.commons.impl.IOUtils;
	import org.apache.chemistry.opencmis.commons.impl.UrlBuilder;
	import org.apache.chemistry.opencmis.commons.server.CmisServiceFactory;
	import org.apache.chemistry.opencmis.server.impl.CmisRepositoryContextListener;
	import org.apache.chemistry.opencmis.server.shared.AbstractCmisHttpServlet;
	import org.apache.chemistry.opencmis.server.shared.CallContextHandler;
	import org.apache.chemistry.opencmis.server.shared.CsrfManager;
	import org.apache.chemistry.opencmis.server.shared.Dispatcher;
	import org.apache.commons.text.StringEscapeUtils;
	import org.apache.cxf.Bus;
	import org.apache.cxf.BusFactory;
	import org.apache.cxf.transport.servlet.CXFNonSpringServlet;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;

	/**
	* CMIS Web Services servlet.
	*/
	public class CmisWebServicesServlet extends CXFNonSpringServlet {

	public static final String PARAM_CMIS_VERSION = "cmisVersion";
	public static final String CMIS_VERSION = "org.apache.chemistry.opencmis.cmisVersion";
	public static final String CSRF_MANAGER = "org.apache.chemistry.opencmis.csrfManager";

	private static final long serialVersionUID = 1L;

	private static final Logger LOG = LoggerFactory.getLogger(CmisWebServicesServlet.class.getName());

	private static final int MAX_SOAP_SIZE = 10 * 1024 * 1024;

	private static final String CMIS10_PATH = "/WEB-INF/cmis10/";
	private static final String CMIS11_PATH = "/WEB-INF/cmis11/";

	private static final Pattern BASE_PATTERN = Pattern.compile("<%cmisbase%>");
	private static final Pattern CORE_PATTERN = Pattern.compile("<%cmiscore%>");
	private static final Pattern MSG_PATTERN = Pattern.compile("<%cmismsg%>");

	private CmisVersion cmisVersion;

	private Map<String, String> docs;

	private CallContextHandler callContextHandler;
	private CsrfManager csrfManager;

	@Override
	public void init(ServletConfig config) throws ServletException {

	// get CMIS version
	String cmisVersionStr = config.getInitParameter(PARAM_CMIS_VERSION);
	if (cmisVersionStr != null) {
	try {
	cmisVersion = CmisVersion.fromValue(cmisVersionStr);
	} catch (IllegalArgumentException e) {
	LOG.warn("CMIS version is invalid! Setting it to CMIS 1.0.");
	cmisVersion = CmisVersion.CMIS_1_0;
	}
	} else {
	LOG.warn("CMIS version is not defined! Setting it to CMIS 1.0.");
	cmisVersion = CmisVersion.CMIS_1_0;
	}

	// initialize the call context handler
	callContextHandler = AbstractCmisHttpServlet.loadCallContextHandler(config);

	// set up WSDL and XSD documents
	docs = new HashMap<String, String>();

	String path = (cmisVersion == CmisVersion.CMIS_1_0 ? CMIS10_PATH : CMIS11_PATH);

	docs.put("wsdl", readFile(config, path + "CMISWS-Service.wsdl.template"));
	docs.put("core", readFile(config, path + "CMIS-Core.xsd.template"));
	docs.put("msg", readFile(config, path + "CMIS-Messaging.xsd.template"));

	// set up CSRF manager
	csrfManager = new CsrfManager(config);

	super.init(config);
	}

	/**
	* Returns the {@code CallContextHandler}.
	*
	* @return the {@code CallContextHandler} or {@code null} if it is not
	* configured
	*/
	protected CallContextHandler getCallContextHandler() {
	return callContextHandler;
	}

	private String readFile(ServletConfig config, String path) throws ServletException {
	InputStream stream = config.getServletContext().getResourceAsStream(path);
	if (stream == null) {
	throw new ServletException("Cannot find file '" + path + "'!");
	}

	try {
	return IOUtils.readAllLines(stream, 100000);
	} catch (IOException e) {
	throw new ServletException("Cannot read file '" + path + "': " + e.getMessage(), e);
	} finally {
	IOUtils.closeQuietly(stream);
	}
	}

	@Override
	public void handleRequest(HttpServletRequest request, HttpServletResponse response) throws ServletException {
	// set CMIS version and CSRF Manager
	request.setAttribute(CMIS_VERSION, cmisVersion);
	request.setAttribute(CSRF_MANAGER, csrfManager);

	try {
	// handle GET requests
	if (request.getMethod().equals("GET")) {
	UrlBuilder baseUrl = compileBaseUrl(request, response);

	String queryString = request.getQueryString();
	if (queryString != null) {
	String doc = docs.get(queryString.toLowerCase(Locale.ENGLISH));
	if (doc != null) {
	printXml(request, response, doc, baseUrl);
	return;
	}
	}

	printPage(request, response, baseUrl);
	return;
	}

	// handle other non-POST requests
	if (!request.getMethod().equals("POST")) {
	printError(request, response, "Not a HTTP POST request.");
	return;
	}

	// handle POST requests
	ProtectionRequestWrapper requestWrapper = null;
	try {
	requestWrapper = new ProtectionRequestWrapper(request, MAX_SOAP_SIZE);
	} catch (ServletException e) {
	printError(request, response, "The request is not MTOM encoded.");
	return;
	}

	super.handleRequest(requestWrapper, response);
	} catch (IOException ioe) {
	throw new ServletException(ioe);
	}
	}

	private void printXml(HttpServletRequest request, HttpServletResponse response, String doc, UrlBuilder baseUrl)
	throws ServletException, IOException {
	response.setStatus(HttpServletResponse.SC_OK);
	response.setContentType("text/xml");
	response.setCharacterEncoding(IOUtils.UTF8);

	String respDoc = doc;
	respDoc = BASE_PATTERN.matcher(respDoc).replaceAll(baseUrl.toString());
	respDoc = CORE_PATTERN.matcher(respDoc).replaceAll(
	(new UrlBuilder(baseUrl)).addPath("cmis").addParameter("core").toString());
	respDoc = MSG_PATTERN.matcher(respDoc).replaceAll(
	(new UrlBuilder(baseUrl)).addPath("cmis").addParameter("msg").toString());

	PrintWriter pw = response.getWriter();
	pw.print(respDoc);
	pw.flush();
	}

	private void printPage(HttpServletRequest request, HttpServletResponse response, UrlBuilder baseUrl)
	throws ServletException, IOException {
	response.setStatus(HttpServletResponse.SC_OK);
	response.setContentType("text/html");
	response.setCharacterEncoding(IOUtils.UTF8);

	String urlEscaped = StringEscapeUtils.escapeHtml4((new UrlBuilder(baseUrl)).addPath("cmis")
	.addParameter("wsdl").toString());

	PrintWriter pw = response.getWriter();

	pw.print("<html><head><title>Apache Chemistry OpenCMIS - CMIS "
	+ cmisVersion.value()
	+ " Web Services</title>"
	+ "<style><!--H1 {font-size:24px;line-height:normal;font-weight:bold;background-color:#f0f0f0;color:#003366;border-bottom:1px solid #3c78b5;padding:2px;} "
	+ "BODY {font-family:Verdana,arial,sans-serif;color:black;font-size:14px;} "
	+ "HR {color:#3c78b5;height:1px;}--></style></head><body>");
	pw.print("<h1>CMIS " + cmisVersion.value() + " Web Services</h1>");
	pw.print("<p>CMIS WSDL for all services: <a href=\"" + urlEscaped + "\">" + urlEscaped + "</a></p>");

	pw.print("</body></html>");
	pw.flush();
	}

	protected void printError(HttpServletRequest request, HttpServletResponse response, String message)
	throws IOException {
	response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
	response.setContentType("text/xml");
	response.setCharacterEncoding(IOUtils.UTF8);

	PrintWriter pw = response.getWriter();

	String messageEscaped = StringEscapeUtils.escapeXml10(message);

	pw.println("<?xml version='1.0' encoding='UTF-8'?>");
	pw.println("<S:Envelope xmlns:S=\"http://schemas.xmlsoap.org/soap/envelope/\">");
	pw.println("<S:Body>");
	pw.println("<S:Fault>");
	pw.println("<faultcode>S:Client</faultcode>");
	pw.println("<faultstring>" + messageEscaped + "</faultstring>");
	pw.println("<detail>");
	pw.println("<cmisFault xmlns=\"http://docs.oasis-open.org/ns/cmis/messaging/200908/\">");
	pw.println("<type>runtime</type>");
	pw.println("<code>0</code>");
	pw.println("<message>" + messageEscaped + "</message>");
	pw.println("</cmisFault>");
	pw.println("</detail>");
	pw.println("</S:Fault>");
	pw.println("</S:Body>");
	pw.println("</S:Envelope>");

	pw.flush();
	}

	private UrlBuilder compileBaseUrl(HttpServletRequest request, HttpServletResponse response) {
	UrlBuilder result;

	String baseUrl = (String) request.getAttribute(Dispatcher.BASE_URL_ATTRIBUTE);
	if (baseUrl != null) {
	result = new UrlBuilder(baseUrl);
	} else {
	result = new UrlBuilder(request.getScheme(), request.getServerName(), request.getServerPort(), null);
	result.addPath(request.getContextPath());
	result.addPath(request.getServletPath());
	}

	return result;
	}

	@Override
	protected void loadBus(ServletConfig servletConfig) {
	super.loadBus(servletConfig);

	CmisServiceFactory factory = CmisRepositoryContextListener.getServiceFactory(servletConfig.getServletContext());

	if (factory == null) {
	throw new CmisRuntimeException("Service factory not available! Configuration problem?");
	}

	Bus bus = getBus();
	BusFactory.setDefaultBus(bus);

	if (factory.getTempDirectory() != null) {
	bus.setProperty("bus.io.CachedOutputStream.OutputDirectory", factory.getTempDirectory().getAbsolutePath());
	}
	if (factory.getMemoryThreshold() >= 0) {
	bus.setProperty("bus.io.CachedOutputStream.Threshold", String.valueOf(factory.getMemoryThreshold()));
	}
	bus.setProperty("bus.io.CachedOutputStream.MaxSize", "-1");
	if (factory.encryptTempFiles()) {
	bus.setProperty("bus.io.CachedOutputStream.CipherTransformation", "AES/CTR/PKCS5Padding");
	}

	configureInterceptors(bus);

	if (cmisVersion == CmisVersion.CMIS_1_0) {
	publish("/RepositoryService", new RepositoryService10());
	publish("/NavigationService", new NavigationService());
	publish("/ObjectService", new ObjectService10());
	publish("/VersioningService", new VersioningService());
	publish("/RelationshipService", new RelationshipService());
	publish("/DiscoveryService", new DiscoveryService());
	publish("/MultiFilingService", new MultiFilingService());
	publish("/ACLService", new AclService());
	publish("/PolicyService", new PolicyService());
	} else {
	publish("/RepositoryService", new RepositoryService());
	publish("/NavigationService", new NavigationService());
	publish("/ObjectService", new ObjectService());
	publish("/VersioningService", new VersioningService());
	publish("/RelationshipService", new RelationshipService());
	publish("/DiscoveryService", new DiscoveryService());
	publish("/MultiFilingService", new MultiFilingService());
	publish("/ACLService", new AclService());
	publish("/PolicyService", new PolicyService());
	}
	}

	/**
	* Adds and configures interceptors for OpenCMIS.
	*
	* Override this method to add more interceptors.
	*/
	protected void configureInterceptors(Bus bus) {
	bus.getInInterceptors().add(new SoapActionRemoveInterceptor());
	bus.getInInterceptors().add(new CallContextHandlerInterceptor(getCallContextHandler()));
	bus.getInInterceptors().add(new UsernameTokenInterceptor());
	}

	private Endpoint publish(String address, Object implementor) {
	Provider provider = Provider.provider();
	if (provider.getClass().getName().startsWith("weblogic.")) {
	// workaround for WebLogic
	address = address + "/";
	}

	Endpoint endpoint = Endpoint.publish(address, implementor);
	SOAPBinding binding = (SOAPBinding) endpoint.getBinding();
	binding.setMTOMEnabled(true);

	return endpoint;
	}
	}