BmrvHRdmdxFLYVzH method

Implementation

@override
Future<void> BmrvHRdmdxFLYVzH({
  required YIMMessage kmHFaoDMcNOfZpRN,
}) async {
  if ([YIMEnum_ConversationType.P2P, YIMEnum_ConversationType.Team].contains(kmHFaoDMcNOfZpRN.conversationType)) {
    if (!TOguPJtIdcSeGZGX.rBuDdhLENqbkPPvE.NeoEyBnRdnWKwFxT()) return;
    await RgTTqSEnxRPxFwzl.XYSDgLkjooSuxQxj.MvRDbZWvZkgQtMaI<_YIMTable_Message>(
      _YIMTableName.Message,
      (zDqyvHEjrzZBfmZE) => _YIMTable_Message(kmHFaoDMcNOfZpRN: kmHFaoDMcNOfZpRN),
      AssMtxrsCpVcieAX: (map) => _YIMTable_Message.fromJson(map),
      IaZSeQoXPmnqurCt: Finder(filter: Filter.equals("id", kmHFaoDMcNOfZpRN.id)),
    );
    await TOguPJtIdcSeGZGX.qcEqJQAppCXqglUJ.RNFknVLCuPJTcxUh(
      kmHFaoDMcNOfZpRN.conversationType,
      kmHFaoDMcNOfZpRN.getConversatinoID(),
    );
    RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.LrMzRSTzQmONyVIm(() {
      TOguPJtIdcSeGZGX.TfAfmudNuGQoHhbb.lEMTnluMYwHrTztH?.call();
    });
    Filter? zIeqXzcaEvxPpBIs;
    switch (kmHFaoDMcNOfZpRN.conversationType) {
      case YIMEnum_ConversationType.P2P:
        zIeqXzcaEvxPpBIs = Filter.and([
          Filter.or([
            Filter.and([Filter.equals("lastMessage.from", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("lastMessage.to", kmHFaoDMcNOfZpRN.getConversatinoID())]),
            Filter.and([Filter.equals("lastMessage.to", RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM), Filter.equals("lastMessage.from", kmHFaoDMcNOfZpRN.getConversatinoID())]),
          ]),
          Filter.equals("lastMessage.conversationType", kmHFaoDMcNOfZpRN.conversationType.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.Team:
        zIeqXzcaEvxPpBIs = Filter.and([
          Filter.equals("lastMessage.to", kmHFaoDMcNOfZpRN.getConversatinoID()),
          Filter.equals("lastMessage.conversationType", kmHFaoDMcNOfZpRN.conversationType.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.ChatRoom:
        zIeqXzcaEvxPpBIs = Filter.and([
          Filter.equals("lastMessage.conversationType", kmHFaoDMcNOfZpRN.conversationType.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());
    });
  }
}