Triggercamapign

pom.xml

@@ -184,6 +184,13 @@
             <artifactId>guava</artifactId>
             <version>18.0</version>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.24</version>
+            <scope>provided</scope>
+        </dependency>
 
         <dependency>
             <groupId>junit</groupId>

src/main/java/com/smartling/marketo/sdk/MarketoClientManager.java

@@ -1,5 +1,7 @@
 package com.smartling.marketo.sdk;
 
+import com.smartling.marketo.sdk.rest.MarketoTriggerCampaignClient;
+
 public interface MarketoClientManager {
     MarketoFolderClient getMarketoFolderClient();
 
@@ -18,4 +20,6 @@ public interface MarketoClientManager {
     MarketoProgramClient getMarketoProgramClient();
 
     MarketoTokenClient getMarketoTokenClient();
+
+    MarketoTriggerCampaignClient getMarketoTriggerCampaignClient();
 }

src/main/java/com/smartling/marketo/sdk/domain/campaign/TriggerCampaignRequest.java

@@ -0,0 +1,36 @@
+package com.smartling.marketo.sdk.domain.campaign;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+@Getter
+@Setter
+@ToString
+@AllArgsConstructor
+public class TriggerCampaignRequest {
+
+    private LeadId[] leads;
+    private Token[] tokens;
+
+    @Getter
+    @Setter
+    @ToString
+    @AllArgsConstructor
+    public static class LeadId {
+
+        private int id;
+    }
+
+    @Getter
+    @Setter
+    @ToString
+    @AllArgsConstructor
+    public static class Token {
+
+        private String name;
+        private String value;
+    }
+}

src/main/java/com/smartling/marketo/sdk/domain/campaign/TriggerCampaignResult.java

@@ -0,0 +1,10 @@
+package com.smartling.marketo.sdk.domain.campaign;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+@Getter @Setter @ToString
+public class TriggerCampaignResult {
+    private int id;
+}

src/main/java/com/smartling/marketo/sdk/rest/MarketoRestClientManager.java

@@ -74,6 +74,11 @@ public MarketoTokenClient getMarketoTokenClient() {
         return new MarketoTokenRestClient(httpCommandExecutor);
     }
 
+    @Override
+    public MarketoTriggerCampaignClient getMarketoTriggerCampaignClient() {
+        return new MarketoTriggerCampaignClient(httpCommandExecutor);
+    }
+
     public final static class Builder {
         private final String identityUrl;
         private final String restUrl;

src/main/java/com/smartling/marketo/sdk/rest/MarketoTriggerCampaignClient.java

@@ -0,0 +1,42 @@
+package com.smartling.marketo.sdk.rest;
+
+import com.smartling.marketo.sdk.MarketoApiException;
+import com.smartling.marketo.sdk.domain.campaign.TriggerCampaignRequest;
+import com.smartling.marketo.sdk.domain.campaign.TriggerCampaignResult;
+import com.smartling.marketo.sdk.rest.command.triggercampaign.ActivateSmartCampaign;
+import com.smartling.marketo.sdk.rest.command.triggercampaign.RequestTriggerCampaign;
+
+import java.util.List;
+
+public class MarketoTriggerCampaignClient {
+
+    private final HttpCommandExecutor httpCommandExecutor;
+
+    MarketoTriggerCampaignClient(HttpCommandExecutor httpCommandExecutor) {
+        this.httpCommandExecutor = httpCommandExecutor;
+    }
+
+    public TriggerCampaignResult requestTriggerCampaign(int campaignId,
+            TriggerCampaignRequest.LeadId[] leadIds)
+            throws MarketoApiException {
+        return this.requestTriggerCampaign(campaignId, leadIds,
+                new TriggerCampaignRequest.Token[]{});
+    }
+
+    public TriggerCampaignResult requestTriggerCampaign(int campaignId,
+            TriggerCampaignRequest.LeadId[] leadIds, TriggerCampaignRequest.Token[] tokens)
+            throws MarketoApiException {
+        List<TriggerCampaignResult> triggerCampaignResults = httpCommandExecutor.execute(
+                new RequestTriggerCampaign(campaignId, leadIds, tokens));
+        return triggerCampaignResults.get(0);
+    }
+
+    public TriggerCampaignResult activateSmartCampaign(int campaignId)
+            throws MarketoApiException {
+        List<TriggerCampaignResult> triggerCampaignResults = httpCommandExecutor.execute(
+                new ActivateSmartCampaign(campaignId));
+        return triggerCampaignResults.get(0);
+    }
+
+
+}

src/main/java/com/smartling/marketo/sdk/rest/command/triggercampaign/ActivateSmartCampaign.java

@@ -0,0 +1,23 @@
+package com.smartling.marketo.sdk.rest.command.triggercampaign;
+
+import com.smartling.marketo.sdk.domain.campaign.TriggerCampaignResult;
+import com.smartling.marketo.sdk.rest.command.BaseMarketoCommand;
+
+public class ActivateSmartCampaign extends BaseMarketoCommand<TriggerCampaignResult> {
+    private final int campaignId;
+
+    public ActivateSmartCampaign(int campaignId) {
+        super(TriggerCampaignResult.class);
+        this.campaignId = campaignId;
+    }
+
+    @Override
+    public String getPath() {
+        return "/asset/v1/smartCampaign/" + campaignId + "/activate.json";
+    }
+
+    @Override
+    public String getMethod() {
+        return "POST_BODY";
+    }
+}

src/main/java/com/smartling/marketo/sdk/rest/command/triggercampaign/RequestTriggerCampaign.java

@@ -0,0 +1,38 @@
+package com.smartling.marketo.sdk.rest.command.triggercampaign;
+
+import com.google.common.collect.ImmutableMap;
+import com.smartling.marketo.sdk.domain.campaign.TriggerCampaignRequest;
+import com.smartling.marketo.sdk.domain.campaign.TriggerCampaignResult;
+import com.smartling.marketo.sdk.rest.command.BaseMarketoCommand;
+
+import java.util.Map;
+
+public class RequestTriggerCampaign extends BaseMarketoCommand<TriggerCampaignResult> {
+
+    private final int campaignId;
+    private final TriggerCampaignRequest triggerCampaignRequest;
+
+    public RequestTriggerCampaign(int campaignId, TriggerCampaignRequest.LeadId[] leadIds,
+            TriggerCampaignRequest.Token[] tokens) {
+        super(TriggerCampaignResult.class);
+        this.campaignId = campaignId;
+        this.triggerCampaignRequest = new TriggerCampaignRequest(leadIds, tokens);
+    }
+
+    @Override
+    public String getPath() {
+        return "/v1/campaigns/" + campaignId + "/trigger.json";
+    }
+
+    @Override
+    public String getMethod() {
+        return "POST_BODY";
+    }
+
+    @Override
+    public Map<String, Object> getParameters() {
+        ImmutableMap.Builder<String, Object> builder = ImmutableMap.<String, Object>builder()
+                .put("input", this.triggerCampaignRequest);
+        return builder.build();
+    }
+}

src/main/java/com/smartling/marketo/sdk/rest/transport/JaxRsHttpCommandExecutor.java

@@ -121,7 +121,12 @@ private <T> MarketoResponse<T> execute(Invocation.Builder invocationBuilder, Com
             MultiPart multiPartEntity = toMultipart(processParameters(command.getParameters(), false));
             Entity<?> entity = Entity.entity(multiPartEntity, multiPartEntity.getMediaType());
             marketoResponse = invocationBuilder.post(entity, typeToken);
-        } else {
+        } else if ("POST_BODY".equalsIgnoreCase(command.getMethod())) {
+            Map<String, Object> body = processParameters(command.getParameters(), false);
+            Entity<?> entity = Entity.entity(body, MediaType.APPLICATION_JSON_TYPE.withCharset("UTF-8"));
+            marketoResponse = invocationBuilder.post(entity, typeToken);
+        }
+        else {
             marketoResponse = invocationBuilder.method(command.getMethod(), typeToken);
         }