LoguxNET.Client.Core 1.0.0

LoguxNET.Client.Core

Русская версия

Pure managed Logux Protocol v5 client library. Transport-agnostic, store-agnostic, works on any .NET runtime.

Target Framework

netstandard2.0 — compatible with .NET Framework 4.6.1+, .NET Core 2.0+, .NET 5–10, Xamarin, MAUI, Blazor, Unity.

Structure

LoguxNET.Client.Core/
├── LoguxClient.cs           Protocol v5 client (connect, sync, subscribe, auto-reconnect)
├── LoguxClientOptions.cs    Client configuration (NodeId, Token, timeouts, reconnect)
├── LoguxClientState.cs      State enum: Disconnected → Connecting → Sending → Synchronized
├── LoguxAction.cs           Action: type + JSON payload
├── LoguxMeta.cs             Metadata: id, time, added, sync flag
├── LoguxProtocol.cs         Protocol message serialization / deserialization (internal)
├── ILoguxTransport.cs       Transport abstraction (WebSocket, TCP, mock, etc.)
├── ILoguxStore.cs           Persistence abstraction (action log + sync counters)
└── InMemoryStore.cs         Default in-memory store implementation

Quick Start

using LoguxNET.Client;

var client = new LoguxClient(
    new LoguxClientOptions
    {
        NodeId = "user1:abc:0",
        Token  = "secret-token",
    },
    transport);  // your ILoguxTransport implementation

client.ActionReceived += (action, meta) =>
    Console.WriteLine($"[{action.Type}] {action.Json}");

client.StateChanged += state =>
    Console.WriteLine($"State: {state}");

await client.StartAsync();

LoguxClient

Public API

Events

Properties

State Machine

Disconnected → Connecting → Sending → Synchronized
     ↑              │           │           │
     └──────────────┴───────────┴───────────┘
                 (on disconnect / error)

LoguxClientOptions

LoguxAction

// Create with type only
var action = LoguxAction.Create("counter/inc");

// Create with payload
var action = LoguxAction.Create("posts/add", new { id = "1", title = "Hello" });

// Parse from JSON
var action = LoguxAction.FromJson("{\"type\":\"counter/inc\",\"value\":1}");

// Deserialize
var payload = action.Deserialize<MyPayload>();

ILoguxTransport

public interface ILoguxTransport
{
    bool IsConnected { get; }
    Task ConnectAsync(CancellationToken ct = default);
    Task DisconnectAsync(CancellationToken ct = default);
    Task SendAsync(string message, CancellationToken ct = default);

    event Action Connected;
    event Action<string> MessageReceived;
    event Action<Exception?> Disconnected;
    event Action<Exception> ErrorOccurred;
}

Provide your own implementation for WebSocket, TCP, in-memory (for tests), or any other transport.

ILoguxStore

public interface ILoguxStore
{
    Task<SyncState> GetLastSyncedAsync();
    Task SetLastSentAsync(long sent);
    Task SetLastReceivedAsync(long received);
    Task<long> GetLastAddedAsync();
    Task<long> AddAsync(LoguxAction action, LoguxMeta meta);
    Task<IReadOnlyList<LogEntry>> GetSyncableEntriesAsync(long sinceAdded);
}

Default: InMemoryStore (data lost on process exit). Implement your own for SQLite, IndexedDB, etc.

Features

• Auto-reconnect with exponential backoff
• Auto-resubscribe to channels after reconnect
• Resync unconfirmed actions after reconnect
• Clock-drift correction (FixTime)
• Keepalive ping/pong
• Response timeout detection