Added concurrency test for #3174

Author: chrisala

src/integration-test/groovy/au/org/ala/fieldcapture/ParatooIntegrationSpec.groovy

@@ -8,6 +8,10 @@ import org.apache.http.HttpStatus
 import spock.lang.Stepwise
 import pages.RlpProjectPage
 
+import java.util.concurrent.Callable
+import java.util.concurrent.ExecutorService
+import java.util.concurrent.Executors
+
 @Stepwise
 // We need GrailsUnitTest because the WebService class has a dependency on grailsApplication.config
 // It slows startup down quite a bit though
@@ -27,6 +31,36 @@ class ParatooIntegrationSpec extends StubbedCasSpec implements GrailsUnitTest {
         webService = new WebService(grailsApplication: getGrailsApplication())
     }
 
+    private Map buildMintCollectionIdPayload() {
+         [
+                "survey_metadata": [
+                        "survey_details": [
+                                "survey_model": "soil-pit-characterisation-full",
+                                "time": "2023-08-28T00:34:13.100Z",
+                                "uuid": "123-123-123-123-123",
+                                "project_id": "monitorProject",
+                                "protocol_id": "guid-1",
+                                "protocol_version": "1"
+                        ],
+                        "provenance":[
+                                "version_app": "0.0.1-xxxxx",
+                                "version_core": "0.1.0-1fb53f81",
+                                "version_core_documentation": "0.0.1-xxxxx",
+                                "version_org": "4.4-SNAPSHOT",
+                                "system_app": "monitor",
+                                "system_core": "Monitor-dummy-data-production",
+                                "system_org": "MERIT"
+                        ]
+                ]
+        ]
+    }
+
+    private Map mintCollectionId(Map payload, String token) {
+        String url = testConfig.ecodata.baseUrl + 'paratoo/mintCollectionId'
+        Map headers = ["Authorization": "Bearer ${token}"]
+        Map resp = webService.post(url, payload, null, ContentType.APPLICATION_JSON, false, false, headers)
+        resp
+    }
 
     def "Add new data set in to project"() {
 
@@ -54,28 +88,7 @@ class ParatooIntegrationSpec extends StubbedCasSpec implements GrailsUnitTest {
                 ]
 
         ]
-        Map mintCollectionIdPayload = [
-                "survey_metadata": [
-                    "survey_details": [
-                        "survey_model": "soil-pit-characterisation-full",
-                        "time": "2023-08-28T00:34:13.100Z",
-                        "uuid": "123-123-123-123-123",
-                        "project_id": "monitorProject",
-                        "protocol_id": "guid-1",
-                        "protocol_version": "1"
-                    ],
-                    "provenance":[
-                        "version_app": "0.0.1-xxxxx",
-                        "version_core": "0.1.0-1fb53f81",
-                        "version_core_documentation": "0.0.1-xxxxx",
-                        "version_org": "4.4-SNAPSHOT",
-                        "system_app": "monitor",
-                        "system_core": "Monitor-dummy-data-production",
-                        "system_org": "MERIT"
-                    ]
-                ]
-            ]
-                        
+        Map mintCollectionIdPayload = buildMintCollectionIdPayload()
 
         Map collectionPayload = [
                 "coreProvenance": [
@@ -93,9 +106,7 @@ class ParatooIntegrationSpec extends StubbedCasSpec implements GrailsUnitTest {
         resp.statusCode == HttpStatus.SC_OK
 
         when:
-        url = testConfig.ecodata.baseUrl + 'paratoo/mintCollectionId'
-        headers = ["Authorization": "Bearer ${token}"]
-        resp = webService.post(url, mintCollectionIdPayload, null, ContentType.APPLICATION_JSON, false, false, headers)
+        resp = mintCollectionId(mintCollectionIdPayload, token)
 
         String orgMintedIdentifier = resp.resp.orgMintedIdentifier
         byte[] jsonBytes = orgMintedIdentifier.decodeBase64()
@@ -139,4 +150,41 @@ class ParatooIntegrationSpec extends StubbedCasSpec implements GrailsUnitTest {
         then: "The data set is displayed"
         datasetDetails.dataSetSummaryCount() == 1
     }
+
+    def "Paratoo data sets can be submitted concurrently without data errors"() {
+        setup:
+        ExecutorService executor = Executors.newFixedThreadPool(20)
+        String token = tokenForUser('1')
+        String projectId = 'monitorProject'
+
+        when:
+        List callables = []
+        for (int i = 0; i < 100; i++) {
+            Callable callable = new Callable() {
+                @Override
+                Object call() throws Exception {
+                    Map payload = buildMintCollectionIdPayload()
+                    payload.survey_metadata.protocol_id = "guid-${i}"
+                    Map result = mintCollectionId(payload, token)
+
+                    return result
+                }
+            }
+            callables.add(callable)
+        }
+        executor.invokeAll(callables)
+
+        String url = testConfig.ecodata.baseUrl + 'project/'+projectId
+        Map resp = webService.get(url)
+
+
+        then:
+        resp.resp?.custom?.dataSets?.size() == 101
+        for (int i = 0; i < 100; i++) {
+            resp.resp.custom.dataSets.find { it.surveyId.survey_metadata.protocol_id == 'guid-' + i } != null
+        }
+
+    }
+
+
 }