Since I'm not sure where to post code to I'll do it here, there is nothing proprietary about it, most of it is derived from your samples:
package gov.nih.niaid.eric;
import org.alfresco.www.ws.model.content.Query;
import org.alfresco.www.ws.model.content.QueryLanguageEnum;
import org.alfresco.www.ws.model.content.Reference;
import org.alfresco.www.ws.model.content.ResultSet;
import org.alfresco.www.ws.model.content.ResultSetRow;
import org.alfresco.www.ws.model.content.Store;
import org.alfresco.www.ws.model.content.StoreEnum;
import org.alfresco.www.ws.service.authentication.AuthenticationResult;
import org.alfresco.www.ws.service.authentication.AuthenticationServiceLocator;
import org.alfresco.www.ws.service.authentication.AuthenticationServiceSoapBindingStub;
import org.alfresco.www.ws.service.content.ContentServiceLocator;
import org.alfresco.www.ws.service.content.ContentServiceSoapBindingStub;
import org.alfresco.www.ws.service.content.ReadResult;
import org.alfresco.www.ws.service.repository.QueryResult;
import org.alfresco.www.ws.service.repository.RepositoryFault;
import org.alfresco.www.ws.service.repository.RepositoryServiceLocator;
import org.alfresco.www.ws.service.repository.RepositoryServiceSoapBindingStub;
import org.apache.axis.EngineConfiguration;
import org.apache.axis.configuration.FileProvider;
import org.apache.ws.security.WSPasswordCallback;
import javax.security.auth.callback.Callback;
import javax.security.auth.callback.CallbackHandler;
import javax.security.auth.callback.UnsupportedCallbackException;
import javax.xml.rpc.ServiceException;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;
import java.rmi.RemoteException;
/**
* Web service sample 1.
* <p/>
* Connect to the reposity and get a list of all the stores available in the repository.
*
* @author Roy Wetherall
*/
public class AlfrescoRepositoryHelper implements CallbackHandler {
/**
* Admin user name and password used to connect to the repository we can change this to user with less privs
*/
public static final String USERNAME = "admin";
public static final String PASSWORD = "admin";
private static RepositoryServiceSoapBindingStub repositoryService = null;
public static String currentTicket;
/**
* WS security information, don't change this, it's need to for proper callback in the headers.
*/
public static final String WS_SECURITY_INFO =
"<deployment xmlns='http://xml.apache.org/axis/wsdd/' xmlns:java='http://xml.apache.org/axis/wsdd/providers/java'>" +
" <transport name='http' pivot='java
rg.apache.axis.transport.http.HTTPSender'/>" +
" <globalConfiguration >" +
" <requestFlow >" +
" <handler type='javarg.apache.ws.axis.security.WSDoAllSender' >" +
" <parameter name='action' value='UsernameToken'/>" +
" <parameter name='user' value='ticket'/>" +
" <parameter name='passwordCallbackClass' value='gov.nih.niaid.eric.AlfrescoRepositoryHelper'/>" +
" <parameter name='passwordType' value='PasswordText'/>" +
" </handler>" +
" </requestFlow >" +
" </globalConfiguration>" +
"</deployment>";
public static String getContentLocation(final String contentToFind, final String storeLocation) throws IOException, ServiceException, NullPointerException {
//Gets an authentication to the repo and gets a ticket to work with.
final AuthenticationServiceSoapBindingStub authenticationService = AlfrescoRepositoryHelper.getTicket();
//Executes the search which returns the file in question.
final Reference myNode = findContent(contentToFind, storeLocation);
// Get the content service
final ContentServiceSoapBindingStub contentService = getContentWebService();
// Read the newly added content from the respository
final ReadResult readResult = contentService.read(myNode);
final String contentLocation = getContentURL(AlfrescoRepositoryHelper.currentTicket, readResult.getUrl());
// End the session
assert authenticationService != null;
authenticationService.endSession();
return contentLocation;
}
private static AuthenticationServiceSoapBindingStub getTicket() throws ServiceException, RemoteException {
final AuthenticationServiceSoapBindingStub authenticationService = (AuthenticationServiceSoapBindingStub) new AuthenticationServiceLocator().getAuthenticationService();
// Get a reference to the respository web service
repositoryService = getRepositoryWebService();
// Start the session
final AuthenticationResult result = authenticationService.startSession(AlfrescoRepositoryHelper.USERNAME, AlfrescoRepositoryHelper.PASSWORD);
AlfrescoRepositoryHelper.currentTicket = result.getTicket();
return authenticationService;
}
/**
* Executes a query looking for theContent in the storeLocation and returns the first item found.
*
* @return returns a content reference item which contains the information about the page we're trying to display
* @throws java.rmi.RemoteException Remove exception
* @throws org.alfresco.www.ws.service.repository.RepositoryFault
* Repository fault
* @throws NullPointerException when a content is not found. The portlet is responsible for dealing with that and displaying the appropriate message.
*/
private static Reference findContent(final String theContent, final String storeLocation) throws RemoteException, RepositoryFault, NullPointerException {
// Create a store object referencing the main spaced store
final Store store = new Store(StoreEnum.workspace, storeLocation);
// Create a query object, look for the item specified in the theContent variable
final Query query = new Query(QueryLanguageEnum.lucene, theContent);
// Execute the query
final QueryResult queryResult = repositoryService.query(store, query, false);
// Display the results
final ResultSet resultSet = queryResult.getResultSet();
final ResultSetRow row = resultSet.getRows(0);
Reference reference = null;
if (row == null) {
return new Reference();
} else {
// Get the id of the first result
final String firstResultId = row.getNode().getId();
reference = new Reference(store, firstResultId, null);
}
return reference;
}
/**
* This method gets the content from the download servlet for a given URL and returns it as a string.
*
* @param ticket the current ticket
* @param strUrl the content URL
* @return the content as a string
* @throws IOException
*/
private static String getContentURL(final String ticket, String strUrl) throws IOException {
//build the URL with ticket
strUrl += "?ticket=" + ticket;
// Connect to donwload servlet
final StringBuilder readContent = new StringBuilder();
final URL url = new URL(strUrl);
final URLConnection conn = url.openConnection();
final InputStream is = conn.getInputStream();
int read = is.read();
while (read != -1)
{
readContent.append((char)read);
read = is.read();
}
return readContent.toString();
}
/**
* Get the respository web service.
*
* @return the respository web service
* @throws ServiceException Service Exception
*/
private static RepositoryServiceSoapBindingStub getRepositoryWebService() throws ServiceException {
// Create the respository service, adding the WS security header information
final EngineConfiguration config = new FileProvider(new ByteArrayInputStream(AlfrescoRepositoryHelper.WS_SECURITY_INFO.getBytes()));
final RepositoryServiceLocator repositoryServiceLocator = new RepositoryServiceLocator(config);
final RepositoryServiceSoapBindingStub repositoryService = (RepositoryServiceSoapBindingStub) repositoryServiceLocator.getRepositoryService();
return repositoryService;
}
/**
* The implementation of the passwrod call back used by the WS Security
* This is an implementation provided by Alfresco
* @see javax.security.auth.callback.CallbackHandler#handle(javax.security.auth.callback.Callback[])
*/
public void handle(final Callback[] callbacks) throws IOException, UnsupportedCallbackException {
for (Callback callback : callbacks) {
if (callback instanceof WSPasswordCallback) {
final WSPasswordCallback pc = (WSPasswordCallback) callback;
pc.setPassword(currentTicket);
} else {
throw new UnsupportedCallbackException(callback, "Unrecognized Callback");
}
}
}
/**
* Get the content web service
*
* @return content web service
* @throws ServiceException
*/
private static ContentServiceSoapBindingStub getContentWebService() throws ServiceException {
// Create the content service, adding the WS security header information
final EngineConfiguration config = new FileProvider(new ByteArrayInputStream(AlfrescoRepositoryHelper.WS_SECURITY_INFO.getBytes()));
final ContentServiceLocator contentServiceLocator = new ContentServiceLocator(config);
return (ContentServiceSoapBindingStub) contentServiceLocator.getContentService();
}
}
package gov.nih.niaid.eric;
import org.alfresco.www.ws.model.content.Query;
import org.alfresco.www.ws.model.content.QueryLanguageEnum;
import org.alfresco.www.ws.model.content.Reference;
import org.alfresco.www.ws.model.content.ResultSet;
import org.alfresco.www.ws.model.content.ResultSetRow;
import org.alfresco.www.ws.model.content.Store;
import org.alfresco.www.ws.model.content.StoreEnum;
import org.alfresco.www.ws.service.authentication.AuthenticationResult;
import org.alfresco.www.ws.service.authentication.AuthenticationServiceLocator;
import org.alfresco.www.ws.service.authentication.AuthenticationServiceSoapBindingStub;
import org.alfresco.www.ws.service.content.ContentServiceLocator;
import org.alfresco.www.ws.service.content.ContentServiceSoapBindingStub;
import org.alfresco.www.ws.service.content.ReadResult;
import org.alfresco.www.ws.service.repository.QueryResult;
import org.alfresco.www.ws.service.repository.RepositoryFault;
import org.alfresco.www.ws.service.repository.RepositoryServiceLocator;
import org.alfresco.www.ws.service.repository.RepositoryServiceSoapBindingStub;
import org.apache.axis.EngineConfiguration;
import org.apache.axis.configuration.FileProvider;
import org.apache.ws.security.WSPasswordCallback;
import javax.security.auth.callback.Callback;
import javax.security.auth.callback.CallbackHandler;
import javax.security.auth.callback.UnsupportedCallbackException;
import javax.xml.rpc.ServiceException;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;
import java.rmi.RemoteException;
/**
* Web service sample 1.
* <p/>
* Connect to the reposity and get a list of all the stores available in the repository.
*
* @author Roy Wetherall
*/
public class AlfrescoRepositoryHelper implements CallbackHandler {
/**
* Admin user name and password used to connect to the repository we can change this to user with less privs
*/
public static final String USERNAME = "admin";
public static final String PASSWORD = "admin";
private static RepositoryServiceSoapBindingStub repositoryService = null;
public static String currentTicket;
/**
* WS security information, don't change this, it's need to for proper callback in the headers.
*/
public static final String WS_SECURITY_INFO =
"<deployment xmlns='http://xml.apache.org/axis/wsdd/' xmlns:java='http://xml.apache.org/axis/wsdd/providers/java'>" +
" <transport name='http' pivot='java
rg.apache.axis.transport.http.HTTPSender'/>" +" <globalConfiguration >" +
" <requestFlow >" +
" <handler type='java
rg.apache.ws.axis.security.WSDoAllSender' >" +" <parameter name='action' value='UsernameToken'/>" +
" <parameter name='user' value='ticket'/>" +
" <parameter name='passwordCallbackClass' value='gov.nih.niaid.eric.AlfrescoRepositoryHelper'/>" +
" <parameter name='passwordType' value='PasswordText'/>" +
" </handler>" +
" </requestFlow >" +
" </globalConfiguration>" +
"</deployment>";
public static String getContentLocation(final String contentToFind, final String storeLocation) throws IOException, ServiceException, NullPointerException {
//Gets an authentication to the repo and gets a ticket to work with.
final AuthenticationServiceSoapBindingStub authenticationService = AlfrescoRepositoryHelper.getTicket();
//Executes the search which returns the file in question.
final Reference myNode = findContent(contentToFind, storeLocation);
// Get the content service
final ContentServiceSoapBindingStub contentService = getContentWebService();
// Read the newly added content from the respository
final ReadResult readResult = contentService.read(myNode);
final String contentLocation = getContentURL(AlfrescoRepositoryHelper.currentTicket, readResult.getUrl());
// End the session
assert authenticationService != null;
authenticationService.endSession();
return contentLocation;
}
private static AuthenticationServiceSoapBindingStub getTicket() throws ServiceException, RemoteException {
final AuthenticationServiceSoapBindingStub authenticationService = (AuthenticationServiceSoapBindingStub) new AuthenticationServiceLocator().getAuthenticationService();
// Get a reference to the respository web service
repositoryService = getRepositoryWebService();
// Start the session
final AuthenticationResult result = authenticationService.startSession(AlfrescoRepositoryHelper.USERNAME, AlfrescoRepositoryHelper.PASSWORD);
AlfrescoRepositoryHelper.currentTicket = result.getTicket();
return authenticationService;
}
/**
* Executes a query looking for theContent in the storeLocation and returns the first item found.
*
* @return returns a content reference item which contains the information about the page we're trying to display
* @throws java.rmi.RemoteException Remove exception
* @throws org.alfresco.www.ws.service.repository.RepositoryFault
* Repository fault
* @throws NullPointerException when a content is not found. The portlet is responsible for dealing with that and displaying the appropriate message.
*/
private static Reference findContent(final String theContent, final String storeLocation) throws RemoteException, RepositoryFault, NullPointerException {
// Create a store object referencing the main spaced store
final Store store = new Store(StoreEnum.workspace, storeLocation);
// Create a query object, look for the item specified in the theContent variable
final Query query = new Query(QueryLanguageEnum.lucene, theContent);
// Execute the query
final QueryResult queryResult = repositoryService.query(store, query, false);
// Display the results
final ResultSet resultSet = queryResult.getResultSet();
final ResultSetRow row = resultSet.getRows(0);
Reference reference = null;
if (row == null) {
return new Reference();
} else {
// Get the id of the first result
final String firstResultId = row.getNode().getId();
reference = new Reference(store, firstResultId, null);
}
return reference;
}
/**
* This method gets the content from the download servlet for a given URL and returns it as a string.
*
* @param ticket the current ticket
* @param strUrl the content URL
* @return the content as a string
* @throws IOException
*/
private static String getContentURL(final String ticket, String strUrl) throws IOException {
//build the URL with ticket
strUrl += "?ticket=" + ticket;
// Connect to donwload servlet
final StringBuilder readContent = new StringBuilder();
final URL url = new URL(strUrl);
final URLConnection conn = url.openConnection();
final InputStream is = conn.getInputStream();
int read = is.read();
while (read != -1)
{
readContent.append((char)read);
read = is.read();
}
return readContent.toString();
}
/**
* Get the respository web service.
*
* @return the respository web service
* @throws ServiceException Service Exception
*/
private static RepositoryServiceSoapBindingStub getRepositoryWebService() throws ServiceException {
// Create the respository service, adding the WS security header information
final EngineConfiguration config = new FileProvider(new ByteArrayInputStream(AlfrescoRepositoryHelper.WS_SECURITY_INFO.getBytes()));
final RepositoryServiceLocator repositoryServiceLocator = new RepositoryServiceLocator(config);
final RepositoryServiceSoapBindingStub repositoryService = (RepositoryServiceSoapBindingStub) repositoryServiceLocator.getRepositoryService();
return repositoryService;
}
/**
* The implementation of the passwrod call back used by the WS Security
* This is an implementation provided by Alfresco
* @see javax.security.auth.callback.CallbackHandler#handle(javax.security.auth.callback.Callback[])
*/
public void handle(final Callback[] callbacks) throws IOException, UnsupportedCallbackException {
for (Callback callback : callbacks) {
if (callback instanceof WSPasswordCallback) {
final WSPasswordCallback pc = (WSPasswordCallback) callback;
pc.setPassword(currentTicket);
} else {
throw new UnsupportedCallbackException(callback, "Unrecognized Callback");
}
}
}
/**
* Get the content web service
*
* @return content web service
* @throws ServiceException
*/
private static ContentServiceSoapBindingStub getContentWebService() throws ServiceException {
// Create the content service, adding the WS security header information
final EngineConfiguration config = new FileProvider(new ByteArrayInputStream(AlfrescoRepositoryHelper.WS_SECURITY_INFO.getBytes()));
final ContentServiceLocator contentServiceLocator = new ContentServiceLocator(config);
return (ContentServiceSoapBindingStub) contentServiceLocator.getContentService();
}
}
