Cache, offline və bir neçə mənbə

class ProfileRepositoryOfflineFirst implements ProfileRepository {
  ProfileRepositoryOfflineFirst({
    required ApiClientService api,
    required DatabaseService database,
  })  : _api = api,
        _database = database;

  final ApiClientService _api;          // remote service
  final DatabaseService _database;      // lokal service

  // ── OXUMA: Stream əsaslı (rəsmi sənədin optimal saydığı variant) ──
  @override
  Stream<UserProfile> watchProfile() async* {
    // 1) Lokal məlumat dərhal verilir — ekran boş qalmır.
    final local = await _database.fetchUserProfile();
    if (local != null) yield local;

    // 2) Sonra serverdən yenilənmiş məlumat.
    try {
      final remote = await _api.getUserProfile();
      await _database.updateUserProfile(remote);
      yield remote;
    } catch (_) {
      // Şəbəkə yoxdur: lokal məlumat artıq verilib, xəta udulur.
      // Lokal da yoxdursa, çağıran tərəf boş axın alır və bunu idarə edir.
      if (local == null) throw const NetworkFailure();
    }
  }

  // ── YAZMA: offline-first (əvvəlcə lokal, sonra server) ──
  @override
  Future<void> updateProfile(UserProfile profile) async {
    // 1) Lokal yazı dərhal baş verir → UI cavab verir, offline işləyir.
    //    Qeyd sinxron olmayan kimi işarələnir.
    await _database.updateUserProfile(
      profile.copyWith(synchronized: false),
    );

    // 2) Serverə göndərməyə cəhd.
    try {
      await _api.putUserProfile(profile);
      // Uğurlu: bayraq qaldırılır.
      await _database.updateUserProfile(
        profile.copyWith(synchronized: true),
      );
    } catch (_) {
      // Uğursuz: qeyd `synchronized: false` qalır və sonra göndəriləcək.
      // Bu, sənədin açıq qeyd etdiyi "müvəqqəti desinxronizasiya"dır.
    }
  }

  // ── SİNXRONİZASİYA: yalnız göndərilməmiş qeydlər ──
  @override
  Future<void> sync() async {
    final pending = await _database.fetchUnsynchronizedProfiles();
    for (final profile in pending) {
      try {
        await _api.putUserProfile(profile);
        await _database.updateUserProfile(
          profile.copyWith(synchronized: true),
        );
      } catch (_) {
        // Bu qeyd növbəti dəfəyə qalır; digərlərini dayandırmır.
      }
    }
  }
}