feat: new API route to apply status changes after RSVP deadline

apps/api/src/routers/admin.py

@@ -125,12 +125,42 @@ async def release_decisions() -> None:
         group = [record for record in records if record["decision"] == decision]
         if not group:
             continue
-
         await asyncio.gather(
             *(_process_batch(batch, decision) for batch in batched(group, 100))
         )
 
 
+@router.post(
+        "/confirm-attendance", dependencies=
+        [Depends(require_role([Role.DIRECTOR]))]
+        )
+async def confirm_attendance() -> None:
+    """Update applicant status to void or attending based on their current status."""
+    records = await mongodb_handler.retrieve(
+        Collection.USERS,
+        {"role": Role.APPLICANT},
+        ["_id", "status"],
+    )
+
+    for record in records:
+        _set_confirmations(record)
+
+    for cur_status in (Status.ATTENDING, Status.VOID):
+        group = [record for record in records if record["status"] == cur_status]
+        await asyncio.gather(
+            *(_process_status(batch, cur_status) for batch in batched(group, 100))
+        )
+
+
+async def _process_status(batch: tuple[dict[str, Any], ...], status: Status) -> None:
+    uids: list[str] = [record["_id"] for record in batch]
+    ok = await mongodb_handler.update(
+        Collection.USERS, {"_id": {"$in": uids}}, {"status": status}
+    )
+    if not ok:
+        raise RuntimeError("gg wp")
+
+
 async def _process_batch(batch: tuple[dict[str, Any], ...], decision: Decision) -> None:
     uids: list[str] = [record["_id"] for record in batch]
     log.info(f"Setting {','.join(uids)} as {decision}")
@@ -165,3 +195,15 @@ def _include_review_decision(applicant_record: dict[str, Any]) -> None:
     """Sets the applicant's decision as the last submitted review decision or None."""
     reviews = applicant_record["application_data"]["reviews"]
     applicant_record["decision"] = reviews[-1][2] if reviews else None
+
+
+def _set_confirmations(applicant_record: dict[str, Any]) -> None:
+    """Sets the applicant's status based on their RSVP status"""
+
+    status = applicant_record["status"]
+    if status == Status.CONFIRMED:
+        applicant_record["status"] = Status.ATTENDING
+    elif status == Status.WAIVER_SIGNED:
+        applicant_record["status"] = Status.VOID
+    elif status == Decision.ACCEPTED:
+        applicant_record["status"] = Status.VOID

apps/api/src/utils/user_record.py

@@ -22,6 +22,8 @@ class Status(str, Enum):
     REVIEWED = "REVIEWED"
     WAIVER_SIGNED = "WAIVER_SIGNED"
     CONFIRMED = "CONFIRMED"
+    ATTENDING = "ATTENDING"
+    VOID = "VOID"
 
 
 class UserRecord(BaseRecord):

apps/api/tests/test_admin.py

@@ -128,6 +128,42 @@ def test_no_decision_from_no_reviews() -> None:
     assert record["decision"] is None
 
 
+def test_confirm_attendance_when_status_confirmed() -> None:
+    """Test that a decision is None for an applicant with no reviews."""
+    record = {
+        "_id": "edu.uci.Hey",
+        "status": "CONFIRMED",
+        "decision": "ACCEPTED",
+    }
+
+    admin._set_confirmations(record)
+    assert record["status"] == "ATTENDING"
+
+
+def test_confirm_attendance_when_status_accepted() -> None:
+    """Test that a decision is None for an applicant with no reviews."""
+    record = {
+        "_id": "edu.uci.Vsauce",
+        "status": "ACCEPTED",
+        "decision": "ACCEPTED",
+    }
+
+    admin._set_confirmations(record)
+    assert record["status"] == "VOID"
+
+
+def test_confirm_attendance_when_status_waiver_signed() -> None:
+    """Test that a decision is None for an applicant with no reviews."""
+    record = {
+        "_id": "edu.uci.Michael",
+        "status": "WAIVER_SIGNED",
+        "decision": "ACCEPTED",
+    }
+
+    admin._set_confirmations(record)
+    assert record["status"] == "VOID"
+
+
 @patch("services.mongodb_handler.raw_update_one", autospec=True)
 @patch("services.mongodb_handler.retrieve_one", autospec=True)
 def test_can_submit_review(