do not publish an "all" lilb

Author: paullatzelsperger

build.gradle.kts

@@ -49,7 +49,7 @@ allprojects {
 
         }
 
-        publishing{
+        publishing {
             repositories {
                 maven {
                     name = "GitHubPackages"
@@ -78,13 +78,4 @@ allprojects {
 
 val test by tasks.getting(Test::class) {
     useJUnitPlatform()
-}
-
-publishing {
-    publications {
-        create<MavenPublication>("all") {
-            artifactId = "edc.all"
-            from(components["java"])
-        }
-    }
 }

extensions/ids/build.gradle.kts

@@ -14,6 +14,7 @@ dependencies {
     api(project(":extensions:ids:ids-core"))
     api(project(":extensions:ids:ids-api-catalog"))
     api(project(":extensions:ids:ids-api-transfer"))
+    api(project(":extensions:ids:ids-policy-mock"))
 }
 
 publishing {

extensions/ids/ids-api-transfer/src/main/java/com/microsoft/dagx/ids/api/transfer/ArtifactRequestController.java

@@ -70,6 +70,7 @@ public ArtifactRequestController(DapsService dapsService,
     public Response request(ArtifactRequestMessage message) {
         var verificationResult = dapsService.verifyAndConvertToken(message.getSecurityToken().getTokenValue());
         if (!verificationResult.valid()) {
+            monitor.info(() -> "verification failed for request " + message.getId());
             return Response.status(Response.Status.FORBIDDEN).entity(new RejectionMessageBuilder()._rejectionReason_(NOT_AUTHENTICATED).build()).build();
         }
 
@@ -93,6 +94,7 @@ public Response request(ArtifactRequestMessage message) {
         var policyResult = policyService.evaluateRequest(clientConnectorId, correlationId, verificationResult.token(), policy);
 
         if (!policyResult.valid()) {
+            monitor.info("Policy evaluation failed");
             return Response.status(Response.Status.FORBIDDEN).entity(new RejectionMessageBuilder()._rejectionReason_(NOT_AUTHORIZED).build()).build();
         }
 
@@ -101,10 +103,11 @@ public Response request(ArtifactRequestMessage message) {
         @SuppressWarnings("unchecked") var destinationMap = (Map<String, Object>) message.getProperties().get(DESTINATION_KEY);
         var type = (String) destinationMap.get("type");
 
-        @SuppressWarnings("unchecked") var properties = (Map<String, String>) destinationMap.get("properties");
+        @SuppressWarnings("unchecked") Map<String, String> properties = (Map<String, String>) destinationMap.get("properties");
         var secretName = (String) destinationMap.get("keyName");
 
-        var dataDestination = DataAddress.Builder.newInstance().type(type).properties(cast(properties)).keyName(secretName).build();
+        final Map<String, String> cast = cast(properties);
+        var dataDestination = DataAddress.Builder.newInstance().type(type).properties(cast).keyName(secretName).build();
 
         var dataRequest = DataRequest.Builder.newInstance().id(randomUUID().toString()).dataEntry(entry).dataDestination(dataDestination).protocol(IDS_REST).build();
 

extensions/transfer/transfer-core/src/main/java/com/microsoft/dagx/transfer/core/transfer/TransferProcessManagerImpl.java

@@ -173,7 +173,7 @@ private int checkProvisioned() {
         List<TransferProcess> requestAcked = transferProcessStore.nextForState(TransferProcessStates.REQUESTED_ACK.code(), batchSize);
 
         for (var process : requestAcked) {
-            if (!process.getProvisionedResourceSet().empty()) {
+            if (process.getProvisionedResourceSet() != null && !process.getProvisionedResourceSet().empty()) {
 
                 if (process.getDataRequest().getTransferType().isFinite()) {
                     process.transitionInProgress();

spi/src/main/java/com/microsoft/dagx/spi/types/domain/transfer/TransferType.java

@@ -6,8 +6,13 @@
 
 package com.microsoft.dagx.spi.types.domain.transfer;
 
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonPOJOBuilder;
+
 import java.util.Objects;
 
+@JsonDeserialize(builder = TransferType.Builder.class)
 public class TransferType {
     private String contentType;
     private boolean isFinite = true;
@@ -20,14 +25,15 @@ public boolean isFinite() {
         return isFinite;
     }
 
-
+    @JsonPOJOBuilder(withPrefix = "")
     public static final class Builder {
         private String contentType = "application/octet-stream";
         private boolean isFinite = true;
 
         private Builder() {
         }
 
+        @JsonCreator
         public static Builder transferType() {
             return new Builder();
         }