Implementing POST request for appending simulation (#258)

Co-authored-by: Italo Garcia <italo.de.moraes.garcia@zalando.de>

Author: 2 people

src/main/java/io/specto/hoverfly/junit/api/HoverflyClient.java

@@ -19,10 +19,20 @@
 public interface HoverflyClient {
 
 
+    /**
+     * Set the given simulation data, overwriting any existing one.
+     * @param simulation Hoverfly simulation data to set
+     */
     void setSimulation(Simulation simulation);
 
     void setSimulation(String simulation);
 
+    /**
+     * Append the given simulation to the existing one in Hoverfly, duplicated pair will not be added
+     * @param simulation Hoverfly simulation data to append
+     */
+    void addSimulation(Simulation simulation);
+
     Simulation getSimulation();
 
     /**

src/main/java/io/specto/hoverfly/junit/api/OkHttpHoverflyClient.java

@@ -42,14 +42,14 @@ class OkHttpHoverflyClient implements HoverflyClient {
     private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
     private static final MediaType JSON = MediaType.parse("application/json");
 
-    private OkHttpClient client;
+    private final OkHttpClient client;
 
-    private HttpUrl baseUrl;
+    private final HttpUrl baseUrl;
 
     OkHttpHoverflyClient(String scheme, String host, int port, String authToken) {
         OBJECT_MAPPER.registerModule(new JavaTimeModule());
         OkHttpClient.Builder clientBuilder = new OkHttpClient.Builder();
-        if (authToken != null ) {
+        if (authToken != null) {
             clientBuilder.addInterceptor(new AuthHeaderInterceptor(authToken));
         }
         this.client = clientBuilder.build();
@@ -86,6 +86,19 @@ public void setSimulation(String simulation) {
         }
     }
 
+    @Override
+    public void addSimulation(Simulation simulation) {
+        try {
+            final Request.Builder builder = createRequestBuilderWithUrl(SIMULATION_PATH);
+            final RequestBody body = createRequestBody(simulation);
+            final Request request = builder.post(body).build();
+            exchange(request);
+        } catch (Exception e) {
+            LOGGER.warn("Failed to add simulation: {}", e.getMessage());
+            throw new HoverflyClientException("Failed to add simulation: " + e.getMessage());
+        }
+    }
+
     @Override
     public Simulation getSimulation() {
         try {
@@ -184,7 +197,7 @@ public StateView getState() {
             throw new HoverflyClientException("Failed to get state: " + e.getMessage());
         }
     }
-  
+
     @Override
     public DiffView getDiffs() {
         try {

src/main/java/io/specto/hoverfly/junit/core/model/Response.java

@@ -19,7 +19,6 @@
 import org.apache.commons.lang3.builder.EqualsBuilder;
 import org.apache.commons.lang3.builder.HashCodeBuilder;
 import org.apache.commons.lang3.builder.ToStringBuilder;
-import sun.rmi.runtime.Log;
 
 import java.util.List;
 import java.util.Map;

src/test/java/io/specto/hoverfly/junit/api/OkHttpHoverflyClientTest.java

@@ -179,6 +179,20 @@ public void shouldBeAbleToDeleteAllSimulation() throws Exception {
         assertThat(result.getHoverflyData().getPairs()).isEmpty();
     }
 
+    @Test
+    public void shouldBeAbleToAppendSimulation() throws Exception {
+        URL resource = Resources.getResource("simulations/v5-simulation.json");
+        Simulation simulation = objectMapper.readValue(resource, Simulation.class);
+        client.setSimulation(simulation);
+
+        resource = Resources.getResource("simulations/v5-simulation-without-response-body.json");
+        simulation = objectMapper.readValue(resource, Simulation.class);
+        client.addSimulation(simulation);
+
+        Simulation result = client.getSimulation();
+        assertThat(result.getHoverflyData().getPairs()).hasSize(2);
+    }
+
     @Test
     public void shouldBeAbleToDeleteJournal() {