FlBZIBxbDmRNAPzh method

  1. @override
Future<void> FlBZIBxbDmRNAPzh({
  1. required YIMEnum_ConversationType sZLnmTKeJUdmBFHE,
  2. required String DLwuDqfWcelSXXhD,
  3. bool USmIoDAtYYoPatIp = true,
  4. void OMKwYKeBBFVoTNBl(
    1. bool oTLKfnnymNCTXHML
    )?,
})
override

Implementation

@override
Future<void> FlBZIBxbDmRNAPzh({
  required YIMEnum_ConversationType sZLnmTKeJUdmBFHE,
  required String DLwuDqfWcelSXXhD,
  bool USmIoDAtYYoPatIp = true,
  void Function(bool oTLKfnnymNCTXHML)? OMKwYKeBBFVoTNBl,
}) async {
  Filter? TKUJvkDHgZbFgVJv;
  switch (sZLnmTKeJUdmBFHE) {
    case YIMEnum_ConversationType.P2P:
      TKUJvkDHgZbFgVJv = Filter.and([
        Filter.or([
          Filter.and([Filter.equals("lastMessage.from", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("lastMessage.to", DLwuDqfWcelSXXhD)]),
          Filter.and([Filter.equals("lastMessage.to", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("lastMessage.from", DLwuDqfWcelSXXhD)]),
        ]),
        Filter.equals("lastMessage.conversationType", sZLnmTKeJUdmBFHE.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      TKUJvkDHgZbFgVJv = Filter.and([
        Filter.equals("lastMessage.to", DLwuDqfWcelSXXhD),
        Filter.equals("lastMessage.conversationType", sZLnmTKeJUdmBFHE.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.ChatRoom:
      eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
        OMKwYKeBBFVoTNBl?.call(true);
      });
      return;
  }
  final BByVDaYVEweNgSCl = await eFtbLxhxTmdNVKuo.HsDBYdwzkEBPFhmJ.LUwlOqRgyVmlEiyp<_YIMTable_Conversation>(
    _YIMTableName.Conversation,
    sprgVkbCCQhGYFSK: (map) => _YIMTable_Conversation.fromJson(map),
    PldCyxtbMzvNSNom: Finder(filter: TKUJvkDHgZbFgVJv),
  );
  if (BByVDaYVEweNgSCl == null) {
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      OMKwYKeBBFVoTNBl?.call(false);
    });
    return;
  }
  if (BByVDaYVEweNgSCl.isEmpty) {
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      OMKwYKeBBFVoTNBl?.call(true);
    });
    return;
  }

  Future<void> VYJZMfkcfZlmPlDx() async {
    final FxTKgeVLVBXARWjH = await eFtbLxhxTmdNVKuo.HsDBYdwzkEBPFhmJ.zWWbrOUfBoaNWrhG<_YIMTable_Conversation>(
      _YIMTableName.Conversation,
      (bnHAuWDzwImIvsuL) => bnHAuWDzwImIvsuL!..unRead = 0,
      sprgVkbCCQhGYFSK: (map) => _YIMTable_Conversation.fromJson(map),
      PldCyxtbMzvNSNom: Finder(filter: TKUJvkDHgZbFgVJv),
    );
    if (!FxTKgeVLVBXARWjH) {
      eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
        OMKwYKeBBFVoTNBl?.call(false);
      });
      return;
    }
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      ptLoDBriUoBUHreo.CTCflLMwyPmjZPwH.vbkGgBUjJANFBecG?.call();
    });
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      ptLoDBriUoBUHreo.CTCflLMwyPmjZPwH.ILHvgzQbwdReWqoO?.call(BByVDaYVEweNgSCl.map((e) => YIMConversation(gxECQohXBcwxDNVO: e)).toList());
    });
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      OMKwYKeBBFVoTNBl?.call(true);
    });
  }

  if (!ptLoDBriUoBUHreo.uvWNunbGgtEdyNiW.otQyjQrYNfRgpyCy()) {
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      OMKwYKeBBFVoTNBl?.call(false);
    });
    return;
  }
  if (USmIoDAtYYoPatIp)
    eFtbLxhxTmdNVKuo.TRicabbJmwhKdzbv.jodencItUatiSpEH("clearUnreadCount", DEzbKDIBPJVTWSIB: {
      "conversationID": DLwuDqfWcelSXXhD,
      "conversationType": sZLnmTKeJUdmBFHE.rawValue,
    }, YzQRKyskQzveDVYH: (oTLKfnnymNCTXHML, OhXEEEJrHsRvZogG, iggZzorTFvICOSCL, PBMZMubGZDFjYEYt) async {
      if (!oTLKfnnymNCTXHML) {
        eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
          OMKwYKeBBFVoTNBl?.call(false);
        });
        return;
      }
      await VYJZMfkcfZlmPlDx();
    });
  else
    await VYJZMfkcfZlmPlDx();
}