RDM-4217 - Create Case Data with document attachment in perftest env

.gitignore

@@ -5,3 +5,5 @@ results/
 src.zip
 .DS_Store
 /gatling.log
+*.zip
+.gradle/

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,5 @@
-#Thu Apr 11 15:34:33 BST 2019
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.3-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.2-all.zip

src/test/resources/application.conf

@@ -7,7 +7,7 @@ importSpreadsheet = "src/test/scala/uk/gov/hmcts/ccd/casedefinition/scenarios/fi
 
 //dev default
 userCcdId = "[email protected]"
-userCcdPassword = "password"
+userCcdPassword = "Monday123"
 userImportId = "[email protected]"
 userImportPassword = "password"
 userProfileUrl = "https://case-user-profile-app.dev.ccd.reform.hmcts.net:4451"
@@ -58,7 +58,7 @@ localhost {
     "1547820791714750", "1547036690988904", "1545234546871901", "1548253985508219", "1547200037389206"]
   //getCaseUrl = "caseworkers/"${userCcdId}"/jurisdictions/PROBATE/case-types/GrantOfRepresentation/cases/:case_reference"
   getCaseUrl = "internal/cases/:case_reference"
-//  getPaginationMetadataUrl = "caseworkers/"${userCcdId}"/jurisdictions/PROBATE/case-types/GrantOfRepresentation/cases/pagination_metadata?state=CaseCreated"
+  //  getPaginationMetadataUrl = "caseworkers/"${userCcdId}"/jurisdictions/PROBATE/case-types/GrantOfRepresentation/cases/pagination_metadata?state=CaseCreated"
   getPaginationMetadataUrl = "caseworkers/"${userCcdId}"/jurisdictions/PROBATE/case-types/GrantOfRepresentation/cases/pagination_metadata?state=CaseCreated&case.PersonLastName=unknown"
   createCaseUrl = "caseworkers/"${userCcdId}"/jurisdictions/SSCS/case-types/Benefit/cases"
   getUserProfileUrl = "caseworkers/538/profile"
