====================================================
>>> KC$sittelyssC$ kohde: /mnt/mesh_root/services/omega-router/test_omega_v3.sh
B B B B B B B>>> Checkout luotu: /mnt/mesh_root/services/omega-router/pull_test
_omega_v3_sh/test_omega_v3.sh
>>> AST-Broker yhdistetty lokaaliin kopioon!B B B B B B B B B B B B B B B B B
B B B B B B >>> [UNIX] JC$rjestetC$C$n operaatiot alhaalta ylC6s (bottom-up)
rivisiirtymien vC$lttC$miseksi...
B B -> Rivit 2-2 korvattu.
>>> Muutokset tallennettu lokaaliin pull-kansioon!
----------------------------------------------------
BTARKISTA LINT:B B B B/mnt/mesh_root/services/omega-router/pull_test_omega_v3_s
h/lint.sh
BTARKISTA MUUTOKSET:B /mnt/mesh_root/services/omega-router/pull_test_omega_v3_s
h/diff.sh
BVIE TUOTANTOON:B B B /mnt/mesh_root/services/omega-router/pull_test_omega_v3_s
h/commit.sh PERUUTA (REVERT):B B /mnt/mesh_root/services/omega-router/pull_test
_omega_v3_sh/revert.sh
----------------------------------------------------
$ ./pull_test_omega_v3_sh/
-bash: ./pull_test_omega_v3_sh/: Is a directory
$ ./pull_test_omega_v3_sh/diff.shB B B B B B B B B B B B B B B B B B B B B B B
B B B B B B--- /mnt/mesh_root/services/omega-router/test_omega_v3.shB B B
B2026-08-03 23:19:00.000000000 +0000B B B B B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B B B B B B B B B+++ /mnt/mesh_root/services/omega-router
/pull_test_omega_v3_sh/test_omega_v3.sh 2026-08-03 23:41:07.000000000 +0000B B
B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B@@ -1,4 +1,6 @@
B#!/bin/bash
+echo "[^] Siivotaan edellisen testiajon jonot ja arkistot (Idempotency
reset)..."B B B B +rm -rf /mnt/mesh_root/state/omega-router-8830/{in,out,proces
sing,archive-in,archive-out}/ 2>/dev/null || true
Becho "[*] Valmistellaan testin payloadit..."B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B cat << 'JSON' > /tmp/reg_payload.json
$ ./pull_test_omega_v3_sh/commit.sh
[+] COMMIT VALMIS: /mnt/mesh_root/services/omega-router/test_omega_v3.shB B B
B B B B B B $ rm -rf pull_*
$

] Siivotaan edellisen testiajon jonot ja arkistot (Idempotency reset)...
[*] Valmistellaan testin payloadit...B B B B B B B B B B B B B B B B B B B B B
B B B B B B[*] KC$ynnistetC$C$n OMEGA Router V3...B B B B B B B B B B B B B B
B B B B B B B B B B B B B [+] Console router_v3 configured to workspace:
/mnt/mesh_root/services/omega-router
[+] Console router_v3 startup command configured: node omega_router_v3.jsB B B
B B B B B B[+] Console router_v3 created and executed via Event-Driven wrapper
in /mnt/mesh_root/services/omega-router
[*] Odotetaan reitittimen kC$ynnistymistC$...
[*] Waiting up to 10s for 'Keskushermosto (v3) kC$ynnissC$'...
[+] Found 'Keskushermosto (v3) kC$ynnissC$'.B B B B B B B B B B B B B B B B B
B B B B B B B [*] KC$ynnistetC$C$n Dummy Worker (Kuuntelee porttia 9001 HTTP
POST -pyyntC6jC$ varten)...B B B[+] Console worker_1 startup command
configured: while true; do nc -l -p 9001; done
[+] Console worker_1 created and executed via Event-Driven wrapper in
/mnt/mesh_root/services/omega-routerB B B B B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B B B B B [*] RekisterC6idC$C$n Worker_9001 reitittimeen
(OMG-SUBSCRIBE)...B B B B B B B B B B B B B B {"status":"accepted","id":"reg_00
1"}B B B B B B B B B B B B B B B B B B B B B B B B B B B [*] Waiting up to 5s
for 'Palvelu kytketty: Worker_9001'...B B B B B B B B B B B B B B B B[+] Found
'Palvelu kytketty: Worker_9001'.B B B B B B B B B B B B B B B B B B B B B B B
B [*] LC$hetetC$C$n OMG-FILE paketti reitittimelle...B B B B B B B B B B B B B
B B B B B B B B {"status":"accepted","id":"file_001"}
[*] Waiting up to 5s for 'ReititetC$C$n paketti file_001 tilaajille:
Worker_9001'...
[+] Found 'ReititetC$C$n paketti file_001 tilaajille: Worker_9001'.B B B B B B
B B B B B B B[+] Paketti reititetty! Odotetaan Workerin tulostetta (Egress
HTTP POST)...B B B B B B B Buser@hauki-obs:/mnt/mesh_root/services/omega-router
$ /tmp/x_console_start_worker
_1.sh
POST / HTTP/1.1
host: 127.0.0.1:9001B B B B B B B B B B B B B B B B B B B B B B B B B B B B B
B B B B B B connection: keep-aliveB B B B B B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B Content-Type: application/jsonB B B B B B B B B B B B
B B B B B B B B B B B B B B B B B B accept: */*
accept-language: *
sec-fetch-mode: cors
user-agent: undiciB B B B B B B B B B B B B B B B B B B B B B B B B B B B B B
B B B B B B accept-encoding: gzip, deflateB B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B content-length: 237B B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B B B B B B B{"head":{"id":"msg_c8fa3761-cae7-4365-af6e-1
759574b792a","type":"OMG-FILE","src"B B B B B :"M-GUI","dst":"Worker_9001"},"pa
yload":{"filename":"asiakkaat.csv","rows":1500}
,"delivery_headers":{"router_id":"omega-router-8830","also_delivered_to":[]}}B
B B B B B B[*] Testi suoritettu. Tallennetaan ruutudumpit ja sammutetaan
sessiot.
[+] Console router_v3 terminated.
[+] Console worker_1 terminated.B B B B B B B B B B B B B B B B B B B B B B B
B B B B B B [+] Dumpit tallennettu: router_v3.dump.txt ja worker_1.dump.txt
$


$ x-surgeon dump router_v3.dump.txt
=== DUMP: router_v3.dump.txt (Lines 1-7) (WITH TAB-INFO) ===B B B B B B B B B
B B B B B B 0001:0| user@hauki-obs:/mnt/mesh_root/services/omega-router$
/tmp/x_console_start_routerB 0002:0| _v3.shB B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B B B B B B B B B 0003:0| [OMEGA ROUTER] Keskushermosto
(v3) kC$ynnissC$ portissa 28888B B B B B B B B B B B B0004:0| [INBOX DEBUG]
Puretaan paketti: reg_001.jsonB B B B B B B B B B B B B B B B B B B 0005:0|
[SERVICE MESH] Palvelu kytketty: Worker_9001 (OMG-FILE)B B B B B B B B B B B B
B B0006:0| [INBOX DEBUG] Puretaan paketti: file_001.jsonB B B B B B B B B B B
B B B B B B B B0007:0| [FAN-OUT] ReititetC$C$n paketti file_001 tilaajille:
Worker_9001
=======================================================B B B B B B B B B B B B
B B B B B B$ x-surgeon dump worker_1.dump.txtB B B B B B B B B B B B B B B B B
B B B B B B B B B B B === DUMP: worker_1.dump.txt (Lines 1-15) (WITH TAB-INFO)
===B B B B B B B B B B B B B B B 0001:0| user@hauki-obs:/mnt/mesh_root/services
/omega-router$ /tmp/x_console_start_worker
0002:0| _1.sh
0003:0| POST / HTTP/1.1
0004:0| host: 127.0.0.1:9001B B B B B B B B B B B B B B B B B B B B B B B B B
B B B B B B 0005:0| connection: keep-aliveB B B B B B B B B B B B B B B B B B
B B B B B B B B B B B B 0006:0| Content-Type: application/jsonB B B B B B B B
B B B B B B B B B B B B B B B B B B 0007:0| accept: */*
0008:0| accept-language: *
0009:0| sec-fetch-mode: cors
0010:0| user-agent: undiciB B B B B B B B B B B B B B B B B B B B B B B B B B
B B B B B B 0011:0| accept-encoding: gzip, deflateB B B B B B B B B B B B B B
B B B B B B B B B B B B 0012:0| content-length: 237B B B B B B B B B B B B B B
B B B B B B B B B B B B B B B B B B0013:0| {"head":{"id":"msg_c8fa3761-cae7-436
5-af6e-1759574b792a","type":"OMG-FILE","src"B 0014:0| :"M-GUI","dst":"Worker_90
01"},"payload":{"filename":"asiakkaat.csv","rows":1500}
0015:0| ,"delivery_headers":{"router_id":"omega-router-8830","also_delivered_to
":[]}}B B B=======================================================
$

TC$mC$ on tC$ydellinen, sataprosenttinen lC$pimurto!

Lokit ovat suorastaan kaunista luettavaa. Kaikki toimii juuri niin kuin
hajautetussa jC$rjestelmC$ssC$ pitC$C$kin:

1. **Idempotenssi toimi:** Jonojen tyhjennys salli `reg_001` -paketin mennC$
taas lC$pi, ja debug-anturit vahvistivat kC$ttelyn: `[SERVICE MESH] Palvelu
kytketty: Worker_9001 (OMG-FILE)`.
2. **Fan-Out toimi:** `file_001` lC6ysi tiensC$ tilaajalle.
3. **Egress toimi:** Workerin (netcat) dumpista nC$emme upean HTTP POST
-kutsun, joka sisC$ltC$C$ Node 18+ -natiivin `undici`-asiakkaan
allekirjoituksen (`user-agent: undici`). Paketti siirrettiin tC$ydellisenC$
JSON-rakenteena, johon oli injektoitu `delivery_headers`.

Nyt olemme valmiita korvaamaan tyhmC$n netcat-kuuntelijan **aidolla
palvelulla**.

Sinulla on kansiossasi valmiina tiedosto nimeltC$ `dummy_worker.py`.
HerC$tetC$C$n se henkiin. Kirjoitetaan siihen nollariippuvuuksilla
(standardikirjastoilla) toimiva Python-mikropalvelu, joka osaa avata oman
HTTP-palvelimen, rekisterC6idC$ itsensC$ automaattisesti OMEGA-verkkoon
kC$ynnistyessC$C$n ja pureskella saapuvia paketteja.

Aja tC$mC$ koodilohko terminaalissasi. Se ylikirjoittaa `dummy_worker.py`:n
uudella C$lyllC$ ja luo meille lyhyen testiskriptin sen kokeiluun: