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 iş parçacığı: 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 paralel işler bitmeden devam etmez
    $siparisler  = receive($ch)
    $gelir       = receive($ch)
    $kullanicilar = receive($ch)
    response::json([
        "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)
    response::json(["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}

# Terminal: look install github.com/Codlook/look-packages
use "pkg/jwt/jwt.lk"
use auth
use crypto
$conn = db::connect(env("DB_DSN", "mysql://root:@127.0.0.1/app"))
# Giriş — token üret
route("POST", "/api/giris", function() use ($conn) {
    $email = request::post("email") ?? ""
    $sifre = request::post("sifre") ?? ""
    $rows = db::query($conn, "SELECT * FROM users WHERE email=?", [$email])
    if (count($rows) == 0 || !auth::verify($sifre, $rows[0]["sifre_hash"])) {
        response::error(401, "Hatalı giriş")
        return
    }

    $token = jwt_sign(
        ["user_id" => $rows[0]["id"], "rol" => $rows[0]["rol"]],
        env("JWT_SECRET", ""),
        ["exp" => 86400]   # 24 saat
    )
    response::json(["ok" => true, "token" => $token])
})
# Korumalı endpoint — Bearer token zorunlu
function auth_required() {
    $header = request::header("Authorization") ?? ""
    $token  = string::substr($header, 7)  # "Bearer " kaldır
    $p = jwt_verify($token, env("JWT_SECRET", ""))
    if ($p == null) {
        response::json(["error" => "Geçersiz token"], 401)
        return null
    }
    return $p
}

route("GET", "/api/profil", function() use ($conn) {
    $user = auth_required()
    if ($user == null) { return }

    $rows = db::query($conn, "SELECT id,ad,email FROM users WHERE id=?", [$user["user_id"]])
    response::json(["ok" => true, "data" => $rows[0]])
})
# Webhook doğrulama — HMAC-SHA256 timing-safe
route("POST", "/webhook/odeme", function() {
    $payload  = request::body()
    $verilen  = request::header("X-Signature") ?? ""
    $beklenen = "sha256=" . crypto::hmac_sha256($payload, env("WEBHOOK_SECRET", ""))
    if (!crypto::constant_compare($verilen, $beklenen)) {
        response::status(401) return
    }
    # İmza geçerli — ödeme işlemi...
    response::json(["ok" => true])
})