inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-08-14 17:58:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

SHA-1629 : Creating a link to file in a different location

Browse Source 
- Added support for multiple files in doclink.post webscript
   - Added unit test for api/node/doclink api
   - Added marker aspect app:linked for nodes that have links attached

git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/BRANCHES/DEV/5.2.N/root@131857 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Ramona Neamtu
2016-10-28 12:09:59 +00:00
parent aab5a5e6be
commit 55e3a4c76c
7 changed files with 573 additions and 213 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
config/alfresco/templates/webscripts/org/alfresco/repository/doclink/doclink.post.desc.xml
View File

@@ -41,12 +41,23 @@
<![CDATA[{ "destinationNodeRef" : string }]]> <![CDATA[{ "destinationNodeRef" : string }]]>
</type> </type>
</request> </request>
<request>
<format>json</format>
<type>
<![CDATA[
{
"destinationNodeRef": string,
"multipleFiles": string
}
]]>
</type>
</request>
</requests> </requests>
<responses> <responses>
<response> <response>
<format>json</format> <format>json</format>
<type> <type>
<![CDATA[{ "linkNodeRef" : string }]]> <![CDATA[{ "result" : string }]]>
</type> </type>
</response> </response>
</responses> </responses>

13
config/alfresco/templates/webscripts/org/alfresco/repository/doclink/doclink.post.json.ftl
View File

@@ -1,5 +1,16 @@
<#escape x as jsonUtils.encodeJSONString(x)> <#escape x as jsonUtils.encodeJSONString(x)>
{ {
"linkNodeRef": "${linkNodeRef}" "linkNodes" :
[
<#list results as result>
{
"nodeRef" : "${result}"
}
<#if result_has_next>,</#if>
</#list>
],
"successCount": "${successCount}",
"failureCount": "${failureCount}",
"overallSuccess": "${overallSuccess?c}"
} }
</#escape> </#escape>

2
config/alfresco/web-scripts-application-context.xml
View File

@@ -1846,6 +1846,7 @@
<property name="nodeService" ref="NodeService" /> <property name="nodeService" ref="NodeService" />
<property name="siteService" ref="SiteService" /> <property name="siteService" ref="SiteService" />
<property name="documentLinkService" ref="DocumentLinkService" /> <property name="documentLinkService" ref="DocumentLinkService" />
<property name="activityService" ref="activityService"/>
</bean> </bean>
<bean id="webscript.org.alfresco.repository.doclink.doclinks.delete" <bean id="webscript.org.alfresco.repository.doclink.doclinks.delete"
@@ -1854,6 +1855,7 @@
<property name="nodeService" ref="NodeService" /> <property name="nodeService" ref="NodeService" />
<property name="siteService" ref="SiteService" /> <property name="siteService" ref="SiteService" />
<property name="documentLinkService" ref="DocumentLinkService" /> <property name="documentLinkService" ref="DocumentLinkService" />
<property name="activityService" ref="activityService"/>
</bean> </bean>
<!-- CMM - Custom model import API --> <!-- CMM - Custom model import API -->

287
source/java/org/alfresco/repo/web/scripts/doclink/AbstractDocLink.java
View File

