This is an automated email from the ASF dual-hosted git repository.

pvillard31 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new f026154de3f NIFI-16437 - Connector configuration API rejects unset 
asset references returned by GET (#11777)
f026154de3f is described below

commit f026154de3f666ba5dd77140a41ead1926e76a1d
Author: Pierre Villard <[email protected]>
AuthorDate: Wed Oct 7 14:40:58 2026 +0200

    NIFI-16437 - Connector configuration API rejects unset asset references 
returned by GET (#11777)
---
 .../authorization/AuthorizeConnectorConfigReferences.java    |  2 +-
 .../AuthorizeConnectorConfigReferencesTest.java              | 12 ++++++------
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferences.java
 
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferences.java
index 9927c5355cc..709d2e48984 100644
--- 
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferences.java
+++ 
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferences.java
@@ -108,7 +108,7 @@ public final class AuthorizeConnectorConfigReferences {
             final NiFiUser user
     ) {
         if (assetReferences == null || assetReferences.isEmpty()) {
-            throw new IllegalArgumentException("Asset references must be 
specified when value type is ASSET_REFERENCE");
+            return;
         }
 
         for (final AssetReferenceDTO assetReference : assetReferences) {
diff --git 
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferencesTest.java
 
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferencesTest.java
index 3a4b762c017..d66b8508f9d 100644
--- 
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferencesTest.java
+++ 
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/authorization/AuthorizeConnectorConfigReferencesTest.java
@@ -154,30 +154,30 @@ class AuthorizeConnectorConfigReferencesTest {
     }
 
     @Test
-    void testRejectsNullAssetReferences() {
+    void testAllowsNullAssetReferences() {
         
when(lookup.getConnector(eq(CONNECTOR_ID))).thenReturn(connectorAuthorizable);
 
         final ConnectorValueReferenceDTO valueReference = new 
ConnectorValueReferenceDTO();
         
valueReference.setValueType(ConnectorValueType.ASSET_REFERENCE.toString());
         valueReference.setAssetReferences(null);
 
-        assertThrows(IllegalArgumentException.class,
-                () -> AuthorizeConnectorConfigReferences.authorize(authorizer, 
lookup, CONNECTOR_ID, configurationStepWithValue(valueReference)));
+        AuthorizeConnectorConfigReferences.authorize(authorizer, lookup, 
CONNECTOR_ID, configurationStepWithValue(valueReference));
 
+        verify(connectorAuthorizable).authorize(eq(authorizer), 
eq(RequestAction.WRITE), any());
         verify(lookup, never()).getConnectorAsset(any(), any());
     }
 
     @Test
-    void testRejectsEmptyAssetReferences() {
+    void testAllowsEmptyAssetReferences() {
         
when(lookup.getConnector(eq(CONNECTOR_ID))).thenReturn(connectorAuthorizable);
 
         final ConnectorValueReferenceDTO valueReference = new 
ConnectorValueReferenceDTO();
         
valueReference.setValueType(ConnectorValueType.ASSET_REFERENCE.toString());
         valueReference.setAssetReferences(List.of());
 
-        assertThrows(IllegalArgumentException.class,
-                () -> AuthorizeConnectorConfigReferences.authorize(authorizer, 
lookup, CONNECTOR_ID, configurationStepWithValue(valueReference)));
+        AuthorizeConnectorConfigReferences.authorize(authorizer, lookup, 
CONNECTOR_ID, configurationStepWithValue(valueReference));
 
+        verify(connectorAuthorizable).authorize(eq(authorizer), 
eq(RequestAction.WRITE), any());
         verify(lookup, never()).getConnectorAsset(any(), any());
     }
 

Reply via email to