Import Contacts from phone's contact book (#952)

android/app/src/main/AndroidManifest.xml

@@ -14,6 +14,7 @@
     <uses-permission android:name="android.permission.INTERNET"/>
     <uses-permission android:name="android.permission.MANAGE_OWN_CALLS"/>
     <uses-permission android:name="android.permission.MODIFY_AUDIO_SETTINGS" />
+    <uses-permission android:name="android.permission.READ_CONTACTS" />
     <uses-permission android:name="android.permission.READ_PHONE_NUMBERS" />
     <uses-permission android:name="android.permission.READ_PHONE_STATE" android:maxSdkVersion="29" />
     <uses-permission android:name="android.permission.RECORD_AUDIO" />

ios/Runner/Info.plist

@@ -58,9 +58,11 @@
   <string>We need access to your microphone to record it</string>
   <key>LSSupportsOpeningDocumentsInPlace</key>
   <true/>
-	<key>CADisableMinimumFrameDurationOnPhone</key>
-	<true/>
-	<key>UIApplicationSupportsIndirectInputEvents</key>
-	<true/>
+  <key>CADisableMinimumFrameDurationOnPhone</key>
+  <true/>
+  <key>UIApplicationSupportsIndirectInputEvents</key>
+  <true/>
+  <key>NSContactsUsageDescription</key>
+  <string>We need access to your contacts to import them.</string>
 </dict>
 </plist>

lib/domain/service/notification.dart

@@ -36,6 +36,7 @@ import '/ui/worker/cache.dart';
 import '/util/android_utils.dart';
 import '/util/audio_utils.dart';
 import '/util/log.dart';
+import '/util/permission.dart';
 import '/util/platform_utils.dart';
 import '/util/web/web_utils.dart';
 import 'disposable_service.dart';
@@ -445,16 +446,14 @@ class NotificationService extends DisposableService {
         Log.error(e.toString(), '$runtimeType');
       }
     }
-
-    NotificationSettings settings =
-        await FirebaseMessaging.instance.requestPermission();
+    NotificationSettings settings = await PermissionUtil.notifications();
 
     // On Android first attempt is always [AuthorizationStatus.denied] due to
     // notifications request popping while invoking a
     // [AndroidUtils.createNotificationChannel], so try again on failure.
     if (PlatformUtils.isAndroid &&
         settings.authorizationStatus != AuthorizationStatus.authorized) {
-      settings = await FirebaseMessaging.instance.requestPermission();
+      settings = await PermissionUtil.notifications();
     }
 
     if (settings.authorizationStatus == AuthorizationStatus.authorized) {

lib/provider/hive/session_data.dart

@@ -78,6 +78,12 @@ class SessionDataHiveProvider extends HiveBaseProvider<SessionData> {
     return getSafe(0)?.blocklistSynchronized;
   }
 
+  /// Returns the stored [SessionData.contactsImported] from [Hive].
+  bool? getContactsImported() {
+    Log.trace('getContactsImported()', '$runtimeType');
+    return getSafe(0)?.contactsImported;
+  }
+
   /// Stores a new [FavoriteChatsListVersion] to [Hive].
   Future<void> setFavoriteChatsListVersion(FavoriteChatsListVersion ver) {
     Log.trace('setChatContactsListVersion($ver)', '$runtimeType');
@@ -125,10 +131,16 @@ class SessionDataHiveProvider extends HiveBaseProvider<SessionData> {
 
   /// Stores a new [SessionData.blocklistSynchronized] to [Hive].
   Future<void> setBlocklistSynchronized(bool val) async {
-    Log.trace('setBlocklistSynchronized()', '$runtimeType');
+    Log.trace('setBlocklistSynchronized($val)', '$runtimeType');
     await putSafe(
       0,
       (box.get(0) ?? SessionData())..blocklistSynchronized = val,
     );
   }
+
+  /// Stores a new [SessionData.contactsImported] to [Hive].
+  Future<void> setContactsImported(bool val) async {
+    Log.trace('setContactsImported($val)', '$runtimeType');
+    await putSafe(0, (box.get(0) ?? SessionData())..contactsImported = val);
+  }
 }

lib/store/contact.dart

@@ -19,9 +19,13 @@ import 'dart:async';
 
 import 'package:async/async.dart';
 import 'package:collection/collection.dart';
+import 'package:device_region/device_region.dart';
+import 'package:fast_contacts/fast_contacts.dart';
 import 'package:get/get.dart';
 import 'package:hive/hive.dart';
 import 'package:mutex/mutex.dart';
+import 'package:permission_handler/permission_handler.dart';
+import 'package:phone_numbers_parser/phone_numbers_parser.dart';
 
 import '/api/backend/extension/contact.dart';
 import '/api/backend/extension/page_info.dart';
@@ -45,6 +49,8 @@ import '/store/pagination/graphql.dart';
 import '/util/log.dart';
 import '/util/new_type.dart';
 import '/util/obs/obs.dart';
+import '/util/permission.dart';
+import '/util/platform_utils.dart';
 import '/util/stream_utils.dart';
 import 'event/contact.dart';
 import 'model/contact.dart';
@@ -129,6 +135,12 @@ class ContactRepository extends DisposableInterface
     _initLocalSubscription();
     _initRemoteSubscription();
 
+    if (PlatformUtils.isMobile &&
+        !PlatformUtils.isWeb &&
+        _sessionLocal.getContactsImported() != true) {
+      _importContacts();
+    }
+
     super.onInit();
   }
 
@@ -388,6 +400,83 @@ class ContactRepository extends DisposableInterface
     await _contactLocal.remove(id);
   }
 
