Add support for anonymous call purchases and account registration

- Introduced `AccountStatus.PENDING` to manage pending account states.
- Added `PurchaseAnonymousCallRequest` schema for anonymous call purchases.
- Implemented `create_anonymous_account_obj` to create accounts with pending status.
- Updated `create_call_obj` to handle both regular and anonymous calls.
- Enhanced email notifications for anonymous bookings.
- Added endpoint for completing account registration, updating status to active.

cbh/api/account/dto.py

@@ -22,6 +22,7 @@ class AccountStatus(Enum):
 
     ACTIVE = 1
     INACTIVE = 2
+    PENDING = 3
 
 
 class CoachOpportunity(Enum):

cbh/api/account/models.py

@@ -62,6 +62,6 @@ class AccountShorten(MongoBaseShortenModel):
 
     name: str | None = None
     email: str
-    pictureUrl: str | None = None
+    status: AccountStatus
 
     accountType: AccountType

cbh/api/calls/db_requests.py

@@ -18,40 +18,34 @@ from cbh.api.common.db_requests import get_all_objs
 from cbh.api.common.schemas import FilterRequest
 from cbh.api.events.dto import EventType
 from cbh.api.events.models import EventModel, EventShorten
+from cbh.api.security.db_requests import check_unique_fields_existence
 from cbh.core.config import settings
 
 
 async def create_call_obj(
-    event: EventModel,
+    request: PurchaseCallRequest,
     coach: AccountShorten,
     customer: AccountModel,
 ) -> CallModel:
     """
     Create a new call.
     """
-    call = CallModel(
-        event=EventShorten(**event.model_dump()),
-        customer=AccountShorten(**customer.model_dump()),
-        coach=coach,
-    )
-    await settings.DB_CLIENT.calls.insert_one(call.to_mongo())
-    return call
-
-
-async def create_event_obj(
-    request: PurchaseCallRequest, coach: AccountShorten
-) -> EventModel:
-    """
-    Create a new event.
-    """
     event = EventModel(
         type=EventType.CALL,
         startDate=request.startDate,
         endDate=request.endDate,
         coach=coach,
     )
-    await settings.DB_CLIENT.events.insert_one(event.to_mongo())
-    return event
+    call = CallModel(
+        event=EventShorten(**event.model_dump()),
+        customer=AccountShorten(**customer.model_dump()),
+        coach=coach,
+    )
+    await asyncio.gather(
+        settings.DB_CLIENT.events.insert_one(event.to_mongo()),
+        settings.DB_CLIENT.calls.insert_one(call.to_mongo()),
+    )
+    return call
 
 
 async def disable_call(call: CallModel) -> CallModel:
@@ -360,4 +354,22 @@ async def check_call_payment(call_id: str) -> StripeCheckResponse:
         raise HTTPException(status_code=404, detail="Call not found")
     is_processed = True if call["status"] == CallStatus.SCHEDULED.value else False
     success = call["event"]["isActive"]
-    return StripeCheckResponse(isProcessed=is_processed, success=success)
+    return StripeCheckResponse(
+        isProcessed=is_processed,
+        success=success,
+        isRequireRegistration=call["customer"]["status"] == AccountStatus.PENDING,
+    )
+
+
+async def create_anonymous_account_obj(email: str) -> AccountModel:
+    """
+    Create a new anonymous account.
+    """
+    await check_unique_fields_existence("email", email)
+    account = AccountModel(
+        email=email,
+        status=AccountStatus.PENDING,
+        accountType=AccountType.USER,
+    )
+    await settings.DB_CLIENT.accounts.insert_one(account.to_mongo())
+    return account

cbh/api/calls/schemas.py

@@ -24,6 +24,18 @@ class PurchaseCallRequest(BaseModel):
     discountCode: str | None = None
 
 
