moved environment variables to common file

db/database.py

@@ -2,16 +2,8 @@ import os
 from sqlalchemy import create_engine
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy.orm import sessionmaker
-from dotenv import load_dotenv
 
-# Load environment variables
-load_dotenv()
-
-# Get database URL from environment variable
-DATABASE_URL = os.getenv(
-    "DATABASE_URL", 
-    "postgresql://postgres:password@localhost:5432/food_ingredients"
-)
+from env import DATABASE_URL
 
 # Create engine
 engine = create_engine(DATABASE_URL)

env.py

@@ -0,0 +1,77 @@
+import os
+from dotenv import load_dotenv
+
+# Load environment variables from .env file
+load_dotenv()
+
+
+# Environment variables for FoodAnalyzer-API
+PORT = int(os.getenv("PORT", 8000))
+
+# JWT Secret Key
+SECRET_KEY = os.getenv("SECRET_KEY", "09d8f7a6b5c4e3d2f1a0b9c8d7e6f5a4")
+ALGORITHM = os.getenv("ALGORITHM", "HS256")
+ACCESS_TOKEN_EXPIRE_MINUTES = int(os.getenv("ACCESS_TOKEN_EXPIRE_MINUTES", 30))
+
+# Hugging Face Transformers API key not required
+# HUGGING_FACE_API_KEY = os.getenv("HUGGING_FACE_API_KEY", None)
+# OpenAI API key not required
+# OPENAI_API_KEY = os.getenv("OPENAI_API_KEY", None)
+
+# API keys and model names for different LLMs here 
+# for google ai studio
+LLM_API_KEY = os.getenv("LLM_API_KEY", None)
+LLM_MODEL_NAME = os.getenv("LLM_MODEL_NAME", "gemini-2.0-flash")
+
+GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY", None)
+GOOGLE_CSE_ID = os.getenv("GOOGLE_CSE_ID", None)
+
+USDA_API_KEY = os.getenv("USDA_API_KEY", "DEMO_KEY")
+
+# pg db url
+DATABASE_URL = os.getenv("DATABASE_URL", None)
+
+# Vuforia keys
+VUFORIA_SERVER_ACCESS_KEY = os.getenv("VUFORIA_SERVER_ACCESS_KEY", None)
+VUFORIA_SERVER_SECRET_KEY = os.getenv("VUFORIA_SERVER_SECRET_KEY", None)
+VUFORIA_TARGET_DATABASE_NAME = os.getenv("VUFORIA_TARGET_DATABASE_NAME", "FoodAnalyzer_BE_PROJ")
+VUFORIA_TARGET_DATABASE_ID = os.getenv("VUFORIA_TARGET_DATABASE_ID", "FoodAnalyzer_BE_PROJ")
+
+# langsmith keys optional
+LANGSMITH_TRACING = os.getenv("LANGSMITH_TRACING", True)
+LANGSMITH_ENDPOINT = os.getenv("LANGSMITH_ENDPOINT", "https://api.smith.langchain.com")
+LANGSMITH_API_KEY = os.getenv("LANGSMITH_API_KEY", None)
+LANGSMITH_PROJECT = os.getenv("LANGSMITH_PROJECT", None)
+
+# app settings
+PARALLEL_RATE_LIMIT = int(os.getenv("PARALLEL_RATE_LIMIT", 10))
+
+# Rate limiting configuration in seconds
+PUBCHEM_TIMEOUT = int(os.getenv("PUBCHEM_TIMEOUT", 2))
+PUBCHEM_MAX_RETRIES = int(os.getenv("PUBCHEM_MAX_RETRIES", 2))
+
+# Delay in seconds
+DUCKDUCKGO_RATE_LIMIT_DELAY = int(os.getenv("DUCKDUCKGO_RATE_LIMIT_DELAY", 2))
+DUCKDUCKGO_MAX_RETRIES = int(os.getenv("DUCKDUCKGO_MAX_RETRIES", 2))
+
+# fake response for testing
+SEND_FAKE_TARGET = os.getenv("SEND_FAKE_TARGET", False) == "true"
+FAKE_TARGET_IMAGE_NAME = os.getenv("FAKE_TARGET_IMAGE_NAME", "detected_Snack_0.13_db8318a668504073ad5fd0677187d305.jpg")
+
+# Define Required Environment Variables and show error if not set
+required_env_vars = {
+    "LLM_API_KEY":LLM_API_KEY,
+    "GOOGLE_API_KEY":GOOGLE_API_KEY,
+    "GOOGLE_CSE_ID":GOOGLE_CSE_ID,
+    "USDA_API_KEY":USDA_API_KEY,
+    "DATABASE_URL":DATABASE_URL,
+    "VUFORIA_SERVER_ACCESS_KEY":VUFORIA_SERVER_ACCESS_KEY,
+    "VUFORIA_SERVER_SECRET_KEY":VUFORIA_SERVER_SECRET_KEY,
+    "VUFORIA_TARGET_DATABASE_NAME":VUFORIA_TARGET_DATABASE_NAME,
+    "VUFORIA_TARGET_DATABASE_ID":VUFORIA_TARGET_DATABASE_ID,
+}
+
+# Check if all required environment variables are set
+for var in required_env_vars.keys():
+    if required_env_vars[var] is None:
+        raise ValueError(f"Environment variable {var} is not set. Please set it in the .env file.")

