#237 Can now export triggers

Author: rjrudin

src/main/java/com/marklogic/appdeployer/export/Exporter.java

@@ -12,6 +12,7 @@
 import com.marklogic.appdeployer.export.security.RoleExporter;
 import com.marklogic.appdeployer.export.security.UserExporter;
 import com.marklogic.appdeployer.export.tasks.TaskExporter;
+import com.marklogic.appdeployer.export.triggers.TriggerExporter;
 import com.marklogic.client.ext.helper.LoggingObject;
 import com.marklogic.mgmt.ManageClient;
 import com.marklogic.mgmt.selector.ResourceSelection;
@@ -55,12 +56,14 @@ public Exporter select(ResourceSelector selector) {
 		cpfConfigs(triggersDatabase, selection.getCpfConfigNames());
 		databases(selection.getDatabaseNames());
 		domains(triggersDatabase, selection.getDomainNames());
+		groups(selection.getGroupNames());
 		pipelines(triggersDatabase, selection.getPipelineNames());
 		privilegesExecute(selection.getPrivilegeExecuteNames());
 		privilegesUri(selection.getPrivilegeUriNames());
 		roles(selection.getRoleNames());
 		servers(selection.getServerNames());
 		tasks(selection.getTaskNames());
+		triggers(triggersDatabase, selection.getTriggerNames());
 		users(selection.getUserNames());
 		return this;
 	}
@@ -157,6 +160,10 @@ public Exporter tasks(String... taskNames) {
 		return this;
 	}
 
+	public Exporter triggers(String databaseIdOrName, String... triggerNames) {
+		return (triggerNames != null && triggerNames.length > 0) ? add(new TriggerExporter(manageClient, databaseIdOrName, triggerNames)) : null;
+	}
+
 	public Exporter users(String... usernames) {
 		return (usernames != null && usernames.length > 0) ? add(new UserExporter(manageClient, usernames)) : null;
 	}

src/main/java/com/marklogic/appdeployer/export/triggers/TriggerExporter.java

@@ -0,0 +1,41 @@
+package com.marklogic.appdeployer.export.triggers;
+
+import com.marklogic.appdeployer.ConfigDir;
+import com.marklogic.appdeployer.export.impl.AbstractNamedResourceExporter;
+import com.marklogic.appdeployer.export.impl.ExportInputs;
+import com.marklogic.mgmt.ManageClient;
+import com.marklogic.mgmt.resource.ResourceManager;
+import com.marklogic.mgmt.resource.triggers.TriggerManager;
+
+import java.io.File;
+
+public class TriggerExporter extends AbstractNamedResourceExporter {
+
+	private String databaseIdOrName;
+
+	public TriggerExporter(ManageClient manageClient, String databaseIdOrName, String... triggerNames) {
+		super(manageClient, triggerNames);
+		this.databaseIdOrName = databaseIdOrName;
+	}
+
+	@Override
+	protected String[] getExportMessages() {
+		return new String[]{"Each exported trigger has the 'id' field removed from it, as that field should be generated by MarkLogic."};
+	}
+
+	@Override
+	protected String beforeResourceWrittenToFile(ExportInputs exportInputs, String payload) {
+		return removeJsonKeyFromPayload(payload, "id");
+	}
+
+	@Override
+	protected ResourceManager newResourceManager(ManageClient manageClient) {
+		return new TriggerManager(manageClient, databaseIdOrName);
+	}
+
+	@Override
+	protected File getResourceDirectory(File baseDir) {
+		return new ConfigDir(baseDir).getTriggersDir();
+	}
+
+}

src/main/java/com/marklogic/mgmt/selector/MapResourceSelection.java

@@ -84,6 +84,11 @@ public String[] getTaskNames() {
 		return getSelectedResourceNames(TASKS);
 	}
 
+	@Override
+	public String[] getTriggerNames() {
+		return getSelectedResourceNames(TRIGGERS);
+	}
+
 	@Override
 	public String[] getUserNames() {
 		return getSelectedResourceNames(USERS);

src/main/java/com/marklogic/mgmt/selector/ResourceSelection.java

@@ -13,6 +13,7 @@ public interface ResourceSelection {
 	String ROLES = "roles";
 	String SERVERS = "servers";
 	String TASKS = "tasks";
+	String TRIGGERS = "triggers";
 	String USERS = "users";
 
 	String[] getCpfConfigNames();
@@ -35,6 +36,8 @@ public interface ResourceSelection {
 
 	String[] getTaskNames();
 
+	String[] getTriggerNames();
+
 	String[] getUserNames();
 
 	/**

src/test/java/com/marklogic/appdeployer/command/triggers/ManageTriggersTest.java

@@ -13,7 +13,7 @@ public class ManageTriggersTest extends AbstractManageResourceTest {
     @Override
     protected void initializeAndDeploy() {
         initializeAppDeployer(new DeploySchemasDatabaseCommand(), new DeployTriggersDatabaseCommand(),
-                new DeployContentDatabasesCommand(), newCommand());
+                new DeployContentDatabasesCommand(1), newCommand());
         appDeployer.deploy(appConfig);
     }
 

src/test/java/com/marklogic/appdeployer/export/ExportTriggersTest.java

@@ -0,0 +1,47 @@
+package com.marklogic.appdeployer.export;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.marklogic.appdeployer.command.databases.DeployContentDatabasesCommand;
+import com.marklogic.appdeployer.command.databases.DeploySchemasDatabaseCommand;
+import com.marklogic.appdeployer.command.databases.DeployTriggersDatabaseCommand;
+import com.marklogic.appdeployer.command.triggers.DeployTriggersCommand;
+import com.marklogic.mgmt.selector.PropertiesResourceSelector;
+import org.junit.After;
+import org.junit.Test;
+
+import java.io.File;
+import java.util.Properties;
+
+public class ExportTriggersTest extends AbstractExportTest {
+
+	@After
+	public void teardown() {
+		undeploySampleApp();
+	}
+
+	@Test
+	public void test() throws Exception {
+		initializeAppDeployer(new DeploySchemasDatabaseCommand(), new DeployTriggersDatabaseCommand(),
+			new DeployContentDatabasesCommand(1), new DeployTriggersCommand());
+		appDeployer.deploy(appConfig);
+
+		Properties props = new Properties();
+		props.setProperty("triggers", "my-trigger");
+
+		ExportedResources resources = new Exporter(manageClient)
+			.withTriggersDatabase(appConfig.getTriggersDatabaseName())
+			.select(new PropertiesResourceSelector(props))
+			.export(exportDir);
+
+		assertEquals(1, resources.getMessages().size());
+		assertEquals("Each exported trigger has the 'id' field removed from it, as that field should be generated by MarkLogic.",
+			resources.getMessages().get(0));
+
+		assertEquals(1, resources.getFiles().size());
+
+		File triggerFile = new File(exportDir, "triggers/my-trigger.json");
+		JsonNode json = objectMapper.readTree(triggerFile);
+		assertNull(json.get("id"));
+		assertEquals("my-trigger", json.get("name").asText());
+	}
+}

src/test/resources/sample-app/src/main/ml-config/triggers/my-trigger.json

@@ -19,4 +19,4 @@
   "enabled": true,
   "recursive": true,
   "task-priority": "normal"
-}
+}