Merge pull request #267 from martiner/jmi-conTimes

introduce zendesk connector start dates

Author: liry

src/main/java/com/gooddata/connector/Zendesk4ProcessExecution.java

@@ -4,14 +4,29 @@
 package com.gooddata.connector;
 
 import static com.gooddata.connector.ConnectorType.ZENDESK4;
+import static com.gooddata.util.Validate.notEmpty;
+import static com.gooddata.util.Validate.notNull;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import org.joda.time.DateTime;
+import org.joda.time.DateTimeZone;
+import org.joda.time.format.DateTimeFormatter;
+import org.joda.time.format.ISODateTimeFormat;
+
+import java.util.Map;
+import java.util.TreeMap;
 
 /**
  * Zendesk 4 (Insights) connector process execution (i.e. definition for single ETL run). Serialization only.
  */
 public class Zendesk4ProcessExecution implements ProcessExecution {
 
+    private static final DateTimeFormatter FORMATTER = ISODateTimeFormat.dateTime().withZone(DateTimeZone.UTC);
+
     private Boolean incremental;
 
+    private Map<String, String> startTimes;
+
     @Override
     public ConnectorType getConnectorType() {
         return ZENDESK4;
@@ -24,4 +39,19 @@ public Boolean getIncremental() {
     public void setIncremental(final Boolean incremental) {
         this.incremental = incremental;
     }
+
+    @JsonAnyGetter
+    public Map<String, String> getStartTimes() {
+        return startTimes;
+    }
+
+
+    public void setStartTime(final String resource, final DateTime startTime) {
+        notEmpty(resource, "resource can't be empty");
+        notNull(startTime, "startTime can't be null");
+
+        startTimes = startTimes == null ? new TreeMap<String, String>() : startTimes;
+
+        startTimes.put(resource + "StartDate", FORMATTER.print(startTime));
+    }
 }

src/test/java/com/gooddata/connector/Zendesk4ProcessExecutionTest.java

@@ -4,6 +4,7 @@
 package com.gooddata.connector;
 
 import com.gooddata.JsonMatchers;
+import org.joda.time.DateTime;
 import org.testng.annotations.Test;
 
 import static org.hamcrest.MatcherAssert.assertThat;
@@ -23,4 +24,13 @@ public void testShouldSerializeIncremental() throws Exception {
         assertThat(execution, JsonMatchers.serializesToJson(
                 "/connector/process-execution-incremental.json"));
     }
+
+    @Test
+    public void testShouldSerializeStartTimes() throws Exception {
+        final Zendesk4ProcessExecution execution = new Zendesk4ProcessExecution();
+        execution.setIncremental(true);
+        execution.setStartTime("tickets", new DateTime(0L));
+        assertThat(execution, JsonMatchers.serializesToJson(
+                "/connector/process-execution-startDate.json"));
+    }
 }

src/test/resources/connector/process-execution-startDate.json

@@ -0,0 +1,6 @@
+{
+    "process": {
+        "incremental": true,
+        "ticketsStartDate": "1970-01-01T00:00:00.000Z"
+    }
+}