addContact method

Future<void> addContact(
  1. ChatContact contact,
  2. UserId userId
)

Adds the provided ChatContactId to the User.contacts with the specified UserId.

Intended to be invoked from ContactRepository, as RxUser has no events of its User.contacts list changes.

Implementation

Future<void> addContact(ChatContact contact, UserId userId) async {
  Log.debug('addContact($contact, $userId)', '$runtimeType');

  final DtoUser? dto = await _userLocal.read(userId);
  if (dto != null) {
    final NestedChatContact? existing = dto.value.contacts.firstWhereOrNull(
      (e) => e.id == contact.id,
    );

    if (existing == null) {
      dto.value.contacts.add(NestedChatContact.from(contact));
      await _userLocal.upsert(dto);
    } else if (existing.name != contact.name) {
      existing.name = contact.name;
      await _userLocal.upsert(dto);
    }
  }
}