chore: format, improve logging, remove deprecated code

.dockerignore

@@ -1,6 +1,5 @@
 .git/
 .github/
-.vscode/
 .venv/
 __pycache__/
 dist/

app/agent/chat_agent_client.py

@@ -9,6 +9,6 @@ class ChatAgentClient:
         # TODO implement the logic to process the chat
         agent_name = self.agent_name
         return AssistantChatAgentResponse(
-            message=f"Here is the {agent_name} Processed message: This is a placeholder response for the user-question",
+            message=f"Here is the {agent_name} Processed message: This is a placeholder response for the user-question typeOfTheRequest:{type(user_chat_agent_request)}",
             figure=None,  # Placeholder for any figure data if needed
         )

app/core/api_response.py

@@ -1,5 +1,5 @@
 from functools import wraps
-import re
+from warnings import deprecated
 from fastapi import HTTPException, Request, status
 from loguru import logger
 import os
@@ -10,55 +10,18 @@ from environs import Env
 env = Env()
 env.read_env()
 
-USE_MOCK = env.bool("USE_MOCK", True)
+USE_MOCK = env.bool("USE_MOCK", False)
 MOCK_DIR = env.str("MOCK_DIR", "resources/mock")
 
 # Deprecated code. because we are using mongomock-motor for database_type=embedded
-# TODO: remove this code after we switch to real database
-
-
-def url_to_filename(url: str, method: str) -> str:
-    """
-    Convert API URL to mock filename.
-    Example:
-    - Input: GET "/v1/chat/completions" -> "chat_completions_GET.json"
-    - Input: GET "/v1/chat/completions/{completion_id}" -> "chat_completions_id_GET.json"
-    - Input: GET "/v1/chat/completions/123/messages" -> "chat_completions_id_messages_GET.json"
-    """
-    logger.trace(f"BEGIN: url: {url} method: {method}")
-    # Remove version prefix and leading/trailing slashes
-    path = url.strip("/")
-    if path.startswith("v1/"):
-        path = path[3:]
-
-    # Replace path parameters with descriptive names
-    path = path.replace("{completion_id}", "id")
-    path = path.replace("{message_id}", "id")
-
-    logger.trace(f"replaced path: {path}")
-
-    # Convert to filename format
-    filename = path.replace("/", "_")
-    logger.trace(f"filename: {filename}")
-
-    # convert conversations_1 to conversations with dynamic id
-    final_filename = re.sub(r"[_][^/]+$", "_id", filename)
-    logger.trace(f"final_filename: {final_filename}")
-
-    # Add method suffix
-    result = f"{final_filename}_{method}"
-    logger.trace(f"END: result: {result}")
-    return result
 
 
+@deprecated("This function is deprecated. Use database_type=embedded with mongomock-motor instead.")
 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}")
-    filename = None
     file_path = None
     try:
-        # Convert to filename
-        # filename = url_to_filename(url_path, method)
         filename = python_module_name + "_" + python_method_name
         filename = filename.replace(".", "_")
         filename = filename.replace("__", "_")
