init

cbh/api/account/dto.py

@@ -29,6 +29,6 @@ class CoachOpportunity(Enum):
     Coach opportunity.
     """
 
-    PRIVATE = 1
+    GENERAL = 1
     BUSINESS = 2
     BOTH = 3

cbh/api/availability/__init__.py

@@ -1,5 +1,5 @@
 from fastapi import APIRouter
 
-availability_router = APIRouter(prefix="/availability", tags=["availability"])
+availability_router = APIRouter(prefix="/api/availability", tags=["availability"])
 
 from . import views

cbh/api/availability/db_requests.py

@@ -0,0 +1,21 @@
+from cbh.api.availability.schemas import UpdateAvailabilityRequest
+from cbh.api.availability.models import AvailabilityModel
+from cbh.api.common.db_requests import get_obj_by_id
+from cbh.core.config import settings
+
+
+async def update_availability_obj(
+    availability: UpdateAvailabilityRequest, coach_id: str
+) -> AvailabilityModel:
+    """
+    Update availability object.
+    """
+    availability_obj = await get_obj_by_id(
+        AvailabilityModel, None, additional_filter={"coach.id": coach_id}
+    )
+    availability_obj.weeklySchedule = availability.weeklySchedule
+    await settings.DB_CLIENT.availabilities.update_one(
+        {"coach.id": coach_id},
+        {"$set": availability_obj.to_mongo()},
+    )
+    return availability_obj

cbh/api/availability/models.py

@@ -1,6 +1,5 @@
 from cbh.api.account.models import AccountShorten
 from cbh.api.availability.dto import DaySchedule
-from cbh.api.timezone.models import TimezoneModel
 from cbh.core.database import MongoBaseModel
 
 
@@ -10,6 +9,4 @@ class AvailabilityModel(MongoBaseModel):
     """
 
     coach: AccountShorten
-    timezone: TimezoneModel
-
     weeklySchedule: list[DaySchedule] | None = None

cbh/api/availability/schemas.py

@@ -1,7 +1,5 @@
 from pydantic import BaseModel
 from cbh.api.availability.dto import DaySchedule
-from cbh.api.availability.models import AvailabilityModel
-from cbh.api.events.models import EventShorten
 
 
 class UpdateAvailabilityRequest(BaseModel):
