aKKajaTwoLkZzwoc method

Implementation

@override
void aKKajaTwoLkZzwoc({
  required YIMEnum_ConversationType TMhjsByyUuXcscSR,
  required String APZrxmPSOMdFqrhE,
  void Function(bool BYQhAOcHRUuLSvkg)? WeQhHiCFWrXRykFU,
}) {
  if (!UFWAGwHDnWMkeYVR.EPwtIwAAPGFWUsid.WPtNMuRLJwMSwfMW()) {
    LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
      WeQhHiCFWrXRykFU?.call(false);
    });
    return;
  }
  LLTqoNwdULMbTCMh.rkgLYlaZYATBeHZH.sEnkoxXAwuAQuaxN("sendMessageReceipt", mCBPWMvoUJveFdlV: {
    "conversationType": TMhjsByyUuXcscSR.rawValue,
    "conversationID": APZrxmPSOMdFqrhE,
  }, YDAPNnFGlbnwsGKD: (BYQhAOcHRUuLSvkg, IvMCaaSVIWcQArzH, oCgstdHjeFkEZJjg, cDeQIDiofjWaDrqG) async {
    if (!BYQhAOcHRUuLSvkg) {
      LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
        WeQhHiCFWrXRykFU?.call(false);
      });
      return;
    }
    if ([YIMEnum_ConversationType.P2P, YIMEnum_ConversationType.Team].contains(TMhjsByyUuXcscSR)) {
      final PaRmLOscFwBqYozV = await XVdMdqaGLUZlUzMl(
        TMhjsByyUuXcscSR,
        APZrxmPSOMdFqrhE,
        true,
      );
      if (!PaRmLOscFwBqYozV) {
        LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
          WeQhHiCFWrXRykFU?.call(false);
        });
        return;
      }
      LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
        UFWAGwHDnWMkeYVR.drSbAyhOZTsmWGTg.wFocFAyakMKTXEwq?.call();
      });
      Filter? RyDvVcXmnThgbKWY;
      switch (TMhjsByyUuXcscSR) {
        case YIMEnum_ConversationType.P2P:
          RyDvVcXmnThgbKWY = Filter.and([
            Filter.or([
              Filter.and([Filter.equals("lastMessage.from", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("lastMessage.to", APZrxmPSOMdFqrhE)]),
              Filter.and([Filter.equals("lastMessage.to", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("lastMessage.from", APZrxmPSOMdFqrhE)]),
            ]),
            Filter.equals("lastMessage.conversationType", TMhjsByyUuXcscSR.rawValue),
          ]);
          break;
        case YIMEnum_ConversationType.Team:
          RyDvVcXmnThgbKWY = Filter.and([
            Filter.equals("lastMessage.to", APZrxmPSOMdFqrhE),
            Filter.equals("lastMessage.conversationType", TMhjsByyUuXcscSR.rawValue),
          ]);
          break;
      }
      final ksHlUMCxsMwUBrvE = await LLTqoNwdULMbTCMh.fWmDEyWlYlSzIgZn.JHzMkZIpOnZbQRwO<_YIMTable_Conversation>(
        _YIMTableName.Conversation,
        KgQmNjCadrqeQjJE: (map) => _YIMTable_Conversation.fromJson(map),
        RaxVrYLTOIwElzzS: Finder(filter: RyDvVcXmnThgbKWY),
      );
      if (ksHlUMCxsMwUBrvE == null) {
        LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
          WeQhHiCFWrXRykFU?.call(false);
        });
        return;
      }
      LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
        UFWAGwHDnWMkeYVR.drSbAyhOZTsmWGTg.xwwJXzdAXRAijlBN?.call(ksHlUMCxsMwUBrvE.map((e) => YIMConversation(tmmBlSfEBRBRYXTr: e)).toList());
      });
    }
    LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
      WeQhHiCFWrXRykFU?.call(true);
    });
  });
}