@@ -67,7 +30,7 @@ def get_mock_response(url_path: str, python_module_name: str, python_method_name
         filename = filename.replace(" ", "_")
         filename = filename.replace("-", "_")
         filename = filename.replace("app_api_", "")
-
+        logger.trace(f"FileName : {filename}")
         # Load mock response
         file_path = os.path.join(MOCK_DIR, f"{filename}.json")
 
@@ -89,7 +52,7 @@ def get_mock_response(url_path: str, python_module_name: str, python_method_name
 
 
 def api_response():
-    """Decorator to handle mock/real API responses."""
+    """Decorator to handle API request and response"""
 
     def decorator(func):
         logger.trace(f"BEGIN: decorator: {func}")

app/mapper/chat_mapper.py

@@ -1,4 +1,4 @@
-import datetime
+from datetime import datetime
 from app.mapper.base_mapper import BaseMapper
 from app.model.chat_model import ChatCompletion, ChatMessageModel
 from app.schema.chat_schema import ChatCompletionResponse, ChatCompletionRequest, ChatMessageResponse, ChoiceResponse

app/model/chat_model.py

@@ -5,51 +5,6 @@ from pydantic import BaseModel, Field
 from datetime import datetime
 from typing import List, Optional, Any
 
-# Chat completion payload example
-# {
-#   "model": "gpt-4o",
-#   "messages": [
-#     {
-#       "role": "system",
-#       "content": "You are a travel assistant with expertise in creating personalized travel itineraries. Provide detailed, practical, and concise recommendations, including specific locations, activities, and tips based on the user's preferences. Always consider budget, travel dates, and any special requests."
-#     },
-#     {
-#       "role": "user",
-#       "content": "I'm planning a 5-day trip to Italy in June 2025 with a moderate budget. I love history, food, and scenic views. Where should I go, and what should I do?"
-#     },
-#     {
-#       "role": "assistant",
-#       "content": "For a 5-day trip to Italy with a focus on history, food, and scenic views on a moderate budget, I recommend visiting Rome and Florence. Here's a suggested itinerary:\n\n**Day 1-3: Rome**\n- **Day 1**: Visit the Colosseum (book skip-the-line tickets online for ~€16) and Roman Forum for a dive into ancient history. Enjoy dinner at a trattoria in Trastevere, like Osteria da Zi Umberto (~€15-20 per person).\n- **Day 2**: Explore the Pantheon (free entry) and Vatican Museums (Sistine Chapel, ~€20). Take an evening stroll at Piazza Navona. Try gelato at Gelateria del Teatro (~€3).\n- **Day 3**: Visit the Capitoline Museums (€15) and take a scenic walk along the Tiber River. Enjoy carbonara at Roscioli (~€12).\n\n**Day 4-5: Florence**\n- **Day 4**: Take a morning train from Rome to Florence (~€30, 1.5 hours). Visit the Uffizi Gallery (book ahead, ~€20) and stroll Ponte Vecchio for views. Dine at Trattoria Mario for affordable Tuscan dishes (~€10-15).\n- **Day 5**: Explore the Florence Cathedral (Duomo, free entry; dome climb ~€20) and enjoy views from Piazzale Michelangelo (free). Try a lampredotto sandwich at a local food stall (~€5).\n\n**Tips**: Book accommodations like budget hotels or Airbnb (~€60-100/night). Use regional trains for cost savings. June weather is warm, so pack light clothing and book tickets early to avoid crowds."
-#     },
-#     {
-#       "role": "user",
-#       "content": "That sounds great! Can you suggest a specific hotel in Rome and any food markets to visit in Florence?"
-#     },
-#     {
-#       "role": "assistant",
-#       "content": "**Rome Hotel**: Consider **Hotel Artemide**, a centrally located 4-star hotel with rates around €80-100 per night on a moderate budget. It's near Termini Station and within walking distance of major sites like the Trevi Fountain. Book directly for potential deals.\n\n**Florence Food Markets**:\n- **Mercato Centrale**: A vibrant indoor market with food stalls offering fresh pasta, pizza, and local cheeses. Try a plate of fresh tortellini (~€8) or focaccia. Open daily, great for lunch.\n- **Sant'Ambrogio Market**: Less touristy, with fresh produce and local specialties like porchetta sandwiches (~€5). It's perfect for an authentic experience, located near Santa Croce. Open mornings until 2 PM.\n\n**Tip**: In Florence, pair market visits with a stop at a nearby café for espresso (~€1.50) to soak in the local vibe."
-#     },
-#     {
-#       "role": "user",
-#       "content": "What about transportation between cities and within Florence?"
-#     },
-#     {
-#       "role": "assistant",
-#       "content": "**Between Cities**: Take a high-speed train (Italo or Trenitalia) from Rome to Florence. Book in advance for tickets around €25-35 one-way (1.5 hours). Trains depart from Roma Termini and arrive at Firenze Santa Maria Novella. Check schedules on trenitalia.com or italo.it.\n\n**Within Florence**: Florence is compact and walkable, so you won't need much public transport. For longer distances (e.g., to Piazzale Michelangelo), use ATAF buses (~€1.50 per ride, buy tickets at tabaccherie). Alternatively, rent a bike (~€10/day) for a scenic way to explore. Taxis are pricier (~€10-15 for short trips), so stick to walking or buses for budget travel.",
-#        "figure": {
-#            "data": {},
-#            "layout": {}
-#        }
-#     }
-#   ],
-#   "temperature": 0.8,
-#   "max_tokens": 500,
-#   "top_p": 1.0,
-#   "frequency_penalty": 0.2,
-#   "presence_penalty": 0.1
-#   "stream": false
-# }
-
 
 class ChatMessageModel(BaseModel):
     """

app/repository/chat_repository.py

@@ -163,7 +163,7 @@ class ChatRepository:
                 return final_entity
             except Exception as e:
                 logger.error(f"Error parsing ChatCompletion from DB for id {completion_id}: {e}", exc_info=True)
-                return None  # Parse hatası durumunda None döndür
+                return None
         else:
             logger.info(f"Chat completion with ID {completion_id} not found in DB.")
             return None

app/schema/chat_schema.py

@@ -46,7 +46,6 @@ class ChoiceResponse(BaseModel):
     )
     index: Optional[int] = Field(None, description="The index of the choice in the list of choices.")
     message: Optional[ChatMessageResponse] = Field(None, description="The message to use for the chat completion")
-    # logprobs: str = None # not implemented yet
 
 
 class ChatCompletionResponse(BaseModel):
@@ -60,7 +59,7 @@ class ChatCompletionResponse(BaseModel):
     model: Optional[str] = Field(None, description="The model used for the chat completion")
     # not implemented yet
     # service_tier: Optional[ServiceTier] = ServiceTier.AUTO
-    # system_fingerprint: Optional[StrictStr] = Field(default=None, description="This fingerprint represents the backend configuration that the model runs with.  Can be used in conjunction with the `seed` request parameter to understand when backend changes have been made that might impact determinism. ")
+    # system_fingerprint: Optional[StrictStr] = Field(default=None, description=This fingerprint represents the backend configuration that the model runs with.  Can be used in conjunction with the `seed` request parameter to understand when backend changes have been made that might impact determinism.)
     # object: StrictStr = Field(description="The object type, which is always `chat.completion`.")
     # usage: Optional[CompletionUsage] = None
 

app/security/auth_service.py

@@ -12,7 +12,7 @@ api_key_header = APIKeyHeader(
     name="Authorization",
     scheme_name="ApiKeyAuth",
     description="API key in the format: sk-{username}-{base64_encoded_data}",
-    auto_error=False,  # API key olmadığında otomatik hata vermesini engelle
+    auto_error=False,
 )
 
 
@@ -51,8 +51,6 @@ class AuthService:
                     status_code=status.HTTP_401_UNAUTHORIZED,
                     detail=f"Invalid API key data format: {str(e)}",
                 )
-
-            # Debug için JSON verilerini logla
             json_data = {
                 "username": data["username"],
                 "created_at": data["created_at"],

app/service/chat_service.py

@@ -124,12 +124,12 @@ class ChatService:
             else:
                 logger.info("Update existing chat completion with new user request message")
 
-                logger.debug(f"before update. current db entity messsage count: {len(current_db_entity.messages)}")
+                logger.trace(f"before update. current db entity messages count: {len(current_db_entity.messages)}")
                 current_db_entity.messages.append(last_user_message_model)
-                logger.debug(f"after update. current db entity messsage count: {len(current_db_entity.messages)}")
+                logger.trace(f"after update. current db entity messages count: {len(current_db_entity.messages)}")
                 current_db_entity.last_updated_date = datetime.datetime.now()
                 final_entity = await self.chat_repository.update(current_db_entity)
-                logger.debug(f"after update. final entity messsage count: {len(final_entity.messages)}")
+                logger.trace(f"after update. final entity messages count: {len(final_entity.messages)}")
 
             # Convert model to response
             result = self.chat_mapper.to_schema(final_entity, convert_last_message=True)

gradio_chatbot.py

@@ -13,7 +13,7 @@ import plotly.graph_objects as go
 env = environs.Env()
 env.read_env()
 
-# Hugging Face Spaces için özel yapılandırma
+# special handling for Hugging Face Space
 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"
 

main.py

@@ -21,7 +21,7 @@ env.read_env()
 
 DB_DATABASE_TYPE = env.str("DB_DATABASE_TYPE", "mongodb")
 
-# Hugging Face Spaces için özel yapılandırma
+# special handling for Hugging Face Space
 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"
 

resources/mock/message.md

@@ -1,15 +1,15 @@
 ## Result
-|status|count|
-|---|---|
-|active|100|
-|cancelled|30|
-|pending|40|
-|passive|150|
+| status    | count |
+|-----------|-------|
+| active    | 100   |
+| cancelled | 30    |
+| pending   | 40    |
+| passive   | 150   |
 
 ## Explanation
 This result represents the number of active, cancelled, pending and passive customers in the year 2025. This is a mock result for the question "How many customers are active, cancelled, pending and passive in the year 2025?"
 
 ## Query
-```sql
+``sql
 SELECT status, COUNT(*) FROM customers WHERE year = 2025 GROUP BY status;
 ```

run.sh

@@ -1,18 +1,18 @@
 #!/bin/bash
 
-# Önce eski uygulamayı durdur
+# stop existing application if running
 echo "Stopping existing application..."
 pkill -f "uvicorn main:app"
 
-# 2 saniye bekle
+# wait for the process to stop
 sleep 2
 
-# FastAPI uygulamasını başlat (Gradio entegre edilmiş)
+# start FastAPI application with uvicorn integrated Gradio Application
 echo "Starting application..."
 uv run uvicorn main:app --host 0.0.0.0 --port 7860 --reload
 
-# Ctrl+C ile durdurma işlemini yakala
+# catch SIGINT (Ctrl+C) to stop the application gracefully
 trap "echo 'Stopping application...'; pkill -f 'uvicorn main:app'; exit" INT
 
-# Uygulamanın çalışmasını bekle
+# wait for the application to run
 wait

scripts/api_key_genenerator.py

@@ -24,7 +24,7 @@ from loguru import logger
 logger.add("logs/api_key_generator.log")
 
 
-def generate_api_key(username: str, secret_key: str) -> str:
+def generate_api_key(username: str, secret_key: str) -> tuple[str, int]:
     """
     Generates an API key for the given username using a secret key.
 
@@ -39,7 +39,6 @@ def generate_api_key(username: str, secret_key: str) -> str:
     timestamp = int(datetime.now().timestamp())
     data = {"username": username, "created_at": timestamp}
 
-    # Debug için JSON verilerini logla
     json_data = {"username": username, "created_at": timestamp}
     json_str = json.dumps(json_data)
     logger.debug(f"JSON data for signature: {json_str}")