MCPcopy Create free account

hub / github.com/Roy3838/Observer / functions

Functions2,101 in github.com/Roy3838/Observer

↓ 2 callersMethodteardownDisplayStream
()
app/src/utils/streamManager.ts:617
↓ 2 callersMethodteardownMicrophoneStream
()
app/src/utils/streamManager.ts:675
↓ 2 callersMethodteardownScreenAudioStream
()
app/src/utils/streamManager.ts:639
↓ 2 callersMethodtestGenerate
* Test generation with a simple prompt, returns response and metrics
app/src/utils/localLlm/NativeLlmManager.ts:915
↓ 2 callersMethodtranscribeLocalAsync
(audio: Float32Array, chunkId: number)
app/src/utils/whisper/UnifiedTranscriptionService.ts:233
↓ 2 callersMethodtranscribeSelfHostedAsync
(audio: Float32Array, chunkId: number)
app/src/utils/whisper/UnifiedTranscriptionService.ts:445
↓ 2 callersFunctionunusual_count
(tokens: &[String])
app/plugins/llm_engine/src/multimodal_thinking_repro.rs:128
↓ 2 callersMethodupdate
(update: ViewUpdate)
app/src/components/AgentCard/ToolsModal.tsx:619
↓ 2 callersMethodupdateCustomServerStatus
(address: string, status: 'online' | 'offline')
app/src/utils/ModelManager.ts:425
↓ 2 callersFunctionupdateDropdownPosition
()
app/src/components/AgentCard/StaticAgentView.tsx:450
↓ 2 callersFunctionupdatePopoverPosition
()
app/src/components/AgentCard/StaticAgentView.tsx:123
↓ 2 callersFunctionupdatePosition
()
app/src/components/ui/FixedDropdown.tsx:29
↓ 2 callersFunctionuseAllIterationData
(agentId: string, pollInterval = DEFAULT_POLL_INTERVAL)
app/src/hooks/useIterations.ts:158
↓ 2 callersFunctionuseHistoricalSessions
( agentId: string, pollInterval = 2000 // Historical data changes rarely )
app/src/hooks/useIterations.ts:129
↓ 2 callersFunctionuseIterations
( agentId: string, pollInterval = DEFAULT_POLL_INTERVAL )
app/src/hooks/useIterations.ts:18
↓ 2 callersFunctionuseTranscriptionState
(type: AudioStreamType)
app/src/hooks/useTranscriptionState.ts:10
↓ 2 callersFunctionuseWhitelistPolling
( initial: PhoneEntry[], getToken: () => Promise<string | undefined>, channel?: WhitelistChannel, enab
app/src/components/whitelist/shared.ts:63
↓ 2 callersMethodwaitForTargetSelection
* Wait for the user to pick a capture target in the selector window. * Resolves with the target id on selection, resolves `null` on a genuine *
app/src/utils/tauriStreamCapture.ts:1286
↓ 2 callersFunctionwakeAgentLoop
(agentId: string)
app/src/utils/main_loop.ts:65
↓ 1 callersFunctionApp
()
app/src/web/App.tsx:1360
↓ 1 callersMethod_acquireMasterStreamImpl
* Internal implementation of master stream acquisition
app/src/utils/browserStreamCapture.ts:158
↓ 1 callersMethod_acquireMasterStreamImpl
(type: MasterStreamType)
app/src/utils/tauriStreamCapture.ts:247
↓ 1 callersMethod_build_payload
(self, request_data: dict, target_model: str)
api/gemini_handler.py:73
↓ 1 callersMethod_convert_gemini_chunk_to_openai
Convert a Gemini streaming chunk to OpenAI format.
api/gemini_pro_handler.py:387
↓ 1 callersFunction_create_billing_portal
Try new Stripe first, fall back to legacy Stripe for old customers.
api/payments.py:183
↓ 1 callersFunction_emit_log
(level: &str, message: String)
app/plugins/llm_engine/src/lib.rs:25
↓ 1 callersMethod_generate_null_stream
Generate a minimal streaming response for the NULL model.
api/openrouter_handler.py:271
↓ 1 callersFunction_get_jwk_client
Get or create the JWK client for Apple's public keys.
api/apple_payments.py:52
↓ 1 callersMethod_handle_commands_stream_stub
Stub handler for /commands-stream SSE endpoint (not needed in headless mode).
docker/observer-ollama/observer_ollama/handler.py:136
↓ 1 callersMethod_handle_favicon_request
(self)
docker/observer-ollama/observer_ollama/handler.py:130
↓ 1 callersMethod_handle_legacy_translation
Handles the full request/response translation cycle. This contains the exact logic from your original _proxy_request method.
docker/observer-ollama/observer_ollama/handler.py:78
↓ 1 callersFunction_load_partners
Build the code -> partner-config map from OBSERVER_PARTNER_<ID>_* env vars.
api/payments.py:314
↓ 1 callersFunction_log_streaming_response
Wrapper that records the complete streaming response with timing metrics. Accumulates content from OpenAI SSE chunks and records when the str
api/compute.py:37
↓ 1 callersMethod_prepare_gemini_content
Extract and prepare content for Gemini API from OpenAI message content. Args: content: Either a string or a list of cont
api/gemini_pro_handler.py:338
↓ 1 callersFunction_send_abuse_alert_async
(user_id: str, service: str)
api/quota_manager.py:106
↓ 1 callersFunction_slugify
(name: str)
api/orgs.py:105
↓ 1 callersMethod_stream_fireworks_response
Stream SSE chunks from Fireworks API.
api/fireworks_handler.py:188
↓ 1 callersMethod_stream_gemini_response
Stream Gemini API response and convert to OpenAI SSE format.
api/gemini_pro_handler.py:225
↓ 1 callersMethod_stream_openrouter_response
Stream SSE chunks from OpenRouter API.
api/openrouter_handler.py:239
↓ 1 callersMethod_stream_response
(self, payload: dict)
api/gemini_handler.py:122
↓ 1 callersFunction_validate_apple_cert_chain
Validate the x5c certificate chain from an Apple JWS. Pins the root against Apple Root CA G3 and verifies each link in the chain. Returns
api/apple_payments.py:80
↓ 1 callersFunctionaccumulatorFor
(tc: any)
app/src/utils/sendApi.ts:193
↓ 1 callersMethodacquireService
* Acquire a transcription service for a stream type. * Returns existing service if one is active, otherwise creates a new one. * Uses reference
app/src/utils/whisper/TranscriptionRouter.ts:80
↓ 1 callersFunctionaddCustomServer
(address: string)
app/src/utils/inferenceServer.ts:57
↓ 1 callersMethodaddCustomServer
(address: string)
app/src/utils/ModelManager.ts:382
↓ 1 callersMethodaddMarker
(label: string)
app/src/utils/recordingManager.ts:46
↓ 1 callersFunctionadd_to_windows_path
(install_dir: &PathBuf)
app/desktop/src/install_cli.rs:97
↓ 1 callersFunctionagentHasCameraSensor
(systemPrompt: string)
app/src/components/AgentCard/agentCapabilities.tsx:206
↓ 1 callersFunctionagentHasScreenSensor
(systemPrompt: string)
app/src/components/AgentCard/agentCapabilities.tsx:199
↓ 1 callersFunctionappendAgentImageMemory
(agentId: string, images: string[])
app/src/utils/agent_database.ts:370
↓ 1 callersFunctionapply
(rec)
api/orgs.py:670
↓ 1 callersMethodapplyPersistedGpuSetting
* Apply persisted GPU setting to the engine * Call this before loading a model
app/src/utils/localLlm/NativeLlmManager.ts:879
↓ 1 callersFunctionat
(offset: number)
app/src/components/AICreator/OptionWheel.tsx:143
↓ 1 callersFunctionawaitGemmaLoaded
Resolve once the Gemma worker reaches `loaded` for `modelId` (or reject on `error`).
app/src/mcp/localModel.ts:35
↓ 1 callersFunctionbroadcast
()
app/src/utils/pullModelManager.ts:35
↓ 1 callersFunctionbroadcast_command
Internal function to broadcast a command via SSE (called by shortcut system)
app/desktop/src/commands.rs:90
↓ 1 callersFunctionbuildImageArg
(ctx: SensorContext)
app/src/utils/agentTemplateManager.ts:22
↓ 1 callersFunctionbuildKeyCombo
(event: KeyboardEvent)
app/src/components/SettingsTab.tsx:126
↓ 1 callersFunctionbuildKeyCombo
(event: KeyboardEvent)
app/src/desktop/LauncherShell.tsx:83
↓ 1 callersMethodbuild_chat_prompt
Build a chat prompt from messages using a simple template
app/plugins/llm_engine/src/lib.rs:632
↓ 1 callersFunctionbuild_engine
(model: PathBuf, mmproj: PathBuf, n_batch: u32, image_tokens: i32, n_ubatch: u32)
app/plugins/llm_engine/src/multimodal_thinking_repro.rs:90
↓ 1 callersMethodbuild_prompt_with_template
Build a prompt using the model's own Jinja chat template via the llama-cpp-2 API. Falls back to `build_chat_prompt` if the model has no embedded templ
app/plugins/llm_engine/src/lib.rs:574
↓ 1 callersFunctionbundled_binary_path
()
app/desktop/src/install_cli.rs:63
↓ 1 callersFunctioncalculateDHash
(base64Image: string, label: string)
app/src/utils/change_detector.ts:383
↓ 1 callersMethodcalculateDuration
(iteration: IterationData)
app/src/utils/IterationStore.ts:230
↓ 1 callersFunctioncalculateLevenshteinSimilarity
(str1: string, str2: string)
app/src/utils/change_detector.ts:161
↓ 1 callersMethodcancelGeneration
()
app/src/utils/localLlm/NativeLlmManager.ts:667
↓ 1 callersFunctioncaptureCameraImage
(_stream: MediaStream, agentId?: string)
app/src/utils/cameraCapture.ts:12
↓ 1 callersFunctioncaptureFrameAndOCR
(_stream: MediaStream, agentId?: string, streamType?: 'camera' | 'screen')
app/src/utils/screenOCR.ts:21
↓ 1 callersFunctioncaptureScreenImage
(_stream: MediaStream, agentId?: string, streamType?: 'camera' | 'screen')
app/src/utils/screenCapture.ts:63
↓ 1 callersFunctioncaptureScreenTauri
* Mobile app (Tauri iOS/Android): trigger the native picker via tauriStreamCapture — the * same singleton the agent loop acquires, so the live stream
app/src/mcp/registry.ts:191
↓ 1 callersFunctioncaptureScreenWeb
Web / mobile web: getDisplayMedia picker, grab one frame via a hidden <video>.
app/src/mcp/registry.ts:135
↓ 1 callersFunctioncapture_monitor_thumbnail
Capture a thumbnail of a monitor
app/plugins/screen-capture/src/targets.rs:181
↓ 1 callersFunctioncapture_pixel_dimensions
Determine the capture buffer size in PIXELS for a given content filter. `SCStreamConfiguration` sizes are in pixels, but `SCDisplay`/`SCWindow` frame
app/plugins/screen-capture/src/macos.rs:707
↓ 1 callersFunctioncapture_window_thumbnail
Capture a thumbnail of a window
app/plugins/screen-capture/src/targets.rs:189
↓ 1 callersFunctioncheck
()
app/src/components/LiveStream.tsx:14
↓ 1 callersFunctioncheck
(s = mgr.getState())
app/src/mcp/localModel.ts:38
↓ 1 callersFunctioncheckAll
()
app/src/components/whitelist/shared.ts:85
↓ 1 callersFunctioncheckCustomServer
(address: string)
app/src/utils/inferenceServer.ts:73
↓ 1 callersMethodcheckCustomServer
(address: string)
app/src/utils/ModelManager.ts:441
↓ 1 callersFunctioncheckDesktop
()
websites/landing/src/AgentDiagram.tsx:380
↓ 1 callersMethodcheckForTeardown
()
app/src/utils/streamManager.ts:606
↓ 1 callersFunctioncheckInferenceServer
(address: string)
app/src/utils/inferenceServer.ts:77
↓ 1 callersFunctioncheckLocalhost
()
app/src/components/ModelHub.tsx:243
↓ 1 callersFunctioncheckMobile
()
app/src/components/AgentCard/ToolsModal.tsx:987
↓ 1 callersFunctioncheckNumber
Check a single number against the whitelist API; resolves false on any failure.
app/src/components/whitelist/shared.ts:33
↓ 1 callersFunctioncheckOllamaSupport
(address: string)
app/src/components/AvailableModels.tsx:137
↓ 1 callersFunctioncheckProStatus
()
app/src/components/ObServerTab.tsx:26
↓ 1 callersFunctioncheckProStatus
()
app/src/components/UpgradeModal.tsx:96
↓ 1 callersFunctioncheckType
(value: any, type: string | undefined)
app/src/mcp/validate.ts:15
↓ 1 callersFunctioncheckVisibilityAndLoad
()
app/src/desktop/ScreenSelectorWindow.tsx:54
↓ 1 callersFunctioncheckWhitelistStatus
()
app/src/components/WhitelistModal.tsx:54
↓ 1 callersFunctioncheck_apple_subscription_by_email
Check if any Auth0 user with this email has an active Apple subscription. Queries Auth0 directly (not relying on JWT which could be stale).
api/auth0_manager.py:339
↓ 1 callersFunctioncheck_provider_seconds_quota
( user_id: str, audio_seconds: float, provider: str, is_pro: bool = False, is_max: bool = False, is_pl
api/quota_manager.py:249
↓ 1 callersFunctioncheck_whitelist
Check if a phone number is whitelisted for the given channel
cli/src/preflight.rs:15
↓ 1 callersMethodchunk_count
(&self)
app/mobile/src/audio_ring.rs:441
↓ 1 callersFunctionclampTop
(t: number)
app/src/components/LocalOnboardingTutorial.tsx:174
↓ 1 callersFunctionclampTop
(t: number)
app/src/components/EditAgent/SimpleCreatorTutorial.tsx:70
↓ 1 callersMethodcleanup
Clean up resources
app/mobile/gen/apple/broadcast/AudioRingBuffer.swift:170
↓ 1 callersMethodcleanupCloudMode
()
app/src/utils/whisper/UnifiedTranscriptionService.ts:399
← previousnext →401–500 of 2,101, ranked by callers