main.py

@@ -6,16 +6,13 @@ from routers.auth import router as auth_router
 from routers.analysis import router as analysis_router
 from routers.history import router as history_router
 from routers.product import router as product_router
-from dotenv import load_dotenv
 import os
 import uvicorn
 from pathlib import Path
 import tensorflow as tf
 import tensorflow_hub as hub
+from env import PORT
 
-load_dotenv()
-# Load environment variables from .env file
-PORT = os.getenv("PORT", 8000)
 
 # Define the templates directory
 templates = Jinja2Templates(directory="templates")
@@ -47,7 +44,7 @@ async def log_requests(request: Request, call_next):
     request._body = body_content
     response = await call_next(request)
     print(f"Request: {request.method} {request.url}")
-    print(f"Data: {body_content}")
+    print(f"Data: {body_content}"[:100])
     print(f"Headers: {request.headers}")
     return response
 

routers/analysis.py

@@ -13,7 +13,6 @@ from interfaces.productModels import ProductIngredientsRequest
 from logger_manager import log_info, log_error
 from db.database import get_db,SessionLocal
 from db.repositories import IngredientRepository
-from dotenv import load_dotenv
 from langsmith import traceable
 from services.auth_service import get_current_user
 from services.ingredientFinderAgent import IngredientInfoAgentLangGraph
@@ -22,10 +21,8 @@ from utils.db_utils import ingredient_db_to_pydantic
 from utils.ingredient_utils import process_single_ingredient
 
 # Load environment variables
-load_dotenv()
+from env import PARALLEL_RATE_LIMIT
 
-# Get rate limit from environment variable or use default
-PARALLEL_RATE_LIMIT = int(os.getenv("PARALLEL_RATE_LIMIT", 10))
 log_info(f"Using parallel rate limit of {PARALLEL_RATE_LIMIT}")
 
 # Create a semaphore to limit concurrent API calls

routers/product.py

@@ -20,7 +20,6 @@ from db.database import get_db
 from fastapi import Depends
 from db.repositories import ProductRepository, IngredientRepository
 
-from dotenv import load_dotenv
 
 
 from services.ingredients import IngredientService 
@@ -30,13 +29,8 @@ from utils.vuforia_utils import add_target_to_vuforia, UPLOADED_IMAGES_DIR
 from utils.fetch_data import fetch_product_data_from_api
 import uuid
 
-
-load_dotenv()
-
-VUFORIA_SERVER_ACCESS_KEY = os.getenv("VUFORIA_SERVER_ACCESS_KEY")
-VUFORIA_SERVER_SECRET_KEY = os.getenv("VUFORIA_SERVER_SECRET_KEY")
-VUFORIA_TARGET_DATABASE_NAME = os.getenv("VUFORIA_TARGET_DATABASE_NAME")
-VUFORIA_TARGET_DATABASE_ID = os.getenv("VUFORIA_TARGET_DATABASE_ID")
+# import environment variables
+from env import VUFORIA_SERVER_ACCESS_KEY,VUFORIA_SERVER_SECRET_KEY,VUFORIA_TARGET_DATABASE_NAME,VUFORIA_TARGET_DATABASE_ID
 
 router = APIRouter()
 

