fcs/lib/pages/carton/model/package_selection_model.dart

import 'dart:async';

import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:logging/logging.dart';

import '../../../domain/constants.dart';
import '../../../domain/entities/package.dart';
import '../../main/model/base_model.dart';

class PackageSelectionModel extends BaseModel {
  final log = Logger("PackageSelectionModel");
  // for search
  String query = "";
  int offset = 0;
  bool reachEnd = false;
  List<Package> packages = [];

  bool isLoading = false;

  // for default package
  DocumentSnapshot? _lastDocument;
  bool ended = false;

  List<Package> selectedPackageList = [];

  Timer? t;
  search(String term,
      {bool imm = false,
      required String shipmentId,
      required String senderId,
      required String consigneeId}) async {
    query = term;
    packages.clear();
    offset = 0;
    reachEnd = false;
    t?.cancel();
    t = Timer(Duration(milliseconds: imm ? 0 : 800), () async {
      await loadMoreSearch(
          term: term,
          shipmentId: shipmentId,
          consigneeId: consigneeId,
          senderId: senderId);
    });
  }

  Future<void> loadMoreSearch(
      {required String term,
      required String shipmentId,
      required String senderId,
      required String consigneeId}) async {
    if (term == "") {
      await _refresh(
          shipmentId: shipmentId, senderId: senderId, consigneeId: consigneeId);
      return;
    }
    // int rowPerPage = 21;
    // List<Carton> list = [];
    // SearchPara searchPara = SearchPara(filters: [], term: term);
    // isLoading = true;

    // var path =
    //     "/search/$cartons_collection/${searchPara.escapeTerm}/$rowPerPage/$offset/${searchPara.escapeFilters}";

    // var result = await requestAPI(path, "GET",
    //     token: await getToken(), url: Config.instance.searchURL);

    // if (result != null) {
    //   for (var row in result) {
    //     var item = ArtistExt.fromMapForSearch(row);
    //     list.add(item);
    //   }
    // }

    // for (var p in list) {
    //   selectedArtistList.contains(p)
    //       ? p.isSelected = true
    //       : p.isSelected = false;
    // }

    // artists.addAll(list);
    // offset += rowPerPage;
    // if (list.length < rowPerPage) {
    //   reachEnd = true;
    // }
    notifyListeners();
  }

  addDefaultPackages(
      {required String shipmentId,
      required String senderId,
      required String consigneeId}) async {
    packages.clear();
    await _refresh(
        shipmentId: shipmentId, senderId: senderId, consigneeId: consigneeId);
  }

  selectPackage(Package a) {
    if (a.isChecked) {
      selectedPackageList.add(a);
    } else {
      selectedPackageList.remove(a);
    }
  }

  Future<void> _refresh(
      {required String shipmentId,
      required String senderId,
      required String consigneeId}) async {
    packages.clear();
    _lastDocument = null;
    ended = false;
    await loadMoreData(
        shipmentId: shipmentId, senderId: senderId, consigneeId: consigneeId);
    notifyListeners();
  }

  Future<void> loadMoreData(
      {required String shipmentId,
      required String senderId,
      required String consigneeId}) async {
    int rowPerPage = 20;

    try {
      isLoading = true;
      String path = "/$packages_collection";
      Query query = FirebaseFirestore.instance
          .collection(path)
          // .where("fcs_shipment_id", isEqualTo: shipmentId)
          // .where("status", isEqualTo: package_processed_status)
          .where("user_id", whereIn: [senderId, consigneeId])
          .where("is_deleted", isEqualTo: false)
          .orderBy("created_date", descending: true);

      if (_lastDocument != null) {
        query = query.startAfterDocument(_lastDocument!);
      }

      QuerySnapshot querySnap = await query.limit(rowPerPage).get();

      if (querySnap.docs.isEmpty) return;
      _lastDocument = querySnap.docs[querySnap.docs.length - 1];

      List<Package> list = querySnap.docs.map((documentSnapshot) {
        var p = Package.fromMap(documentSnapshot.data() as Map<String, dynamic>,
            documentSnapshot.id);
        return p;
      }).toList();

      for (var p in list) {
        selectedPackageList.contains(p)
            ? p.isChecked = true
            : p.isChecked = false;
      }

      packages.addAll(list);
      if (list.length < rowPerPage) ended = true;
      notifyListeners();
    } catch (e) {
      log.warning("error:$e");
    } finally {
      isLoading = false;
    }
  }

  clearSelection() {
    selectedPackageList.clear();
    packages.clear();
    query = "";
  }
}