@@ -9,14 +7,4 @@ class UpdateAvailabilityRequest(BaseModel):
     Update availability request.
     """
 
-    timezoneId: str
     weeklySchedule: list[DaySchedule]
-
-
-class ExtendedAvailabilityResponse(BaseModel):
-    """
-    Extended availability response.
-    """
-
-    availability: AvailabilityModel
-    events: list[EventShorten]

cbh/api/availability/views.py

@@ -1,9 +1,10 @@
 from fastapi import Depends
 from cbh.api.account.models import AccountModel
+from cbh.api.availability.db_requests import update_availability_obj
 from cbh.api.availability.schemas import (
     UpdateAvailabilityRequest,
-    ExtendedAvailabilityResponse,
 )
+from cbh.api.common.db_requests import get_obj_by_id
 from cbh.core.security import PermissionDependency
 from cbh.api.account.dto import AccountType
 from cbh.core.wrappers import CbhResponseWrapper
@@ -16,21 +17,25 @@ async def get_own_availability(
     account: AccountModel = Depends(PermissionDependency([AccountType.COACH])),
 ) -> CbhResponseWrapper[AvailabilityModel]:
 
-    availability = await get_availability_obj(account)
+    availability = await get_obj_by_id(
+        AvailabilityModel, None, additional_filter={"coach.id": account.id}
+    )
     return CbhResponseWrapper(data=availability)
 
 
 @availability_router.get("/{coachId}")
-async def get_extended_availability(
+async def get_availability(
     coachId: str,
-    account: AccountModel = Depends(
+    _: AccountModel = Depends(
         PermissionDependency([AccountType.ADMIN, AccountType.USER])
     ),
-) -> CbhResponseWrapper[ExtendedAvailabilityResponse]:
+) -> CbhResponseWrapper[AvailabilityModel]:
     """
     Get availability by coach ID.
     """
-    availability = await get_extended_availability_obj(coachId)
+    availability = await get_obj_by_id(
+        AvailabilityModel, None, additional_filter={"coach.id": coachId}
+    )
     return CbhResponseWrapper(data=availability)
 
 
@@ -42,5 +47,18 @@ async def update_own_availability(
     """
     Update own availability.
     """
-    availability = await update_own_availability_obj(availability, account)
+    availability = await update_availability_obj(availability, account.id)
+    return CbhResponseWrapper(data=availability)
+
+
+@availability_router.put("/{coachId}")
+async def update_availability(
+    coachId: str,
+    availability: UpdateAvailabilityRequest,
+    _: AccountModel = Depends(PermissionDependency([AccountType.ADMIN])),
+) -> CbhResponseWrapper[AvailabilityModel]:
+    """
+    Update availability.
+    """
+    availability = await update_availability_obj(availability, coachId)
     return CbhResponseWrapper(data=availability)

cbh/api/calls/__init__.py

@@ -1,5 +1,5 @@
 from fastapi import APIRouter
 
-calls_router = APIRouter(prefix="/calls", tags=["calls"])
+calls_router = APIRouter(prefix="/api/calls", tags=["calls"])
 
 from . import views

cbh/api/calls/db_requests.py

@@ -3,8 +3,8 @@ from datetime import datetime, timedelta
 
 from fastapi import HTTPException
 
-from cbh.api.account.models import AccountModel, AccountShorten
 from cbh.api.account.dto import AccountStatus, AccountType, CoachOpportunity
+from cbh.api.account.models import AccountModel, AccountShorten
 from cbh.api.calls.dto import CallAvailabilityOption, CallStatus
 from cbh.api.calls.models import CallModel
 from cbh.api.calls.schemas import (
@@ -24,12 +24,12 @@ async def create_call_obj(
     event: EventModel,
     coach: AccountShorten,
     customer: AccountModel,
-    is_code_valid: bool,
+    is_business: bool,
 ) -> CallModel:
     """
     Create a new call.
     """
-    status = CallStatus.SCHEDULED if is_code_valid else CallStatus.CREATED
+    status = CallStatus.SCHEDULED if is_business else CallStatus.CREATED
     call = CallModel(
         event=EventShorten(**event.model_dump()),
         customer=AccountShorten(**customer.model_dump()),
@@ -200,7 +200,7 @@ async def calculate_call_availabilities(
     opportunity_filter = (
         [CoachOpportunity.BUSINESS.value, CoachOpportunity.BOTH.value]
         if isBusiness
-        else [CoachOpportunity.PRIVATE.value, CoachOpportunity.BOTH.value]
+        else [CoachOpportunity.GENERAL.value, CoachOpportunity.BOTH.value]
     )
 
     pipeline = [
@@ -332,17 +332,12 @@ 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 = time_slot.get("startTime")
-                        slot_end_time = time_slot.get("endTime")
-
-                        if isinstance(slot_start_time, str):
-                            slot_start_time = datetime.strptime(
-                                slot_start_time, "%H:%M:%S"
-                            ).time()
-                        if isinstance(slot_end_time, str):
-                            slot_end_time = datetime.strptime(
-                                slot_end_time, "%H:%M:%S"
-                            ).time()
+                        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()
 
                         if slot_start_time <= slot_time and slot_end_time >= slot_end:
                             is_available = True

cbh/api/calls/schemas.py

@@ -38,12 +38,12 @@ class CallsFilter(BaseModel):
     Calls filter.
     """
 
-    customerIds: list[str]
-    coachIds: list[str]
-    statuses: list[int]
-    minDate: datetime
-    maxDate: datetime
-    searchTerm: str
+    customerIds: list[str] | None = None
+    coachIds: list[str] | None = None
+    statuses: list[int] | None = None
+    minDate: datetime | None = None
+    maxDate: datetime | None = None
+    searchTerm: str | None = None
 
 
 class CallAvailabilityResponse(BaseModel):
