format: ruff format line-length 145

app/api/chat_api.py

@@ -8,7 +8,10 @@ from app.schema.chat_schema import (
     MessageResponse,
     PlotResponse,
 )
-from app.schema.conversation import ConversationResponse, ConversationItemResponse
+from app.schema.conversation import (
+    ConversationResponse,
+    ConversationItemResponse,
+)
 from app.service.chat_service import ChatService
 from app.security.auth_service import AuthService
 from app.core.api_response import api_response
@@ -46,7 +49,8 @@ async def create_chat_completion(
 @router.get("/chat/completions", response_model=List[ChatCompletionResponse])
 @api_response()
 async def list_chat_completions(
-    request: Request, username: str = Depends(auth_service.verify_credentials)
+    request: Request,
+    username: str = Depends(auth_service.verify_credentials),
 ):
     """
     Get all chat completions
@@ -66,7 +70,10 @@ async def list_chat_completions(
 
 
 # get a chat completion by id
-@router.get("/chat/completions/{completion_id}", response_model=ChatCompletionResponse)
+@router.get(
+    "/chat/completions/{completion_id}",
+    response_model=ChatCompletionResponse,
+)
 @api_response()
 async def retrieve_chat_completion(
     completion_id: str,
@@ -85,7 +92,8 @@ async def retrieve_chat_completion(
 
 # get all messages for a chat completion
 @router.get(
-    "/chat/completions/{completion_id}/messages", response_model=List[MessageResponse]
+    "/chat/completions/{completion_id}/messages",
+    response_model=List[MessageResponse],
 )
 @api_response()
 async def list_messages(
@@ -139,7 +147,8 @@ async def retrieve_plot(
 @router.get("/conversations", response_model=ConversationResponse)
 @api_response()
 async def list_conversations(
-    request: Request, username: str = Depends(auth_service.verify_credentials)
+    request: Request,
+    username: str = Depends(auth_service.verify_credentials),
 ):
     """
     Get all conversations
@@ -156,7 +165,10 @@ async def list_conversations(
 # get a conversation by id
 
 
-@router.get("/conversations/{completion_id}", response_model=ConversationItemResponse)
+@router.get(
+    "/conversations/{completion_id}",
+    response_model=ConversationItemResponse,
+)
 @api_response()
 async def retrieve_conversation(
     completion_id: str,

app/config/db.py

@@ -3,7 +3,10 @@ from pydantic_settings import BaseSettings, SettingsConfigDict
 
 class DBConfig(BaseSettings):
     model_config = SettingsConfigDict(
-        env_prefix="DB_", env_file=".env", env_file_encoding="utf-8", extra="ignore"
+        env_prefix="DB_",
+        env_file=".env",
+        env_file_encoding="utf-8",
+        extra="ignore",
     )
 
     MONGO_USER: str = "root"

app/config/log.py

@@ -16,7 +16,10 @@ class LogConfig(BaseSettings):
         )
 
     model_config = SettingsConfigDict(
-        env_prefix="LOG_", env_file=".env", env_file_encoding="utf-8", extra="ignore"
+        env_prefix="LOG_",
+        env_file=".env",
+        env_file_encoding="utf-8",
+        extra="ignore",
     )
 
     LEVEL: str = "DEBUG"

app/config/secret.py

@@ -5,7 +5,10 @@ class SecretConfig(BaseSettings):
     """Secret configuration to be set in env variables"""
 
     model_config = SettingsConfigDict(
-        env_prefix="SECRET_", env_file=".env", env_file_encoding="utf-8", extra="ignore"
+        env_prefix="SECRET_",
+        env_file=".env",
+        env_file_encoding="utf-8",
+        extra="ignore",
     )
 
     KEY: str = "mock-secret-key"

app/core/api_response.py

@@ -48,13 +48,9 @@ def url_to_filename(url: str, method: str) -> str:
     return result
 
 
-def get_mock_response(
-    url_path: str, python_module_name: str, python_method_name: str
-) -> Dict:
+def get_mock_response(url_path: str, python_module_name: str, python_method_name: str) -> Dict:
     """Get mock response from JSON file."""
-    logger.trace(
-        f"BEGIN: url_path: {url_path} python_module_name: {python_module_name} python_method_name: {python_method_name}"
-    )
+    logger.trace(f"BEGIN: url_path: {url_path} python_module_name: {python_module_name} python_method_name: {python_method_name}")
     filename = None
     file_path = None
     try:
@@ -115,12 +111,12 @@ def api_response():
             if USE_MOCK:
                 python_method_name = func.__name__
                 python_module_name = func.__module__
-                logger.warning(
-                    f"Using mock response for {request.url.path} [{request.method}] > {python_module_name}.{python_method_name}"
-                )
+                logger.warning(f"Using mock response for {request.url.path} [{request.method}] > {python_module_name}.{python_method_name}")
                 try:
                     result = get_mock_response(
-                        request.url.path, python_module_name, python_method_name
+                        request.url.path,
+                        python_module_name,
+                        python_method_name,
                     )
                     logger.trace(f"Mock response: {result}")
                     return result

app/model/chat_model.py

@@ -72,11 +72,16 @@ class ChatMessage(BaseModel):
     role: MessageRole = Field(
         ...,
         description="The role of the message sender",
-        examples=[MessageRole.USER, MessageRole.ASSISTANT, MessageRole.SYSTEM],
+        examples=[
+            MessageRole.USER,
+            MessageRole.ASSISTANT,
+            MessageRole.SYSTEM,
+        ],
     )
     content: str = Field(..., description="The content of the message")
     timestamp: datetime = Field(
-        default_factory=datetime.now, description="The timestamp of the message"
+        default_factory=datetime.now,
+        description="The timestamp of the message",
     )
 
 
@@ -97,9 +102,7 @@ class ChatCompletion(BaseModel):
         description="The model used for the chat completion",
         examples=["gpt-4o-mini", "gpt-4o", "gpt-3.5-turbo"],
     )
-    messages: List[ChatMessage] = Field(
-        ..., description="The messages in the chat completion"
-    )
+    messages: List[ChatMessage] = Field(..., description="The messages in the chat completion")
 
     # not implemented yet
     # temperature: float = Field(default=0.7,ge=0.0, le=1.0, description="What sampling temperature to use, between 0 and 1. Higher values like 0.8 will make the output more random, while lower values like 0.2 will make it more focused and deterministic.")
@@ -120,9 +123,7 @@ class ChatCompletion(BaseModel):
         default_factory=datetime.now,
         description="The date and time the chat completion was created",
     )
