pendingForEntity method

@override Future<List<SyncQueueEntry>> pendingForEntity(String table, String entityId)

Returns unsynced queue entries for the row identified by (table, entityId), ordered by created_at ASC. Used by the engine's pull pipeline to detect pending local edits that conflict with an incoming remote row. Added in 0.2.0.

Implementation

@override
Future<List<SyncQueueEntry>> pendingForEntity(
  String table,
  String entityId,
) async {
  final filtered = _queue
      .where((e) => !e.synced && e.table == table && e.entityId == entityId)
      .toList()
    ..sort((a, b) => a.createdAt.compareTo(b.createdAt));
  return filtered;
}