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

↓ 260 callersMethodinfo

(self, message: str, **kwargs: object)

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

↓ 222 callersMethodget

(cls, task_name: str)

src/app/connections/celery_registry.py:62

↓ 159 callersMethodget

(self, name: str)

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

↓ 112 callersMethodwarning

(self, message: str, **kwargs: object)

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

↓ 89 callersFunctionget_settings

Returns a cached instance of the application settings.

src/app/config/settings.py:400

↓ 81 callersMethodexecute

Execute the query and return results.

src/app/utils/api_features.py:110

↓ 56 callersMethodget

Get embedding from cache.

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

↓ 44 callersMethodainvoke

Single async invocation. Args: user_message: The user's input message. thread_id: LangGraph thread ID for co

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

↓ 44 callersMethodexecute

(self, key: str, fn: Any, *args: Any, **kwargs: Any)

src/app/shared/agents/tools/idempotency.py:24

↓ 41 callersMethodexception

(self, message: str, **kwargs: object)

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

↓ 39 callersFunctionhttp_response

Create standardized HTTP success response using ContextVar.

src/app/utils/http_response.py:37

↓ 37 callersFunctionlog_expected_failure

Log an expected failure once at the ownership boundary.

src/app/shared/result/logging.py:8

↓ 30 callersFunctionrender_prompt_sections

Render plain labeled prompt sections, skipping empty bodies.

src/app/shared/langchain_layer/prompts.py:144

↓ 25 callersFunction_build_database_exception

Create a normalized database exception with the original error attached.

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

↓ 25 callersFunctionapp_error_to_exception

Translate expected internal failures to the existing exception boundary.

src/app/shared/result/mappers.py:23

↓ 22 callersFunctionretry_immediate

Run an async operation through Tenacity with immediate three-attempt retry.

src/app/shared/langgraph_layer/kb_retry.py:19

↓ 19 callersFunctionmax

(a int, b int)

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

↓ 19 callersMethodset

(self, *args: object, **kwargs: object)

src/app/connections/celery_reliability.py:28

↓ 19 callersMethodwith_structured_output

(self, schema: type[LegalMetadataExtraction])

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

↓ 16 callersFunction_redis_any

Treat Redis client variants uniformly for runtime command execution.

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

↓ 15 callersMethodget

Retrieve a value by namespace + key.

src/app/shared/langchain_layer/agents/memory/cognee_client.py:291

↓ 15 callersFunctionget_cache_key

Get a cache key handling single or multiple key parts. Args: object_type: Entity type key: Single key, ID, or list of key compone

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

↓ 14 callersFunction_build_chat_model

Return a configured Gemini chat model instance.

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

↓ 12 callersMethod__init__