-    last_updated_by: str = Field(
-        ..., description="The user who last updated the chat completion"
-    )
+    last_updated_by: str = Field(..., description="The user who last updated the chat completion")
     last_updated_date: datetime = Field(
         default_factory=datetime.now,
         description="The date and time the chat completion was last updated",

app/repository/chat_repository.py

@@ -17,9 +17,7 @@ class ChatRepository:
 
         result = self.db.chat_completion.update_one(query, update, upsert=True)
 
-        completion_id = (
-            str(result.upserted_id) if result.upserted_id else entity.completion_id
-        )
+        completion_id = str(result.upserted_id) if result.upserted_id else entity.completion_id
         entity.completion_id = completion_id
 
         # save conversation if new chat completion
@@ -43,12 +41,7 @@ class ChatRepository:
         skip = (page - 1) * limit
         sort = sort if sort else {"created_date": -1}
 
-        result = (
-            self.db.chat_completion.find(query, project)
-            .skip(skip)
-            .limit(limit)
-            .sort(sort)
-        )
+        result = self.db.chat_completion.find(query, project).skip(skip).limit(limit).sort(sort)
         return [ChatCompletion(**item) for item in result]
 
     def find_by_id(self, completion_id: str, project: dict = None) -> ChatCompletion:
@@ -56,9 +49,7 @@ class ChatRepository:
         Find a chat completion by a given id.
         Example : completion_id = "123"
         """
-        result = self.db.chat_completion.find_one(
-            {"completion_id": completion_id}, project
-        )
+        result = self.db.chat_completion.find_one({"completion_id": completion_id}, project)
         return ChatCompletion(**result)
 
     def find_messages(self, completion_id: str) -> List[ChatMessage]:

app/schema/chat_schema.py

@@ -41,9 +41,7 @@ class ChatCompletionRequest(ChatCompletionBase):
     """
 
     model: str = Field(..., description="The model to use for the chat completion")
-    messages: List[MessageRequest] = Field(
-        ..., description="The messages to use for the chat completion"
-    )
+    messages: List[MessageRequest] = Field(..., description="The messages to use for the chat completion")
     stream: bool = Field(..., description="Whether to stream the chat completion")
 
 
@@ -63,12 +61,8 @@ class ChoiceResponse(BaseModel):
         ...,
         description="The reason the model stopped generating tokens. This will be `stop` if the model hit a natural stop point or a provided stop sequence, `length` if the maximum number of tokens specified in the request was reached, `content_filter` if content was omitted due to a flag from our content filters",
     )
