From 1b8c6886f6d22f9c61e978b42d066dce91e334dc Mon Sep 17 00:00:00 2001
From: rtkay123 <dev@kanjala.com>
Date: Thu, 14 Aug 2025 18:05:07 +0200
Subject: feat(config): rule grpc

---
 crates/configuration/src/state.rs | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'crates/configuration/src/state.rs')

diff --git a/crates/configuration/src/state.rs b/crates/configuration/src/state.rs
index 5a51d5b..de58d4b 100644
--- a/crates/configuration/src/state.rs
+++ b/crates/configuration/src/state.rs
@@ -1,5 +1,6 @@
 mod cache_key;
 mod routing;
+mod rule;
 
 use async_nats::jetstream::Context;
 use sqlx::PgPool;
@@ -44,6 +45,13 @@ impl AppState {
     ) -> Result<AppHandle, AppError> {
         let local_config: LocalConfig = serde_json::from_value(configuration.misc.clone())?;
 
+        local_config
+            .nats
+            .subject
+            .split(".")
+            .next()
+            .ok_or_else(|| anyhow::anyhow!("expected a dot separated config for nats subjects"))?;
+
         create_stream(&services.jetstream, &local_config.nats).await?;
 
         Ok(AppHandle(Arc::new(Self {
-- 
cgit v1.2.3