Refactor account and call management features

- Removed the discount code router and related functionality from the project.
- Introduced `update_account_status_obj` function to handle account status updates.
- Added `ChangeStatusRequest` schema for updating account status via API.
- Updated account model to include a phone number field instead of picture URL.
- Cleaned up unused reschedule call functionality and related schemas.
- Enhanced account creation process to include phone number and account status.

cbh/api/calls/db_requests.py

@@ -25,23 +25,14 @@ async def create_call_obj(
     event: EventModel,
     coach: AccountShorten,
     customer: AccountModel,
-    is_business: bool,
 ) -> CallModel:
     """
     Create a new call.
     """
-    from cbh.api.calls.services.daily import create_meeting_room
-
-    status = CallStatus.SCHEDULED if is_business else CallStatus.CREATED
-    room_url = None
-    if is_business:
-        room_url = await create_meeting_room(event)
     call = CallModel(
         event=EventShorten(**event.model_dump()),
         customer=AccountShorten(**customer.model_dump()),
         coach=coach,
-        status=status,
-        roomUrl=room_url,
     )
     await settings.DB_CLIENT.calls.insert_one(call.to_mongo())
     return call
@@ -155,12 +146,6 @@ async def filter_calls_objs(
     return calls, total_count
 
 
-async def verify_discount_code(discount_code: str | None) -> bool:
-    """
-    Verify discount code.
-    """
-    return True
-
 def _generate_time_slots(start: datetime, end: datetime) -> list[datetime]:
     """
     Generate time slots between start and end.
@@ -182,7 +167,7 @@ def _generate_time_slots(start: datetime, end: datetime) -> list[datetime]:
 async def calculate_call_availabilities(
     startDate: datetime,
     endDate: datetime,
-    isBusiness: bool,
+    promotion_code: str | None,
 ) -> CallAvailabilityResponse:
     """
     Get call availabilities.
@@ -194,7 +179,7 @@ async def calculate_call_availabilities(
 
     opportunity_filter = (
         [CoachOpportunity.BUSINESS.value, CoachOpportunity.BOTH.value]
-        if isBusiness
+        if promotion_code
         else [CoachOpportunity.GENERAL.value, CoachOpportunity.BOTH.value]
     )
 
@@ -370,9 +355,3 @@ async def check_call_payment(call_id: str) -> StripeCheckResponse:
     is_processed = True if call["status"] == CallStatus.SCHEDULED.value else False
     success = call["event"]["isActive"]
     return StripeCheckResponse(isProcessed=is_processed, success=success)
-
-
-if __name__ == "__main__":
-    import asyncio
-
-    asyncio.run(verify_discount_code("TEST_CODE"))

cbh/api/calls/services/__init__.py

@@ -3,10 +3,12 @@ from .stripe import (
     verify_stripe_webhook,
     manage_stripe_event,
     refund_stripe_payment,
+    verify_discount_code,
 )
 __all__ = [
     "create_stripe_session",
     "verify_stripe_webhook",
     "manage_stripe_event",
     "refund_stripe_payment",
+    "verify_discount_code",
 ]

cbh/api/calls/services/stripe.py

@@ -11,7 +11,7 @@ from cbh.api.common.db_requests import get_obj_by_id
 from cbh.core.config import settings
 
 
-async def create_stripe_session(call: CallModel) -> str:
+async def create_stripe_session(call: CallModel, code: str | None) -> str:
     """
     Create a stripe session.
     """
@@ -19,13 +19,13 @@ async def create_stripe_session(call: CallModel) -> str:
         "callId": call.id,
     }
 
-    checkout_session = await settings.STRIPE_CLIENT.checkout.sessions.create_async(
+    checkout_session = await settings.STRIPE_CLIENT.v1.checkout.sessions.create_async(
         params={
             "customer_email": call.customer.email,
             "line_items": [
                 {
                     "price_data": {
-                        "currency": "usd",
+                        "currency": "eur",
                         "unit_amount": 150 * 100,
                         "product_data": {
                             "name": "Coaching Session",
@@ -39,6 +39,7 @@ async def create_stripe_session(call: CallModel) -> str:
             "success_url": f"{settings.Audience}/payment/success?callId={call.id}",
             "cancel_url": f"{settings.Audience}/payment/cancel?callId={call.id}",
             "metadata": metadata,
+            "discounts": [{"promotion_code": code}] if code else None,
             "expires_at": int(time.time()) + 1800,
         },
         options={"api_key": settings.STRIPE_API_KEY},
@@ -67,16 +68,16 @@ async def manage_stripe_event(event: dict) -> str:
 
     call_id = pydash.get(session, "metadata.callId")
     call = await get_obj_by_id(CallModel, call_id)
-    print(f'Event type: {event_type}')
-    print(f'Session: {session}')
+    print(f"Event type: {event_type}")
+    print(f"Session: {session}")
     if event_type in [
         "checkout.session.completed",
         "checkout.session.async_payment_succeeded",
     ]:
         payment_intent_id = session.get("payment_intent")
-        print(f'Payment intent id: {payment_intent_id}')
+        print(f"Payment intent id: {payment_intent_id}")
         meeting_room = await create_meeting_room(call.event)
-        print(f'Meeting room: {meeting_room}')
+        print(f"Meeting room: {meeting_room}")
         await enable_call(call, payment_intent_id, meeting_room)
 
     elif event_type in (
@@ -91,10 +92,24 @@ async def refund_stripe_payment(payment_intent_id: str) -> None:
     Refund a Stripe payment.
     """
     try:
-        await settings.STRIPE_CLIENT.refunds.create_async(
+        await settings.STRIPE_CLIENT.v1.refunds.create_async(
             payment_intent=payment_intent_id,
         )
     except stripe.error.StripeError as e:
         raise HTTPException(
             status_code=400, detail=f"Failed to refund payment: {str(e)}"
         )
+
+
+async def verify_discount_code(discount_code: str | None) -> str | None:
+    """
+    Verify discount code.
+    """
+    if not discount_code:
+        return None
+    promotion_codes = await settings.STRIPE_CLIENT.v1.promotion_codes.list_async(
+        params={"code": discount_code, "active": True}
+    )
+    if not promotion_codes.data:
+        raise HTTPException(status_code=400, detail="Invalid discount code")
+    return promotion_codes.data[0].id

cbh/api/calls/views.py

@@ -13,7 +13,6 @@ from cbh.api.calls.db_requests import (
     create_call_obj,
     create_event_obj,
     filter_calls_objs,
-    verify_discount_code,
 )
 from cbh.api.calls.models import CallModel
 from cbh.api.calls.schemas import (
@@ -29,6 +28,7 @@ from cbh.api.calls.services import (
     manage_stripe_event,
     refund_stripe_payment,
     verify_stripe_webhook,
+    verify_discount_code,
 )
 from cbh.api.calls.services.daily import create_daily_token
 from cbh.api.calls.utils import can_edit_call
@@ -70,8 +70,8 @@ async def get_availabilities(
     """
     Get availabilities.
     """
-    is_business = await verify_discount_code(discountCode)
-    response = await calculate_call_availabilities(startDate, endDate, is_business)
+    promotion_code = await verify_discount_code(discountCode)
+    response = await calculate_call_availabilities(startDate, endDate, promotion_code)
     return CbhResponseWrapper(data=response)
 
 
@@ -114,18 +114,15 @@ async def purchase_call(
     """
     Purchase a call.
     """
-    coach, is_business = await asyncio.gather(
+    coach, promotion_code = await asyncio.gather(
         get_obj_by_id(
             AccountShorten, request.coachId, projection=AccountShorten.to_mongo_fields()
         ),
         verify_discount_code(request.discountCode),
     )
     event = await create_event_obj(request, coach)
-    call = await create_call_obj(event, coach, account, is_business)
-
-    session_url = None
-    if not is_business:
-        session_url = await create_stripe_session(call)
+    call = await create_call_obj(event, coach, account)
+    session_url = await create_stripe_session(call, promotion_code)
     return CbhResponseWrapper(data=StripeSessionResponse(sessionUrl=session_url))