dyYObqQjtCtNbScf method

  1. @override
Future<void> dyYObqQjtCtNbScf({
  1. required YIMEnum_ConversationType TIVvnmucZCCCoXWZ,
  2. required String DdEJLInBukyevMKs,
  3. bool yxhkFPnlUSgfKznc = true,
  4. void dFOzKXrUQFAiVUMV(
    1. bool IWxelvVBXdhLiYGw
    )?,
})
override

Implementation

@override
Future<void> dyYObqQjtCtNbScf({
  required YIMEnum_ConversationType TIVvnmucZCCCoXWZ,
  required String DdEJLInBukyevMKs,
  bool yxhkFPnlUSgfKznc = true,
  void Function(bool IWxelvVBXdhLiYGw)? dFOzKXrUQFAiVUMV,
}) async {
  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;
    case YIMEnum_ConversationType.ChatRoom:
      lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
        dFOzKXrUQFAiVUMV?.call(true);
      });
      return;
  }
  final dtmfXZcFGyRKHKIm = await lnHdKoLeAXayLaTQ.vByYuYitJBHbvUKL.uKKZjqnYwajOojnf<_YIMTable_Conversation>(
    _YIMTableName.Conversation,
    kXTnRNGoMYqcQtxj: (map) => _YIMTable_Conversation.fromJson(map),
    fnfSorwGDrYrXXrJ: Finder(filter: PViwEfkxnHthuFaW),
  );
  if (dtmfXZcFGyRKHKIm == null) {
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      dFOzKXrUQFAiVUMV?.call(false);
    });
    return;
  }
  if (dtmfXZcFGyRKHKIm.isEmpty) {
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      dFOzKXrUQFAiVUMV?.call(true);
    });
    return;
  }

  Future<void> HICtEsPqpJhvRxyB() async {
    final eCwqNHFuvuJLmpqA = await lnHdKoLeAXayLaTQ.vByYuYitJBHbvUKL.wWZGwmhKzGRaHief<_YIMTable_Conversation>(
      _YIMTableName.Conversation,
      (LxGZqXAMduWvarPc) => LxGZqXAMduWvarPc!..unRead = 0,
      kXTnRNGoMYqcQtxj: (map) => _YIMTable_Conversation.fromJson(map),
      fnfSorwGDrYrXXrJ: Finder(filter: PViwEfkxnHthuFaW),
    );
    if (!eCwqNHFuvuJLmpqA) {
      lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
        dFOzKXrUQFAiVUMV?.call(false);
      });
      return;
    }
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      UChfQaxIZXBHpDHw.hTyLGxoJhBOoadid.zYXHYCxBRzMmefXt?.call();
    });
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      UChfQaxIZXBHpDHw.hTyLGxoJhBOoadid.rMqppijxSRmKvvLu?.call(dtmfXZcFGyRKHKIm.map((e) => YIMConversation(BXiYJGYbkPLwuERt: e)).toList());
    });
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      dFOzKXrUQFAiVUMV?.call(true);
    });
  }

  if (!UChfQaxIZXBHpDHw.njDzuTHDjwOofRwd.anPqdZrnWKekLPyp()) {
    lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
      dFOzKXrUQFAiVUMV?.call(false);
    });
    return;
  }
  if (yxhkFPnlUSgfKznc)
    lnHdKoLeAXayLaTQ.IDteDTVOmCXMeoaZ.xAbmkiHIVdSWVdsf("clearUnreadCount", JUQwIovWWbGEtXed: {
      "conversationID": DdEJLInBukyevMKs,
      "conversationType": TIVvnmucZCCCoXWZ.rawValue,
    }, jCuQmdbQKfCyjgLe: (IWxelvVBXdhLiYGw, iRnmzMAYPMjltgiU, RIJJEwowWZYrUgoB, ojKzdeKHBwmcEOBz) async {
      if (!IWxelvVBXdhLiYGw) {
        lnHdKoLeAXayLaTQ.hqSwzyClHgtHzAja.bhMrnZZKiorcTBJp(() {
          dFOzKXrUQFAiVUMV?.call(false);
        });
        return;
      }
      await HICtEsPqpJhvRxyB();
    });
  else
    await HICtEsPqpJhvRxyB();
}