mirror of
https://github.com/OpenHands/OpenHands.git
synced 2025-12-26 13:52:43 +08:00
72 lines
2.5 KiB
Python
72 lines
2.5 KiB
Python
import uuid
|
|
|
|
from fastapi import Depends, HTTPException, Request, status
|
|
|
|
from openhands.core.logger import openhands_logger as logger
|
|
from openhands.server.shared import (
|
|
ConversationStoreImpl,
|
|
config,
|
|
conversation_manager,
|
|
)
|
|
from openhands.server.user_auth import get_user_id
|
|
from openhands.storage.conversation.conversation_store import ConversationStore
|
|
from openhands.storage.data_models.conversation_metadata import ConversationMetadata
|
|
|
|
|
|
async def get_conversation_store(request: Request) -> ConversationStore | None:
|
|
conversation_store: ConversationStore | None = getattr(
|
|
request.state, 'conversation_store', None
|
|
)
|
|
if conversation_store:
|
|
return conversation_store
|
|
user_id = await get_user_id(request)
|
|
conversation_store = await ConversationStoreImpl.get_instance(config, user_id)
|
|
request.state.conversation_store = conversation_store
|
|
return conversation_store
|
|
|
|
|
|
async def generate_unique_conversation_id(
|
|
conversation_store: ConversationStore,
|
|
) -> str:
|
|
conversation_id = uuid.uuid4().hex
|
|
while await conversation_store.exists(conversation_id):
|
|
conversation_id = uuid.uuid4().hex
|
|
return conversation_id
|
|
|
|
|
|
async def get_conversation_metadata(
|
|
conversation_id: str,
|
|
conversation_store: ConversationStore = Depends(get_conversation_store),
|
|
) -> ConversationMetadata:
|
|
"""Get conversation metadata and validate user access without requiring an active conversation."""
|
|
try:
|
|
metadata = await conversation_store.get_metadata(conversation_id)
|
|
return metadata
|
|
except FileNotFoundError:
|
|
raise HTTPException(
|
|
status_code=status.HTTP_404_NOT_FOUND,
|
|
detail=f'Conversation {conversation_id} not found',
|
|
)
|
|
|
|
|
|
async def get_conversation(
|
|
conversation_id: str, user_id: str | None = Depends(get_user_id)
|
|
):
|
|
"""Grabs conversation id set by middleware. Adds the conversation_id to the openapi schema."""
|
|
conversation = await conversation_manager.attach_to_conversation(
|
|
conversation_id, user_id
|
|
)
|
|
if not conversation:
|
|
logger.warning(
|
|
f'get_conversation: conversation {conversation_id} not found, attach_to_conversation returned None',
|
|
extra={'session_id': conversation_id, 'user_id': user_id},
|
|
)
|
|
raise HTTPException(
|
|
status_code=status.HTTP_404_NOT_FOUND,
|
|
detail=f'Conversation {conversation_id} not found',
|
|
)
|
|
try:
|
|
yield conversation
|
|
finally:
|
|
await conversation_manager.detach_from_conversation(conversation)
|