✨(backend) manage reconciliation requests for user accounts

For now, the reconciliation requests are imported through CSV in the Django admin, which sends confirmation email to both addresses. When both are checked, the actual reconciliation is processed, in a threefold process (update document acess, update invitations, update user status.)
2026-01-20 14:44:59 +01:00
parent b1a18b2477
commit 7e1d8111b3
28 changed files with 1200 additions and 46 deletions
@@ -37,6 +37,7 @@ and this project adheres to
 - ✨(helm) redirecting system #1697
 - 📱(frontend) add comments for smaller device #1737
 - ✨(project) add custom js support via config #1759
+- ✨(backend) manage reconciliation requests for user accounts #1708

 ### Changed

@@ -0,0 +1,19 @@
+# User account reconciliation
+
+It is possible to merge user accounts based on their email addresses.
+
+Docs does not have an internal process to requests, but it allows the import of a CSV from an external form
+(e.g. made with Grist) in the Django admin panel (in "Core" > "User reconciliation CSV imports" > "Add user reconciliation")
+
+The CSV must contain the following mandatory columns:
+
+- `active_email`: the email of the user that will remain active after the process.
+- `inactive_email`: the email of the user(s) that will be merged into the active user. It is possible to indicate several emails, so the user only has to make one request even if they have more than two accounts.
+- `status`: the value must be `pending`. Rows with other values will be ignored.
+
+The following columns are optional: `active_email_checked` and `inactive_email_checked` (both must contain `0` (False) or `1` (True), and both default to False.)
+If present, it allows to indicate that the source form has a way to validate that the user making the request actually controls the email addresses, skipping the need to send confirmation emails (cf. below)
+
+Once the CSV file is processed, this will create entries in "Core" > "User reconciliations" and send verification emails to validate that the user making the request actually controls the email addresses (unless `active_email_checked` and `inactive_email_checked` were set to `1` in the CSV)
+
+In "Core" > "User reconciliations", an admin can then select all rows they wish to process and check the action "Process selected user reconciliations". Only rows that have the status `ready` and for which both emails have been validated will be processed.
@@ -1,12 +1,14 @@
 """Admin classes and registrations for core app."""

-from django.contrib import admin
+from django.contrib import admin, messages
 from django.contrib.auth import admin as auth_admin
+from django.shortcuts import redirect
 from django.utils.translation import gettext_lazy as _

 from treebeard.admin import TreeAdmin

-from . import models
+from core import models
+from core.tasks.user_reconciliation import user_reconciliation_csv_import_job


 class TemplateAccessInline(admin.TabularInline):
@@ -104,6 +106,71 @@ class UserAdmin(auth_admin.UserAdmin):
    search_fields = ("id", "sub", "admin_email", "email", "full_name")


+@admin.register(models.UserReconciliationCsvImport)
+class UserReconciliationCsvImportAdmin(admin.ModelAdmin):
+    """Admin class for UserReconciliationCsvImport model."""
+
+    list_display = ("id", "created_at", "status")
+
+    def save_model(self, request, obj, form, change):
+        """Override save_model to trigger the import task on creation."""
+        super().save_model(request, obj, form, change)
+
+        if not change:
+            user_reconciliation_csv_import_job.delay(obj.pk)
+            messages.success(request, _("Import job created and queued."))
+        return redirect("..")
+
+
+@admin.action(description=_("Process selected user reconciliations"))
+def process_reconciliation(_modeladmin, _request, queryset):
+    """
+    Admin action to process selected user reconciliations.
+    The action will process only entries that are ready and have both emails checked.
+
+    Its action is threefold:
+    - Transfer document accesses from inactive to active user, updating roles as needed.
+    - Activate the active user and deactivate the inactive user.
+    """
+    processable_entries = queryset.filter(
+        status="ready", active_email_checked=True, inactive_email_checked=True
+    )
+
+    # Prepare the bulk operations
+    updated_documentaccess = []
+    removed_documentaccess = []
+    update_users_active_status = []
+
+    for entry in processable_entries:
+        new_updated_documentaccess, new_removed_documentaccess = (
+            entry.process_documentaccess_reconciliation()
+        )
+        updated_documentaccess += new_updated_documentaccess
+        removed_documentaccess += new_removed_documentaccess
+
+        entry.active_user.is_active = True
+        entry.inactive_user.is_active = False
+        update_users_active_status.append(entry.active_user)
+        update_users_active_status.append(entry.inactive_user)
+
+    # Actually perform the bulk operations
+    models.DocumentAccess.objects.bulk_update(updated_documentaccess, ["user", "role"])
+
+    if removed_documentaccess:
+        ids_to_delete = [rd.id for rd in removed_documentaccess]
+        models.DocumentAccess.objects.filter(id__in=ids_to_delete).delete()
+
+    models.User.objects.bulk_update(update_users_active_status, ["is_active"])
+
+
+@admin.register(models.UserReconciliation)
+class UserReconciliationAdmin(admin.ModelAdmin):
+    """Admin class for UserReconciliation model."""
+
+    list_display = ["id", "created_at", "status"]
+    actions = [process_reconciliation]
+
+
@admin.register(models.Template)
 class TemplateAdmin(admin.ModelAdmin):
    """Template admin interface declaration."""
@@ -40,6 +40,8 @@ from lasuite.oidc_login.decorators import refresh_oidc_access_token
 from rest_framework import filters, status, viewsets
 from rest_framework import response as drf_response
 from rest_framework.permissions import AllowAny
+from rest_framework.response import Response
+from rest_framework.views import APIView

 from core import authentication, choices, enums, models
 from core.api.filters import remove_accents
@@ -247,6 +249,59 @@ class UserViewSet(
        )


