Update App_Function_Libraries/DB/RAG_QA_Chat_DB.py

App_Function_Libraries/DB/RAG_QA_Chat_DB.py

@@ -23,41 +23,56 @@ from App_Function_Libraries.Utils.Utils import get_project_relative_path, get_pr
 ########################################################################################################################
 #
 # Functions:
+
 def get_rag_qa_db_path():
-    # Get and verify project root
-    project_root = get_project_root()
-    print(f"Project root path: {project_root}")
-    
-    # Construct and verify config path
-    config_path = os.path.join(project_root, 'Config_Files', 'config.txt')
-    print(f"Looking for config at: {config_path}")
-    print(f"Config file exists: {os.path.exists(config_path)}")
-    
-    # If config exists, check its contents
-    if os.path.exists(config_path):
-        with open(config_path, 'r') as f:
-            print("Raw config contents:")
-            print(f.read())
-    
-    config = configparser.ConfigParser()
-    files_read = config.read(config_path)
-    print(f"Files successfully read: {files_read}")
-    print(f"Available sections: {config.sections()}")
-    
-    if config.has_section('Database'):
-        print(f"Database section options: {config.options('Database')}")
-        if config.has_option('Database', 'rag_qa_db_path'):
-            rag_qa_db_path = config.get('Database', 'rag_qa_db_path')
-            print(f"Found rag_qa_db_path: {rag_qa_db_path}")
-            if not os.path.isabs(rag_qa_db_path):
-                rag_qa_db_path = get_project_relative_path(rag_qa_db_path)
-            return rag_qa_db_path
+    try:
+        config_path = os.path.join(get_project_root(), 'Config_Files', 'config.txt')
+        print(f"Attempting to read config from: {config_path}")
+        
+        if not os.path.exists(config_path):
+            print(f"Config file does not exist at: {config_path}")
+            raise FileNotFoundError(f"Config file not found at: {config_path}")
+        
+        config = configparser.ConfigParser()
+        files_read = config.read(config_path)
+        print(f"Config files read: {files_read}")
+        print(f"Sections in config: {config.sections()}")
+        
+        if 'Database' in config.sections():
+            print("Found Database section")
+            print(f"Options in Database section: {config.options('Database')}")
+            
+            if 'rag_qa_db_path' in config.options('Database'):
+                rag_qa_db_path = config.get('Database', 'rag_qa_db_path')
+                print(f"Found rag_qa_db_path: {rag_qa_db_path}")
+                
+                if not os.path.isabs(rag_qa_db_path):
+                    project_root = get_project_root()
+                    rag_qa_db_path = os.path.join(project_root, rag_qa_db_path)
+                    print(f"Converted to absolute path: {rag_qa_db_path}")
+                
+                # Ensure the directory exists
+                db_dir = os.path.dirname(rag_qa_db_path)
+                if not os.path.exists(db_dir):
+                    print(f"Creating directory: {db_dir}")
+                    os.makedirs(db_dir, exist_ok=True)
+                
+                return rag_qa_db_path
+            else:
+                print("rag_qa_db_path not found in Database section")
+                print(f"Available options: {config.options('Database')}")
         else:
-            print("rag_qa_db_path option not found in Database section")
-    else:
-        print("Database section not found")
-    
-    raise ValueError("Database path not found in config file")
+            print("Database section not found in config")
+            print(f"Available sections: {config.sections()}")
+        
+        raise ValueError("Database path not found in config file")
+        
+    except Exception as e:
+        print(f"Error in get_rag_qa_db_path: {str(e)}")
+        print(f"Error type: {type(e)}")
+        import traceback
+        print(f"Traceback: {traceback.format_exc()}")
+        raise
 
 def check_config_file():
     current_dir = os.getcwd()