mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-08-07 17:49:17 +00:00
d90fd683b3
6846: used ] instead of } in ${ldap.synchronisation.userIdAttributeName]
6856: Fixed 2 NPEs, one reported by MIT and one found by Jan (WCM-835)
6859: Truncate an existing file when uploading via FTP. WCM-836.
6869: Removed temporary files and folders from deploy-installer project
6870: Updated ignore property
6875: Fix for AWC-1605
6878: Fix for AWC-1587
6880: Fix for French language pack - locked_user message
6883: Fix for AWC-1565
6884: Relax trhe permissions required to get the parent links from a child node
6891: Fix for AR-1781 and AR-1782 (requires CHK-1451)
6892: Fixed AR-1777: Node status not updated for addition and removal of secondary associations (affects index tracking)
6893: Sample for replicating content store sample
6896: Added JVM shutdown check into inner loop to get faster breakout in the event of shutdown.
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@6899 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
715 lines
26 KiB
Java
715 lines
26 KiB
Java
/*
|
|
* Copyright (C) 2005-2007 Alfresco Software Limited.
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU General Public License
|
|
* as published by the Free Software Foundation; either version 2
|
|
* of the License, or (at your option) any later version.
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
|
|
* As a special exception to the terms and conditions of version 2.0 of
|
|
* the GPL, you may redistribute this Program in connection with Free/Libre
|
|
* and Open Source Software ("FLOSS") applications as described in Alfresco's
|
|
* FLOSS exception. You should have recieved a copy of the text describing
|
|
* the FLOSS exception, and it is also available here:
|
|
* http://www.alfresco.com/legal/licensing"
|
|
*/
|
|
package org.alfresco.web.scripts;
|
|
|
|
import java.io.IOException;
|
|
import java.io.InputStream;
|
|
import java.io.InputStreamReader;
|
|
import java.io.Reader;
|
|
import java.io.UnsupportedEncodingException;
|
|
import java.util.ArrayList;
|
|
import java.util.Arrays;
|
|
import java.util.List;
|
|
|
|
import org.alfresco.error.AlfrescoRuntimeException;
|
|
import org.alfresco.model.ContentModel;
|
|
import org.alfresco.repo.security.authentication.AuthenticationUtil;
|
|
import org.alfresco.repo.transaction.RetryingTransactionHelper;
|
|
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
|
|
import org.alfresco.service.cmr.model.FileFolderService;
|
|
import org.alfresco.service.cmr.model.FileInfo;
|
|
import org.alfresco.service.cmr.model.FileNotFoundException;
|
|
import org.alfresco.service.cmr.repository.ContentReader;
|
|
import org.alfresco.service.cmr.repository.ContentService;
|
|
import org.alfresco.service.cmr.repository.ContentWriter;
|
|
import org.alfresco.service.cmr.repository.NodeRef;
|
|
import org.alfresco.service.cmr.repository.NodeService;
|
|
import org.alfresco.service.cmr.repository.ScriptLocation;
|
|
import org.alfresco.service.cmr.repository.StoreRef;
|
|
import org.alfresco.service.cmr.search.ResultSet;
|
|
import org.alfresco.service.cmr.search.SearchService;
|
|
import org.alfresco.service.cmr.security.PermissionService;
|
|
import org.alfresco.service.namespace.NamespaceService;
|
|
import org.alfresco.util.AbstractLifecycleBean;
|
|
import org.springframework.beans.BeansException;
|
|
import org.springframework.context.ApplicationContext;
|
|
import org.springframework.context.ApplicationContextAware;
|
|
import org.springframework.context.ApplicationEvent;
|
|
import org.springframework.context.ApplicationListener;
|
|
|
|
import freemarker.cache.TemplateLoader;
|
|
|
|
|
|
/**
|
|
* Repository based Web Script Store
|
|
*
|
|
* @author davidc
|
|
*/
|
|
public class RepoStore implements WebScriptStore, ApplicationContextAware, ApplicationListener
|
|
{
|
|
private ProcessorLifecycle lifecycle = new ProcessorLifecycle();
|
|
protected boolean mustExist = false;
|
|
protected StoreRef repoStore;
|
|
protected String repoPath;
|
|
protected NodeRef baseNodeRef;
|
|
protected String baseDir;
|
|
|
|
// dependencies
|
|
protected RetryingTransactionHelper retryingTransactionHelper;
|
|
protected SearchService searchService;
|
|
protected NodeService nodeService;
|
|
protected ContentService contentService;
|
|
protected FileFolderService fileService;
|
|
protected NamespaceService namespaceService;
|
|
protected PermissionService permissionService;
|
|
|
|
|
|
/**
|
|
* Sets helper that provides transaction callbacks
|
|
*/
|
|
public void setTransactionHelper(RetryingTransactionHelper retryingTransactionHelper)
|
|
{
|
|
this.retryingTransactionHelper = retryingTransactionHelper;
|
|
}
|
|
|
|
/**
|
|
* Sets the search service
|
|
*/
|
|
public void setSearchService(SearchService searchService)
|
|
{
|
|
this.searchService = searchService;
|
|
}
|
|
|
|
/**
|
|
* Sets the node service
|
|
*/
|
|
public void setNodeService(NodeService nodeService)
|
|
{
|
|
this.nodeService = nodeService;
|
|
}
|
|
|
|
/**
|
|
* Sets the content service
|
|
*/
|
|
public void setContentService(ContentService contentService)
|
|
{
|
|
this.contentService = contentService;
|
|
}
|
|
|
|
/**
|
|
* Sets the file service
|
|
*/
|
|
public void setFileFolderService(FileFolderService fileService)
|
|
{
|
|
this.fileService = fileService;
|
|
}
|
|
|
|
/**
|
|
* Sets the namespace service
|
|
*/
|
|
public void setNamespaceService(NamespaceService namespaceService)
|
|
{
|
|
this.namespaceService = namespaceService;
|
|
}
|
|
|
|
/**
|
|
* Sets the permission service
|
|
*/
|
|
public void setPermissionService(PermissionService permissionService)
|
|
{
|
|
this.permissionService = permissionService;
|
|
}
|
|
|
|
/**
|
|
* Sets whether the repo store must exist
|
|
*
|
|
* @param mustExist
|
|
*/
|
|
public void setMustExist(boolean mustExist)
|
|
{
|
|
this.mustExist = mustExist;
|
|
}
|
|
|
|
/**
|
|
* Sets the repo store
|
|
*/
|
|
public void setStore(String repoStore)
|
|
{
|
|
this.repoStore = new StoreRef(repoStore);
|
|
}
|
|
|
|
/**
|
|
* Sets the repo path
|
|
*
|
|
* @param repoPath repoPath
|
|
*/
|
|
public void setPath(String repoPath)
|
|
{
|
|
this.repoPath = repoPath;
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.springframework.context.ApplicationContextAware#setApplicationContext(org.springframework.context.ApplicationContext)
|
|
*/
|
|
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
|
|
{
|
|
lifecycle.setApplicationContext(applicationContext);
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.springframework.context.ApplicationListener#onApplicationEvent(org.springframework.context.ApplicationEvent)
|
|
*/
|
|
public void onApplicationEvent(ApplicationEvent event)
|
|
{
|
|
lifecycle.onApplicationEvent(event);
|
|
}
|
|
|
|
/**
|
|
* Hooks into Spring Application Lifecycle
|
|
*/
|
|
private class ProcessorLifecycle extends AbstractLifecycleBean
|
|
{
|
|
@Override
|
|
protected void onBootstrap(ApplicationEvent event)
|
|
{
|
|
init();
|
|
}
|
|
|
|
@Override
|
|
protected void onShutdown(ApplicationEvent event)
|
|
{
|
|
}
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
|
|
*/
|
|
protected void init()
|
|
{
|
|
AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<Object>()
|
|
{
|
|
public Object doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Object>()
|
|
{
|
|
public Object execute() throws Exception
|
|
{
|
|
String query = "PATH:\"" + repoPath + "\"";
|
|
ResultSet resultSet = searchService.query(repoStore, SearchService.LANGUAGE_LUCENE, query);
|
|
if (resultSet.length() == 1)
|
|
{
|
|
baseNodeRef = resultSet.getNodeRef(0);
|
|
baseDir = getPath(baseNodeRef);
|
|
}
|
|
else if (mustExist)
|
|
{
|
|
throw new WebScriptException("Web Script Store " + repoStore.toString() + repoPath + " must exist; it was not found");
|
|
}
|
|
return null;
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#exists()
|
|
*/
|
|
public boolean exists()
|
|
{
|
|
return (baseNodeRef != null);
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#getBasePath()
|
|
*/
|
|
public String getBasePath()
|
|
{
|
|
return repoStore.toString() + repoPath;
|
|
}
|
|
|
|
/**
|
|
* Gets the display path for the specified node
|
|
*
|
|
* @param nodeRef
|
|
* @return display path
|
|
*/
|
|
protected String getPath(NodeRef nodeRef)
|
|
{
|
|
return nodeService.getPath(nodeRef).toDisplayPath(nodeService, permissionService) +
|
|
"/" + nodeService.getProperty(nodeRef, ContentModel.PROP_NAME);
|
|
}
|
|
|
|
/**
|
|
* Gets the node ref for the specified path within this repo store
|
|
*
|
|
* @param documentPath
|
|
* @return node ref
|
|
*/
|
|
protected NodeRef findNodeRef(String documentPath)
|
|
{
|
|
NodeRef node = null;
|
|
try
|
|
{
|
|
String[] pathElements = documentPath.split("/");
|
|
List<String> pathElementsList = Arrays.asList(pathElements);
|
|
FileInfo file = fileService.resolveNamePath(baseNodeRef, pathElementsList);
|
|
node = file.getNodeRef();
|
|
}
|
|
catch (FileNotFoundException e)
|
|
{
|
|
// NOTE: return null
|
|
}
|
|
return node;
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#getScriptDocumentPaths(org.alfresco.web.scripts.WebScript)
|
|
*/
|
|
public String[] getScriptDocumentPaths(final WebScript script)
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<String[]>()
|
|
{
|
|
public String[] doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<String[]>()
|
|
{
|
|
public String[] execute() throws Exception
|
|
{
|
|
int baseDirLength = baseDir.length() +1;
|
|
List<String> documentPaths = new ArrayList<String>();
|
|
String scriptPath = script.getDescription().getScriptPath();
|
|
NodeRef scriptNodeRef = findNodeRef(scriptPath);
|
|
if (scriptNodeRef != null)
|
|
{
|
|
org.alfresco.service.cmr.repository.Path repoScriptPath = nodeService.getPath(scriptNodeRef);
|
|
String id = script.getDescription().getId().substring(script.getDescription().getScriptPath().length() +1);
|
|
String query = "+PATH:\"" + repoScriptPath.toPrefixString(namespaceService) + "//*\" +QNAME:" + id + "*";
|
|
ResultSet resultSet = searchService.query(repoStore, SearchService.LANGUAGE_LUCENE, query);
|
|
List<NodeRef> nodes = resultSet.getNodeRefs();
|
|
for (NodeRef nodeRef : nodes)
|
|
{
|
|
String name = (String)nodeService.getProperty(nodeRef, ContentModel.PROP_NAME);
|
|
if (name.startsWith(id))
|
|
{
|
|
String nodeDir = getPath(nodeRef);
|
|
String documentPath = nodeDir.substring(baseDirLength);
|
|
documentPaths.add(documentPath);
|
|
}
|
|
}
|
|
}
|
|
|
|
return documentPaths.toArray(new String[documentPaths.size()]);
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#getDescriptionDocumentPaths()
|
|
*/
|
|
public String[] getDescriptionDocumentPaths()
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<String[]>()
|
|
{
|
|
public String[] doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<String[]>()
|
|
{
|
|
public String[] execute() throws Exception
|
|
{
|
|
int baseDirLength = baseDir.length() +1;
|
|
List<String> documentPaths = new ArrayList<String>();
|
|
|
|
String query = "+PATH:\"" + repoPath + "//*\" +QNAME:*.desc.xml";
|
|
ResultSet resultSet = searchService.query(repoStore, SearchService.LANGUAGE_LUCENE, query);
|
|
List<NodeRef> nodes = resultSet.getNodeRefs();
|
|
for (NodeRef nodeRef : nodes)
|
|
{
|
|
String nodeDir = getPath(nodeRef);
|
|
if (nodeDir.endsWith(".desc.xml"))
|
|
{
|
|
String documentPath = nodeDir.substring(baseDirLength);
|
|
documentPaths.add(documentPath);
|
|
}
|
|
}
|
|
|
|
return documentPaths.toArray(new String[documentPaths.size()]);
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#hasDocument(java.lang.String)
|
|
*/
|
|
public boolean hasDocument(final String documentPath)
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<Boolean>()
|
|
{
|
|
public Boolean doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Boolean>()
|
|
{
|
|
public Boolean execute() throws Exception
|
|
{
|
|
NodeRef nodeRef = findNodeRef(documentPath);
|
|
return (nodeRef != null);
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#getDescriptionDocument(java.lang.String)
|
|
*/
|
|
public InputStream getDocument(final String documentPath)
|
|
throws IOException
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<InputStream>()
|
|
{
|
|
public InputStream doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<InputStream>()
|
|
{
|
|
public InputStream execute() throws Exception
|
|
{
|
|
NodeRef nodeRef = findNodeRef(documentPath);
|
|
if (nodeRef == null)
|
|
{
|
|
throw new IOException("Document " + documentPath + " does not exist.");
|
|
}
|
|
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
|
|
if (reader == null || !reader.exists())
|
|
{
|
|
throw new IOException("Failed to read content at " + documentPath + " (content reader does not exist)");
|
|
}
|
|
return reader.getContentInputStream();
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#createDocument(java.lang.String, java.lang.String)
|
|
*/
|
|
public void createDocument(String documentPath, String content) throws IOException
|
|
{
|
|
String[] pathElements = documentPath.split("/");
|
|
String[] folderElements = new String[pathElements.length -1];
|
|
System.arraycopy(pathElements, 0, folderElements, 0, pathElements.length -1);
|
|
List<String> folderElementsList = Arrays.asList(folderElements);
|
|
|
|
// create folder
|
|
FileInfo pathInfo = fileService.makeFolders(baseNodeRef, folderElementsList, ContentModel.TYPE_FOLDER);
|
|
|
|
// create file
|
|
String fileName = pathElements[pathElements.length -1];
|
|
if (fileService.searchSimple(pathInfo.getNodeRef(), fileName) != null)
|
|
{
|
|
throw new IOException("Document " + documentPath + " already exists");
|
|
}
|
|
FileInfo fileInfo = fileService.create(pathInfo.getNodeRef(), fileName, ContentModel.TYPE_CONTENT);
|
|
ContentWriter writer = fileService.getWriter(fileInfo.getNodeRef());
|
|
writer.putContent(content);
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#getTemplateLoader()
|
|
*/
|
|
public TemplateLoader getTemplateLoader()
|
|
{
|
|
return new RepoTemplateLoader();
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.WebScriptStore#getScriptLoader()
|
|
*/
|
|
public ScriptLoader getScriptLoader()
|
|
{
|
|
return new RepoScriptLoader();
|
|
}
|
|
|
|
/**
|
|
* Repository path based template loader
|
|
*
|
|
* @author davidc
|
|
*/
|
|
private class RepoTemplateLoader implements TemplateLoader
|
|
{
|
|
/* (non-Javadoc)
|
|
* @see freemarker.cache.TemplateLoader#findTemplateSource(java.lang.String)
|
|
*/
|
|
public Object findTemplateSource(final String name)
|
|
throws IOException
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<Object>()
|
|
{
|
|
public Object doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Object>()
|
|
{
|
|
public Object execute() throws Exception
|
|
{
|
|
RepoTemplateSource source = null;
|
|
NodeRef nodeRef = findNodeRef(name);
|
|
if (nodeRef != null)
|
|
{
|
|
source = new RepoTemplateSource(nodeRef);
|
|
}
|
|
return source;
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see freemarker.cache.TemplateLoader#getLastModified(java.lang.Object)
|
|
*/
|
|
public long getLastModified(Object templateSource)
|
|
{
|
|
return ((RepoTemplateSource)templateSource).lastModified();
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see freemarker.cache.TemplateLoader#getReader(java.lang.Object, java.lang.String)
|
|
*/
|
|
public Reader getReader(Object templateSource, String encoding) throws IOException
|
|
{
|
|
return ((RepoTemplateSource)templateSource).getReader();
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see freemarker.cache.TemplateLoader#closeTemplateSource(java.lang.Object)
|
|
*/
|
|
public void closeTemplateSource(Object arg0) throws IOException
|
|
{
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Repository (content) node template source
|
|
*
|
|
* @author davidc
|
|
*/
|
|
private class RepoTemplateSource
|
|
{
|
|
protected final NodeRef nodeRef;
|
|
|
|
/**
|
|
* Construct
|
|
*
|
|
* @param ref
|
|
*/
|
|
private RepoTemplateSource(NodeRef ref)
|
|
{
|
|
this.nodeRef = ref;
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see java.lang.Object#equals(java.lang.Object)
|
|
*/
|
|
public boolean equals(Object o)
|
|
{
|
|
if (o instanceof RepoTemplateSource)
|
|
{
|
|
return nodeRef.equals(((RepoTemplateSource)o).nodeRef);
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see java.lang.Object#hashCode()
|
|
*/
|
|
public int hashCode()
|
|
{
|
|
return nodeRef.hashCode();
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see java.lang.Object#toString()
|
|
*/
|
|
public String toString()
|
|
{
|
|
return nodeRef.toString();
|
|
}
|
|
|
|
/**
|
|
* Gets the last modified time of the content
|
|
*
|
|
* @return last modified time
|
|
*/
|
|
public long lastModified()
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<Long>()
|
|
{
|
|
public Long doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Long>()
|
|
{
|
|
public Long execute() throws Exception
|
|
{
|
|
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
|
|
return reader.getLastModified();
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/**
|
|
* Gets the content reader
|
|
*
|
|
* @return content reader
|
|
* @throws IOException
|
|
*/
|
|
public Reader getReader() throws IOException
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<Reader>()
|
|
{
|
|
public Reader doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Reader>()
|
|
{
|
|
public Reader execute() throws Exception
|
|
{
|
|
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
|
|
return new InputStreamReader(reader.getContentInputStream(), reader.getEncoding());
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Repository path based script loader
|
|
*
|
|
* @author davidc
|
|
*/
|
|
private class RepoScriptLoader implements ScriptLoader
|
|
{
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.web.scripts.ScriptLoader#getScriptLocation(java.lang.String)
|
|
*/
|
|
public ScriptLocation getScriptLocation(final String path)
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<ScriptLocation>()
|
|
{
|
|
public ScriptLocation doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<ScriptLocation>()
|
|
{
|
|
public ScriptLocation execute() throws Exception
|
|
{
|
|
ScriptLocation location = null;
|
|
NodeRef nodeRef = findNodeRef(path);
|
|
if (nodeRef != null)
|
|
{
|
|
location = new RepoScriptLocation(path, nodeRef);
|
|
}
|
|
return location;
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Repo path script location
|
|
*
|
|
* @author davidc
|
|
*/
|
|
private class RepoScriptLocation implements ScriptLocation
|
|
{
|
|
protected String path;
|
|
protected NodeRef nodeRef;
|
|
|
|
/**
|
|
* Construct
|
|
*
|
|
* @param location
|
|
*/
|
|
public RepoScriptLocation(String path, NodeRef nodeRef)
|
|
{
|
|
this.path = path;
|
|
this.nodeRef = nodeRef;
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.service.cmr.repository.ScriptLocation#getInputStream()
|
|
*/
|
|
public InputStream getInputStream()
|
|
{
|
|
return AuthenticationUtil.runAs(new AuthenticationUtil.RunAsWork<InputStream>()
|
|
{
|
|
public InputStream doWork() throws Exception
|
|
{
|
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<InputStream>()
|
|
{
|
|
public InputStream execute() throws Exception
|
|
{
|
|
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
|
|
return reader.getContentInputStream();
|
|
}
|
|
});
|
|
}
|
|
}, AuthenticationUtil.getSystemUserName());
|
|
}
|
|
|
|
/* (non-Javadoc)
|
|
* @see org.alfresco.service.cmr.repository.ScriptLocation#getReader()
|
|
*/
|
|
public Reader getReader()
|
|
{
|
|
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
|
|
try
|
|
{
|
|
return new InputStreamReader(getInputStream(), reader.getEncoding());
|
|
}
|
|
catch (UnsupportedEncodingException e)
|
|
{
|
|
throw new AlfrescoRuntimeException("Unsupported Encoding", e);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public String toString()
|
|
{
|
|
return repoStore + "/" + baseDir + "/" + path;
|
|
}
|
|
}
|
|
|
|
}
|