services/ingredientFinderAgent.py

@@ -3,7 +3,6 @@ from functools import partial
 import os
 import json
 import traceback
-from dotenv import load_dotenv
 from typing import Dict, Any
 
 from langchain_google_genai import ChatGoogleGenerativeAI
@@ -14,9 +13,7 @@ from logger_manager import log_debug, log_error, log_info, log_warning
 from utils.agent_tools import search_local_db,search_web,search_wikipedia,search_open_food_facts,search_usda,search_pubchem
 
 # Load environment variables from .env file
-load_dotenv()
-
-
+from env import GOOGLE_API_KEY, LLM_MODEL_NAME
 
 def create_summary_from_source(source: Dict[str, Any]) -> str:
     """Create a meaningful summary from source data."""
@@ -94,12 +91,9 @@ def analyze_ingredient(state: IngredientState) -> IngredientState:
     Returns:
         Updated state with analysis results
     """
-    # Get API key and model from environment
-    api_key = os.getenv("GOOGLE_API_KEY")
-    model_name = os.getenv("LLM_MODEL_NAME", "gemini-1.5-pro")
     
     # Basic validation
-    if not api_key:
+    if not GOOGLE_API_KEY:
         log_error("No Google API key found in environment variables")
         new_state = state.copy()
         new_state["result"] = {
@@ -114,8 +108,8 @@ def analyze_ingredient(state: IngredientState) -> IngredientState:
     # Initialize LLM
     try:
         llm = ChatGoogleGenerativeAI(
-            google_api_key=api_key,
-            model=model_name,
+            google_GOOGLE_API_KEY=GOOGLE_API_KEY,
+            model=LLM_MODEL_NAME,
             temperature=0.3,  # Lower temperature for more factual responses
             # convert_system_message_to_human=True
         )

services/productAnalyzerAgent.py

@@ -1,13 +1,12 @@
 import os
 from typing import List, Dict, Any, Optional
-from dotenv import load_dotenv
 from langchain_core.messages import HumanMessage
 from langchain_google_genai import ChatGoogleGenerativeAI
 from logger_manager import log_error, log_info
 from interfaces.ingredientModels import IngredientAnalysisResult
 
 # Load environment variables
-load_dotenv()
+from env import LLM_API_KEY, LLM_MODEL_NAME
 
 async def analyze_product_ingredients(
     ingredients_data: List[IngredientAnalysisResult],
@@ -19,13 +18,10 @@ async def analyze_product_ingredients(
     """
     log_info(f"Analyzing product with {len(ingredients_data)} ingredients")
     
-    # Initialize LLM
-    api_key = os.getenv("LLM_API_KEY")
-    model_name = os.getenv("LLM_MODEL_NAME", "gemini-2.0-flash")
-    
+    # Initialize LLM    
     llm = ChatGoogleGenerativeAI(
-        google_api_key=api_key,
-        model=model_name,
+        google_LLM_API_KEY=LLM_API_KEY,
+        model=LLM_MODEL_NAME,
         temperature=0.2  # Lower temperature for more factual responses
     )
     

utils/agent_tools.py

@@ -2,12 +2,10 @@ import asyncio
 import os
 
 import pandas as pd
-from dotenv import load_dotenv
 
 from typing import Dict, Any
 # modular
 from logger_manager import log_error, log_info, log_warning
-from dotenv import load_dotenv
 
 import aiohttp
 import time
@@ -20,7 +18,7 @@ from langchain_core.tools import tool
 
 
 # Load environment variables from .env file
-load_dotenv()
+from env import PUBCHEM_MAX_RETRIES, PUBCHEM_TIMEOUT,DUCKDUCKGO_MAX_RETRIES,DUCKDUCKGO_RATE_LIMIT_DELAY,USDA_API_KEY
 
 # Load Scraped Database
 SCRAPED_DB_PATH = "data/Food_Aditives_E_numbers.csv"  # Ensure this file exists
@@ -32,15 +30,6 @@ else:
     log_warning("Scraped database not found!")
 
 