+class ReconciliationConfirmView(APIView):
+    """API endpoint to confirm user reconciliation emails.
+
+    GET /user_reconciliations/{user_type}/{confirmation_id}/
+    Marks `active_email_checked` or `inactive_email_checked` to True.
+    """
+
+    permission_classes = [AllowAny]
+
+    def get(self, request, user_type, confirmation_id):
+        """
+        Check the confirmation ID and mark the corresponding email as checked.
+        """
+        try:
+            # validate UUID
+            uuid_obj = uuid.UUID(confirmation_id)
+        except ValueError:
+            return Response(
+                {"detail": "Badly formatted confirmation id"},
+                status=status.HTTP_400_BAD_REQUEST,
+            )
+
+        if user_type not in ("active", "inactive"):
+            return Response(
+                {"detail": "Invalid user_type"}, status=status.HTTP_400_BAD_REQUEST
+            )
+
+        lookup = (
+            {"active_confirmation_id": uuid_obj}
+            if user_type == "active"
+            else {"inactive_confirmation_id": uuid_obj}
+        )
+
+        try:
+            rec = models.UserReconciliation.objects.get(**lookup)
+        except models.UserReconciliation.DoesNotExist:
+            return Response(
+                {"detail": "Reconciliation entry not found"},
+                status=status.HTTP_404_NOT_FOUND,
+            )
+
+        field_name = (
+            "active_email_checked"
+            if user_type == "active"
+            else "inactive_email_checked"
+        )
+        if not getattr(rec, field_name):
+            setattr(rec, field_name, True)
+            rec.save()
+
+        return Response({"detail": "Confirmation received"})
+
+
 class ResourceAccessViewsetMixin:
    """Mixin with methods common to all access viewsets."""

@@ -0,0 +1,164 @@
+# Generated by Django 5.2.9 on 2026-01-06 18:46
+
+import uuid
+
+import django.db.models.deletion
+from django.conf import settings
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ("core", "0027_auto_20251120_0956"),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name="UserReconciliationCsvImport",
+            fields=[
+                (
+                    "id",
+                    models.UUIDField(
+                        default=uuid.uuid4,
+                        editable=False,
+                        help_text="primary key for the record as UUID",
+                        primary_key=True,
+                        serialize=False,
+                        verbose_name="id",
+                    ),
+                ),
+                (
+                    "created_at",
+                    models.DateTimeField(
+                        auto_now_add=True,
+                        help_text="date and time at which a record was created",
+                        verbose_name="created on",
+                    ),
+                ),
+                (
+                    "updated_at",
+                    models.DateTimeField(
+                        auto_now=True,
+                        help_text="date and time at which a record was last updated",
+                        verbose_name="updated on",
+                    ),
+                ),
+                ("file", models.FileField(upload_to="imports/")),
+                (
+                    "status",
+                    models.CharField(
+                        choices=[
+                            ("pending", "Pending"),
+                            ("running", "Running"),
+                            ("done", "Done"),
+                            ("error", "Error"),
+                        ],
+                        default="pending",
+                        max_length=20,
+                    ),
+                ),
+                ("logs", models.TextField(blank=True)),
+            ],
+            options={
+                "verbose_name": "user reconciliation CSV import",
+                "verbose_name_plural": "user reconciliation CSV imports",
+            },
+        ),
+        migrations.CreateModel(
+            name="UserReconciliation",
+            fields=[
+                (
+                    "id",
+                    models.UUIDField(
+                        default=uuid.uuid4,
+                        editable=False,
+                        help_text="primary key for the record as UUID",
+                        primary_key=True,
+                        serialize=False,
+                        verbose_name="id",
+                    ),
+                ),
+                (
+                    "created_at",
+                    models.DateTimeField(
+                        auto_now_add=True,
+                        help_text="date and time at which a record was created",
+                        verbose_name="created on",
+                    ),
+                ),
+                (
+                    "updated_at",
+                    models.DateTimeField(
+                        auto_now=True,
+                        help_text="date and time at which a record was last updated",
+                        verbose_name="updated on",
+                    ),
+                ),
+                (
+                    "active_email",
+                    models.EmailField(
+                        max_length=254, verbose_name="Active email address"
+                    ),
+                ),
+                (
+                    "inactive_email",
+                    models.EmailField(
+                        max_length=254, verbose_name="Email address to deactivate"
+                    ),
+                ),
+                ("active_email_checked", models.BooleanField(default=False)),
+                ("inactive_email_checked", models.BooleanField(default=False)),
+                (
+                    "active_confirmation_id",
+                    models.UUIDField(
+                        default=uuid.uuid4, editable=False, null=True, unique=True
+                    ),
+                ),
+                (
+                    "inactive_confirmation_id",
+                    models.UUIDField(
+                        default=uuid.uuid4, editable=False, null=True, unique=True
+                    ),
+                ),
+                (
+                    "status",
+                    models.CharField(
+                        choices=[
+                            ("pending", "Pending"),
+                            ("ready", "Ready"),
+                            ("done", "Done"),
+                            ("error", "Error"),
+                        ],
+                        default="pending",
+                        max_length=20,
+                    ),
+                ),
+                ("logs", models.TextField(blank=True)),
+                (
+                    "active_user",
+                    models.ForeignKey(
+                        blank=True,
+                        null=True,
+                        on_delete=django.db.models.deletion.CASCADE,
+                        related_name="active_user",
+                        to=settings.AUTH_USER_MODEL,
+                    ),
+                ),
+                (
+                    "inactive_user",
+                    models.ForeignKey(
+                        blank=True,
+                        null=True,
+                        on_delete=django.db.models.deletion.CASCADE,
+                        related_name="inactive_user",
+                        to=settings.AUTH_USER_MODEL,
+                    ),
+                ),
+            ],
+            options={
+                "verbose_name": "user reconciliation",
+                "verbose_name_plural": "user reconciliations",
+                "ordering": ["-created_at"],
+            },
+        ),
+    ]
@@ -1,6 +1,7 @@
 """
 Declare and configure the models for the impress core application
 """
