feat(config): identify resource to reload

2 files changed, 36 insertions, 6 deletions

diff --git a/crates/configuration/src/state/routing/mutate_routing.rs b/crates/configuration/src/state/routing/mutate_routing.rs
index 105cf18..9542ba7 100644
--- a/crates/configuration/src/state/routing/mutate_routing.rs
+++ b/crates/configuration/src/state/routing/mutate_routing.rs
@@ -4,7 +4,7 @@ use tracing::{Instrument, error, info_span, instrument, trace};
 use tracing_opentelemetry::OpenTelemetrySpanExt;
 use uuid::Uuid;
 use warden_core::configuration::{
-    ReloadEvent,
+    ConfigKind, ReloadEvent,
     routing::{
         DeleteConfigurationRequest, RoutingConfiguration, UpdateRoutingRequest,
         mutate_routing_server::MutateRouting,
@@ -100,7 +100,14 @@ impl MutateRouting for AppHandle {
 
         let (_del_result, _publish_result) = tokio::try_join!(
             invalidate_cache(self, CacheKey::Routing(&id)),
-            publish_reload(self, conf, ReloadEvent::Routing)
+            publish_reload(
+                self,
+                conf,
+                ReloadEvent {
+                    kind: ConfigKind::Routing.into(),
+                    ..Default::default()
+                }
+            )
         )?;
 
         let res = updated.configuration.0;
@@ -151,7 +158,14 @@ impl MutateRouting for AppHandle {
 
         let (_del_result, _publish_result) = tokio::try_join!(
             invalidate_cache(self, CacheKey::Routing(&id)),
-            publish_reload(self, conf, ReloadEvent::Routing)
+            publish_reload(
+                self,
+                conf,
+                ReloadEvent {
+                    kind: ConfigKind::Routing.into(),
+                    ..Default::default()
+                }
+            )
         )?;
 
         let res = updated.configuration.0;
diff --git a/crates/configuration/src/state/rule/mutate_rule.rs b/crates/configuration/src/state/rule/mutate_rule.rs
index 7b853aa..9c4f393 100644
--- a/crates/configuration/src/state/rule/mutate_rule.rs
+++ b/crates/configuration/src/state/rule/mutate_rule.rs
@@ -4,7 +4,7 @@ use tracing::{Instrument, error, info_span};
 use tracing_opentelemetry::OpenTelemetrySpanExt;
 use uuid::Uuid;
 use warden_core::configuration::{
-    ReloadEvent,
+    ConfigKind, ReloadEvent,
     rule::{
         DeleteRuleConfigurationRequest, RuleConfiguration, UpdateRuleRequest,
         mutate_rule_configuration_server::MutateRuleConfiguration,
@@ -92,7 +92,15 @@ impl MutateRuleConfiguration for AppHandle {
                     version: &config.version,
                 }
             ),
-            publish_reload(self, conf, ReloadEvent::Rule)
+            publish_reload(
+                self,
+                conf,
+                ReloadEvent {
+                    kind: ConfigKind::Rule.into(),
+                    id: Some(config.id.to_owned()),
+                    version: Some(config.version.to_owned()),
+                }
+            )
         )?;
 
         Ok(Response::new(config))
@@ -144,7 +152,15 @@ impl MutateRuleConfiguration for AppHandle {
                     version: &request.version,
                 }
             ),
-            publish_reload(self, conf, ReloadEvent::Rule)
+            publish_reload(
+                self,
+                conf,
+                ReloadEvent {
+                    kind: ConfigKind::Rule.into(),
+                    id: Some(request.id.to_owned()),
+                    version: Some(request.version.to_owned()),
+                }
+            )
         )?;
 
         let res = updated.configuration.0;