@@ -51,5 +51,5 @@ class CallAvailabilityResponse(BaseModel):
     Call availability response.
     """
 
-    closestOption: CallAvailabilityOption
+    closestOption: CallAvailabilityOption | None
     options: list[CallAvailabilityOption]

cbh/api/calls/services/stripe.py

@@ -21,25 +21,28 @@ async def create_stripe_session(
     }
 
     checkout_session = await settings.STRIPE_CLIENT.checkout.sessions.create_async(
-        payment_method_types=["card", "ideal"],
-        line_items=[
-            {
-                "price_data": {
-                    "currency": "usd",
-                    "unit_amount": 150,
-                    "product_data": {
-                        "name": f"Call ({call.duration} minutes)",
-                        "description": f"Payment for a call of {call.duration} minutes",
+        params={
+            "customer_email": call.customer.email,
+            "line_items": [
+                {
+                    "price_data": {
+                        "currency": "usd",
+                        "unit_amount": 150 * 100,
+                        "product_data": {
+                            "name": "Coaching Session",
+                            "description": f"1-on-1 coaching session with {call.coach.name}",
+                        },
                     },
+                    "quantity": 1,
                 },
-                "quantity": 1,
-            },
-        ],
-        mode="payment",
-        success_url=f"{settings.Issuer}/api/calls/stripe/callback",
-        cancel_url=f"{settings.Issuer}/api/calls/stripe/callback",
-        metadata=metadata,
-        expires_at=int(time.time()) + 1800,
+            ],
+            "mode": "payment",
+            "success_url": f"{settings.Issuer}/payment/success?callId={call.id}",
+            "cancel_url": f"{settings.Issuer}/payment/cancel",
+            "metadata": metadata,
+            "expires_at": int(time.time()) + 1800,
+        },
+        options={"api_key": settings.STRIPE_API_KEY}
     )
     return checkout_session.url
 

cbh/api/calls/views.py

@@ -34,7 +34,6 @@ 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
 from cbh.api.common.schemas import AllObjectsResponse, FilterRequest
-from cbh.api.discountcode.models import DiscountCodeModel
 from cbh.core.security import PermissionDependency
 from cbh.core.wrappers import CbhResponseWrapper
 
@@ -47,17 +46,17 @@ async def purchase_call(
     """
     Purchase a call.
     """
-    coach, is_code_valid = await asyncio.gather(
+    coach, is_business = 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)
+    call = await create_call_obj(event, coach, account, is_business)
 
     session_url = None
-    if is_code_valid:
+    if not is_business:
         session_url = await create_stripe_session(call)
     return CbhResponseWrapper(data=StripeSessionResponse(sessionUrl=session_url))
 

cbh/api/common/db_requests.py

@@ -20,28 +20,12 @@ T = TypeVar("T", bound=BaseModel)
 collection_map = {
     "AccountModel": "accounts",
     "AccountShorten": "accounts",
-    "ScenarioModel": "scenarios",
-    "ScenarioShorten": "scenarios",
-    "SessionReportModel": "sessionreports",
-    "SessionReportShorten": "sessionreports",
-    "TeamModel": "teams",
-    "TeamModelShorten": "teams",
-    "OrganizationModel": "organizations",
-    "OrganizationShorten": "organizations",
-    "OrganizationDocumentModel": "organizationdocuments",
-    "OrganizationSettingsModel": "organizationsettings",
-    "UserInsightModel": "userinsights",
-    "UserInsightShorten": "userinsights",
-    "VoiceModel": "voices",
-    "VoiceModelShorten": "voices",
-    "ActivityLogModel": "activitylogs",
-    "AccountNotificationModel": "accountnotifications",
-    "FeedbackModel": "generalfeedbacks",
-    "FeedbackExtendedModel": "extendedfeedbacks",
-    "ScenarioChangeModel": "scenariochanges",
-    "WaitlistModel": "waitlists",
-    "NotificationModel": "notifications",
-    "NotificationModelShorten": "notifications",
+    "AvailabilityModel": "availabilities",
+    "CallModel": "calls",
+    "DiscountCodeModel": "discountcodes",
+    "EventModel": "events",
+    "EventShorten": "events",
+    
 }
 
 

cbh/api/discountcode/__init__.py

@@ -1,5 +1,5 @@
 from fastapi import APIRouter
 
-discountcode_router = APIRouter(prefix="/discountcodes", tags=["discount-code"])
+discountcode_router = APIRouter(prefix="/api/discountcodes", tags=["discount-code"])
 
 from . import views

cbh/api/events/__init__.py

@@ -1,5 +1,5 @@
 from fastapi import APIRouter
 
-events_router = APIRouter(prefix="/events", tags=["events"])
+events_router = APIRouter(prefix="/api/events", tags=["events"])
 
 from . import views

cbh/api/security/db_requests.py

@@ -2,13 +2,15 @@
 Database requests module for security functionality.
 """
 
+import asyncio
 from datetime import datetime
 
 from fastapi import HTTPException
-from passlib.context import CryptContext
 from pydantic import EmailStr
 
+from cbh.api.account.dto import AccountType, CoachOpportunity
 from cbh.api.account.models import AccountModel, AccountShorten
