dGIUyyShkAGrYEdE method

  1. @override
Future<void> dGIUyyShkAGrYEdE({
  1. required YIMEnum_ConversationType FhjdxBSxQMYGyidK,
  2. required String vINCQVmsnelWAFiE,
  3. required List<String> DvvMCPSuXjvOtLya,
})
override

Implementation

@override
Future<void> dGIUyyShkAGrYEdE({
  required YIMEnum_ConversationType FhjdxBSxQMYGyidK,
  required String vINCQVmsnelWAFiE,
  required List<String> DvvMCPSuXjvOtLya,
}) async {
  if (!iDxDuKoCRjwSpSnP.lUBagJdrpVTUiLlL.nJlQLbYMmygXrVIu()) return;
  Filter? gRbSnqfUMZGoixFM;
  switch (FhjdxBSxQMYGyidK) {
    case YIMEnum_ConversationType.P2P:
      gRbSnqfUMZGoixFM = Filter.and([
        Filter.inList("id", DvvMCPSuXjvOtLya),
        Filter.or([
          Filter.and([Filter.equals("from", pUedSqApqySLXfuk.HDRcNNpDAaYaKnho), Filter.equals("to", vINCQVmsnelWAFiE)]),
          Filter.and([Filter.equals("to", pUedSqApqySLXfuk.HDRcNNpDAaYaKnho), Filter.equals("from", vINCQVmsnelWAFiE)]),
        ]),
        Filter.equals("conversationType", FhjdxBSxQMYGyidK.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      gRbSnqfUMZGoixFM = Filter.and([
        Filter.inList("id", DvvMCPSuXjvOtLya),
        Filter.equals("to", vINCQVmsnelWAFiE),
        Filter.equals("conversationType", FhjdxBSxQMYGyidK.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.ChatRoom:
      return;
    default:
      break;
  }
  final QAcDYqZrYYtsqnGm = await pUedSqApqySLXfuk.ahWEMLhfSiuhBwFl.SeJaoOYwfIiXMvyG(
    _YIMTableName.Message,
    bNcvVipPUFFpNiXa: Finder(
      filter: gRbSnqfUMZGoixFM,
    ),
  );
  if (!QAcDYqZrYYtsqnGm) return;
  switch (FhjdxBSxQMYGyidK) {
    case YIMEnum_ConversationType.P2P:
      gRbSnqfUMZGoixFM = Filter.and([
        Filter.or([
          Filter.and([Filter.equals("from", pUedSqApqySLXfuk.HDRcNNpDAaYaKnho), Filter.equals("to", vINCQVmsnelWAFiE)]),
          Filter.and([Filter.equals("to", pUedSqApqySLXfuk.HDRcNNpDAaYaKnho), Filter.equals("from", vINCQVmsnelWAFiE)]),
        ]),
        Filter.equals("conversationType", FhjdxBSxQMYGyidK.rawValue),
      ]);
      break;
    case YIMEnum_ConversationType.Team:
      gRbSnqfUMZGoixFM = Filter.and([
        Filter.equals("to", vINCQVmsnelWAFiE),
        Filter.equals("conversationType", FhjdxBSxQMYGyidK.rawValue),
      ]);
      break;
    default:
      break;
  }
  final QgBzKiNpnHcBSCXv = await pUedSqApqySLXfuk.ahWEMLhfSiuhBwFl.QgBzKiNpnHcBSCXv(
    _YIMTableName.Message,
    filter: gRbSnqfUMZGoixFM,
  );
  if (QgBzKiNpnHcBSCXv == null) return;
  if (QgBzKiNpnHcBSCXv > 0) {
    final kNWClwNpWkhUiUnu = await iDxDuKoCRjwSpSnP.fzjbYoEllDvCcigm.VJhqgocOoZnovLIz(FhjdxBSxQMYGyidK, vINCQVmsnelWAFiE, gpNGjWdnIDwBNcoS: JKoIbQhNEBkeBGCn.LkZJIphaGhPJXKvT);
    if (!kNWClwNpWkhUiUnu) return;
    pUedSqApqySLXfuk.UdAwLgllDinVqLkg.JraVUDkLNAsqCzWV(() {
      iDxDuKoCRjwSpSnP.tAlpmicvlJCqimjh.UuYFyMelxcIiuATS?.call();
    });
    Filter? PczaErAOrgmnlYTK;
    switch (FhjdxBSxQMYGyidK) {
      case YIMEnum_ConversationType.P2P:
        PczaErAOrgmnlYTK = Filter.and([
          Filter.or([
            Filter.and([Filter.equals("lastMessage.from", pUedSqApqySLXfuk.HDRcNNpDAaYaKnho), Filter.equals("lastMessage.to", vINCQVmsnelWAFiE)]),
            Filter.and([Filter.equals("lastMessage.to", pUedSqApqySLXfuk.HDRcNNpDAaYaKnho), Filter.equals("lastMessage.from", vINCQVmsnelWAFiE)]),
          ]),
          Filter.equals("lastMessage.conversationType", FhjdxBSxQMYGyidK.rawValue),
        ]);
        break;
      case YIMEnum_ConversationType.Team:
        PczaErAOrgmnlYTK = Filter.and([
          Filter.equals("lastMessage.to", vINCQVmsnelWAFiE),
          Filter.equals("lastMessage.conversationType", FhjdxBSxQMYGyidK.rawValue),
        ]);
        break;
    }
    final RJJZEVUaxDvrzUJv = await pUedSqApqySLXfuk.ahWEMLhfSiuhBwFl.wanYqaCFigqxxdwW<_YIMTable_Conversation>(
      _YIMTableName.Conversation,
      BozapwVfDLDEsXet: (map) => _YIMTable_Conversation.fromJson(map),
      bNcvVipPUFFpNiXa: Finder(filter: PczaErAOrgmnlYTK),
    );
    if (RJJZEVUaxDvrzUJv == null) {
      return;
    }
    pUedSqApqySLXfuk.UdAwLgllDinVqLkg.JraVUDkLNAsqCzWV(() {
      iDxDuKoCRjwSpSnP.tAlpmicvlJCqimjh.WXBRvbiPvYYuBfEB?.call(RJJZEVUaxDvrzUJv.map((e) => YIMConversation(OxbmHPoYuPTpcmgT: e)).toList());
    });
  } else {
    await iDxDuKoCRjwSpSnP.fzjbYoEllDvCcigm.SeJaoOYwfIiXMvyG(FhjdxBSxQMYGyidK: FhjdxBSxQMYGyidK, vINCQVmsnelWAFiE: vINCQVmsnelWAFiE);
  }
}