@@ -23,122 +23,171 @@
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>. * along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
* #L% * #L%
*/ */
package org.alfresco.repo.web.scripts.doclink; package org.alfresco.repo.web.scripts.doclink;
import java.util.Map; import java.io.StringWriter;
import java.util.StringTokenizer; import java.util.Map;
import java.util.StringTokenizer;
import org.alfresco.model.ContentModel;
import org.alfresco.service.cmr.repository.DocumentLinkService; import org.alfresco.model.ContentModel;
import org.alfresco.service.cmr.repository.NodeRef; import org.alfresco.repo.web.scripts.links.AbstractLinksWebScript;
import org.alfresco.service.cmr.repository.NodeService; import org.alfresco.service.cmr.activities.ActivityService;
import org.alfresco.service.cmr.site.SiteInfo; import org.alfresco.service.cmr.links.LinkInfo;
import org.alfresco.service.cmr.site.SiteService; import org.alfresco.service.cmr.repository.DocumentLinkService;
import org.alfresco.util.ParameterCheck; import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.util.PropertyCheck; import org.alfresco.service.cmr.repository.NodeService;
import org.springframework.extensions.webscripts.DeclarativeWebScript; import org.alfresco.service.cmr.site.SiteInfo;
import org.springframework.extensions.webscripts.Status; import org.alfresco.service.cmr.site.SiteService;
import org.springframework.extensions.webscripts.WebScriptException; import org.alfresco.util.ParameterCheck;
import org.alfresco.util.PropertyCheck;
/** import org.apache.commons.logging.Log;
* This class contains common code for doclink webscripts controllers import org.apache.commons.logging.LogFactory;
* import org.json.JSONStringer;
* @author Ana Bozianu import org.json.simple.JSONObject;
* @since 5.1 import org.springframework.extensions.webscripts.DeclarativeWebScript;
*/ import org.springframework.extensions.webscripts.Status;
public abstract class AbstractDocLink extends DeclarativeWebScript import org.springframework.extensions.webscripts.WebScriptException;
{ import org.springframework.extensions.webscripts.WebScriptRequest;
private static String PARAM_STORE_TYPE = "store_type"; import org.springframework.extensions.webscripts.json.JSONWriter;
private static String PARAM_STORE_ID = "store_id";
private static String PARAM_ID = "id"; /**
private static String PARAM_SITE = "site"; * This class contains common code for doclink webscripts controllers
private static String PARAM_CONTAINER = "container"; *
private static String PARAM_PATH = "path"; * @author Ana Bozianu
* @since 5.1
protected NodeService nodeService; */
protected SiteService siteService; public abstract class AbstractDocLink extends DeclarativeWebScript
protected DocumentLinkService documentLinkService; {
private static String PARAM_STORE_TYPE = "store_type";
protected NodeRef parseNodeRefFromTemplateArgs(Map<String, String> templateVars) private static String PARAM_STORE_ID = "store_id";
{ private static String PARAM_ID = "id";
if (templateVars == null) private static String PARAM_SITE = "site";
{ private static String PARAM_CONTAINER = "container";
return null; private static String PARAM_PATH = "path";
}
private static final String ACTIVITY_TOOL = "documentLinkService";
String storeTypeArg = templateVars.get(PARAM_STORE_TYPE);
String storeIdArg = templateVars.get(PARAM_STORE_ID); protected NodeService nodeService;
String idArg = templateVars.get(PARAM_ID); protected SiteService siteService;
protected DocumentLinkService documentLinkService;
if (storeTypeArg != null) protected ActivityService activityService;
{
ParameterCheck.mandatoryString("storeTypeArg", storeTypeArg); private static Log logger = LogFactory.getLog(AbstractDocLink.class);
ParameterCheck.mandatoryString("storeIdArg", storeIdArg);
ParameterCheck.mandatoryString("idArg", idArg); protected NodeRef parseNodeRefFromTemplateArgs(Map<String, String> templateVars)
{
/* if (templateVars == null)
* NodeRef based request {
* <url>URL_BASE/{store_type}/{store_id}/{id}</url> return null;
*/ }
return new NodeRef(storeTypeArg, storeIdArg, idArg);
} String storeTypeArg = templateVars.get(PARAM_STORE_TYPE);
else String storeIdArg = templateVars.get(PARAM_STORE_ID);
{ String idArg = templateVars.get(PARAM_ID);
String siteArg = templateVars.get(PARAM_SITE);
String containerArg = templateVars.get(PARAM_CONTAINER); if (storeTypeArg != null)
String pathArg = templateVars.get(PARAM_PATH); {
ParameterCheck.mandatoryString("storeTypeArg", storeTypeArg);
if (siteArg != null) ParameterCheck.mandatoryString("storeIdArg", storeIdArg);
{ ParameterCheck.mandatoryString("idArg", idArg);
ParameterCheck.mandatoryString("siteArg", siteArg);
ParameterCheck.mandatoryString("containerArg", containerArg); /*
* NodeRef based request
/* * <url>URL_BASE/{store_type}/{store_id}/{id}</url>
* Site based request <url>URL_BASE/{site}/{container}</url> or */
* <url>URL_BASE/{site}/{container}/{path}</url> return new NodeRef(storeTypeArg, storeIdArg, idArg);
*/ }
SiteInfo site = siteService.getSite(siteArg); else
PropertyCheck.mandatory(this, "site", site); {
String siteArg = templateVars.get(PARAM_SITE);
NodeRef node = siteService.getContainer(site.getShortName(), containerArg); String containerArg = templateVars.get(PARAM_CONTAINER);
if (node == null) String pathArg = templateVars.get(PARAM_PATH);
{
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid 'container' variable"); if (siteArg != null)
} {
ParameterCheck.mandatoryString("siteArg", siteArg);
if (pathArg != null) ParameterCheck.mandatoryString("containerArg", containerArg);
{
// <url>URL_BASE/{site}/{container}/{path}</url> /*
StringTokenizer st = new StringTokenizer(pathArg, "/"); * Site based request <url>URL_BASE/{site}/{container}</url> or
while (st.hasMoreTokens()) * <url>URL_BASE/{site}/{container}/{path}</url>
{ */
String childName = st.nextToken(); SiteInfo site = siteService.getSite(siteArg);
node = nodeService.getChildByName(node, ContentModel.ASSOC_CONTAINS, childName); PropertyCheck.mandatory(this, "site", site);
if (node == null)
{ NodeRef node = siteService.getContainer(site.getShortName(), containerArg);
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid 'path' variable"); if (node == null)
} {
} throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid 'container' variable");
} }
return node; if (pathArg != null)
} {
} // <url>URL_BASE/{site}/{container}/{path}</url>
return null; StringTokenizer st = new StringTokenizer(pathArg, "/");
} while (st.hasMoreTokens())
{
public void setNodeService(NodeService nodeService) String childName = st.nextToken();
{ node = nodeService.getChildByName(node, ContentModel.ASSOC_CONTAINS, childName);
this.nodeService = nodeService; if (node == null)
} {
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid 'path' variable");
public void setSiteService(SiteService siteService) }
{ }
this.siteService = siteService; }
}
return node;
public void setDocumentLinkService(DocumentLinkService documentLinkService) }
{ }
this.documentLinkService = documentLinkService; return null;
} }
}
/**
* Generates an activity entry for the link
*/
protected void addActivityEntry(String activityType, String title, String nodeRef, String site)
{
try
{
StringWriter activityJson = new StringWriter();
JSONWriter activity = new JSONWriter(activityJson);
activity.startObject();
activity.writeValue("title", title);
activity.writeValue("nodeRef", nodeRef);
activity.writeValue("page", "document-details?nodeRef=" + nodeRef);
activity.endObject();
activityService.postActivity(
activityType,
site,
ACTIVITY_TOOL,
activityJson.toString());
}
catch (Exception e)
{
// Warn, but carry on
logger.warn("Error adding link event to activities feed", e);
}
}
public void setNodeService(NodeService nodeService)
{
this.nodeService = nodeService;
}
public void setSiteService(SiteService siteService)
{
this.siteService = siteService;
}
public void setDocumentLinkService(DocumentLinkService documentLinkService)
{
this.documentLinkService = documentLinkService;
}
public void setActivityService(ActivityService activityService)
{
this.activityService = activityService;
}
}