+
 # pylint: disable=too-many-lines

 import hashlib
@@ -32,14 +33,14 @@ from rest_framework.exceptions import ValidationError
 from timezone_field import TimeZoneField
 from treebeard.mp_tree import MP_Node, MP_NodeManager, MP_NodeQuerySet

-from .choices import (
+from core.choices import (
    PRIVILEGED_ROLES,
    LinkReachChoices,
    LinkRoleChoices,
    RoleChoices,
    get_equivalent_link_definition,
 )
-from .validators import sub_validator
+from core.validators import sub_validator

 logger = getLogger(__name__)

@@ -250,6 +251,37 @@ class User(AbstractBaseUser, BaseModel, auth_models.PermissionsMixin):

        valid_invitations.delete()

+    def send_email(self, subject, context=None, language=None):
+        """Generate and send email to the user from a template."""
+        emails = [self.email]
+        context = context or {}
+        domain = Site.objects.get_current().domain
+        language = language or get_language()
+        context.update(
+            {
+                "brandname": settings.EMAIL_BRAND_NAME,
+                "domain": domain,
+                "logo_img": settings.EMAIL_LOGO_IMG,
+            }
+        )
+
+        with override(language):
+            msg_html = render_to_string("mail/html/user_template.html", context)
+            msg_plain = render_to_string("mail/text/user_template.txt", context)
+            subject = str(subject)  # Force translation
+
+            try:
+                send_mail(
+                    subject.capitalize(),
+                    msg_plain,
+                    settings.EMAIL_FROM,
+                    emails,
+                    html_message=msg_html,
+                    fail_silently=False,
+                )
+            except smtplib.SMTPException as exception:
+                logger.error("invitation to %s was not sent: %s", emails, exception)
+
    def email_user(self, subject, message, from_email=None, **kwargs):
        """Email this user."""
        if not self.email:
@@ -265,6 +297,246 @@ class User(AbstractBaseUser, BaseModel, auth_models.PermissionsMixin):
        return []


+class UserReconciliation(BaseModel):
+    """Model to run batch jobs to replace an active user by another one"""
+
+    active_email = models.EmailField(_("Active email address"))
+    inactive_email = models.EmailField(_("Email address to deactivate"))
+    active_email_checked = models.BooleanField(default=False)
+    inactive_email_checked = models.BooleanField(default=False)
+    active_user = models.ForeignKey(
+        User,
+        on_delete=models.CASCADE,
+        null=True,
+        blank=True,
+        related_name="active_user",
+    )
+    inactive_user = models.ForeignKey(
+        User,
+        on_delete=models.CASCADE,
+        null=True,
+        blank=True,
+        related_name="inactive_user",
+    )
+    active_confirmation_id = models.UUIDField(
+        default=uuid.uuid4, unique=True, editable=False, null=True
+    )
+    inactive_confirmation_id = models.UUIDField(
+        default=uuid.uuid4, unique=True, editable=False, null=True
+    )
+
+    status = models.CharField(
+        max_length=20,
+        choices=[
+            ("pending", _("Pending")),
+            ("ready", _("Ready")),
+            ("done", _("Done")),
+            ("error", _("Error")),
+        ],
+        default="pending",
+    )
+    logs = models.TextField(blank=True)
+
+    class Meta:
+        verbose_name = _("user reconciliation")
+        verbose_name_plural = _("user reconciliations")
+        ordering = ["-created_at"]
+
+    def __str__(self):
+        return f"Reconciliation from {self.inactive_email} to {self.active_email}"
+
+    def save(self, *args, **kwargs):
+        """
+        For pending queries, identify the actual users and send validation emails
+        """
+        if self.status == "pending":
+            self.active_user = User.objects.filter(email=self.active_email).first()
+            self.inactive_user = User.objects.filter(email=self.inactive_email).first()
+
+            if self.active_user and self.inactive_user:
+                if not self.active_email_checked:
+                    self.send_reconciliation_confirm_email(
+                        self.active_user, "active", self.active_confirmation_id
+                    )
+                if not self.inactive_email_checked:
+                    self.send_reconciliation_confirm_email(
+                        self.inactive_user, "inactive", self.inactive_confirmation_id
+                    )
+                self.status = "ready"
+            else:
+                self.status = "error"
+                self.logs = "Error: Both active and inactive users need to exist."
+
+        super().save(*args, **kwargs)
+
+    def process_documentaccess_reconciliation(self):
+        """
+        Process the reconciliation by transferring document accesses from the inactive user
+        to the active user.
+        """
+        updated_accesses = []
+        removed_accesses = []
+        inactive_accesses = DocumentAccess.objects.filter(user=self.inactive_user)
+
+        # Check documents where the active user already has access
+        documents_with_both_users = inactive_accesses.values_list("document", flat=True)
+        existing_accesses = DocumentAccess.objects.filter(user=self.active_user).filter(
+            document__in=documents_with_both_users
+        )
+        existing_roles_per_doc = dict(existing_accesses.values_list("document", "role"))
+
+        for entry in inactive_accesses:
+            if entry.document_id in existing_roles_per_doc:
+                # Update role if needed
+                existing_role = existing_roles_per_doc[entry.document_id]
+                max_role = RoleChoices.max(entry.role, existing_role)
+                if existing_role != max_role:
+                    existing_access = existing_accesses.get(document=entry.document)
+                    existing_access.role = max_role
+                    updated_accesses.append(existing_access)
+                removed_accesses.append(entry)
+            else:
+                entry.user = self.active_user
+                updated_accesses.append(entry)
+
+        self.logs += f"""Requested update for {len(updated_accesses)} DocumentAccess items
+            and deletion for {len(removed_accesses)} DocumentAccess items.\n"""
+        self.status = "done"
+        self.send_reconciliation_done_email()
+
+        self.save()
+
+        return updated_accesses, removed_accesses
+
+    def send_reconciliation_confirm_email(
+        self, user, user_type, confirmation_id, language=None
+    ):
+        """Method allowing to send confirmation email for reconciliation requests."""
+        language = language or get_language()
+        domain = Site.objects.get_current().domain
+
+        with override(language):
+            subject = _("Confirm by clicking the link to start the reconciliation")
+            context = {
+                "title": subject,
+                "message_bold": _(
+                    "You have requested a reconciliation of your user accounts on Docs."
+                ),
+                "message": _(
+                    """To confirm that you are the one who initiated the request
+                    and that this email belongs to you:"""
+                ),
+                "link": f"{domain}/user_reconciliations/{user_type}/{confirmation_id}/",
+                "link_label": str(_("Click here")),
+                "button_label": str(_("Confirm")),
+            }
+
+        user.send_email(subject, context, language)
+
+    def send_reconciliation_done_email(self, language=None):
+        """Method allowing to send done email for reconciliation requests."""
+        language = language or get_language()
+        domain = Site.objects.get_current().domain
+
+        with override(language):
+            subject = _("Your accounts have been merged")
+            context = {
+                "title": subject,
+                "message_bold": _("Your reconciliation request has been processed."),
+                "message": _("New documents are likely associated with your account:"),
+                "link": f"{domain}/",
+                "link_label": str(_("Click here to see")),
+                "button_label": str(_("See my documents")),
+            }
+
+        self.active_user.send_email(subject, context, language)
+
+
+class UserReconciliationCsvImport(BaseModel):
+    """Model to import reconciliations requests from an external source
+    (eg, )"""
+
+    file = models.FileField(upload_to="imports/")
+    status = models.CharField(
+        max_length=20,
+        choices=[
+            ("pending", _("Pending")),
+            ("running", _("Running")),
+            ("done", _("Done")),
+            ("error", _("Error")),
+        ],
+        default="pending",
+    )
+    logs = models.TextField(blank=True)
+
+    class Meta:
+        verbose_name = _("user reconciliation CSV import")
+        verbose_name_plural = _("user reconciliation CSV imports")
+
+    def __str__(self):
+        return f"User reconciliation CSV import {self.id}"
+
+    def send_email(self, subject, emails, context=None, language=None):
+        """Generate and send email to the user from a template."""
+        context = context or {}
+        domain = Site.objects.get_current().domain
+        language = language or get_language()
+        context.update(
+            {
+                "brandname": settings.EMAIL_BRAND_NAME,
+                "domain": domain,
+                "logo_img": settings.EMAIL_LOGO_IMG,
+            }
+        )
+
+        with override(language):
+            msg_html = render_to_string("mail/html/user_template.html", context)
+            msg_plain = render_to_string("mail/text/user_template.txt", context)
+            subject = str(subject)  # Force translation
+
+            try:
+                send_mail(
+                    subject.capitalize(),
+                    msg_plain,
+                    settings.EMAIL_FROM,
+                    emails,
+                    html_message=msg_html,
+                    fail_silently=False,
+                )
+            except smtplib.SMTPException as exception:
+                logger.error("invitation to %s was not sent: %s", emails, exception)
+
+    def send_reconciliation_error_email(self, email_1, email_2, language=None):
+        """Method allowing to send email for reconciliation requests with errors."""
+        language = language or get_language()
+        domain = Site.objects.get_current().domain
+
+        emails = [email_1, email_2]
+
+        with override(language):
+            subject = _("Reconciliation of your Docs accounts not completed")
+            context = {
+                "title": subject,
+                "message_bold": _("Your request for reconciliation was unsuccessful."),
+                "message": _(
+                    """Reconciliation failed for the following email addresses:
+
+                            - {email1}
+                            - {email2}
+
+                            Please check for typos.
+
+                            You can submit another request with the valid email addresses.
+                             """
+                ).format(email1=email_1, email2=email_2),
+                "link": f"{domain}/",
+                "link_label": str(_("Click here")),
+                "button_label": str(_("Make a new request")),
+            }
+
+        self.send_email(subject, emails, context, language)
+
+
 class BaseAccess(BaseModel):
    """Base model for accesses to handle resources."""

@@ -0,0 +1,98 @@
+"""Processing tasks for user reconciliation CSV imports."""
+
+import csv
+import traceback
+import uuid
+
+from django.core.exceptions import ValidationError
+from django.core.validators import validate_email
+from django.db import IntegrityError
+
+from botocore.exceptions import ClientError
+
+from core.models import UserReconciliation, UserReconciliationCsvImport
+
+from impress.celery_app import app
+
+
+@app.task
+def user_reconciliation_csv_import_job(job_id):
+    """Process a UserReconciliationCsvImport job.
+    Creates UserReconciliation entries from the CSV file.
+
+    Does some sanity checks on the data:
+    - active_email and inactive_email must be valid email addresses
+    - active_email and inactive_email cannot be the same
+    """
+    # Imports the CSV file, breaks it into UserReconciliation items
+    job = UserReconciliationCsvImport.objects.get(id=job_id)
+    job.status = "running"
+    job.save()
+
+    try:
+        with job.file.open(mode="r") as f:
+            reader = csv.DictReader(f)
+            rec_entries_created = 0
+            for row in reader:
+                status = row["status"]
+
+                if status == "pending":
+                    active_email_checked = row.get("active_email_checked", "0") == "1"
+                    inactive_email_checked = (
+                        row.get("inactive_email_checked", "0") == "1"
+                    )
+
+                    active_email = row["active_email"]
+                    inactive_emails = row["inactive_email"].split("|")
+                    try:
+                        validate_email(active_email)
+                    except ValidationError as e:
+                        job.send_reconciliation_error_email(
+                            active_email, inactive_emails[0]
+                        )
+                        job.status = "error"
+                        job.logs = f"{e!s}\n{traceback.format_exc()}"
+
+                    for inactive_email in inactive_emails:
+                        try:
+                            validate_email(inactive_email)
+                        except ValidationError as e:
+                            job.send_reconciliation_error_email(
+                                active_email, inactive_email
+                            )
+                            job.status = "error"
+                            job.logs = f"{e!s}\n{traceback.format_exc()}"
+                        if inactive_email == active_email:
+                            raise ValueError(
+                                "Active and inactive emails cannot be the same."
+                            )
+
+                        rec_entry = UserReconciliation.objects.create(
+                            active_email=active_email,
+                            inactive_email=inactive_email,
+                            active_email_checked=active_email_checked,
+                            inactive_email_checked=inactive_email_checked,
+                            active_confirmation_id=uuid.uuid4(),
+                            inactive_confirmation_id=uuid.uuid4(),
+                            status="pending",
+                        )
+                        rec_entry.save()
+                        rec_entries_created += 1
+
+        job.status = "done"
+        job.logs = f"""Import completed successfully. {reader.line_num} rows processed.
+        {rec_entries_created} reconciliation entries created."""
+    except (
+        csv.Error,
+        KeyError,
+        ValueError,
+        ValidationError,
+        IntegrityError,
+        OSError,
+        ClientError,
+    ) as e:
+        # Catch expected I/O/CSV/model errors and record traceback in logs for debugging
+        job.status = "error"
+        job.logs = f"{e!s}\n{traceback.format_exc()}"
+    finally:
+        job.save()
@@ -0,0 +1,6 @@
+active_email,inactive_email,active_email_checked,inactive_email_checked,status
+"[email protected]","[email protected]",0,0,pending
+"[email protected]","[email protected]",0,1,pending
+"[email protected]","[email protected]",1,0,pending
+"[email protected]","[email protected]",1,1,pending
+"[email protected]","[email protected]",1,1,pending
@@ -0,0 +1,2 @@
+active_email,inactive_email,active_email_checked,inactive_email_checked,status
+"[email protected]",,0,0,pending
@@ -0,0 +1,5 @@
+merge_accept,active_email,inactive_email,status
+true,[email protected],[email protected]|[email protected],pending
+true,[email protected],[email protected]|[email protected]|[email protected]|[email protected]|[email protected],pending
+true,[email protected],[email protected],pending
+true,[email protected],[email protected],pending
@@ -0,0 +1,2 @@
+merge_accept,active_email,inactive_email,status
+true,[email protected],[email protected],pending
@@ -0,0 +1,396 @@
+"""
+Unit tests for the UserReconciliationCsvImport model
+"""
+
+import uuid
+from pathlib import Path
+
+from django.core import mail
+from django.core.files.base import ContentFile
+
+import pytest
+
+from core import factories, models
+from core.admin import process_reconciliation
+from core.tasks.user_reconciliation import user_reconciliation_csv_import_job
+
+pytestmark = pytest.mark.django_db
+
+
+@pytest.fixture(name="import_example_csv_basic")
+def fixture_import_example_csv_basic():
+    """
+    Import an example CSV file for user reconciliation
+    and return the created import object.
+    """
+    # Create users referenced in the CSV
+    for i in range(40, 50):
+        factories.UserFactory(email=f"user.test{i}@example.com")
+
+    example_csv_path = Path(__file__).parent / "data/example_reconciliation_basic.csv"
+    with open(example_csv_path, "rb") as f:
+        csv_file = ContentFile(f.read(), name="example_reconciliation_basic.csv")
+    csv_import = models.UserReconciliationCsvImport(file=csv_file)
+    csv_import.save()
+
+    return csv_import
+
+
+@pytest.fixture(name="import_example_csv_grist_form")
+def fixture_import_example_csv_grist_form():
+    """
+    Import an example CSV file for user reconciliation
+    and return the created import object.
+    """
+    # Create users referenced in the CSV
+    for i in range(10, 40):
+        factories.UserFactory(email=f"user.test{i}@example.com")
+
+    example_csv_path = (
+        Path(__file__).parent / "data/example_reconciliation_grist_form.csv"
+    )
+    with open(example_csv_path, "rb") as f:
+        csv_file = ContentFile(f.read(), name="example_reconciliation_grist_form.csv")
+    csv_import = models.UserReconciliationCsvImport(file=csv_file)
+    csv_import.save()
+
+    return csv_import
+
+
+def test_user_reconciliation_csv_import_entry_is_created(import_example_csv_basic):
+    """Test that a UserReconciliationCsvImport entry is created correctly."""
+    assert import_example_csv_basic.status == "pending"
+    assert import_example_csv_basic.file.name.endswith(
+        "example_reconciliation_basic.csv"
+    )
+
+
+def test_user_reconciliation_csv_import_entry_is_created_grist_form(
+    import_example_csv_grist_form,
+):
+    """Test that a UserReconciliationCsvImport entry is created correctly."""
+    assert import_example_csv_grist_form.status == "pending"
+    assert import_example_csv_grist_form.file.name.endswith(
+        "example_reconciliation_grist_form.csv"
+    )
+
+
+def test_incorrect_csv_format_handling():
+    """Test that an incorrectly formatted CSV file is handled gracefully."""
+    example_csv_path = Path(__file__).parent / "data/example_reconciliation_error.csv"
+    with open(example_csv_path, "rb") as f:
+        csv_file = ContentFile(f.read(), name="example_reconciliation_error.csv")
+    csv_import = models.UserReconciliationCsvImport(file=csv_file)
+    csv_import.save()
+
+    assert csv_import.status == "pending"
+
+    user_reconciliation_csv_import_job(csv_import.id)
+    csv_import.refresh_from_db()
+
+    assert "This field cannot be blank" in csv_import.logs
+    assert csv_import.status == "error"
+
+    # pylint: disable-next=no-member
+    assert len(mail.outbox) == 1
+
+    # pylint: disable-next=no-member
+    email = mail.outbox[0]
+
+    assert email.to == ["[email protected]", ""]
+    email_content = " ".join(email.body.split())
+
+    assert "Reconciliation of your Docs accounts not completed" in email_content
+
+
+def test_incorrect_csv_data_handling_grist_form():
+    """Test that a CSV file with incorrect data is handled gracefully."""
+    example_csv_path = (
+        Path(__file__).parent / "data/example_reconciliation_grist_form_error.csv"
+    )
+    with open(example_csv_path, "rb") as f:
+        csv_file = ContentFile(
+            f.read(), name="example_reconciliation_grist_form_error.csv"
+        )
+    csv_import = models.UserReconciliationCsvImport(file=csv_file)
+    csv_import.save()
+
+    assert csv_import.status == "pending"
+
+    user_reconciliation_csv_import_job(csv_import.id)
+    csv_import.refresh_from_db()
+
+    assert "Active and inactive emails cannot be the same." in csv_import.logs
+    assert csv_import.status == "error"
+
+
+def test_job_creates_reconciliation_entries(import_example_csv_basic):
+    """Test that the CSV import job creates UserReconciliation entries."""
+    assert import_example_csv_basic.status == "pending"
+    user_reconciliation_csv_import_job(import_example_csv_basic.id)
+
+    # Verify the job status changed
+    import_example_csv_basic.refresh_from_db()
+    assert import_example_csv_basic.status == "done"
+    assert "Import completed successfully." in import_example_csv_basic.logs
+    assert "6 rows processed." in import_example_csv_basic.logs
+    assert "5 reconciliation entries created." in import_example_csv_basic.logs
+
+    # Verify reconciliation entries were created
+    reconciliations = models.UserReconciliation.objects.all()
+    assert reconciliations.count() == 5
+
+
+def test_job_creates_reconciliation_entries_grist_form(import_example_csv_grist_form):
+    """Test that the CSV import job creates UserReconciliation entries."""
+    assert import_example_csv_grist_form.status == "pending"
+    user_reconciliation_csv_import_job(import_example_csv_grist_form.id)
+
+    # Verify the job status changed
+    import_example_csv_grist_form.refresh_from_db()
+    assert "Import completed successfully" in import_example_csv_grist_form.logs
+    assert import_example_csv_grist_form.status == "done"
+
+    # Verify reconciliation entries were created
+    reconciliations = models.UserReconciliation.objects.all()
+    assert reconciliations.count() == 9
+
+
+def test_csv_import_reconciliation_data_is_correct(import_example_csv_basic):
+    """Test that the data in created UserReconciliation entries matches the CSV."""
+    user_reconciliation_csv_import_job(import_example_csv_basic.id)
+
+    reconciliations = models.UserReconciliation.objects.order_by("created_at")
+    first_entry = reconciliations.first()
+
+    assert first_entry.active_email == "[email protected]"
+    assert first_entry.inactive_email == "[email protected]"
+    assert first_entry.active_email_checked is False
+    assert first_entry.inactive_email_checked is False
+
+    for rec in reconciliations:
+        assert rec.status == "ready"
+
+
+@pytest.fixture(name="user_reconciliation_users_and_docs")
+def fixture_user_reconciliation_users_and_docs():
+    """Fixture to create two users with overlapping document accesses
+    for reconciliation tests."""
+    user_1 = factories.UserFactory(email="[email protected]")
+    user_2 = factories.UserFactory(email="[email protected]")
+
+    # Create 10 distinct document accesses for each user
+    userdocs_u1 = [
+        factories.UserDocumentAccessFactory(user=user_1, role="editor")
+        for _ in range(10)
+    ]
+    userdocs_u2 = [
+        factories.UserDocumentAccessFactory(user=user_2, role="editor")
+        for _ in range(10)
+    ]
+
+    # Make the first 3 documents of each list shared with the other user
+    # with a lower role
+    for ud in userdocs_u1[0:3]:
+        factories.UserDocumentAccessFactory(
+            user=user_2, document=ud.document, role="reader"
+        )
+
+    for ud in userdocs_u2[0:3]:
+        factories.UserDocumentAccessFactory(
+            user=user_1, document=ud.document, role="reader"
+        )
+
+    # Make the next 3 documents of each list shared with the other user
+    # with a higher role
+    for ud in userdocs_u1[3:6]:
+        factories.UserDocumentAccessFactory(
+            user=user_2, document=ud.document, role="owner"
+        )
+
+    for ud in userdocs_u2[3:6]:
+        factories.UserDocumentAccessFactory(
+            user=user_1, document=ud.document, role="owner"
+        )
+
+    return (user_1, user_2, userdocs_u1, userdocs_u2)
+
+
+def test_user_reconciliation_is_created(user_reconciliation_users_and_docs):
+    """Test that a UserReconciliation entry can be created and saved."""
+    user_1, user_2, _userdocs_u1, _userdocs_u2 = user_reconciliation_users_and_docs
+    rec = models.UserReconciliation.objects.create(
+        active_email=user_1.email,
+        inactive_email=user_2.email,
+        active_email_checked=False,
+        inactive_email_checked=True,
+        active_confirmation_id=uuid.uuid4(),
+        inactive_confirmation_id=uuid.uuid4(),
+        status="pending",
+    )
+
+    rec.save()
+    assert rec.status == "ready"
+
+
+def test_user_reconciliation_verification_emails_are_sent(
+    user_reconciliation_users_and_docs,
+):
+    """Test that both UserReconciliation verification emails are sent."""
+    user_1, user_2, _userdocs_u1, _userdocs_u2 = user_reconciliation_users_and_docs
+    rec = models.UserReconciliation.objects.create(
+        active_email=user_1.email,
+        inactive_email=user_2.email,
+        active_email_checked=False,
+        inactive_email_checked=False,
+        active_confirmation_id=uuid.uuid4(),
+        inactive_confirmation_id=uuid.uuid4(),
+        status="pending",
+    )
+
+    rec.save()
+
+    # pylint: disable-next=no-member
+    assert len(mail.outbox) == 2
+
+    # pylint: disable-next=no-member
+    email_1 = mail.outbox[0]
+
+    assert email_1.to == [user_1.email]
+    email_1_content = " ".join(email_1.body.split())
+
+    assert (
+        "You have requested a reconciliation of your user accounts on Docs."
+        in email_1_content
+    )
+    active_confirmation_id = rec.active_confirmation_id
+    inactive_confirmation_id = rec.inactive_confirmation_id
+    assert f"user_reconciliations/active/{active_confirmation_id}/" in email_1_content
+
+    # pylint: disable-next=no-member
+    email_2 = mail.outbox[1]
+
+    assert email_2.to == [user_2.email]
+    email_2_content = " ".join(email_2.body.split())
+
+    assert (
+        "You have requested a reconciliation of your user accounts on Docs."
+        in email_2_content
+    )
+
+    assert (
+        f"user_reconciliations/inactive/{inactive_confirmation_id}/" in email_2_content
+    )
+
+
+def test_user_reconciliation_only_starts_if_checks_are_made(
+    user_reconciliation_users_and_docs,
+):
+    """Test that the admin action does not process entries
+    unless both email checks are confirmed.
+    """
+    user_1, user_2, _userdocs_u1, _userdocs_u2 = user_reconciliation_users_and_docs
+
+    # Create a reconciliation entry where only one email has been checked
+    rec = models.UserReconciliation.objects.create(
+        active_email=user_1.email,
+        inactive_email=user_2.email,
+        active_email_checked=True,
+        inactive_email_checked=False,
+        status="pending",
+    )
+    rec.save()
+
+    # Capture counts before running admin action
+    accesses_before_active = models.DocumentAccess.objects.filter(user=user_1).count()
+    accesses_before_inactive = models.DocumentAccess.objects.filter(user=user_2).count()
+    users_active_before = (user_1.is_active, user_2.is_active)
+
+    # Call the admin action with the queryset containing our single rec
+    qs = models.UserReconciliation.objects.filter(id=rec.id)
+    process_reconciliation(None, None, qs)
+
+    # Reload from DB and assert nothing was processed (checks prevent processing)
+    rec.refresh_from_db()
+    user_1.refresh_from_db()
+    user_2.refresh_from_db()
+
+    assert rec.status == "ready"
+    assert (
+        models.DocumentAccess.objects.filter(user=user_1).count()
+        == accesses_before_active
+    )
+    assert (
+        models.DocumentAccess.objects.filter(user=user_2).count()
+        == accesses_before_inactive
+    )
+    assert (user_1.is_active, user_2.is_active) == users_active_before
+
+
+def test_process_documentaccess_reconciliation(
+    user_reconciliation_users_and_docs,
+):
+    """Use the fixture to verify accesses are consolidated on the active user."""
+    user_1, user_2, userdocs_u1, userdocs_u2 = user_reconciliation_users_and_docs
+
+    u1_2 = userdocs_u1[2]
+    u1_5 = userdocs_u1[5]
+    u2doc1 = userdocs_u2[1].document
+    u2doc5 = userdocs_u2[5].document
+
+    rec = models.UserReconciliation.objects.create(
+        active_email=user_1.email,
+        inactive_email=user_2.email,
+        active_user=user_1,
+        inactive_user=user_2,
+        active_email_checked=True,
+        inactive_email_checked=True,
+        status="ready",
+    )
+
+    qs = models.UserReconciliation.objects.filter(id=rec.id)
+    process_reconciliation(None, None, qs)
+
+    rec.refresh_from_db()
+    user_1.refresh_from_db()
+    user_2.refresh_from_db()
+    u1_2.refresh_from_db(
+        from_queryset=models.DocumentAccess.objects.select_for_update()
+    )
+    u1_5.refresh_from_db(
+        from_queryset=models.DocumentAccess.objects.select_for_update()
+    )
+
+    # After processing, inactive user should have no accesses
+    # and active user should have one access per union document
+    # with the highest role
+    assert rec.status == "done"
+    assert "Requested update for 10 DocumentAccess items" in rec.logs
+    assert "and deletion for 12 DocumentAccess items" in rec.logs
+    assert models.DocumentAccess.objects.filter(user=user_2).count() == 0
+    assert models.DocumentAccess.objects.filter(user=user_1).count() == 20
+    assert u1_2.role == "editor"
+    assert u1_5.role == "owner"
+
+    assert (
+        models.DocumentAccess.objects.filter(user=user_1, document=u2doc1).first().role
+        == "editor"
+    )
+    assert (
+        models.DocumentAccess.objects.filter(user=user_1, document=u2doc5).first().role
+        == "owner"
+    )
+
+    assert user_1.is_active is True
+    assert user_2.is_active is False
+
+    # pylint: disable-next=no-member
+    assert len(mail.outbox) == 1
+
+    # pylint: disable-next=no-member
+    email = mail.outbox[0]
+
+    assert email.to == [user_1.email]
+    email_content = " ".join(email.body.split())
+
+    assert "Your accounts have been merged" in email_content
@@ -7,6 +7,7 @@ from lasuite.oidc_login.urls import urlpatterns as oidc_urls
 from rest_framework.routers import DefaultRouter

 from core.api import viewsets
+from core.api.viewsets import ReconciliationConfirmView

 # - Main endpoints
 router = DefaultRouter()
@@ -60,6 +61,10 @@ urlpatterns = [
                    r"^documents/(?P<resource_id>[0-9a-z-]*)/threads/(?P<thread_id>[0-9a-z-]*)/",
                    include(thread_related_router.urls),
                ),
+                path(
+                    "user_reconciliations/<str:user_type>/<uuid:confirmation_id>/",
+                    ReconciliationConfirmView.as_view(),
+                ),
            ]
        ),
    ),
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Breton\n"
 "Language: br_FR\n"
