Fixed "unknown UC contract" issue for provider push scenario

Fraunhofer-AISEC · Mar 2, 2022 · 07f8f32 · 07f8f32
1 parent eed269e
commit 07f8f32
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...s/src/main/kotlin/de/fhg/aisec/ids/camel/processors/ContractAgreementReceiverProcessor.kt b/...s/src/main/kotlin/de/fhg/aisec/ids/camel/processors/ContractAgreementReceiverProcessor.kt
@@ -50,6 +50,7 @@ class ContractAgreementReceiverProcessor : Processor {
 
         ProviderDB.contractAgreements[contractAgreement.id] = contractAgreement
         for (permission in contractAgreement.permission) {
+            // Entry for the case when provider is setting up multiple agreements with different requesting connectors
             ProviderDB.artifactUrisMapped2ContractAgreements[
                 Pair(
                     permission.target,
@@ -60,6 +61,8 @@ class ContractAgreementReceiverProcessor : Processor {
                         )
                 )
             ] = contractAgreement.id
+            // Additional entry for the case when an artifact is pushed directly to the consumer
+            ProviderDB.artifactUrisMapped2ContractAgreements[Pair(permission.target, null)] = contractAgreement.id
         }
 
         if (LOG.isDebugEnabled) {

diff --git a/camel-processors/src/main/kotlin/de/fhg/aisec/ids/camel/processors/ProviderDB.kt b/camel-processors/src/main/kotlin/de/fhg/aisec/ids/camel/processors/ProviderDB.kt
@@ -27,7 +27,7 @@ import java.util.concurrent.ConcurrentHashMap
 object ProviderDB {
     val availableArtifactURIs: ConcurrentHashMap<URI, String> = ConcurrentHashMap()
     val artifactUrisMapped2ContractAgreements:
-        ConcurrentHashMap<Pair<URI, AppLayerConnection>, URI> = ConcurrentHashMap()
+        ConcurrentHashMap<Pair<URI, AppLayerConnection?>, URI> = ConcurrentHashMap()
     val contractAgreements: ConcurrentHashMap<URI, ContractAgreement> = ConcurrentHashMap()
 
     init {