Functions — github.com/Harmeet10000/AgentNexus-LangChain-FastAPI

hub / github.com/Harmeet10000/AgentNexus-LangChain-FastAPI / functions

Functions1,424 in github.com/Harmeet10000/AgentNexus-LangChain-FastAPI

⨍ Functions 1,424◇ Types & classes 479↳ Endpoints 62

↓ 1 callersMethodget_user

(self, user_id: str)

src/app/features/users/service.py:78

↓ 1 callersFunctionget_user_activity

Get user's recent activities.

src/app/examples/redis_examples.py:168

↓ 1 callersFunctionget_user_repository

( db=Depends(get_mongodb), )

src/app/features/auth/dependencies.py:25

↓ 1 callersMethodget_user_sessions

(self, user_id: str)

src/app/features/auth/repository.py:334

↓ 1 callersMethodhard_delete

( self, user_id: str, requesting_admin_id: str, )

src/app/features/users/service.py:125

↓ 1 callersFunctionheadingLevel

(style string)

src/lynk/internal/adapters/docx/reader.go:235

↓ 1 callersMethodimpersonate

( self, target_user_id: str, admin_user_id: str, )

src/app/features/users/service.py:142

↓ 1 callersFunctioninferTitle

(doc *model.Document)

src/lynk/internal/adapters/docx/reader.go:226

↓ 1 callersMethodingest_document

