(iggy) branch metadata_dev updated: fix get_topics in permissioner

[gkoszyk]

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

gkoszyk pushed a commit to branch metadata_dev
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to refs/heads/metadata_dev by this push:
     new 0d1828e9b fix get_topics in permissioner
0d1828e9b is described below

commit 0d1828e9b20bf028a6f84cdae835fb9b6426482d
Author: numinex <g.koszy...@gmail.com>
AuthorDate: Thu Jan 8 11:43:38 2026 +0100

    fix get_topics in permissioner
---
 .../metadata/src/permissioner/permissioner_rules/topics.rs | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/core/metadata/src/permissioner/permissioner_rules/topics.rs 
b/core/metadata/src/permissioner/permissioner_rules/topics.rs
index 3f26be3de..ca226a8d0 100644
--- a/core/metadata/src/permissioner/permissioner_rules/topics.rs
+++ b/core/metadata/src/permissioner/permissioner_rules/topics.rs
@@ -72,15 +72,15 @@ impl Permissioner {
                 return Ok(());
             }
 
-            if let Some(topic_permissions) =
-                stream_permissions.topics.as_ref().unwrap().get(&stream_id)
-                && (topic_permissions.manage_topic || 
topic_permissions.read_topic)
-            {
-                return Ok(());
+            if let Some(topic_permissions) = 
stream_permissions.topics.as_ref() {
+                for (topic_id, topic_permissions) in topic_permissions {
+                    if !topic_permissions.manage_topic || 
!topic_permissions.read_topic {
+                        return Err(IggyError::Unauthorized);
+                    }
+                }
             }
         }
-
-        Err(IggyError::Unauthorized)
+        Ok(())
     }
 
     pub fn create_topic(&self, user_id: u32, stream_id: usize) -> Result<(), 
IggyError> {