ZenQuery<T> constructor

Implementation

ZenQuery({
  required Object queryKey,
  required this.fetcher,
  ZenQueryConfig? config,
  this.initialData,
  this.scope,
  this.autoDispose = true,
  bool registerInCache = true,
  bool enabled = true,
})  : queryKey = QueryKey.normalize(queryKey),
      config = ZenQueryConfig.defaults.merge(config).cast<T>(),
      _registerInCache = registerInCache,
      enabled = RxBool(enabled) {
  // Set initial data if provided
  if (initialData != null) {
    data.value = initialData;
    status.value = ZenQueryStatus.success;
    // Don't set _lastFetchTime here - initial data should be considered stale
    // so that the first fetch() actually fetches fresh data
    _lastFetchTime = null;
  } else if (this.config.placeholderData != null) {
    data.value = this.config.placeholderData;
    status.value = ZenQueryStatus.success;
    isPlaceholderData.value = true;
  }

  // Register in cache (scope-aware or global)
  if (_registerInCache) {
    if (scope != null) {
      _registerInScope();
    } else {
      ZenQueryCache.instance.register(this);
    }
  }

  // Setup background refetch if enabled
  _setupBackgroundRefetch();

  // Setup enabled listener
  ZenWorkers.ever(this.enabled, (isEnabled) {
    if (isEnabled && !_isDisposed) {
      // When re-enabled, fetch if stale or idle
      if (isStale || status.value == ZenQueryStatus.idle) {
        fetch().then((_) {}, onError: (_) {});
      }
    }
  });

  _initData();
}