Migrate DMNs to API-first calls via event handlers

build.gradle

@@ -109,6 +109,19 @@ configurations {
   cftlibTestRuntime.extendsFrom testRuntime
 }
 
+configurations.configureEach {
+  resolutionStrategy.eachDependency { details ->
+    if (details.requested.group == 'com.github.hmcts') {
+      if (details.requested.name == 'decentralised-runtime'
+          || details.requested.name == 'task-management'
+          || details.requested.name == 'ccd-config-generator') {
+        details.useVersion 'task-mgmt-40.1-46b69557'
+        details.because 'Ensure task-management, decentralised-runtime and ccd-config-generator stay aligned'
+      }
+    }
+  }
+}
+
 tasks.withType(JavaCompile) {
   options.compilerArgs << "-Xlint:unchecked" << "-Werror"
 }
@@ -245,7 +258,8 @@ def sonarExclusions = [
   '**/uk/gov/hmcts/sptribs/ciccase/model/UserRolesForAccessProfiles.java',
   '**/uk/gov/hmcts/sptribs/common/config/**',
   '**/uk/gov/hmcts/sptribs/common/event/UpdateCaseDataEvent.java',
-  '**/uk/gov/hmcts/sptribs/common/service/CaseDataFieldService.java'
+  '**/uk/gov/hmcts/sptribs/common/service/CaseDataFieldService.java',
+  '**/uk/gov/hmcts/sptribs/taskmanagement/model/**'
 ]
 
 sonarqube {
@@ -330,6 +344,10 @@ def versions = [
 dependencies {
 // uncomment for local version
 // implementation group: 'com.github.hmcts', name: 'ccd-config-generator', version: 'DEV-SNAPSHOT'
+//  implementation 'com.github.hmcts:task-management:DEV-SNAPSHOT'
+  implementation 'com.github.hmcts:task-management:task-mgmt-40.1-46b69557'
+  implementation 'com.github.hmcts:decentralised-runtime:task-mgmt-40.1-46b69557'
+  implementation 'com.github.hmcts:ccd-config-generator:task-mgmt-40.1-46b69557'
 
   implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: versions.jackson
   implementation group: 'com.fasterxml.jackson.core', name: 'jackson-core', version: versions.jackson
@@ -430,6 +448,10 @@ dependencies {
 
   // Provides fast-reload of just the sptribs service.
   cftlibImplementation 'org.springframework.boot:spring-boot-devtools'
+  cftlibTestImplementation sourceSets.test.runtimeClasspath
+  cftlibTestImplementation 'com.github.hmcts:task-management:task-mgmt-40.1-46b69557'
+  cftlibTestImplementation 'com.github.hmcts:decentralised-runtime:task-mgmt-40.1-46b69557'
+  cftlibTestImplementation 'com.github.hmcts:ccd-config-generator:task-mgmt-40.1-46b69557'
   cftlibTestImplementation 'com.microsoft.playwright:playwright:1.58.0'
   cftlibTestImplementation 'org.junit-pioneer:junit-pioneer:2.3.0'
   cftlibTestImplementation 'io.github.artsok:rerunner-jupiter:2.1.6'
@@ -525,10 +547,66 @@ ccd {
   configDir = file('build/definitions')
 }
 
+def localRseCftLibDir = file('../rse-cft-lib')
+def localWaTaskManagementApiDir = file("${localRseCftLibDir}/projects/wa-task-management-api")
+def localCftLibPublishingInit = file("${localRseCftLibDir}/cftlib/buildSrc/configurePublishing.gradle")
+def localWaPublishingFixInit = file("$rootDir/gradle/wa-publish-fix.init.gradle")
+def localWaM2Jar = file("${System.properties['user.home']}/.m2/repository/com/github/hmcts/rse-cft-lib/wa-task-management-api/0.19.2017/wa-task-management-api-0.19.2017.jar")
+def useLocalWaTaskManagementApi = (project.findProperty('useLocalWaTaskManagementApi') ?: 'false').toString().toBoolean()
+
+tasks.register('publishLocalWaTaskManagementApiToMavenLocal', Exec) {
+  group = 'ccd tasks'
+  description = 'Publishes local WA task-management-api for cftlib (if ../rse-cft-lib is present)'
+  onlyIf {
+    useLocalWaTaskManagementApi
+        && localWaTaskManagementApiDir.exists()
+        && localCftLibPublishingInit.exists()
+        && localWaPublishingFixInit.exists()
+  }
+  workingDir localWaTaskManagementApiDir
+  commandLine './gradlew', '--no-daemon',
+      '-I', localCftLibPublishingInit.absolutePath,
+      '-I', localWaPublishingFixInit.absolutePath,
+      'publishToMavenLocal'
+  environment 'RELEASE_VERSION', '0.19.2017'
+}
+
 tasks.withType(CftlibExec).configureEach {
+  dependsOn tasks.named('publishLocalWaTaskManagementApiToMavenLocal')
   environment 'RSE_LIB_ADDITIONAL_DATABASES', 'sptribs'
   environment 'CCD_DECENTRALISED_CASE-TYPE-SERVICE-URLS_CriminalInjuriesCompensation', 'http://localhost:4013'
   environment 'SPRING_JMS_SERVICEBUS_ENABLED', 'false'
+  // The IDAM simulator authorizes /api/v1/users requests only when the token subject exists in simulator memory.
+  // Default data-store system user is not present there, which causes 401s in cftlib parity tests.
+  // Keep explicit env override support for local/custom setups.
+  environment 'IDAM_DATA_STORE_SYSTEM_USER_USERNAME',
+      System.getenv('IDAM_DATA_STORE_SYSTEM_USER_USERNAME') ?: 'TEST_CASE_WORKER_USER@mailinator.com'
+  environment 'TASK_MANAGEMENT_EXCLUSIVE_CLIENTS',
+      'wa_task_management_api,wa_task_monitor,wa_case_event_handler,wa_workflow_api,nfdiv_case_api,sptribs_case_api'
+  environment 'TASK_MANAGEMENT_PRIVILEGED_CLIENTS',
+      'wa_task_management_api,xui_webapp,ccd_case_disposer,sptribs_case_api'
+  doFirst {
+    def waManifest = file("$buildDir/cftlib/wa-task-management-api")
+    if (useLocalWaTaskManagementApi && waManifest.exists() && localWaM2Jar.exists()) {
+      def lines = waManifest.readLines()
+      if (lines.size() > 1) {
+        lines[1] = localWaM2Jar.absolutePath
+        waManifest.text = lines.join(System.lineSeparator()) + System.lineSeparator()
+      }
+    }
+
+    def selectClass = project.findProperty('cftlibSelectClass')
+    if (name == 'cftlibTest' && selectClass) {
+      def libTestManifest = file("$buildDir/cftlib/libTest")
+      if (libTestManifest.exists()) {
+        def lines = libTestManifest.readLines()
+        if (!lines.isEmpty()) {
+          lines[0] = "org.junit.platform.console.ConsoleLauncher --select-class=${selectClass}"
+          libTestManifest.text = lines.join(System.lineSeparator()) + System.lineSeparator()
+        }
+      }
+    }
+  }
 }
 
 bootWithCCD {
@@ -573,15 +651,13 @@ cftlibTest {
   environment 'CASE_DOCUMENT_AM_API_ATTACH_DOCUMENT_ENABLED', 'false'
   environment 'CASE_DATA_STORE_BASEURL', 'http://localhost:4452'
   environment 'ROLE_ASSIGNMENT_URL', 'http://localhost:4096'
+  environment 'TASK_MANAGEMENT_API_URL', 'http://localhost:8087'
+  environment 'TASK_MONITOR_API_URL', 'http://localhost:8087'
+  environment 'WA_S2S_AUTHORIZED_SERVICES', 'ccd,ccd_data,ccd_gw,ccd_ps,iac,wa_task_management_api,xui_webapp,wa_task_monitor,camunda_bpm,wa_workflow_api,wa_case_event_handler,ccd_case_disposer,civil_service,sscs,sptribs_case_api'
   environment 'CCD_S2S_AUTHORISED_SERVICES_CASE_USER_ROLES', 'sptribs_case_api'
   environment 'DATA_STORE_S2S_AUTHORISED_SERVICES', 'ccd_gw,fpl_case_service,ccd_data,ccd_ps,sptribs_frontend,xui_webapp,sptribs_case_api,ccd_case_document_am_api,am_role_assignment_service'
 }
 
-// exclude the logback binding is coming in via cftlib
-configurations.cftlibTestImplementation {
-  exclude group: 'ch.qos.logback', module: 'logback-classic'
-}
-
 tasks.register('installChromium', JavaExec) {
   // group = "Execution"
   // description = "Run the main class with JavaExecTask"
@@ -592,11 +668,6 @@ tasks.register('installChromium', JavaExec) {
 
 tasks.cftlibTest.dependsOn(installChromium)
 
-// exclude the logback binding is coming in via cftlib
-configurations.testImplementation {
-  exclude group: 'ch.qos.logback', module: 'logback-classic'
-}
-
 tasks.named("processContractTestResources") {
   duplicatesStrategy = 'include'
 }

charts/sptribs-case-api/values.preview.template.yaml

@@ -11,6 +11,9 @@ java:
   devmemoryLimits: 2Gi
   environment:
     PDF_API_URL: "http://rpe-pdf-service-aat.service.core-compute-aat.internal"
+    TASK_MONITOR_API_URL: ${TASK_MONITOR_API_URL}
+    TASK_MANAGEMENT_API_URL: ${TASK_MANAGEMENT_API_URL}
+    ROLE_ASSIGNMENT_API_URL: ${ROLE_ASSIGNMENT_API_URL}
     CASE_DATA_STORE_BASEURL: http://{{ .Release.Name }}-ccd-data-store-api
     CASE_DOCUMENT_AM_BASEURL: http://${SERVICE_NAME}-ccd-case-document-am-api
     BUNDLING_API_URL: https://em-ccdorc-${SERVICE_FQDN}

charts/sptribs-case-api/values.wa.preview.template.yaml

@@ -8,7 +8,10 @@ java:
       key: connectionString
   environment:
     SPRING_JMS_SERVICEBUS_ENABLED: true
-    SPTRIBS_SERVICEBUS_SCHEDULER_ENABLED: true
+    SPTRIBS_SERVICEBUS_SCHEDULER_ENABLED: false
+    TASK_MONITOR_API_URL: ${TASK_MONITOR_API_URL}
+    TASK_MANAGEMENT_API_URL: ${TASK_MANAGEMENT_API_URL}
+    ROLE_ASSIGNMENT_API_URL: ${ROLE_ASSIGNMENT_API_URL}
     AZURE_SERVICE_BUS_TOPIC_NAME: ${SERVICE_NAME}-asb-ccd-case-events
     AZURE_SERVICE_BUS_SUBSCRIPTION_NAME: ${SERVICE_NAME}-asb-ccd-case-events
 
@@ -72,9 +75,13 @@ wa:
   wa-task-management-api:
     java:
       ingressHost: wa-task-management-api-${SERVICE_FQDN}
+      image: 'hmctspublic.azurecr.io/wa/task-management-api:pr-1598'
       environment:
         ALLOWED_CASE_TYPES: wacasetype,criminalinjuriescompensation
         ALLOWED_JURISDICTIONS: wa,st_cic
+        WA_S2S_AUTHORIZED_SERVICES: ccd,ccd_data,ccd_gw,ccd_ps,iac,wa_task_management_api,xui_webapp,wa_task_monitor,camunda_bpm,wa_workflow_api,wa_case_event_handler,ccd_case_disposer,civil_service,sscs,sptribs_case_api
+        TASK_MANAGEMENT_EXCLUSIVE_CLIENTS: wa_task_management_api,wa_task_monitor,wa_case_event_handler,wa_workflow_api,nfdiv_case_api,sptribs_case_api
+        TASK_MANAGEMENT_PRIVILEGED_CLIENTS: wa_task_management_api,xui_webapp,ccd_case_disposer,sptribs_case_api
 
   wa-task-monitor:
     java:

gradle/wa-publish-fix.init.gradle

@@ -0,0 +1,9 @@
+allprojects {
+  afterEvaluate { p ->
+    if (p.tasks.findByName('sourcesJar') && p.tasks.findByName('openApiGenerate')) {
+      p.tasks.named('sourcesJar') {
+        dependsOn p.tasks.named('openApiGenerate')
+      }
+    }
+  }
+}

settings.gradle

@@ -20,4 +20,3 @@ rootProject.name = 'sptribs-case-api'
 if (file(configGenerator).exists()) {
   includeBuild configGenerator
 }*/
-

src/cftlib/java/uk/gov/hmcts/sptribs/cftlib/CftLibConfig.java

@@ -30,11 +30,23 @@ public class CftLibConfig implements CFTLibConfigurer {
     @Override
     public void configure(CFTLib lib) throws Exception {
 
-        List<String> roleList = List.of("caseworker",
+        List<String> roleList = List.of(
+            "caseworker",
             "caseworker-st_cic",
             "caseworker-st_cic-caseworker",
+            "caseworker-st_cic-senior-caseworker",
+            "caseworker-st_cic-hearing-centre-admin",
+            "caseworker-st_cic-hearing-centre-team-leader",
+            "caseworker-st_cic-senior-judge",
+            "caseworker-st_cic-judge",
+            "caseworker-st_cic-respondent",
+            "caseworker-wa-task-configuration",
+            "caseworker-sptribs-systemupdate",
+            "caseworker-sptribs-superuser",
+            "citizen",
             "pui-case-manager",
-            "jrd-admin");
+            "jrd-admin"
+        );
 
         Map<String, List<String>> users = Map.of(
             "TEST_CASE_WORKER_USER@mailinator.com", roleList,