+from cbh.api.availability.models import AvailabilityModel
 from cbh.api.security.schemas import (
     LoginAccountRequest,
     RegisterAccountRequest,
@@ -38,17 +40,35 @@ async def save_account(data: RegisterAccountRequest) -> AccountModel:
     Create a new user account in the database.
     """
     await check_unique_fields_existence("email", data.email)
+    
+    opportunity = None
+    if data.accountType == AccountType.COACH:
+        opportunity = CoachOpportunity.GENERAL
+    
     account = AccountModel(
         name=f"{data.firstName} {data.lastName}",
         email=data.email,
         password=data.password,
         datetimeUpdated=datetime.now(),
         accountType=data.accountType,
+        opportunity=opportunity,
     )
     await settings.DB_CLIENT.accounts.insert_one(account.to_mongo())
+    
+    if account.accountType == AccountType.COACH:
+        asyncio.create_task(create_availability_obj(account))
     return account
 
 
+async def create_availability_obj(account: AccountModel) -> AvailabilityModel:
+    """
+    Create a new availability object.
+    """
+    availability = AvailabilityModel(coach=AccountShorten(**account.to_mongo()))
+    await settings.DB_CLIENT.availabilities.insert_one(availability.to_mongo())
+    return availability
+
+
 async def authenticate_account(data: LoginAccountRequest) -> AccountModel:
     """
     Authenticate a user account using mail and password.

cbh/core/config.py

@@ -30,6 +30,7 @@ class BaseConfig:
     ).spark
 
     STRIPE_CLIENT = StripeClient(api_key=os.getenv("STRIPE_API_KEY"))
+    STRIPE_API_KEY = os.getenv("STRIPE_API_KEY")
     STRIPE_WEBHOOK_SECRET = os.getenv("STRIPE_WEBHOOK_SECRET")
 
     @staticmethod
@@ -78,9 +79,8 @@ class DevelopmentConfig(BaseConfig):
     Development environment configuration settings.
     """
 
-    Issuer = "https://trainwitharena.com"
-    Audience = "https://trainwitharena.com"
-    Domain = "trainwitharena.com"
+    Issuer = "http://localhost:8000"
+    Audience = "http://localhost:3000"
 
 
 class ProductionConfig(BaseConfig):
@@ -88,9 +88,8 @@ class ProductionConfig(BaseConfig):
     Production environment configuration settings.
     """
 
-    Issuer = "https://trainwitharena.com"
-    Audience = "https://trainwitharena.com"
-    Domain = "trainwitharena.com"
+    Issuer = "https://brestok-spark.hf.space"
+    Audience = "http://localhost:3000"
 
 
 @lru_cache()

cbh/core/database.py

