cDCrRRvlWwZqcZPg method

Implementation

@override
Future<void> cDCrRRvlWwZqcZPg({
  required YIMMessage mWEnrkpgWgfnODZg,
}) async {
  if ([YIMEnum_ConversationType.P2P, YIMEnum_ConversationType.Team].contains(mWEnrkpgWgfnODZg.conversationType)) {
    if (!ptLoDBriUoBUHreo.uvWNunbGgtEdyNiW.otQyjQrYNfRgpyCy()) return;
    await eFtbLxhxTmdNVKuo.HsDBYdwzkEBPFhmJ.zWWbrOUfBoaNWrhG<_YIMTable_Message>(
      _YIMTableName.Message,
      (bnHAuWDzwImIvsuL) => _YIMTable_Message(mWEnrkpgWgfnODZg: mWEnrkpgWgfnODZg),
      sprgVkbCCQhGYFSK: (map) => _YIMTable_Message.fromJson(map),
      PldCyxtbMzvNSNom: Finder(filter: Filter.equals("id", mWEnrkpgWgfnODZg.id)),
    );
    await ptLoDBriUoBUHreo.PDCrHbGmsBdFRajZ.seQaUCGGFYuCERMG(
      mWEnrkpgWgfnODZg.conversationType,
      mWEnrkpgWgfnODZg.getConversatinoID(),
    );
    eFtbLxhxTmdNVKuo.WeloVHMlcPVpCsCr.vUWyYsqBHvAmVrYc(() {
      ptLoDBriUoBUHreo.CTCflLMwyPmjZPwH.vbkGgBUjJANFBecG?.call();
    });
    Filter? TKUJvkDHgZbFgVJv;
    switch (mWEnrkpgWgfnODZg.conversationType) {
      case YIMEnum_ConversationType.P2P:
        TKUJvkDHgZbFgVJv = Filter.and([
          Filter.or([
            Filter.and([Filter.equals("lastMessage.from", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("lastMessage.to", mWEnrkpgWgfnODZg.getConversatinoID())]),
            Filter.and([Filter.equals("lastMessage.to", eFtbLxhxTmdNVKuo.hBYZOFteqhkvDgHA), Filter.equals("lastMessage.from", mWEnrkpgWgfnODZg.getConversatinoID())]),
          ]),
          Filter.equals("lastMessage.conversationType", mWEnrkpgWgfnODZg.conversationType.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.Team:
        TKUJvkDHgZbFgVJv = Filter.and([
          Filter.equals("lastMessage.to", mWEnrkpgWgfnODZg.getConversatinoID()),
          Filter.equals("lastMessage.conversationType", mWEnrkpgWgfnODZg.conversationType.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.ChatRoom:
        TKUJvkDHgZbFgVJv = Filter.and([
          Filter.equals("lastMessage.conversationType", mWEnrkpgWgfnODZg.conversationType.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());
    });
  }
}