+class PurchaseAnonymousCallRequest(BaseModel):
+    """
+    Purchase anonymous call request.
+    """
+
+    email: str
+    startDate: datetime
+    endDate: datetime
+    coachId: str
+    discountCode: str | None = None
+
+
 class CallsFilter(BaseModel):
     """
     Calls filter.
@@ -53,6 +65,7 @@ class StripeCheckResponse(BaseModel):
 
     isProcessed: bool
     success: bool
+    isRequireRegistration: bool
 
 
 class DailyInitializeResponse(BaseModel):

cbh/api/calls/services/stripe.py

@@ -1,7 +1,8 @@
 import time
+from urllib.parse import urlencode
 
-import stripe
 import pydash
+import stripe
 from fastapi import HTTPException, Request
 
 from cbh.api.calls.db_requests import disable_call, enable_call
@@ -11,7 +12,9 @@ from cbh.api.common.db_requests import get_obj_by_id
 from cbh.core.config import settings
 
 
-async def create_stripe_session(call: CallModel, code: str | None) -> str:
+async def create_stripe_session(
+    call: CallModel, code: str | None, is_anonymous: bool = False
+) -> str:
     """
     Create a stripe session.
     """
@@ -19,6 +22,10 @@ async def create_stripe_session(call: CallModel, code: str | None) -> str:
         "callId": call.id,
     }
 
+    query_params = {"callId": call.id}
+    if is_anonymous:
+        query_params["accountId"] = call.customer.id
+
     checkout_session = await settings.STRIPE_CLIENT.v1.checkout.sessions.create_async(
         params={
             "customer_email": call.customer.email,
@@ -36,8 +43,8 @@ async def create_stripe_session(call: CallModel, code: str | None) -> str:
                 },
             ],
             "mode": "payment",
-            "success_url": f"{settings.Audience}/payment/success?callId={call.id}",
-            "cancel_url": f"{settings.Audience}/payment/cancel?callId={call.id}",
+            "success_url": f"{settings.Audience}/payment/success?{urlencode(query_params)}",
+            "cancel_url": f"{settings.Audience}/payment/cancel?{urlencode(query_params)}",
             "metadata": metadata,
             "discounts": [{"promotion_code": code}] if code else None,
             "expires_at": int(time.time()) + 1800,

cbh/api/calls/utils.py

@@ -192,3 +192,28 @@ async def send_session_reminder_coach_email(call: CallModel) -> None:
         f"Your session with {call.customer.name} is starting in 1 hour.",
         template_content,
     )
+
+
+async def send_anonymous_booking_email(call: CallModel) -> None:
+    """
+    Send a anonymous booking email.
+    """
+    templates_path = settings.BASE_DIR / "cbh" / "templates" / "emails"
+    env = Environment(
+        loader=FileSystemLoader(templates_path),
+        autoescape=select_autoescape(["html", "xml"]),
+    )
+    template = env.get_template("anonymousBookingConfirmation.html")
+    template_content = template.render(
+        coach_name=call.coach.name,
+        start_date=call.event.startDate.strftime("%d %B %Y, %H:%M"),
+        join_link=f"{settings.Audience}/calls/{call.id}",
+        duration=(call.event.endDate - call.event.startDate).total_seconds() // 60,
+        registration_link=f"{settings.Audience}/signup/complete?accountId={call.customer.id}",
+    )
+
+    await settings.EMAIL_CLIENT.send_email(
+        call.customer.email,
+        f"You're all set! Session with {call.coach.name} confirmed!",
+        template_content,
+    )

cbh/api/calls/views.py

@@ -3,15 +3,15 @@ from datetime import datetime
 
 from fastapi import Depends, Query, Request
 
-from cbh.api.account.dto import AccountType
+from cbh.api.account.dto import AccountStatus, AccountType
 from cbh.api.account.models import AccountModel, AccountShorten
 from cbh.api.calls import calls_router
 from cbh.api.calls.db_requests import (
     calculate_call_availabilities,
     cancel_call_obj,
     check_call_payment,
+    create_anonymous_account_obj,
     create_call_obj,
-    create_event_obj,
     filter_calls_objs,
 )
 from cbh.api.calls.models import CallModel
@@ -19,6 +19,7 @@ from cbh.api.calls.schemas import (
     CallAvailabilityResponse,
     CallsFilter,
     DailyInitializeResponse,
+    PurchaseAnonymousCallRequest,
     PurchaseCallRequest,
     StripeCheckResponse,
     StripeSessionResponse,
@@ -33,6 +34,7 @@ from cbh.api.calls.services import (
 from cbh.api.calls.services.daily import create_daily_token
 from cbh.api.calls.utils import (
     can_edit_call,
+    send_anonymous_booking_email,
     send_coach_booking_email,
     send_customer_booking_email,
     send_cancel_customer_email,
@@ -73,7 +75,7 @@ async def get_availabilities(
     startDate: datetime = Query(...),
     endDate: datetime = Query(...),
     discountCode: str | None = Query(None),
-    _: AccountModel = Depends(PermissionDependency([AccountType.USER])),
+    _: AccountModel = Depends(PermissionDependency([AccountType.USER], required=False)),
 ) -> CbhResponseWrapper[CallAvailabilityResponse]:
     """
     Get availabilities.
@@ -130,12 +132,30 @@ async def purchase_call(
         ),
         verify_discount_code(request.discountCode),
     )
-    event = await create_event_obj(request, coach)
-    call = await create_call_obj(event, coach, account)
+    call = await create_call_obj(request, coach, account)
     session_url = await create_stripe_session(call, promotion_code)
     return CbhResponseWrapper(data=StripeSessionResponse(sessionUrl=session_url))
 
 
