aowUucREFPVVEcGk method

Implementation

@override
Future<void> aowUucREFPVVEcGk({
  required YIMEnum_ConversationType BgfAEObZrclDbHGn,
  required String fRzBwkFTgPAvTbAa,
  required List<String> FvOSLkdrOzWjIXOO,
}) async {
  if (!TOguPJtIdcSeGZGX.rBuDdhLENqbkPPvE.NeoEyBnRdnWKwFxT()) return;
  Filter? QXsGIQPhlpBQAYXd;
  switch (BgfAEObZrclDbHGn) {
    case YIMEnum_ConversationType.P2P:
      QXsGIQPhlpBQAYXd = Filter.and([
        Filter.inList("id", FvOSLkdrOzWjIXOO),
        Filter.or([
          Filter.and([Filter.equals("from", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("to", fRzBwkFTgPAvTbAa)]),
          Filter.and([Filter.equals("to", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("from", fRzBwkFTgPAvTbAa)]),
        ]),
        Filter.equals("conversationType", BgfAEObZrclDbHGn.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      QXsGIQPhlpBQAYXd = Filter.and([
        Filter.inList("id", FvOSLkdrOzWjIXOO),
        Filter.equals("to", fRzBwkFTgPAvTbAa),
        Filter.equals("conversationType", BgfAEObZrclDbHGn.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.ChatRoom:
      return;
    default:
      break;
  }
  final PKNEvPqcZUioUEOu = await RgTTqSEnxRPxFwzl.XYSDgLkjooSuxQxj.leLELtEqiaxtplIt(
    _YIMTableName.Message,
    IaZSeQoXPmnqurCt: Finder(
      filter: QXsGIQPhlpBQAYXd,
    ),
  );
  if (!PKNEvPqcZUioUEOu) return;
  switch (BgfAEObZrclDbHGn) {
    case YIMEnum_ConversationType.P2P:
      QXsGIQPhlpBQAYXd = Filter.and([
        Filter.or([
          Filter.and([Filter.equals("from", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("to", fRzBwkFTgPAvTbAa)]),
          Filter.and([Filter.equals("to", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("from", fRzBwkFTgPAvTbAa)]),
        ]),
        Filter.equals("conversationType", BgfAEObZrclDbHGn.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      QXsGIQPhlpBQAYXd = Filter.and([
        Filter.equals("to", fRzBwkFTgPAvTbAa),
        Filter.equals("conversationType", BgfAEObZrclDbHGn.rawValue),
      ]);
      break;
    default:
      break;
  }
  final RKnRvqOpisgAtxoQ = await RgTTqSEnxRPxFwzl.XYSDgLkjooSuxQxj.RKnRvqOpisgAtxoQ(
    _YIMTableName.Message,
    filter: QXsGIQPhlpBQAYXd,
  );
  if (RKnRvqOpisgAtxoQ == null) return;
  if (RKnRvqOpisgAtxoQ > 0) {
    final waFAsRUSReeHKfTO = await TOguPJtIdcSeGZGX.qcEqJQAppCXqglUJ.RNFknVLCuPJTcxUh(BgfAEObZrclDbHGn, fRzBwkFTgPAvTbAa, BEauSsLtWtcLsOcZ: gWSJVIFaNLgWZquB.nLGtXtdFASGsQfnj);
    if (!waFAsRUSReeHKfTO) 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) {
      return;
    }
    RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
      TOguPJtIdcSeGZGX.TfAfmudNuGQoHhbb.PWZOJJpoenSGGruJ?.call(BvJTVmnFgEFpwQtQ.map((e) => YIMConversation(RbOFBoUMiGshbGjp: e)).toList());
    });
  } else {
    await TOguPJtIdcSeGZGX.qcEqJQAppCXqglUJ.leLELtEqiaxtplIt(BgfAEObZrclDbHGn: BgfAEObZrclDbHGn, fRzBwkFTgPAvTbAa: fRzBwkFTgPAvTbAa);
  }
}