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 callersFunctionbuild_chunk_rows

Create row payloads for repository upsert calls.

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

↓ 1 callersMethodbuild_context

( self, *, claims: TokenClaims, origin: str | None, connection_id: str )

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

↓ 1 callersFunctionbuild_default_middleware_stack

Production-ready default middleware stack. Order matters — middleware runs in list order for before_model, and reverse order for after_m

src/app/shared/langchain_layer/agents/middlewares/guardrails.py:299

↓ 1 callersFunctionbuild_document_ingestion_graph

Build the per-job ingestion graph.

src/app/features/documents/ingestion_graph.py:37

↓ 1 callersFunctionbuild_fastapi_guard_config

Create the FastAPI Guard configuration used by the main app.

src/app/middleware/server_middleware.py:164

↓ 1 callersFunctionbuild_mcp_http_middleware

(parent_app: Any | None)

src/mcp_core/server/middleware.py:140

↓ 1 callersFunctionbuild_retrieval_graph

Build a request-scoped retrieval graph over clauses.

src/app/shared/langgraph_layer/retrieval_kb/graph.py:28

↓ 1 callersFunctionbuild_search_filter_params

(*, metadata_filter: dict[str, Any])

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

↓ 1 callersFunctionbuild_validation_error_handler

Create a stable validation error formatter bound to a specific schema.

src/app/shared/langchain_layer/agents/tools/base.py:118

↓ 1 callersFunctionbuild_websocket_security_service

( redis: Redis, settings: Settings, )

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

↓ 1 callersMethodchange_password