-    index: int = Field(
-        ..., description="The index of the choice in the list of choices."
-    )
-    message: MessageResponse = Field(
-        ..., description="The message to use for the chat completion"
-    )
+    index: int = Field(..., description="The index of the choice in the list of choices.")
+    message: MessageResponse = Field(..., description="The message to use for the chat completion")
     # logprobs: str = None # not implemented yet
 
 
@@ -77,12 +71,8 @@ class ChatCompletionResponse(ChatCompletionBase):
     Represents a chat completion response returned by model, based on the provided input.
     """
 
-    completion_id: str = Field(
-        ..., description="The unique identifier for the chat completion"
-    )
-    choices: List[ChoiceResponse] = Field(
-        ..., description="A list of chat completion choices."
-    )
+    completion_id: str = Field(..., description="The unique identifier for the chat completion")
+    choices: List[ChoiceResponse] = Field(..., description="A list of chat completion choices.")
     created: int = Field(
         ...,
         description="The Unix timestamp (in seconds) of when the chat completion was created.",
@@ -107,7 +97,8 @@ class PlotRequest(BaseModel):
     """
 
     message_id: str = Field(
-        ..., description="The unique identifier for the message that the plot is for"
+        ...,
+        description="The unique identifier for the message that the plot is for",
     )
 
 
@@ -122,6 +113,7 @@ class PlotResponse(BaseModel):
         description="The unique identifier for the chat completion that the plot is for",
     )
     message_id: str = Field(
-        ..., description="The unique identifier for the message that the plot is for"
+        ...,
+        description="The unique identifier for the message that the plot is for",
     )
     figure: dict = Field(..., description="The figure data to be visualized")

app/schema/conversation.py

@@ -6,18 +6,12 @@ from typing import List, Optional
 class ConversationItemResponse(BaseModel):
     """Represents an individual conversation record in the platform's chat history."""
 
-    completion_id: str = Field(
-        description="Unique identifier for the conversation in UUID format."
-    )
-    title: str = Field(
-        description="Title or name of the conversation, describing its content or purpose."
-    )
+    completion_id: str = Field(description="Unique identifier for the conversation in UUID format.")
+    title: str = Field(description="Title or name of the conversation, describing its content or purpose.")
     create_time: datetime = Field(
         description="Timestamp when the conversation was created, in ISO 8601 format (e.g., '2025-05-22T10:54:37.569747Z')."
     )
-    update_time: datetime = Field(
-        description="Timestamp when the conversation was last updated, in ISO 8601 format."
-    )
+    update_time: datetime = Field(description="Timestamp when the conversation was last updated, in ISO 8601 format.")
     mapping: Optional[dict] = Field(
         default=None,
         description="Optional dictionary containing additional conversation metadata or mappings, if applicable.",
@@ -34,9 +28,7 @@ class ConversationItemResponse(BaseModel):
         default=None,
         description="Identifier for the gizmo or tool associated with the conversation, if applicable.",
     )
