1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34 package info.magnolia.module.exchangesimple;
35
36 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.ACTION;
37 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.ACTIVATE;
38 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.CONTENT_FILTER_RULE;
39 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.NODE_UUID;
40 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.PARENT_PATH;
41 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.REPOSITORY_NAME;
42 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_FILE;
43 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_FILE_ELEMENT;
44 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_ID_ATTRIBUTE;
45 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_MD_ATTRIBUTE;
46 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_NAME_ATTRIBUTE;
47 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_ROOT_ELEMENT;
48 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.RESOURCE_MAPPING_UUID_ATTRIBUTE;
49 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.SIBLINGS_ELEMENT;
50 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.SIBLINGS_ROOT_ELEMENT;
51 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.SIBLING_UUID;
52 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.UTF8_STATUS;
53 import static info.magnolia.module.exchangesimple.BaseSyndicatorImpl.WORKSPACE_NAME;
54 import info.magnolia.cms.core.Content;
55 import info.magnolia.cms.core.ItemType;
56 import info.magnolia.cms.core.Path;
57 import info.magnolia.cms.core.SystemProperty;
58 import info.magnolia.cms.security.SecurityUtil;
59 import info.magnolia.cms.util.Rule;
60 import info.magnolia.cms.util.RuleBasedContentFilter;
61 import info.magnolia.jcr.wrapper.DelegateNodeWrapper;
62 import info.magnolia.repository.RepositoryConstants;
63
64 import java.io.ByteArrayOutputStream;
65 import java.io.File;
66 import java.io.FileInputStream;
67 import java.io.FileOutputStream;
68 import java.io.IOException;
69 import java.io.OutputStream;
70 import java.util.Iterator;
71 import java.util.List;
72 import java.util.zip.GZIPOutputStream;
73
74 import javax.jcr.Node;
75 import javax.jcr.RepositoryException;
76 import javax.jcr.Session;
77
78 import org.apache.commons.io.IOUtils;
79 import org.apache.commons.io.output.TeeOutputStream;
80 import org.apache.xml.serialize.OutputFormat;
81 import org.apache.xml.serialize.XMLSerializer;
82 import org.jdom.Document;
83 import org.jdom.Element;
84 import org.jdom.output.XMLOutputter;
85 import org.slf4j.Logger;
86 import org.slf4j.LoggerFactory;
87 import org.xml.sax.InputSource;
88 import org.xml.sax.SAXException;
89 import org.xml.sax.XMLReader;
90 import org.xml.sax.helpers.XMLReaderFactory;
91
92
93
94
95
96
97
98 public class ResourceCollector {
99
100 private static final Logger log = LoggerFactory.getLogger(ResourceCollector.class);
101
102
103
104
105
106
107
108
109
110
111
112 public ActivationContent collect(Content node, List<String> orderBefore, String parent, String workspaceName, String repositoryName, Rule contentFilterRule) throws Exception {
113 Content.ContentFilter contentFilter = getContentFilter(contentFilterRule);
114
115
116 File resourceFile = File.createTempFile("resources", ".xml", Path.getTempDirectory());
117
118 ActivationContent activationContent = new ActivationContent();
119
120 activationContent.addProperty(PARENT_PATH, parent);
121 activationContent.addProperty(WORKSPACE_NAME, workspaceName);
122 activationContent.addProperty(REPOSITORY_NAME, repositoryName);
123 activationContent.addProperty(RESOURCE_MAPPING_FILE, resourceFile.getName());
124 activationContent.addProperty(ACTION, ACTIVATE);
125 activationContent.addProperty(CONTENT_FILTER_RULE, contentFilterRule.toString());
126 activationContent.addProperty(NODE_UUID, node.getUUID());
127 activationContent.addProperty(UTF8_STATUS, SystemProperty.getProperty(SystemProperty.MAGNOLIA_UTF8_ENABLED));
128
129 Document document = new Document();
130 Element root = new Element(RESOURCE_MAPPING_ROOT_ELEMENT);
131 document.setRootElement(root);
132
133 addOrderingInfo(root, orderBefore);
134
135 this.addResources(root, node.getWorkspace().getSession(), node, contentFilter, activationContent);
136 XMLOutputter outputter = new XMLOutputter();
137
138 ByteArrayOutputStream md5 = new ByteArrayOutputStream();
139 outputter.output(document, new TeeOutputStream(new FileOutputStream(resourceFile), md5));
140
141 activationContent.addFile(resourceFile.getName(), resourceFile);
142
143 activationContent.addProperty(RESOURCE_MAPPING_MD_ATTRIBUTE, SecurityUtil.getMD5Hex(md5.toByteArray()));
144
145
146 activationContent.addProperty(ItemType.DELETED_NODE_MIXIN, "" + node.hasMixin(ItemType.DELETED_NODE_MIXIN));
147
148 return activationContent;
149 }
150
151 protected Content.ContentFilter getContentFilter(Rule contentFilterRule) {
152 return new RuleBasedContentFilter(contentFilterRule);
153 }
154
155
156
157
158
159
160
161
162 protected void addOrderingInfo(Element root, List<String> orderBefore) {
163
164 Element siblingRoot = new Element(SIBLINGS_ROOT_ELEMENT);
165 root.addContent(siblingRoot);
166 if (orderBefore == null) {
167 return;
168 }
169 Iterator<String> siblings = orderBefore.iterator();
170 while (siblings.hasNext()) {
171 String uuid = siblings.next();
172 Element e = new Element(SIBLINGS_ELEMENT);
173 e.setAttribute(SIBLING_UUID, uuid);
174 siblingRoot.addContent(e);
175 }
176 }
177
178 protected void addResources(Element resourceElement, Session session, final Content content, Content.ContentFilter filter, ActivationContent activationContent) throws IOException, RepositoryException, SAXException, Exception {
179 final String workspaceName = content.getWorkspace().getName();
180
181 log.debug("Preparing content {}:{} for publishing.", new String[] { workspaceName, content.getHandle() });
182 final String uuid = content.getUUID();
183
184 File file = File.createTempFile("exchange_" + uuid, ".xml.gz", Path.getTempDirectory());
185 ByteArrayOutputStream md5 = new ByteArrayOutputStream();
186 OutputStream outputStream = new TeeOutputStream(new GZIPOutputStream(new FileOutputStream(file)), md5);
187
188
189 if (content.isNodeType("nt:frozenNode") || workspaceName.equals(RepositoryConstants.VERSION_STORE)) {
190 XMLReader elementfilter = new FrozenElementFilter(XMLReaderFactory
191 .createXMLReader(org.apache.xerces.parsers.SAXParser.class.getName()));
192 ((FrozenElementFilter) elementfilter).setNodeName(content.getName());
193
194
195
196 boolean noRecurse = !content.isNodeType(ItemType.NT_FILE);
197 exportAndParse(session, content, elementfilter, outputStream, noRecurse);
198 } else {
199
200
201
202 if (content.isNodeType(ItemType.NT_FILE)) {
203 session.exportSystemView(content.getJCRNode().getPath(), outputStream, false, false);
204 } else {
205 session.exportSystemView(content.getJCRNode().getPath(), outputStream, false, true);
206 }
207 }
208
209 IOUtils.closeQuietly(outputStream);
210
211 Element element = new Element(RESOURCE_MAPPING_FILE_ELEMENT);
212 element.setAttribute(RESOURCE_MAPPING_NAME_ATTRIBUTE, content.getName());
213 element.setAttribute(RESOURCE_MAPPING_UUID_ATTRIBUTE, uuid);
214 element.setAttribute(RESOURCE_MAPPING_ID_ATTRIBUTE, file.getName());
215
216 element.setAttribute(RESOURCE_MAPPING_MD_ATTRIBUTE, SecurityUtil.getMD5Hex(md5.toByteArray()));
217
218 resourceElement.addContent(element);
219
220 activationContent.addFile(file.getName(), file);
221
222 Iterator<Content> children = content.getChildren(filter).iterator();
223 while (children.hasNext()) {
224 Content child = children.next();
225 this.addResources(element, session, child, filter, activationContent);
226 }
227 }
228
229
230
231
232 protected void exportAndParse(Session session, Content content, XMLReader elementfilter, OutputStream os, boolean noRecurse) throws Exception {
233 File tempFile = File.createTempFile("Frozen_" + content.getName(), ".xml");
234 OutputStream tmpFileOutStream = null;
235 FileInputStream tmpFileInStream = null;
236 try {
237 tmpFileOutStream = new FileOutputStream(tempFile);
238
239 Node node = content.getJCRNode();
240 if (node instanceof DelegateNodeWrapper) {
241 node = ((DelegateNodeWrapper) node).getWrappedNode();
242 }
243 session.exportSystemView(node.getPath(), tmpFileOutStream, false, noRecurse);
244 tmpFileOutStream.flush();
245 tmpFileOutStream.close();
246
247 OutputFormat outputFormat = new OutputFormat();
248 outputFormat.setPreserveSpace(false);
249
250 tmpFileInStream = new FileInputStream(tempFile);
251 elementfilter.setContentHandler(new XMLSerializer(os, outputFormat));
252 elementfilter.parse(new InputSource(tmpFileInStream));
253 tmpFileInStream.close();
254 } catch (Throwable t) {
255 log.error("Failed to parse XML using FrozenElementFilter", t);
256 throw new Exception(t);
257 } finally {
258 IOUtils.closeQuietly(tmpFileInStream);
259 IOUtils.closeQuietly(tmpFileOutStream);
260 tempFile.delete();
261 }
262 }
263
264
265
266
267
268 }