[NOTICKET] Update env key name

.env.example

@@ -8,15 +8,15 @@ causalogy--pg--host = ""
 causalogy--pg--port = ""
 
 # Local Postgresql
-ss--postgresql--url = ""
+ss__postgresql__url = ""
 
 
 ## -------------------- OBSERVABILITY -------------------- ##
 
 # Langfuse (dev)
-ss--langfuse--secret-key = ""
-ss--langfuse--public-key = ""
-langfuse--host = ""
+ss__langfuse__secret_key = ""
+ss__langfuse__public_key = ""
+langfuse__host = ""
 
 
 ## -------------------- LLM CONFIGURATION -------------------- ##
@@ -25,22 +25,22 @@ langfuse--host = ""
 GOOGLE_API_KEY= ""
 
 # GPT-4O-MINI
-azureai--api-key--4omini = ""
-azureai--endpoint--url--4omini = ""
-azureai--deployment--name--4omini = ""
-azureai--api--version--4omini = ""
+azureai__api_key__4omini = ""
+azureai__endpoint__url__4omini = ""
+azureai__deployment__name__4omini = ""
+azureai__api__version__4omini = ""
 
 # GPT-5-MINI
-azureai--api-key--5mini = ""
-azureai--endpoint--url--5mini = ""
-azureai--deployment--name--5mini = ""
-azureai--api--version--5mini = ""
+azureai__api_key__5mini = ""
+azureai__endpoint__url__5mini = ""
+azureai__deployment__name__5mini = ""
+azureai__api__version__5mini = ""
 
 # GPT-4O-2
-azureai--api-key--4o-2 = ""
-azureai--endpoint--url--4o-2 = ""
-azureai--deployment--name--4o-2 = ""
-azureai--api--version--4o-2 = ""
+azureai__api_key__4o_2 = ""
+azureai__endpoint__url__4o_2 = ""
+azureai__deployment__name__4o_2 = ""
+azureai__api__version__4o_2 = ""
 
 # Qdrant
 ss--qdrant--api-key = ""
@@ -48,20 +48,20 @@ ss--qdrant--endpoint--url = ""
 ss--qdrant--collection--name = ""
 
 # Embedding Model
-azureai--embedmodel--endpoint = ""
-azureai--embedmodel--api-key = ""
-azureai--embedmodel--api--version = ""
-azureai--embedmodel--name = ""
+azureai__embedmodel__endpoint = ""
+azureai__embedmodel__api_key = ""
+azureai__embedmodel__api__version = ""
+azureai__embedmodel__name = ""
 
 # AZURE BLOB 
-azureai--search--sas = ""
-azureai--container--endpoint = ""
-azureai--container--name = ""
-azureai--container--account--name = ""
-azureai--max-file-size-mb = 5
+azureai__search__sas = ""
+azureai__container__endpoint = ""
+azureai__container__name = ""
+azureai__container__account__name = ""
+azureai__max_file_size_mb = 5
 
 
 # JWT
-ss--jwt--secret-key = ""
-ss--jwt--algorithm = ""
-ss--jwt--access-token-expire-minutes = 60
+ss__jwt__secret_key = ""
+ss__jwt__algorithm = ""
+ss__jwt__access_token_expire_minutes = 60

config/constant.py

@@ -8,24 +8,24 @@ load_dotenv(EnvFilepath.ENVPATH)
 
 @dataclass
 class EnvPostgresConstants:
-    CONSTRING: str = os.environ.get("ss--postgresql--url")
+    CONSTRING: str = os.environ.get("ss__postgresql__url")
 
 @dataclass(frozen=True)
 class SecurityConstants:
     BCRYPT_MAX_BYTES: int = 72
