Create Pretix voucher and email on grantee confirmation

Queue `create_and_send_voucher_to_grantee` when `sendGrantReply` moves status
to `confirmed`. Task mirrors schedule voucher flow: Pretix via
`create_conference_voucher`, then grant_voucher_code email.

Grant admin Create grant vouchers now uses `create_conference_voucher` and
handles co-speaker upgrade. Grant pending-status proxy keeps shared
confirm_pending_status from custom_admin.

Tests patch Pretix in grant voucher admin tests; sendGrantReply tests
assert voucher task on confirm only.

Author: estyxx

backend/api/grants/mutations.py

@@ -15,7 +15,11 @@
     create_change_admin_log_entry,
 )
 from grants.models import Grant as GrantModel
-from grants.tasks import get_name, notify_new_grant_reply_slack
+from grants.tasks import (
+    create_and_send_voucher_to_grantee,
+    get_name,
+    notify_new_grant_reply_slack,
+)
 from notifications.models import EmailTemplate, EmailTemplateIdentifier
 from participants.models import Participant
 from privacy_policy.record import record_privacy_policy_acceptance
@@ -342,9 +346,13 @@ def send_grant_reply(
         if grant.status in (GrantModel.Status.pending, GrantModel.Status.rejected):
             return SendGrantReplyError(message="You cannot reply to this grant")
 
+        old_status = grant.status
         grant.status = input.status.to_grant_status()
         grant.save()
 
+        if old_status != grant.status and grant.status == GrantModel.Status.confirmed:
+            create_and_send_voucher_to_grantee.delay(grant_id=grant.id)
+
         create_change_admin_log_entry(
             request.user, grant, f"Grantee has replied with status {grant.status}."
         )

backend/api/grants/tests/test_send_grant_reply.py

@@ -75,9 +75,12 @@ def test_user_cannot_reply_if_status_is_rejected(graphql_client, user):
     )
 
 
-def test_status_is_updated_when_reply_is_confirmed(graphql_client, user):
+def test_status_is_updated_when_reply_is_confirmed(graphql_client, user, mocker):
     graphql_client.force_login(user)
     grant = GrantFactory(user_id=user.id, status=Grant.Status.waiting_for_confirmation)
+    mock_voucher = mocker.patch(
+        "api.grants.mutations.create_and_send_voucher_to_grantee"
+    )
 
     response = _send_grant_reply(graphql_client, grant, status="confirmed")
 
@@ -86,6 +89,8 @@ def test_status_is_updated_when_reply_is_confirmed(graphql_client, user):
     grant.refresh_from_db()
     assert grant.status == Grant.Status.confirmed
 
+    mock_voucher.delay.assert_called_once_with(grant_id=grant.id)
+
     # Verify audit log entry was created correctly
     assert LogEntry.objects.filter(
         user=user,
@@ -94,9 +99,12 @@ def test_status_is_updated_when_reply_is_confirmed(graphql_client, user):
     ).exists()
 
 
-def test_status_is_updated_when_reply_is_refused(graphql_client, user):
+def test_status_is_updated_when_reply_is_refused(graphql_client, user, mocker):
     graphql_client.force_login(user)
     grant = GrantFactory(user_id=user.id, status=Grant.Status.waiting_for_confirmation)
+    mock_voucher = mocker.patch(
+        "api.grants.mutations.create_and_send_voucher_to_grantee"
+    )
 
     response = _send_grant_reply(graphql_client, grant, status="refused")
 
@@ -105,6 +113,9 @@ def test_status_is_updated_when_reply_is_refused(graphql_client, user):
     grant.refresh_from_db()
     assert grant.status == Grant.Status.refused
 