@@ -79,7 +79,7 @@ msgstr "Doare korf"
 msgid "Format"
 msgstr "Stumm"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "eilenn {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: German\n"
 "Language: de_DE\n"
@@ -79,7 +79,7 @@ msgstr "Typ"
 msgid "Format"
 msgstr "Format"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "Kopie von {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: English\n"
 "Language: en_US\n"
@@ -79,7 +79,7 @@ msgstr ""
 msgid "Format"
 msgstr ""

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr ""
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Spanish\n"
 "Language: es_ES\n"
@@ -79,7 +79,7 @@ msgstr "Tipo de Cuerpo"
 msgid "Format"
 msgstr "Formato"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "copia de {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: French\n"
 "Language: fr_FR\n"
@@ -79,7 +79,7 @@ msgstr "Type de corps"
 msgid "Format"
 msgstr "Format"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "copie de {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Italian\n"
 "Language: it_IT\n"
@@ -79,7 +79,7 @@ msgstr ""
 msgid "Format"
 msgstr "Formato"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "copia di {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Dutch\n"
 "Language: nl_NL\n"
@@ -79,7 +79,7 @@ msgstr "Text type"
 msgid "Format"
 msgstr "Formaat"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "kopie van {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Portuguese\n"
 "Language: pt_PT\n"