-    is_archived: bool = Field(
-        description="Indicates whether the conversation is archived."
-    )
+    is_archived: bool = Field(description="Indicates whether the conversation is archived.")
     is_starred: Optional[bool] = Field(
         default=None,
         description="Indicates whether the conversation is marked as starred or favorite, if set.",
@@ -45,9 +37,7 @@ class ConversationItemResponse(BaseModel):
         default=None,
         description="Indicates whether the conversation is excluded from memory or history, if set.",
     )
-    memory_scope: str = Field(
-        description="Scope of the conversation's memory, e.g., 'global_enabled' for global memory access."
-    )
+    memory_scope: str = Field(description="Scope of the conversation's memory, e.g., 'global_enabled' for global memory access.")
     workspace_id: Optional[str] = Field(
         default=None,
         description="Identifier for the workspace the conversation belongs to, if applicable.",
@@ -56,14 +46,11 @@ class ConversationItemResponse(BaseModel):
         default=None,
         description="Status of any asynchronous operations related to the conversation, if applicable.",
     )
-    safe_urls: List[str] = Field(
-        description="List of URLs deemed safe for the conversation context."
-    )
-    blocked_urls: List[str] = Field(
-        description="List of URLs blocked for the conversation context."
-    )
+    safe_urls: List[str] = Field(description="List of URLs deemed safe for the conversation context.")
+    blocked_urls: List[str] = Field(description="List of URLs blocked for the conversation context.")
     conversation_origin: Optional[str] = Field(
-        default=None, description="Origin or source of the conversation, if specified."
+        default=None,
+        description="Origin or source of the conversation, if specified.",
     )
     snippet: Optional[str] = Field(
         default=None,
@@ -74,15 +61,7 @@ class ConversationItemResponse(BaseModel):
 class ConversationResponse(BaseModel):
     """Represents the response object containing a list of conversation records and pagination metadata from the platform."""
 
-    items: List[ConversationItemResponse] = Field(
-        description="List of conversation items representing the user's chat history."
-    )
-    total: int = Field(
-        description="Total number of conversations available in the user's history."
-    )
-    limit: int = Field(
-        description="Maximum number of conversation items returned in this response."
-    )
-    offset: int = Field(
-        description="Starting index of the conversation items in this response, used for pagination."
-    )
+    items: List[ConversationItemResponse] = Field(description="List of conversation items representing the user's chat history.")
+    total: int = Field(description="Total number of conversations available in the user's history.")
+    limit: int = Field(description="Maximum number of conversation items returned in this response.")
+    offset: int = Field(description="Starting index of the conversation items in this response, used for pagination.")

app/security/auth_service.py

@@ -52,7 +52,10 @@ class AuthService:
                 )
 
             # Debug için JSON verilerini logla
-            json_data = {"username": data["username"], "created_at": data["created_at"]}
+            json_data = {
+                "username": data["username"],
+                "created_at": data["created_at"],
+            }
             json_str = json.dumps(json_data)
             logger.trace(f"JSON data for signature: {json_str}")
             logger.trace(f"Secret key: {self.secret.KEY}")

app/service/chat_service.py

@@ -17,13 +17,9 @@ class ChatService:
     def __init__(self):
         self.chat_repository = ChatRepository()
 
-    async def handle_chat_completion(
-        self, request: ChatCompletionRequest
-    ) -> ChatCompletionResponse:
+    async def handle_chat_completion(self, request: ChatCompletionRequest) -> ChatCompletionResponse:
         last_user_message = request.messages[-1].content
-        response_content = (
-            f"TODO implement ai-agent response for this message: {last_user_message}"
-        )
+        response_content = f"TODO implement ai-agent response for this message: {last_user_message}"
         username = "admin"
 
         entity = ChatCompletion(**request.model_dump())