258
source/java/org/alfresco/repo/web/scripts/doclink/DocLinkPost.java
View File

@@ -23,95 +23,169 @@
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>. * along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
* #L% * #L%
*/ */
package org.alfresco.repo.web.scripts.doclink; package org.alfresco.repo.web.scripts.doclink;
import java.io.IOException; import java.io.IOException;
import java.util.HashMap; import java.util.ArrayList;
import java.util.Map; import java.util.HashMap;
import java.util.List;
import org.alfresco.repo.content.MimetypeMap; import java.util.Map;
import org.alfresco.repo.security.permissions.AccessDeniedException;
import org.alfresco.service.cmr.repository.NodeRef; import org.alfresco.error.AlfrescoRuntimeException;
import org.alfresco.util.ParameterCheck; import org.alfresco.model.ContentModel;
import org.json.simple.JSONObject; import org.alfresco.repo.activities.ActivityType;
import org.json.simple.JSONValue; import org.alfresco.repo.content.MimetypeMap;
import org.json.simple.parser.ParseException; import org.alfresco.repo.security.permissions.AccessDeniedException;
import org.springframework.extensions.webscripts.Cache; import org.alfresco.service.cmr.repository.NodeRef;
import org.springframework.extensions.webscripts.Status; import org.alfresco.util.ParameterCheck;
import org.springframework.extensions.webscripts.WebScriptException; import org.json.simple.JSONArray;
import org.springframework.extensions.webscripts.WebScriptRequest; import org.json.simple.JSONObject;
import org.json.simple.JSONValue;
/** import org.json.simple.parser.ParseException;
* This class is the controller for the doclink.post webscript doclink.post is a import org.springframework.extensions.webscripts.Cache;
* webscript for creating a link of a document within a target destination import org.springframework.extensions.webscripts.Status;
* import org.springframework.extensions.webscripts.WebScriptException;
* @author Ana Bozianu import org.springframework.extensions.webscripts.WebScriptRequest;
* @since 5.1
*/ /**
public class DocLinkPost extends AbstractDocLink * This class is the controller for the doclink.post webscript doclink.post is a
{ * webscript for creating a link of a document within a target destination
private static String PARAM_DESTINATION_NODE = "destinationNodeRef"; *
* @author Ana Bozianu
@Override * @since 5.1
protected Map<String, Object> executeImpl(WebScriptRequest req, Status status, Cache cache) */
{ public class DocLinkPost extends AbstractDocLink
NodeRef sourceNodeRef = null; {
NodeRef destinationNodeRef = null; private static final String PARAM_DESTINATION_NODE = "destinationNodeRef";
private static final String PARAM_MULTIPLE_FILES = "multipleFiles";
/* Parse the template vars */
Map<String, String> templateVars = req.getServiceMatch().getTemplateVars(); @Override
sourceNodeRef = parseNodeRefFromTemplateArgs(templateVars); protected Map<String, Object> executeImpl(WebScriptRequest req, Status status, Cache cache)
{
/* Parse the JSON content */ NodeRef sourceNodeRef = null;
JSONObject json = null; NodeRef destinationNodeRef = null;
String contentType = req.getContentType();
if (contentType != null && contentType.indexOf(';') != -1) /* Parse the template vars */
{ Map<String, String> templateVars = req.getServiceMatch().getTemplateVars();
contentType = contentType.substring(0, contentType.indexOf(';')); sourceNodeRef = parseNodeRefFromTemplateArgs(templateVars);
}
if (MimetypeMap.MIMETYPE_JSON.equals(contentType)) /* Parse the JSON content */
{ JSONObject json = null;
try String contentType = req.getContentType();
{ if (contentType != null && contentType.indexOf(';') != -1)
json = (JSONObject) JSONValue.parseWithException(req.getContent().getContent()); {
} contentType = contentType.substring(0, contentType.indexOf(';'));
catch (IOException io) }
{ if (MimetypeMap.MIMETYPE_JSON.equals(contentType))
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid JSON: " + io.getMessage()); {
} try
catch (ParseException pe) {
{ json = (JSONObject) JSONValue.parseWithException(req.getContent().getContent());
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid JSON: " + pe.getMessage()); }
} catch (IOException io)
} {
else throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid JSON: " + io.getMessage());
{ }
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "invalid request content type"); catch (ParseException pe)
} {
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid JSON: " + pe.getMessage());
/* Parse the destination NodeRef parameter */ }
String destinationNodeParam = (String) json.get(PARAM_DESTINATION_NODE); }
ParameterCheck.mandatoryString("destinationNodeParam", destinationNodeParam); else
destinationNodeRef = new NodeRef(destinationNodeParam); {
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "invalid request content type");
/* Create link */ }
NodeRef linkNodeRef = null;
try /* Parse the destination NodeRef parameter */
{ String destinationNodeParam = (String) json.get(PARAM_DESTINATION_NODE);
linkNodeRef = documentLinkService.createDocumentLink(sourceNodeRef, destinationNodeRef); ParameterCheck.mandatoryString("destinationNodeParam", destinationNodeParam);
} destinationNodeRef = new NodeRef(destinationNodeParam);
catch (IllegalArgumentException ex)
{ List<NodeRef> nodeRefs = new ArrayList<NodeRef>();
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid Arguments: " + ex.getMessage()); if (json.containsKey(PARAM_MULTIPLE_FILES))
} {
catch (AccessDeniedException e) JSONArray multipleFiles = (JSONArray) json.get(PARAM_MULTIPLE_FILES);
{ for (int i = 0; i < multipleFiles.size(); i++)
throw new WebScriptException(Status.STATUS_FORBIDDEN, "You don't have permission to perform this operation"); {
} String nodeRefString = (String) multipleFiles.get(i);
if (nodeRefString != null)
/* Build response */ {
Map<String, Object> model = new HashMap<String, Object>(); try
model.put("linkNodeRef", linkNodeRef.toString()); {
return model; NodeRef nodeRefToCreateLink = new NodeRef(nodeRefString);
} nodeRefs.add(nodeRefToCreateLink);
} }
catch (AlfrescoRuntimeException ex)
{
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid Arguments: " + ex.getMessage());
}
}
}
}
else
{
nodeRefs.add(sourceNodeRef);
}
// getSite for destination folder
String siteName = siteService.getSiteShortName(destinationNodeRef);
List<String> linksResults = new ArrayList<String>();
NodeRef linkNodeRef = null;
int successCount = 0;
int failureCount = 0;
if (nodeRefs != null && nodeRefs.size() > 0)
{
for (NodeRef sourceNode : nodeRefs)
{
/* Create link */
linkNodeRef = createLink(destinationNodeRef, sourceNode);
if (linkNodeRef != null)
{
String sourceName = (String) nodeService.getProperty(sourceNode, ContentModel.PROP_NAME);
if (siteName != null)
{
addActivityEntry(ActivityType.DOCLINK_CREATED, sourceName, sourceNode.toString(), siteName);
}
linksResults.add(linkNodeRef.toString());
successCount++;
}
}
}
failureCount = nodeRefs.size() - successCount;
Map<String, Object> model = new HashMap<String, Object>();
model.put("results", linksResults);
model.put("successCount", successCount);
model.put("failureCount", failureCount);
model.put("overallSuccess", failureCount == 0);
return model;
}
/**
* Create link for sourceNodeRef in destinationNodeRef location
*
* @param destinationNodeRef
* @param sourceNodeRef
* @return
*/
private NodeRef createLink(NodeRef destinationNodeRef, NodeRef sourceNodeRef)
{
NodeRef linkNodeRef = null;
try
{
linkNodeRef = documentLinkService.createDocumentLink(sourceNodeRef, destinationNodeRef);
}
catch (IllegalArgumentException ex)
{
throw new WebScriptException(Status.STATUS_BAD_REQUEST, "Invalid Arguments: " + ex.getMessage());
}
catch (AccessDeniedException e)
{
throw new WebScriptException(Status.STATUS_FORBIDDEN, "You don't have permission to perform this operation");
}
return linkNodeRef;
}
}

