CqOvqFmESAloKhLa method

Implementation

@override
void CqOvqFmESAloKhLa({
  required YIMEnum_ConversationType BgfAEObZrclDbHGn,
  required String fRzBwkFTgPAvTbAa,
  void Function(bool HNMwGFsvIPdZudoP)? RpTfEMreuKahSHPQ,
}) {
  if (!TOguPJtIdcSeGZGX.rBuDdhLENqbkPPvE.NeoEyBnRdnWKwFxT()) {
    RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
      RpTfEMreuKahSHPQ?.call(false);
    });
    return;
  }
  RgTTqSEnxRPxFwzl.EuaPwsZVIqeyUiTs.zbgQyaSxTZRIXxzk("sendMessageReceipt", GlIXyNxjXRjKcoLX: {
    "conversationType": BgfAEObZrclDbHGn.rawValue,
    "conversationID": fRzBwkFTgPAvTbAa,
  }, rMjlZMNvtlJSxSWt: (HNMwGFsvIPdZudoP, BYjAdmrVoQXFvmBX, cbqBlPPvVikjecgS, YDevfGtnNcdOmnZK) async {
    if (!HNMwGFsvIPdZudoP) {
      RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
        RpTfEMreuKahSHPQ?.call(false);
      });
      return;
    }
    if ([YIMEnum_ConversationType.P2P, YIMEnum_ConversationType.Team].contains(BgfAEObZrclDbHGn)) {
      final eefnNiLIEupRyXVP = await rpcGzxzmwAGAbiws(
        BgfAEObZrclDbHGn,
        fRzBwkFTgPAvTbAa,
        true,
      );
      if (!eefnNiLIEupRyXVP) {
        RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
          RpTfEMreuKahSHPQ?.call(false);
        });
        return;
      }
      RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
        TOguPJtIdcSeGZGX.TfAfmudNuGQoHhbb.lEMTnluMYwHrTztH?.call();
      });
      Filter? zIeqXzcaEvxPpBIs;
      switch (BgfAEObZrclDbHGn) {
        case YIMEnum_ConversationType.P2P:
          zIeqXzcaEvxPpBIs = Filter.and([
            Filter.or([
              Filter.and([Filter.equals("lastMessage.from", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("lastMessage.to", fRzBwkFTgPAvTbAa)]),
              Filter.and([Filter.equals("lastMessage.to", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("lastMessage.from", fRzBwkFTgPAvTbAa)]),
            ]),
            Filter.equals("lastMessage.conversationType", BgfAEObZrclDbHGn.rawValue),
          ]);
          break;
        case YIMEnum_ConversationType.Team:
          zIeqXzcaEvxPpBIs = Filter.and([
            Filter.equals("lastMessage.to", fRzBwkFTgPAvTbAa),
            Filter.equals("lastMessage.conversationType", BgfAEObZrclDbHGn.rawValue),
          ]);
          break;
      }
      final BvJTVmnFgEFpwQtQ = await RgTTqSEnxRPxFwzl.XYSDgLkjooSuxQxj.mIfLIZlbruepMfyA<_YIMTable_Conversation>(
        _YIMTableName.Conversation,
        AssMtxrsCpVcieAX: (map) => _YIMTable_Conversation.fromJson(map),
        IaZSeQoXPmnqurCt: Finder(filter: zIeqXzcaEvxPpBIs),
      );
      if (BvJTVmnFgEFpwQtQ == null) {
        RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
          RpTfEMreuKahSHPQ?.call(false);
        });
        return;
      }
      RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
        TOguPJtIdcSeGZGX.TfAfmudNuGQoHhbb.PWZOJJpoenSGGruJ?.call(BvJTVmnFgEFpwQtQ.map((e) => YIMConversation(RbOFBoUMiGshbGjp: e)).toList());
      });
    }
    RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
      RpTfEMreuKahSHPQ?.call(true);
    });
  });
}