From f761eab1b481df73b9c8bcb53f1360df2e1f43f0 Mon Sep 17 00:00:00 2001
From: phact <estevezsebastian@gmail.com>
Date: Thu, 11 Sep 2025 11:58:35 -0400
Subject: [PATCH] upload dir should respect langflow flag

---
 src/api/upload.py | 32 ++++++++++++++++++++++++--------
 src/main.py       |  1 +
 2 files changed, 25 insertions(+), 8 deletions(-)

diff --git a/src/api/upload.py b/src/api/upload.py
index 373b2948..d845e978 100644
--- a/src/api/upload.py
+++ b/src/api/upload.py
@@ -45,7 +45,7 @@ async def upload(request: Request, document_service, session_manager):
             return JSONResponse({"error": error_msg}, status_code=500)
 
 
-async def upload_path(request: Request, task_service, session_manager):
+async def upload_path(request: Request, task_service, session_manager, langflow_file_service):
     """Upload all files from a directory path"""
     payload = await request.json()
     base_dir = payload.get("path")
@@ -74,13 +74,29 @@ async def upload_path(request: Request, task_service, session_manager):
         owner_name = user.name
         owner_email = user.email
 
-    task_id = await task_service.create_upload_task(
-        owner_user_id,
-        file_paths,
-        jwt_token=jwt_token,
-        owner_name=owner_name,
-        owner_email=owner_email,
-    )
+    from config.settings import DISABLE_INGEST_WITH_LANGFLOW
+    
+    # Use same logic as single file uploads - respect the Langflow setting
+    if DISABLE_INGEST_WITH_LANGFLOW:
+        # Use direct DocumentFileProcessor (no Langflow)
+        task_id = await task_service.create_upload_task(
+            owner_user_id,
+            file_paths,
+            jwt_token=jwt_token,
+            owner_name=owner_name,
+            owner_email=owner_email,
+        )
+    else:
+        # Use Langflow pipeline for processing
+        task_id = await task_service.create_langflow_upload_task(
+            user_id=owner_user_id,
+            file_paths=file_paths,
+            langflow_file_service=langflow_file_service,
+            session_manager=session_manager,
+            jwt_token=jwt_token,
+            owner_name=owner_name,
+            owner_email=owner_email,
+        )
 
     return JSONResponse(
         {"task_id": task_id, "total_files": len(file_paths), "status": "accepted"},
diff --git a/src/main.py b/src/main.py
index 1c0dc09f..a0f00268 100644
--- a/src/main.py
+++ b/src/main.py
@@ -558,6 +558,7 @@ async def create_app():
                     upload.upload_path,
                     task_service=services["task_service"],
                     session_manager=services["session_manager"],
+                    langflow_file_service=services["langflow_file_service"],
                 )
             ),
             methods=["POST"],