UzBNTmnyYLiVoGiK method

  1. @override
Future<void> UzBNTmnyYLiVoGiK({
  1. required YIMEnum_ConversationType TIVvnmucZCCCoXWZ,
  2. required String DdEJLInBukyevMKs,
  3. required List<String> TDAyyywicMtSIQVe,
})
override

Implementation

@override
Future<void> UzBNTmnyYLiVoGiK({
  required YIMEnum_ConversationType TIVvnmucZCCCoXWZ,
  required String DdEJLInBukyevMKs,
  required List<String> TDAyyywicMtSIQVe,
}) async {
  if (!UChfQaxIZXBHpDHw.njDzuTHDjwOofRwd.anPqdZrnWKekLPyp()) return;
  Filter? CtfXnnlMSVlkkRNg;
  switch (TIVvnmucZCCCoXWZ) {
    case YIMEnum_ConversationType.P2P:
      CtfXnnlMSVlkkRNg = Filter.and([
        Filter.inList("id", TDAyyywicMtSIQVe),
        Filter.or([
          Filter.and([Filter.equals("from", lnHdKoLeAXayLaTQ.wkoLiCQozKacYjmM), Filter.equals("to", DdEJLInBukyevMKs)]),
          Filter.and([Filter.equals("to", lnHdKoLeAXayLaTQ.wkoLiCQozKacYjmM), Filter.equals("from", DdEJLInBukyevMKs)]),
        ]),
        Filter.equals("conversationType", TIVvnmucZCCCoXWZ.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      CtfXnnlMSVlkkRNg = Filter.and([
        Filter.inList("id", TDAyyywicMtSIQVe),
        Filter.equals("to", DdEJLInBukyevMKs),
        Filter.equals("conversationType", TIVvnmucZCCCoXWZ.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.ChatRoom:
      return;
    default:
      break;
  }
  final mcEMIWcoAFUcNgLl = await lnHdKoLeAXayLaTQ.vByYuYitJBHbvUKL.bOVAkIDmBYLGsrST(
    _YIMTableName.Message,
    fnfSorwGDrYrXXrJ: Finder(
      filter: CtfXnnlMSVlkkRNg,
    ),
  );
  if (!mcEMIWcoAFUcNgLl) return;
  switch (TIVvnmucZCCCoXWZ) {
    case YIMEnum_ConversationType.P2P:
      CtfXnnlMSVlkkRNg = Filter.and([
        Filter.or([
          Filter.and([Filter.equals("from", lnHdKoLeAXayLaTQ.wkoLiCQozKacYjmM), Filter.equals("to", DdEJLInBukyevMKs)]),
          Filter.and([Filter.equals("to", lnHdKoLeAXayLaTQ.wkoLiCQozKacYjmM), Filter.equals("from", DdEJLInBukyevMKs)]),
        ]),
        Filter.equals("conversationType", TIVvnmucZCCCoXWZ.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      CtfXnnlMSVlkkRNg = Filter.and([
        Filter.equals("to", DdEJLInBukyevMKs),
        Filter.equals("conversationType", TIVvnmucZCCCoXWZ.rawValue),
      ]);
      break;
    default:
      break;
  }
  final fSZjgxfqRzThwulA = await lnHdKoLeAXayLaTQ.vByYuYitJBHbvUKL.fSZjgxfqRzThwulA(
    _YIMTableName.Message,
    filter: CtfXnnlMSVlkkRNg,
  );
  if (fSZjgxfqRzThwulA == null) return;
  if (fSZjgxfqRzThwulA > 0) {
    final mcEPlVXzTebdsxXZ = await UChfQaxIZXBHpDHw.VurOaXdcuMhmFxOY.PZljnyQTHQWpRuih(TIVvnmucZCCCoXWZ, DdEJLInBukyevMKs, IpnvQLcAhgIkPBhZ: ghgUnqfoANgJzhoD.iqOiYjPAbyqWkkFy);
    if (!mcEPlVXzTebdsxXZ) return;
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      UChfQaxIZXBHpDHw.hTyLGxoJhBOoadid.zYXHYCxBRzMmefXt?.call();
    });
    Filter? PViwEfkxnHthuFaW;
    switch (TIVvnmucZCCCoXWZ) {
      case YIMEnum_ConversationType.P2P:
        PViwEfkxnHthuFaW = Filter.and([
          Filter.or([
            Filter.and([Filter.equals("lastMessage.from", lnHdKoLeAXayLaTQ.wkoLiCQozKacYjmM), Filter.equals("lastMessage.to", DdEJLInBukyevMKs)]),
            Filter.and([Filter.equals("lastMessage.to", lnHdKoLeAXayLaTQ.wkoLiCQozKacYjmM), Filter.equals("lastMessage.from", DdEJLInBukyevMKs)]),
          ]),
          Filter.equals("lastMessage.conversationType", TIVvnmucZCCCoXWZ.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.Team:
        PViwEfkxnHthuFaW = Filter.and([
          Filter.equals("lastMessage.to", DdEJLInBukyevMKs),
          Filter.equals("lastMessage.conversationType", TIVvnmucZCCCoXWZ.rawValue),
        ]);
        break;
    }
    final dtmfXZcFGyRKHKIm = await lnHdKoLeAXayLaTQ.vByYuYitJBHbvUKL.uKKZjqnYwajOojnf<_YIMTable_Conversation>(
      _YIMTableName.Conversation,
      kXTnRNGoMYqcQtxj: (map) => _YIMTable_Conversation.fromJson(map),
      fnfSorwGDrYrXXrJ: Finder(filter: PViwEfkxnHthuFaW),
    );
    if (dtmfXZcFGyRKHKIm == null) {
      return;
    }
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      UChfQaxIZXBHpDHw.hTyLGxoJhBOoadid.rMqppijxSRmKvvLu?.call(dtmfXZcFGyRKHKIm.map((e) => YIMConversation(BXiYJGYbkPLwuERt: e)).toList());
    });
  } else {
    await UChfQaxIZXBHpDHw.VurOaXdcuMhmFxOY.bOVAkIDmBYLGsrST(TIVvnmucZCCCoXWZ: TIVvnmucZCCCoXWZ, DdEJLInBukyevMKs: DdEJLInBukyevMKs);
  }
}