Add create institutions

Author: jmarin

cluster/src/test/resources/application.conf

@@ -2,9 +2,11 @@ hmda {
   benchmark {
     host = "localhost"
     host = ${?HMDA_BENCHMARK_HOST}
-    port = "8080"
+    port = 8080
     port = ${?HMDA_BENCHMARK_PORT}
-    nrOfUsers = 1000
-    rampUpTime = 30
+    adminPort = 8081
+    adminPort = ${?HMDA_BENCHMARK_ADMIN_PORT}
+    nrOfUsers = 10
+    rampUpTime = 5
   }
 }

cluster/src/test/scala/api/http/benchmark/FilingSimulation.scala

@@ -16,6 +16,7 @@ class FilingSimulation extends Simulation with WriteInstitutionProtocol {
   val config = ConfigFactory.load()
   val host = config.getString("hmda.benchmark.host")
   val port = config.getInt("hmda.benchmark.port")
+  val adminPort = config.getInt("hmda.benchmark.adminPort")
   val nrOfUsers = config.getInt("hmda.benchmark.nrOfUsers")
   val rampUpTime = config.getInt("hmda.benchmark.rampUpTime")
 
@@ -29,22 +30,114 @@ class FilingSimulation extends Simulation with WriteInstitutionProtocol {
     .acceptLanguageHeader("en-US,en;q=0.5")
     .userAgentHeader("Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:16.0) Gecko/20100101 Firefox/16.0")
     .header("cfpb-hmda-username", "user")
-    .header("cfpb-hmda-institutions", institutionIds.mkString(","))
+    //.header("cfpb-hmda-institutions", institutionIds.mkString(","))
     .disableCaching
 
-  val filingScenario = scenario("HMDA Filing")
-    .exec(http("GET Institutions")
-      .get("/institutions")
-      .check(
-        status is 200
-      ))
-  //.pause(1)
-  //    .exec(http("POST Institutions")
-  //      .post("/institutions")
-  //      //.post(Institution.empty.toJson.toString()).asJSON
-  //      .check(status is 201))
-
-  setUp(filingScenario.inject(
-    rampUsers(nrOfUsers) over (rampUpTime seconds)
-  ).protocols(httpProtocol))
+  object InstitutionScenario {
+
+    def list(institutionId: String) = {
+      exec(http("Institutions")
+        .get("/institutions")
+        .header("cfpb-hmda-institutions", institutionId)
+        .check(status is 200))
+    }
+
+    def create(institutionId: String) = {
+      exec(http("Create Institution")
+        .post(s"http://$host:$adminPort/institutions")
+        .body(StringBody(
+          s"""
+              {
+                  "otherLenderCode": 0,
+                  "parent": {
+                      "respondentId": "-1",
+                      "city": "",
+                      "name": "",
+                      "state": "",
+                      "idRssd": -1
+                  },
+                  "activityYear": 2017,
+                  "cra": false,
+                  "assets": 35788,
+                  "agency": "ncua",
+                  "hmdaFilerFlag": false,
+                  "respondent": {
+                      "city": "HONOLULU",
+                      "name": "HAWAIIAN ELECTRIC EMPLOYEES FEDERAL CREDIT UNION",
+                      "externalId": {
+                          "value": "1869",
+                          "externalIdType": {
+                              "code": "ncua-charter-id",
+                              "name": "NCUA Charter Number"
+                          }
+                      },
+                      "state": "HI",
+                      "fipsStateNumber": "15"
+                  },
+                  "topHolder": {
+                      "city": "",
+                      "name": "",
+                      "state": "",
+                      "country": "",
+                      "idRssd": -1
+                  },
+                  "externalIds": [
+                      {
+                          "value": ${JsString(institutionId)},
+                          "externalIdType": {
+                              "code": "rssd-id",
+                              "name": "RSSD ID"
+                          }
+                      },
+                      {
+                          "value": "0",
+                          "externalIdType": {
+                              "code": "fdic-certificate-number",
+                              "name": "FDIC Certificate Number"
+                          }
+                      },
+                      {
+                          "value": "1869",
+                          "externalIdType": {
+                              "code": "ncua-charter-id",
+                              "name": "NCUA Charter Number"
+                          }
+                      },
+                      {
+                          "value": "0",
+                          "externalIdType": {
+                              "code": "occ-charter-id",
+                              "name": "OCC Charter Number"
+                          }
+                      },
+                      {
+                          "value": "990073423",
+                          "externalIdType": {
+                              "code": "federal-tax-id",
+                              "name": "Federal Tax ID"
+                          }
+                      }
+                  ],
+                  "id": ${JsString(institutionId)},
+                  "emailDomains": [
+                      ""
+                  ],
+                  "institutionType": "credit-union"
+              }
+            """.stripMargin
+        )).asJSON)
+    }
+  }
+
+  val listInstitutions = scenario("List Institutions").exec(InstitutionScenario.list("4277"))
+  val createInstitutions = scenario("Create Institutions").exec(InstitutionScenario.create("4277"))
+
+  setUp(
+    listInstitutions.inject(
+      atOnceUsers(1)
+    ),
+    createInstitutions.inject(atOnceUsers(1))
+      .protocols(httpProtocol)
+  )
+
 }