Implement is_bucket_matching method

HIRO-MicroDataCenters-BV · Nov 16, 2024 · 052c912 · 052c912
1 parent 5e6f22d
commit 052c912
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/rhio/src/node/actor.rs b/rhio/src/node/actor.rs
@@ -392,8 +392,20 @@ fn is_subject_matching(subscriptions: &Vec<Subscription>, incoming: &ScopedSubje
 }
 
 /// Returns true if incoming blob announcement is of interested to our local node.
-#[allow(unused_variables)]
 fn is_bucket_matching(subscriptions: &Vec<Subscription>, incoming: &ScopedBucket) -> bool {
-    // @TODO
+    for subscription in subscriptions {
+        match subscription {
+            Subscription::Bucket { bucket } => {
+                if bucket == incoming {
+                    return true;
+                } else {
+                    continue;
+                }
+            }
+            Subscription::Subject { .. } => {
+                continue;
+            }
+        }
+    }
     false
 }