+  /// Imports contacts from the device's contact list.
+  Future<void> _importContacts() async {
+    Log.debug('_importContacts()', '$runtimeType');
+
+    PermissionStatus status = await Permission.contacts.status;
+
+    if (status.isPermanentlyDenied || status.isRestricted) {
+      return;
+    }
+
+    if (!status.isGranted) {
+      status = await PermissionUtil.contacts();
+
+      if (!status.isGranted) {
+        return;
+      }
+    }
+
+    final List<Contact> contacts = await FastContacts.getAllContacts();
+
+    IsoCode? isoCode;
+    final String? countryCode = await DeviceRegion.getSIMCountryCode();
+    if (countryCode != null) {
+      isoCode = IsoCode.fromJson(countryCode.toUpperCase());
+    }
+
+    for (final Contact contact in contacts) {
+      final List<UserPhone> phones = [];
+      final List<UserEmail> emails = [];
+
+      for (var e in contact.phones) {
+        try {
+          final PhoneNumber phone =
+              PhoneNumber.parse(e.number, callerCountry: isoCode);
+
+          if (!phone.isValid(type: PhoneNumberType.mobile)) {
+            throw const FormatException('Not valid');
+          }
+
+          phones.add(UserPhone('+${phone.countryCode}${phone.nsn}'));
+        } catch (ex) {
+          Log.warning(
+            'Failed to parse ${e.number} into UserPhone with $ex',
+            '$runtimeType',
+          );
+        }
+      }
+
+      for (var e in contact.emails) {
+        try {
+          emails.add(UserEmail(e.address));
+        } catch (ex) {
+          Log.warning(
+            'Failed to parse ${e.address} into UserEmail with $ex',
+            '$runtimeType',
+          );
+        }
+      }
+
+      try {
+        if (phones.isNotEmpty || emails.isNotEmpty) {
+          _graphQlProvider.createChatContact(
+            name: UserName(contact.displayName.padRight(2, '_')),
+            records: [
+              ...phones.map((e) => ChatContactRecord(phone: e)),
+              ...emails.map((e) => ChatContactRecord(email: e)),
+            ],
+          );
+        }
+      } catch (_) {
+        // No-op.
+      }
+    }
+
+    await _sessionLocal.setContactsImported(true);
+  }
+
   /// Searches [ChatContact]s by the provided [UserName].
   ///
   /// This is a fuzzy search.

lib/store/model/session_data.dart

