Merge commit '558af09830d96b69772981eb80df33adef7f94c6' into include-sub-projects

Author: haiodo

foundations/hulypulse/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "hulypulse"
-version = "0.1.32"
+version = "0.2.1"
 edition = "2024"
 
 [dependencies]
@@ -30,7 +30,8 @@ tokio-stream = "0.1"
 strum = { version = "0.27.2", features = ["derive"] }
 strum_macros = "0.27.2"
 regorus = "0.5.0"
-
+actix-ws = "0.3.0"
+futures-util = "0.3"
 
 [[bin]]
 name = "hulypulse"

foundations/hulypulse/Cargo.toml

@@ -67,25 +67,25 @@ <h1>WebSocket JSON Tester</h1>
 
   <p>
 
-<button onclick="place()" data='{"type":"info", "correlation": "abc123"}'>INFO</button>
+<button onclick="place()" data='{"correlation": "1", "type":"info"}'>INFO</button>
 
-<button onclick="place()" data='{"type":"put", "key":"00000000-0000-0000-0000-000000000001/foo/bar1", "data": "hello 1", "TTL":5, "correlation": "abc123"}'>PUT 1</button>
-<button onclick="place()" data='{"type":"put", "key":"00000000-0000-0000-0000-000000000001/foo/bar2", "data": "hello 2", "TTL":9, "correlation": "abc123"}'>PUT 2</button>
+<button onclick="place()" data='{"correlation": "1", "type":"put", "key":"00000000-0000-0000-0000-000000000001/foo/bar1", "data": "hello 1", "TTL":5}'>PUT 1</button>
+<button onclick="place()" data='{"correlation": "1", "type":"put", "key":"00000000-0000-0000-0000-000000000001/foo/bar2", "data": "hello 2", "TTL":9}'>PUT 2</button>
 
-<button onclick="place()" data='{"type":"delete", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>DEL 1</button>
-<button onclick="place()" data='{"type":"delete", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>DEL 2</button>
+<button onclick="place()" data='{"correlation": "1", "type":"delete", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>DEL 1</button>
+<button onclick="place()" data='{"correlation": "1", "type":"delete", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>DEL 2</button>
 
-<button onclick="place()" data='{"type":"get", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>GET 1</button>
-<button onclick="place()" data='{"type":"get", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>GET 2</button>
+<button onclick="place()" data='{"correlation": "1", "type":"get", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>GET 1</button>
+<button onclick="place()" data='{"correlation": "1", "type":"get", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>GET 2</button>
 
-<button onclick="place()" data='{"type":"sub", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>SUB 1</button>
-<button onclick="place()" data='{"type":"sub", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>SUB 2</button>
+<button onclick="place()" data='{"correlation": "1", "type":"sub", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>SUB 1</button>
+<button onclick="place()" data='{"correlation": "1", "type":"sub", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>SUB 2</button>
 
-<button onclick="place()" data='{"type":"unsub", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>UNSUB 1</button>
-<button onclick="place()" data='{"type":"unsub", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>UNSUB 2</button>
-<button onclick="place()" data='{"type":"unsub", "key":"*"}'>UNSUB *</button>
+<button onclick="place()" data='{"correlation": "1", "type":"unsub", "key":"00000000-0000-0000-0000-000000000001/foo/bar1"}'>UNSUB 1</button>
+<button onclick="place()" data='{"correlation": "1", "type":"unsub", "key":"00000000-0000-0000-0000-000000000001/foo/bar2"}'>UNSUB 2</button>
+<button onclick="place()" data='{"correlation": "1", "type":"unsub", "key":"*"}'>UNSUB *</button>
 
-<button onclick="place()" data='{"type": "sublist" }'>SUBLIST</button>
+<button onclick="place()" data='{"correlation": "1", "type": "sublist" }'>SUBLIST</button>
 
 
   <div id="output">Waiting for server response...</div>
@@ -110,7 +110,11 @@ <h1>WebSocket JSON Tester</h1>
 
     ws.onopen = () => {
 	pr("clear");
-	pr("✅ WebSocket connected.");
+	pr("✅ WebSocket connected");
+    };
+
+    ws.onclose = () => {
+	pr("❌ WebSocket closed");
     };
 
     ws.onmessage = (e) => {

foundations/hulypulse/scripts/TEST.html

@@ -58,6 +58,7 @@ pub struct Config {
     pub no_authorization: bool,
 
     pub heartbeat_timeout: u64,
+    pub ping_timeout: u64,
 
     pub policy_file: Option<String>,
 }

foundations/hulypulse/src/config.rs

@@ -13,6 +13,7 @@ backend = "redis"
 no_authorization = false
 
 heartbeat_timeout = 90
+ping_timeout = 30
 
 # optional settings
 # max_size = 100