feat: destinations node interpretation for wasm components

src/proxy/compute/data_collection/components.rs

@@ -50,7 +50,7 @@ pub async fn send_data_collection(p: &Payload) -> anyhow::Result<()> {
     // clone the payload to be able to move it to the async thread
     let p = p.clone();
     let payload = provider::Payload {
-        uuid: p.uuid,
+        uuid: p.uuid.clone(),
         timestamp: p.timestamp.timestamp(),
         timestamp_millis: p.timestamp.timestamp_millis(),
         timestamp_micros: p.timestamp.timestamp_micros(),
@@ -281,6 +281,9 @@ pub async fn send_data_collection(p: &Payload) -> anyhow::Result<()> {
     };
 
     for cfg in &config::get().components.data_collection {
+        if !p.is_destination_enabled(cfg.name.as_str()) {
+            continue;
+        }
         let component = WASM_COMPONENTS
             .get()
             .unwrap()

src/proxy/compute/data_collection/payload.rs

@@ -227,3 +227,26 @@ pub struct Session {
     pub first_seen: DateTime<Utc>,
     pub last_seen: DateTime<Utc>,
 }
+
+impl Payload {
+    pub fn is_destination_enabled(&self, name: &str) -> &bool {
+        // if destinations is not set, return true
+        if self.destinations.is_none() {
+            return &true;
+        }
+
+        // get destinations.get("all")
+        let all = self
+            .destinations
+            .as_ref()
+            .unwrap()
+            .get("all")
+            .unwrap_or(&true);
+
+        // check if the destination is enabled
+        if self.destinations.as_ref().unwrap().contains_key(name) {
+            return self.destinations.as_ref().unwrap().get(name).unwrap();
+        }
+        all
+    }
+}