rudder-csharp-sdk/Services/ScenarioService.cs

using System.Threading;
using System.Threading.Tasks;
using RudderSdk.Core.Models.Scenarios;

namespace RudderSdk.Core;

/// <summary>
/// Scenario trigger. Execution lives on the server; resulting effects surface
/// through <see cref="RudderClient.Effects"/>.
/// </summary>
public sealed class ScenarioService
{
    private readonly RudderClient _client;

    internal ScenarioService(RudderClient client) => _client = client;

    /// <summary>
    /// Triggers scenarios by event name. Returned pending effects are ingested
    /// into <see cref="RudderClient.Effects"/>.
    /// </summary>
    public async Task TriggerAsync(string eventName, CancellationToken cancellationToken = default)
    {
        var response = await _client.SendAsync<TriggerScenarioRequest, TriggerScenarioResponse>(
            "POST",
            "/sdk/v1/scenarios/trigger",
            new TriggerScenarioRequest { Event = eventName },
            cancellationToken).ConfigureAwait(false);

        _client.Effects.Ingest(response?.Effects);
    }
}