ashnaali22/phase-3-h2

1o

2�8Ji��@s�dZd
dl
mZ
d
dlmZmZ
d
dlmZ
d
dl	m3Z4
e5s"ed�
�
e6�dd�Z
ee
d	d7ddd
di
d�Zeeed	d�Zdeefdd�ZdS)z�8Async database session for Phase 3 chat endpoint.9 10This module provides AsyncSession for non-blocking database operations11required by ConversationService and chat endpoint.12 13IMPORTANT: Phase 2 sync sessions remain unchanged - this is ADDITIVE.14�)
�
AsyncIterator)�create_async_engine�AsyncSession)
�sessionmaker)
�DATABASE_URLz-DATABASE_URL environment variable is requiredz
postgresql://zpostgresql+asyncpg://F��15T�timeout�)�echo�	pool_size�max_overflow�
pool_pre_ping�connect_args)�class_�expire_on_commit�returnc
	CsH�t�4Id
H�}|V
Wd
�Id
H
d
S1Id
Hsw



Y
d
S)a�
16    FastAPI dependency for async database sessions.17 18    Use this ONLY for Phase 3 chat endpoints.19    Phase 2 REST endpoints continue using get_db().20 21    Example:22        @router.post("/{user_id}/chat")23        async def chat_endpoint(24            session: AsyncSession = Depends(get_async_session)25        ):26            conversation = await get_or_create_conversation(session, ...)27    N)
�AsyncSessionLocal)
�session�r�OD:\code\Q4\hackathon-2\todo-app\phase-3\backend\.\src\database\async_session.py�get_async_session*s�
.�rN)�__doc__�typingr�sqlalchemy.ext.asynciorrZAsyncSessionType�sqlalchemy.ormr�configr�28ValueError�replaceZasync_database_url�async_enginerrrrrr�<module>
s,	









�29


