PHP gibi kur,
Go gibi yaz,
C++ gibi koş.

# --mode http ile çalışır
$hub = channel();   # broadcast kanalı

route("WS", "/chat", function($ws) use ($hub) {

    # Gelen mesajları bu client'a ilet
    parallel(function() use ($ws, $hub) {
        while (true) {
            $msg = receive($hub);
            if ($msg == null) { break; }
            ws::send($ws, $msg);
        }
    });

    # Mesaj gelince hub'a gönder → tüm clientlar duyar
    ws::on($ws, "message", function($data) use ($hub) {
        $p = json::decode($data);
        send($hub, json::encode([
            "from" => request::ip(),
            "msg"  => $p["msg"]
        ]));
    });

    ws::on($ws, "close", function() {
        log::info("Chat bağlantısı kapandı");
    });
});

# 30s keepalive ping — SSE ile aynı pattern
timer::every(30000, function() {
    ws::broadcast(json::encode(["type" => "ping"]));
});

$conn = db::connect("mysql://root:@127.0.0.1/qrmenu");

route("GET", "/panel/ozet", function() use ($conn) {

    # 3 sorguyu paralel çalıştır — toplam süre max(t1,t2,t3)
    $ch = channel(3);

    parallel(function() use ($ch, $conn) {
        send($ch, db::col($conn, "SELECT count(*) FROM firmalar", []));
    });
    parallel(function() use ($ch, $conn) {
        send($ch, db::col($conn, "SELECT count(*) FROM urunler", []));
    });
    parallel(function() use ($ch, $conn) {
        send($ch, db::col($conn, "SELECT count(*) FROM kategoriler", []));
    });

    $firmalar    = receive($ch);
    $urunler     = receive($ch);
    $kategoriler = receive($ch);

    print(json::encode([
        "firmalar"    => $firmalar,
        "urunler"     => $urunler,
        "kategoriler" => $kategoriler
    ]));
});

use jobs;
use mail;

# Route: isteği anında yanıtla, işi kuyruğa at
route("POST", "/kayit", function() use ($conn) {
    $data = request::json();
    db::exec($conn, "INSERT INTO kullanicilar (email,ad) VALUES (?,?)",
             [$data["email"], $data["ad"]]);

    # Kuyruğa at — max 3 deneme, hemen çalıştır
    jobs::push("hosgeldin_email", [
        "to" => $data["email"],
        "ad" => $data["ad"]
    ], 3, 0);

    print(json::encode(["ok" => true]));
});

# worker.lk — ayrı process (systemd servisi)
jobs::recover("hosgeldin_email");   # crash recovery

jobs::worker("hosgeldin_email", function($job) {
    $r = mail::send(
        $job["payload"]["to"],
        "Hoş geldiniz!",
        "Merhaba " . $job["payload"]["ad"] . ", kaydınız tamamlandı."
    );
    return $r["ok"];  # false → retry (max 3)
});
jobs::run(5000);   # 5 saniyede bir — blocking

use template;

struct Yazi {
    id
    baslik
    icerik
    tarih
    begeni: 0
}

$tpl = env("VIEWS_DIR", "/app/views");

route("GET", "/blog", function() use ($conn, $tpl) {
    $rows = db::query($conn, "SELECT * FROM yazilar", []);
    print(template::render($tpl . "/blog/index", [
        "baslik"  => "Blog",
        "yazilar" => $rows
    ]));
});

# views/blog/index.html:
# {#extends "views/layout/base"}
# {#block "content"}
# {#each $yazilar as $y}
#   <h2>{$y.baslik}</h2>
# {/each}
# {/block}