From f80282893b7913d3af768a60176d3a26503e2ad0 Mon Sep 17 00:00:00 2001
From: Britt Park <britt.park@alfresco.com>
Date: Fri, 2 Feb 2007 18:47:26 +0000
Subject: [PATCH] CrossRepositoryCopyService now can copy from AVM to Repo.

git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@5025 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
---
 .../org/alfresco/repo/avm/AVMServiceTest.java |  4 ++
 .../copy/CrossRepositoryCopyServiceImpl.java  | 51 +++++++++++++++++++
 2 files changed, 55 insertions(+)

diff --git a/source/java/org/alfresco/repo/avm/AVMServiceTest.java b/source/java/org/alfresco/repo/avm/AVMServiceTest.java
index ad6d64656a..9c564e5139 100644
--- a/source/java/org/alfresco/repo/avm/AVMServiceTest.java
+++ b/source/java/org/alfresco/repo/avm/AVMServiceTest.java
@@ -237,6 +237,10 @@ public class AVMServiceTest extends AVMServiceTestBase
             desc = fService.lookup(-1, "main:/Guest Home");
             assertTrue(desc.isDirectory());
             System.out.println(this.recursiveList("main", -1, true));
+            copyService.copy(AVMNodeConverter.ToNodeRef(-1, "main:/a"), toCopy.getFirst(), "a");
+            Pair<NodeRef, Boolean> theCopy = remoteService.lookup(toCopy.getFirst(), "a");
+            assertTrue(theCopy.getSecond());
+            remoteService.removeNode(theCopy.getFirst());
         }
         catch (Exception e)
         {
diff --git a/source/java/org/alfresco/repo/copy/CrossRepositoryCopyServiceImpl.java b/source/java/org/alfresco/repo/copy/CrossRepositoryCopyServiceImpl.java
index 25ee1454c8..6eb783a325 100644
--- a/source/java/org/alfresco/repo/copy/CrossRepositoryCopyServiceImpl.java
+++ b/source/java/org/alfresco/repo/copy/CrossRepositoryCopyServiceImpl.java
@@ -7,6 +7,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.io.Serializable;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -14,6 +15,7 @@ import java.util.Set;
 import org.alfresco.error.AlfrescoRuntimeException;
 import org.alfresco.model.ContentModel;
 import org.alfresco.repo.avm.AVMNodeConverter;
+import org.alfresco.service.cmr.avm.AVMNodeDescriptor;
 import org.alfresco.service.cmr.avm.AVMService;
 import org.alfresco.service.cmr.dictionary.DictionaryService;
 import org.alfresco.service.cmr.model.FileFolderService;
@@ -161,6 +163,55 @@ public class CrossRepositoryCopyServiceImpl implements
      */
     private void copyAVMToRepo(NodeRef src, NodeRef dst, String name)
     {
+        Pair<Integer, String> versionPath = AVMNodeConverter.ToAVMVersionPath(src);
+        AVMNodeDescriptor desc = fAVMService.lookup(versionPath.getFirst(), versionPath.getSecond());
+        if (desc.isFile())
+        {
+            FileInfo newChild = fFileFolderService.create(dst, name, ContentModel.TYPE_CONTENT);
+            NodeRef childRef = newChild.getNodeRef();
+            InputStream in = fAVMService.getFileInputStream(desc);
+            OutputStream out = fContentService.getWriter(childRef, ContentModel.PROP_CONTENT, true).getContentOutputStream();
+            copyData(in, out);
+            copyPropsAndAspectsAVMToRepo(src, childRef);
+        }
+        else
+        {
+            FileInfo newChild = fFileFolderService.create(dst, name, ContentModel.TYPE_FOLDER);
+            NodeRef childRef = newChild.getNodeRef();
+            copyPropsAndAspectsAVMToRepo(src, childRef);
+            Map<String, AVMNodeDescriptor> listing = fAVMService.getDirectoryListing(desc);
+            for (Map.Entry<String, AVMNodeDescriptor> entry : listing.entrySet())
+            {
+                NodeRef srcChild = AVMNodeConverter.ToNodeRef(versionPath.getFirst(), entry.getValue().getPath());
+                copyAVMToRepo(srcChild, childRef, entry.getKey());
+            }
+        }
+    }
+    
+    /**
+     * Helper that copies aspects and properties.
+     * @param src The source AVM node.
+     * @param dst The destination Repo node.
+     */
+    private void copyPropsAndAspectsAVMToRepo(NodeRef src, NodeRef dst)
+    {
+        Map<QName, Serializable> props = fNodeService.getProperties(src);
+        fNodeService.setProperties(dst, props);
+        Set<QName> aspects = fNodeService.getAspects(src);
+        Map<QName, Serializable> empty = new HashMap<QName, Serializable>();
+        for (QName aspect : aspects)
+        {
+            fNodeService.addAspect(dst, aspect, empty);
+        }
+        if (!fNodeService.hasAspect(dst, ContentModel.ASPECT_COPIEDFROM))
+        {
+            empty.put(ContentModel.PROP_COPY_REFERENCE, src);
+            fNodeService.addAspect(dst, ContentModel.ASPECT_COPIEDFROM, empty);
+        }
+        else
+        {
+            fNodeService.setProperty(dst, ContentModel.PROP_COPY_REFERENCE, src);
+        }
     }
 
     /**