+@calls_router.post("/purchase/anonymous")
+async def purchase_call_anonymous(
+    request: PurchaseAnonymousCallRequest,
+) -> CbhResponseWrapper[StripeSessionResponse]:
+    """
+    Purchase a call.
+    """
+    coach, promotion_code, account = await asyncio.gather(
+        get_obj_by_id(
+            AccountShorten, request.coachId, projection=AccountShorten.to_mongo_fields()
+        ),
+        verify_discount_code(request.discountCode),
+        create_anonymous_account_obj(request.email),
+    )
+    call = await create_call_obj(request, coach, account)
+    session_url = await create_stripe_session(call, promotion_code, is_anonymous=True)
+    return CbhResponseWrapper(data=StripeSessionResponse(sessionUrl=session_url))
+
+
 @calls_router.post("/stripe/callback")
 async def stripe_callback(request: Request) -> CbhResponseWrapper:
     """
@@ -144,17 +164,22 @@ async def stripe_callback(request: Request) -> CbhResponseWrapper:
     payload = await request.body()
     event = verify_stripe_webhook(request, payload)
     call = await manage_stripe_event(event)
-    # asyncio.create_task(send_customer_booking_email(call))
-    # asyncio.create_task(send_coach_booking_email(call))
-    # asyncio.create_task(send_session_reminder_email(call))
-    # asyncio.create_task(send_session_reminder_coach_email(call))
+
+    if call.customer.status == AccountStatus.PENDING:
+        asyncio.create_task(send_anonymous_booking_email(call))
+    else:
+        asyncio.create_task(send_customer_booking_email(call))
+
+    asyncio.create_task(send_coach_booking_email(call))
+    asyncio.create_task(send_session_reminder_email(call))
+    asyncio.create_task(send_session_reminder_coach_email(call))
     return CbhResponseWrapper(data=None)
 
 
 @calls_router.get("/stripe/check/{callId}")
 async def check_stripe_payment(
     callId: str,
-    _: AccountModel = Depends(PermissionDependency()),
+    _: AccountModel = Depends(PermissionDependency(required=False)),
 ) -> CbhResponseWrapper[StripeCheckResponse]:
     """
     Check stripe payment.

cbh/api/security/db_requests.py

@@ -14,7 +14,9 @@ from cbh.api.availability.models import AvailabilityModel
 from cbh.api.security.schemas import (
     LoginAccountRequest,
     RegisterAccountRequest,
+    RegisterCompleteRequest,
 )
+from cbh.api.common.db_requests import get_obj_by_id
 from cbh.core.config import settings
 from cbh.core.security import verify_password
 
@@ -105,3 +107,40 @@ async def get_account_by_email(
     elif account is None:
         return None
     return AccountModel.from_mongo(account)
+
+
+async def complete_account_registration(
+    accountId: str,
+    request: RegisterCompleteRequest,
+) -> AccountModel:
+    """
+    Complete account registration.
+    """
+    account = await get_obj_by_id(AccountModel, accountId)
+    if account is None:
+        raise HTTPException(status_code=404, detail="Account not found")
+    elif account.status != AccountStatus.PENDING:
+        raise HTTPException(status_code=400, detail="Account already registered")
+    account.name = f"{request.firstName} {request.lastName}"
+    account.password = request.password
+    account.status = AccountStatus.ACTIVE
+
+    account_shorten = AccountShorten(
+        id=account.id,
+        name=account.name,
+        email=account.email,
+        status=account.status,
+        accountType=account.accountType,
+    )
+    await asyncio.gather(
+        settings.DB_CLIENT.accounts.update_one(
+            {"email": request.email}, {"$set": account.to_mongo()}
+        ),
+        settings.DB_CLIENT.calls.update_one(
+            {
+                "customer.email": request.email,
+            },
+            {"$set": {"customer": account_shorten.to_mongo()}},
+        ),
+    )
+    return account

cbh/api/security/schemas.py

@@ -22,6 +22,16 @@ class RegisterAccountRequest(BaseModel):
     accountType: AccountType
 
 
+class RegisterCompleteRequest(BaseModel):
+    """
+    Request model for account registration completion.
+    """
+
+    firstName: str
+    lastName: str
+    password: str
+
+
 class LoginAccountRequest(BaseModel):
     """
     Request model for account login.

cbh/api/security/views.py

@@ -9,6 +9,7 @@ from cbh.api.account.models import AccountModel
 from cbh.api.common.db_requests import get_obj_by_id
 from cbh.api.security import security_router
 from cbh.api.security.db_requests import (
+    complete_account_registration,
     save_account,
     authenticate_account,
 )
@@ -17,6 +18,7 @@ from cbh.api.security.schemas import (
     RegisterAccountRequest,
     LoginAccountRequest,
     LoginAccountResponse,
+    RegisterCompleteRequest,
 )
 from cbh.core.security import PermissionDependency, create_access_token
 from cbh.core.wrappers import CbhResponseWrapper
@@ -78,3 +80,15 @@ async def login_as_user(
         account=account,
     )
     return CbhResponseWrapper(data=response)
+
+
+@security_router.post("/register/{accountId}/complete")
+async def register_complete(
+    accountId: str,
+    request: RegisterCompleteRequest,
+) -> CbhResponseWrapper[AccountModel]:
+    """
+    Signup complete.
+    """
+    account = await complete_account_registration(accountId, request)
+    return CbhResponseWrapper(data=account)