@@ -79,7 +79,7 @@ msgstr "Tipo de corpo"
 msgid "Format"
 msgstr "Formato"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "cópia de {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Russian\n"
 "Language: ru_RU\n"
@@ -79,7 +79,7 @@ msgstr "Тип сообщения"
 msgid "Format"
 msgstr "Формат"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "копия {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Slovenian\n"
 "Language: sl_SI\n"
@@ -79,7 +79,7 @@ msgstr "Vrsta telesa"
 msgid "Format"
 msgstr "Oblika"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr ""
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Swedish\n"
 "Language: sv_SE\n"
@@ -79,7 +79,7 @@ msgstr ""
 msgid "Format"
 msgstr "Format"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr ""
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Turkish\n"
 "Language: tr_TR\n"
@@ -79,7 +79,7 @@ msgstr ""
 msgid "Format"
 msgstr ""

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr ""
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Ukrainian\n"
 "Language: uk_UA\n"
@@ -79,7 +79,7 @@ msgstr "Тип вмісту"
 msgid "Format"
 msgstr "Формат"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "копія {title}"
@@ -2,8 +2,8 @@ msgid ""
 msgstr ""
 "Project-Id-Version: lasuite-docs\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2025-12-16 21:44+0000\n"
-"PO-Revision-Date: 2026-01-05 08:21\n"
+"POT-Creation-Date: 2026-01-08 15:38+0000\n"
+"PO-Revision-Date: 2026-01-13 13:17\n"
 "Last-Translator: \n"
 "Language-Team: Chinese Simplified\n"
 "Language: zh_CN\n"
