MCPcopy Create free account

hub / github.com/Roy3838/Observer / functions

Functions2,175 in github.com/Roy3838/Observer

⨍ Functions 2,175◇ Types & classes 458↳ Endpoints 52
↓ 2 callersMethodstart
(&self)
app/mobile/plugins/pip/src/mobile.rs:22
↓ 2 callersMethodstartClip
()
app/src/utils/recordingManager.ts:60
↓ 2 callersMethodstartTranscriptionForStream
(type: AudioStreamType, stream: MediaStream)
app/src/utils/streamManager.ts:703
↓ 2 callersMethodstart_capture
(&self)
app/plugins/screen-capture/src/mobile.rs:32
↓ 2 callersMethodstart_video_stream
(&self)
app/plugins/screen-capture/src/mobile.rs:99
↓ 2 callersMethodstop
* Stop the transcription service
app/src/utils/whisper/UnifiedTranscriptionService.ts:139
↓ 2 callersMethodstop
* Stop capturing system audio. */
app/plugins/screen-capture/android/src/main/java/com/plugin/screencapture/AudioCaptureManager.kt:159
↓ 2 callersMethodstop
(&self)
app/mobile/plugins/pip/src/mobile.rs:29
↓ 2 callersMethodstopClip
()
app/src/utils/recordingManager.ts:69
↓ 2 callersMethodsubscriberKey
* Create subscriber key from agentId and stream type
app/src/utils/streamManager.ts:185
↓ 2 callersMethodswitchCameraDevice
Switch to a different camera device (stops current stream and re-acquires with new device)
app/src/utils/streamManager.ts:318
↓ 2 callersFunctionsync_org_from_stripe
Reconcile an org record against Stripe. Called from the webhook when the event's customer carries an org_id in its metadata. Stripe is t
api/orgs.py:687
↓ 2 callersFunctionsync_user_from_stripe
Single idempotent function to sync a user's subscription state from Stripe to Auth0. Uses EMAIL as the link between Stripe and Auth0 (not cu
api/payments.py:691
↓ 2 callersFunctiontakeCompleteLines
* Split an SSE buffer into COMPLETE lines, leaving any trailing partial line behind. * * A network read is not aligned to line boundaries: a single
app/src/utils/sendApi.ts:93
↓ 2 callersFunctiontarget_fps
Target frames per second (an upper bound; static frames are dropped by the OS).
app/plugins/screen-capture/src/capture_config.rs:37
↓ 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 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
↓ 2 callersFunctionwhatsappCodeQRValue
(code: string)
app/src/components/whitelist/shared.ts:25
↓ 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 callersFunction_encode_batch
(batch: list[tuple])
api/usage_log.py:230
↓ 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_invalidate
()
api/marketplace.py:76
↓ 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 callersFunction_period_for
(day: datetime, bucket: str)
api/usage_log.py:341
↓ 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_rollup_field
(service: str, day: str)
api/usage_log.py:224
↓ 1 callersFunction_save_temp_video
( video_b64: str, max_size_mb: float, transcode: bool, scratch: Path )
api/messaging.py:354
↓ 1 callersFunction_send_abuse_alert_async
(user_id: str, service: str)
api/quota_manager.py:107
↓ 1 callersFunction_slugify
(name: str)
api/orgs.py:106
↓ 1 callersFunction_sorted
Featured first in their curated order, then most recent.
api/marketplace.py:108
↓ 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 callersFunction_write_archive
(batch: list[tuple])
api/usage_log.py:241
↓ 1 callersFunction_write_rollup
(batch: list[tuple])
api/usage_log.py:261
↓ 1 callersFunction_writer_loop
Drain the queue into the sinks in batches until cancelled.
api/usage_log.py:310
↓ 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:721
↓ 1 callersFunctionapply
(record: dict)
api/marketplace.py:87
↓ 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)
websites/landing/src/wheel/OptionWheel.tsx:146
↓ 1 callersFunctionat
(offset: number)
app/src/components/AICreator/OptionWheel.tsx:146
↓ 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
← previousnext →401–500 of 2,175, ranked by callers