Automation

Ticaret için kurulmuş bir iş akışı motoru. Bir olay gelir — sipariş ödenir, ödeme başarısız olur, müşteri kaydolur — ve Lunixi sizin tasarladığınız akışı koşturur: koşullara göre dallanır, ödemeyi veya müşteriyi getirir, şablon render eder, kendi sağlayıcınız üzerinden e-posta ya da SMS gönderir.

n8n seviyesinde, ama ödeme ve ticaret yerlisi: tetikleyiciler kanonik commerce.* olaylarına eşlenir, lookup'lar doğrudan sizin ödeme ve aboneliklerinizden okur, her koşum idempotent, kiracı-yalıtımlı ve tam gözlemlenebilirdir.

Bir akış nasıl koşar

1. Tetikleyici — bir platform olayı, imzalı gelen webhook, cron zamanlaması ya da elle koşum akışı başlatır.
2. Çözümleme — motor akışın yayınlanmış sürümünü yükler (taslaklar asla yan etki üretmez).
3. Yürütme — grafiği düğüm düğüm gezer: koşullar dallanır, lookup'lar zenginleştirir, şablonlar render edilir, aksiyonlar gönderir.
4. Kayıt — her koşum, her düğüm denemesi ve her giden teslimat, redakte edilmiş ve sorgulanabilir bir olay olarak kaydedilir.

Tetikleyiciler

Bir akış dört kaynaktan biriyle başlar.

Kanonik ticaret olayları

Mağazadan gelen olaylar kanonik bir taksonomiye normalize edilir; böylece bir kez yazdığınız akış, kaynak platform ne olursa olsun çalışır:

Düğüm kataloğu

Akış, tipli düğümlerden oluşan bir grafiktir. Her düğüm girdisini {{ }} ifadeleriyle yukarı akıştan okur ve sonucunu, sonraki düğümlerin başvurabileceği bir saveAs değişkenine yazar.

Mantık ve kontrol

Veri

Aksiyonlar (yan etkili)

Düğümler arası veri referansı

Herhangi bir düğüm config alanı, çalışma zamanında çözülen değerleri araya yerleştirebilir:

{{ input.payload.order.total }}        // the triggering event
{{ vars.customer.email }}              // output a prior node saved
{{ nodes.lookup_pay.output.status }}   // a specific node's result

Tek başına {{ vars.customer }} ham nesneyi döndürür; bir metnin içine gömülü {{ }} ise değeri araya yerleştirir.

Kendi sağlayıcınızı getirin

send_email, send_sms ve send_invoice, sizin sağlayıcı hesabınızla ve sizin API anahtarınızla teslim eder — Lunixi araya bir gönderim servisi olarak girmez. Sağlayıcıyı bir kez bağlar, kimlik bilgisini kasada saklar ve herhangi bir düğümden referans verirsiniz.

Genel HTTP sağlayıcısı bir kaçış kapısıdır: listede olmayan herhangi bir sağlayıcı için isteğin tamamını (URL, metot, başlıklar, gövde) siz tanımlarsınız.

{
  "type": "send_email",
  "config": {
    "provider": "sendgrid",
    "apiKeySecretRef": "vault:sg_prod",
    "to": "{{ vars.customer.email }}",
    "templateId": "welcome_v2",
    "variables": { "name": "{{ vars.customer.firstName }}" },
    "saveAs": "emailResult"
  }
}

Akış motoru

Hızlı başlangıç

Akışı yönetim API'siyle kurun, simüle edin ve yayınlayın. Tüm yönetim çağrıları Bearer token kullanır (at_live_…); merchantId token'dan çözülür, gövdede asla gönderilmez.

# 1. Create a draft
curl https://api-gateway.lunixi.com/api/v1/automation/flows/draft \
  -H "Authorization: Bearer at_live_5f3e2b1a..." \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Welcome email on signup",
    "nodes": [ /* start → lookup_customer → send_email → stop */ ]
  }'
 
# 2. Validate, then dry-run simulate (no side effects)
curl https://api-gateway.lunixi.com/api/v1/automation/flows/{id}/simulate \
  -H "Authorization: Bearer at_live_5f3e2b1a..." \
  -d '{ "input": { "payload": { "customerId": "cus_123" } } }'
 
# 3. Publish (immutable version)
curl https://api-gateway.lunixi.com/api/v1/automation/flows/{id}/publish \
  -H "Authorization: Bearer at_live_5f3e2b1a..." -d '{}'
 
# 4. Manual run
curl https://api-gateway.lunixi.com/api/v1/automation/flows/{id}/run \
  -H "Authorization: Bearer at_live_5f3e2b1a..." \
  -d '{ "input": { "payload": { "customerId": "cus_123" } } }'

Gelen webhook'lar

Akışları mağazanızdan tetiklemek için bir entegrasyon kaydedersiniz; karşılığında imzalı bir giriş URL'si ve bir HMAC secret'ı (yalnız bir kez gösterilir) alırsınız. Olaylar şuraya gönderilir:

POST https://api-gateway.lunixi.com/api/v1/automation/integrations/{provider}/{integrationId}/events

Her istek imzayla doğrulanır — Bearer token yoktur:

SIG=$(printf '%s.%s' "$TS" "$BODY" \
  | openssl dgst -sha256 -hmac "$SIGNING_SECRET" -hex | sed 's/^.* //')
 
curl https://api-gateway.lunixi.com/api/v1/automation/integrations/wordpress/intg_123/events \
  -H "X-Automation-Signature: sha256=$SIG" \
  -H "X-Automation-Timestamp: $TS" \
  -d "$BODY"

Yanıt durumu sonucu yansıtır; böylece üretici tarafınız doğru yeniden deneyebilir: 202 kabul edildi, 200 kopya, 401 imza hatalı, 404 eşleşen akış yok, 409 nonce tekrarı, 413 gövde çok büyük, 429 hız limiti.

Güvenlik ve çok kiracılılık

Gözlemlenebilirlik

Her yüzey sorgulanabilir, redakte edilmiş ve merchant kapsamlıdır:

• Genel bakış — kayan pencerede koşum hacmi, başarı oranı, gecikme ve son hatalar.
• Koşum geçmişi — akış bazında koşumlar, düğüm düğüm ize kadar inilebilir.
• Tetikleyici olayları — gelen giriş kaydı.
• Konnektör teslimatları — giden HTTP kaydı.
• Denetim olayları — akış değişikliklerinin yalnız-ekleme izi.

{
  "runId": "run_01HV3K9X...",
  "flowId": "flow_8f2a9c",
  "status": "success",
  "latencyMs": 412,
  "path": ["start", "if", "lookup_customer", "send_email", "stop"],
  "nodes": [
    { "id": "lookup_customer", "status": "success" },
    { "id": "send_email", "status": "success", "output": { "delivered": true } }
  ]
}

İlgili

• Automation İş Akışları — uçtan uca çalışılmış akış örnekleri
• Payment Orchestrator — akışları tetikleyen ödeme olayları
• Fraud — gönderimleri ve aksiyonları risk sinyaline göre kapılandırın