( self, user: User, current_password: str, new_password: str, current_

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

↓ 1 callersFunctionchunk_document

Chunk a document using Docling's HybridChunker or fallback. Args: content: Document content (markdown format) title: Documen

src/app/shared/rag/document_processing/chunker.py:38

↓ 1 callersFunctionclassify_document

(*, markdown: str, filename: str)

src/app/features/documents/classification.py:60

↓ 1 callersFunctionclose_crawl4ai_crawler

Close the Crawl4AI browser during lifespan shutdown.

src/app/connections/crawl4ai.py:37

↓ 1 callersFunctionclose_db

()

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

↓ 1 callersFunctionclose_neo4j_driver

Close Neo4j driver and cleanup connections. Args: driver: Neo4j async driver instance

src/app/connections/neo4j.py:78

↓ 1 callersFunctionclose_tavily_http_client

Close the Tavily HTTP client during lifespan shutdown.

src/app/connections/tavily.py:47

↓ 1 callersMethodclose_with_violation

( self, websocket: WebSocket, context: WebSocketSecurityContext, violation: We

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

↓ 1 callersFunctionconfigure_langsmith

Bootstrap LangSmith tracing by setting env vars. Call this at application startup, before any agents are built.

src/app/shared/langchain_layer/callback.py:21

↓ 1 callersMethodconfigured_server_names

(self)

src/mcp_core/client/manager.py:45

↓ 1 callersFunctioncontract_event_dates

(metadata: LegalMetadataExtraction)

src/app/features/documents/legal_metadata.py:119

↓ 1 callersMethodcrawl

Crawl a URL or URLs based on request. Args: request: Crawl request parameters Returns: CrawlRespons

src/app/features/crawler/service.py:88

↓ 1 callersMethodcrawl

Crawl a single URL.

src/app/shared/crawler/crawler.py:185

↓ 1 callersMethodcrawl_recursive

Recursively crawl internal links using native BFS deep crawl strategy.

src/app/shared/crawler/crawler.py:251

↓ 1 callersFunctioncreate_app

Create and configure FastAPI application with proper middleware order.

src/app/main.py:43

↓ 1 callersFunctioncreate_celery_app

Create and configure Celery application.

src/app/connections/celery.py:181

↓ 1 callersFunctioncreate_crawl4ai_crawler

Create and start a Crawl4AI browser for lifespan management. Uses full CrawlerConfig for consistent BrowserConfig across all paths. Raises:

src/app/connections/crawl4ai.py:20

↓ 1 callersMethodcreate_document

( self, *, user_id: str, title: str, source_uri: str | None, o

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

↓ 1 callersMethodcreate_document

( self, *, title: str, source_uri: str | None, content_hash: str,

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

↓ 1 callersFunctioncreate_extractor

Factory function to create entity extractor. Args: use_graphiti: Whether to use Graphiti (requires Neo4j) neo4j_config: Neo4

src/app/shared/rag/document_processing/entity_extractor.py:346

↓ 1 callersFunctioncreate_httpx_client

Create production-grade HTTPX client with HTTP/2 and connection pooling. Key optimizations: - HTTP/2 multiplexing (multiple requests ove

src/app/connections/httpx_client.py:15

↓ 1 callersFunctioncreate_impersonation_token

Short-lived access token embedding who impersonated whom. No refresh token is issued. No session is stored in Redis. The 15-minute TTL IS the

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

↓ 1 callersFunctioncreate_mongo_client

Initialize database connection using Beanie's recommended approach.

src/app/connections/mongodb.py:8

↓ 1 callersFunctioncreate_node_map

Flatten tree for fast node lookup by node_id.

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

↓ 1 callersFunctioncreate_production_agent

Build a fully configured production agent from a spec. Returns a ProductionAgent with async invoke, stream, and batch methods.

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

↓ 1 callersFunctioncreate_refresh_token

Return (encoded_jwt, expires_in_seconds). session_id is stored as jti.

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

↓ 1 callersFunctioncreate_tavily_http_client

Create Tavily HTTP client for FastAPI lifespan management.

src/app/connections/tavily.py:42

↓ 1 callersFunctiondb_create_payment

(user_id: int, amount: float, currency: str)

src/app/examples/logger_usage_example.py:7

↓ 1 callersMethoddelete_by_uri

(self, *, uri: str)

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

↓ 1 callersFunctiondelete_cache

Delete a cached value. Args: redis: Redis client instance object_type: Entity type for namespacing key: Cache key identif

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

↓ 1 callersFunctiondelete_list

Delete an entire Redis list. Args: redis: Redis client instance object_type: Entity type for namespacing key: List key id

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

↓ 1 callersMethoddelete_object

(self, *, key: str)

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

↓ 1 callersFunctiondelete_tool_messages

Strip all ToolMessages and their paired AI tool-call messages.

src/app/shared/langchain_layer/messages.py:88

↓ 1 callersMethodemail_exists

(self, email: str)

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

↓ 1 callersFunctionembed_chunks

Generate embeddings for document chunks. Args: chunks: List of document chunks model: Embedding model to use batch_s

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

↓ 1 callersFunctionenrich_legal_chunks

( *, chunks: list[PreparedChunk], classified: ClassifiedDocument, metadata: LegalMetadataExtra

src/app/features/documents/legal_metadata.py:89

↓ 1 callersMethodensure_connection_capacity

(self, user_id: str)

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

↓ 1 callersMethodensure_origin_allowed

(self, origin: str | None)

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

↓ 1 callersFunctionexpand_from_seeds

Expand from seed node UUIDs to depth-N subgraph. Args: config: Neo4j subgraph configuration with driver. seed_uuids: Root nodes t

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

↓ 1 callersFunctionexpand_query_variations

Generate multiple variations of a query for better retrieval. Args: query: Original search query Returns: List of query

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

↓ 1 callersFunctionextract_code_blocks

Extract code blocks with language detection.

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

↓ 1 callersFunctionextract_document_metadata

Extract metadata from document content.

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

↓ 1 callersFunctionextract_entities

Extract entities and relationships.

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

↓ 1 callersFunctionextract_entities_simple

Extract entities using lightweight pattern matching. Args: text: Text to extract from document_id: Source document identifie

src/app/shared/rag/document_processing/entity_extractor.py:264

↓ 1 callersFunctionextract_headers

Extract headers from a chunk for context.

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

↓ 1 callersFunctionextract_images

Extract images from document.

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

↓ 1 callersFunctionextract_legal_metadata

( *, llm: object, markdown: str, classified: ClassifiedDocument, )

src/app/features/documents/legal_metadata.py:38

↓ 1 callersFunctionextract_raw_token_from_connection

Read a bearer token from an HTTP or WebSocket connection.

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

↓ 1 callersFunctionextract_tables

Extract tables from document.

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

↓ 1 callersFunctionextract_title

Extract title from document content or filename.

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

↓ 1 callersMethodfetch_chunks_by_ids

(self, chunk_ids: Sequence[str])

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

↓ 1 callersMethodfetch_chunks_by_ids

( self, chunk_ids: Sequence[str], )

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

↓ 1 callersFunctionfetch_oauth_userinfo

Exchange authorization code for token, then fetch and normalize userinfo.

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

↓ 1 callersMethodfetch_status

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

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

↓ 1 callersMethodfind_by_id

(self, user_id: str)

src/app/features/users/repository.py:18

↓ 1 callersMethodfind_by_reset_token_hash

( self, token_hash: str, )

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

↓ 1 callersMethodfind_by_verification_token_hash

( self, token_hash: str, )

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

↓ 1 callersFunctionfind_document_files

Find all supported document files in the documents folder.

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

↓ 1 callersMethodfind_or_create_oauth_user

( self, email: str, provider: str, provider_user_id: str, provider_ema

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

↓ 1 callersFunctionformat_tool_validation_error

Return a schema-first validation error message the model can retry against.

src/app/shared/langchain_layer/agents/tools/base.py:105

↓ 1 callersMethodfrom_boto_client

(cls, *, bucket: str, client: S3Client)

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

↓ 1 callersFunctionfrom_json

(data: str | bytes)

src/app/utils/json_serializer.py:36

↓ 1 callersFunctionfrom_json_float_list

(data: str | bytes)

src/app/utils/json_serializer.py:40

↓ 1 callersFunctiongenerate_embeddings_batch

Generate embeddings for a batch of texts. Args: texts: List of texts to embed model: Embedding model to use max_retr

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

↓ 1 callersMethodget_active_connection_count

(self, user_id: str)

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

↓ 1 callersMethodget_by_uri

(self, *, uri: str)

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

↓ 1 callersFunctionget_cache

Retrieve a cached value. Args: redis: Redis client instance object_type: Entity type for namespacing key: Cache key ident

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

↓ 1 callersMethodget_document_by_content_hash

( self, content_hash: str, )

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

↓ 1 callersMethodget_document_by_id

( self, document_id: str, )

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

↓ 1 callersMethodget_document_by_user_hash

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

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

↓ 1 callersMethodget_health

Run all health checks and return aggregated status.

src/app/features/health/service.py:56

↓ 1 callersMethodget_ingest_status

Return ingestion status from Celery and, when possible, document metadata.

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

↓ 1 callersFunctionget_list_items

Retrieve items from a Redis list. Args: redis: Redis client instance object_type: Entity type for namespacing key: List k

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

↓ 1 callersFunctionget_mcp_http_app

( *, parent_app: FastAPI | None = None, path: str = "/", transport: MCPHTTPTransport | None =

src/mcp_core/server/http.py:21

↓ 1 callersFunctionget_metrics

Get Prometheus metrics via OTel PrometheusMetricReader.

src/app/middleware/server_middleware.py:248

↓ 1 callersFunctionget_model_token_limit

Look up token limits for configured Gemini models.

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

↓ 1 callersFunctionget_mongodb

(connection: HTTPConnection)

src/app/connections/mongodb.py:43

↓ 1 callersMethodget_object

(self, *, key: str)

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

↓ 1 callersMethodget_obligation_chain

( self, entity_name: str, user_id: str, doc_id: str | None = None, dep

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

↓ 1 callersFunctionget_prometheus_metrics

()

src/app/shared/otel_integrations.py:6

↓ 1 callersFunctionget_prometheus_reader

()

src/app/shared/otel/metrics.py:36

↓ 1 callersMethodget_proxy_dict

Get proxy configuration for Crawl4AI.

src/app/shared/crawler/config.py:75

↓ 1 callersFunctionget_redis

(connection: HTTPConnection)

src/app/connections/redis.py:54

↓ 1 callersFunctionget_refresh_token_repository

( redis=Depends(get_redis), )

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

↓ 1 callersFunctionget_security_middleware

Walk the built middleware stack and return the FastAPI Guard middleware instance.

src/app/middleware/server_middleware.py:134

↓ 1 callersMethodget_self_info

Return basic service metadata.

src/app/features/health/service.py:42

↓ 1 callersMethodget_signed_get_url

(self, *, key: str, expires_in: int = 900)

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

↓ 1 callersMethodget_signed_multipart_part_url

( self, *, key: str, upload_id: str, part_number: int, expires

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

↓ 1 callersMethodget_status

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

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

↓ 1 callersFunctionget_tavily_client

()

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

← previous next →501–600 of 1,424, ranked by callers