Add ConnectID Invite/De-Link/Re-Link features

corehq/apps/user_importer/importer.py

@@ -52,7 +52,11 @@
     InvitationStatus
 )
 from corehq.const import USER_CHANGE_VIA_BULK_IMPORTER
-from corehq.toggles import DOMAIN_PERMISSIONS_MIRROR, TABLEAU_USER_SYNCING
+from corehq.toggles import (
+    DOMAIN_PERMISSIONS_MIRROR,
+    TABLEAU_USER_SYNCING,
+    COMMCARE_CONNECT,
+)
 from corehq.apps.sms.util import validate_phone_number
 
 from dimagi.utils.logging import notify_error
@@ -96,6 +100,9 @@ def check_headers(user_specs, domain, is_web_upload=False):
     if TABLEAU_USER_SYNCING.enabled(domain):
         allowed_headers.update({'tableau_role', 'tableau_groups'})
 
+    if COMMCARE_CONNECT.enabled(domain):
+        allowed_headers.add('send_connectid_invite')
+
     illegal_headers = headers - allowed_headers
 
     if is_web_upload:
@@ -497,6 +504,9 @@ def _parse_username(self):
 
     def _parse_password(self):
         from corehq.apps.user_importer.validation import is_password
+        if self.column_values["send_connectid_invite"]:
+            # password login is disabled for connectid
+            password = ''
         if self.row.get('password'):
             password = str(self.row.get('password'))
         elif self.column_values["send_confirmation_sms"]:
@@ -530,10 +540,10 @@ def _process_column_values(self):
         }
 
         for v in ['is_active', 'is_account_confirmed', 'send_confirmation_email',
-                  'remove_web_user', 'send_confirmation_sms']:
+                  'remove_web_user', 'send_confirmation_sms', 'send_connectid_invite']:
             values[v] = spec_value_to_boolean_or_none(self.row, v)
 
-        if values["send_confirmation_sms"] and not values["user_id"]:
+        if (values["send_confirmation_sms"] or values["send_connectid_invite"]) and not values["user_id"]:
             values["is_account_confirmed"] = False
         else:
             values["is_account_confirmed"] = values["is_account_confirmed"]
@@ -691,6 +701,9 @@ def _process_web_user(self):
                 send_account_confirmation_if_necessary(self.user)
             if cv["send_confirmation_sms"]:
                 send_account_confirmation_sms_if_necessary(self.user)
+            elif cv["send_connectid_invite"]:
+                from corehq.apps.users.views.mobile.users import deliver_connectid_invite
+                deliver_connectid_invite(self.user)
 
 
 class WebUserRow(BaseUserRow):

corehq/apps/user_importer/validation.py

@@ -64,7 +64,8 @@ def get_user_import_validators(domain_obj, all_specs, is_web_user_import, all_us
             NewUserPasswordValidator(domain),
             PasswordValidator(domain) if validate_passwords else noop,
             GroupValidator(domain, allowed_groups),
-            ConfirmationSmsValidator(domain)
+            ConfirmationSmsValidator(domain),
+            ConnectIdInviteValidator(domain)
         ]
 
 
@@ -455,6 +456,10 @@ def validate_spec(self, spec):
                     return self.error_existing_user.format(self.confirmation_sms_header, errors_formatted)
 
 
+class ConnectIdInviteValidator(ConfirmationSmsValidator):
+    confirmation_sms_header = "send_connectid_invite"
+
+
 class LocationValidator(ImportValidator):
     error_message_user_access = _("Based on your locations you do not have permission to edit this user or user "
                                   "invitation")

corehq/apps/users/views/mobile/users.py

@@ -811,7 +811,7 @@ def create_mobile_worker(self, in_data):
         if self.new_mobile_worker_form.cleaned_data['account_invite_by_cid']:
             phone_number = self.new_mobile_worker_form.cleaned_data['phone_number']
             couch_user.set_default_phone_number(phone_number)
-            deliver_connectid_invite(couch_user)
+            deliver_connectid_invite(couch_user, self.request)
 
         plan_limit, user_count = Subscription.get_plan_and_user_count_by_domain(self.domain)
         check_and_send_limit_email(self.domain, plan_limit, user_count, user_count - 1)
@@ -1747,7 +1747,6 @@ def link_connectid_user(request, domain):
 @require_can_edit_commcare_users
 @location_safe
 def send_connectid_invite(request, domain, user_id):
-    # Currently same as what send_confirmation_sms does
     user = CommCareUser.get_by_user_id(user_id, domain)
     if user.domain != domain:
         return HttpResponse(status=400)
@@ -1757,10 +1756,11 @@ def send_connectid_invite(request, domain, user_id):
     return HttpResponse(status=200)
 
 
-def deliver_connectid_invite(user):
+def deliver_connectid_invite(user, request=None):
     # ConnectID server delivers the invite to user
     if user.is_account_confirmed or not user.is_commcare_user():
-        messages.error(request, "The user is already confirmed or is not a mobile user")
+        if request:
+            messages.error(request, "The user is already confirmed or is not a mobile user")
         return False
 
     invite_code = encrypt_account_confirmation_info(user)