Models and signup & login views for consumer_user_poc

corehq/apps/consumer_user/__init__.py

@@ -0,0 +1,12 @@
+from django.apps import AppConfig
+
+
+class ConsumerUserAppConfig(AppConfig):
+    name = 'corehq.apps.consumer_user'
+
+    def ready(self):
+        from corehq.apps.consumer_user.signals import connect_signals
+        connect_signals()
+
+
+default_app_config = 'corehq.apps.consumer_user.ConsumerUserAppConfig'

corehq/apps/consumer_user/admin.py

@@ -0,0 +1,5 @@
+from django.contrib import admin
+
+from corehq.apps.consumer_user.models import ConsumerUser
+
+admin.site.register(ConsumerUser)

corehq/apps/consumer_user/apps.py

@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class ConsumerUserConfig(AppConfig):
+    name = 'consumer_user'

corehq/apps/consumer_user/decorators.py

@@ -0,0 +1,16 @@
+from functools import wraps
+from django.contrib.auth.views import redirect_to_login
+from django.urls import reverse
+
+
+def login_required(view_func):
+    @wraps(view_func)
+    def _inner(request, *args, **kwargs):
+        user = request.user
+        if not (user.is_authenticated and user.is_active):
+            url = reverse('consumer_user:patient_login')
+            return redirect_to_login(request.get_full_path(), url)
+
+        # User's login and domain have been validated - it's safe to call the view function
+        return view_func(request, *args, **kwargs)
+    return _inner

corehq/apps/consumer_user/forms/change_contact_details_form.py

@@ -0,0 +1,16 @@
+from django.contrib.auth.models import User
+from django.forms import ModelForm
+
+
+class ChangeContactDetailsForm(ModelForm):
+    class Meta:
+        model = User
+        fields = ['first_name', 'last_name']
+
+    def save(self, commit=True):
+        user = super(ChangeContactDetailsForm, self).save(commit=False)
+        user.first_name = self.cleaned_data["first_name"]
+        user.last_name = self.cleaned_data["last_name"]
+        if commit:
+            user.save()
+        return user

corehq/apps/consumer_user/forms/patient_authentication_form.py

@@ -0,0 +1,45 @@
+from django import forms
+from django.contrib.auth.forms import AuthenticationForm
+from corehq.apps.domain.forms import NoAutocompleteMixin
+from django.utils.translation import ugettext_lazy as _
+from django.core.exceptions import ValidationError
+from corehq.apps.consumer_user.models import ConsumerUser
+from corehq.apps.consumer_user.models import ConsumerUserCaseRelationship
+from corehq.apps.hqcase.utils import update_case
+
+
+class PatientAuthenticationForm(NoAutocompleteMixin, AuthenticationForm):
+    username = forms.EmailField(label=_("Email Address"), max_length=75,
+                                widget=forms.TextInput(attrs={'class': 'form-control'}),
+                                required=True)
+    password = forms.CharField(label=_("Password"),
+                               widget=forms.PasswordInput(attrs={'class': 'form-control'}),
+                               required=True)
+
+    def __init__(self, *args, **kwargs):
+        self.invitation = kwargs.pop('invitation', None)
+        super().__init__(*args, **kwargs)
+
+    def clean(self):
+        username = self.cleaned_data.get('username')
+        if username is None:
+            raise ValidationError('Please enter a valid email address.')
+
+        password = self.cleaned_data.get('password')
+        if not password:
+            raise ValidationError("Please enter a password.")
+        try:
+            cleaned_data = super(PatientAuthenticationForm, self).clean()
+            if self.invitation and not self.invitation.accepted:
+                consumer_user, _ = ConsumerUser.objects.get_or_create(user=self.user_cache)
+                self.invitation.accepted = True
+                self.invitation.save()
+                _ = ConsumerUserCaseRelationship.objects.create(case_id=self.invitation.case_id,
+                                                                domain=self.invitation.domain,
+                                                                consumer_user=consumer_user)
+                update_case(self.invitation.domain,
+                            self.invitation.case_id,
+                            {'invitation_status': 'accepted'})
+        except ValidationError:
+            raise
+        return cleaned_data

corehq/apps/consumer_user/forms/patient_signup_form.py

