From b2b9670a23dd6df1f9e8ce32558b9aec4689e55c Mon Sep 17 00:00:00 2001
From: ManishMadan2882 <manishmadan321@gmail.com>
Date: Tue, 9 Sep 2025 00:00:58 +0530
Subject: [PATCH] (feat:connectors) type as connector:file

---
 application/api/connector/routes.py | 2 +-
 application/worker.py               | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/application/api/connector/routes.py b/application/api/connector/routes.py
index 5b12d8c4..f1ba247b 100644
--- a/application/api/connector/routes.py
+++ b/application/api/connector/routes.py
@@ -173,7 +173,7 @@ class ConnectorSources(Resource):
             return make_response(jsonify({"success": False}), 401)
         user = decoded_token.get("sub")
         try:
-            sources = sources_collection.find({"user": user, "type": "connector"}).sort("date", -1)
+            sources = sources_collection.find({"user": user, "type": {"$regex": "^connector:"}}).sort("date", -1)
             connector_sources = []
             for source in sources:
                 connector_sources.append({
diff --git a/application/worker.py b/application/worker.py
index 10fb6c2b..5a29d00a 100755
--- a/application/worker.py
+++ b/application/worker.py
@@ -978,13 +978,13 @@ def ingest_connector(
                 "tokens": tokens,
                 "retriever": retriever,
                 "id": str(id),
-                "type": "connector",
+                "type": "connector:file",
                 "remote_data": json.dumps({
                     "provider": source_type,
                     **api_source_config
                 }),
                 "directory_structure": json.dumps(directory_structure),
-                "sync_frequency": sync_frequency 
+                "sync_frequency": sync_frequency
             }
 
             if operation_mode == "sync":