Repository implementation: the source of truth

class ProductRepositoryRemote implements ProductRepository {
  ProductRepositoryRemote({
    required ProductApiClient apiClient,
    Duration cacheTtl = const Duration(minutes: 5),
  })  : _apiClient = apiClient,
        _cacheTtl = cacheTtl;

  final ProductApiClient _apiClient;
  final Duration _cacheTtl;

  // Cache: məlumat + vaxt möhürü. Bu, repository-nin state-idir.
  List<Product>? _cache;
  DateTime? _cachedAt;

  // Paralel sorğuların birləşdirilməsi: eyni anda 3 ekran açılsa,
  // şəbəkəyə BİR sorğu gedir.
  Future<List<Product>>? _inFlight;

  final _controller = StreamController<List<Product>>.broadcast();

  bool get _isCacheFresh =>
      _cache != null &&
      _cachedAt != null &&
      DateTime.now().difference(_cachedAt!) < _cacheTtl;

  @override
  Future<List<Product>> fetchActive({bool forceRefresh = false}) {
    if (!forceRefresh && _isCacheFresh) return Future.value(_cache);
    return _inFlight ??= _load().whenComplete(() => _inFlight = null);
  }

  Future<List<Product>> _load() async {
    try {
      final dtos = await _apiClient.getActiveProducts();
      final products = dtos.map((dto) => dto.toDomain()).toList();

      _cache = products;
      _cachedAt = DateTime.now();
      _controller.add(products);          // dinləyiciləri xəbərdar edir
      return products;
    } on UnauthorizedException {
      // Texniki exception → domain dilinə çevrilir.
      throw const AuthFailure();
    } on SocketException {
      // Şəbəkə yoxdur: köhnə cache varsa, onu vermək daha yaxşıdır.
      final stale = _cache;
      if (stale != null) return stale;
      throw const NetworkFailure();
    }
  }

  @override
  Stream<List<Product>> watchActive() async* {
    if (_cache != null) yield _cache!;    // dərhal cache
    yield* _controller.stream;            // sonra yeniləmələr
  }

  @override
  Future<Product> fetchById(String id) async {
    // Cache-də varsa, şəbəkəyə çıxmır.
    final cached = _cache?.where((p) => p.id == id).firstOrNull;
    if (cached != null) return cached;
    return (await _apiClient.getProduct(id)).toDomain();
  }

  void dispose() => _controller.close();
}