-    JWT_SECRET_KEY: str = os.environ.get("ss--jwt--secret-key")
-    JWT_ALGORITHM: str = os.environ.get("ss--jwt--algorithm")
-    JWT_EXPIRE_MINUTES: int = int(os.environ.get("ss--jwt--access-token-expire-minutes", 60))
+    JWT_SECRET_KEY: str = os.environ.get("ss__jwt__secret_key")
+    JWT_ALGORITHM: str = os.environ.get("ss__jwt__algorithm")
+    JWT_EXPIRE_MINUTES: int = int(os.environ.get("ss__jwt__access_token_expire_minutes", 60))
 
 @dataclass(frozen=True)
 class AzureBlobConstants:
     BLOB_PREFIX: str = "dev" # DOCS: change accordingly
-    ENDPOINT: str = os.environ.get("azureai--container--endpoint")
-    CONTAINER_NAME: str = os.environ.get("azureai--container--name")
-    SAS_KEY: str = os.environ.get("azureai--search--sas")
-    MAX_FILE_SIZE_MB: int = int(os.getenv("azureai--max-file-size-mb", "5"))
+    ENDPOINT: str = os.environ.get("azureai__container__endpoint")
+    CONTAINER_NAME: str = os.environ.get("azureai__container__name")
+    SAS_KEY: str = os.environ.get("azureai__search__sas")
+    MAX_FILE_SIZE_MB: int = int(os.getenv("azureai__max_file_size_mb", "5"))
     CHUNK_SIZE: int = 4 * 1024 * 1024
-    ACCOUNT_NAME: str = os.environ.get("azureai--container--account--name")
+    ACCOUNT_NAME: str = os.environ.get("azureai__container__account__name")
 
 @dataclass
 class ProfileFieldTypes:

externals/observability/langfuse.py

@@ -7,9 +7,9 @@ from langchain_core.callbacks.base import BaseCallbackHandler
 
 
 langfuse = Langfuse(
-    secret_key=os.environ.get('ss--langfuse--secret-key'), 
-    public_key=os.environ.get('ss--langfuse--public-key'), 
-    host=os.environ.get('langfuse--host'),
+    secret_key=os.environ.get('ss__langfuse__secret_key'), 
+    public_key=os.environ.get('ss__langfuse__public_key'), 
+    host=os.environ.get('langfuse__host'),
 )
 
 

services/embed_model/embed_model.py

@@ -8,10 +8,10 @@ from langchain_openai import AzureOpenAIEmbeddings
 def serve_embed_model():
     try:
         embed_model = AzureOpenAIEmbeddings(
-            model=os.environ.get('azureai--embedmodel--name'),
-            azure_endpoint=os.environ.get('azureai--embedmodel--endpoint'),
-            api_key=os.environ.get('azureai--embedmodel--api-key'),
-            api_version=os.environ.get('azureai--embedmodel--api--version')
+            model=os.environ.get('azureai__embedmodel__name'),
+            azure_endpoint=os.environ.get('azureai__embedmodel__endpoint'),
+            api_key=os.environ.get('azureai__embedmodel__api_key'),
+            api_version=os.environ.get('azureai__embedmodel__api__version')
         )
         # asyncio.run(embed_model.aembed_documents("Hello my name is EMA"))
         print(f"✅ [INFO] Initialized embedding model succeeded")

services/llms/LLM.py

@@ -1,6 +1,7 @@
 import os
 from dotenv import load_dotenv
-load_dotenv() 
+from config.env_constant import EnvFilepath
+load_dotenv(EnvFilepath.ENVPATH) 
 from langchain_openai import AzureChatOpenAI
 # from langchain_google_genai import ChatGoogleGenerativeAI
 # from langchain.callbacks import AsyncIteratorCallbackHandler
@@ -10,7 +11,7 @@ from langchain_openai import AzureChatOpenAI
 # langfuse_handler = CallbackHandler(
 #     secret_key=os.environ.get('buma--langfuse--secret-key'), 
 #     public_key=os.environ.get('buma--langfuse--public-key'), 
-#     host=os.environ.get('buma--langfuse--host')
+#     host=os.environ.get('buma--langfuse__host')
 # )
 
 
