ptmJKBttbJggXLUw method

Implementation

@override
Future<void> ptmJKBttbJggXLUw({
  required YIMEnum_ConversationType TMhjsByyUuXcscSR,
  required String APZrxmPSOMdFqrhE,
  required List<String> lmdSACzMyAcmOhjq,
}) async {
  if (!UFWAGwHDnWMkeYVR.EPwtIwAAPGFWUsid.WPtNMuRLJwMSwfMW()) return;
  Filter? LebqekJGWsJVYQvG;
  switch (TMhjsByyUuXcscSR) {
    case YIMEnum_ConversationType.P2P:
      LebqekJGWsJVYQvG = Filter.and([
        Filter.inList("id", lmdSACzMyAcmOhjq),
        Filter.or([
          Filter.and([Filter.equals("from", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("to", APZrxmPSOMdFqrhE)]),
          Filter.and([Filter.equals("to", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("from", APZrxmPSOMdFqrhE)]),
        ]),
        Filter.equals("conversationType", TMhjsByyUuXcscSR.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      LebqekJGWsJVYQvG = Filter.and([
        Filter.inList("id", lmdSACzMyAcmOhjq),
        Filter.equals("to", APZrxmPSOMdFqrhE),
        Filter.equals("conversationType", TMhjsByyUuXcscSR.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.ChatRoom:
      return;
    default:
      break;
  }
  final trdscMaeTAtpaHuT = await LLTqoNwdULMbTCMh.fWmDEyWlYlSzIgZn.CUaYUjqiPzvKsgVw(
    _YIMTableName.Message,
    RaxVrYLTOIwElzzS: Finder(
      filter: LebqekJGWsJVYQvG,
    ),
  );
  if (!trdscMaeTAtpaHuT) return;
  switch (TMhjsByyUuXcscSR) {
    case YIMEnum_ConversationType.P2P:
      LebqekJGWsJVYQvG = Filter.and([
        Filter.or([
          Filter.and([Filter.equals("from", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("to", APZrxmPSOMdFqrhE)]),
          Filter.and([Filter.equals("to", LLTqoNwdULMbTCMh.IemXKsVNcGUWeUgJ), Filter.equals("from", APZrxmPSOMdFqrhE)]),
        ]),
        Filter.equals("conversationType", TMhjsByyUuXcscSR.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      LebqekJGWsJVYQvG = Filter.and([
        Filter.equals("to", APZrxmPSOMdFqrhE),
        Filter.equals("conversationType", TMhjsByyUuXcscSR.rawValue),
      ]);
      break;
    default:
      break;
  }
  final SgNaxYQfLxOCnKld = await LLTqoNwdULMbTCMh.fWmDEyWlYlSzIgZn.SgNaxYQfLxOCnKld(
    _YIMTableName.Message,
    filter: LebqekJGWsJVYQvG,
  );
  if (SgNaxYQfLxOCnKld == null) return;
  if (SgNaxYQfLxOCnKld > 0) {
    final lJJHuNCxLYuccEFO = await UFWAGwHDnWMkeYVR.uzkozbjuyYvNIrYu.wMubTEqkFbXrseOf(TMhjsByyUuXcscSR, APZrxmPSOMdFqrhE, uiHyFYalrgOKbWFH: HWeWyeCJyQtwlSNl.iibmzSFBvlultFXg);
    if (!lJJHuNCxLYuccEFO) 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) {
      return;
    }
    LLTqoNwdULMbTCMh.DwbTkDIljwhCkWxz.KuzgoGyXoqDTCcrr(() {
      UFWAGwHDnWMkeYVR.drSbAyhOZTsmWGTg.xwwJXzdAXRAijlBN?.call(ksHlUMCxsMwUBrvE.map((e) => YIMConversation(tmmBlSfEBRBRYXTr: e)).toList());
    });
  } else {
    await UFWAGwHDnWMkeYVR.uzkozbjuyYvNIrYu.CUaYUjqiPzvKsgVw(TMhjsByyUuXcscSR: TMhjsByyUuXcscSR, APZrxmPSOMdFqrhE: APZrxmPSOMdFqrhE);
  }
}