@@ -0,0 +1,40 @@
+from django.forms import ModelForm
+from django.forms import PasswordInput
+from django.contrib.auth.models import User
+from corehq.apps.consumer_user.models import ConsumerUser
+from corehq.apps.consumer_user.models import ConsumerUserCaseRelationship
+from corehq.apps.hqcase.utils import update_case
+
+
+class PatientSignUpForm(ModelForm):
+
+    def __init__(self, *args, **kwargs):
+        self.invitation = kwargs.pop('invitation', None)
+        super().__init__(*args, **kwargs)
+        for key in self.fields:
+            self.fields[key].required = True
+
+    class Meta:
+        model = User
+        fields = ['first_name', 'last_name', 'email', 'password']
+        widgets = {
+            'password': PasswordInput(),
+        }
+
+    def save(self, commit=True):
+        user = super(PatientSignUpForm, self).save(commit=False)
+        user.set_password(self.cleaned_data["password"])
+        user.username = self.cleaned_data['email']
+        if commit:
+            user.save()
+            consumer_user = ConsumerUser.objects.create(user=user)
+            if self.invitation:
+                self.invitation.accepted = True
+                self.invitation.save()
+                _ = ConsumerUserCaseRelationship.objects.create(case_id=self.invitation.case_id,
+                                                                domain=self.invitation.domain,
+                                                                consumer_user=consumer_user)
+                update_case(self.invitation.domain,
+                            self.invitation.case_id,
+                            {'invitation_status': 'accepted'})
+        return user

corehq/apps/consumer_user/migrations/0001_initial.py

@@ -0,0 +1,51 @@
+# Generated by Django 2.2.16 on 2021-02-23 06:52
+
+from django.conf import settings
+from django.db import migrations, models
+import django.db.models.deletion
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='ConsumerUser',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('user', models.OneToOneField(on_delete=django.db.models.deletion.CASCADE,
+                                              to=settings.AUTH_USER_MODEL)),
+            ],
+        ),
+        migrations.CreateModel(
+            name='ConsumerUserInvitation',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('email', models.EmailField(max_length=254)),
+                ('case_id', models.CharField(max_length=255)),
+                ('domain', models.CharField(max_length=255)),
+                ('accepted', models.BooleanField(default=False)),
+                ('invited_by', models.CharField(max_length=255)),
+                ('invited_on', models.DateTimeField(auto_now=True)),
+                ('active', models.BooleanField(default=True)),
+            ],
+        ),
+        migrations.CreateModel(
+            name='ConsumerUserCaseRelationship',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('case_id', models.CharField(max_length=255)),
+                ('domain', models.CharField(max_length=255)),
+                ('consumer_user', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE,
+                                                    to='consumer_user.ConsumerUser')),
+            ],
+            options={
+                'unique_together': {('case_id', 'domain')},
+            },
+        ),
+    ]

corehq/apps/consumer_user/models.py

@@ -0,0 +1,25 @@
+from django.contrib.auth.models import User
+from django.db import models
+
+
+class ConsumerUser(models.Model):
+    user = models.OneToOneField(User, on_delete=models.CASCADE)
+
+
+class ConsumerUserCaseRelationship(models.Model):
+    consumer_user = models.ForeignKey(ConsumerUser, on_delete=models.CASCADE)
+    case_id = models.CharField(max_length=255)
+    domain = models.CharField(max_length=255)
+
+    class Meta:
+        unique_together = ('case_id', 'domain',)
+
+
+class ConsumerUserInvitation(models.Model):
+    email = models.EmailField()
+    case_id = models.CharField(max_length=255)
+    domain = models.CharField(max_length=255)
+    accepted = models.BooleanField(default=False)
+    invited_by = models.CharField(max_length=255)
+    invited_on = models.DateTimeField(auto_now=True)
+    active = models.BooleanField(default=True)

corehq/apps/consumer_user/signals.py

