Signalbird.Sdk - .NET / ASP.NET Core

dotnet add package Signalbird.Sdk

// Program.cs
builder.Services.AddSignalbird(options =>
{
    options.DomainKey = builder.Configuration["Signalbird:RadioKey"]!;   // sb_secret_live_…
    options.Source = "api-01";
});

builder.Services.AddSignalbirdMessaging(options =>
    options.DomainKey = builder.Configuration["Signalbird:DomainKey"]!);    // sb_…

builder.Services.AddSignalbirdManagement(options =>
    options.DomainKey = builder.Configuration["Signalbird:DomainKey"]!);

var radio = new SignalbirdClient(new SignalbirdOptions { DomainKey = "sb_secret_live_…" });

public class PaymentService(SignalbirdClient signalbird)
{
    public async Task ChargeAsync(Order order, CancellationToken ct)
    {
        try
        {
            await _gateway.ChargeAsync(order, ct);

            await signalbird.InfoAsync("odeme", $"Sipariş #{order.Id} başarılı", ct: ct);
        }
        catch (Exception error)
        {
            await signalbird.CriticalAsync("critical", error.Message,
                new Dictionary<string, object?>
                {
                    ["order"] = order.Id,
                    ["gateway"] = "iyzico",
                }, ct);

            throw;   // Log göndermek hatayı yutmaz
        }
    }
}

await signalbird.BatchAsync(new[]
{
    new LogEvent { Channel = "deploy", Message = "v2.4.0 yayında", Level = SignalbirdLevel.Info },
    new LogEvent { Channel = "critical", Message = "kuyruk doldu" },
});

var result = await messaging.SendEmailAsync(new
{
    to = "ahmet@example.com",
    @class = "transactional",     // `class` ayrılmış sözcük - @ ile kaçılır
    subject = "Siparişiniz yola çıktı",
    body = "<p>Kargo takip no: 1234</p>",
});

if (!result.Ok)
{
    logger.LogWarning("signalbird: {Code} - {Message}", result.Code, result.Message);
}

await messaging.SendSmsAsync(new { to = "+905551112233", @class = "transactional", body = "Kodunuz: 123456" });
await messaging.PreviewSmsAsync("Merhaba, siparişiniz hazır.");   // kota harcamaz
await messaging.SendPushAsync(new { to = "contact:42", @class = "transactional", subject = "Sipariş", body = "Yola çıktı" });

await messaging.ListContactsAsync(new Dictionary<string, object?> { ["q"] = "ahmet" });
await messaging.CreateContactAsync(new { email = "ahmet@example.com", first_name = "Ahmet" });
await messaging.UpdateContactAsync(contactId, new { phone = "+905551112233" });
await messaging.DeleteContactAsync(contactId);

// 1000'lik parçalar, SIRAYLA
await messaging.BulkContactsAsync(rows, new Dictionary<string, object?>
{
    ["list_id"] = 42,
    ["consent_source"] = "web_form",
});

await messaging.CreateCampaignAsync(new
{
    name = "Ağustos bülteni",
    channel = "email",
    list_id = 42,
    subject = "Bu ay neler oldu?",
    body = "<h1>Merhaba</h1>",
});

// Sayfa sayfa gezer; tüm listeyi belleğe almaz
await foreach (var message in messaging.IterateCampaignMessagesAsync(batchId))
{
    Reconcile(message.GetProperty("external_ref").GetString());
}

// Program.cs - ham gövdeyi okuyabilmek için
app.Use(async (context, next) =>
{
    context.Request.EnableBuffering();
    await next();
});

// Controller
[HttpPost("/webhooks/signalbird")]
public async Task<IActionResult> Handle()
{
    Request.Body.Position = 0;
    using var reader = new StreamReader(Request.Body);
    var rawBody = await reader.ReadToEndAsync();

    // HAM gövde: modeli deserialize edip yeniden serialize etmek imzayı bozar
    if (!Webhook.Verify(rawBody, Request.Headers["X-Signalbird-Signature"], _secret))
    {
        return Unauthorized();
    }

    return Ok();
}

// Ortam kurulumu (deploy adımı ya da yönetim komutu)
var created = await management.CreateModuleKeyAsync("logger", new Dictionary<string, object?> { ["title"] = "Ödeme hataları" });

// `secret` YALNIZ burada döner; sunucuda yalnız özeti saklanır
var secret = created.Data?.GetProperty("secret").GetString();
var projectId = created.Data?.GetProperty("project").GetProperty("id").GetInt32();

await management.CreateRadioChannelAsync(projectId!, new
{
    key = "odeme",
    name = "Ödeme",
    level = "critical",
    notify_push = true,
    quiet_from = 0,
    quiet_to = 7,
});

// Sohbet gelen kutusu botu
var inbox = await management.ListConversationsAsync(
    new Dictionary<string, object?> { ["status"] = "open" });

await management.ReplyAsync(conversationId, new { body = "Merhaba! Birazdan dönüyoruz." });
await management.SetConversationStatusAsync(conversationId, "pending");

public sealed class SbResult
{
    public bool Ok { get; }
    public int Status { get; }
    public JsonElement? Data { get; }
    public string? Code { get; }
    public string? Message { get; }

    public T? Into<T>();     // gövdeyi tipinize çözer
}

var result = await management.GetAppAsync(id);

var app = result.Into<AppRecord>();

// SignalbirdClient DI'dan
var hash = signalbird.IdentityHash(user.Id);

identity_hash = hex( HMAC-SHA256( hex(SHA-256(sb_secret_live_…)), external_id ) )

dotnet add package Signalbird.Sdk