Gatling: Add negative validation scenario

Author: bitxon

common-api/src/main/java/bitxon/api/model/Account.java

@@ -1,6 +1,8 @@
 package bitxon.api.model;
 
+import javax.validation.constraints.Email;
 import javax.validation.constraints.NotEmpty;
+import javax.validation.constraints.NotNull;
 import javax.validation.constraints.Pattern;
 import javax.validation.constraints.PositiveOrZero;
 
@@ -16,7 +18,9 @@
 public class Account {
     Long id;
     @NotEmpty
+    @Email
     String email;
+    @NotNull
     @Pattern(regexp = "USD|EUR|GBP")
     String currency;
     @PositiveOrZero

dropwizard-app/src/main/resources/config.yml

@@ -5,6 +5,8 @@ server:
   adminConnectors:
     - type: http
       port: 8081
+  requestLog:
+    appenders: [] # Disable default logging (response status)
 
 database:
   driverClass: org.postgresql.Driver

loadtest/src/gatling/java/gatling/simulation/CommonSimulation.java

@@ -14,6 +14,11 @@
 import io.gatling.javaapi.http.*;
 
 public class CommonSimulation extends Simulation {
+
+    static final String BASE_URL = System.getProperty("base.url", "http://localhost:8080/accounts");
+
+    //-----------------------------------------------------------------------------------------------------------------
+
     static Iterator<Map<String, Object>> feederPost = Stream.generate((Supplier<Map<String, Object>>) () ->
         Map.of(
             "email", UUID.randomUUID() + "@mail.com",
@@ -28,24 +33,54 @@ public class CommonSimulation extends Simulation {
         )
     ).iterator();
 
+    static FeederBuilder<String> feederInvalidPost = csv("feeders/post-account-invalid-body.csv").random();
+
 
     //-----------------------------------------------------------------------------------------------------------------
 
     private static ChainBuilder postAccount(String sessionFieldNameForId) {
-        return exec().feed(feederPost).exec(http("Create One")
+        return exec().feed(feederPost).exec(http("Create")
             .post("/")
             .header("Content-Type", "application/json")
-            .body(StringBody("{\"email\": \"#{email}\",\"currency\": \"#{currency}\",\"moneyAmount\": #{moneyAmount}}"))
+            .body(StringBody("""
+                {
+                    "email": "#{email}",
+                    "currency": "#{currency}",
+                    "moneyAmount": #{moneyAmount}
+                }
+                """))
+            .check(status().is(200))
             .check(jsonPath("$.id").saveAs(sessionFieldNameForId))
         );
     }
 
+    private static ChainBuilder postInvalidAccount() {
+        return exec().feed(feederInvalidPost).exec(http("Create (400,422)")
+            .post("/")
+            .header("Content-Type", "application/json")
+            .body(StringBody("""
+                {
+                    "email": "#{email}",
+                    "currency": "#{currency}",
+                    "moneyAmount": #{moneyAmount}
+                }
+                """))
+            .check(status().in(400, 422))
+        );
+    }
+
     private static ChainBuilder getOneAccountById() {
-        return exec(http("Get One by Id").get("/#{id}"));
+        return exec(http("Get One")
+            .get("/#{id}")
+            .check(status().is(200))
+        );
     }
 
     private static ChainBuilder getAllAccounts() {
-        return exec(http("Get All").get("/"));
+        return exec(http("Get All")
+            .get("/")
+            .check(status().is(200))
+        );
     }
 
     private static ChainBuilder postTransfer() {
@@ -59,32 +94,35 @@ private static ChainBuilder postTransfer() {
                     "moneyAmount": #{moneyAmount}
                 }
                 """))
+            .check(status().is(204))
         );
     }
 
     //-----------------------------------------------------------------------------------------------------------------
 
-    HttpProtocolBuilder httpProtocol = http.baseUrl("http://localhost:8080/accounts")
+    HttpProtocolBuilder httpProtocol = http.baseUrl(BASE_URL)
         .acceptHeader("application/json")
-        .acceptLanguageHeader("en-US,en;q=0.5")
-        .acceptEncodingHeader("gzip, deflate")
-        .userAgentHeader("Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:16.0) Gecko/20100101 Firefox/16.0");
+        .acceptLanguageHeader("en-US,en;q=0.5");
 
     ScenarioBuilder scenarioGetAll = scenario("Get All - Scenario").exec(
         getAllAccounts()
     );
 
     ScenarioBuilder scenarioGetOne = scenario("Get One - Scenario").exec(
-        postAccount("id"),
+        postAccount("id").exitHereIfFailed(),
         getOneAccountById()
     );
 
     ScenarioBuilder scenarioTransfer = scenario("Transfer - Scenario").exec(
-        postAccount("senderId"),
-        postAccount("recipientId"),
+        postAccount("senderId").exitHereIfFailed(),
+        postAccount("recipientId").exitHereIfFailed(),
         postTransfer()
     );
 
+    ScenarioBuilder scenarioValidation = scenario("Validation 4xx - Scenario").exec(
+        postInvalidAccount()
+    );
+
     //-----------------------------------------------------------------------------------------------------------------
 
     {
@@ -108,6 +146,9 @@ private static ChainBuilder postTransfer() {
                     .eachLevelLasting(8)
                     .separatedByRampsLasting(8)
                     .startingFrom(8)
+            ),
+            scenarioValidation.injectOpen(
+                constantUsersPerSec(10).during(90)
             )
         ).protocols(httpProtocol);
     }

loadtest/src/gatling/resources/feeders/post-account-invalid-body.csv

@@ -0,0 +1,4 @@
+email,currency,moneyAmount
+invalidEmail,USD,340
+[email protected],INVALID,340
+[email protected],USD,-1