adminandClaude Sonnet 5
5bd6967421
EventStore.Pull gab bisher den globalen ServerSeq-Höchststand als neuen Cursor zurück statt den höchsten unter den tatsächlich gelieferten Ereignissen - hatte ein Gerät selbst kurz zuvor etwas gepusht, sprang sein Pull-Cursor über noch nicht abgeholte Ereignisse anderer Geräte hinweg und verpasste sie dauerhaft, ohne jeden Fehler. Ersetzt außerdem die bisherige 30-Sekunden-Heuristik zur Konflikterkennung beim Push durch exakte BasedOnServerSeq-Prüfung: jedes SyncEvent trägt die ServerSeq, auf der es aufbaut: der Server lehnt ab, wenn der aktuelle Stand nicht mehr passt. Bei Ablehnung lädt der Client sofort den neuen Server-Stand nach, löst den Konflikt nach der bestehenden Desktop-vs-Companion/ Timestamp-Politik auf und macht ihn immer in der Konflikt-Review-UI sichtbar, statt die verworfene Änderung stillschweigend zu verlieren. Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
50 lines
2.1 KiB
C#
50 lines
2.1 KiB
C#
using LehrerApp.Sync.Models;
|
|
|
|
namespace LehrerApp.Sync;
|
|
|
|
/// <summary>
|
|
/// Desktop gewinnt gegen Companion.
|
|
/// Bei Gleichstand: späterer Timestamp gewinnt.
|
|
/// </summary>
|
|
public class ConflictResolver(EventQueue queue)
|
|
{
|
|
public ConflictEntry? TryResolve(SyncEvent remote, string localDeviceId)
|
|
{
|
|
var local = queue.GetPending()
|
|
.FirstOrDefault(e => e.EntityType == remote.EntityType
|
|
&& e.EntityId == remote.EntityId
|
|
&& e.DeviceId != remote.DeviceId);
|
|
if (local is null) return null;
|
|
|
|
var winner = DetermineWinner(local, remote);
|
|
|
|
if (winner == remote) queue.Acknowledge([local.EventId]);
|
|
|
|
return new ConflictEntry
|
|
{
|
|
LocalEvent = local,
|
|
RemoteEvent = remote,
|
|
Resolution = winner == local ? "LocalWon" : "RemoteWon",
|
|
};
|
|
}
|
|
|
|
/// <summary>
|
|
/// Desktop schlägt Companion; bei gleichem Gerätetyp gewinnt der spätere Timestamp. Auch von
|
|
/// SyncEngine für die Ablehnungsbehandlung eines per BasedOnServerSeq abgelehnten Push
|
|
/// genutzt — dieselbe Politik unabhängig davon, ob der Konflikt beim Pull (gleichzeitig
|
|
/// eingetroffenes fremdes Ereignis) oder erst durch eine Server-Ablehnung entdeckt wurde.
|
|
/// </summary>
|
|
public static SyncEvent DetermineWinner(SyncEvent local, SyncEvent remote) =>
|
|
(local.DeviceType, remote.DeviceType) switch
|
|
{
|
|
(DeviceType.Desktop, DeviceType.Companion) => local,
|
|
(DeviceType.Companion, DeviceType.Desktop) => remote,
|
|
// ToUniversalTime(): LiteDB liefert DateTime beim Auslesen aus der Queue als Kind=Local
|
|
// zurück (Ticks werden dabei um die lokale Zeitzone verschoben). DateTime-Vergleiche
|
|
// berücksichtigen Kind nicht, sondern vergleichen nur rohe Ticks — ein direkter Vergleich
|
|
// von local.Timestamp (Local, aus der Queue) mit remote.Timestamp (Utc, vom Server) wäre
|
|
// daher außerhalb von UTC+0 falsch.
|
|
_ => local.Timestamp.ToUniversalTime() >= remote.Timestamp.ToUniversalTime() ? local : remote,
|
|
};
|
|
}
|