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 callersMethodrun_startup_scan

One-time scan for unpublished events created while relay was offline.

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

↓ 1 callersFunctionsave_to_postgres

Save document and chunks to PostgreSQL.

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

↓ 1 callersMethodsearch

Search the web using Tavily. Args: request: Search request parameters Returns: SearchResponse with

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

↓ 1 callersMethodsearch_for_precedent_chains

( self, query: str, user_id: str, jurisdiction: str, num_results: int )

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

↓ 1 callersMethodsearch_for_risk_context

( self, query: str, user_id: str, doc_id: str | None = None, num_resul

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

↓ 1 callersMethodsearch_for_risk_context

( self, query: str, user_id: str, doc_id: str, num_results: int )

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

↓ 1 callersFunctionsearch_rag_data

Search rag_data table.

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

↓ 1 callersFunctionsegment_chunks

( *, parsed: ParsedDocument, classified: ClassifiedDocument, )

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

↓ 1 callersFunctionselectRenderer

(format string)

src/lynk/internal/adapters/cli/lint_command.go:64

↓ 1 callersFunctionsetup_cognee

Configure Cognee to use the same Neo4j + Postgres as the app. Cognee creates its own internal connection pools — these are separate from app.

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

↓ 1 callersFunctionsetup_logging

Configure loguru logger with console and file handlers.

src/app/utils/logger.py:61

↓ 1 callersFunctionsetup_mongodb

Initialize MongoDB with health check.

src/app/lifecycle/lifespan.py:55

↓ 1 callersFunctionsetup_neo4j

Initialize Neo4j with connectivity verification.

src/app/lifecycle/lifespan.py:74

↓ 1 callersFunctionsetup_redis

Initialize Redis with health check.

src/app/lifecycle/lifespan.py:47

↓ 1 callersFunctionsha256Hex

(data []byte)

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

↓ 1 callersFunctionshouldFail

(diagnostics []model.Diagnostic, failOn string)

src/lynk/internal/adapters/cli/lint_command.go:90

↓ 1 callersFunctionsign_oauth_state

(state: str, provider: str)

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

↓ 1 callersMethodsort

Apply sorting to query.

src/app/utils/api_features.py:57

↓ 1 callersMethodstore_final_report

( self, report_json: str, user_id: str, doc_id: str, thread_id: str )

src/app/shared/rag/graphiti/write_final_report.py:44

↓ 1 callersMethodstore_relationships

( self, relationships_text: str, user_id: str, doc_id: str )

src/app/shared/rag/graphiti/write_final_report.py:48

↓ 1 callersMethodstore_session

(self, session: SessionData)

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

↓ 1 callersFunctionsummarize_history

Default memory strategy for production agents. 1. Keeps the SystemMessage (if any). 2. Summarizes all but the last `keep_last` messages

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

↓ 1 callersFunctionsummarize_result

(result: dict[str, str | None])

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

↓ 1 callersFunctionsummarize_webpage

Summarize webpage content with timeout protection.

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

↓ 1 callersFunctiontavily_search_async

Execute bounded Tavily searches through the shared service client.

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

↓ 1 callersFunctionteardown_langgraph_checkpointer

Graceful shutdown of AsyncPostgresSaver connection pool. Closes all active connections and cleans up resources. Args: checkpoin

src/app/shared/langgraph_layer/checkpointer.py:61

↓ 1 callersMethodto_agent_string

Return a compact string for tool observations.

src/app/shared/langgraph_layer/open_deep_search/tools.py:41

↓ 1 callersMethodto_context_text

(self)

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

↓ 1 callersMethodto_episode_body

(self)

src/app/shared/rag/graphiti/schemas.py:221

↓ 1 callersFunctionto_float_list_str

(data: list[float])

src/app/utils/json_serializer.py:32

↓ 1 callersFunctionto_json_str

(data: object)

src/app/utils/json_serializer.py:20

↓ 1 callersMethodtrigram_search

( self, *, user_id: str, query: str, candidate_limit: int, fil

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

↓ 1 callersMethodtrigram_search

( self, *, query: str, candidate_limit: int, metadata_filter: dict[str

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

↓ 1 callersMethodtyped_send

Validate kwargs against registered model, then send. Falls back to LegacyTaskPayload (accepts any kwargs) if task is not registered.

src/app/connections/celery_registry.py:66

↓ 1 callersMethodunregister_connection

(self, context: WebSocketSecurityContext)

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

↓ 1 callersFunctionupdate_cached_user

Update user and refresh cache. For small updates, use Hash to avoid re-fetching entire document.

src/app/examples/redis_examples.py:115

↓ 1 callersMethodupdate_profile

( self, user: User, dto: UpdateProfileRequest, )

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

↓ 1 callersMethodupdate_role

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

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

↓ 1 callersMethodupload_avatar

( self, user: User, file_data: bytes, content_type: str, )

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

↓ 1 callersMethodupload_document

( self, *, user_id: str, filename: str, content_type: str, raw

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

↓ 1 callersMethodupsert_chunks

Bulk upsert chunk rows using the document/chunk unique key.

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

↓ 1 callersMethodvector_search

( self, *, user_id: str, embedding: list[float], candidate_limit: int,

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

↓ 1 callersMethodvector_search

( self, *, embedding: list[float], candidate_limit: int, metadata_filt

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

↓ 1 callersMethodverify_email

(self, token: str)

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

↓ 1 callersFunctionverify_oauth_state

( signed: str, state: str, provider: str, max_age: int = 300, )

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

↓ 1 callersFunctionwrite_and_verify_chunk

( *, graphiti: Graphiti | None, user_id: str, document_id: str, chunk_id: str, clause_

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

↓ 1 callersMethodwrite_clause_episode

( self, clause_text: str, metadata: ClauseEpisodeMetadata, )

src/app/shared/rag/graphiti/write_clause_episodes.py:47

↓ 1 callersMethodwrite_final_report_episode

( self, report_summary: str, metadata: FinalReportEpisodeMetadata )

src/app/shared/rag/graphiti/write_final_report.py:37

↓ 1 callersMethodwrite_relationship_edge

(self, edge: LegalEdgeInput)

src/app/shared/rag/graphiti/write_clause_episodes.py:53

FunctionBuildIndexes

(doc *model.Document)

src/lynk/internal/support/analyze/indexes.go:5

MethodCode

()

src/lynk/internal/adapters/rules/structural.go:11

MethodCode

()

src/lynk/internal/adapters/rules/b2b.go:11

MethodCode

()

src/lynk/internal/adapters/rules/b2b.go:33

MethodCode

()

src/lynk/internal/adapters/rules/b2b.go:54

MethodCode

()

src/lynk/internal/adapters/rules/lexical.go:16

MethodCode

()

src/lynk/internal/adapters/rules/lexical.go:20

FunctionDefaultRegistry

()

src/lynk/internal/adapters/rules/registry.go:5

MethodRead

(path string)

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

MethodRender

(writer io.Writer, result model.LintResult)

src/lynk/internal/adapters/output/text.go:12

MethodRender

(writer io.Writer, result model.LintResult)

src/lynk/internal/adapters/output/json.go:13

MethodRun

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

src/lynk/internal/adapters/rules/structural.go:15

MethodRun

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

src/lynk/internal/adapters/rules/b2b.go:15

MethodRun

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

src/lynk/internal/adapters/rules/b2b.go:37

MethodRun

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

src/lynk/internal/adapters/rules/b2b.go:58

MethodRun

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

src/lynk/internal/adapters/rules/lexical.go:24

MethodRun

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

src/lynk/internal/adapters/rules/lexical.go:50

FunctionRunLint

(args []string)

src/lynk/internal/adapters/cli/lint_command.go:17

FunctionTestAmbiguousDaysFixture

(t *testing.T)

src/lynk/internal/adapters/rules/rules_test.go:132

FunctionTestBrokenCrossReferenceFixture

(t *testing.T)

src/lynk/internal/adapters/rules/rules_test.go:102

FunctionTestConflictingDisputeFixture

(t *testing.T)

src/lynk/internal/adapters/rules/rules_test.go:87

FunctionTestLintJSONGolden

(t *testing.T)

src/lynk/internal/adapters/cli/lint_command_test.go:11

FunctionTestMissingGoverningLawFixture

(t *testing.T)

src/lynk/internal/adapters/rules/rules_test.go:117

FunctionTestNormalizeWhitespace

(t *testing.T)

src/lynk/internal/adapters/docx/reader_test.go:5

FunctionTestReadAdditionalFixtures

(t *testing.T)

src/lynk/internal/adapters/docx/reader_test.go:80

FunctionTestReadFixtureDocument

(t *testing.T)

src/lynk/internal/adapters/docx/reader_test.go:67

FunctionTestRules

(t *testing.T)

src/lynk/internal/adapters/rules/rules_test.go:11

FunctionTestSplitSectionHeading

(t *testing.T)

src/lynk/internal/adapters/docx/reader_test.go:33

Method__aiter__

(self)

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

Method__anext__

(self)

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

Method__call__

Track request-scoped logging state for the full ASGI response lifecycle.

src/app/middleware/server_middleware.py:30

Method__call__

(self, *args, **kwargs)

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

Method__call__

(self, scope: dict[str, Any], receive: Callable, send: Callable)

src/mcp_core/server/middleware.py:45

Method__call__

(self, scope: dict[str, Any], receive: Callable, send: Callable)

src/mcp_core/server/middleware.py:101

Function__getattr__

(name: str)

src/app/__init__.py:8

Function__init__

Initialize extraction tools.

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

Method__init__

( self, detail: str = "Validation error", error_code: str = ErrorCode.VALIDATION_ERROR

src/app/utils/exceptions.py:51

Method__init__

( self, resource: str, identifier: str | int | None = None, error_code: str =

src/app/utils/exceptions.py:68

Method__init__

( self, detail: str = "Authentication failed", error_code: str = ErrorCode.UNAUTHORIZE

src/app/utils/exceptions.py:88

Method__init__

( self, detail: str = "Insufficient permissions", error_code: str = ErrorCode.FORBIDDE

src/app/utils/exceptions.py:104

Method__init__

( self, detail: str, error_code: str = ErrorCode.CONFLICT, data: dict | None =

src/app/utils/exceptions.py:119

Method__init__

( self, detail: str = "Too many requests", error_code: str = ErrorCode.TOO_MANY_REQUES

src/app/utils/exceptions.py:136

Method__init__

( self, detail: str = "Service temporarily unavailable", error_code: str = ErrorCode.S

src/app/utils/exceptions.py:155

Method__init__

( self, detail: str = "Database operation failed", error_code: str = ErrorCode.DATABAS

src/app/utils/exceptions.py:179

Method__init__

( self, service: str, detail: str, error_code: str = ErrorCode.EXTERNAL_SERVIC

src/app/utils/exceptions.py:199

Method__init__

(self, reason: str | None = None)

src/app/utils/exceptions.py:218

Method__init__

(self)

src/app/utils/exceptions.py:228

Method__init__

(self, reason: str | None = None)

src/app/utils/exceptions.py:235

Method__init__

(self, collection: AsyncIOMotorCollection, query_params: dict[str, Any])

src/app/utils/api_features.py:10

Method__init__

(self, redis: Redis, redis_prefix: str = "fastapi_guard:")

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

Method__init__

(self, redis: Redis)

src/app/utils/rate_limit/service.py:53

← previous next →701–800 of 1,424, ranked by callers