hNKDrlqhNSIWnZUU method

Implementation

@override
Future<void> hNKDrlqhNSIWnZUU({
  required YIMEnum_ConversationType sZLnmTKeJUdmBFHE,
  required String DLwuDqfWcelSXXhD,
  required List<String> qziDnancOrFLXEnw,
}) async {
  if (!ptLoDBriUoBUHreo.uvWNunbGgtEdyNiW.otQyjQrYNfRgpyCy()) return;
  Filter? tTliTnHJVQHQfYah;
  switch (sZLnmTKeJUdmBFHE) {
    case YIMEnum_ConversationType.P2P:
      tTliTnHJVQHQfYah = Filter.and([
        Filter.inList("id", qziDnancOrFLXEnw),
        Filter.or([
          Filter.and([Filter.equals("from", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("to", DLwuDqfWcelSXXhD)]),
          Filter.and([Filter.equals("to", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("from", DLwuDqfWcelSXXhD)]),
        ]),
        Filter.equals("conversationType", sZLnmTKeJUdmBFHE.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      tTliTnHJVQHQfYah = Filter.and([
        Filter.inList("id", qziDnancOrFLXEnw),
        Filter.equals("to", DLwuDqfWcelSXXhD),
        Filter.equals("conversationType", sZLnmTKeJUdmBFHE.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.ChatRoom:
      return;
    default:
      break;
  }
  final XPanlJwxrORLopWk = await eFtbLxhxTmdNVKuo.HsDBYdwzkEBPFhmJ.gJFpokRUWVWhCZRg(
    _YIMTableName.Message,
    PldCyxtbMzvNSNom: Finder(
      filter: tTliTnHJVQHQfYah,
    ),
  );
  if (!XPanlJwxrORLopWk) return;
  switch (sZLnmTKeJUdmBFHE) {
    case YIMEnum_ConversationType.P2P:
      tTliTnHJVQHQfYah = Filter.and([
        Filter.or([
          Filter.and([Filter.equals("from", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("to", DLwuDqfWcelSXXhD)]),
          Filter.and([Filter.equals("to", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("from", DLwuDqfWcelSXXhD)]),
        ]),
        Filter.equals("conversationType", sZLnmTKeJUdmBFHE.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      tTliTnHJVQHQfYah = Filter.and([
        Filter.equals("to", DLwuDqfWcelSXXhD),
        Filter.equals("conversationType", sZLnmTKeJUdmBFHE.rawValue),
      ]);
      break;
    default:
      break;
  }
  final imJcUbKexoRWPKuV = await eFtbLxhxTmdNVKuo.HsDBYdwzkEBPFhmJ.imJcUbKexoRWPKuV(
    _YIMTableName.Message,
    filter: tTliTnHJVQHQfYah,
  );
  if (imJcUbKexoRWPKuV == null) return;
  if (imJcUbKexoRWPKuV > 0) {
    final MaHGdkWWOVttEAeS = await ptLoDBriUoBUHreo.PDCrHbGmsBdFRajZ.seQaUCGGFYuCERMG(sZLnmTKeJUdmBFHE, DLwuDqfWcelSXXhD, BtkEDcyLJWFVWCMk: VeUEakwqWzqKWGlo.KMIeRFEKPykTWKrk);
    if (!MaHGdkWWOVttEAeS) return;
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      ptLoDBriUoBUHreo.CTCflLMwyPmjZPwH.vbkGgBUjJANFBecG?.call();
    });
    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;
    }
    final BByVDaYVEweNgSCl = await eFtbLxhxTmdNVKuo.HsDBYdwzkEBPFhmJ.LUwlOqRgyVmlEiyp<_YIMTable_Conversation>(
      _YIMTableName.Conversation,
      sprgVkbCCQhGYFSK: (map) => _YIMTable_Conversation.fromJson(map),
      PldCyxtbMzvNSNom: Finder(filter: TKUJvkDHgZbFgVJv),
    );
    if (BByVDaYVEweNgSCl == null) {
      return;
    }
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      ptLoDBriUoBUHreo.CTCflLMwyPmjZPwH.ILHvgzQbwdReWqoO?.call(BByVDaYVEweNgSCl.map((e) => YIMConversation(gxECQohXBcwxDNVO: e)).toList());
    });
  } else {
    await ptLoDBriUoBUHreo.PDCrHbGmsBdFRajZ.gJFpokRUWVWhCZRg(sZLnmTKeJUdmBFHE: sZLnmTKeJUdmBFHE, DLwuDqfWcelSXXhD: DLwuDqfWcelSXXhD);
  }
}