fix: implement robust neo4j driver fallback with verify_connectivity to prevent AuthError

AGENTS.md

@@ -79,8 +79,9 @@ def test_portfolio_showcase_aggregation_query():
     assert any(indicator in response.answer for indicator in ["1.", "TOP", "기사", "출처"]) # 일종의 skill
 ```
 
-## 자동 검사
+## 자동 검사 및 런타임 에러 방지
 - 로컬 개발 환경에서 커밋하기 전, 반드시 터미널에 `ruff check .` 및 `mypy src tests --ignore-missing-imports` 명령어를 직접 실행하여 린트 및 엄격한 타입 오류를 확실하게 확인하고 모두 고칠 것 (오류가 남아있는 상태로 커밋 금지).
+- **런타임 Auth/연결 에러 방지**: 린트/타입 검사 후 반드시 `python tests/smoke_test_rag.py`를 로컬에서 실행하여 `neo4j.exceptions.AuthError` 등의 런타임 에러가 터지지 않고 완벽히 RAG 결과가 출력되는지(DB 정상 접속) 현장 점검(Smoke Test) 후 푸시할 것.
 - 커밋 전 `pre-commit` 자동 실행
 - `ruff`, `mypy` 검사 통과 필수
 - 검사 실패 시 커밋 불가

app.py

@@ -22,6 +22,7 @@ dotenv.load_dotenv()
 # 1. LangGraph 챗봇 State 정의
 # ──────────────────────────────────────────
 
+
 class ChatState(TypedDict):
     question: str        # 사용자 질문
     history: List[dict]  # 대화 히스토리 [{"role": "user"/"assistant", "content": "..."}]

run_pipeline.py

@@ -59,5 +59,6 @@ def run_test():
     else:
         print("\n⏭️ AI 관련 기사가 아니므로 그래프 상세 분석 및 벡터 적재를 건너뜁니다.")
 
+
 if __name__ == "__main__":
     run_test()

src/graphBuilder/neo4j/finGraph.py

@@ -26,11 +26,28 @@ from neo4j_graphrag.llm import OpenAILLM
 
 dotenv.load_dotenv()
 
-URI = os.getenv("NEO4J_URI", "neo4j://localhost:7687")
-username = os.getenv("NEO4J_CLIENT_ID") or os.getenv("NEO4J_USERNAME") or "neo4j"
-password = os.getenv("NEO4J_CLIENT_SECRET") or os.getenv("NEO4J_PASSWORD") or "password"
-AUTH = (username, password)
-driver = neo4j.GraphDatabase.driver(URI, auth=AUTH)
+
+def get_neo4j_driver() -> neo4j.Driver:
+    uri = os.getenv("NEO4J_URI", "neo4j://localhost:7687")
+    client_id = os.getenv("NEO4J_CLIENT_ID")
+    client_secret = os.getenv("NEO4J_CLIENT_SECRET")
+    
+    if client_id and client_secret:
+        try:
+            d = neo4j.GraphDatabase.driver(uri, auth=(client_id, client_secret))
+            d.verify_connectivity()
+            return d
+        except Exception:
+            pass
+            
+    username = os.getenv("NEO4J_USERNAME", "neo4j")
+    password = os.getenv("NEO4J_PASSWORD", "password")
+    d = neo4j.GraphDatabase.driver(uri, auth=(username, password))
+    d.verify_connectivity()
+    return d
+
+
+driver = get_neo4j_driver()
 
 chat_llm = ChatOpenAI(model="gpt-4o-mini", temperature=0)
 rag_llm = OpenAILLM(model_name="gpt-4o", model_params={"temperature": 0})

src/retrieval/finRetrieval.py

@@ -30,11 +30,28 @@ dotenv.load_dotenv()
 # 1. DB / LLM / Embedder 초기화
 # ──────────────────────────────────────────
 
-URI = os.getenv("NEO4J_URI", "neo4j://localhost:7687")
-username = os.getenv("NEO4J_CLIENT_ID") or os.getenv("NEO4J_USERNAME") or "neo4j"
-password = os.getenv("NEO4J_CLIENT_SECRET") or os.getenv("NEO4J_PASSWORD") or "password"
-AUTH = (username, password)
-driver = neo4j.GraphDatabase.driver(URI, auth=AUTH)
+
+def get_neo4j_driver() -> neo4j.Driver:
+    uri = os.getenv("NEO4J_URI", "neo4j://localhost:7687")
+    client_id = os.getenv("NEO4J_CLIENT_ID")
+    client_secret = os.getenv("NEO4J_CLIENT_SECRET")
+    
+    if client_id and client_secret:
+        try:
+            d = neo4j.GraphDatabase.driver(uri, auth=(client_id, client_secret))
+            d.verify_connectivity()
+            return d
+        except Exception:
+            pass  # Fallback to Username/Password
+            
+    username = os.getenv("NEO4J_USERNAME", "neo4j")
+    password = os.getenv("NEO4J_PASSWORD", "password")
+    d = neo4j.GraphDatabase.driver(uri, auth=(username, password))
+    d.verify_connectivity()
+    return d
+
+
+driver = get_neo4j_driver()
 
 rag_llm = OpenAILLM(model_name="gpt-4o", model_params={"temperature": 0})
 embedder = OpenAIEmbeddings(model="text-embedding-3-small")
@@ -180,18 +197,21 @@ class HybridFallbackRetriever(Retriever):
             return self.fallback_retriever.search(query_text=query_text, **kwargs)
         return res
 
+
 # 하이브리드 검색 인스턴스 장착
 hybrid_retriever = HybridFallbackRetriever(
     tools_retriever=tools_retriever,
     fallback_retriever=vector_cypher_retriever,
 )
 
+
 class CustomRagTemplate(RagTemplate):
     EXPECTED_INPUTS = ["context", "query_text"]
 
     def format(self, query_text: str, context: str, examples: str = "") -> str:
         return self._format(query_text=query_text, context=context)
 
+
 _prompt_template = CustomRagTemplate(
     template="""당신은 AI 기술 트렌드 분석 전문가입니다.
 반드시 아래 제공된 [컨텍스트(Neo4j 지식 그래프 검색 결과)]에 기반해서만 답변하세요.

tests/smoke_test_rag.py

@@ -20,15 +20,28 @@ import dotenv
 
 dotenv.load_dotenv()
 
+
 # ── 0. 그래프 구성 사전 점검 (Neo4j 노드/관계 통계) ─────────────────────────
 def check_graph_structure():
     import neo4j
 
     uri = os.getenv("NEO4J_URI", "neo4j://localhost:7687")
-    username = os.getenv("NEO4J_CLIENT_ID") or os.getenv("NEO4J_USERNAME") or "neo4j"
-    password = os.getenv("NEO4J_CLIENT_SECRET") or os.getenv("NEO4J_PASSWORD") or "password"
-    auth = (username, password)
-    driver = neo4j.GraphDatabase.driver(uri, auth=auth)
+    client_id = os.getenv("NEO4J_CLIENT_ID")
+    client_secret = os.getenv("NEO4J_CLIENT_SECRET")
+    
+    driver = None
+    if client_id and client_secret:
+        try:
+            driver = neo4j.GraphDatabase.driver(uri, auth=(client_id, client_secret))
+            driver.verify_connectivity()
+        except Exception:
+            driver = None
+            
+    if not driver:
+        username = os.getenv("NEO4J_USERNAME", "neo4j")
+        password = os.getenv("NEO4J_PASSWORD", "password")
+        driver = neo4j.GraphDatabase.driver(uri, auth=(username, password))
+        driver.verify_connectivity()
 
     print("\n" + "=" * 60)
     print("📊 [사전 점검] Neo4j 그래프 구성 현황")

tests/test_retrieval.py

@@ -10,6 +10,7 @@ has_credentials = (
     os.getenv("NEO4J_URI") is not None
 )
 
+
 @pytest.mark.skipif(
     not has_credentials, 
     reason="OpenAI API Key 또는 Neo4j 연결 환경변수가 없으므로 통합 테스트를 건너뜁니다."