@@ -2,7 +2,7 @@
 Database utilities for ClipboardHealthAI application.
 """
 
-from datetime import datetime
+from datetime import datetime, time, date
 from enum import Enum
 import re
 from typing import Any, Dict, Type, TypeVar
@@ -122,7 +122,7 @@ class MongoBaseModel(BaseModel):
                     doc[key] = [model_to_dict(item) for item in value]  # type: ignore
                 elif value and isinstance(value, Enum):
                     doc[key] = value.value
-                elif isinstance(value, datetime):
+                elif isinstance(value, (datetime, time, date)):
                     doc[key] = value.isoformat()  # type: ignore
                 elif value and isinstance(value, AnyUrl):
                     doc[key] = str(value)  # type: ignore

requirements.txt

@@ -1,77 +1,135 @@
-aiosmtplib==5.1.0
-annotated-doc==0.0.4
+aiohappyeyeballs==2.6.1
+aiohttp==3.11.16
+aiosignal==1.3.2
+aiosmtplib==3.0.2
 annotated-types==0.7.0
-anyio==4.12.1
-black==25.12.0
-certifi==2026.1.4
-charset-normalizer==3.4.4
-click==8.3.1
+anyio==4.8.0
+APScheduler==3.11.0
+asn1crypto==1.5.1
+assemblyai==0.40.2
+astroid==3.3.10
+attrs==25.3.0
+bandit==1.8.3
+bcrypt==4.2.1
+beautifulsoup4==4.13.4
+black==24.3.0
+boto3==1.35.97
+botocore==1.35.99
+cachetools==6.2.0
+certifi==2025.1.31
+cffi==1.17.1
+chardet==5.2.0
+charset-normalizer==3.4.1
+click==8.1.8
+cryptography==44.0.1
+cssselect==1.3.0
+cssutils==2.11.1
+dateutils==0.6.12
+dill==0.4.0
 distro==1.9.0
-dnspython==2.8.0
-ecdsa==0.19.1
-email-validator==2.3.0
-fastapi==0.128.0
-h11==0.16.0
-httpcore==1.0.9
-httptools==0.7.1
+dnspython==2.7.0
+ecdsa==0.19.0
+email_validator==2.2.0
+emails==0.6
+fastapi==0.115.8
+filelock==3.17.0
+flake8==7.0.0
+frozenlist==1.5.0
+git-filter-repo==2.47.0
+h11==0.14.0
+html2text==2025.4.15
+httpcore==1.0.7
+httptools==0.6.4
 httpx==0.28.1
-idna==3.11
-jiter==0.12.0
+idna==3.10
+isodate==0.7.2
+isort==6.0.1
+Jinja2==3.1.6
+jiter==0.8.2
+jmespath==1.0.1
 jsonpatch==1.33
 jsonpointer==3.0.0
-langchain==1.2.3
-langchain-classic==1.0.1
-langchain-core==1.2.7
-langchain-mongodb==0.10.0
-langchain-openai==1.1.7
-langchain-text-splitters==1.1.0
-langgraph==1.0.5
-langgraph-checkpoint==3.0.1
-langgraph-prebuilt==1.0.5
-langgraph-sdk==0.3.2
-langsmith==0.6.2
-lark==1.3.1
+lark==1.2.2
+lxml==6.0.0
+markdown-it-py==3.0.0
+MarkupSafe==3.0.2
+mccabe==0.7.0
+mdurl==0.1.2
+more-itertools==10.7.0
 motor==3.7.1
+multidict==6.4.3
+mypy==1.15.0
 mypy_extensions==1.1.0
-numpy==2.4.1
-openai==2.15.0
-orjson==3.11.5
-ormsgpack==1.12.1
-packaging==25.0
+numpy==2.2.3
+orjson==3.10.16
+packaging==24.2
+pandas==2.2.3
+pandas-stubs==2.2.3.250308
 passlib==1.7.4
-pathspec==1.0.3
-pillow==12.1.0
-platformdirs==4.5.1
-pyasn1==0.6.2
-pydantic==2.12.5
-pydantic_core==2.41.5
+pathspec==0.12.1
+pbr==6.1.1
+pillow==11.3.0
+platformdirs==4.3.6
+premailer==3.10.0
+propcache==0.3.1
+pyasn1==0.4.8
+pycodestyle==2.11.1
+pycparser==2.22
+pydantic==2.11.7
+pydantic-mongo==3.1.0
+pydantic_core==2.33.2
 pydash==8.0.5
-pymongo==4.16.0
-pymongo-search-utils==0.1.0
-python-dotenv==1.2.1
-python-jose==3.5.0
-python-multipart==0.0.22
-pytokens==0.3.0
-PyYAML==6.0.3
-regex==2025.11.3
-requests==2.32.5
+pydub==0.25.1
+pyflakes==3.2.0
+Pygments==2.19.1
+PyJWT==2.10.1
+pylint==3.3.7
+pymongo==4.15.2
+pyOpenSSL==24.3.0
+python-dateutil==2.9.0.post0
+python-dotenv==1.0.1
+python-jose==3.4.0
+python-multipart==0.0.20
+pytz==2025.1
+PyYAML==6.0.2
+regex==2024.11.6
+requests==2.32.3
+requests-file==2.1.0
 requests-toolbelt==1.0.0
-rsa==4.9.1
+rich==14.0.0
+rsa==4.9
+ruff==0.11.9
+s3transfer==0.10.4
+setuptools==80.8.0
+simple-salesforce==1.12.6
 six==1.17.0
+slack_sdk==3.35.0
 sniffio==1.3.1
-SQLAlchemy==2.0.45
-starlette==0.50.0
-stripe==14.1.0
+snowflake-connector-python==3.13.2
+sortedcontainers==2.4.0
+soupsieve==2.7
+SQLAlchemy==2.0.40
+starlette==0.45.3
+stevedore==5.4.1
 tenacity==9.1.2
-tiktoken==0.12.0
+tiktoken==0.9.0
+tomlkit==0.13.2
 tqdm==4.67.1
-typing-inspection==0.4.2
-typing_extensions==4.15.0
-urllib3==2.6.3
-uuid_utils==0.13.0
-uvicorn==0.40.0
-uvloop==0.22.1
-watchfiles==1.1.1
-websockets==16.0
-xxhash==3.6.0
-zstandard==0.25.0
+types-passlib==1.7.7.20250408
+types-pyasn1==0.6.0.20250208
+types-python-dateutil==2.9.0.20241206
+types-python-jose==3.4.0.20250224
+types-pytz==2025.2.0.20250326
+types-requests==2.32.0.20250328
+typing-inspection==0.4.0
+typing_extensions==4.12.2
+tzdata==2025.1
+tzlocal==5.3.1
+urllib3==2.3.0
+uvicorn==0.34.0
+uvloop==0.21.0
+watchfiles==1.0.4
+websockets==14.2
+yarl==1.19.0
+zeep==4.3.1
+zstandard==0.23.0