@@ -38,24 +34,29 @@ class ChatService:
         entity = self.chat_repository.save(entity)
 
         result = ChatCompletionResponse(**entity.model_dump())
-        messages = [
-            MessageResponse(**{"role": "assistant", "content": response_content})
-        ]  # TODO: implement ai-agent response
+        messages = [MessageResponse(**{"role": "assistant", "content": response_content})]  # TODO: implement ai-agent response
         result.choices = [
             ChoiceResponse(
-                **{"index": 0, "message": messages[0], "finish_reason": "stop"}
+                **{
+                    "index": 0,
+                    "message": messages[0],
+                    "finish_reason": "stop",
+                }
             )
         ]
         return result
 
     async def find(
-        self, query: dict, page: int, limit: int, sort: dict, project: dict = None
+        self,
+        query: dict,
+        page: int,
+        limit: int,
+        sort: dict,
+        project: dict = None,
     ) -> List[ChatCompletion]:
         return self.chat_repository.find(query, page, limit, sort, project)
 
-    async def find_by_id(
-        self, completion_id: str, project: dict = None
-    ) -> ChatCompletion:
+    async def find_by_id(self, completion_id: str, project: dict = None) -> ChatCompletion:
         return self.chat_repository.find_by_id(completion_id, project)
 
     async def find_messages(self, completion_id: str) -> List[ChatMessage]:

gradio_chatbot.py

@@ -15,11 +15,7 @@ env.read_env()
 
 # Hugging Face Spaces için özel yapılandırma
 IS_HF_SPACE = os.environ.get("SPACE_ID") is not None
-SPACE_URL = (
-    "https://lokumai-openai-openapi-template.hf.space"
-    if IS_HF_SPACE
-    else "http://localhost:7860"
-)
+SPACE_URL = "https://lokumai-openai-openapi-template.hf.space" if IS_HF_SPACE else "http://localhost:7860"
 
 # API Configuration
 BASE_URL = env.str("BASE_URL", SPACE_URL)
@@ -43,6 +39,7 @@ def app_auth(username: str, password: str) -> bool:
     logger.debug(f"AUTH_USERNAME: {AUTH_USERNAME}")
     return username == AUTH_USERNAME and password == AUTH_PASSWORD
 
