pull method

@override Future<List<SyncRecord>> pull({ required String collection, DateTime? since, int? limit, int? offset, SyncFilter? filter, })

Pull data from backend with optional pagination and filtering

Parameters:

• collection: Collection name to pull from
• since: Only pull records modified after this timestamp
• limit: Maximum number of records to pull
• offset: Number of records to skip (for pagination)
• filter: Optional sync filter for selective synchronization

Implementation

@override
Future<List<SyncRecord>> pull({
  required String collection,
  DateTime? since,
  int? limit,
  int? offset,
  SyncFilter? filter,
}) async {
  dynamic query = client.from(collection).select();

  // Use filter's since if provided, otherwise use since parameter
  final effectiveSince = filter?.since ?? since;
  if (effectiveSince != null) {
    query = query.gt('updated_at', effectiveSince.toIso8601String());
  }

  // Apply filter where conditions
  if (filter?.where != null) {
    for (final entry in filter!.where!.entries) {
      // Supabase uses JSON operators for nested data
      query = query.eq('data->${entry.key}', entry.value);
    }
  }

  // Apply pagination - use filter's limit if provided
  final effectiveLimit = filter?.limit ?? limit;
  if (offset != null && effectiveLimit != null) {
    query = query.range(offset, offset + effectiveLimit - 1);
  } else if (effectiveLimit != null) {
    query = query.limit(effectiveLimit);
  }

  final response = await query;
  final List<dynamic> data = response as List<dynamic>;

  return data.map((item) {
    final record = item as Map<String, dynamic>;
    var recordData = record['data'] as Map<String, dynamic>;

    // Apply field filtering if specified
    if (filter != null) {
      recordData = filter.applyFieldFilter(recordData);
    }

    return SyncRecord(
      recordId: record['record_id'] as String,
      data: recordData,
      updatedAt: DateTime.parse(record['updated_at'] as String),
      version: record['version'] as int? ?? 1,
    );
  }).toList();
}