@@ -0,0 +1,80 @@
+from dimagi.utils.logging import notify_exception
+from dimagi.utils.web import get_site_domain
+from django.db.utils import IntegrityError
+from django.template.loader import render_to_string
+from django.utils.encoding import force_bytes
+from django.urls import reverse
+from corehq.apps.consumer_user.models import ConsumerUserInvitation
+from corehq.apps.consumer_user.models import ConsumerUserCaseRelationship
+from corehq.form_processor.models import CommCareCaseSQL
+from corehq.form_processor.signals import sql_case_post_save
+from corehq.apps.hqwebapp.tasks import send_html_email_async
+from django.utils.http import urlsafe_base64_encode
+from django.core.signing import TimestampSigner
+from corehq.apps.hqcase.utils import update_case
+
+
+def send_email_case_changed_receiver(sender, case, **kwargs):
+    try:
+        if case.type != 'commcare-caseuserinvitation':
+            return
+        try:
+            email = case.get_case_property('email')
+        except IntegrityError:
+            email = '[email protected]'
+        try:
+            updated_by = case.get_case_property('updated_by')
+        except IntegrityError:
+            updated_by = None
+        try:
+            invitation = ConsumerUserInvitation.objects.filter(case_id=case.case_id,
+                                                               domain=case.domain,
+                                                               active=True).latest('invited_on')
+            if invitation:
+                if updated_by and updated_by == 'patient' and email == invitation.email and not case.closed:
+                    return
+                invitation.active = False
+                ConsumerUserCaseRelationship.objects.filter(case_id=case.case_id,
+                                                            domain=case.domain).delete()
+                invitation.save()
+        except ConsumerUserInvitation.DoesNotExist:
+            pass
+        if case.closed:
+            return
+        invitation = ConsumerUserInvitation.objects.create(case_id=case.case_id, domain=case.domain)
+        invitation.invited_by = case.opened_by
+        invitation.email = email
+        invitation.accepted = False
+        invitation.save()
+        # Change to https after the discussion
+        url = 'http://%s%s' % (get_site_domain(),
+                               reverse('consumer_user:patient_register',
+                                       kwargs={
+                                           'invitation': TimestampSigner().sign(urlsafe_base64_encode(
+                                               force_bytes(invitation.pk)
+                                           ))
+                                       }))
+        email_context = {
+            'link': url,
+        }
+        send_html_email_async.delay(
+            'Beneficiary Registration',
+            email,
+            render_to_string('email/registration_email.html', email_context),
+            text_content=render_to_string('email/registration_email.txt', email_context)
+        )
+        update_case(case.domain, case.case_id, {'invitation_status': 'sent', 'updated_by': 'patient'})
+
+    except Exception:
+        notify_exception(
+            None,
+            message="Could not create messaging case changed task. Is RabbitMQ running?"
+        )
+
+
+def connect_signals():
+    sql_case_post_save.connect(
+        send_email_case_changed_receiver,
+        CommCareCaseSQL,
+        dispatch_uid='send_email_case_changed_receiver'
+    )

corehq/apps/consumer_user/templates/change_contact_details.html

@@ -0,0 +1,26 @@
+{% block content %}
+<h2>Change Contact Details</h2>
+{% if msg %}
+    <p style="font-weight:bold">{{ msg }}</p>
+{% endif %}
+{% if form.errors %}
+    <ul class="user-msg error">
+    {% for field in form %}
+        {% for error in field.errors %}
+            <li>
+              {% if field != '__all__' %}
+                <strong>{{ field.label }}:</strong>
+              {% endif %}
+              {{ error }}
+            </li>
+        {% endfor %}
+    {% endfor %}
+    </ul>
+{% endif %}
+<form method="post">
+  {% csrf_token %}
+  {{ form.as_p }}
+  <input type="submit" value="Submit">
+</form>
+<a href="{% url 'consumer_user:patient_homepage' %}">HomePage</a>
+{% endblock %}

corehq/apps/consumer_user/templates/change_password.html

@@ -0,0 +1,26 @@
+{% block content %}
+<h2>Change Password</h2>
+{% if msg %}
+    <p style="font-weight:bold">{{ msg }}</p>
+{% endif %}
+{% if form.errors %}
+    <ul class="user-msg error">
+    {% for field in form %}
+        {% for error in field.errors %}
+            <li>
+              {% if field != '__all__' %}
+                <strong>{{ field.label }}:</strong>
+              {% endif %}
+              {{ error }}
+            </li>
+        {% endfor %}
+    {% endfor %}
+    </ul>
+{% endif %}
+<form method="post">
+  {% csrf_token %}
+  {{ form.as_p }}
+  <input type="submit" value="Submit">
+</form>
+<a href="{% url 'consumer_user:patient_homepage' %}">HomePage</a>
+{% endblock %}

corehq/apps/consumer_user/templates/domains_and_cases.html

@@ -0,0 +1,19 @@
+{% block content %}
+<h2>Domains and cases</h2>
+{% if msg %}
+    <p style="font-weight:bold">{{ msg }}</p>
+{% endif %}
+<table>
+  <tr>
+    <th>Domain</th>
+    <th>Cases</th>
+  </tr>
+  {% for dict in domains_and_cases %}
+  <tr>
+    <td>{{dict.domain}}</td>
+    <td>{{dict.case_id}}</td>
+  </tr>
+  {% endfor %}
+</table>
+<a href="{% url 'consumer_user:patient_homepage' %}">HomePage</a>
+{% endblock %}

corehq/apps/consumer_user/templates/email/registration_email.html

@@ -0,0 +1,14 @@
+<p>
+  Dear user,
+</p>
+
+<p>Click on the below link to register</p>
+
+<p>
+  <a href={{link}}></a>
+</p>
+
+<p>
+  Cheers,<br />
+  --The CommCareHQ Team
+</p>