Replication Definition deletion support + unit test

(Disabled) unit test for edit/save/load/edit/save of replication definitions,
 so that Derek can look at why the node service breaks for this


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@21093 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261

source/java/org/alfresco/repo/replication/ReplicationDefinitionImpl.java

@@ -91,9 +91,14 @@ public class ReplicationDefinitionImpl extends ActionImpl implements Replication
      */
    @SuppressWarnings("unchecked")
    public List<NodeRef> getPayload() {
+      // Retrieve the previous payload
+      // Could be null, could be a list, or could be a single
+      //  NodeRef (if the list had one entry when saved)
       Object payloadO =
          getParameterValue(REPLICATION_DEFINITION_PAYLOAD);
       
+      // Ensure we always have a list, no matter what
+      //  we got back
       List<NodeRef> payload;
       if(payloadO == null) {
          payload = new ArrayList<NodeRef>();
@@ -104,8 +109,11 @@ public class ReplicationDefinitionImpl extends ActionImpl implements Replication
          if(payloadO instanceof List) {
             payload = (List<NodeRef>)payloadO;
          } else {
+            // Turn it into a list
             payload = new ArrayList<NodeRef>();
             payload.add((NodeRef)payloadO);
+            // And switch to using the list from now on
+            setParameterValue(REPLICATION_DEFINITION_PAYLOAD, (Serializable)payload);
          }
       }
 

source/java/org/alfresco/repo/replication/ReplicationDefinitionPersister.java

@@ -42,6 +42,16 @@ public interface ReplicationDefinitionPersister
      */
     void saveReplicationDefinition(ReplicationDefinition replicationDefinition);
 
+    /**
+     * This method removes the previously serializes {@link ReplicationDefinition}
+     * from the repository. The {@link ReplicationDefinition} will then no longer
+     * be available using the load methods.
+     * 
+     * @param replicationDefinition The {@link ReplicationDefinition} to be
+     *            deleted.
+     */
+    void deleteReplicationDefinition(ReplicationDefinition replicationDefinition);
+
     /**
      * This method retrieves a {@link ReplicationDefinition} that has been stored
      * in the repository using the <code>save()</code> method. If no

source/java/org/alfresco/repo/replication/ReplicationDefinitionPersisterImpl.java

@@ -141,6 +141,15 @@ public class ReplicationDefinitionPersisterImpl implements ReplicationDefinition
         runtimeActionService.saveActionImpl(actionNodeRef, replicationAction);
     }
     
+    public void deleteReplicationDefinition(ReplicationDefinition replicationAction)
+    {
+       QName actionName = replicationAction.getReplicationName();
+       NodeRef actionNode = findActionNode(actionName);
+       if(actionNode != null) {
+          nodeService.deleteNode(actionNode);
+       }
+    }
+    
     private NodeRef findActionNode(QName replicationDefinitionName)
     {
         checkReplicationActionRootNodeExists();

source/java/org/alfresco/repo/replication/ReplicationServiceImpl.java

@@ -148,6 +148,17 @@ public class ReplicationServiceImpl implements ReplicationService, ReplicationDe
       replicationDefinitionPersister.saveReplicationDefinition(replicationDefinition);
    }
 
+   /*
+    * (non-Javadoc)
+    * @see
+    * org.alfresco.service.cmr.replication.ReplicationService#deleteReplicationDefinition
+    * (ReplicationDefinition)
+    */
+   public void deleteReplicationDefinition(
+         ReplicationDefinition replicationDefinition) {
+      replicationDefinitionPersister.deleteReplicationDefinition(replicationDefinition);
+   }
+
    /*
     * (non-Javadoc)
     * @see

source/java/org/alfresco/repo/replication/ReplicationServiceIntegrationTest.java

@@ -236,6 +236,121 @@ public class ReplicationServiceIntegrationTest extends BaseAlfrescoSpringTest
        assertEquals(0, replicationService.loadReplicationDefinitions("TestTarget2").size());
     }
     
+    /**
+     * Ensures that deletion works correctly
+     */
+    public void testDeletion() throws Exception
+    {
+       // Delete does nothing if not persisted
+       assertEquals(0, replicationService.loadReplicationDefinitions().size());
+       ReplicationDefinition rd1 = replicationService.createReplicationDefinition(ACTION_NAME, "Test");
+       assertEquals(0, replicationService.loadReplicationDefinitions().size());
+       
+       replicationService.deleteReplicationDefinition(rd1);
+       assertEquals(0, replicationService.loadReplicationDefinitions().size());
+       
+       
+       // Create and save two
+       ReplicationDefinition rd2 = replicationService.createReplicationDefinition(ACTION_NAME2, "Test2");
+       replicationService.saveReplicationDefinition(rd1);
+       replicationService.saveReplicationDefinition(rd2);
+       assertEquals(2, replicationService.loadReplicationDefinitions().size());
+       
+       
+       // Delete one - the correct one goes!
+       replicationService.deleteReplicationDefinition(rd2);
+       assertEquals(1, replicationService.loadReplicationDefinitions().size());
+       assertEquals(ACTION_NAME, replicationService.loadReplicationDefinitions().get(0).getReplicationName());
+       
+       
+       // Re-delete already deleted, no change
+       replicationService.deleteReplicationDefinition(rd2);
+       assertEquals(1, replicationService.loadReplicationDefinitions().size());
+       assertEquals(ACTION_NAME, replicationService.loadReplicationDefinitions().get(0).getReplicationName());
+       
+       
+       // Delete the 2nd
+       replicationService.deleteReplicationDefinition(rd1);
+       assertEquals(0, replicationService.loadReplicationDefinitions().size());
+       
+       
+       // Can add back in again after being deleted
+       replicationService.saveReplicationDefinition(rd1);
+       assertEquals(1, replicationService.loadReplicationDefinitions().size());
+       assertEquals(ACTION_NAME, replicationService.loadReplicationDefinitions().get(0).getReplicationName());
+    }
+    
+    /**
+     * Ensures that we can create, save, edit, save
+     *  load, edit, save, load etc, all without
+     *  problems, and without creating duplicates
+     * DISABLED until Derek can look at it
+     */
+    public void DISABLEDtestEditing() throws Exception
+    {
+       ReplicationDefinition rdTT = replicationService.createReplicationDefinition(ACTION_NAME, "Test");
+       rdTT.setTargetName("TestTarget");
+       replicationService.saveReplicationDefinition(rdTT);
+       
+       // Load, and check it hasn't changed
+       rdTT = replicationService.loadReplicationDefinition(ACTION_NAME);
+       assertEquals(ACTION_NAME, rdTT.getReplicationName());
+       assertEquals("Test", rdTT.getDescription());
+       assertEquals("TestTarget", rdTT.getTargetName());
+       assertEquals(0, rdTT.getPayload().size());
+       
+       // Save and re-load without changes
+       replicationService.saveReplicationDefinition(rdTT);
+       rdTT = replicationService.loadReplicationDefinition(ACTION_NAME);
+       assertEquals(ACTION_NAME, rdTT.getReplicationName());
+       assertEquals("Test", rdTT.getDescription());
+       assertEquals("TestTarget", rdTT.getTargetName());
+       assertEquals(0, rdTT.getPayload().size());
+       
+       // Make some small changes
+       rdTT.setDescription("Test Description");
+       rdTT.getPayload().add(folder2a);
+       
+       // Check we see them on save/load
+       replicationService.saveReplicationDefinition(rdTT);
+       rdTT = replicationService.loadReplicationDefinition(ACTION_NAME);
+       assertEquals(ACTION_NAME, rdTT.getReplicationName());
+       assertEquals("Test Description", rdTT.getDescription());
+       assertEquals("TestTarget", rdTT.getTargetName());
+       assertEquals(1, rdTT.getPayload().size());
+       assertEquals(folder2a, rdTT.getPayload().get(0));
+       
+       // And some more changes
+       rdTT.setDescription("Another One");
+       rdTT.getPayload().clear();
+       rdTT.getPayload().add(folder1);
+       rdTT.getPayload().add(folder2b);
+       assertEquals(2, rdTT.getPayload().size());
+       
+       // Ensure these also come with save/load
+       replicationService.saveReplicationDefinition(rdTT);
+       rdTT = replicationService.loadReplicationDefinition(ACTION_NAME);
+       assertEquals(ACTION_NAME, rdTT.getReplicationName());
+       assertEquals("Another One", rdTT.getDescription());
+       assertEquals("TestTarget", rdTT.getTargetName());
+       assertEquals(2, rdTT.getPayload().size());
+       assertEquals(folder1, rdTT.getPayload().get(0));
+       assertEquals(folder2b, rdTT.getPayload().get(0));
+       
+       // And more payload changes
+       rdTT.getPayload().clear();
+       rdTT.getPayload().add(content1_1);
+       assertEquals(1, rdTT.getPayload().size());
+       
+       replicationService.saveReplicationDefinition(rdTT);
+       rdTT = replicationService.loadReplicationDefinition(ACTION_NAME);
+       assertEquals(ACTION_NAME, rdTT.getReplicationName());
+       assertEquals("Another One", rdTT.getDescription());
+       assertEquals("TestTarget", rdTT.getTargetName());
+       assertEquals(1, rdTT.getPayload().size());
+       assertEquals(content1_1, rdTT.getPayload().get(0));
+    }
+
     /**
      * Test that the action service can find the executor
      *  for us, and that it has everything it needs
@@ -365,6 +480,10 @@ public class ReplicationServiceIntegrationTest extends BaseAlfrescoSpringTest
        // Put in Folder 2, so we can send Folder 2a
        // TODO Finish creating it properly
        NodeRef folderT2 = makeNode(destinationFolder, ContentModel.TYPE_FOLDER, folder2.getId());
+System.err.println("F2 = " + folder2);
+System.err.println("F2 @ " + nodeService.getPath(folder2));
+System.err.println("FT2 = " + folderT2);
+System.err.println("FT2 @ " + nodeService.getPath(folderT2));
        
        // Run a transfer
        ReplicationDefinition rd = replicationService.createReplicationDefinition(ACTION_NAME, "Test");