a-router/
user@hauki-obs:/mnt/mesh_root/services/omega-router$ ls -ltra
total 84
drwxr-xr-x 1 root root    37 Jul 30 14:56 ..
-rw-r--r-- 1 root root 28563 Jul 30 15:02 package-lock.json
-rw-r--r-- 1 root root    52 Jul 30 15:02 package.json
drwxr-xr-x 1 root root    68 Jul 30 15:02 node_modules
-rw-r--r-- 1 root root  7979 Aug  1 16:09 omega_router_core.js
-rw-r--r-- 1 root root 10928 Aug  1 16:27 omega_router_v3.js
-rw-r--r-- 1 root root  2280 Aug  1 16:29 dummy_worker.py
-rw-r--r-- 1 root root  1670 Aug  1 16:53 wa_sender_mock.py
-rw-r--r-- 1 root root  2477 Aug  1 16:54 gem_wa_receiver.py
-rwxr-xr-x 1 root root  1010 Aug  3 22:35 test_omega_flow.sh
-rw-r--r-- 1 root root  1183 Aug  3 22:38 demo_skenaario.xc
drwxr-xr-x 1 root root    12 Aug  3 22:38 .
user@hauki-obs:/mnt/mesh_root/services/omega-router$ x-gem-terminal list
=== MESH TERMINAL PROPOSALS ===
Aug 3 22:51  |  gem_2026-08-03T22-49-52-681Z_1f82310f.gem-terminal-script
user@hauki-obs:/mnt/mesh_root/services/omega-router$ x-gem-terminal view
--- LUKUTILASSA: gem_2026-08-03T22-49-52-681Z_1f82310f.gem-terminal-script ---
cat << 'EOF' > /mnt/mesh_root/services/omega-router/test_omega_v3.sh
#!/bin/bash
echo "[*] Valmistellaan testin payloadit..."

cat << 'JSON' > /tmp/reg_payload.json
{
"head": { "id": "reg_001", "type": "OMG-SUBSCRIBE", "src": "Worker_9001" },
"payload": {
"token": "super_secret_crm_key_123",
"capabilities": [ { "type": "OMG-FILE" } ],
"endpoint": "http://127.0.0.1:9001",
"ttl_seconds": 300
}
}
JSON

cat << 'JSON' > /tmp/data_payload.json
{
"head": { "id": "file_001", "type": "OMG-FILE", "src": "M-GUI" },
"payload": {
"filename": "asiakkaat.csv",
"rows": 1500
}
}
JSON

echo "[*] KC$ynnistetC$C$n OMEGA Router V3..."
x-console router_v3 conf-cwd "/mnt/mesh_root/services/omega-router"
x-console router_v3 conf-start "node omega_router_v3.js"
x-console router_v3 start

echo "[*] Odotetaan reitittimen kC$ynnistymistC$..."
x-console router_v3 wait-for "Keskushermosto (v3) kC$ynnissC$" 10

echo "[*] KC$ynnistetC$C$n Dummy Worker (Kuuntelee porttia 9001 HTTP POST
-pyyntC6jC$ varten)..."
x-console worker_1 conf-start "while true; do nc -l -p 9001; done"
x-console worker_1 start

sleep 1

echo "[*] RekisterC6idC$C$n Worker_9001 reitittimeen (OMG-SUBSCRIBE)..."
curl -s -X POST -H "Content-Type: application/json" -d @/tmp/reg_payload.json
http://127.0.0.1:20280/api/omega/inbox
echo ""
x-console router_v3 wait-for "Palvelu kytketty: Worker_9001" 5

echo "[*] LC$hetetC$C$n OMG-FILE paketti reitittimelle..."
curl -s -X POST -H "Content-Type: application/json" -d @/tmp/data_payload.json
http://127.0.0.1:20280/api/omega/inbox
echo ""
x-console router_v3 wait-for "ReititetC$C$n paketti file_001 tilaajille:
Worker_9001" 5