2
source/test-java/org/alfresco/repo/web/scripts/WebScriptTestSuite.java
View File

@@ -45,6 +45,7 @@ import org.alfresco.repo.web.scripts.groups.GroupsTest;
import org.alfresco.repo.web.scripts.invitation.InvitationWebScriptTest; import org.alfresco.repo.web.scripts.invitation.InvitationWebScriptTest;
import org.alfresco.repo.web.scripts.invite.InviteServiceTest; import org.alfresco.repo.web.scripts.invite.InviteServiceTest;
import org.alfresco.repo.web.scripts.links.LinksRestApiTest; import org.alfresco.repo.web.scripts.links.LinksRestApiTest;
import org.alfresco.repo.web.scripts.node.NodeWebScripTest;
import org.alfresco.repo.web.scripts.person.PersonServiceTest; import org.alfresco.repo.web.scripts.person.PersonServiceTest;
import org.alfresco.repo.web.scripts.preference.PreferenceServiceTest; import org.alfresco.repo.web.scripts.preference.PreferenceServiceTest;
import org.alfresco.repo.web.scripts.publishing.PublishingRestApiTest; import org.alfresco.repo.web.scripts.publishing.PublishingRestApiTest;
@@ -117,6 +118,7 @@ public class WebScriptTestSuite extends TestSuite
suite.addTestSuite( ReadOnlyTransactionInGetRestApiTest.class ); suite.addTestSuite( ReadOnlyTransactionInGetRestApiTest.class );
suite.addTestSuite( CustomModelImportTest.class ); suite.addTestSuite( CustomModelImportTest.class );
suite.addTestSuite( SurfConfigTest.class ); suite.addTestSuite( SurfConfigTest.class );
suite.addTestSuite( NodeWebScripTest.class );
// This uses a slightly different context // This uses a slightly different context
// As such, we can't run it in the same suite as the others, // As such, we can't run it in the same suite as the others,
// due to finalisers closing caches when we're not looking // due to finalisers closing caches when we're not looking