( self, raw_bytes: bytes, user_id: str, filename: str, source: str,

src/app/features/ingestion/service.py:30

↓ 1 callersFunctioningest_documents

Ingest all documents from the documents folder. Args: config: Ingestion configuration documents_folder: Folder containing ma

src/app/shared/rag/document_processing/ingest_v2.py:290

↓ 1 callersMethodingest_documents

Ingest all documents from the documents folder. Args: progress_callback: Optional callback for progress updates

src/app/shared/rag/document_processing/ingest.py:77

↓ 1 callersFunctioninit_neo4j

Initialize Neo4j driver and test connection. Returns: AsyncDriver: Configured Neo4j driver for app.state injection Raises: E

src/app/connections/neo4j.py:15

↓ 1 callersMethodinitialize

(self)

src/app/utils/cache/redis_protocol_adapter.py:15

↓ 1 callersMethodinitialize

Initialize database connections.

src/app/shared/rag/document_processing/ingest.py:58

↓ 1 callersFunctioninitialize_fastapi_guard

Attach app-managed resources to FastAPI Guard after lifespan startup.

src/app/middleware/server_middleware.py:148

↓ 1 callersFunctioninitialize_reranker

()

src/app/shared/rag/rag_agent_advanced.py:41

↓ 1 callersFunctioninvalidate_user_cache

Invalidate user cache (use when user deleted or cache expires).

src/app/examples/redis_examples.py:142

↓ 1 callersFunctionisSectionHeading

(paragraph model.Paragraph)

src/lynk/internal/adapters/docx/reader.go:249

↓ 1 callersFunctionis_private_ip

Check if an IP address is private.

src/app/shared/crawler/validator.py:46

↓ 1 callersFunctionis_valid_url

Quick check if URL is valid and allowed.

src/app/shared/crawler/validator.py:119

↓ 1 callersMethodlegal_rrf_search

( self, *, user_id: str, query_text: str, query_embedding: list[float]

src/app/features/documents/repository.py:472

↓ 1 callersMethodlegal_rrf_search

Run weighted in-database RRF over canonical clauses.

src/app/features/search/repository.py:299

↓ 1 callersMethodlist_multipart_upload_parts

( self, *, key: str, upload_id: str, )

src/app/shared/services/storage.py:529

↓ 1 callersMethodlist_objects

( self, *, prefix: str = "", max_keys: int = 1000, )

src/app/shared/services/storage.py:372

↓ 1 callersMethodlist_tools

(self)

src/mcp_core/testing.py:40

↓ 1 callersMethodlist_users

( self, page: int, per_page: int, role: UserRole | None = None, is_act

src/app/features/users/service.py:54

↓ 1 callersFunctionload_mcp_client_server_configs

()

src/mcp_core/client/settings.py:12

↓ 1 callersFunctionmain

()

src/app/server.py:12

↓ 1 callersFunctionmain

Main entry point.

src/app/shared/rag/rag_agent_advanced.py:554

↓ 1 callersFunctionmain

Main function for running ingestion.

src/app/shared/rag/document_processing/ingest.py:467

↓ 1 callersFunctionmake_apply_changes_node

( db_engine: AsyncEngine, )

src/app/shared/langgraph_layer/reconciliation/nodes.py:202

↓ 1 callersFunctionmake_classify_extract_node

( extraction_llm: StructuredRunnable, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:254

↓ 1 callersFunctionmake_compliance_node

(compliance_agent: Any)

src/app/shared/langgraph_layer/agent_saul/nodes.py:604

↓ 1 callersFunctionmake_context_grader_node

( grader_llm: Any, )

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:212

↓ 1 callersFunctionmake_contextualize_chunk_node

( contextualize_llm: StructuredRunnable, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:210

↓ 1 callersFunctionmake_deep_research_node

( deep_research_tool: BaseTool, )

src/app/shared/langgraph_layer/agent_saul/nodes.py:827

↓ 1 callersFunctionmake_embed_store_node

( db_engine: AsyncEngine, embedding_fn: EmbeddingFunction, redis: Redis | None = None, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:297

↓ 1 callersFunctionmake_entity_extraction_node

( entity_llm: Runnable[list[Any], EntityExtractionOutput], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:491

↓ 1 callersFunctionmake_extract_schema_node

( schema_llm: StructuredRunnable, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:109

↓ 1 callersFunctionmake_fetch_existing_node

( db_engine: AsyncEngine, )

src/app/shared/langgraph_layer/reconciliation/nodes.py:61

↓ 1 callersFunctionmake_finalization_node

( finalization_llm: Runnable[list[Any], FinalReport], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:733

↓ 1 callersFunctionmake_gateway_node

()

src/app/shared/langgraph_layer/agent_saul/nodes.py:106

↓ 1 callersFunctionmake_generator_node

( generator_llm: Any, redis: Redis | None, )

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:249

↓ 1 callersFunctionmake_get_obligation_chain_tool

Create the obligation-chain LangChain tool.

src/app/shared/langchain_layer/agents/tools/get_obligation_chain.py:39

↓ 1 callersFunctionmake_graph_retrieval_node

( graphiti: Any, )

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:136

↓ 1 callersFunctionmake_graphiti_upsert_node

( graphiti: Any, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:348

↓ 1 callersFunctionmake_grounding_verification_node

( grounding_llm: Runnable[list[Any], GroundingVerificationOutput], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:643

↓ 1 callersFunctionmake_human_review_node

()

src/app/shared/langgraph_layer/agent_saul/nodes.py:672

↓ 1 callersFunctionmake_hybrid_retrieval_node

( repo: SearchRepository, embedding_fn: EmbeddingFunction, redis: Redis | None, )

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:167

↓ 1 callersFunctionmake_ingestion_node

()

src/app/shared/langgraph_layer/agent_saul/nodes.py:324

↓ 1 callersFunctionmake_normalization_node

( normalization_llm: Runnable[list[Any], NormalizedDocument], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:390

↓ 1 callersFunctionmake_orchestrator_node

( orchestrator_llm: Runnable[list[Any], OrchestratorAction], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:197

↓ 1 callersFunctionmake_parse_document_node

()

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:89

↓ 1 callersFunctionmake_persist_memory_node

(_cognee_client: Any)

src/app/shared/langgraph_layer/agent_saul/nodes.py:772

↓ 1 callersFunctionmake_planner_node

(planner_llm: Runnable[list[Any], PlannerOutput])

src/app/shared/langgraph_layer/agent_saul/nodes.py:267

↓ 1 callersFunctionmake_qna_node

(qna_llm: Runnable[list[Any], QnAOutput])

src/app/shared/langgraph_layer/agent_saul/nodes.py:146

↓ 1 callersFunctionmake_query_analyzer_node

( query_llm: Any, redis: Redis | None, )

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:89

↓ 1 callersFunctionmake_query_knowledge_graph_tool

( graphiti_service: GraphitiService, idempotency: IdempotencyGuard, )

src/app/shared/langchain_layer/agents/tools/query_knowledge_graph.py:34

↓ 1 callersFunctionmake_reconcile_node

( reconcile_llm: ReconciliationRunnable, )

src/app/shared/langgraph_layer/reconciliation/nodes.py:133

↓ 1 callersFunctionmake_relationship_mapping_node

( relationship_llm: Runnable[list[Any], RelationshipMappingOutput], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:519

↓ 1 callersFunctionmake_reranker_node

( reranker: CrossEncoderReranker | None = None, )

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:196

↓ 1 callersFunctionmake_retrieve_statute_section_tool

( db_engine: AsyncEngine, idempotency: IdempotencyGuard, )

src/app/shared/langchain_layer/agents/tools/retrieve_statute_section.py:36

↓ 1 callersFunctionmake_risk_analysis_node

(risk_agent: Any)

src/app/shared/langgraph_layer/agent_saul/nodes.py:547

↓ 1 callersFunctionmake_search_legal_precedents_tool

Factory: returns @tool with injected infra via closure. Call once at lifespan startup. Store result in ToolRegistry.

src/app/shared/langchain_layer/agents/tools/search_legal_precedents.py:44

↓ 1 callersFunctionmake_segment_document_node

( segmentation_llm: StructuredRunnable, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:149

↓ 1 callersFunctionmake_segmentation_node

( segmentation_llm: Runnable[list[Any], ClauseSegmentationOutput], )

src/app/shared/langgraph_layer/agent_saul/nodes.py:424

↓ 1 callersFunctionmake_write_versions_node

( db_engine: AsyncEngine, )

src/app/shared/langgraph_layer/reconciliation/nodes.py:270

↓ 1 callersFunctionmark_idempotency_completed

( redis_client: RedisClientProtocol, idempotency_key: str, *, task_id: str | None = None,

src/app/connections/celery_reliability.py:122

↓ 1 callersFunctionmark_idempotency_failed_permanently

( redis_client: RedisClientProtocol, idempotency_key: str, *, task_id: str | None = None,

src/app/connections/celery_reliability.py:144

↓ 1 callersFunctionneeds_rehash

True when stored hash was created with weaker argon2 params than current config.

src/app/features/auth/security.py:47

↓ 1 callersMethodoauth_callback

( self, provider: str, code: str, state: str, signed_state: str,

src/app/features/auth/service.py:330

↓ 1 callersMethodoauth_get_authorization_url

Return (authorization_url, signed_state_for_cookie).

src/app/features/auth/service.py:314

↓ 1 callersMethodobject_exists

(self, *, key: str)

src/app/shared/services/storage.py:352

↓ 1 callersFunctionparse_document

(*, raw_bytes: bytes, filename: str, content_type: str)

src/app/features/documents/parser.py:15

↓ 1 callersFunctionpreprocess_legal_document

Async wrapper around Docling (CPU-heavy).

src/app/shared/rag/langextract/docling_preprocessor.py:39

↓ 1 callersFunctionprocess_document_full

Full document processing pipeline.

src/app/shared/rag/document_processing/todo_temp.py:221

↓ 1 callersFunctionprocess_with_semaphore

(source: str, idx: int)

src/app/shared/rag/document_processing/docling_enhanced.py:403

↓ 1 callersMethodprotect

Wrap a fragile downstream call with a Redis-backed circuit breaker.

src/app/shared/circuit_breaker/service.py:58

↓ 1 callersFunctionpush_to_list

Push value(s) to a Redis list. Args: redis: Redis client instance object_type: Entity type for namespacing key: List key

src/app/utils/cache/redis_func.py:543

↓ 1 callersMethodrag

( self, *, user_id: str, payload: documents_dto.UnifiedRagRequest )

src/app/features/documents/service.py:306

↓ 1 callersMethodrag_search

Return ranked hits plus ordered context sections for RAG use.

src/app/features/search/service.py:206

↓ 1 callersFunctionread_document

Read document content from file - supports multiple formats via Docling. Returns: Tuple of (markdown_content, docling_document)

src/app/shared/rag/document_processing/ingest_v2.py:96

↓ 1 callersMethodregister_connection

(self, context: WebSocketSecurityContext)

src/app/features/auth/websocket_security.py:174

↓ 1 callersFunctionregister_prompts

(server: Any)

src/mcp_core/server/prompts.py:11

↓ 1 callersFunctionregister_resources

(server: Any)

src/mcp_core/server/resources.py:98

↓ 1 callersFunctionrelease_idempotency_processing_lock

Release the processing lock so a later retry can acquire it again.

src/app/connections/celery_reliability.py:166

↓ 1 callersFunctionremove_up_to_last_ai_message

Truncate message history up to the last AI message.

src/app/shared/langgraph_layer/open_deep_search/utils.py:299

↓ 1 callersFunctionreplay

(limit: int = 50)

scripts/replay_outbox.py:36

↓ 1 callersFunctionrequire_role

Dependency factory. Validates role from JWT claims without a DB round trip. Usage: Depends(require_role(UserRole.ADMIN, UserRole.MODERATOR))

src/app/features/auth/dependencies.py:162

↓ 1 callersMethodresend_verification

(self, email: str)

src/app/features/auth/service.py:224

↓ 1 callersFunctionrun_async_migrations

Run migrations in async mode using init_db() to get the engine.

src/alembic/env.py:76

↓ 1 callersFunctionrun_cli

Run the agent in an interactive CLI with streaming.

src/app/shared/rag/rag_agent_advanced.py:504

↓ 1 callersFunctionrun_document_ingestion_task

( *, document_id: str, user_id: str, filename: str, content_type: str, object_uri: str

src/app/features/documents/service.py:569

↓ 1 callersFunctionrun_ingestion_task

Create a task-local async DB session and execute search ingestion.

src/app/features/search/service.py:344

↓ 1 callersFunctionrun_legal_extraction_batch

Batch processor: Docling → LangExtract with proper grounding.

src/app/shared/rag/langextract/langextract_batch_processor.py:41

↓ 1 callersMethodrun_listener

Long-running listen loop. Subscribe to outbox_channel, handle notifications.

src/app/shared/outbox/relay.py:64

↓ 1 callersFunctionrun_mcp_server

( *, transport: MCPTransport | None = None, host: str | None = None, port: int | None = None,

src/mcp_core/server/http.py:41

↓ 1 callersFunctionrun_migrations_offline

Run migrations in 'offline' mode. This is used for generating migration scripts without connecting to the database.

src/alembic/env.py:34

↓ 1 callersFunctionrun_migrations_online

Run migrations in 'online' mode. This connects to the database and applies pending migrations.

src/alembic/env.py:98

↓ 1 callersMethodrun_session

Main session loop. Runs until graph completes or WS closes.

src/app/features/agent_saul/service.py:111

← previous next →601–700 of 1,424, ranked by callers