diff --git a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.desc.xml b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.desc.xml index a8315255a5..69691f85bb 100644 --- a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.desc.xml +++ b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.desc.xml @@ -39,9 +39,11 @@ { "url": string, "name": string, + "title": string, "channelType": { "id": string, + "title": string, "url": string, "channelNodeType": string, "contentRootNodeType": string, @@ -61,9 +63,11 @@ { "url": string, "name": string, + "title": string, "channelType": { "id": string, + "title": string, "url": string, "channelNodeType": string, "contentRootNodeType": string, diff --git a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.json.ftl b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.json.ftl index f62df898ae..8658650106 100644 --- a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.json.ftl +++ b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/channels.get.json.ftl @@ -2,10 +2,11 @@ <#import "publishing.lib.ftl" as publishLib /> { "data": - [ - <#list data as channel> - <@publishLib.channelJSON channel=channel /> - <#if channel_has_next>, - - ] + { + urlLength: ${data.urlLength}, + "publishChannels": + <@publishLib.channelsJSON channels=data.publishChannels />, + "statusUpdateChannels": + <@publishLib.channelsJSON channels=data.statusUpdateChannels /> + } } diff --git a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/publishing.lib.ftl b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/publishing.lib.ftl index b30875664c..2be177a135 100644 --- a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/publishing.lib.ftl +++ b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/publishing.lib.ftl @@ -1,20 +1,31 @@ +<#-- Renders a List of Channel.s --> +<#macro channelsJSON channels> +<#escape x as jsonUtils.encodeJSONString(x)> + [ + <#list channels as channel> + <@channelJSON channel=channel /> + <#if channel_has_next>, + + ] + + + <#-- Renders a Channel. --> <#macro channelJSON channel> -<#escape x as jsonUtils.encodeJSONString(x)> { "url": "${channel.url}", "name": "${channel.name}", + "title": "${channel.title}", "channelType": <@channelTypeJSON type=channel.channelType /> } - <#-- Renders a Channel Type. --> <#macro channelTypeJSON type> -<#escape x as jsonUtils.encodeJSONString(x)> { "id": "${type.id}", + "title": "${type.title}", "url": "${type.url}", "channelNodeType": "${type.channelNodeType}", "contentRootNodeType": "${type.contentRootNodeType}", @@ -22,21 +33,20 @@ <@iterateStringsJSON strings=type.supportedContentTypes />, "supportedMimeTypes": <@iterateStringsJSON strings=type.supportedMimeTypes/>, - "canPublish": "${type.canPublish}", - "canPublishStatusUpdates": "${type.canPublishStatusUpdates}", - "canUnpublish": "${type.canUnpublish}" + "canPublish": ${type.canPublish}, + "canPublishStatusUpdates": ${type.canPublishStatusUpdates}, + "canUnpublish": ${type.canUnpublish}, + "maxStatusLength": ${type.maxStatusLength}, + "icon": "${type.icon}" } - <#-- Renders a List of Strings. --> <#macro iterateStringsJSON strings> -<#escape x as jsonUtils.encodeJSONString(x)> [ <#list strings as string> "${string}" <#if string_has_next>, ] - diff --git a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/supported-channels.get.desc.xml b/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/supported-channels.get.desc.xml deleted file mode 100644 index 820a0de5dc..0000000000 --- a/config/alfresco/templates/webscripts/org/alfresco/repository/publishing/supported-channels.get.desc.xml +++ /dev/null @@ -1,73 +0,0 @@ - - Get Supported Delivery Channels - Get the publishing channels for the specified Node. - /api/publishing/{store_protocol}/{store_id}/{node_id}/channels - - user - required - public_api - - - store_protocol - The Store protocol. - - - store_id - The Store id. - - - node_id - The Node id. - - - - - json - - - - - - \ No newline at end of file diff --git a/source/java/org/alfresco/repo/web/scripts/publishing/ChannelsGet.java b/source/java/org/alfresco/repo/web/scripts/publishing/ChannelsGet.java index 13cd86c795..24d6f69725 100644 --- a/source/java/org/alfresco/repo/web/scripts/publishing/ChannelsGet.java +++ b/source/java/org/alfresco/repo/web/scripts/publishing/ChannelsGet.java @@ -27,6 +27,7 @@ import javax.servlet.http.HttpServletResponse; import org.alfresco.service.cmr.publishing.channels.Channel; import org.alfresco.service.cmr.publishing.channels.ChannelService; +import org.alfresco.service.cmr.repository.NodeRef; import org.springframework.extensions.webscripts.Cache; import org.springframework.extensions.webscripts.DeclarativeWebScript; import org.springframework.extensions.webscripts.Status; @@ -40,18 +41,25 @@ import org.springframework.extensions.webscripts.WebScriptRequest; */ public class ChannelsGet extends DeclarativeWebScript { - public static final String DATA_KEY = "data"; public static final String SITE_ID = "site_id"; + public static final String STORE_PROTOCOL = "store_protocol"; + public static final String STORE_ID = "store_id"; + public static final String NODE_ID = "node_id"; + + // Model Keys + public static final String DATA_KEY = "data"; + public static final String URL_LENGTH = "urlLength"; + public static final String PUBLISHING_CHANNELS = "publishChannels"; + public static final String STATUS_UPDATE_CHANNELS = "statusUpdateChannels"; private ChannelService channelService; - + /** * {@inheritDoc} */ @Override protected Map executeImpl(WebScriptRequest req, Status status, Cache cache) { - PublishingModelBuilder builder = new PublishingModelBuilder(); return buildModel(builder, req, status, cache); } @@ -61,14 +69,46 @@ public class ChannelsGet extends DeclarativeWebScript { Map params = req.getServiceMatch().getTemplateVars(); String siteId = params.get(SITE_ID); - if (siteId== null) + + List publishingChannels; + List statusUpdateChannels; + if (siteId!= null) { - throw new WebScriptException(HttpServletResponse.SC_BAD_REQUEST, "A Site ID must be specified!"); + publishingChannels = channelService.getPublishingChannels(siteId); + statusUpdateChannels = channelService.getStatusUpdateChannels(siteId); + } + else + { + NodeRef node = getNodeRef(params); + if(node == null) + { + String msg = "Either a Site ID or valid NodeRef must be specified!"; + throw new WebScriptException(HttpServletResponse.SC_BAD_REQUEST, msg); + } + publishingChannels = channelService.getRelevantPublishingChannels(node); + statusUpdateChannels = channelService.getStatusUpdateChannels(node); } - List channels = channelService.getChannels(siteId); - List> results = builder.buildChannels(channels); - return createBaseModel(results); + Map model = new HashMap(); + + //TODO Implement URL shortening. + model.put(URL_LENGTH, 20); + + model.put(PUBLISHING_CHANNELS, builder.buildChannels(publishingChannels)); + model.put(STATUS_UPDATE_CHANNELS, builder.buildChannels(statusUpdateChannels)); + return createBaseModel(model); + } + + private NodeRef getNodeRef(Map params) + { + String protocol = params.get(STORE_PROTOCOL); + String storeId= params.get(STORE_ID); + String nodeId= params.get(NODE_ID); + if(protocol == null || storeId == null || nodeId==null ) + { + return null; + } + return new NodeRef(protocol, storeId, nodeId); } protected Map createBaseModel(Map result) diff --git a/source/java/org/alfresco/repo/web/scripts/publishing/PublishingModelBuilder.java b/source/java/org/alfresco/repo/web/scripts/publishing/PublishingModelBuilder.java index 95b4e4d5c7..230a267edb 100644 --- a/source/java/org/alfresco/repo/web/scripts/publishing/PublishingModelBuilder.java +++ b/source/java/org/alfresco/repo/web/scripts/publishing/PublishingModelBuilder.java @@ -42,28 +42,31 @@ public class PublishingModelBuilder // General Keys public static final String ID = "id"; public static final String URL = "url"; + public static final String ICON = "icon"; + public static final String TITLE = "title"; // Channel Type Keys - public static final String CHANNEL_NODE_TYP = "channelNodeType"; - public static final String CONTENT_ROOT_NODE_TYP = "contentRootNodeType"; + public static final String CHANNEL_NODE_TYPE = "channelNodeType"; + public static final String CONTENT_ROOT_NODE_TYPE = "contentRootNodeType"; public static final String SUPPORTED_CONTENT_TYPES = "supportedContentTypes"; public static final String SUPPORTED_MIME_TYPES = "supportedMimeTypes"; public static final String CAN_PUBLISH = "canPublish"; public static final String CAN_PUBLISH_STATUS_UPDATES = "canPublishStatusUpdates"; public static final String CAN_UNPUBLISH = "canUnpublish"; + public static final String MAX_STATUS_LENGTH = "maxStatusLength"; // Channel Keys - public static final String CHANNEL_TYPE = "channelType"; public static final String NAME = "name"; + public static final String CHANNEL_TYPE = "channelType"; public Map buildChannel(Channel channel) { Map model = new HashMap(); - - model.put(NAME, channel.getName()); model.put(URL, getUrl(channel)); + model.put(NAME, channel.getName()); + //TODO Localize the title. + model.put(TITLE, channel.getName()); model.put(CHANNEL_TYPE, buildChannelType(channel.getChannelType())); - return model; } @@ -82,16 +85,22 @@ public class PublishingModelBuilder { Map model = new HashMap(); model.put(ID, type.getId()); + //TODO Localize the title. + model.put(TITLE, type.getId()); model.put(URL, getUrl(type)); - model.put(CHANNEL_NODE_TYP, type.getChannelNodeType().toString()); - model.put(CONTENT_ROOT_NODE_TYP, type.getContentRootNodeType().toString()); + model.put(CHANNEL_NODE_TYPE, type.getChannelNodeType().toString()); + model.put(CONTENT_ROOT_NODE_TYPE, type.getContentRootNodeType().toString()); + model.put(SUPPORTED_CONTENT_TYPES, toListOfStrings(type.getSupportedContentTypes())); model.put(SUPPORTED_MIME_TYPES, type.getSupportedMimetypes()); + model.put(CAN_PUBLISH, toString(type.canPublish())); model.put(CAN_PUBLISH_STATUS_UPDATES, toString(type.canPublishStatusUpdates())); model.put(CAN_UNPUBLISH, toString(type.canUnpublish())); + model.put(MAX_STATUS_LENGTH, type.getMaximumStatusLength()); + model.put(ICON, ""); return model; } diff --git a/source/java/org/alfresco/repo/web/scripts/publishing/PublishingRestApiTest.java b/source/java/org/alfresco/repo/web/scripts/publishing/PublishingRestApiTest.java new file mode 100644 index 0000000000..619b0e97c9 --- /dev/null +++ b/source/java/org/alfresco/repo/web/scripts/publishing/PublishingRestApiTest.java @@ -0,0 +1,377 @@ +/* + * 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 . + */ + +package org.alfresco.repo.web.scripts.publishing; + +import static org.alfresco.model.ContentModel.TYPE_CONTENT; +import static org.alfresco.repo.publishing.PublishingModel.TYPE_DELIVERY_CHANNEL; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.CAN_PUBLISH; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.CAN_PUBLISH_STATUS_UPDATES; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.CAN_UNPUBLISH; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.CHANNEL_NODE_TYPE; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.CHANNEL_TYPE; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.CONTENT_ROOT_NODE_TYPE; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.ICON; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.ID; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.MAX_STATUS_LENGTH; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.NAME; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.SUPPORTED_CONTENT_TYPES; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.SUPPORTED_MIME_TYPES; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.TITLE; +import static org.alfresco.repo.web.scripts.publishing.PublishingModelBuilder.URL; +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.when; + +import java.io.File; +import java.text.MessageFormat; +import java.util.Collection; +import java.util.Collections; +import java.util.List; + +import org.alfresco.model.ContentModel; +import org.alfresco.repo.content.MimetypeMap; +import org.alfresco.repo.content.transform.AbstractContentTransformerTest; +import org.alfresco.repo.publishing.ChannelServiceImpl; +import org.alfresco.repo.publishing.PublishingObjectFactory; +import org.alfresco.repo.security.authentication.AuthenticationUtil; +import org.alfresco.repo.transaction.RetryingTransactionHelper; +import org.alfresco.repo.web.scripts.BaseWebScriptTest; +import org.alfresco.service.ServiceRegistry; +import org.alfresco.service.cmr.model.FileFolderService; +import org.alfresco.service.cmr.publishing.channels.Channel; +import org.alfresco.service.cmr.publishing.channels.ChannelService; +import org.alfresco.service.cmr.publishing.channels.ChannelType; +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.StoreRef; +import org.alfresco.service.cmr.site.SiteService; +import org.alfresco.service.cmr.site.SiteVisibility; +import org.alfresco.util.GUID; +import org.alfresco.util.collections.CollectionUtils; +import org.json.JSONArray; +import org.json.JSONObject; +import org.springframework.context.ApplicationContext; +import org.springframework.extensions.surf.util.URLEncoder; +import org.springframework.extensions.webscripts.TestWebScriptServer.GetRequest; +import org.springframework.extensions.webscripts.TestWebScriptServer.Response; + +/** + * @author Nick Smith + * @since 4.0 + * + */ +public class PublishingRestApiTest extends BaseWebScriptTest +{ + private static final String environmentName = "live"; + private static final String publishPdfType = "publishPdfForTest"; + private static final String publishAnyType = "publishAnyForTest"; + private static final String statusUpdateType = "statusUpdateForTest"; + private static final int maxStatusLength = 100; + + private static final String CHANNELS_SITE_URL = "api/publishing/site/{0}/channels"; + private static final String CHANNELS_NODE_URL = "api/publishing/{0}/{1}/{2}/channels"; + + private SiteService siteService; + private FileFolderService fileFolderService; + private NodeService nodeService; + private ChannelService channelService; + private RetryingTransactionHelper txHelper; + + private NodeRef docLib; + private String siteId; + + public void testGetChannelsForNode() throws Exception + { + NodeRef textNode = createContentNode("plainContent", "Some plain text", MimetypeMap.MIMETYPE_TEXT_PLAIN); + + File pdfFile = AbstractContentTransformerTest.loadQuickTestFile("pdf"); + assertNotNull("Failed to load required test file.", pdfFile); + NodeRef xmlNode = createContentNode("xmlContent", pdfFile, MimetypeMap.MIMETYPE_PDF); + StoreRef store = textNode.getStoreRef(); + + assertEquals(MimetypeMap.MIMETYPE_PDF, fileFolderService.getReader(xmlNode).getMimetype()); + String plainTextNodeUrl = MessageFormat.format(CHANNELS_NODE_URL, store.getProtocol(), store.getIdentifier(), textNode.getId() ); + Response response = sendRequest(new GetRequest(plainTextNodeUrl), 200); + + // Call with no channels defined on site. + response = sendRequest(new GetRequest(plainTextNodeUrl), 200); + JSONObject data = getJsonData(response); + + //TODO Fix hard coding. + assertEquals(20, data.getInt(ChannelsGet.URL_LENGTH)); + JSONArray publishingChannels = data.getJSONArray(ChannelsGet.PUBLISHING_CHANNELS); + assertEquals(0, publishingChannels.length()); + JSONArray statusChannels = data.getJSONArray(ChannelsGet.STATUS_UPDATE_CHANNELS); + assertEquals(0, statusChannels.length()); + + Channel publishAnyChannel = createChannel(publishAnyType); + Channel publishPdfChannel = createChannel(publishPdfType); + Channel statusUpdateChannel= createChannel(statusUpdateType); + + // Call with channels defined. + response = sendRequest(new GetRequest(plainTextNodeUrl), 200); + data = getJsonData(response); + + //TODO Fix hard coding. + assertEquals(20, data.getInt(ChannelsGet.URL_LENGTH)); + publishingChannels = data.getJSONArray(ChannelsGet.PUBLISHING_CHANNELS); + statusChannels = data.getJSONArray(ChannelsGet.STATUS_UPDATE_CHANNELS); + + checkChannels(publishingChannels, publishAnyChannel); + checkChannels(statusChannels, statusUpdateChannel); + + String xmlNodeUrl = MessageFormat.format(CHANNELS_NODE_URL, store.getProtocol(), store.getIdentifier(), xmlNode.getId() ); + response = sendRequest(new GetRequest(xmlNodeUrl), 200); + data = getJsonData(response); + + //TODO Fix hard coding. + assertEquals(20, data.getInt(ChannelsGet.URL_LENGTH)); + publishingChannels = data.getJSONArray(ChannelsGet.PUBLISHING_CHANNELS); + statusChannels = data.getJSONArray(ChannelsGet.STATUS_UPDATE_CHANNELS); + + checkChannels(publishingChannels, publishAnyChannel, publishPdfChannel); + checkChannels(statusChannels, statusUpdateChannel); + } + + public void testGetChannelsForSite() throws Exception + { + String badSiteUrl = MessageFormat.format(CHANNELS_SITE_URL, "foo"); + Response response = sendRequest(new GetRequest(badSiteUrl), 500); + + // Call with no channels defined on site. + String siteUrl = MessageFormat.format(CHANNELS_SITE_URL, siteId); + response = sendRequest(new GetRequest(siteUrl), 200); + JSONObject data = getJsonData(response); + + //TODO Fix hard coding. + assertEquals(20, data.getInt(ChannelsGet.URL_LENGTH)); + JSONArray publishingChannels = data.getJSONArray(ChannelsGet.PUBLISHING_CHANNELS); + assertEquals(0, publishingChannels.length()); + JSONArray statusChannels = data.getJSONArray(ChannelsGet.STATUS_UPDATE_CHANNELS); + assertEquals(0, statusChannels.length()); + + Channel publishAnyChannel = createChannel(publishAnyType); + Channel publishPdfChannel = createChannel(publishPdfType); + Channel statusUpdateChannel= createChannel(statusUpdateType); + + // Call channels defined. + response = sendRequest(new GetRequest(siteUrl), 200); + data = getJsonData(response); + + //TODO Fix hard coding. + assertEquals(20, data.getInt(ChannelsGet.URL_LENGTH)); + publishingChannels = data.getJSONArray(ChannelsGet.PUBLISHING_CHANNELS); + statusChannels = data.getJSONArray(ChannelsGet.STATUS_UPDATE_CHANNELS); + + checkChannels(publishingChannels, publishAnyChannel, publishPdfChannel); + checkChannels(statusChannels, statusUpdateChannel); + } + + private void checkChannels(JSONArray json, Channel... channels)throws Exception + { + assertEquals(channels.length, json.length()); + for (Channel channel : channels) + { + checkContainsChannel(json, channel); + } + } + + private void checkContainsChannel(JSONArray json, Channel channel) throws Exception + { + for (int i = 0; i < json.length(); i++) + { + JSONObject jsonChannel = json.getJSONObject(i); + String name = jsonChannel.getString(NAME); + if(channel.getName().equals(name)) + { + checkChannel(jsonChannel, channel); + return; + } + } + fail("Json did not contain channel: " + channel.getName()); + } + + private void checkChannel(JSONObject jsonChannel, Channel channel) throws Exception + { + NodeRef node = channel.getNodeRef(); + StoreRef storeRef = node.getStoreRef(); + String expUrl = "api/publishing/channels/" + + storeRef.getProtocol() + "/" + + storeRef.getIdentifier() + "/" + + node.getId(); + check(URL, jsonChannel, expUrl); + check(TITLE, jsonChannel, channel.getName()); + JSONObject jsonType = jsonChannel.getJSONObject(CHANNEL_TYPE); + assertNotNull("The channel type is null!", jsonType); + checkChannelType(jsonType, channel.getChannelType()); + } + + private void checkChannelType(JSONObject jsonType, ChannelType channelType) throws Exception + { + check(ID, jsonType, channelType.getId()); + check(TITLE, jsonType, channelType.getId()); + + String expUrl = "api/publishing/channelTypes/"+URLEncoder.encode(channelType.getId()); + check(URL, jsonType, expUrl); + check(CHANNEL_NODE_TYPE, jsonType, channelType.getChannelNodeType().toString()); + check(CONTENT_ROOT_NODE_TYPE, jsonType, channelType.getContentRootNodeType().toString()); + + List contentTypes = CollectionUtils.toListOfStrings(channelType.getSupportedContentTypes()); + checkStrings(jsonType.getJSONArray(SUPPORTED_CONTENT_TYPES), contentTypes); + checkStrings(jsonType.getJSONArray(SUPPORTED_MIME_TYPES), channelType.getSupportedMimetypes()); + + check(CAN_PUBLISH, jsonType, channelType.canPublish()); + check(CAN_PUBLISH_STATUS_UPDATES, jsonType, channelType.canPublishStatusUpdates()); + check(CAN_UNPUBLISH, jsonType, channelType.canUnpublish()); + check(MAX_STATUS_LENGTH, jsonType, channelType.getMaximumStatusLength()); + + //TODO Implement Icon URL + check(ICON, jsonType, ""); + } + + private void check(String key, JSONObject json, Object exp) + { + assertEquals("Comparing "+key, exp, json.opt(key)); + } + + private void checkStrings(JSONArray json, Collection strings) throws Exception + { + assertEquals(strings.size(), json.length()); + for (String string : strings) + { + checkContains(json, string); + } + } + + private void checkContains(JSONArray json, String string) throws Exception + { + for (int i = 0; i < json.length(); i++) + { + if(string.equals(json.getString(i))) + { + return; + } + } + fail("Did not contain " + string); + } + + private Channel createChannel(String typeId) + { + return channelService.createChannel(siteId, typeId, GUID.generate(), null); + } + + private JSONObject getJsonData(Response response) throws Exception + { + String jsonStr = response.getContentAsString(); + assertNotNull("The JSON is null!", jsonStr); + JSONObject json = new JSONObject(jsonStr); + JSONObject data = json.getJSONObject("data"); + assertNotNull("Data was null!", data); + return data; + } + + private NodeRef createContentNode(String name, File theContent, String mimetype) + { + NodeRef source = fileFolderService.create(docLib, name, TYPE_CONTENT).getNodeRef(); + writeContent(source, theContent, mimetype); + return source; + } + + private NodeRef createContentNode(String name, String theContent, String mimetype) + { + NodeRef source = fileFolderService.create(docLib, name, TYPE_CONTENT).getNodeRef(); + writeContent(source, theContent, mimetype); + return source; + } + + private void writeContent(NodeRef source, String theContent, String mimetype) + { + ContentWriter writer = fileFolderService.getWriter(source); + writer.setEncoding("UTF-8"); + writer.putContent(theContent); + writer.setMimetype(mimetype); + } + + private void writeContent(NodeRef source, File theContent, String mimetype) + { + ContentWriter writer = fileFolderService.getWriter(source); + writer.setMimetype(mimetype); + writer.setEncoding("UTF-8"); + writer.putContent(theContent); + } + + private ChannelType mockChannelType(String channelTypeId) + { + ChannelType channelType = channelService.getChannelType(channelTypeId); + if(channelType != null) + { + return channelType; + } + channelType = mock(ChannelType.class); + when(channelType.getId()).thenReturn(channelTypeId); + when(channelType.getChannelNodeType()).thenReturn(TYPE_DELIVERY_CHANNEL); + when(channelType.getContentRootNodeType()).thenReturn(ContentModel.TYPE_FOLDER); + channelService.register(channelType); + return channelType; + } + + @Override + protected void setUp() throws Exception + { + super.setUp(); + ApplicationContext ctx = getServer().getApplicationContext(); + AuthenticationUtil.setFullyAuthenticatedUser(AuthenticationUtil.getAdminUserName()); + ServiceRegistry serviceRegistry = (ServiceRegistry) ctx.getBean(ServiceRegistry.SERVICE_REGISTRY); + this.siteService = serviceRegistry.getSiteService(); + this.fileFolderService = serviceRegistry.getFileFolderService(); + this.nodeService = serviceRegistry.getNodeService(); + this.txHelper = serviceRegistry.getRetryingTransactionHelper(); + this.channelService = (ChannelService) ctx.getBean(ChannelServiceImpl.NAME); + PublishingObjectFactory factory = (PublishingObjectFactory) ctx.getBean(PublishingObjectFactory.NAME); + + ChannelType publishAny = mockChannelType(publishAnyType); + when(publishAny.canPublish()).thenReturn(true); + + ChannelType publishPdf= mockChannelType(publishPdfType); + when(publishPdf.canPublish()).thenReturn(true); + when(publishPdf.getSupportedMimetypes()).thenReturn(Collections.singleton(MimetypeMap.MIMETYPE_PDF)); + + ChannelType statusUpdate= mockChannelType(statusUpdateType); + when(statusUpdate.canPublishStatusUpdates()).thenReturn(true); + when(statusUpdate.getMaximumStatusLength()).thenReturn(maxStatusLength); + + this.siteId = GUID.generate(); + siteService.createSite("test", siteId, + "Test site created by ChannelServiceImplIntegratedTest", + "Test site created by ChannelServiceImplIntegratedTest", + SiteVisibility.PUBLIC); + this.docLib = siteService.createContainer(siteId, SiteService.DOCUMENT_LIBRARY, ContentModel.TYPE_FOLDER, null); + + factory.createEnvironmentObject(siteId, environmentName); + + } + + @Override + public void tearDown() throws Exception + { + siteService.deleteSite(siteId); + super.tearDown(); + } +} diff --git a/source/java/org/alfresco/repo/web/scripts/publishing/SupportedChannelsGet.java b/source/java/org/alfresco/repo/web/scripts/publishing/SupportedChannelsGet.java new file mode 100644 index 0000000000..e5535f7d5d --- /dev/null +++ b/source/java/org/alfresco/repo/web/scripts/publishing/SupportedChannelsGet.java @@ -0,0 +1,32 @@ +/* + * 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 . + */ + +package org.alfresco.repo.web.scripts.publishing; + +import org.springframework.extensions.webscripts.DeclarativeWebScript; + +/** + * @author Nick Smith + * @since 4.0 + * + */ +public class SupportedChannelsGet extends DeclarativeWebScript +{ + +}