Enhance scenario deletion process

- Improved the `form_delete_scenario_filter` utility function for better filter creation during scenario deletions.
- Refined the `bulk_delete_scenarios_objs` and `delete_scenario` functions to enhance clarity and maintainability.
- Strengthened access control measures in the filtering logic for scenario deletions.

cbh/api/calls/db_requests.py

@@ -1,6 +1,7 @@
 import asyncio
 from datetime import datetime, timedelta
 
+import dateutil
 from fastapi import HTTPException
 
 from cbh.api.account.dto import AccountStatus, AccountType, CoachOpportunity
@@ -30,12 +31,18 @@ async def create_call_obj(
     """
     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
@@ -71,14 +78,17 @@ async def disable_call(call: CallModel) -> None:
     )
 
 
-async def enable_call(call: CallModel, payment_intent_id: str | None = None) -> None:
+async def enable_call(
+    call: CallModel, payment_intent_id: str | None, mr_url: str | None
+) -> None:
     """
     Enable a call.
     """
     update_data = {"status": CallStatus.SCHEDULED.value}
     if payment_intent_id:
         update_data["paymentIntentId"] = payment_intent_id
-    print(update_data)
+    if mr_url:
+        update_data["roomUrl"] = mr_url
     await settings.DB_CLIENT.calls.update_one({"id": call.id}, {"$set": update_data})
 
 
@@ -333,12 +343,8 @@ async def calculate_call_availabilities(
             for day_schedule in weekly_schedule:
                 if day_schedule.get("dayOfWeek") == slot_day_of_week:
                     for time_slot in day_schedule.get("slots", []):
-                        slot_start_time = datetime.strptime(
-                            time_slot.get("startTime"), "%H:%M:%S.%f%z"
-                        ).time()
-                        slot_end_time = datetime.strptime(
-                            time_slot.get("endTime"), "%H:%M:%S.%f%z"
-                        ).time()
+                        slot_start_time = dateutil.parser.parse(time_slot["startTime"]).time()
+                        slot_end_time = dateutil.parser.parse(time_slot["endTime"]).time()
 
                         if slot_start_time <= slot_time and slot_end_time >= slot_end:
                             is_available = True

cbh/api/calls/models.py

@@ -18,6 +18,7 @@ class CallModel(MongoBaseModel):
     customer: AccountShorten
     coach: AccountShorten
 
+    roomUrl: str | None = None
     duration: int | None = None
 
     status: CallStatus = CallStatus.CREATED

cbh/api/calls/schemas.py

@@ -59,5 +59,15 @@ class StripeCheckResponse(BaseModel):
     """
     Stripe check response.
     """
+
     isProcessed: bool
-    success: bool
+    success: bool
+
+
+class DailyInitializeResponse(BaseModel):
+    """
+    Daily initialize response.
+    """
+
+    token: str
+    roomUrl: str

cbh/api/calls/services/__init__.py

@@ -4,7 +4,6 @@ from .stripe import (
     manage_stripe_event,
     refund_stripe_payment,
 )
-
 __all__ = [
     "create_stripe_session",
     "verify_stripe_webhook",

cbh/api/calls/services/stripe.py

@@ -6,6 +6,7 @@ from fastapi import HTTPException, Request
 
 from cbh.api.calls.db_requests import disable_call, enable_call
 from cbh.api.calls.models import CallModel
+from cbh.api.calls.services.daily import create_meeting_room
 from cbh.api.common.db_requests import get_obj_by_id
 from cbh.core.config import settings
 
@@ -35,8 +36,8 @@ async def create_stripe_session(call: CallModel) -> str:
                 },
             ],
             "mode": "payment",
-            "success_url": f"{settings.Issuer}/payment/success?callId={call.id}",
-            "cancel_url": f"{settings.Issuer}/payment/cancel?callId={call.id}",
+            "success_url": f"{settings.Audience}/payment/success?callId={call.id}",
+            "cancel_url": f"{settings.Audience}/payment/cancel?callId={call.id}",
             "metadata": metadata,
             "expires_at": int(time.time()) + 1800,
         },
@@ -45,7 +46,7 @@ async def create_stripe_session(call: CallModel) -> str:
     return checkout_session.url
 
 
-async def verify_stripe_webhook(request: Request, payload: bytes) -> dict:
+def verify_stripe_webhook(request: Request, payload: bytes) -> dict:
     """
     Verify a stripe webhook.
     """
@@ -72,7 +73,8 @@ async def manage_stripe_event(event: dict) -> str:
         "checkout.session.async_payment_succeeded",
     ]:
         payment_intent_id = session.get("payment_intent")
-        await enable_call(call, payment_intent_id)
+        meeting_room = await create_meeting_room(call.event)
+        await enable_call(call, payment_intent_id, meeting_room)
 
     elif event_type in (
         "checkout.session.async_payment_failed",

cbh/api/calls/views.py

@@ -2,7 +2,6 @@ import asyncio
 from datetime import datetime
 
 from fastapi import Depends, Query, Request
-from fastapi.responses import RedirectResponse
 
 from cbh.api.account.dto import AccountType
 from cbh.api.account.models import AccountModel, AccountShorten
@@ -21,6 +20,7 @@ from cbh.api.calls.models import CallModel
 from cbh.api.calls.schemas import (
     CallAvailabilityResponse,
     CallsFilter,
+    DailyInitializeResponse,
     PurchaseCallRequest,
     RescheduleCallRequest,
     StripeCheckResponse,
@@ -32,6 +32,7 @@ from cbh.api.calls.services import (
     refund_stripe_payment,
     verify_stripe_webhook,
 )
+from cbh.api.calls.services.daily import create_daily_token
 from cbh.api.calls.utils import can_edit_call
 from cbh.api.common.db_requests import get_obj_by_id
 from cbh.api.common.dto import Paging
@@ -124,7 +125,7 @@ async def cancel_call(
     return CbhResponseWrapper(data=call)
 
 
-@calls_router.post("")
+@calls_router.post("/purchase")
 async def purchase_call(
     request: PurchaseCallRequest,
     account: AccountModel = Depends(PermissionDependency([AccountType.USER])),
@@ -153,7 +154,7 @@ async def stripe_callback(request: Request) -> CbhResponseWrapper[None]:
     Stripe callback.
     """
     payload = await request.body()
-    event = await verify_stripe_webhook(request, payload)
+    event = verify_stripe_webhook(request, payload)
     await manage_stripe_event(event)
     return CbhResponseWrapper(data=None)
 
@@ -168,3 +169,24 @@ async def check_stripe_payment(
     """
     response = await check_call_payment(callId)
     return CbhResponseWrapper(data=response)
+
+
+@calls_router.get("/daily/{callId}/initialize")
+async def initialize_daily(
+    callId: str,
+    account: AccountModel = Depends(PermissionDependency()),
+) -> CbhResponseWrapper[str]:
+    """
+    Fetch daily token.
+    """
+    call = await get_obj_by_id(
+        CallModel,
+        callId,
+        additional_filter={
+            "$or": [{"customer.id": account.id}, {"coach.id": account.id}]
+        },
+    )
+    token = await create_daily_token(call, account.id)
+    return CbhResponseWrapper(
+        data=DailyInitializeResponse(token=token, roomUrl=call.roomUrl)
+    )

cbh/core/config.py

@@ -5,11 +5,9 @@ Configuration module for ClipboardHealthAI application.
 import os
 import pathlib
 from functools import lru_cache
-from typing import Optional, Type
 
 from dotenv import load_dotenv
 from motor.motor_asyncio import AsyncIOMotorClient, AsyncIOMotorDatabase
-from pydantic import BaseModel
 from stripe import StripeClient
 
 load_dotenv()
@@ -31,6 +29,8 @@ class BaseConfig:
     STRIPE_API_KEY = os.getenv("STRIPE_API_KEY")
     STRIPE_WEBHOOK_SECRET = os.getenv("STRIPE_WEBHOOK_SECRET")
 
+    DAILY_API_KEY = os.getenv("DAILY_API_KEY")
+
     @staticmethod
     def get_headers(api_key: str) -> dict:
         """