Web için yazılmış
bir scripting dili.

# Hub: tüm bağlantıların ortak yayın kanalı (setup fazında)
$hub = channel();

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

    # Her bağlantı için bir goroutine: hub'dan dinle → bu client'a yaz
    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("Bağlantı kapandı — aktif: " . ws::clients());
    });
});

# Keepalive ping — her 30 saniyede tüm clientlara
timer::every(30000, function() {
    ws::broadcast(json::encode(["type" => "ping"]));
});

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

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

    $ch = channel(3);   # 3 sonuç beklenecek

    parallel(function() use ($ch, $conn) {
        send($ch, db::col($conn, "SELECT count(*) FROM siparisler", []));
    });
    parallel(function() use ($ch, $conn) {
        send($ch, db::col($conn, "SELECT sum(toplam) FROM siparisler WHERE durum='odendi'", []));
    });
    parallel(function() use ($ch, $conn) {
        send($ch, db::col($conn, "SELECT count(*) FROM kullanicilar WHERE aktif=1", []));
    });

    # Tüm goroutine'ler bitmeden devam etmez
    $siparisler  = receive($ch);
    $gelir       = receive($ch);
    $kullanicilar = receive($ch);

    print(json::encode([
        "siparisler"   => $siparisler,
        "gelir"        => $gelir,
        "kullanicilar" => $kullanicilar
    ]));
});

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

# SSE: tarayıcı bağlandığında sürekli veri akışı gönderilir
route("SSE", "/canli/siparisler", function($sse) use ($conn) {

    # Her 2 saniyede yeni sipariş kontrolü
    $tick = timer::every(2000, function() use ($sse, $conn) {
        $yeni = db::query($conn,
            "SELECT * FROM siparisler WHERE olusturma > date_sub(now(), interval 5 second)", []);
        if (count($yeni) > 0) {
            $ok = sse::send($sse, json::encode($yeni), "yeni_siparis");
            if (!$ok) { timer::cancel($tick); }   # bağlantı kapandı
        }
    });

    # 30s keepalive — tarayıcı timeout etmesin
    $ping = timer::every(30000, function() use ($sse) {
        sse::send($sse, "keepalive", "ping");
    });

    sse::on($sse, "close", function() use ($tick, $ping) {
        timer::cancel($tick);
        timer::cancel($ping);
        log::info("SSE kapandı — aktif: " . sse::clients());
    });
});

use jobs;
use mail;

# Route: isteği anında yanıtla (1ms), 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"]]);

    # max 3 deneme, hemen işle (delay_sec=0)
    jobs::push("hosgeldin_email", ["to" => $data["email"], "ad" => $data["ad"]], 3, 0);

    # 10 dakika sonra hatırlatma maili
    jobs::push("hatirlatma_email", ["to" => $data["email"]], 3, 600);

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

# worker.lk — ayrı process (systemd servis olarak çalışır)
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), sonra dead-letter
});

jobs::run(5000);   # 5 saniyede bir poll

use template;

# Struct — Go stili, method yok, sadece veri
struct Yazi {
    id
    baslik
    icerik
    tarih
    begeni: 0
    yayinda: true
}

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

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


# views/blog/index.html — sunucu taraflı, JS yok
# {#extends "views/layout/base"}
# {#block "content"}
# {#each $yazilar as $y}
#   <article>
#     <h2>{$y.baslik}</h2>
#     <p>{$y.tarih} · {$y.begeni} beğeni</p>
#     <div>{!$y.icerik}</div>
#   </article>
# {/each}
# {#empty}<p>Henüz yazı yok.</p>{/each}
# {/block}