1 files changed, 77 insertions, 0 deletions
diff --git a/branches/sca-java-1.x/modules/domain-search/src/main/java/org/apache/tuscany/sca/domain/search/impl/ZipDocumentProcessor.java b/branches/sca-java-1.x/modules/domain-search/src/main/java/org/apache/tuscany/sca/domain/search/impl/ZipDocumentProcessor.java
new file mode 100644
index 0000000000..3f3112dd60
--- /dev/null
+++ b/branches/sca-java-1.x/modules/domain-search/src/main/java/org/apache/tuscany/sca/domain/search/impl/ZipDocumentProcessor.java
@@ -0,0 +1,77 @@
+package org.apache.tuscany.sca.domain.search.impl;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.zip.ZipException;
+import java.util.zip.ZipFile;
+
+import org.apache.lucene.document.Field;
+import org.apache.tuscany.sca.domain.search.DocumentMap;
+import org.apache.tuscany.sca.domain.search.DocumentProcessor;
+
+public class ZipDocumentProcessor implements DocumentProcessor {
+	
+	final public static char ARCHIVE_SEPARATOR = '\u0004';
+
+	public Object getDocumentKey(Object object) {
+
+		if (object instanceof File) {
+			File file = (File) object;
+			String path = file.getPath();
+
+			if (path != null && path.length() == 0) {
+				return null;
+			}
+
+			return path;
+
+		}
+
+		throw new IllegalArgumentException();
+
+	}
+
+	public Document process(DocumentProcessor parentProcessor,
+			DocumentMap documents, Object object, Document document,
+			String parent) {
+
+		if (object instanceof SystemFileContent) {
+			SystemFileContent file = (SystemFileContent) object;
+
+			try {
+				ZipFile zip = new ZipFile(file);
+				
+				if (document == null) {
+					document = documents.get(file.getPath());
+				}
+
+				parent += DomainPathAnalyzer.PATH_SEPARATOR
+						+ SearchFields.FILE_FIELD
+						+ DomainPathAnalyzer.TYPE_SEPARATOR + file.getPath() + ARCHIVE_SEPARATOR
+						+ DomainPathAnalyzer.URI_SEPARATOR + file.getName();
+				
+				document.add(new Field(SearchFields.FILE_FIELD, file.getName(), Field.Store.YES,
+						Field.Index.ANALYZED));
+
+				ZipFileContent[] zipFiles = ZipFileContent.createZipFileContent(zip);
+
+				for (ZipFileContent zipFile : zipFiles) {
+					
+					parentProcessor.process(parentProcessor, documents,
+							zipFile, document, parent);
+					
+				}
+				
+				return document;
+
+			} catch (IOException e) {
+				// ignore file
+			}
+
+		}
+		
+		return null;
+
+	}
+
+}