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 callersMethod_build_client

(self, config: MCPClientServerConfig)

src/mcp_core/client/manager.py:210

↓ 1 callersMethod_build_config

(self, thread_id: str)

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

↓ 1 callersFunction_build_context_prefix

Section 19.2: structured context assembly. context = { "goal": ..., "return_format": ..., "warnings": ..., "conte

src/app/shared/rag/graphiti/memory_pipeline.py:159

↓ 1 callersFunction_build_create_search_index_args

Build the FT.CREATE command arguments.

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

↓ 1 callersMethod_build_dispatcher

Build dispatcher with optional CrawlerMonitor.

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

↓ 1 callersFunction_build_graph_nodes

( registry: AgentRegistry, pro_llm: BaseChatModel, cognee_client: Any, tool_registry: ToolRegi

src/app/shared/langgraph_layer/agent_saul/factory.py:178

↓ 1 callersFunction_build_image_message

Build a multimodal HumanMessage with text + image. Accepts a local path, a URL, or raw base64 bytes.

src/app/shared/langchain_layer/models.py:324

↓ 1 callersMethod_build_initial_state

Build the minimal initial LegalAgentState dict. All Annotated accumulation fields (segments, extracted_entities, relationships, error

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

↓ 1 callersMethod_build_keys

(self, service_name: str)

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

↓ 1 callersFunction_build_preamble

(*, classified: ClassifiedDocument, clause_type: str)

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

↓ 1 callersFunction_build_preamble

(segment: ClauseSegment, metadata: ContractMetadata)

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

↓ 1 callersFunction_build_query_plan

( *, query_llm: Any, query: str, doc_ids_filter: list[str], jurisdiction: str | None,

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

↓ 1 callersFunction_build_resource

(service_name: str | None = None)

src/app/shared/otel/__init__.py:12

↓ 1 callersFunction_build_search_index_query_args

Build the FT.SEARCH command arguments.

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

↓ 1 callersFunction_build_search_items

( *, fused_results: Sequence[RankedChunk], chunk_lookup: dict[str, dict[str, object]], )

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

↓ 1 callersFunction_build_search_result

Build a SearchResult from API response data.

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

↓ 1 callersFunction_build_trigram_statement

(metadata_filter: dict[str, Any])

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

↓ 1 callersFunction_build_vector_statement

(metadata_filter: dict[str, Any])

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

↓ 1 callersFunction_cached_embedding

( redis: Redis | None, embedding_fn: object, text_to_embed: str, )

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

↓ 1 callersFunction_cached_embedding

( redis: Redis | None, embedding_fn: EmbeddingFunction, text_to_embed: str, )

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

↓ 1 callersFunction_cached_embedding

( redis: Redis | None, embedding_fn: EmbeddingFunction, text_to_embed: str, )

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

↓ 1 callersFunction_call_embedding_fn

(embedding_fn: EmbeddingFunction, text_to_embed: str)

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

↓ 1 callersFunction_call_embedding_fn

(embedding_fn: EmbeddingFunction, text_to_embed: str)

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

↓ 1 callersFunction_change_type

(item: object)

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

↓ 1 callersMethod_check_celery

(self)

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

↓ 1 callersMethod_check_disk

()

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

↓ 1 callersMethod_check_memory

()

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

↓ 1 callersMethod_check_mongodb

(self)

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

↓ 1 callersMethod_check_neo4j

(self)

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

↓ 1 callersMethod_check_postgres

(self)

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

↓ 1 callersMethod_check_redis

(self)

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

↓ 1 callersFunction_chunk_document

( *, parsed: ParsedDocument, classified: ClassifiedDocument )

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

↓ 1 callersFunction_chunk_metadata_json

( *, metadata: ContractMetadata, source: str, page_no: int, )

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

↓ 1 callersMethod_clean_databases

Clean existing data from databases.

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

↓ 1 callersFunction_client_ip

(scope: dict[str, Any])

src/mcp_core/server/middleware.py:133

↓ 1 callersFunction_coerce_entity_types

( entity_types: Iterable[MemoryEntityType | str], )

src/app/shared/langchain_layer/agents/memory/memory_scope.py:96

↓ 1 callersFunction_coerce_sources

( sources: Iterable[MemorySource | str], )

src/app/shared/langchain_layer/agents/memory/memory_scope.py:105

↓ 1 callersFunction_coerce_time_filter

(time_filter: MemoryTimeFilter | str)

src/app/shared/langchain_layer/agents/memory/memory_scope.py:113

↓ 1 callersMethod_compute_overall_status

(checks: HealthChecksDTO)

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

↓ 1 callersFunction_contract_events

(metadata: ContractMetadata | None)

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

↓ 1 callersFunction_detect_language

Detect programming language from metadata or content.

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

↓ 1 callersFunction_embed_chunks

( *, user_id: str, document_id: str, chunks: list[PreparedChunk], extra_warnings: list[Qua

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

↓ 1 callersFunction_encode_base64

Encode image data to base64.

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

↓ 1 callersFunction_ensure_chunk_enrichment

(segments: list[ClauseSegment])

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

↓ 1 callersFunction_entity_update_statement

(field_name: str)

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

↓ 1 callersFunction_estimate_tokens

Rough token estimate: 4 chars ≈ 1 token.

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

↓ 1 callersFunction_extract_code_fallback

Fallback regex-based code extraction.

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

↓ 1 callersFunction_extract_compliance_output

(_messages: list[Any])

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

↓ 1 callersFunction_extract_contract_type

(text: str)

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

↓ 1 callersMethod_extract_document_metadata

Extract metadata from document content.

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

↓ 1 callersFunction_extract_jurisdiction

(markdown: str)

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

↓ 1 callersFunction_extract_parties

(markdown: str)

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

↓ 1 callersFunction_extract_postgres_chunk_ids

(value: str)

src/app/features/documents/graphiti_verifier.py:90

↓ 1 callersFunction_extract_relationships_simple

Simple pattern-based relationship extraction.

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

↓ 1 callersFunction_extract_risk_output

(_messages: list[Any])

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

↓ 1 callersFunction_extract_search_blob

(item: object)

src/app/features/documents/graphiti_verifier.py:84

↓ 1 callersFunction_extract_title

(markdown: str, filename: str)

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

↓ 1 callersFunction_extract_title

(markdown: str, filename: str)

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

↓ 1 callersMethod_extract_title

Extract title from document content or filename.

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

↓ 1 callersFunction_fallback_segments

(markdown: str)

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

↓ 1 callersFunction_fetch_dead_letters

( session_factory: async_sessionmaker[AsyncSession], limit: int, )

scripts/replay_outbox.py:14

↓ 1 callersFunction_fetch_statute_section

( db_engine: AsyncEngine, act_name: str, section_ref: str, jurisdiction: str, )

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

↓ 1 callersFunction_filter_supported_entity_updates

(fields: dict[str, object])

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

↓ 1 callersFunction_filter_tool_messages

Remove ToolMessage and AIMessage tool_calls; replace with summary. LangChain's filter_messages removes by type. We additionally strip AI mes

src/app/shared/rag/graphiti/memory_pipeline.py:128

↓ 1 callersMethod_find_document_files

Find all supported document files in the documents folder.

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

↓ 1 callersFunction_find_mcp_error

(exc: BaseException)

src/mcp_core/client/auth.py:124

↓ 1 callersFunction_first_nonempty_paragraph

(markdown: str)

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

↓ 1 callersFunction_force_merge_bm25

(session: AsyncSession)

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

↓ 1 callersFunction_format_obligation_chain

Format graph results into a compact chain summary for the LLM.

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

↓ 1 callersFunction_generate_answer

( *, generator_llm: Any, query: str, reranked: Sequence[RetrievedChunk], )

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

↓ 1 callersFunction_generate_vlm_caption

Generate caption using VLM (Gemini).

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

↓ 1 callersMethod_get_application_health

(self)

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

↓ 1 callersFunction_get_catalog

()

src/mcp_core/server/resources.py:93

↓ 1 callersFunction_get_config

()

src/mcp_core/server/resources.py:34

↓ 1 callersFunction_get_crawl4ai_crawler_from_config

Read the lifespan-owned Crawl4AI AsyncWebCrawler from RunnableConfig when present.

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

↓ 1 callersFunction_get_document_llm

()

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

↓ 1 callersFunction_get_features

()

src/mcp_core/server/resources.py:59

↓ 1 callersMethod_get_from_cache

Get cached crawl result.

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

↓ 1 callersMethod_get_from_postgres

(self, key: str)

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

↓ 1 callersFunction_get_health

()

src/mcp_core/server/resources.py:71

↓ 1 callersFunction_get_httpx_client_from_config

Read the lifespan-owned HTTPX client from RunnableConfig when present.

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

↓ 1 callersMethod_get_rate_limiter

(self)

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

↓ 1 callersFunction_get_search_llm

()

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

↓ 1 callersMethod_get_system_health

()

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

↓ 1 callersFunction_get_upstream_status

(server_name: str)

src/mcp_core/server/resources.py:89

↓ 1 callersFunction_grade_context

( *, grader_llm: Any, query: str, reranked: Sequence[RetrievedChunk], )

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

↓ 1 callersFunction_graphiti_filter_chunk_ids

( *, graphiti: Graphiti | None, user_id: str, query: str, doc_ids_filter: list[str], )

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

↓ 1 callersMethod_handle_hitl

Emit HITL frame, wait for WSResumeMessage, return Command(resume=...).

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

↓ 1 callersFunction_has_jurisdiction

Check if episode matches the given jurisdiction.

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

↓ 1 callersFunction_heuristic_metadata

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

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

↓ 1 callersFunction_infer_clause_type

(text: str)

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

↓ 1 callersFunction_infer_relationships

Infer relationships between extracted entities.

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

↓ 1 callersMethod_ingest_single_document

Ingest a single document. Args: file_path: Path to the document file Returns: Ingestion result

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

↓ 1 callersFunction_ingestion_failure

(error: AppError)

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

↓ 1 callersFunction_instructions

()

src/mcp_core/server/factory.py:22

↓ 1 callersMethod_is_envelope_violation

(response_model)

src/app/api/strict_envelope.py:31

↓ 1 callersFunction_is_streaming_response

(response: Response)

src/app/middleware/server_middleware.py:112

↓ 1 callersFunction_jwt_key

()

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

↓ 1 callersMethod_load_model

(self)

src/app/shared/langgraph_layer/retrieval_kb/reranker.py:58

↓ 1 callersFunction_looks_like_contract

(text: str)

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

← previous next →301–400 of 1,424, ranked by callers