211
source/test-java/org/alfresco/repo/web/scripts/node/NodeWebScripTest.java
View File

@@ -26,9 +26,12 @@
package org.alfresco.repo.web.scripts.node; package org.alfresco.repo.web.scripts.node;
import java.io.Serializable; import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List;
import java.util.Map; import java.util.Map;
import org.alfresco.model.ApplicationModel;
import org.alfresco.model.ContentModel; import org.alfresco.model.ContentModel;
import org.alfresco.repo.content.MimetypeMap; import org.alfresco.repo.content.MimetypeMap;
import org.alfresco.repo.node.archive.NodeArchiveService; import org.alfresco.repo.node.archive.NodeArchiveService;
@@ -37,6 +40,7 @@ import org.alfresco.repo.site.SiteModel;
import org.alfresco.repo.transaction.RetryingTransactionHelper; import org.alfresco.repo.transaction.RetryingTransactionHelper;
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback; import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
import org.alfresco.repo.web.scripts.BaseWebScriptTest; import org.alfresco.repo.web.scripts.BaseWebScriptTest;
import org.alfresco.service.cmr.repository.ChildAssociationRef;
import org.alfresco.service.cmr.repository.NodeRef; import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.service.cmr.repository.NodeService; import org.alfresco.service.cmr.repository.NodeService;
import org.alfresco.service.cmr.security.MutableAuthenticationService; import org.alfresco.service.cmr.security.MutableAuthenticationService;
@@ -44,10 +48,12 @@ import org.alfresco.service.cmr.security.PersonService;
import org.alfresco.service.cmr.site.SiteInfo; import org.alfresco.service.cmr.site.SiteInfo;
import org.alfresco.service.cmr.site.SiteService; import org.alfresco.service.cmr.site.SiteService;
import org.alfresco.service.cmr.site.SiteVisibility; import org.alfresco.service.cmr.site.SiteVisibility;
import org.alfresco.service.namespace.NamespaceService;
import org.alfresco.service.namespace.QName; import org.alfresco.service.namespace.QName;
import org.alfresco.util.PropertyMap; import org.alfresco.util.PropertyMap;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser; import org.json.simple.parser.JSONParser;
import org.springframework.context.support.AbstractRefreshableApplicationContext; import org.springframework.context.support.AbstractRefreshableApplicationContext;
@@ -377,4 +383,209 @@ public class NodeWebScripTest extends BaseWebScriptTest
AuthenticationUtil.setFullyAuthenticatedUser(USER_TWO); AuthenticationUtil.setFullyAuthenticatedUser(USER_TWO);
sendRequest(req, Status.STATUS_FORBIDDEN); sendRequest(req, Status.STATUS_FORBIDDEN);
} }
@SuppressWarnings("unchecked")
public void testLinkCreation() throws Exception
{
// Create a folder within the DocLib
NodeRef siteDocLib = siteService.getContainer(TEST_SITE.getShortName(), SiteService.DOCUMENT_LIBRARY);
String testFolder1Name = "testingLinkCreationFolder1";
Map<QName, Serializable> testFolderProps = new HashMap<QName, Serializable>();
testFolderProps.put(ContentModel.PROP_NAME, testFolder1Name);
NodeRef testFolder1 = nodeService.createNode(siteDocLib, ContentModel.ASSOC_CONTAINS,
QName.createQName("testingLinkCreationFolder1"), ContentModel.TYPE_FOLDER, testFolderProps).getChildRef();
JSONObject jsonReq = null;
JSONObject json = null;
JSONArray jsonArray = new JSONArray();
JSONArray jsonLinkNodes = null;
JSONObject jsonLinkNode = null;
//Create files in the folder
NodeRef testFile1 = createNode(testFolder1, "testingLinkCreationFile1", ContentModel.TYPE_CONTENT,
AuthenticationUtil.getAdminUserName());
NodeRef testFile2 = createNode(testFolder1, "testingLinkCreationFile2", ContentModel.TYPE_CONTENT,
AuthenticationUtil.getAdminUserName());
NodeRef testFile3 = createNode(testFolder1, "testingLinkCreationFile3", ContentModel.TYPE_CONTENT,
AuthenticationUtil.getAdminUserName());
//Create another folder in the folder
String testFolder2Name = "testingLinkCreationFolder2";
testFolderProps = new HashMap<QName, Serializable>();
testFolderProps.put(ContentModel.PROP_NAME, testFolder2Name);
NodeRef testFolder2 = nodeService.createNode(siteDocLib, ContentModel.ASSOC_CONTAINS,
QName.createQName("testingLinkCreationFolder2"), ContentModel.TYPE_FOLDER, testFolderProps).getChildRef();
// Create link to file1 in same folder
Request req = new Request("POST", "/api/node/doclink/" + testFile1.getStoreRef().getProtocol() + "/"
+ testFile1.getStoreRef().getIdentifier() + "/" + testFile1.getId());
jsonReq = new JSONObject();
jsonReq.put("destinationNodeRef", testFolder1.toString());
jsonArray.add(testFile1.toString());
jsonReq.put("multipleFiles", jsonArray);
req.setBody(jsonReq.toString().getBytes());
req.setType(MimetypeMap.MIMETYPE_JSON);
json = asJSON(sendRequest(req, Status.STATUS_OK));
jsonLinkNodes = (JSONArray) json.get("linkNodes");
assertNotNull(jsonLinkNodes);
assertEquals(1, jsonLinkNodes.size());
assertEquals("true", json.get("overallSuccess"));
assertEquals("1", json.get("successCount"));
assertEquals("0", json.get("failureCount"));
jsonLinkNode = (JSONObject) jsonLinkNodes.get(0);
String nodeRef = (String) jsonLinkNode.get("nodeRef");
NodeRef file1Link = new NodeRef(nodeRef);
//Check that app:linked aspect is added on sourceNode
assertEquals(true, nodeService.hasAspect(testFile1, ApplicationModel.ASPECT_LINKED));
assertEquals(true, nodeService.exists(file1Link));
nodeService.deleteNode(file1Link);
assertEquals(false, nodeService.hasAspect(testFile1, ApplicationModel.ASPECT_LINKED));
//Create link to testFolder2 in same folder (testFolder1)
req = new Request("POST", "/api/node/doclink/" + testFolder2.getStoreRef().getProtocol() + "/"
+ testFolder2.getStoreRef().getIdentifier() + "/" + testFolder2.getId());
jsonReq = new JSONObject();
jsonReq.put("destinationNodeRef", testFolder1.toString());
jsonArray = new JSONArray();
jsonArray.add(testFolder2.toString());
jsonReq.put("multipleFiles", jsonArray);
req.setBody(jsonReq.toString().getBytes());
req.setType(MimetypeMap.MIMETYPE_JSON);
json = asJSON(sendRequest(req, Status.STATUS_OK));
jsonLinkNodes = (JSONArray) json.get("linkNodes");
assertNotNull(jsonLinkNodes);
assertEquals(1, jsonLinkNodes.size());
assertEquals("true", json.get("overallSuccess"));
assertEquals("1", json.get("successCount"));
assertEquals("0", json.get("failureCount"));
jsonLinkNode = (JSONObject) jsonLinkNodes.get(0);
nodeRef = (String) jsonLinkNode.get("nodeRef");
NodeRef folder2Link = new NodeRef(nodeRef);
assertEquals(true, nodeService.hasAspect(testFolder2, ApplicationModel.ASPECT_LINKED));
assertEquals(true, nodeService.exists(folder2Link));
// create another link of testFolder2 in siteDocLib
req = new Request("POST", "/api/node/doclink/" + testFolder2.getStoreRef().getProtocol() + "/"
+ testFolder2.getStoreRef().getIdentifier() + "/" + testFolder2.getId());
jsonReq = new JSONObject();
jsonReq.put("destinationNodeRef", siteDocLib.toString());
jsonArray = new JSONArray();
jsonArray.add(testFolder2.toString());
jsonReq.put("multipleFiles", jsonArray);
req.setBody(jsonReq.toString().getBytes());
req.setType(MimetypeMap.MIMETYPE_JSON);
json = asJSON(sendRequest(req, Status.STATUS_OK));
jsonLinkNodes = (JSONArray) json.get("linkNodes");
assertNotNull(jsonLinkNodes);
assertEquals(1, jsonLinkNodes.size());
assertEquals("true", json.get("overallSuccess"));
assertEquals("1", json.get("successCount"));
assertEquals("0", json.get("failureCount"));
jsonLinkNode = (JSONObject) jsonLinkNodes.get(0);
nodeRef = (String) jsonLinkNode.get("nodeRef");
NodeRef folder2Link2 = new NodeRef(nodeRef);
// delete folder2Link and check that aspect exists since we have another
// link for testFolder2
nodeService.deleteNode(folder2Link);
assertEquals(true, nodeService.hasAspect(testFolder2, ApplicationModel.ASPECT_LINKED));
nodeService.deleteNode(folder2Link2);
assertEquals(false, nodeService.hasAspect(testFolder2, ApplicationModel.ASPECT_LINKED));
// Create link to testFile1, testFile2 and testFile3 in same testFolder1
req = new Request("POST", "/api/node/doclink/" + testFolder1.getStoreRef().getProtocol() + "/"
+ testFolder1.getStoreRef().getIdentifier() + "/" + testFolder1.getId());
jsonReq = new JSONObject();
jsonReq.put("destinationNodeRef", testFolder1.toString());
jsonArray = new JSONArray();
jsonArray.add(testFile1.toString());
jsonArray.add(testFile2.toString());
jsonArray.add(testFile3.toString());
jsonReq.put("multipleFiles", jsonArray);
req.setBody(jsonReq.toString().getBytes());
req.setType(MimetypeMap.MIMETYPE_JSON);
json = asJSON(sendRequest(req, Status.STATUS_OK));
jsonLinkNodes = (JSONArray) json.get("linkNodes");
assertNotNull(jsonLinkNodes);
assertEquals(3, jsonLinkNodes.size());
assertEquals("true", json.get("overallSuccess"));
assertEquals("3", json.get("successCount"));
assertEquals("0", json.get("failureCount"));
NodeRef fileLink = null;
List<NodeRef> fileLinks = new ArrayList<NodeRef>();
for (int i = 0; i < jsonLinkNodes.size(); i++)
{
jsonLinkNode = (JSONObject) jsonLinkNodes.get(i);
nodeRef = (String) jsonLinkNode.get("nodeRef");
fileLink = new NodeRef(nodeRef);
fileLinks.add(fileLink);
assertEquals(true, nodeService.exists(fileLink));
}
//try to create another link in the same location - an exception should be thrown
req = new Request("POST", "/api/node/doclink/" + testFolder1.getStoreRef().getProtocol() + "/"
+ testFolder1.getStoreRef().getIdentifier() + "/" + testFolder1.getId());
jsonReq = new JSONObject();
jsonReq.put("destinationNodeRef", testFolder1.toString());
jsonArray = new JSONArray();
jsonArray.add(testFile1.toString());
jsonReq.put("multipleFiles", jsonArray);
req.setBody(jsonReq.toString().getBytes());
req.setType(MimetypeMap.MIMETYPE_JSON);
json = asJSON(sendRequest(req, Status.STATUS_BAD_REQUEST));
// delete all 3 files and check that the links are deleted too
nodeService.deleteNode(testFile1);
nodeService.deleteNode(testFile2);
nodeService.deleteNode(testFile3);
for (NodeRef linkNodeRef : fileLinks)
{
assertEquals(false, nodeService.exists(linkNodeRef));
}
//try create a link to a site
SiteInfo site2 = createSite("Site2TestingNodeCreateLink");
NodeRef siteNodeRef = site2.getNodeRef();
req = new Request("POST", "/api/node/doclink/" + testFolder1.getStoreRef().getProtocol() + "/"
+ testFolder1.getStoreRef().getIdentifier() + "/" + testFolder1.getId());
jsonReq = new JSONObject();
jsonReq.put("destinationNodeRef", testFolder1.toString());
jsonArray = new JSONArray();
jsonArray.add(siteNodeRef.toString());
jsonReq.put("multipleFiles", jsonArray);
req.setBody(jsonReq.toString().getBytes());
req.setType(MimetypeMap.MIMETYPE_JSON);
json = asJSON(sendRequest(req, Status.STATUS_BAD_REQUEST));
siteService.deleteSite(site2.getShortName());
nodeArchiveService.purgeArchivedNode(nodeArchiveService.getArchivedNode(siteNodeRef));
}
private NodeRef createNode(NodeRef parentNode, String nodeCmName, QName nodeType, String ownerUserName)
{
QName childName = QName.createQName(NamespaceService.APP_MODEL_1_0_URI, nodeCmName);
Map<QName, Serializable> props = new HashMap<QName, Serializable>();
props.put(ContentModel.PROP_NAME, nodeCmName);
ChildAssociationRef childAssoc = nodeService.createNode(parentNode,
ContentModel.ASSOC_CONTAINS,
childName,
nodeType,
props);
return childAssoc.getChildRef();
}
} }