From 60e0003ebb26ba31075ba047b6d15af1a4f29bbb Mon Sep 17 00:00:00 2001
From: rtkay123 <dev@kanjala.com>
Date: Mon, 18 Aug 2025 20:10:15 +0200
Subject: feat: rule 901 (#10)

---
 crates/rule-executor/src/main.rs | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

(limited to 'crates/rule-executor/src/main.rs')

diff --git a/crates/rule-executor/src/main.rs b/crates/rule-executor/src/main.rs
index ed284c6..abae26d 100644
--- a/crates/rule-executor/src/main.rs
+++ b/crates/rule-executor/src/main.rs
@@ -1,4 +1,3 @@
-#[allow(dead_code)]
 mod cnfg;
 
 mod processor;
@@ -47,6 +46,9 @@ async fn main() -> Result<()> {
         .nats_jetstream(&config.nats)
         .await
         .inspect_err(|e| error!("nats: {e}"))?
+        .postgres(&config.database)
+        .await
+        .inspect_err(|e| error!("postgres: {e}"))?
         .build();
 
     let jetstream = services
@@ -54,7 +56,15 @@ async fn main() -> Result<()> {
         .take()
         .ok_or_else(|| anyhow::anyhow!("jetstream is not ready"))?;
 
-    let services = state::Services { jetstream };
+    let postgres = services
+        .postgres
+        .take()
+        .ok_or_else(|| anyhow::anyhow!("database is not ready"))?;
+
+    let services = state::Services {
+        jetstream,
+        postgres,
+    };
 
     processor::serve(services, config, provider)
         .await
-- 
cgit v1.2.3