Repository müqaviləsi: abstract sinif və asılılığın tərsinə çevrilməsi

// ══ lib/domain/repositories/order_repository.dart ══ (müqavilə)
import 'package:my_app/domain/models/order.dart';

// `abstract interface class`: yalnız `implements` — `extends` qadağandır.
abstract interface class OrderRepository {
  /// Cari istifadəçinin sifarişləri, ən yenisi əvvəldə.
  Future<List<Order>> fetchMine({int page = 1, int pageSize = 20});

  /// Bir sifariş. Tapılmadıqda `OrderNotFoundFailure` qaytarır.
  Future<Order> fetchById(String id);

  /// Sifarişi ləğv edir və yenilənmiş obyekti qaytarır.
  Future<Order> cancel(String id);

  /// Siyahının canlı axını — lokal cache dəyişdikdə də yenilənir.
  Stream<List<Order>> watchMine();
}

// ══ lib/data/repositories/order_repository_remote.dart ══ (məhsul rejimi)
class OrderRepositoryRemote implements OrderRepository {
  OrderRepositoryRemote({required OrderApiClient apiClient})
      : _apiClient = apiClient;

  final OrderApiClient _apiClient;
  final _controller = StreamController<List<Order>>.broadcast();

  @override
  Future<List<Order>> fetchMine({int page = 1, int pageSize = 20}) async {
    final dtos = await _apiClient.getOrders(page: page, limit: pageSize);
    final orders = dtos.map((d) => d.toDomain()).toList();
    _controller.add(orders);          // canlı axını da yeniləyir
    return orders;
  }

  @override
  Future<Order> fetchById(String id) async =>
      (await _apiClient.getOrder(id)).toDomain();

  @override
  Future<Order> cancel(String id) async =>
      (await _apiClient.cancelOrder(id)).toDomain();

  @override
  Stream<List<Order>> watchMine() => _controller.stream;
}

// ══ test/fakes/fake_order_repository.dart ══ (test rejimi)
class FakeOrderRepository implements OrderRepository {
  FakeOrderRepository(this._orders);
  List<Order> _orders;

  @override
  Future<List<Order>> fetchMine({int page = 1, int pageSize = 20}) async =>
      _orders;

  @override
  Future<Order> fetchById(String id) async =>
      _orders.firstWhere((o) => o.id == id);

  @override
  Future<Order> cancel(String id) async {
    final cancelled = (await fetchById(id))
        .copyWith(status: OrderStatus.cancelled);
    _orders = [
      for (final o in _orders) if (o.id == id) cancelled else o,
    ];
    return cancelled;
  }

  @override
  Stream<List<Order>> watchMine() => Stream.value(_orders);
}