EventSource.cs

Go to the documentation of this file.

using System.Text.Json;
 
namespace Fauna.Types;
 
public sealed class EventSource : IEquatable<EventSource>
{
    internal string Token { get; }
 
    internal EventOptions Options { get; set; }
 
    public EventSource(string token)
    {
        Token = token;
        Options = new EventOptions();
    }
 
    public void Serialize(Stream stream)
    {
        var writer = new Utf8JsonWriter(stream);
        writer.WriteStartObject();
        writer.WriteString("token", Token);
        if (Options.Cursor != null)
        {
            writer.WriteString("cursor", Options.Cursor);
        }
        else if (Options.StartTs != null)
        {
            writer.WriteNumber("start_ts", Options.StartTs.Value);
        }
 
        if (Options.PageSize is > 0)
        {
            writer.WriteNumber("page_size", Options.PageSize.Value);
        }
 
        writer.WriteEndObject();
        writer.Flush();
    }
 
 
    public bool Equals(EventSource? other)
    {
        if (ReferenceEquals(null, other)) return false;
        if (ReferenceEquals(this, other)) return true;
        return Token == other.Token;
    }
 
    public override bool Equals(object? obj)
    {
        if (ReferenceEquals(null, obj)) return false;
        if (ReferenceEquals(this, obj)) return true;
        if (obj.GetType() != GetType()) return false;
        return Equals((EventSource)obj);
    }
 
    public override int GetHashCode()
    {
        return Token.GetHashCode();
    }
}
 
public class EventOptions
{
    public string? Cursor { get; internal set; }
 
    public long? StartTs { get; protected init; }
 
    public int? PageSize { get; protected init; }
}