echo "[+] Paketti reititetty! Odotetaan Workerin tulostetta (Egress HTTP
POST)..."
sleep 2
x-console worker_1 tail 20

echo "[*] Testi suoritettu. Sammutetaan sessiot."
x-console router_v3 stop
x-console worker_1 stop
EOF

chmod +x /mnt/mesh_root/services/omega-router/test_omega_v3.sh

cat << 'EOF' > /mnt/mesh_root/services/omega-router/demo_skenaario_v3.xc

OMEGA ROUTER V3 - AutomaatiokC$sikirjoitus (x-console-auto)
# -- 1. ALUSTUS --

+0.0s  router   conf-cwd "/mnt/mesh_root/services/omega-router"
+0.0s  router   conf-start "node omega_router_v3.js"
+0.0s  worker   conf-start "while true; do nc -l -p 9001; done"

# -- 2. KCYNNISTYS --

+0.5s  router   start
+0.6s  router   wait-for "Keskushermosto" 10
+1.0s  worker   start

# -- 3. REKISTERCITYMINEN (HTTP POST) --

+2.0s  client   send "curl -s -X POST -H 'Content-Type: application/json' -d
'{"head":{"id":"reg1","type":"OMG-SUBSCRIBE","src":"Worker_9001"},"payload":{"t
oken":"super_secret_crm_key_123","capabilities":[{"type":"OMG-FILE"}],"endpoint
":"http://127.0.0.1:9001","ttl_seconds":300}}' http://127.0.0.1:20280/api/omega
/inbox" Enter
+2.5s  router   wait-for "Palvelu kytketty" 5

# -- 4. TIEDOSTON LCHETYS JA FAN-OUT --

+3.0s  client   send "curl -s -X POST -H 'Content-Type: application/json' -d
'{"head":{"id":"file1","type":"OMG-FILE","src":"M-GUI"},"payload":{"data":"test
i"}}' http://127.0.0.1:20280/api/omega/inbox" Enter
+3.5s  router   wait-for "ReititetC$C$n paketti file1" 5
+4.5s  router   wait-for "Toimitettu onnistuneesti" 5

# -- 5. ALASAJO --

+5.0s  router   stop
+5.0s  worker   stop
EOF

user@hauki-obs:/mnt/mesh_root/services/omega-router$ 


user@hauki-obs:/mnt/mesh_root/services/omega-router$ x-gem-terminal run
[+] HyvC$ksytty. Suoritetaan: gem_2026-08-03T22-49-52-681Z_1f82310f.gem-termina
l-script
[*] ========= RUN =========
[:] /mnt/mesh_root/state/gem-terminal-proposals/gem_2026-08-03T22-49-52-681Z_1f
82310f.gem-terminal-script


user@hauki-obs:/mnt/mesh_root/services/omega-router$ ls -ltra
total 92
drwxr-xr-x 1 root root    37 Jul 30 14:56 ..
-rw-r--r-- 1 root root 28563 Jul 30 15:02 package-lock.json
-rw-r--r-- 1 root root    52 Jul 30 15:02 package.json
drwxr-xr-x 1 root root    68 Jul 30 15:02 node_modules
-rw-r--r-- 1 root root  7979 Aug  1 16:09 omega_router_core.js
-rw-r--r-- 1 root root 10928 Aug  1 16:27 omega_router_v3.js
-rw-r--r-- 1 root root  2280 Aug  1 16:29 dummy_worker.py
-rw-r--r-- 1 root root  1670 Aug  1 16:53 wa_sender_mock.py
-rw-r--r-- 1 root root  2477 Aug  1 16:54 gem_wa_receiver.py
-rwxr-xr-x 1 root root  1010 Aug  3 22:35 test_omega_flow.sh
-rw-r--r-- 1 root root  1183 Aug  3 22:38 demo_skenaario.xc
-rwxr-xr-x 1 root root  1779 Aug  3 22:53 test_omega_v3.sh
-rw-r--r-- 1 root root  1219 Aug  3 22:53 demo_skenaario_v3.xc