Functions — github.com/diegosouzapw/OmniRoute

hub / github.com/diegosouzapw/OmniRoute / functions

Functions20,485 in github.com/diegosouzapw/OmniRoute

⨍ Functions 20,485◇ Types & classes 2,883

↓ 1 callersFunctioncreateA2AStream

( task: A2ATask, executeSkill: ( task: A2ATask ) => Promise<{ artifacts: Array<{ content: string }>;

src/lib/a2a/streaming.ts:90

↓ 1 callersFunctioncreateAnthropicStreamResponse

(text: string, body: unknown)

src/lib/usage/internalUsageCommand.ts:674

↓ 1 callersFunctioncreateAnthropicTextResponse

(text: string, body: unknown)

src/lib/usage/internalUsageCommand.ts:660

↓ 1 callersFunctioncreateBackup

()

bin/cli/commands/update.mjs:53

↓ 1 callersFunctioncreateBackupMultipartStream

(backupPath, info, boundary)

bin/cli/commands/backup.mjs:316

↓ 1 callersFunctioncreateBadgeNotificationStream

( apiKeyId: string, signal?: AbortSignal )

src/lib/gamification/notifications.ts:68

↓ 1 callersFunctioncreateBatchState

(batch: BatchRecord)

open-sse/services/batchProcessor.ts:630

↓ 1 callersFunctioncreateBetterSqliteAdapter

(db: import("better-sqlite3").Database)

src/lib/db/adapters/betterSqliteAdapter.ts:3

↓ 1 callersFunctioncreateCaptureLog

()

tests/unit/codex-stream-false.test.ts:38

↓ 1 callersFunctioncreateCavemanStats

( originalTokens: number, compressedTokens: number, techniquesUsed: string[], rulesApplied: string[] |

open-sse/services/compression/caveman.ts:395

↓ 1 callersFunctioncreateChunkEvent

(taskId: string, content: string)

src/lib/a2a/streaming.ts:30

↓ 1 callersFunctioncreateClaudeEmptyResponseLifecycle

()

open-sse/utils/stream.ts:408

↓ 1 callersFunctioncreateClaudeOAuth

(i: number)

tests/unit/provider-limits-oauth-sequential-sync.test.ts:41

↓ 1 callersFunctioncreateCodexClientIdentity

( sessionId: string | null, providerSpecificData?: Record<string, unknown> | null )

open-sse/config/codexIdentity.ts:42

↓ 1 callersFunctioncreateCombo

(name: string, model: string)

tests/unit/error-message-sanitization.test.ts:48

↓ 1 callersFunctioncreateComboLog

()

tests/unit/codex-stream-false.test.ts:28

↓ 1 callersFunctioncreateCompatibleProviderNode

( input: CreateCompatibleProviderNodeInput )

src/app/(dashboard)/dashboard/providers/components/onboarding/providerOnboardingApi.ts:262

↓ 1 callersFunctioncreateCompletionEvent

(taskId: string, metadata: Record<string, unknown>)

src/lib/a2a/streaming.ts:44

↓ 1 callersFunctioncreateCompressionCombo

(data: Partial<CompressionCombo>)

src/lib/db/compressionCombos.ts:253

↓ 1 callersFunctioncreateCurrencyFormatter

(locale: string)

src/app/(dashboard)/dashboard/costs/components/ApiKeyUsageLimitCard.tsx:35

↓ 1 callersFunctioncreateDraftFromImportedSuite

( payload: ImportedEvalSuiteFile, fallbackName: string )

src/app/(dashboard)/dashboard/usage/components/EvalsTab.tsx:310

↓ 1 callersFunctioncreateEmptyStreamChunks

()

open-sse/utils/requestLogger.ts:95

↓ 1 callersFunctioncreateEnvBackup

()

src/app/api/system/env/repair/route.ts:19

↓ 1 callersFunctioncreateErrorFile

( batchId: string, current: any, results: any[], itemsWithErrors: any[] )

open-sse/services/batchProcessor.ts:842

↓ 1 callersFunctioncreateExecutorModelClient

( provider: string, credentials: ProviderCredentials, costPerKTokenOut?: number )

open-sse/services/compression/eval/executorModelClient.ts:14

↓ 1 callersFunctioncreateFakeEmbeddingRelay

()

tests/integration/batch-e2e-rate-limit.test.ts:92

↓ 1 callersFunctioncreateFakeOpenAiRelay

()

tests/integration/resilience-http-e2e.test.ts:85

↓ 1 callersFunctioncreateHeartbeat

(taskId: string)

src/lib/a2a/streaming.ts:58

↓ 1 callersFunctioncreateHookSandbox

* Build the minimal, capability-free context object exposed to hook code. * * TRUST MODEL: Node's `vm` is NOT a hard security boundary (it shares th

src/lib/middleware/registry.ts:76

↓ 1 callersFunctioncreateInviteToken

( id: string, code: string, tokenHash: string, createdBy: string, serverUrl?: string, maxUses?: nu

src/lib/db/gamification.ts:421

↓ 1 callersFunctioncreateJsonResponse

( upstream: Response, model: string, signal?: AbortSignal | null )

open-sse/executors/commandCode.ts:583

↓ 1 callersFunctioncreateLegacyArchive

(targets: ArchiveTarget[])

src/lib/usage/migrations.ts:161

↓ 1 callersFunctioncreateLegacyCallLogsDb

(sqliteFile)

tests/unit/db-core-init.test.ts:134

↓ 1 callersFunctioncreateLegacyEncrypted

(plaintext: string, secret: string)

tests/unit/encryption.spec.ts:5

↓ 1 callersFunctioncreateLimiter

(max)

scripts/i18n/run-translation.mjs:443

↓ 1 callersFunctioncreateLimiter

(max)

scripts/i18n/sync-ui-keys.mjs:283

↓ 1 callersFunctioncreateLog

()

tests/unit/rate-limit-queue-timeout-lockout.test.ts:17

↓ 1 callersFunctioncreateLog

()

tests/unit/model-lockout-max-cooldown.test.ts:19

↓ 1 callersFunctioncreateLog

()

tests/unit/combo-round-robin-streaming-lock-3811.test.ts:29

↓ 1 callersFunctioncreateLogger

(requestId: string | null = null)

open-sse/utils/logger.ts:151

↓ 1 callersFunctioncreateLogger

(component: string)

src/shared/utils/structuredLogger.ts:171

↓ 1 callersFunctioncreateManagementSessionToken

( secret = process.env.JWT_SECRET || TEST_MANAGEMENT_JWT_SECRET )

tests/helpers/managementSession.ts:10

↓ 1 callersFunctioncreateMiniMaxQuotaFromCount

( total: number, count: number, resetAt: string | null, countMeansRemaining: boolean )

open-sse/services/usage/minimax.ts:116

↓ 1 callersFunctioncreateMockRedisClient

* Create a simple in-memory mock that mimics ioredis behaviour. * Tracks calls so we can assert on them.

tests/unit/quota-redis-store.test.ts:66

↓ 1 callersFunctioncreateMockResponse

()

tests/unit/opencode-executor.test.ts:8

↓ 1 callersFunctioncreateModelComboMapping

(data: { pattern: string; comboId: string; priority?: number; enabled?: boolean; description?: strin

src/lib/db/modelComboMappings.ts:120

↓ 1 callersFunctioncreateNodeSqliteAuditAdapter

* node:sqlite's `DatabaseSync` does NOT expose a boolean `open` property — * `open` and `close` are methods on the prototype, and the only state * s

open-sse/mcp-server/audit.ts:46

↓ 1 callersFunctioncreateNonStreamingResponse

* Create non-streaming response with translation * Use translator to convert OpenAI → sourceFormat

open-sse/utils/bypassHandler.ts:129

↓ 1 callersFunctioncreateNoopReleaseFn

()

open-sse/services/accountSemaphore.ts:61

↓ 1 callersFunctioncreateOneItemBatch

(prefix: string)

tests/unit/batch-processor.test.ts:234

↓ 1 callersFunctioncreateOpenAIStreamFromBedrock

(stream, model)

open-sse/executors/bedrock.ts:507

↓ 1 callersFunctioncreateOpenAIStreamResponse

(text: string, body: unknown)

src/lib/usage/internalUsageCommand.ts:634

↓ 1 callersFunctioncreateOpenAITextResponse

(text: string, body: unknown)

src/lib/usage/internalUsageCommand.ts:614

↓ 1 callersFunctioncreatePendingCommandCodeAuthSession

(input: { stateHash: string; expiresAt: string; })

src/lib/db/commandCodeAuth.ts:109

↓ 1 callersFunctioncreatePlaygroundPreset

(input: { name: string; endpoint: string; model: string; system: string | null | undefined; params:

src/lib/db/playgroundPresets.ts:83

↓ 1 callersFunctioncreatePreMigrationBackup

* Create a pre-migration backup of the SQLite database using VACUUM INTO. * Returns the backup path on success, null on failure.

src/lib/db/migrationRunner.ts:751

↓ 1 callersFunctioncreatePricedJudgeClient

( provider: string, credentials: ProviderCredentials )

src/lib/compression/judgeModelClient.ts:17

↓ 1 callersFunctioncreateProxyAndAssign

( payload: ProxyPayload, assignment: ProxyAssignmentPayload )

src/lib/db/proxies.ts:311

↓ 1 callersFunctioncreateRecoverableDb

(sqliteFile)

tests/unit/db-core-init.test.ts:206

↓ 1 callersFunctioncreateRelayToken

(input: CreateRelayTokenInput)

src/lib/db/relayProxies.ts:104

↓ 1 callersFunctioncreateRoundRobinDirectDispatcher

(connectionLimit: number)

open-sse/utils/proxyDispatcher.ts:132

↓ 1 callersFunctioncreateSSEEventPrefixBuffer

()

open-sse/utils/streamHelpers.ts:187

↓ 1 callersFunctioncreateSandbox

* createSandbox — capability-gated object passed to vm.createContext(). * * TRUST MODEL: vm is NOT a security boundary (shares the worker's V8 heap;

src/lib/plugins/pluginWorker.ts:55

↓ 1 callersFunctioncreateScorecardFromRuns

( runs: Array<{ suiteId: string; suiteName: string; summary: EvalRunSummary; results: Array<

src/lib/db/evals.ts:294

↓ 1 callersFunctioncreateSelectionLock

(key: string)

src/sse/services/auth.ts:965

↓ 1 callersFunctioncreateServerProcess

()

tests/integration/batch-e2e-rate-limit.test.ts:163

↓ 1 callersFunctioncreateServerProcess

(dataDir: string, port: number)

tests/integration/resilience-http-e2e.test.ts:183

↓ 1 callersFunctioncreateServerProcess

(dataDir: string, port: number)

tests/e2e/system-failover.test.ts:92

↓ 1 callersFunctioncreateSession

(opts?: { name?: string; profile?: "llm" | "custom" | "all"; })

src/lib/db/inspectorSessions.ts:38

↓ 1 callersMethodcreateSession

* Create a fresh session with new cookies and conversationId.

open-sse/executors/copilot-web.ts:191

↓ 1 callersFunctioncreateSessionToken

()

tests/unit/acp-agents-route.test.ts:27

↓ 1 callersFunctioncreateSettingsApiHarness

()

tests/unit/settings-api.test.ts:8

↓ 1 callersFunctioncreateSocksDispatcherWithFamily

( proxy: SocksProxy, family: 4 | 6 | null, agentOptions: Agent.Options = {} )

open-sse/utils/socksConnectorWithFamily.ts:77

↓ 1 callersFunctioncreateSqlJsLikeDb

()

tests/unit/db-migration-runner.test.ts:64

↓ 1 callersFunctioncreateStageExecutor

* Create a stageExecutor that wraps handleChatCore for pipeline stage execution. * * - Intermediate stages (stream:false): buffer the response, extr

open-sse/services/autoCombo/pipelineRouter.ts:124

↓ 1 callersFunctioncreateStreamResponse

( upstream: Response, model: string, signal?: AbortSignal | null )

open-sse/executors/commandCode.ts:442

↓ 1 callersFunctioncreateStreamTracker

(requestId, metadata)

src/sse/services/streamState.ts:189

↓ 1 callersFunctioncreateStreamableSession

()

open-sse/mcp-server/httpTransport.ts:103

↓ 1 callersFunctioncreateStreamingResponse

* Create streaming response with translation * Use translator to convert OpenAI chunks → sourceFormat

open-sse/utils/bypassHandler.ts:181

↓ 1 callersFunctioncreateStreamingState

()

open-sse/utils/composerToolCalls.ts:243

↓ 1 callersFunctioncreateSuccessFile

(batchId: string, current: any, results: any[])

open-sse/services/batchProcessor.ts:823

↓ 1 callersFunctioncreateSummarizer

()

open-sse/services/compression/summarizer.ts:242

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-backup-command.test.ts:9

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-providers-command.test.ts:12

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-combo-command.test.ts:10

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-serve-stop-command.test.ts:10

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-keys-command.test.ts:26

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-providers-rotate.test.ts:11

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-setup-command.test.ts:13

↓ 1 callersFunctioncreateTempDataDir

()

tests/unit/cli-doctor-command.test.ts:24

↓ 1 callersFunctioncreateTestAdapter

()

tests/unit/arena-elo-sync.test.ts:102

↓ 1 callersFunctioncreateTestStorage

()

src/shared/components/AutoRoutingBanner.test.tsx:9

↓ 1 callersFunctioncreateTestStorage

()

tests/unit/shared/components/AutoRoutingBanner.test.tsx:9

↓ 1 callersFunctioncrushMessages

( messages: MessageLike[], minRows: number = DEFAULT_MIN_ROWS )

open-sse/services/compression/engines/headroom/smartcrusher.ts:214

↓ 1 callersFunctioncryptoRandomFloat

Default source: uniform float in [0, 1) from 48 bits of crypto entropy.

src/shared/utils/secureRandom.ts:22

↓ 1 callersFunctionctx

()

tests/unit/authz/public-policy.test.ts:7

↓ 1 callersFunctioncurrentVersion

()

scripts/check/check-deprecated-versions.mjs:19

↓ 1 callersFunctiondashboardLoginRedirect

(request: NextRequest, requestId: string)

src/server/authz/pipeline.ts:150

↓ 1 callersFunctiondateMsOrNull

(value: DateLike)

src/lib/usage/apiKeySelfService.ts:87

↓ 1 callersFunctiondecideStep

( result: CompressionResult, bailout: BailoutConfig )

open-sse/services/compression/stackedStepCore.ts:53

← previous next →10,701–10,800 of 20,485, ranked by callers