bBCnNVNpEtaDPQgS method

Implementation

@override
Future<void> bBCnNVNpEtaDPQgS({
  required YIMMessage LzYZgypaJvlVWNba,
}) async {
  if ([YIMEnum_ConversationType.P2P, YIMEnum_ConversationType.Team].contains(LzYZgypaJvlVWNba.conversationType)) {
    if (!UFWAGwHDnWMkeYVR.EPwtIwAAPGFWUsid.WPtNMuRLJwMSwfMW()) return;
    await LLTqoNwdULMbTCMh.fWmDEyWlYlSzIgZn.YBmRYDaAbsiKcUrK<_YIMTable_Message>(
      _YIMTableName.Message,
      (snASIbbnhGihRLOr) => _YIMTable_Message(LzYZgypaJvlVWNba: LzYZgypaJvlVWNba),
      KgQmNjCadrqeQjJE: (map) => _YIMTable_Message.fromJson(map),
      RaxVrYLTOIwElzzS: Finder(filter: Filter.equals("id", LzYZgypaJvlVWNba.id)),
    );
    await UFWAGwHDnWMkeYVR.uzkozbjuyYvNIrYu.wMubTEqkFbXrseOf(
      LzYZgypaJvlVWNba.conversationType,
      LzYZgypaJvlVWNba.getConversatinoID(),
    );
    LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
      UFWAGwHDnWMkeYVR.drSbAyhOZTsmWGTg.wFocFAyakMKTXEwq?.call();
    });
    Filter? RyDvVcXmnThgbKWY;
    switch (LzYZgypaJvlVWNba.conversationType) {
      case YIMEnum_ConversationType.P2P:
        RyDvVcXmnThgbKWY = Filter.and([
          Filter.or([
            Filter.and([Filter.equals("lastMessage.from", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("lastMessage.to", LzYZgypaJvlVWNba.getConversatinoID())]),
            Filter.and([Filter.equals("lastMessage.to", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("lastMessage.from", LzYZgypaJvlVWNba.getConversatinoID())]),
          ]),
          Filter.equals("lastMessage.conversationType", LzYZgypaJvlVWNba.conversationType.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.Team:
        RyDvVcXmnThgbKWY = Filter.and([
          Filter.equals("lastMessage.to", LzYZgypaJvlVWNba.getConversatinoID()),
          Filter.equals("lastMessage.conversationType", LzYZgypaJvlVWNba.conversationType.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.ChatRoom:
        RyDvVcXmnThgbKWY = Filter.and([
          Filter.equals("lastMessage.conversationType", LzYZgypaJvlVWNba.conversationType.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) return;
    LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
      UFWAGwHDnWMkeYVR.drSbAyhOZTsmWGTg.xwwJXzdAXRAijlBN?.call(ksHlUMCxsMwUBrvE.map((e) => YIMConversation(tmmBlSfEBRBRYXTr: e)).toList());
    });
  }
}