updateItemInInfiniteQuery<T> method

void updateItemInInfiniteQuery<T>({
  1. required String keyPrefix,
  2. required dynamic matcher(
    1. T
    ),
  3. required dynamic updater(
    1. T
    ),
})

Find by the matcher and replace with the updater in all query cache results, that start with the keyPrefix, and are of type DAQInfiniteQueryResponse

Implementation

void updateItemInInfiniteQuery<T>({
  required String keyPrefix,
  required Function(T) matcher,
  required Function(T) updater,
}) {
  final allKeys = getKeysByPattern('${keyPrefix}_*');

  for (String key in allKeys) {
    final singleResponse = getValue(key);

    if (singleResponse is DAQInfiniteQueryResponse<T>?) {
      if (singleResponse == null) continue;

      final updatedItems = singleResponse.items.map<T>((item) {
        if (matcher(item)) {
          return updater(item);
        }
        return item;
      }).toList();

      final updatedResponse = singleResponse.copyWith(items: updatedItems);

      updateCache<DAQInfiniteQueryResponse<T>>(key, (prevResponse) {
        return updatedResponse;
      });

      //   addToCache<DAQInfiniteQueryResponse<T>>(key, updatedResponse);
    }
  }
}