@@ -29,30 +30,30 @@ from langchain_openai import AzureChatOpenAI
 # )
 
 model_4o_2 = AzureChatOpenAI(
-    azure_endpoint=os.environ.get("azureai--endpoint--url--4o-2"),  # or your deployment
-    openai_api_version=os.environ.get("azureai--api--version--4o-2"),  # or your api version
-    deployment_name=os.environ.get("azureai--deployment--name--4o-2"),
-    openai_api_key=os.environ.get("azureai--api-key--4o-2"),
+    azure_endpoint=os.environ.get("azureai__endpoint__url__4o_2"),  # or your deployment
+    openai_api_version=os.environ.get("azureai__api__version__4o_2"),  # or your api version
+    deployment_name=os.environ.get("azureai__deployment__name__4o_2"),
+    openai_api_key=os.environ.get("azureai__api_key__4o_2"),
     openai_api_type="azure",
     max_retries=2,
     disable_streaming=True
 )
 
 model_4omini = AzureChatOpenAI(
-    azure_endpoint=os.environ.get("azureai--endpoint--url--4omini"),  # or your deployment
-    openai_api_version=os.environ.get("azureai--api--version--4omini"),  # or your api version
-    deployment_name=os.environ.get("azureai--deployment--name--4omini"),
-    openai_api_key=os.environ.get("azureai--api-key--4omini"),
+    azure_endpoint=os.environ.get("azureai__endpoint__url__4omini"),  # or your deployment
+    openai_api_version=os.environ.get("azureai__api__version__4omini"),  # or your api version
+    deployment_name=os.environ.get("azureai__deployment__name__4omini"),
+    openai_api_key=os.environ.get("azureai__api_key__4omini"),
     openai_api_type="azure",
     max_retries=2,
     disable_streaming=True
 )
 
 model_5mini = AzureChatOpenAI(
-    azure_endpoint=os.environ.get("azureai--endpoint--url--5mini"),  # or your deployment
-    openai_api_version=os.environ.get("azureai--api--version--5mini"),  # or your api version
-    deployment_name=os.environ.get("azureai--deployment--name--5mini"),
-    openai_api_key=os.environ.get("azureai--api-key--5mini"),
+    azure_endpoint=os.environ.get("azureai__endpoint__url__5mini"),  # or your deployment
+    openai_api_version=os.environ.get("azureai__api__version__5mini"),  # or your api version
+    deployment_name=os.environ.get("azureai__deployment__name__5mini"),
+    openai_api_key=os.environ.get("azureai__api_key__5mini"),
     openai_api_type="azure",
     max_retries=2,
     disable_streaming=True

services/uploader/azure_blob_service.py

@@ -20,7 +20,7 @@ logger = get_logger("azure blob")
 # CONNECTION_STRING = os.getenv("AZURE_STORAGE_CONNECTION_STRING")
 # CONTAINER_NAME = "pdf-uploads"  # The name of your Azure Blob Storage container
 
-async def get_blob_service_client(url=os.environ.get('azureai--container--endpoint')) -> BlobServiceClient:
+async def get_blob_service_client(url=os.environ.get('azureai__container__endpoint')) -> BlobServiceClient:
     try:
         default_credential = DefaultAzureCredential()
         blob_service_client = BlobServiceClient(url, credential=default_credential)
@@ -29,7 +29,7 @@ async def get_blob_service_client(url=os.environ.get('azureai--container--endpoi
         logger.error(f'❌ Getting blob service client error, {E}')
 
 
-async def get_container_client(url=os.environ.get('azureai--container--endpoint'), container_name=os.environ.get("azureai--container--name")) -> ContainerClient:
+async def get_container_client(url=os.environ.get('azureai__container__endpoint'), container_name=os.environ.get("azureai__container__name")) -> ContainerClient:
     try:
         blob_service_client = await get_blob_service_client(url=url)
         blob_client = blob_service_client.get_container_client(container_name)