@@ -245,19 +245,37 @@ cnp_perftest {
   oAuth2clientSecret = "${IDAM_OAUTH2_CLIENT_SECRET}"
 
   cases = ["1559642192860544"]
-  getCaseUrl = "internal/cases/:case_reference"
+  ccdCaseMgmtUrl = "https://ccd-case-management-web-perftest.service.core-compute-perftest.internal"
+  getCaseUrl = "aggregated/caseworkers/a2fe2e87-94f7-44a9-a272-5c413a4775c0/jurisdictions/AUTOTEST1/case-types/AAT/cases/1531212825013102"
+  getCaseUrlV2 = "internal/cases/1559642192860544"
   createCaseUrl = "caseworkers/a2fe2e87-94f7-44a9-a272-5c413a4775c0/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
   validateCaseUrl = "caseworkers/176475/jurisdictions/AUTOTEST1/case-types/AAT/cases"
-  getUserProfileUrl = "caseworkers/176475/profile"
+  getUserProfileUrl = "caseworkers/a2fe2e87-94f7-44a9-a272-5c413a4775c0/profile"
+  getUserProfileUrlV2 = "caseworkers/539560/profile"
   searchCases = "aggregated/caseworkers/176475/jurisdictions/AUTOTEST1/case-types/AAT/cases?state=CaseCreated"
   getPaginationMetadataUrl = "caseworkers/176475/jurisdictions/AUTOTEST1/case-types/AAT/cases/pagination_metadata?state=CaseCreated"
   saveEventUrl = "caseworkers/176475/jurisdictions/AUTOTEST1/case-types/CASETYPE2/cases/1531207599597587/events"
   searchInputDetails = "aggregated/caseworkers/176475/jurisdictions/AUTOTEST1/case-types/AAT/inputs"
   workbasketInputDetails = "/aggregated/caseworkers/176475/jurisdictions/AUTOTEST1/case-types/AAT/work-basket-inputs"
   getPrintableDocumentsForEvent = "caseworkers/176475/jurisdictions/AUTOTEST1/case-types/CASETYPE2/cases/1531207599597587/documents"
   validateCaseDetails = "caseworkers/176475/jurisdictions/AUTOTEST1/case-types/AAT/validate"
-  docStoreBashURL = "https://dm-store-perftest.service.core-compute-perftest.internal"
   ESSearch = "searchCases"
+  docStoreBashURL123 = "https://dm-store-perftest.service.core-compute-perftest.internal"
+  docStoreBashURL = "https://gateway-ccd.perftest.platform.hmcts.net"
+  prodSSCSWorkBasket = "aggregated/caseworkers/560966/jurisdictions/SSCS/case-types/Benefit/cases?view=WORKBASKET&page=1&case.caseReference=test1234567"
+  prodSSCSPagination = "caseworkers/560966/jurisdictions/SSCS/case-types/Benefit/cases/pagination_metadata?case.caseReference=test123456"
+  prodDIVORCED8caseReference = "aggregated/caseworkers/560966/jurisdictions/DIVORCE/case-types/DIVORCE/cases?page=1&case.D8caseReference=EZ12D81234"
+  prodDIVORCED8caseReferencePagination = "caseworkers/560966/jurisdictions/DIVORCE/case-types/DIVORCE/cases/pagination_metadata?case.D8caseReference=EZ12D81234"
+  createCaseDIVUrl = "caseworkers/81d4aa29-7ba2-4884-a5a4-e2a0211bfe7c/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createCaseSSCSUrl = "caseworkers/81d4aa29-7ba2-4884-a5a4-e2a0211bfe7c/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createCaseCMCUrl = "caseworkers/81d4aa29-7ba2-4884-a5a4-e2a0211bfe7c/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createCaseProbateGrantApplicationUrl = "caseworkers/81d4aa29-7ba2-4884-a5a4-e2a0211bfe7c/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createCaseProbateCaveatApplicationUrl = "caseworkers/81d4aa29-7ba2-4884-a5a4-e2a0211bfe7c/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createIACaseAppURL = "caseworkers/81d4aa29-7ba2-4884-a5a4-e2a0211bfe7c/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createFPLCaseAppURL = "caseworkers/77a5a58b-4d17-43b1-8df4-5cccd6cb1472/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createFRCaseAppURL = "caseworkers/44d5d0eb-0739-49e6-8c5e-bd556ef633d2/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  createETHOSCaseAppURL = "caseworkers/b1d866d5-2e78-454a-b18a-95020d0bb603/jurisdictions/:jurisdictions_reference/case-types/:casetype_reference/cases"
+  saveEventETHOSUploadDocsUrl = "caseworkers/30b48b61-7abf-4747-9270-8e86f466c0d6/jurisdictions/PUBLICLAW/case-types/TRIB_MVP_3_TYPE_Manc/cases/1559571632599539/events"
 }
 
 cnp_saat {

src/test/resources/listoffiles.csv

@@ -0,0 +1,2 @@
+filename
+1MB.pdf

src/test/resources/logback-test.xml

@@ -16,12 +16,9 @@
 		</encoder>
 	</appender>
 
-	<!-- Uncomment for logging ALL HTTP request and responses -->
-	  	<logger name="io.gatling.http.ahc" level="TRACE" />
-		<logger name="io.gatling.http.response" level="TRACE" />
-	<!-- Uncomment for logging ONLY FAILED HTTP request and responses -->
-	<!--<logger name="io.gatling.http.ahc" level="DEBUG" />-->
-    <!--<logger name="io.gatling.http.response" level="DEBUG" />-->
+	<!-- uncomment and set to DEBUG to log all failing HTTP requests -->
+	<!-- uncomment and set to TRACE to log all HTTP requests -->
+	<logger name="io.gatling.http.engine.response" level="TRACE" />
 
 
    <root level="WARN">

src/test/scala/uk/gov/hmcts/ccd/corecasedata/scenarios/GetCaseDataV2.scala

@@ -0,0 +1,51 @@
+package uk.gov.hmcts.ccd.corecasedata.scenarios
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import uk.gov.hmcts.ccd.util.{CcdTokenGenerator, PerformanceTestsConfig}
+import scala.concurrent.duration._
+
+object GetCaseDataV2 extends PerformanceTestsConfig {
+
+  private val getCaseUrl = caseDataUrl(config.getString("getCaseUrlV2"))
+  println("Retrieving case with base url: " + getCaseUrl)
+
+  def getCaseDataHttp() = {
+    val s2sToken = CcdTokenGenerator.generateGatewayS2SToken()
+    val userToken = CcdTokenGenerator.generateWebUserToken()
+    //val userToken = CcdTokenGenerator.generateWebUserToken(getCaseUrl)
+    //http("get case data")
+    http("TX01_CCD_GetCaseDataEndpoint_getcasedataV2")
+      .get(_ => url())
+      .header("ServiceAuthorization", s2sToken)
+      .header("Authorization", userToken)
+      .header("Content-Type","application/json")
+      .header("Accept","application/vnd.uk.gov.hmcts.ccd-data-store-api.ui-case-view.v2+json")
+      .header("Experimental","true")
+      .check(status in  (200))
+  }
+
+  def url(): String = {
+    val result: String = if(!getCaseUrl.contains(":case_reference")) {
+      getCaseUrl
+    } else {
+      resolveGetCaseUrl()
+    }
+//    println("Retrieving case: " + result)
+    result
+  }
+
+  private def resolveGetCaseUrl(): String = {
+    getCaseUrl.replace(":case_reference", pickRandomReference().replaceAll("-", ""))
+  }
+
+  println("GetCaseData: Minimum think time " + MinThinkTime + " Maximum think time " + MaxThinkTime)
+  val GetCaseDataV2Scenarios = scenario("Get Case Data V2").during(TotalRunDuration minutes) {
+      exec(
+        getCaseDataHttp()
+      )
+      .pause(MinThinkTime seconds, MaxThinkTime seconds)
+  }
+
+  val waitForNextIteration = pace(MinWaitForNextIteration seconds, MaxWaitForNextIteration seconds)
+}

src/test/scala/uk/gov/hmcts/ccd/corecasedata/scenarios/GetPrintableDocumentsForEvent.scala

@@ -0,0 +1,31 @@
+package uk.gov.hmcts.ccd.corecasedata.scenarios
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import uk.gov.hmcts.ccd.util.{CcdTokenGenerator, PerformanceTestsConfig}
+
+import scala.concurrent.duration._
+
+object GetPrintableDocumentsForEvent extends PerformanceTestsConfig {
+
+  private val url: String = config.getString("caseDataUrl") + "/" + config.getString("getPrintableDocumentsForEvent")
+  println("Retrieving getPrintableDocumentsForEvent URL : " + url)
+
+  def httpRequest() = {
+    val s2sToken = CcdTokenGenerator.generateGatewayS2SToken()
+    val userToken = CcdTokenGenerator.generateWebUserToken()
+    http("TX09_CCD_GetPrintableDocumentsForEvent_getDocumentsForEvent")
+      .get(url)
+      .header("ServiceAuthorization", s2sToken)
+      .header("Authorization", userToken)
+      .header("Content-Type","application/json")
+      .check(status in  (200))
+  }
+
+  println("WorkBasketInputDetails: Minimum think time " + MinThinkTime + " Maximum think time " + MaxThinkTime)
+
+  val getPrintableDocumentForEvents = scenario("Get Printable Document for Events").during(TotalRunDuration minutes) {
+    exec(httpRequest())
+      .pause(MinThinkTime seconds, MaxThinkTime seconds)
+  }
+}

src/test/scala/uk/gov/hmcts/ccd/corecasedata/scenarios/GetUserProfile.scala

@@ -20,6 +20,7 @@ object GetUserProfile extends PerformanceTestsConfig {
       .header("ServiceAuthorization", s2sToken)
       .header("Authorization", userToken)
       .header("Content-Type","application/json")
+      .header("Accept"," application/vnd.uk.gov.hmcts.ccd-data-store-api.ui-case-view.v2+json")
       .check(status in  (200))
   }
 

src/test/scala/uk/gov/hmcts/ccd/corecasedata/scenarios/SearchInputDetails.scala

@@ -0,0 +1,33 @@
+package uk.gov.hmcts.ccd.corecasedata.scenarios
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import uk.gov.hmcts.ccd.util.{CcdTokenGenerator, PerformanceTestsConfig}
+
+import scala.concurrent.duration._
+
+object SearchInputDetails extends PerformanceTestsConfig {
+
+  private val url: String = config.getString("caseDataUrl") + "/" + config.getString("searchInputDetails")
+  println("Retrieving searchInputDetails URL : " + url)
+
+  def httpRequest() = {
+    val s2sToken = CcdTokenGenerator.generateGatewayS2SToken()
+    val userToken = CcdTokenGenerator.generateWebUserToken()
+    http("TX07_CCD_SearchInputDetails_searchInputDetails")
+      .get(url)
+      .header("ServiceAuthorization", s2sToken)
+      .header("Authorization", userToken)
+      .header("Content-Type","application/json")
+      .check(status in  (200))
+  }
+
+  println("SearchInputDetails: Minimum think time " + MinThinkTime + " Maximum think time " + MaxThinkTime)
+
+  val getSearchInputDetails = scenario("Search Input Details").during(TotalRunDuration minutes) {
+    exec(
+      httpRequest()
+    )
+      .pause(MinThinkTime seconds, MaxThinkTime seconds)
+  }
+}

src/test/scala/uk/gov/hmcts/ccd/corecasedata/scenarios/ValidateCaseDetails.scala

@@ -0,0 +1,77 @@
+package uk.gov.hmcts.ccd.corecasedata.scenarios
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import uk.gov.hmcts.ccd.util.{CcdTokenGenerator, PerformanceTestsConfig}
+
+import scala.concurrent.duration._
+
+object ValidateCaseDetails extends PerformanceTestsConfig {
+
+ // val EventId = "applyForGrant"
+  val EventId = "CREATE"
+  val CreateCaseUrl = caseDataUrl(config.getString("validateCaseUrl"))
+  val CreateCaseTokenUrl = s"${CreateCaseUrl.replaceAll("cases", "")}event-triggers/$EventId/token"
+  println("create case url: " + CreateCaseUrl)
+  println("create case token url: " + CreateCaseTokenUrl)
+
+  private val url: String = config.getString("caseDataUrl") + "/" + config.getString("validateCaseDetails")
+  println("Retrieving validateCaseDetails URL : " + url)
+
+  val ReqPayload = StringBody("""
+                               {
+                                "data": {
+                                    "TextField": "First Page",
+                                    "NumberField": "123",
+                                    "YesOrNoField": "Yes",
+                                    "PhoneUKField": "02920001002",
+                                    "EmailField": "[email protected]"
+                                    },
+                                "event": {
+                                    "id": "CREATE",
+                                    "summary": "",
+                                    "description": ""
+                                    },
+                                "event_token": "${eventToken}",
+                                "ignore_warning": false
+                                }
+                              """)
+
+
+  def validateCaseDatahttp() = {
+    val token = CcdTokenGenerator.generateGatewayS2SToken()
+    val userToken = CcdTokenGenerator.generateWebUserToken()
+    exec(
+         //http("get create case event token")
+           http("TX10_CCD_ValidateCaseDataEndpoint_validatecasedata_eventtoken")
+           .get(CreateCaseTokenUrl)
+           .header("ServiceAuthorization", token)
+           .header("Authorization", userToken)
+           .header("Content-Type","application/json")
+           .check(status.is(200),jsonPath("$.token").saveAs("eventToken"))
+      ).exec(
+        //http("create case data")
+        http("TX11_CCD_CCD_ValidateCaseDataEndpoint_validatecasedata")
+        .post(url)
+        .body(
+          ReqPayload).asJson
+        .header("ServiceAuthorization", token)
+        .header("Authorization", userToken)
+        .header("Content-Type","application/json")
+        .check(status is 200)
+    )
+  }
+
+
+  println("ValidateCaseData: Minimum think time " + MinThinkTime + " Maximum think time " + MaxThinkTime)
+
+  val   validateCaseData = scenario("Validate Case Data").during(TotalRunDuration minutes) {
+      exec(
+        validateCaseDatahttp()
+      )
+      .pause(MinThinkTime seconds, MaxThinkTime seconds)
+  }
+
+  val waitForNextIteration = pace(MinWaitForNextIteration seconds, MaxWaitForNextIteration seconds)
+}
+

src/test/scala/uk/gov/hmcts/ccd/corecasedata/scenarios/WorkBasketInputDetails.scala

@@ -0,0 +1,33 @@
+package uk.gov.hmcts.ccd.corecasedata.scenarios
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import uk.gov.hmcts.ccd.util.{CcdTokenGenerator, PerformanceTestsConfig}
+
+import scala.concurrent.duration._
+
+object WorkBasketInputDetails extends PerformanceTestsConfig {
+
+  private val url: String = config.getString("caseDataUrl") + "/" + config.getString("workbasketInputDetails")
+  println("Retrieving workbasketInputDetails URL : " + url)
+
+  def httpRequest() = {
+    val s2sToken = CcdTokenGenerator.generateGatewayS2SToken()
+    val userToken = CcdTokenGenerator.generateWebUserToken()
+    http("TX08_CCD_WorkBasketInputDetails_workbasketInputDetails")
+      .get(url)
+      .header("ServiceAuthorization", s2sToken)
+      .header("Authorization", userToken)
+      .header("Content-Type","application/json")
+      .check(status in  (200))
+  }
+
+  println("WorkBasketInputDetails: Minimum think time " + MinThinkTime + " Maximum think time " + MaxThinkTime)
+
+  val getWorkbasketInputDetails = scenario("Work Basket Input Details").during(TotalRunDuration minutes) {
+    exec(
+      httpRequest()
+    )
+      .pause(MinThinkTime seconds, MaxThinkTime seconds)
+  }
+}