+    # Verify voucher was not sent
+    mock_voucher.delay.assert_not_called()
+
     # Verify audit log entry was created correctly
     assert LogEntry.objects.filter(
         user=user,

backend/grants/admin.py

@@ -15,6 +15,7 @@
 from import_export.resources import ModelResource
 
 from conferences.models.conference_voucher import ConferenceVoucher
+from conferences.vouchers import create_conference_voucher
 from countries import countries
 from countries.filters import CountryFilter
 from custom_admin.admin import (
@@ -49,6 +50,7 @@
 
 logger = logging.getLogger(__name__)
 
+
 EXPORT_GRANTS_FIELDS = (
     "name",
     "full_name",
@@ -299,18 +301,7 @@ def send_reply_email_waiting_list_update(modeladmin, request, queryset):
 @validate_single_conference_selection
 @transaction.atomic
 def create_grant_vouchers(modeladmin, request, queryset):
-    conference = queryset.first().conference
-    existing_vouchers_by_user_id = {
-        voucher.user_id: voucher
-        for voucher in ConferenceVoucher.objects.for_conference(conference).filter(
-            user_id__in=queryset.values_list("user_id", flat=True),
-        )
-    }
-
-    vouchers_to_create = []
-    vouchers_to_update = []
-
-    for grant in queryset.order_by("id"):
+    for grant in queryset.order_by("id").select_related("user", "conference"):
         if grant.status != Grant.Status.confirmed:
             messages.error(
                 request,
@@ -319,45 +310,56 @@ def create_grant_vouchers(modeladmin, request, queryset):
             )
             continue
 
-        existing_voucher = existing_vouchers_by_user_id.get(grant.user_id)
+        if not grant.user_id:
+            messages.error(
+                request,
+                f"Grant for {grant.name} has no user linked; can't create a voucher.",
+            )
+            continue
+
+        existing = (
+            ConferenceVoucher.objects.for_conference(grant.conference)
+            .for_user(grant.user)
+            .first()
+        )
 
-        if not existing_voucher:
+        if not existing:
+            create_conference_voucher(
+                conference=grant.conference,
+                user=grant.user,
+                voucher_type=ConferenceVoucher.VoucherType.GRANT,
+            )
             create_addition_admin_log_entry(
                 request.user,
                 grant,
                 change_message="Created voucher for this grant.",
             )
+            continue
 
-            vouchers_to_create.append(
-                ConferenceVoucher(
-                    conference_id=grant.conference_id,
-                    user_id=grant.user_id,
-                    voucher_code=ConferenceVoucher.generate_code(),
-                    voucher_type=ConferenceVoucher.VoucherType.GRANT,
-                )
-            )
+        if existing.voucher_type in (
+            ConferenceVoucher.VoucherType.GRANT,
+            ConferenceVoucher.VoucherType.SPEAKER,
+        ):
             continue
 
-        if existing_voucher.voucher_type == ConferenceVoucher.VoucherType.CO_SPEAKER:
+        if existing.voucher_type == ConferenceVoucher.VoucherType.CO_SPEAKER:
             messages.warning(
                 request,
-                f"Grant for {grant.name} already has a Co-Speaker voucher. Upgrading to a Grant voucher.",
+                f"Grant for {grant.name} already has a Co-Speaker voucher. "
+                "Upgrading to a Grant voucher.",
             )
             create_change_admin_log_entry(
                 request.user,
-                existing_voucher,
+                existing,
                 change_message="Upgraded Co-Speaker voucher to Grant voucher.",
             )
             create_change_admin_log_entry(
                 request.user,
                 grant,
                 change_message="Updated existing Co-Speaker voucher to grant.",
             )
-            existing_voucher.voucher_type = ConferenceVoucher.VoucherType.GRANT
-            vouchers_to_update.append(existing_voucher)
-
-    ConferenceVoucher.objects.bulk_create(vouchers_to_create, ignore_conflicts=True)
-    ConferenceVoucher.objects.bulk_update(vouchers_to_update, ["voucher_type"])
+            existing.voucher_type = ConferenceVoucher.VoucherType.GRANT
+            existing.save(update_fields=["voucher_type"])
 
     messages.success(request, "Vouchers created!")
 

backend/grants/tasks.py

@@ -5,6 +5,8 @@
 from django.conf import settings
 from django.utils import timezone
 
+from conferences.models.conference_voucher import ConferenceVoucher
+from conferences.vouchers import create_conference_voucher
 from grants.models import Grant
 from integrations import slack
 from notifications.models import EmailTemplate, EmailTemplateIdentifier
@@ -21,6 +23,80 @@ def get_name(user: User | None, fallback: str = "<no name specified>") -> str:
     return user.full_name or user.name or user.username or fallback
 
 
+@app.task
+def send_grant_voucher_email(*, grant_id: int) -> None:
+    grant = Grant.objects.select_related("conference", "user").get(pk=grant_id)
+    if not grant.user_id:
+        return
+
+    conference_voucher = (
+        ConferenceVoucher.objects.for_conference(grant.conference)
+        .for_user(grant.user)
+        .first()
+    )
+    if not conference_voucher:
+        return
+
+    visa_page_link = urljoin(settings.FRONTEND_URL, "/visa")
+    conference_name = grant.conference.name.localize("en")
+
+    email_template = EmailTemplate.objects.for_conference(
+        grant.conference
+    ).get_by_identifier(EmailTemplateIdentifier.grant_voucher_code)
+    email_template.send_email(
+        recipient=grant.user,
+        placeholders={
+            "conference_name": conference_name,
+            "user_name": get_name(grant.user, "there"),
+            "voucher_code": conference_voucher.voucher_code,
+            "has_approved_accommodation": grant.has_approved_accommodation(),
+            "visa_page_link": visa_page_link,
+        },
+    )
+
+    conference_voucher.voucher_email_sent_at = timezone.now()
+    conference_voucher.save(update_fields=["voucher_email_sent_at"])
+
+
+@app.task
+def create_and_send_voucher_to_grantee(*, grant_id: int) -> None:
+    grant = Grant.objects.select_related("user", "conference").get(pk=grant_id)
+    if grant.status != Grant.Status.confirmed:
+        return
+    if not grant.user_id:
+        return
+
+    user = grant.user
+    conference = grant.conference
+    conference_voucher = (
+        ConferenceVoucher.objects.for_conference(conference).for_user(user).first()
+    )
+
+    if conference_voucher:
+        if conference_voucher.voucher_type in (
+            ConferenceVoucher.VoucherType.GRANT,
+            ConferenceVoucher.VoucherType.SPEAKER,
+        ):
+            logger.info(
+                "User %s already has a voucher for conference %s, not creating a new one",
+                user.id,
+                conference.id,
+            )
+            return
+        if conference_voucher.voucher_type == ConferenceVoucher.VoucherType.CO_SPEAKER:
+            conference_voucher.voucher_type = ConferenceVoucher.VoucherType.GRANT
+            conference_voucher.save(update_fields=["voucher_type"])
+            send_grant_voucher_email.delay(grant_id=grant.id)
+            return
+
+    create_conference_voucher(
+        conference=conference,
+        user=user,
+        voucher_type=ConferenceVoucher.VoucherType.GRANT,
+    )
+    send_grant_voucher_email.delay(grant_id=grant.id)
+
+
 @app.task
 def send_grant_reply_approved_email(*, grant_id: int, is_reminder: bool) -> None:
     logger.info("Sending Reply APPROVED email for Grant %s", grant_id)

backend/grants/tests/test_admin.py

@@ -10,9 +10,9 @@
 from conferences.models.conference_voucher import ConferenceVoucher
 from conferences.tests.factories import ConferenceFactory, ConferenceVoucherFactory
 from grants.admin import (
-    confirm_pending_status,
     GrantAdmin,
     GrantReimbursementAdmin,
+    confirm_pending_status,
     create_grant_vouchers,
     mark_rejected_and_send_email,
     reset_pending_status_back_to_status,
@@ -305,6 +305,7 @@ def test_send_reply_email_waiting_list_update(rf, mocker, admin_user):
 
 def test_create_grant_vouchers(rf, mocker, admin_user):
     mock_messages = mocker.patch("grants.admin.messages")
+    mocker.patch("conferences.vouchers.create_voucher", return_value={"id": 999})
 
     conference = ConferenceFactory()
 
@@ -357,6 +358,7 @@ def test_create_grant_vouchers_with_existing_voucher_is_reused(
     rf, mocker, admin_user, type
 ):
     mock_messages = mocker.patch("grants.admin.messages")
+    mocker.patch("conferences.vouchers.create_voucher", return_value={"id": 999})
 
     conference = ConferenceFactory()
 
@@ -407,6 +409,7 @@ def test_create_grant_vouchers_with_voucher_from_other_conf_is_ignored(
     rf, mocker, type, admin_user
 ):
     mock_messages = mocker.patch("grants.admin.messages")
+    mocker.patch("conferences.vouchers.create_voucher", return_value={"id": 999})
 
     conference = ConferenceFactory()
     other_conference = ConferenceFactory()
@@ -461,6 +464,7 @@ def test_create_grant_vouchers_with_voucher_from_other_conf_is_ignored(
 
 def test_create_grant_vouchers_co_speaker_voucher_is_upgraded(rf, mocker, admin_user):
     mock_messages = mocker.patch("grants.admin.messages")
+    mocker.patch("conferences.vouchers.create_voucher", return_value={"id": 999})
 
     conference = ConferenceFactory()
 
@@ -506,6 +510,7 @@ def test_create_grant_vouchers_co_speaker_voucher_is_upgraded(rf, mocker, admin_
 
 def test_create_grant_vouchers_only_for_confirmed_grants(rf, mocker, admin_user):
     mock_messages = mocker.patch("grants.admin.messages")
+    mocker.patch("conferences.vouchers.create_voucher", return_value={"id": 999})
     conference = ConferenceFactory()
     grant_1 = GrantFactory(
         status=Grant.Status.refused,