SpacetimeDB/crates/bindings-csharp/Runtime/Internal/IReducer.cs

namespace SpacetimeDB.Internal;

using System;
using System.Text;
using SpacetimeDB.BSATN;

public interface IReducerContext
{
    public static Identity GetDatabaseIdentity()
    {
        FFI.identity(out var identity);
        return identity;
    }

    [Obsolete("IReducerContext.GetIdentity() is deprecated. Use GetDatabaseIdentity() instead.")]
    public static Identity GetIdentity() => GetDatabaseIdentity();
}

public interface IReducer
{
    RawReducerDefV10 MakeReducerDef(ITypeRegistrar registrar);

    Lifecycle? Lifecycle { get; }

    // This one is not static because we need to be able to store IReducer in a list.
    void Invoke(BinaryReader reader, IReducerContext args);

    public static void VolatileNonatomicScheduleImmediate(string name, MemoryStream args)
    {
        var name_bytes = Encoding.UTF8.GetBytes(name);
        var args_bytes = args.ToArray();

        FFI.volatile_nonatomic_schedule_immediate(
            name_bytes,
            (uint)name_bytes.Length,
            args_bytes,
            (uint)args_bytes.Length
        );
    }
}