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

Functionfile_search

Search for a string or regex pattern across files in a directory.

src/app/shared/langchain_layer/agents/tools/shell.py:172

Methodfilter

Apply filtering to query.

src/app/utils/api_features.py:19

Functionfinal_report_generation

Generate the final research report from compressed findings.

src/app/shared/langgraph_layer/open_deep_search/graph.py:472

Functionfinalization_node

(state: LegalAgentState)

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

Functionforgot_password

( body: ForgotPasswordRequest, service: AuthServiceDep, )

src/app/features/auth/router.py:199

Functiongateway_node

(state: LegalAgentState)

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

Functiongather_node_text

Extract clean text from selected nodes for LangGraph workflows.

src/app/shared/rag/pageindex/functions.py:223

Methodgenerate_presigned_upload_urls

( self, *, files: Sequence[UploadRequest] = (), destination: str = "uploads",

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

Methodgenerate_presigned_url

( self, operation: str, params: dict[str, Any], expires_in: int )

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

Functiongenerate_text

( cb_service: Annotated[CircuitBreakerService, Depends(get_circuit_breaker)], )

src/app/api/generation_with_cb.py:20

Functiongenerator_node

(state: RetrievalState)

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

Methodget

Return a cached tool result when a prior execution exists.

src/app/shared/langchain_layer/agents/tools/idempotency.py:76

Functionget_activity_endpoint

Get user's recent activity. Endpoint example: GET /api/v1/users/123/activity?limit=10 Behavior: - Returns user's recent activities f

src/app/examples/redis_examples.py:303

Functionget_agent_saul_deps

( graph: Annotated[CompiledStateGraph, Depends(get_saul_graph)], checkpointer: Annotated[AsyncPostgres

src/app/features/agent_saul/dependencies.py:86

Functionget_agent_saul_ws_security_context

( websocket: WebSocket, claims: WebSocketClaims, token_repo: Annotated[RefreshTokenRepository, Dep

src/app/features/agent_saul/dependencies.py:94

Functionget_all_tools

Get all web search and crawl tools.

src/app/shared/langchain_layer/agents/tools/registry.py:51

Functionget_auth_service

( user_repo: Annotated[UserRepository, Depends(get_user_repository)], token_repo: Annotated[RefreshTok

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

Functionget_bloom_filter_info

Get Bloom filter info (BF.INFO). Args: redis: Redis client instance filter_name: Name of the filter Returns: Diction

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

Functionget_by_uri

(storage: StorageService, *, uri: str)

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

Methodget_by_uri

(self, *, uri: str)

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

Functionget_chunk_summary

Get a summary of a chunk.

src/app/shared/crawler/chunker.py:110

Functionget_circuit_breaker

(request: Request)

src/app/api/generation_with_cb.py:15

Methodget_connection

(self)

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

Functionget_context

Build a plain-text context block from Tavily results. Args: query: The search query max_results: Maximum number of results to inc

src/app/shared/services/tavily.py:216

Functionget_crawl4ai_crawler

Dependency to inject Crawl4AI crawler from lifespan.

src/app/connections/crawl4ai.py:44

Methodget_crawl_tool

Get the crawl URL tool.

src/app/shared/langchain_layer/agents/tools/registry.py:35

Functionget_crawler_service

Get crawler service instance with Redis from app.state.

src/app/features/crawler/dependencies.py:14

Functionget_current_active_user

( user: Annotated[User, Depends(get_current_user)], )

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

Functionget_current_user

Full user hydration from MongoDB. Use when the handler needs live user state.

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

Functionget_current_user_id

(request: Request)

src/app/features/documents/dependencies.py:58

Functionget_current_user_id

Stub — replace with your project's JWT/session auth dependency. The user_id is injected into LegalAgentState.user_id and used as the Lang

src/app/features/agent_saul/dependencies.py:53

Functionget_current_user_id

(request: Request)

src/app/features/search/dependencies.py:44

Functionget_current_user_id

(request: Request)

src/app/features/ingestion/dependencies.py:11

Functionget_current_verified_user

( user: Annotated[User, Depends(get_current_active_user)], )

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

Methodget_document_by_id

( self, *, user_id: str, document_id: str, )

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

Functionget_document_command_service

( repo: Annotated[DocumentRepository, Depends(get_document_repository)], request: Request, )

src/app/features/documents/dependencies.py:33

Functionget_document_query_service

( repo: Annotated[DocumentRepository, Depends(get_document_repository)], redis: Annotated[Redis, Depen

src/app/features/documents/dependencies.py:45

Functionget_document_repository

( session: Annotated[AsyncSession, Depends(get_postgres_db)], )

src/app/features/documents/dependencies.py:19

Functionget_document_status

( doc_id: Annotated[str, Path(min_length=1)], service: documents_dependencies.DocumentCommandServiceDe

src/app/features/documents/router.py:50

Functionget_domain_from_url

Extract domain from URL.

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

Functionget_embedding_dimension

Get the dimension of embeddings for this model. Args: model: Embedding model Returns: Embedding dimension

src/app/shared/rag/document_processing/embedder.py:281

Functionget_hash

Retrieve a hash from Redis. Args: redis: Redis client instance object_type: Entity type for namespacing key: Hash key ide

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

Functionget_health

( response: Response, service: Annotated[HealthService, Depends(get_health_service)], )

src/app/features/health/router.py:34

Functionget_health_celery_app

(request: Request)

src/app/features/health/dependencies.py:31

Functionget_health_mongodb_client

(request: Request)

src/app/features/health/dependencies.py:13

Functionget_health_neo4j_driver

(request: Request)

src/app/features/health/dependencies.py:27

Functionget_health_postgres_session_factory

( request: Request, )

src/app/features/health/dependencies.py:21

Functionget_health_redis_client

(request: Request)

src/app/features/health/dependencies.py:17

Functionget_health_service

( mongo_client: AsyncIOMotorClient | None = Depends(get_health_mongodb_client), redis_client: Redis |

src/app/features/health/dependencies.py:35

Functionget_httpx_client

Dependency to inject HTTPX client.

src/app/connections/httpx_client.py:65

Functionget_idempotency_status

( redis_client: RedisClientProtocol, idempotency_key: str, *, namespace: str = IDEMPOTENCY_NAM

src/app/connections/celery_reliability.py:176

Functionget_ingest_status

( task_id: Annotated[str, Path(min_length=1)], service: SearchServiceDep, )

src/app/features/search/router.py:42

Functionget_ingestion_graph

(request: Request)

src/app/features/ingestion/dependencies.py:7

Methodget_key

(self, namespace: str, key: str)

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

Functionget_list_length

Get the length of a Redis list. Args: redis: Redis client instance object_type: Entity type for namespacing key: List key

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

Functionget_mcp_client_manager_dep

Dependency to inject MCP client manager from lifespan.

src/mcp_core/mcp.py:26

Functionget_me

(user: CurrentVerifiedUser)

src/app/features/auth/router.py:304

Functionget_multiple_users

Get multiple users efficiently. Query example: GET /api/v1/users/batch/users?user_ids=1&user_ids=2&user_ids=3 Behavior: - Fetches al

src/app/examples/redis_examples.py:334

Functionget_neo4j_driver

(connection: HTTPConnection)

src/app/connections/neo4j.py:47

Functionget_neo4j_session

Context manager for Neo4j sessions. Args: driver: Neo4j async driver instance database: Optional database name (defaults to confi

src/app/connections/neo4j.py:52

Functionget_object

(storage: StorageService, *, key: str)

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

Methodget_object

(self, *, key: str)

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

Functionget_obligation_chain

Trace obligations and consequences connected to a named entity. Use this when the agent needs forward-chained legal consequences such

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

Functionget_obligation_chain

Forward-chain obligations from a named entity. Example: given "Acme Corp", returns: Acme Corp → INDEMNIFIES → GlobalTech Ltd Acme Cor

src/app/shared/rag/graphiti/client.py:459

Functionget_obligation_chain

Find and expand obligation chain for a named entity. Args: config: Neo4j subgraph configuration with driver. entity_name: Entity

src/app/shared/rag/graphiti/subgraph.py:178

Functionget_postgres_db

Dependency for database sessions retrieved from app.state.

src/app/connections/postgres.py:124

Functionget_profile

(user: CurrentVerifiedUser)

src/app/features/profile/router.py:36

Functionget_rate_limit_info

Get current rate limit information.

src/app/features/crawler/router.py:109

Functionget_rate_limiter

Build a FastAPI dependency that enforces a Redis-backed rate limit. Args: burst: Maximum burst capacity before requests are throttle

src/app/utils/rate_limit/dependencies.py:8

Functionget_redis

(request: Request)

src/app/features/agent_saul/dependencies.py:49

Functionget_redis

()

src/mcp_core/server/middleware.py:143

Functionget_research_agent

()

src/app/shared/langchain_layer/agents/registry.py:85

Functionget_saul_checkpointer

(request: Request)

src/app/features/agent_saul/dependencies.py:41

Functionget_saul_graph

(request: Request)

src/app/features/agent_saul/dependencies.py:37

Functionget_schema_for_type

Get predefined schema for a type.

src/app/shared/crawler/processor.py:267

Functionget_search_repository

( session: Annotated[AsyncSession, Depends(get_postgres_db)], )

src/app/features/search/dependencies.py:17

Functionget_search_service

( repo: Annotated[SearchRepository, Depends(get_search_repository)], redis: Annotated[Redis, Depends(g

src/app/features/search/dependencies.py:31

Methodget_search_tool

Get the web search tool.

src/app/shared/langchain_layer/agents/tools/registry.py:31

Functionget_self

( request: Request, service: Annotated[HealthService, Depends(get_health_service)], )

src/app/features/health/router.py:17

Functionget_server_metadata

()

src/mcp_core/server/tools.py:221

Functionget_shared_mcp_client_manager

Return a process-wide MCP client manager for non-request runtimes.

src/mcp_core/mcp.py:15

Functionget_signed_get_url

(storage: StorageService, *, key: str, expires_in: int = 900)

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

Functionget_signed_put_url

( storage: StorageService, *, key: str, content_type: str, expires_in: int = 900 )

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

Methodget_state

Get current checkpoint state for a thread.

src/app/shared/langchain_layer/agents/factory.py:329

Methodget_state_history

Get full checkpoint history for time-travel debugging.

src/app/shared/langchain_layer/agents/factory.py:334

Functionget_stored_mcp_tokens

(config: RunnableConfig)

src/mcp_core/client/auth.py:62

Functionget_tavily_http_client

Dependency to inject Tavily HTTP client from request lifespan.

src/app/connections/tavily.py:37

Functionget_token_claims

Decode and validate JWT claims. Zero database round trips.

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

Methodget_tool

Get a specific tool by name.

src/app/shared/langchain_layer/agents/tools/registry.py:24

Methodget_tool_adapter

(self, server_name: str, tool_name: str)

src/mcp_core/client/manager.py:163

Methodget_tree

(self, doc_id: str, node_summary: bool = True)

src/app/shared/rag/pageindex/client.py:87

Functionget_user

( user_id: Annotated[str, Path()], service: UserAdminServiceDep, )

src/app/features/users/router.py:49

Functionget_user_admin_repository

()

src/app/features/users/dependencies.py:11

Functionget_user_admin_service

( user_repo: Annotated[UserAdminRepository, Depends(get_user_admin_repository)], token_repo: Annotated

src/app/features/users/dependencies.py:15

Functionget_user_endpoint

Get user profile with Redis caching. Endpoint example: GET /api/v1/users/123 Behavior: - First request: fetches from DB, caches for

src/app/examples/redis_examples.py:193

Functionget_web_tools

Get all web-related tools for agents.

src/app/shared/langchain_layer/agents/tools/registry.py:56

Functionget_websocket_security_service

(websocket: WebSocket)

src/app/features/agent_saul/dependencies.py:63

Functionget_websocket_token_claims

Decode access-token claims during WebSocket handshake.

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

Functionglobal_exception_handler

(request: Request, exc: Exception)

src/app/middleware/global_exception_handler.py:22

Functiongraph_retrieval_node

(state: RetrievalState)

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

← previous next →1,001–1,100 of 1,424, ranked by callers