@@ -54,4 +54,9 @@ class SessionData extends HiveObject {
   /// remote, meaning no queries should be made.
   @HiveField(5)
   bool? blocklistSynchronized;
+
+  /// Persisted indicator whether contacts from device's contacts book was
+  /// imported.
+  @HiveField(6)
+  bool? contactsImported;
 }

lib/ui/page/call/search/controller.dart

@@ -585,11 +585,11 @@ class SearchController extends GetxController {
 
       // Predicates to filter the [allContacts] by.
       bool isMember(RxChatContact c) =>
-          chat?.members.items.containsKey(c.user.value!.id) ?? false;
-      bool inRecent(RxChatContact c) => recent.containsKey(c.user.value!.id);
+          chat?.members.items.containsKey(c.user.value?.id) ?? false;
+      bool inRecent(RxChatContact c) => recent.containsKey(c.user.value?.id);
       bool inChats(RxChatContact c) => chats.values.any((chat) =>
           chat.chat.value.isDialog &&
-          chat.members.items.containsKey(c.user.value!.id));
+          chat.members.items.containsKey(c.user.value?.id));
       bool matchesQuery(RxChatContact c) => _matchesQuery(user: c.user.value);
 
       final List<RxChatContact> filtered = allContacts

lib/ui/page/home/tab/chats/view.dart