-# Define a rate limit (adjust as needed)
-PUBCHEM_TIMEOUT = float(os.getenv("PUBCHEM_TIMEOUT", "2.0"))   # seconds
-PUBCHEM_MAX_RETRIES = int(os.getenv("PUBCHEM_MAX_RETRIES", "3"))  # Max retries
-
-# Rate limiting configuration
-DUCKDUCKGO_RATE_LIMIT_DELAY = float(os.getenv("DUCKDUCKGO_RATE_LIMIT_DELAY", "2.0"))  # Delay in seconds
-DUCKDUCKGO_MAX_RETRIES = int(os.getenv("DUCKDUCKGO_MAX_RETRIES", "3"))  # Max retries
-
-
 # Define tool functions
 @tool("search_local_db")
 def search_local_db(ingredient: str) -> Dict[str, Any]:
@@ -98,12 +87,11 @@ def search_usda(ingredient: str) -> Dict[str, Any]:
     
     try:
         usda_api = "https://api.nal.usda.gov/fdc/v1"
-        usda_api_key = os.getenv("USDA_API_KEY", "DEMO_KEY")  # Use DEMO_KEY if not provided
         
         # Search for the ingredient
         search_url = f"{usda_api}/foods/search"
         params = {
-            "api_key": usda_api_key,
+            "api_key": USDA_API_KEY,
             "query": ingredient,
             "dataType": ["Foundation", "SR Legacy", "Branded"],
             "pageSize": 5

utils/external_api_utils.py

@@ -2,12 +2,8 @@ import requests
 import json
 import os
 from logger_manager import log_info, log_error
-from dotenv import load_dotenv
 
-load_dotenv()
-
-VUFORIA_SERVER_ACCESS_KEY = os.getenv("VUFORIA_SERVER_ACCESS_KEY")
-VUFORIA_SERVER_SECRET_KEY = os.getenv("VUFORIA_SERVER_SECRET_KEY")
+from env import VUFORIA_SERVER_ACCESS_KEY, VUFORIA_SERVER_SECRET_KEY
 
 def get_vuforia_auth_headers():
     """

utils/ingredient_utils.py

@@ -6,17 +6,14 @@ from db.repositories import IngredientRepository
 from interfaces.ingredientModels import IngredientAnalysisResult
 from logger_manager import log_error, log_info
 from services.ingredientFinderAgent import IngredientInfoAgentLangGraph
-from dotenv import load_dotenv
 from langsmith import traceable
 import pytz
 
 from utils.db_utils import ingredient_db_to_pydantic
 
 # Load environment variables
-load_dotenv()
+from env import PARALLEL_RATE_LIMIT
 
-# Get rate limit from environment variable or use default
-PARALLEL_RATE_LIMIT = int(os.getenv("PARALLEL_RATE_LIMIT", 10))
 
 # Create a semaphore to limit concurrent API calls
 llm_semaphore = asyncio.Semaphore(PARALLEL_RATE_LIMIT)

utils/vuforia_utils.py

@@ -3,19 +3,13 @@ from logger_manager import log_info, log_error
 from PIL import Image
 import os
 from pathlib import Path
-from dotenv import load_dotenv
 import requests
-load_dotenv()
 
 UPLOADED_IMAGES_DIR = "uploaded_images"
 if not os.path.exists(UPLOADED_IMAGES_DIR):
     os.makedirs(UPLOADED_IMAGES_DIR)
 
-
-VUFORIA_SERVER_ACCESS_KEY = os.getenv("VUFORIA_SERVER_ACCESS_KEY")
-VUFORIA_SERVER_SECRET_KEY = os.getenv("VUFORIA_SERVER_SECRET_KEY")
-VUFORIA_TARGET_DATABASE_NAME = os.getenv("VUFORIA_TARGET_DATABASE_NAME")
-VUFORIA_TARGET_DATABASE_ID = os.getenv("VUFORIA_TARGET_DATABASE_ID")
+from env import VUFORIA_SERVER_ACCESS_KEY, VUFORIA_SERVER_SECRET_KEY, VUFORIA_TARGET_DATABASE_NAME, VUFORIA_TARGET_DATABASE_ID
 
 def get_vuforia_auth_headers():
     """