( self, status_code: int, detail: str, error_code: str | None = None,

src/app/utils/exceptions.py:17

↓ 12 callersMethodall

(self)

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

↓ 12 callersMethodok

(cls, data: Any, **metadata: Any)

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

↓ 12 callersMethodto_agent_string

Return a string the agent can parse.

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

↓ 11 callersFunctionserialize_to_toon

Serialize structured prompt context with TOON for lower token overhead than JSON. Use this when passing large tables, records, or nested obj

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

↓ 10 callersMethodfrom_runnable_config

Create a Configuration instance from RunnableConfig and environment.

src/app/shared/langgraph_layer/open_deep_search/config.py:49

↓ 10 callersFunctionmake_mock_user

(**kwargs)

tests/integration/test_auth.py:20

↓ 10 callersFunctionnormalize_embedding

Normalise an embedding vector to the expected dimension. Logs a warning if the actual dimension differs from the expected dimension.

src/app/utils/embedding.py:8

↓ 9 callersMethodRun

(doc *model.Document, idx *model.Indexes)

src/lynk/internal/core/ports/rule.go:7

↓ 9 callersMethod_get_config

(self, server_name: str)

src/mcp_core/client/manager.py:185

↓ 9 callersMethod_not_configured

()

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

↓ 9 callersMethodclose

Close all connections.

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

↓ 9 callersMethodfail

(cls, error: str, **metadata: Any)

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

↓ 9 callersMethodhybrid_search

Run BM25 and vector retrieval, fuse the results, and hydrate ranked chunks.

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

↓ 9 callersMethodsave

(self, user: User)

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

↓ 9 callersMethodset

Persist an execution result to Redis and Postgres.

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

↓ 8 callersMethod_send_json

(self, ws: WebSocket, payload: object)

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

↓ 8 callersFunctioncreate_converter

Factory function to create enhancement config.

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

↓ 8 callersMethoddelete

(self, *args: object, **kwargs: object)

src/app/connections/celery_reliability.py:30

↓ 8 callersMethodmake_key

Build a deterministic SHA-256 key for a tool invocation.

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

↓ 8 callersFunctionreciprocal_rank_fusion

Fuse ranked result lists with the standard reciprocal-rank formula.

src/app/features/search/fusion.py:28

↓ 8 callersMethodregister

(self, dto: RegisterRequest)

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

↓ 8 callersFunctionrun_redis_call

Resolve either a direct Redis result or an awaitable returned by async Redis.

src/app/connections/celery_reliability.py:65

↓ 7 callersFunction_make_repo

(**method_kwargs: dict)

tests/integration/test_search.py:18

↓ 7 callersFunction_ok

(data: Any, **metadata: Any)

src/mcp_core/server/tools.py:54

↓ 7 callersFunctionget_today_str

Get current UTC date formatted for prompts.

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

↓ 6 callersFunction_build_model

Build a shared Gemini model for deep research nodes.

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

↓ 6 callersFunction_build_scope

( *, agent_id: str, entity_types: Iterable[MemoryEntityType | str], sources: Iterable[MemorySo

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

↓ 6 callersFunction_timed_tool

( tool_name: str, fn: Callable[[], Any], )

src/mcp_core/server/tools.py:142

↓ 6 callersMethodacquire_idempotency_lock

( self, idempotency_key: str, *, metadata: dict[str, Any] | None = None, )

src/app/connections/celery.py:70

↓ 6 callersFunctionbuild_embedding_client

Construct the shared Gemini embedding client used by search.

src/app/features/search/embeddings.py:10

↓ 6 callersFunctioninitialize_db

()

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

↓ 6 callersMethodlogin

( self, dto: LoginRequest, ip: str | None = None, user_agent: str | None = Non

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

↓ 6 callersFunctionmake_session_json

(session_id="sid-1", user_id="507f1f77bcf86cd799439011")

tests/integration/test_auth.py:42

↓ 6 callersMethodmark_idempotency_completed

( self, idempotency_key: str, *, metadata: dict[str, Any] | None = None, )

src/app/connections/celery.py:84

↓ 6 callersMethodrelease_idempotency_processing_lock

(self, idempotency_key: str)

src/app/connections/celery.py:112

↓ 6 callersMethodsearch

(self, *, user_id: str, payload: UnifiedSearchRequest)

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

↓ 6 callersMethodsend_json

( self, websocket: WebSocket, payload: object, context: WebSocketSecurityConte

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

↓ 6 callersFunctionserialize_data

Serialize data to JSON string. Args: value: Data to serialize Returns: JSON string Raises: DatabaseException: I

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

↓ 6 callersFunctionwith_outbox

Write an outbox event and notify the relay in the same transaction. pg_notify() is transactional — the notification is only delivered after t

src/app/shared/outbox/helper.py:15

↓ 5 callersMethodRead

(path string)

src/lynk/internal/core/ports/document_source.go:6

↓ 5 callersFunction_extract_text_after_label

(markdown: str, label_regex: str)

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

↓ 5 callersMethod_get_user_or_raise

(self, user_id: str)

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

↓ 5 callersFunction_state_failure

Construct a state dict from a failure error (node boundary).

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

↓ 5 callersFunction_validation_failure

(code: str, message: str, *, doc_id: str = "")

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

↓ 5 callersFunctionassemble_rag_context

Group by document, restore chunk order, merge adjacent chunks, and budget output.

src/app/features/search/rag.py:37

↓ 5 callersFunctionbuild_idempotency_key

( idempotency_key: str, *, namespace: str = IDEMPOTENCY_NAMESPACE, )

src/app/connections/celery_reliability.py:72

↓ 5 callersFunctionchunk_text

Split text into overlapping token windows while preserving order.

src/app/features/search/chunking.py:18

↓ 5 callersFunctionconvert_document

Convert document with enhanced extraction.

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

↓ 5 callersMethodcreate

(self, user: User)

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

↓ 5 callersFunctioncreate_embedder

()

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

↓ 5 callersFunctiondecode_token

Decode and validate a JWT. Raises UnauthorizedException on any failure.

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

↓ 5 callersMethodfail

(cls, name: str, message: str, latency_ms: float = 0.0)

src/app/utils/response_type.py:84

↓ 5 callersFunctionget_model_config

Get model-specific configuration.

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

↓ 5 callersMethodget_redis_client

(cls)

src/app/connections/celery.py:65

↓ 5 callersFunctionhash_token

SHA-256 digest stored in DB; the raw token travels only via email.

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

↓ 5 callersFunctionhttp_error

Create standardized HTTP error response using ContextVar.

src/app/utils/http_response.py:53

↓ 5 callersMethodok

(cls, name: str, latency_ms: float = 0.0)

src/app/utils/response_type.py:80

↓ 5 callersFunctionprogress_callback

(current: int, total: int)

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

↓ 5 callersFunctionrequire_permission

Dependency factory. Validates permissions from JWT claims without a DB round trip. Usage: Depends(require_permission(Permission.USERS_READ, Permi

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

↓ 5 callersMethodrevoke_all_user_sessions

( self, user_id: str, except_session_id: str | None = None, reason: str = "rev

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

↓ 4 callersFunction_extract_postgres_chunk_ids

(value: str)

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

↓ 4 callersFunction_infrastructure_failure

( code: str, message: str, *, user_id: str, retryable: bool = True, )

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

↓ 4 callersFunction_json_error_response

( payload, status_code: int, headers: dict[str, str] | None = None )

src/app/middleware/global_exception_handler.py:12

↓ 4 callersFunction_jwt_oct_key

()

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

↓ 4 callersFunction_structured

(llm: Any, schema: type[Any])

src/app/shared/langgraph_layer/ingestion_kb/graph.py:87

↓ 4 callersFunction_to_admin_response

(user: User)

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

↓ 4 callersFunction_truncate

(data: Any)

src/mcp_core/server/resources.py:27

↓ 4 callersMethodclose

Close database connections.

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

↓ 4 callersFunctionconfig_from_settings

Build a MailerConfig from the current application settings.

src/app/shared/services/mailer.py:34

↓ 4 callersFunctionget_database_url

Convert psycopg2 URL to asyncpg URL.

src/app/connections/postgres.py:30

↓ 4 callersFunctionget_mcp_client_manager

()

src/mcp_core/client/manager.py:295

↓ 4 callersMethodget_permissions

(self)

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

↓ 4 callersFunctionget_rate_limiter

Get rate limiter instance with Redis from app.state.

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

↓ 4 callersFunctionhash_password

(password: str)

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

↓ 4 callersFunctioninit_db

Initialize database engine and session factory. Returns: tuple: (engine, AsyncSessionLocal) for app.state injection

src/app/connections/postgres.py:57

↓ 4 callersFunctionis_circuit_breaker_open

( redis_client: RedisClientProtocol, name: str, *, recovery_timeout_seconds: int, namespac

src/app/connections/celery_reliability.py:235

next →1–100 of 1,424, ranked by callers