Files
alfresco-community-repo/source/java/org/alfresco/repo/cmis/rest/CMISScript.java
Derek Hulley bb3f458a65 Merged DEV/SWIFT to HEAD
27908: ALF-8706: RSOLR 023: Locale is persisted for all nodes
          - Part of ALF-7991: RSOLR 023: Locale support for query: Repository
          - Added alf_node.locale_id mandatory column
          - sys:localizable is now spoofed and mandatory on sys:base
          - sys:locale property is always available
          - The locale set is the I18NUtil.getLocale() (thread then server)
          - TODO: Upgrade scripts, so drop database to take this change
   27909: ALF-8706: RSOLR 023: Locale is persisted for all nodes
          - Part of ALF-7991: RSOLR 023: Locale support for query: Repository
          - Extended locale test to ensure that sys:locale can be set using properties during create
   27910: ALF-8707: RSOLR 023: Upgrade to give nodes their default locales
          - Part of ALF-7991:RSOLR 023: Locale support for query: Repository
          - Upgrade scripts for PostgreSQL and MySQL: patch.db-V4.0-Node-Locale
   27912: WCM QS ML Support for creating missing intermediate directories when adding an "orphan" translation, plus tests
   27913: Fixed failing JbpmEngineUnitTest.
   27914: Build fix. Fixes failing test DiscussionServiceTest.testDeleteTopLevelPost
   27916: WCM QS ML forms config for overrideable name, and passing the initially orphaned flag through to the behaviour
   27917: Enable the WCM QS ML Manage Translations action in the folder details page, as well as the document details page as before
   27919: Quick build fix. Introduction of new property sys:locale on all nodes means that FormService is seeing some off-by-one errors.
   27921: WCM QS ML - Support copying parts of the section collections to the new folder when translating a section, plus tests
   27925: ALF-8707: RSOLR 023: Upgrade to give nodes their default locales
          - Part of ALF-7991: RSOLR 023: Locale support for query: Repository
          - Upgrade scripts for DB2, Oracle and SQLServer
   27927: Update FileFolderService list/paging (RINF 09) & CQ permission checking (RINF 11)
          - also added additional unit tests and update FileFolderPerformanceTester utility (for read / list testing)
   27930: Corrected bean reference: "ServiceRegistry"
   27931: Partially implemented EnvironmentImpl.getPublishingEvents(). This currently only supports searching on publishing event ids.
   27933: Implemented PublishService.getPublishingEvent(String) method.
   27934: WCM QS ML Pull over the locale resolver from Ian, and delegate much of the work to the main class
   27941: ALF-7874 - Mime Type entries for detection and display for some Apple and Adobe formats
   27947: ALF-2707 - Largely fix custom site properties that have multiple values, and custom site properties without a full definition, plus tests.
   27964: ALF-7339:RSOLR 009: Index track and build from SOLR
          - complete
          ALF-7475: RSOLR 010: Index integrity check
          - check ACL info
   27966: RINF 09: FileFolderService list - if skipCount > number of items then return empty list
          - related to ALF-7884 when using CMIS getChildren (via OpenCMIS - eg. http://localhost:8080/alfresco/cmisatom/...)
   27968: ALF-7884 - getChildren() returns an error if skipCount > number of children
   27970: WCM QS Fix issue in the webapp for sites where no port has been given yet
   27972: WPUB: F150: Foundation API: Request that a node be removed from the live environment
          - Initial support for "unpublish"
   27975: ALF-8790:RSOLR 033: Automated build produces SOLR artifacts
          - add configuration per core based on properties files
   27976: ALF-8790: RSOLR 033: Automated build produces SOLR artifacts
          - restructure, added properties files for config, track archived store
   27977: ALF-8790: RSOLR 033: Automated build produces SOLR artifacts
          - Solr zip included in continuous build
   27978: Fixed missing policy event when sys:locale is changed.
   27979: Fixed tests and checks after sys:locale became a mandatory property.
   27982: ALF-8547: WPUB: F163: Foundation API: Create/update/remove a delivery channel
          - Code and tests for channel update and delete
   28007: Implemented starting publishing workflow on schedulePublishingEvent method. Added tests for PublishingEventHelper.
   28008: Updated web-publishing-context.xml to include WorkflowService and workflowEngineId for PublishingEventHelper.
   28009: Added more PublishingEventHelper tests.
   28012: Support for ALF-8792: RSOLR 036: SOLR APIs to support index integrity checking
   28013: Fix failing Web Publishing tests.
   28015: Adding a DoNotCopy CopyBehaviourCallback for the fm:commentsRollup aspect. Part of ALF-8498.
   28016: Bring over the WCM QS ML RootNavInterceptor from Ian, and productise it
   28019: CMIS browser: close invalid connections
   28025: Update the WCM QS ML behaviour, webscript and test to handle more things having locales by default
   28026: ML-WQS:
          - Wired up the RootNavInterceptor to detect locale based on path
          - Wired up the replacement locale resolver to respect the locale determined by the RootNavInterceptor
          - Adjusted "Manage Translations" page to render the data table correctly
          - Adjusted site search box to restrict search to selected site localisation
          - Adjusted top nav component to select menu items only from appropriate site localisation
   28029: Added more tests for PublishingEventHelper and PublishingQueueImpl. Also added WebPublishingTestSuite.
   28034: Support for ALF-8792: RSOLR 036: SOLR APIs to support index integrity checking
          - ACL and ACLTX support
   28036: WCM QS ML UI tweaks for marking something as the initial translation
   28038: ALF-8548: WPUB: F165: Foundation API: Cancel a scheduled publishing event
           - Code and initial test cases
   28043: Added missing JCR mapping for property type d:locale
           - This property type is not new, btw.
   28312: RepoBM: minor cleanup
          - remove hardcoded JMeter install dir
          - add configurable user.dir (for default import of test data) - check that default zip exists
          - update readme
          - default threadfolder should be null (in case of absolute folder paths)

git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@28320 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
2011-06-09 22:40:27 +00:00

1274 lines
41 KiB
Java

/*
* Copyright (C) 2005-2010 Alfresco Software Limited.
*
* This file is part of Alfresco
*
* Alfresco is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Alfresco 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 Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
*/
package org.alfresco.repo.cmis.rest;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.alfresco.cmis.CMISAccessControlEntry;
import org.alfresco.cmis.CMISAccessControlService;
import org.alfresco.cmis.CMISAclCapabilityEnum;
import org.alfresco.cmis.CMISAclPropagationEnum;
import org.alfresco.cmis.CMISAclSupportedPermissionEnum;
import org.alfresco.cmis.CMISBaseObjectTypeIds;
import org.alfresco.cmis.CMISCapabilityChanges;
import org.alfresco.cmis.CMISChangeEvent;
import org.alfresco.cmis.CMISChangeLog;
import org.alfresco.cmis.CMISChangeLogService;
import org.alfresco.cmis.CMISConstraintException;
import org.alfresco.cmis.CMISDictionaryModel;
import org.alfresco.cmis.CMISDictionaryService;
import org.alfresco.cmis.CMISInvalidArgumentException;
import org.alfresco.cmis.CMISJoinEnum;
import org.alfresco.cmis.CMISObjectReference;
import org.alfresco.cmis.CMISPermissionDefinition;
import org.alfresco.cmis.CMISPermissionMapping;
import org.alfresco.cmis.CMISPropertyDefinition;
import org.alfresco.cmis.CMISQueryEnum;
import org.alfresco.cmis.CMISQueryOptions;
import org.alfresco.cmis.CMISQueryService;
import org.alfresco.cmis.CMISRelationshipDirectionEnum;
import org.alfresco.cmis.CMISRelationshipReference;
import org.alfresco.cmis.CMISRepositoryReference;
import org.alfresco.cmis.CMISResultSet;
import org.alfresco.cmis.CMISServiceException;
import org.alfresco.cmis.CMISServices;
import org.alfresco.cmis.CMISTypeDefinition;
import org.alfresco.cmis.CMISTypesFilterEnum;
import org.alfresco.cmis.CMISVersioningStateEnum;
import org.alfresco.cmis.CMISQueryOptions.CMISQueryMode;
import org.alfresco.cmis.acl.CMISAccessControlEntryImpl;
import org.alfresco.repo.cmis.reference.ObjectIdReference;
import org.alfresco.repo.cmis.reference.ReferenceFactory;
import org.alfresco.repo.jscript.Association;
import org.alfresco.repo.jscript.BaseScopableProcessorExtension;
import org.alfresco.repo.jscript.ScriptNode;
import org.alfresco.repo.jscript.ValueConverter;
import org.alfresco.repo.web.util.paging.Cursor;
import org.alfresco.repo.web.util.paging.Page;
import org.alfresco.repo.web.util.paging.PagedResults;
import org.alfresco.repo.web.util.paging.Paging;
import org.alfresco.service.ServiceRegistry;
import org.alfresco.service.cmr.repository.AssociationRef;
import org.alfresco.service.cmr.repository.NodeRef;
import org.mozilla.javascript.Context;
import org.mozilla.javascript.Scriptable;
import org.mozilla.javascript.ScriptableObject;
import org.springframework.extensions.webscripts.Status;
import org.springframework.extensions.webscripts.WebScriptException;
/**
* CMIS Javascript API.
*
* @author davidc
* @author dward
*/
public class CMISScript extends BaseScopableProcessorExtension
{
//
// Argument Names
//
public static final String ARG_CHILD_TYPES = "childTypes";
public static final String ARG_CONTINUE_ON_FAILURE = "continueOnFailure";
public static final String ARG_CHECKIN = "checkin";
public static final String ARG_CHECKIN_COMMENT = "checkinComment";
public static final String ARG_DEPTH = "depth";
public static final String ARG_DIRECTION = "relationshipDirection";
public static final String ARG_FILTER = "filter";
public static final String ARG_FOLDER_BY_PATH = "folderByPath";
public static final String ARG_FOLDER_ID = "folderId";
public static final String ARG_INCLUDE_ALLOWABLE_ACTIONS = "includeAllowableActions";
public static final String ARG_INCLUDE_PROPERTY_DEFINITIONS = "includePropertyDefinitions";
public static final String ARG_INCLUDE_RELATIONSHIPS = "includeRelationships";
public static final String ARG_INCLUDE_SUB_RELATIONSHIP_TYPES = "includeSubRelationshipTypes";
public static final String ARG_LENGTH = "length";
public static final String ARG_MAJOR = "major";
public static final String ARG_MAJOR_VERSION = "majorVersion";
public static final String ARG_MAX_ITEMS = "maxItems";
public static final String ARG_OFFSET = "offset";
public static final String ARG_QUERY_STATEMENT = "q";
public static final String ARG_REMOVE_FROM = "removeFrom";
public static final String ARG_RELATIONSHIP_TYPE = "typeId";
public static final String ARG_REPOSITORY_ID = "repositoryId";
public static final String ARG_RETURN_VERSION = "returnVersion";
public static final String ARG_SKIP_COUNT = "skipCount";
public static final String ARG_THIS_VERSION = "thisVersion";
public static final String ARG_TYPE_ID = "typeId";
public static final String ARG_TYPES = "types";
public static final String ARG_UNFILE_OBJECTS = "unfileObjects";
public static final String ARG_VERSIONING_STATE = "versioningState";
public static final String ARG_SOURCE_FOLDER_ID = "sourceFolderId";
public static final String ARG_INCLUDE_ACL = "includeACL";
public static final String ARG_RENDITION_FILTER = "renditionFilter";
public static final String ARG_CHANGE_LOG_TOKEN = "changeLogToken";
public static final String ARG_ORDER_BY = "orderBy";
// service dependencies
private ServiceRegistry services;
private CMISServices cmisService;
private CMISDictionaryService cmisDictionaryService;
private CMISQueryService cmisQueryService;
private CMISAccessControlService cmisAccessControlService;
private CMISChangeLogService cmisChangeLogService;
private Paging paging;
private ReferenceFactory referenceFactory;
private ValueConverter valueConverter = new ValueConverter();
/**
* Set the service registry
*
* @param services the service registry
*/
public void setServiceRegistry(ServiceRegistry services)
{
this.services = services;
}
/**
* Set the paging helper.
*
* @param paging
* the paging helper
*/
public void setPaging(Paging paging)
{
this.paging = paging;
}
/**
* Set the CMIS Service.
*
* @param cmisService
* the cmis service
*/
public void setCMISService(CMISServices cmisService)
{
this.cmisService = cmisService;
}
/**
* Set the CMIS Dictionary Service.
*
* @param cmisDictionaryService
* the cmis dictionary service
*/
public void setCMISDictionaryService(CMISDictionaryService cmisDictionaryService)
{
this.cmisDictionaryService = cmisDictionaryService;
}
/**
* Set the CMIS Query Service.
*
* @param cmisQueryService
* the cmis query service
*/
public void setCMISQueryService(CMISQueryService cmisQueryService)
{
this.cmisQueryService = cmisQueryService;
}
/**
* Sets the CMIS access control service.
*
* @param cmisAccessControlService
* the access control service
*/
public void setCMISAccessControlService(CMISAccessControlService cmisAccessControlService)
{
this.cmisAccessControlService = cmisAccessControlService;
}
/**
* Sets the CMIS change log service.
*
* @param cmisChangeLogService
* the change log service
*/
public void setCMISChangeLogService(CMISChangeLogService cmisChangeLogService) {
this.cmisChangeLogService = cmisChangeLogService;
}
/**
* Set the CMIS Reference Factory.
*
* @param referenceFactory
* the reference factory
*/
public void setCMISReferenceFactory(ReferenceFactory referenceFactory)
{
this.referenceFactory = referenceFactory;
}
/**
* Gets the supported CMIS Version
*
* @return CMIS version
*/
public String getVersion()
{
return cmisService.getCMISVersion();
}
/**
* Gets the supported CMIS Specification Title
*
* @return CMIS Specification Title
*/
public String getSpecTitle()
{
return cmisService.getCMISSpecTitle();
}
/**
* Gets the default root folder path
*
* @return default root folder path
*/
public String getDefaultRootFolderPath()
{
return cmisService.getDefaultRootPath();
}
/**
* Gets the default root folder
*
* @return default root folder
*/
public ScriptNode getDefaultRootFolder()
{
return new ScriptNode(cmisService.getDefaultRootNodeRef(), services, getScope());
}
/**
* Gets the default Types filter
*
* @return default types filter
*/
public String getDefaultTypesFilter()
{
return CMISTypesFilterEnum.FACTORY.getDefaultLabel();
}
/**
* Is specified Types filter valid?
*
* @param typesFilter types filter
* @return true => valid
*/
public boolean isValidTypesFilter(String typesFilter)
{
return CMISTypesFilterEnum.FACTORY.validLabel(typesFilter);
}
/**
* Resolve to a Types Filter
*
* NOTE: If specified types filter is not specified or invalid, the default types
* filter is returned
*
* @param typesFilter types filter
* @return resolved types filter
*/
private CMISTypesFilterEnum resolveTypesFilter(String typesFilter)
{
return (CMISTypesFilterEnum)CMISTypesFilterEnum.FACTORY.toEnum(typesFilter);
}
/**
* Create CMIS Repository Reference from URL segments
*
* @param args url arguments
* @param templateArgs url template arguments
* @return Repository Reference (or null, in case of bad url)
*/
public CMISRepositoryReference createRepoReferenceFromUrl(Map<String, String> args, Map<String, String> templateArgs)
{
return referenceFactory.createRepoReferenceFromUrl(args, templateArgs);
}
/**
* Create CMIS Object Reference from URL segments
*
* @param args url arguments
* @param templateArgs url template arguments
* @return Repository Reference (or null, in case of bad url)
*/
public CMISObjectReference createObjectReferenceFromUrl(Map<String, String> args, Map<String, String> templateArgs)
{
return referenceFactory.createObjectReferenceFromUrl(args, templateArgs);
}
/**
* Create CMIS Relationship Reference from URL segments
*
* @param args url arguments
* @param templateArgs url template arguments
* @return Repository Reference (or null, in case of bad url)
*/
public CMISRelationshipReference createRelationshipReferenceFromUrl(Map<String, String> args, Map<String, String> templateArgs)
{
return referenceFactory.createRelationshipReferenceFromUrl(args, templateArgs);
}
/**
* Create Object Reference
*
* @param repo repository reference
* @param object id object id (NodeRef.toString() format)
* @return object id reference
*/
public CMISObjectReference createObjectIdReference(String objectId)
{
return new ObjectIdReference(cmisService, objectId);
}
/**
* Get Node from Object Reference
*
* @param ref object reference
* @return node
*/
public ScriptNode getNode(CMISObjectReference ref)
{
NodeRef nodeRef = ref.getNodeRef();
if (nodeRef == null)
{
return null;
}
return new ScriptNode(nodeRef, services, getScope());
}
/**
* Get Association from Relationship Reference
*
* @param ref relationship reference
* @return association
*/
public Association getAssociation(CMISRelationshipReference ref)
{
AssociationRef assocRef = ref.getAssocRef();
if (assocRef == null)
{
return null;
}
return new Association(services, assocRef);
}
/**
* Query for node children
*
* @param parent
* node to query children for
* @param typesFilter
* types filter
* @param orderBy
* comma-separated list of query names and the ascending modifier "ASC" or the descending modifier "DESC"
* for each query name
* @param page
* page to query for
* @return paged result set of children
*/
public PagedResults queryChildren(ScriptNode parent, String typesFilter, String orderBy, Page page)
{
CMISTypesFilterEnum filter = resolveTypesFilter(typesFilter);
NodeRef[] children;
try
{
children = cmisService.getChildren(parent.getNodeRef(), filter, orderBy);
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
Cursor cursor = paging.createCursor(children.length, page);
int cnt = (cursor.getRowCount() < 0 ? 0 : cursor.getRowCount());
ScriptNode[] nodes = new ScriptNode[cnt];
for (int i = cursor.getStartRow(); i <= cursor.getEndRow(); i++)
{
nodes[i - cursor.getStartRow()] = new ScriptNode(children[i], services, getScope());
}
PagedResults results = paging.createPagedResults(nodes, cursor);
return results;
}
/**
* Query for node relationships
*
* @param node
* @param relDef
* @param includeSubTypes
* @param direction
* @param page
* @return
*/
public PagedResults queryRelationships(ScriptNode node, CMISTypeDefinition relDef, boolean includeSubTypes, CMISRelationshipDirectionEnum direction, Page page)
{
AssociationRef[] relationships;
try
{
relationships = cmisService.getRelationships(node.getNodeRef(), relDef, includeSubTypes, direction);
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
Cursor cursor = paging.createCursor(relationships.length, page);
Association[] assocs = new Association[cursor.getRowCount()];
for (int i = cursor.getStartRow(); i <= cursor.getEndRow(); i++)
{
assocs[i - cursor.getStartRow()] = new Association(services, relationships[i], getScope());
}
PagedResults results = paging.createPagedResults(assocs, cursor);
return results;
}
/**
* Query for items checked-out to user within folder (and possibly descendants)
*
* @param username user
* @param folder folder
* @param includeDescendants true = include descendants
* @param page
* @return paged result set of checked-out items
*/
public PagedResults queryCheckedOut(String username, ScriptNode folder, boolean includeDescendants, Page page)
{
NodeRef[] checkedout;
try
{
checkedout = cmisService.getCheckedOut(username, (folder == null) ? null : folder.getNodeRef(), includeDescendants, null);
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
Cursor cursor = paging.createCursor(checkedout.length, page);
ScriptNode[] nodes = new ScriptNode[cursor.getRowCount()];
for (int i = cursor.getStartRow(); i <= cursor.getEndRow(); i++)
{
nodes[i - cursor.getStartRow()] = new ScriptNode(checkedout[i], services, getScope());
}
PagedResults results = paging.createPagedResults(nodes, cursor);
return results;
}
/**
* Query for child types (of a given type), or the base types (if no type given).
*
* @param typeDef
* the type def
* @param page
* the page
* @return the paged results
*/
public PagedResults queryTypeChildren(CMISTypeDefinition typeDef, Page page)
{
Collection<CMISTypeDefinition> children = (typeDef == null) ? cmisService.getBaseTypes() : typeDef
.getSubTypes(false);
Cursor cursor = paging.createCursor(children.size(), page);
// skip
Iterator<CMISTypeDefinition> iterTypeDefs = children.iterator();
for (int i = 0; i < cursor.getStartRow(); i++)
{
iterTypeDefs.next();
}
// get types for page
CMISTypeDefinition[] types = new CMISTypeDefinition[cursor.getRowCount()];
for (int i = cursor.getStartRow(); i <= cursor.getEndRow(); i++)
{
types[i - cursor.getStartRow()] = iterTypeDefs.next();
}
PagedResults results = paging.createPagedResults(types, cursor);
return results;
}
/**
* Query for a Type Definition given a CMIS Type Id.
*
* @param typeId
* the type id
* @return CMIS Type Definition
*/
public CMISTypeDefinition queryType(String typeId)
{
try
{
return cmisService.getTypeDefinition(typeId);
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Query the Type Definition for the given Node.
*
* @param node
* the node
* @return CMIS Type Definition
*/
public CMISTypeDefinition queryType(ScriptNode node)
{
try
{
return cmisService.getTypeDefinition(node.getNodeRef());
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Query the Property Definition for the given Property.
*
* @param propertyName
* the property name
* @return the CMIS property definition
*/
public CMISPropertyDefinition queryProperty(String propertyName)
{
return cmisDictionaryService.findProperty(propertyName, null);
}
/**
* Sets the aspects on a node (Alfresco extension).
*
* @param node
* the node
* @param aspectsToRemove
* the aspects to remove
* @param aspectsToAdd
* the aspects to add
* @throws WebScriptException
* if an argument is invalid
*/
public void setAspects(ScriptNode node, Iterable<String> aspectsToRemove, Iterable<String> aspectsToAdd)
{
try
{
cmisService.setAspects(node.getNodeRef(), aspectsToRemove, aspectsToAdd);
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
//
// SQL Query
//
/**
* Can you query the private working copy of a document.
*
* @return is the PWC searchable?
*/
public boolean getPwcSearchable()
{
return cmisQueryService.getPwcSearchable();
}
/**
* Can you query non-latest versions of a document.
*
* The current latest version is always searchable according to the type definition.
*
* @return
*/
public boolean getAllVersionsSearchable()
{
return cmisQueryService.getAllVersionsSearchable();
}
/**
* Get the query support level.
*
* @return the query support level
*/
public CMISQueryEnum getQuerySupport()
{
return cmisQueryService.getQuerySupport();
}
/**
* Get the join support level in queries.
*
* @return the join support level
*/
public CMISJoinEnum getJoinSupport()
{
return cmisQueryService.getJoinSupport();
}
/**
* Issue query.
*
* @param statement
* query statement
* @param page
* the page
* @return paged result set
*/
public PagedResults query(String statement, Page page)
{
Cursor unknownRows = paging.createCursor(Integer.MAX_VALUE, page);
CMISQueryOptions options = new CMISQueryOptions(statement, cmisService.getDefaultRootStoreRef());
options.setQueryMode(CMISQueryMode.CMS_WITH_ALFRESCO_EXTENSIONS);
options.setSkipCount(unknownRows.getStartRow());
CMISResultSet resultSet = cmisQueryService.query(options);
Cursor cursor = paging.createCursor(unknownRows.getStartRow() + resultSet.getLength(), page);
return paging.createPagedResult(resultSet, cursor);
}
/**
* Gets the ACL capability.
*
* @return the ACL capability
*/
public CMISAclCapabilityEnum getAclCapability()
{
return cmisAccessControlService.getAclCapability();
}
/**
* Gets the supported permission types.
*
* @return the supported permission types
*/
public CMISAclSupportedPermissionEnum getAclSupportedPermissions()
{
return cmisAccessControlService.getSupportedPermissions();
}
/**
* Gets the ACL propagation.
*
* @return the ACL propagation
*/
public CMISAclPropagationEnum getAclPropagation()
{
return cmisAccessControlService.getAclPropagation();
}
/**
* Get all the permissions defined by the repository.
*
* @return a list of permissions
*/
public List<CMISPermissionDefinition> getRepositoryPermissions()
{
return cmisAccessControlService.getRepositoryPermissions();
}
/**
* Get the list of permission mappings.
*
* @return get the permission mapping as defined by the CMIS specification.
*/
public List<? extends CMISPermissionMapping> getPermissionMappings()
{
return cmisAccessControlService.getPermissionMappings();
}
/**
* Gets the name of the principal who is used for anonymous access. This principal can then be passed to the ACL
* services to specify what permissions anonymous users should have.
*
* @return name of the principal who is used for anonymous access
*/
public String getPrincipalAnonymous()
{
return cmisAccessControlService.getPrincipalAnonymous();
}
/**
* Gets the name of the principal who is used to indicate any authenticated user. This principal can then be passed
* to the ACL services to specify what permissions any authenticated user should have.
*
* @return name of the principal who is used to indicate any authenticated user
*/
public String getPrincipalAnyone()
{
return cmisAccessControlService.getPrincipalAnyone();
}
/**
* Applies an ACL to a node.
*
* @param node
* the node
* @param principalIds
* the principal IDs
* @param permissions
* the permissions for each principal ID
*/
@SuppressWarnings("unchecked")
public void applyACL(ScriptNode node, Serializable principalIds, Serializable permissions)
{
List<String> principalList = (List<String>) valueConverter.convertValueForRepo(principalIds);
List<String> permissionList = (List<String>) valueConverter.convertValueForRepo(permissions);
List<CMISAccessControlEntry> acesToApply = new ArrayList<CMISAccessControlEntry>(principalList.size());
for(int i=0; i<principalList.size(); i++)
{
acesToApply.add(new CMISAccessControlEntryImpl(principalList.get(i), permissionList.get(i)));
}
try
{
cmisAccessControlService.applyAcl(node.getNodeRef(), acesToApply);
}
catch (CMISConstraintException e)
{
// Force the appropriate status code on error
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Gets the change log capability.
*
* @return the change log capability
*/
public CMISCapabilityChanges getChangeLogCapability()
{
return cmisChangeLogService.getCapability();
}
/**
* Gets the last change log token.
*
* @return the last change log token
*/
public String getLastChangeLogToken()
{
return cmisChangeLogService.getLastChangeLogToken();
}
/**
* Gets the list of base types for which changes are available.
*
* @return the list of base types for which changes are available
*/
public String[] getChangesOnType()
{
List<CMISBaseObjectTypeIds> typeList = cmisChangeLogService.getChangesOnTypeCapability();
String[] changesOnType = new String[typeList.size()];
int i=0;
for (CMISBaseObjectTypeIds type: typeList)
{
changesOnType[i++] = type.getLabel();
}
return changesOnType;
}
/**
* Determines whether the repository's change log can return all changes ever made to any object in the repository
* or only changes made after a particular point in time.
*
* @return <code>false</code> if the change log can return all changes ever made to every object.<code>true</code>
* if the change log includes all changes made since a particular point in time, but not all changes ever
* made.
*/
public boolean getChangesIncomplete()
{
return cmisChangeLogService.getChangesIncomplete();
}
/**
* Gets the change log attributes.
*
* @param changeLogToken
* the change log token
* @param maxItems
* the maximum number of events to include to return or <code>null</code>
* @return the change log attributes
*/
public Scriptable getChangeLog(String changeLogToken, Integer maxItems)
{
Scriptable scope = getScope();
Context cx = Context.enter();
try
{
Scriptable changeLogMap = cx.newObject(scope);
CMISChangeLog changeLog = cmisChangeLogService.getChangeLogEvents(changeLogToken, maxItems);
List<CMISChangeEvent> changeEvents = changeLog.getChangeEvents();
// Wrap the events
int size = changeEvents.size();
Scriptable changeEventArr = cx.newArray(scope, size);
for (int i = 0; i < size; i++)
{
ScriptableObject.putProperty(changeEventArr, i, Context.javaToJS(changeEvents.get(i), scope));
}
ScriptableObject.putProperty(changeLogMap, "changeEvents", changeEventArr);
// Wrap the nodes
Scriptable changeNodes = cx.newArray(scope, size);
for (int i = 0; i < size; i++)
{
ScriptableObject.putProperty(changeNodes, i, new ScriptNode(changeEvents.get(i).getChangedNode(), services,
scope));
}
ScriptableObject.putProperty(changeLogMap, "changeNodes", changeNodes);
// Provide the other attributes
ScriptableObject.putProperty(changeLogMap, "hasMoreItems", Context
.javaToJS(changeLog.hasMoreItems(), scope));
ScriptableObject
.putProperty(changeLogMap, "eventCount", Context.javaToJS(changeLog.getEventCount(), scope));
// Handle paging parameters
String nextChangeToken = changeLog.getNextChangeToken();
if (nextChangeToken != null)
{
ScriptableObject.putProperty(changeLogMap, "nextChangeToken", Context.javaToJS(nextChangeToken, scope));
}
String previousPageChangeLogToken = cmisChangeLogService.getPreviousPageChangeLogToken(changeLogToken,
maxItems);
if (previousPageChangeLogToken != null)
{
ScriptableObject.putProperty(changeLogMap, "previousPageToken", Context.javaToJS(
previousPageChangeLogToken, scope));
}
String lastPageChangeLogToken = cmisChangeLogService.getLastPageChangeLogToken(changeLogToken, maxItems);
if (lastPageChangeLogToken != null)
{
ScriptableObject.putProperty(changeLogMap, "lastPageToken", Context.javaToJS(lastPageChangeLogToken,
scope));
}
return changeLogMap;
}
catch (CMISInvalidArgumentException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
finally
{
Context.exit();
}
}
/**
* Applies a versioning state to a new node, potentially resulting in a new node.
*
* @param source
* the source
* @param versioningState
* the versioning state
* @return the node to write changes to
* @throws CMISConstraintException
*/
public ScriptNode applyVersioningState(ScriptNode source, String versioningState)
{
CMISVersioningStateEnum versioningStateEnum = CMISVersioningStateEnum.FACTORY.fromLabel(versioningState);
try
{
return new ScriptNode(cmisService.applyVersioningState(source.getNodeRef(), versioningStateEnum), services,
getScope());
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Checks out an object by ID.
*
* @param objectId
* the object id
* @return the private working copy node
*/
public ScriptNode checkOut(String objectId)
{
try
{
return new ScriptNode(cmisService.checkOut(objectId), services, getScope());
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Checks in a given private working copy node.
*
* @param source
* the node
* @param checkinComment
* the checkin comment
* @param isMajor
* is this a major version?
* @return the checked-in node
*/
public ScriptNode checkIn(ScriptNode source, String checkinComment, boolean isMajor)
{
try
{
return new ScriptNode(cmisService.checkIn((String) cmisService.getProperty(source.getNodeRef(), CMISDictionaryModel.PROP_OBJECT_ID), checkinComment, isMajor), services,
getScope());
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Cancels a check out.
*
* @param source
* the private working copy
*/
public void cancelCheckOut(ScriptNode source)
{
try
{
cmisService.cancelCheckOut((String) cmisService.getProperty(source.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID));
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Gets all the versions of a node.
*
* @param source
* the node
* @return a Javascript array of all the versions
*/
public Scriptable getAllVersions(ScriptNode source)
{
Scriptable scope = getScope();
Context cx = Context.enter();
try
{
List<NodeRef> allVersions = cmisService.getAllVersions((String) cmisService.getProperty(
source.getNodeRef(), CMISDictionaryModel.PROP_OBJECT_ID));
// Wrap the version
int size = allVersions.size();
Scriptable allVersionsArr = cx.newArray(scope, size);
for (int i = 0; i < size; i++)
{
ScriptableObject.putProperty(allVersionsArr, i, new ScriptNode(allVersions.get(i), services, scope));
}
return allVersionsArr;
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
finally
{
Context.exit();
}
}
/**
* Gets the required version of a node
*
* @param source
* the node
* @param returnVersion
* value indicating version required
* @return the version
*/
public ScriptNode getReturnVersion(ScriptNode source, String returnVersion)
{
if (returnVersion == null || returnVersion.equals("this"))
{
return source;
}
try
{
return new ScriptNode(cmisService.getLatestVersion((String) cmisService.getProperty(source.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), returnVersion.equals("latestmajor")), services, getScope());
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Attempts to delete a folder and all of its children, recording the status in the given status object.
*
* @param source
* the folder node
* @param status
* the status
* @param continueOnFailure
* should we continue if an error occurs with one of the children?
* @param unfile
* should we remove non-primary associations to nodes rather than delete them?
* @param deleteAllVersions
* should we delete all the versions of the nodes we delete?
*/
public void deleteTree(ScriptNode source, Status status, boolean continueOnFailure, boolean unfile,
boolean deleteAllVersions)
{
// Let's avoid all deletions getting rolled back by catching the exception and setting the status ourselves
try
{
cmisService.deleteTreeReportLastError((String) cmisService.getProperty(source.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), continueOnFailure, unfile, deleteAllVersions);
// Success, but no response content
status.setCode(Status.STATUS_NO_CONTENT);
status.setRedirect(true);
}
catch (CMISServiceException e)
{
status.setCode(e.getStatusCode());
status.setMessage(e.getMessage());
status.setRedirect(true);
}
}
/**
* Deletes a node's content stream.
*
* @param source
* the node
*/
public void deleteContentStream(ScriptNode source)
{
try
{
cmisService.deleteContentStream((String) cmisService.getProperty(source.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID));
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Deletes a node.
*
* @param source
* the node
* @param allVersions
* should we delete all the versions of the node?
*/
public void deleteObject(ScriptNode source, boolean allVersions)
{
try
{
cmisService.deleteObject((String) cmisService.getProperty(source.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), allVersions);
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Deletes an association.
*
* @param assoc
* the association
*/
public void deleteObject(Association assoc)
{
try
{
cmisService.deleteObject((String) cmisService.getProperty(assoc.getAssociationRef(),
CMISDictionaryModel.PROP_OBJECT_ID), true);
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Adds an object to a folder.
*
* @param child
* the object to add
* @param parent
* the folder
*/
public void addObjectToFolder(ScriptNode child, ScriptNode parent)
{
try
{
cmisService.addObjectToFolder((String) cmisService.getProperty(child.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), (String) cmisService.getProperty(parent.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID));
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Moves an object from a source folder to a target folder.
*
* @param child
* the object to move
* @param targetFolder
* the target folder
* @param sourceFolderId
* the source folder object ID
*/
public void moveObject(ScriptNode child, ScriptNode targetFolder, String sourceFolderId)
{
try
{
cmisService.moveObject((String) cmisService.getProperty(child.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), (String) cmisService.getProperty(targetFolder.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), sourceFolderId);
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Creates a policy object of the specified type, and optionally adds the policy to a folder. Currently no policy
* types can be created in Alfresco.
*
* @param typeId
* the policy type
* @param parent
* parent folder for this new policy
* @return the created policy object
* @throws WebScriptException on error
*/
public ScriptNode createPolicy(String typeId, ScriptNode parent)
{
try
{
cmisService.createPolicy(Collections.<String, Serializable> singletonMap(
CMISDictionaryModel.PROP_OBJECT_TYPE_ID, typeId), (String) cmisService.getProperty(parent
.getNodeRef(), CMISDictionaryModel.PROP_OBJECT_ID), Collections.<String> emptyList());
return null;
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Applies a policy object to a target object.
*
* @param policyId
* policy Id
* @param target
* target node
* @throws WebScriptException on error
*/
public void applyPolicy(String policyId, ScriptNode target)
{
try
{
cmisService.applyPolicy(policyId, (String) cmisService.getProperty(target.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID));
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
/**
* Gets the list of policy objects currently applied to a target object.
*
* @param source
* source node
* @param filter
* property filter
* @throws WebScriptException on error
*/
public PagedResults getAppliedPolicies(ScriptNode source, String filter, Page page)
{
List<CMISTypeDefinition> policies;
try
{
policies = cmisService.getAppliedPolicies((String) cmisService.getProperty(source.getNodeRef(),
CMISDictionaryModel.PROP_OBJECT_ID), filter);
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
Cursor cursor = paging.createCursor(policies.size(), page);
Object[] policyArr = new Object[cursor.getRowCount()];
for (int i = cursor.getStartRow(); i <= cursor.getEndRow(); i++)
{
policyArr[i - cursor.getStartRow()] = Context.javaToJS(policies.get(i), getScope());
}
PagedResults results = paging.createPagedResults(policyArr, cursor);
return results;
}
/**
* Removes a previously applied policy from a target object. The policy object is not deleted, and may still be
* applied to other objects.
*
* @param policyId
* policy Id
* @param objectId
* target object Id.
* @throws WebScriptException
* on error
*/
public void removePolicy(String policyId, String objectId)
{
try
{
cmisService.removePolicy(policyId, objectId);
}
catch (CMISServiceException e)
{
throw new WebScriptException(e.getStatusCode(), e.getMessage(), e);
}
}
}