feat(config): rule grpc

1 files changed, 8 insertions, 0 deletions

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 {