+
 # Custom CSS for fonts
 CUSTOM_CSS = """
 @font-face {{
@@ -183,7 +180,7 @@ class ChatAPI:
                 logger.trace("######################## BEGIN API response #########################")
                 logger.trace(json.dumps(result, indent=4))
                 logger.trace("######################## END API response #########################")
-                
+
                 if "choices" in result and len(result["choices"]) > 0:
                     message = result["choices"][0].get("message", {})
                     figure = message.get("figure", None)
@@ -191,7 +188,9 @@ class ChatAPI:
                     content = message.get("content", "Content not found")
                     logger.trace(f"Last message: {content}")
                     return MessageResponse(
-                        status=MessageStatus.SUCCESS, content=content, figure=figure
+                        status=MessageStatus.SUCCESS,
+                        content=content,
+                        figure=figure,
                     )
                 else:
                     logger.error("Invalid API response")
@@ -200,7 +199,7 @@ class ChatAPI:
                         content="",
                         error="Invalid API response",
                     )
-                
+
         except httpx.TimeoutException:
             logger.error("API request timed out")
             return MessageResponse(
@@ -211,7 +210,9 @@ class ChatAPI:
         except Exception as e:
             logger.error(f"Error: {str(e)}")
             return MessageResponse(
-                status=MessageStatus.ERROR, content="", error=f"Error: {str(e)}"
+                status=MessageStatus.ERROR,
+                content="",
+                error=f"Error: {str(e)}",
             )
 
 
@@ -276,13 +277,11 @@ class ChatInterface:
                     last_message = gr.Textbox(label="Last Message", interactive=False)
 
             # Event handlers
-            async def user_message(
-                message: str, history: List[List[str]]
-            ) -> Tuple[List[List[str]], str, str, str, object]:
+            async def user_message(message: str, history: List[List[str]]) -> Tuple[List[List[str]], str, str, str, object]:
                 """Handle user message submission"""
                 if not message.strip():
                     return history, "", "Please enter a message.", "", None
-                
+
                 logger.debug(f"User message: {message}")
 
                 history.append([message, ""])
@@ -301,14 +300,24 @@ class ChatInterface:
                         except Exception as e:
                             logger.error(f"Error creating plotly figure: {e}")
                             figure = None
-                            history[-1][1] += (
-                                "\n\n⚠️ Graph data is not valid, cannot be displayed."
-                            )
+                            history[-1][1] += "\n\n⚠️ Graph data is not valid, cannot be displayed."
                     history[-1][1] = content
-                    return history, "", "Message sent successfully.", content, figure
+                    return (
+                        history,
+                        "",
+                        "Message sent successfully.",
+                        content,
+                        figure,
+                    )
                 else:
                     history[-1][1] = f"❌ {response.error}"
-                    return history, "", f"Error: {response.error}", "", None
+                    return (
+                        history,
+                        "",
+                        f"Error: {response.error}",
+                        "",
+                        None,
+                    )
 
             def clear_history() -> Tuple[List[List[str]], str, str, str, dict]:
                 """Clear chat history"""

main.py

@@ -21,11 +21,7 @@ STORAGE_TYPE = env.str("STORAGE_TYPE", "mongodb")
 
 # Hugging Face Spaces için özel yapılandırma
 IS_HF_SPACE = os.environ.get("SPACE_ID") is not None
-SPACE_URL = (
-    "https://lokumai-openai-openapi-template.hf.space"
-    if IS_HF_SPACE
-    else "http://localhost:7860"
-)
+SPACE_URL = "https://lokumai-openai-openapi-template.hf.space" if IS_HF_SPACE else "http://localhost:7860"
 
 
 @asynccontextmanager

pyproject.toml

@@ -18,3 +18,7 @@ dependencies = [
     "requests>=2.32.3",
     "uvicorn>=0.34.2",
 ]
+
+# ruff line length
+[tool.ruff]
+line-length = 145

scripts/api_key_genenerator.py

@@ -46,9 +46,7 @@ def generate_api_key(username: str, secret_key: str) -> str:
     logger.debug(f"Secret key: {secret_key}")
 
     # Add HMAC signature for additional security
-    signature = hmac.new(
-        secret_key.encode(), json_str.encode(), hashlib.sha256
-    ).hexdigest()
+    signature = hmac.new(secret_key.encode(), json_str.encode(), hashlib.sha256).hexdigest()
 
     logger.debug(f"Generated signature: {signature}")
 
@@ -69,9 +67,7 @@ def save_api_key(username: str, api_key: str, timestamp: int):
         api_key (str): Generated API key
         timestamp (int): Creation timestamp
     """
-    formatted_timestamp = datetime.fromtimestamp(timestamp).strftime(
-        "%Y-%m-%d %H:%M:%S"
-    )
+    formatted_timestamp = datetime.fromtimestamp(timestamp).strftime("%Y-%m-%d %H:%M:%S")
     with open("api_keys.txt", "a") as f:
         f.write(f"Username: {username}\n")
         f.write(f"API Key: {api_key}\n")
@@ -100,9 +96,7 @@ def main():
         print('curl -X POST "http://localhost:8000/v1/chat/completions" \\')
         print(f'     -H "Authorization: Bearer {api_key}" \\')
         print('     -H "Content-Type: application/json" \\')
-        print(
-            '     -d \'{"model": "gpt-3.5-turbo", "messages": [{"role": "user", "content": "Hello!"}]}\''
-        )
+        print('     -d \'{"model": "gpt-3.5-turbo", "messages": [{"role": "user", "content": "Hello!"}]}\'')
 
     except argparse.ArgumentError:
         print("Please provide a username and secret key", file=sys.stderr)