(feat:connectors) type as connector:file

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({

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":