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

bossenti pushed a commit to branch remove-redundant-parameter
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit c13c3796c0546623a7c619ae558cebacbd4922bb
Author: bossenti <[email protected]>
AuthorDate: Thu Mar 14 12:02:46 2024 +0100

    refactor: remove unnecessary parameter 'username'
---
 .../rest/impl/admin/ExtensionsServiceEndpointResource.java     | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)

diff --git 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java
 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java
index f89a8840fb..748d9f0a26 100644
--- 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java
+++ 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java
@@ -85,7 +85,6 @@ public class ExtensionsServiceEndpointResource extends 
AbstractAuthGuardedRestRe
   @GetMapping(path = "/items", produces = MediaType.APPLICATION_JSON_VALUE)
   public ResponseEntity<List<ExtensionsServiceEndpointItem>> 
getEndpointContents() {
     List<ExtensionsServiceEndpoint> endpoints = getEndpoints();
-    String username = getAuthenticatedUsername();
 
     var installedExtensions = getAllInstalledExtensions();
     List<ExtensionsServiceEndpointItem> items = 
Operations.getEndpointUriContents(endpoints);
@@ -93,9 +92,9 @@ public class ExtensionsServiceEndpointResource extends 
AbstractAuthGuardedRestRe
 
     // also add installed elements that are currently not running or available
     items.addAll(getAllAdapterEndpoints(items));
-    items.addAll(getAllDataStreamEndpoints(username, items));
-    items.addAll(getAllDataProcessorEndpoints(username, items));
-    items.addAll(getAllDataSinkEndpoints(username, items));
+    items.addAll(getAllDataStreamEndpoints(items));
+    items.addAll(getAllDataProcessorEndpoints(items));
+    items.addAll(getAllDataSinkEndpoints(items));
 
     return ok(items);
   }
@@ -144,7 +143,6 @@ public class ExtensionsServiceEndpointResource extends 
AbstractAuthGuardedRestRe
   }
 
   private List<ExtensionsServiceEndpointItem> getAllDataStreamEndpoints(
-      String username,
       List<ExtensionsServiceEndpointItem> existingItems) {
     return getAllDataStreams()
         .stream()
@@ -156,7 +154,6 @@ public class ExtensionsServiceEndpointResource extends 
AbstractAuthGuardedRestRe
 
 
   private List<ExtensionsServiceEndpointItem> getAllDataProcessorEndpoints(
-      String username,
       List<ExtensionsServiceEndpointItem> existingItems) {
 
     return getAllDataProcessors()
@@ -167,7 +164,6 @@ public class ExtensionsServiceEndpointResource extends 
AbstractAuthGuardedRestRe
   }
 
   private List<ExtensionsServiceEndpointItem> getAllDataSinkEndpoints(
-      String username,
       List<ExtensionsServiceEndpointItem> existingItems) {
 
     return getAllDataSinks()

Reply via email to