@@ -79,7 +79,7 @@ msgstr "正文类型"
 msgid "Format"
 msgstr "格式"

-#: build/lib/core/api/viewsets.py:1024 core/api/viewsets.py:1024
+#: build/lib/core/api/viewsets.py:1081 core/api/viewsets.py:1081
 #, python-brace-format
 msgid "copy of {title}"
 msgstr "{title} 的副本"
@@ -0,0 +1,62 @@
+<mjml>
+  <mj-include path="./partial/header.mjml" />
+
+  <mj-body mj-class="bg--blue-100">
+    <mj-wrapper css-class="wrapper" padding="5px 25px 0px 25px">
+      <mj-section css-class="wrapper-logo">
+        <mj-column>
+          <mj-image
+            align="center"
+            src="{{logo_img}}"
+            width="320px"
+            align="left"
+            alt="{%trans 'Logo email' %}"
+          />
+        </mj-column>
+      </mj-section>
+      <mj-section mj-class="bg--white-100" padding="0px 20px 60px 20px">
+        <mj-column>
+          <mj-text align="center">
+            <h1>{{title|capfirst}}</h1>
+          </mj-text>
+          <!-- Main Message -->
+          <mj-text font-weight="bold">
+            {{message_bold|capfirst}}
+          </mj-text>
+          <mj-text>
+            {{message|capfirst}}
+            <a href="{{link}}">{{link_label}}</a>
+          </mj-text>
+          <mj-button
+            href="{{link}}"
+            background-color="#000091"
+            color="white"
+            padding-bottom="30px"
+          >
+            {{button_label}}
+          </mj-button>
+          <mj-divider
+            border-width="1px"
+            border-style="solid"
+            border-color="#DDDDDD"
+            width="30%"
+            align="center"
+          />
+          <mj-text>
+            {% blocktrans %}
+              Docs, your new essential tool for organizing, sharing and collaborating on your documents as a team.
+            {% endblocktrans %}
+          </mj-text>
+          <!-- Signature -->
+          <mj-text>
+            <p>
+              {% blocktrans %}
+                Brought to you by {{brandname}}
+              {% endblocktrans %}
+            </p>
+          </mj-text>
+        </mj-column>
+      </mj-section>
+    </mj-wrapper>
+  </mj-body>
+</mjml>