@@ -308,6 +308,8 @@ class ChatsTabView extends StatelessWidget {
                                 c.search.value?.search.clear();
                                 c.search.value?.query.value = '';
                                 c.search.value?.search.focus.requestFocus();
+                              } else {
+                                c.closeSearch(true);
                               }
                             } else if (c.selecting.value) {
                               c.toggleSelecting();

lib/ui/page/home/tab/contacts/controller.dart

@@ -19,6 +19,7 @@ import 'dart:async';
 
 import 'package:async/async.dart';
 import 'package:back_button_interceptor/back_button_interceptor.dart';
+import 'package:collection/collection.dart';
 import 'package:flutter/material.dart' hide SearchController;
 import 'package:flutter/scheduler.dart';
 import 'package:flutter/services.dart';
@@ -140,6 +141,7 @@ class ContactsTabController extends GetxController {
     scrollController.addListener(_scrollListener);
 
     contacts.value = _contactService.paginated.values
+        .where((e) => e.contact.value.users.isNotEmpty)
         .map((e) => ContactEntry(e))
         .toList()
       ..sort();
@@ -427,10 +429,12 @@ class ContactsTabController extends GetxController {
     _contactsSubscription = _contactService.paginated.changes.listen((e) {
       switch (e.op) {
         case OperationKind.added:
-          final entry = ContactEntry(e.value!);
-          contacts.add(entry);
-          contacts.sort();
-          listen(entry);
+          if (e.value!.contact.value.users.isNotEmpty) {
+            final entry = ContactEntry(e.value!);
+            contacts.add(entry);
+            contacts.sort();
+            listen(entry);
+          }
           break;
 
         case OperationKind.removed:
@@ -440,7 +444,14 @@ class ContactsTabController extends GetxController {
           break;
 
         case OperationKind.updated:
-          contacts.sort();
+          if (e.value!.contact.value.users.isNotEmpty) {
+            if (contacts.none((c) => c.id == e.key)) {
+              final entry = ContactEntry(e.value!);
+              contacts.add(entry);
+            }
+
+            contacts.sort();
+          }
           break;
       }
     });
@@ -474,15 +485,16 @@ class ContactsTabController extends GetxController {
     if (!_scrollIsInvoked) {
       _scrollIsInvoked = true;
 
-      SchedulerBinding.instance.addPostFrameCallback((_) {
+      SchedulerBinding.instance.addPostFrameCallback((_) async {
         _scrollIsInvoked = false;
 
         if (scrollController.hasClients &&
             hasNext.isTrue &&
             _contactService.nextLoading.isFalse &&
             scrollController.position.pixels >
                 scrollController.position.maxScrollExtent - 500) {
-          _contactService.next();
+          await _contactService.next();
+          _scrollListener();
         }
       });
     }
@@ -500,14 +512,12 @@ class ContactsTabController extends GetxController {
           return;
         }
 
-        if (!scrollController.hasClients) {
-          return await _ensureScrollable();
-        }
-
         // If the fetched initial page contains less elements than required to
         // fill the view and there's more pages available, then fetch those pages.
-        if (scrollController.position.maxScrollExtent < 50 &&
-            _contactService.nextLoading.isFalse) {
+        if ((!scrollController.hasClients ||
+                scrollController.position.maxScrollExtent < 50) &&
+            _contactService.nextLoading.isFalse &&
+            hasNext.isTrue) {
           await _contactService.next();
           _ensureScrollable();
         }

lib/ui/page/home/tab/contacts/view.dart

@@ -182,6 +182,8 @@ class ContactsTabView extends StatelessWidget {
                           c.search.value?.search.clear();
                           c.search.value?.query.value = '';
                           c.search.value?.search.focus.requestFocus();
+                        } else {
+                          c.toggleSearch(false);
                         }
                       } else if (c.selecting.value) {
                         c.toggleSelecting();

lib/util/permission.dart

@@ -0,0 +1,42 @@
+// Copyright © 2022-2024 IT ENGINEERING MANAGEMENT INC,
+//                       <https://github.com/team113>
+//
+// This program is free software: you can redistribute it and/or modify it under
+// the terms of the GNU Affero General Public License v3.0 as published by the
+// Free Software Foundation, either version 3 of the License, or (at your
+// option) any later version.
+//
+// This program is distributed in the hope that it will be useful, but WITHOUT
+// ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
+// FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License v3.0 for
+// more details.
+//
+// You should have received a copy of the GNU Affero General Public License v3.0
+// along with this program. If not, see
+// <https://www.gnu.org/licenses/agpl-3.0.html>.
+
+import 'package:firebase_messaging/firebase_messaging.dart';
+import 'package:mutex/mutex.dart';
+import 'package:permission_handler/permission_handler.dart';
+
+/// Utility class for requesting permissions.
+class PermissionUtil {
+  /// Mutex for synchronized access to permissions requesting.
+  ///
+  /// Ensures that only one permission is requested at the same time.
+  static final Mutex _permissionMutex = Mutex();
+
+  /// Requests the notifications permission.
+  static Future<NotificationSettings> notifications() {
+    return _permissionMutex.protect(() {
+      return FirebaseMessaging.instance.requestPermission();
+    });
+  }
+
+  /// Requests the contacts permission.
+  static Future<PermissionStatus> contacts() {
+    return _permissionMutex.protect(() async {
+      return Permission.contacts.request();
+    });
+  }
+}

linux/flutter/generated_plugin_registrant.cc

@@ -7,6 +7,7 @@
 #include "generated_plugin_registrant.h"
 
 #include <desktop_drop/desktop_drop_plugin.h>
+#include <device_region/device_region_plugin.h>
 #include <flutter_custom_cursor/flutter_custom_cursor_plugin.h>
 #include <medea_flutter_webrtc/medea_flutter_webrtc_plugin.h>
 #include <medea_jason/medea_jason_plugin.h>
@@ -21,6 +22,9 @@ void fl_register_plugins(FlPluginRegistry* registry) {
   g_autoptr(FlPluginRegistrar) desktop_drop_registrar =
       fl_plugin_registry_get_registrar_for_plugin(registry, "DesktopDropPlugin");
   desktop_drop_plugin_register_with_registrar(desktop_drop_registrar);
+  g_autoptr(FlPluginRegistrar) device_region_registrar =
+      fl_plugin_registry_get_registrar_for_plugin(registry, "DeviceRegionPlugin");
+  device_region_plugin_register_with_registrar(device_region_registrar);
   g_autoptr(FlPluginRegistrar) flutter_custom_cursor_registrar =
       fl_plugin_registry_get_registrar_for_plugin(registry, "FlutterCustomCursorPlugin");
   flutter_custom_cursor_plugin_register_with_registrar(flutter_custom_cursor_registrar);