From 000885c1d5a23eb353c3f490e32363010ca804d3 Mon Sep 17 00:00:00 2001
From: rtkay123 <dev@kanjala.com>
Date: Sat, 16 Aug 2025 00:47:43 +0200
Subject: feat(config): identify resource to reload

---
 crates/router/src/processor/reload.rs | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)

(limited to 'crates/router')

diff --git a/crates/router/src/processor/reload.rs b/crates/router/src/processor/reload.rs
index 900b7ce..e15ca07 100644
--- a/crates/router/src/processor/reload.rs
+++ b/crates/router/src/processor/reload.rs
@@ -1,8 +1,9 @@
 use async_nats::jetstream::consumer;
 use futures_util::StreamExt;
-use tracing::{debug, error, info, trace};
+use prost::Message as _;
+use tracing::{error, info, trace};
 use uuid::Uuid;
-use warden_core::configuration::ReloadEvent;
+use warden_core::configuration::{ConfigKind, ReloadEvent};
 
 use crate::state::AppHandle;
 
@@ -31,18 +32,19 @@ pub async fn reload(state: AppHandle) -> anyhow::Result<()> {
     while let Some(value) = messages.next().await {
         match value {
             Ok(message) => {
-                trace!("got reload cache event",);
-                if let Ok(Some(event)) = String::from_utf8(message.payload.to_vec())
-                    .map(|value| ReloadEvent::from_str_name(&value))
+                trace!("got reload cache event");
+                if let Ok(res) = ReloadEvent::decode(message.payload.as_ref())
+                    && let Ok(kind) = ConfigKind::try_from(res.kind)
                 {
-                    match event {
-                        ReloadEvent::Routing => {
+                    match kind {
+                        ConfigKind::Routing => {
+                            trace!("update triggered, invalidating active routing config");
                             let local_cache = state.local_cache.write().await;
                             local_cache.invalidate_all();
                             let _ = message.ack().await.inspect_err(|e| error!("{e}"));
                         }
-                        _ => {
-                            debug!(event = ?event, "detected reload event, acknowledging");
+                        ConfigKind::Rule => {
+                            trace!(kind = ?kind, "detected reload event, nothing to do here, acknowledging");
                             let _ = message.ack().await.inspect_err(|e| error!("{e}"));
                         }
                     }
-- 
cgit v1.2.3