init method

Implementation

void init() {
  fetchBlackList();

  // 断网重连，重新拉取数据

  subscriptions.add(NimCore.instance.loginService.onDataSync.listen((event) {
    if (event.type == NIMDataSyncType.nimDataSyncMain &&
        event.state == NIMDataSyncState.nimDataSyncStateCompleted) {
      fetchBlackList();
    }
  }));

  subscriptions
      .add(ContactRepo.registerBlockListRemovedObserver().listen((event) {
    blackListUsers.removeWhere((element) => event == element.accountId);
    notifyListeners();
  }));

  subscriptions
      .add(ContactRepo.registerBlockListAddedObserver().listen((event) {
    int index = blackListUsers
        .indexWhere((element) => element.accountId == event.accountId);
    if (index >= 0) {
      blackListUsers[index] = event;
    } else {
      blackListUsers.add(event);
    }
    notifyListeners();
  }));

  subscriptions
      .add(ContactRepo.registerFriendInfoChangedObserver().listen((event) {
    int index = blackListUsers
        .indexWhere((element) => element.accountId == event.accountId);
    if (index >= 0 && blackListUsers[index].name != event.alias) {
      blackListUsers[index].name = event.alias;
    }
    notifyListeners();
  }));

  subscriptions
      .add(ContactRepo.registerUserProfileChangedObserver().listen((event) {
    for (var e in event) {
      int index = blackListUsers
          .indexWhere((element) => element.accountId == e.accountId);
      if (index >= 0) {
        blackListUsers[index] = e;
      }
    }
    notifyListeners();
  }));
}