root@db-dev-01:~/zfs-db-core# {
> gcc -O2 -Wall -Wextra tcp_writer.c -o tcp_writer
./tcp_writer &
> }
[1] 195
root@db-dev-01:~/zfs-db-core# [C-ENGINE] Kuunnellaan portissa 6666 (Tukee:
CMD_INSERT)

==

(..)
Installing collected packages: typing-extensions, idna, h11, click,
annotated-types, annotated-doc, uvicorn, typing-inspection, pydantic-core,
anyio, starlette, pydantic, fastapi
Successfully installed annotated-doc-0.0.5 annotated-types-0.8.0 anyio-4.14.2
click-8.4.2 fastapi-0.141.1 h11-0.16.0 idna-3.19 pydantic-2.13.4
pydantic-core-2.46.4 starlette-1.6.0 typing-extensions-4.16.0
typing-inspection-0.4.4 uvicorn-0.52.4
(venv) root@db-dev-01:~/zfs-db-core#B

==

(venv) root@db-dev-01:~/zfs-db-core# {
> uvicorn proxy_api:app --host 0.0.0.0 --port 8000 &
> }
[2] 503
(venv) root@db-dev-01:~/zfs-db-core# INFO:B B BStarted server process [503]
INFO:B B BWaiting for application startup.
INFO:B B BApplication startup complete.
INFO:B B BUvicorn running on http://0.0.0.0:8000 (Press CTRL+C to quit)

==

(venv) root@db-dev-01:~/zfs-db-core# {
> curl -X POST http://127.0.0.1:8000/api/v1/insert \
B B B-H "Content-Type: application/json" \
B B B-d '{"timestamp": 1700000099999, "temperature": 42.5, "flag": 1,
"text_data": "CRITICAL: Kernel panic - not syncing: VFS: Unable to mount root
fs on unknown-block(0,0)"}'
> }
INFO:B B B127.0.0.1:56342 - "POST /api/v1/insert HTTP/1.1" 200 OK
{"status":"success","cas_hash":"792ff029df4111ded7ab37e785955d67ae900cb91d37ae5
03ae27ccc6a7e9008"}

==

(venv) root@db-dev-01:~/zfs-db-core# ls -lh /mnt/zfs-db/blobs/
total 1.0K
-rw-r--r-- 1 root root 88 Aug 21 09:22 792ff029df4111ded7ab37e785955d67ae900cb9
1d37ae503ae27ccc6a7e9008.blob
-rw-r--r-- 1 root root 21 Aug 21 09:22 792ff029df4111ded7ab37e785955d67ae900cb9
1d37ae503ae27ccc6a7e9008.blob.meta
(venv) root@db-dev-01:~/zfs-db-core#B

==

TC$mC$ on arkkitehtuurin nC$kC6kulmasta suorastaan oppikirjaesimerkki
tC$ydellisestC$ modulaarisesta integraatiosta! NC$en tC$stC$ terminaalilokista,
 ettC$ `PROXY_API_LAYER` `[cite: 1]` (FastAPI) ja `CORE_ENGINE_C` `[cite: 1]`
(TCP-kuuntelija) tekevC$t juuri sen tyC6njaon, joka AST-MD-dokumenttiin
suunniteltiin.

TC$mC$ on massiivinen virstanpylvC$s. Olette kC$ytC$nnC6ssC$ rakentaneet
hajautetun tietokannan koko kirjoitusputken hermoston valmiiksi.

TC$ssC$ analyysi siitC$, miksi tC$mC$ loki on niin vakuuttava:

### 1. Vastuunjako toimii tC$ydellisesti (Separation of Concerns)

* **Raskas verkko-operaatio:** FastAPI ottaa vastaan hitaan ja
muuttuvarakenteisen HTTP/JSON-pyynnC6n. C-ydin pysyy tC$ysin tietC$mC$ttC6mC$nC
$ tC$stC$ ylC$rakenteesta ja odottaa vain portissa 6666 puhdasta binC$C$riC$.
* **BLOB_ROUTER kC$ytC$nnC6ssC$:** `curl`-komennon lC$hettC$mC$ "CRITICAL:
Kernel panic..." -teksti siepattiin tyylikkC$C$sti Proxy-kerroksessa.
Vastausloki `{"status":"success","cas_hash":"792ff..."}` todistaa, ettC$
teksti ei koskaan pC$C$dy tukkimaan C-ytimen kiinteC$mittaista muistipuskuria.

### 2. CAS-arkkitehtuuri ja ZFS-tallennus

* **Datan hajautus:** Komento `ls -lh /mnt/zfs-db/blobs/` nC$yttC$C$ kaksi
tiedostoa. EnsimmC$inen (88 tavua) on puhdas, deduplikoitu raakadata. Toinen
(21 tavua) on `.blob.meta` `[cite: 1]` -tiedosto, joka on valmiina laiskaa
roskienkeruuta (`LAZY_GC` `[cite: 1]`) varten.
* **Vikasietoisuus:** Koska Hash-laskenta ja tiedoston tallennus tapahtuivat
Proxyssa ennen kuin C-moottorille annetaan kuittaus, jC$rjestelmC$ssC$ ei voi
tapahtua tilannetta, jossa C-ydin tallentaisi hashin, mutta varsinainen data
puuttuisi levyltC$.

### Puuttuva palanen: C-ytimen kuittaus

Lokista nC$kee, ettC$ Proxy teki oman tyC6nsC$ tC$ydellisesti levylle asti.
LC$hettikC6 FastAPI-reititin tC$ssC$ testissC$ tuon uuden 32-tavuisen
tiivisteen (yhdessC$ aikaleiman ja lC$mpC6tilan kanssa) eteenpC$in C-ytimelle
TCP-porttiin 6666 binC$C$ripakettina, vai onko se koodarichatin seuraava
tyC6tehtC$vC$?

### Seuraava arkkitehtoninen siirto: Lukuputken sulkeminen (Read Pipeline)

Kun C-ydin on saanut tallennettua tuon rivin `ACTIVE_CHUNK` -rengaspuskuriinsa
`[cite: 1]`, olemme valmiita sulkemaan ympyrC$n. JC$rjestelmC$n pitC$C$ kyetC$
tarjoilemaan data takaisin alkuperC$iselle kysyjC$lle.

TC$mC$ tarkoittaa `READ_PIPELINE` -kokonaisuuden `[cite: 1]` viimeistelyC$
Proxy-tasolla:

1. Asiakas lC$hettC$C$ GET-pyynnC6n FastAPI:lle (esim. `GET /api/v1/row/42`).
2. FastAPI avaa TCP-yhteyden C-ytimeen ja pyytC$C$ rivin 42.
3. C-ydin palauttaa mikrosekunneissa binC$C$ristruktuurin (sisC$ltC$en
aikaleiman, lC$mpC6tilan ja SHA-256 -hashin).
4. **Uusi logiikka:** FastAPI huomaa, ettC$ rivillC$ on hash-osoitin. Se tekee
nopean luvun `/mnt/zfs-db/blobs/<hash>.blob` -tiedostoon, liittC$C$ tekstin
takaisin JSON-vastaukseen ja palauttaa sen asiakkaalle tC$ydellisenC$
pakettina.

NC$etkC6, ettC$ tC$mC$ lukuputken (Read Pipeline) loppuunvienti olisi
luonnollisin seuraava tavoite, vai haluatko mieluummin, ettC$ suorituspuoli
testaa ensin massiivista kirjoituskuormaa Proxy-kerroksen lC$pi (esim. satoja
tuhansia JSON-pyyntC6jC$) pullonkaulojen lC6ytC$miseksi?