MCPcopy Create free account

hub / github.com/Roy3838/Observer / functions

Functions1,954 in github.com/Roy3838/Observer

⨍ Functions 1,954◇ Types & classes 422↳ Endpoints 41
↓ 2 callersFunctionload_image
(path: PathBuf)
app/plugins/llm_engine/src/multimodal_thinking_confirm.rs:27
↓ 2 callersFunctionlog_conversation_metrics
Log conversation metrics to memory (no disk I/O).
api/compute.py:95
↓ 2 callersFunctionlogout
Logout - delete stored tokens
cli/src/auth.rs:279
↓ 2 callersFunctionmax_width
Max output width in pixels; the source is downscaled to fit (aspect preserved).
app/plugins/screen-capture/src/capture_config.rs:27
↓ 2 callersFunctionmaybe_stop_capture
Stop capture if neither video nor audio is needed
app/plugins/screen-capture/src/macos.rs:661
↓ 2 callersFunctionmodel_id_from_filename
Extract model ID from a filename (removes .gguf extension)
app/plugins/llm_engine/src/lib.rs:750
↓ 2 callersFunctionnormalize_phone
Normalize phone number to E.164 format using phonenumbers library. Handles all country codes and formatting variations automatically. Ex
api/messaging.py:40
↓ 2 callersMethodnotifyListeners
()
app/src/utils/ModelManager.ts:723
↓ 2 callersFunctiononReasoningChunk
(chunk: string)
app/src/utils/main_loop.ts:334
↓ 2 callersFunctiononStreamChunk
(chunk: string)
app/src/utils/main_loop.ts:322
↓ 2 callersFunctionparseAgentResponse
(configText: string)
app/src/utils/agentParser.ts:125
↓ 2 callersFunctionparseArguments
(argsString: string)
app/src/components/AgentCard/ToolsModal.tsx:394
↓ 2 callersFunctionparseToolCalls
(code: string, channel?: WhitelistChannel)
app/src/components/AgentCard/ToolsModal.tsx:554
↓ 2 callersFunctionparse_target_id
Parse a target ID into its components
app/plugins/screen-capture/src/targets.rs:162
↓ 2 callersMethodpcmCallback
(samples, streamType)
app/src/utils/streamManager.ts:714
↓ 2 callersFunctionperformOCR
(imageData: string)
app/src/utils/screenOCR.ts:37
↓ 2 callersMethodpersistSettings
(filename: string)
app/src/utils/localLlm/NativeLlmManager.ts:709
↓ 2 callersFunctionphone_numbers_fuzzy_match
Fuzzy match two phone numbers using subsequence matching. Rules: 1. Both must have at least 8 digits (prevents "911" matching long numbe
api/messaging.py:65
↓ 2 callersFunctionpostProcess
( agentId: string, response: string, code: string, iterationId: string, // <-- New parameter
app/src/utils/post-processor.ts:12
↓ 2 callersFunctionpreProcess
(agentId: string, systemPrompt: string, iterationId?: string)
app/src/utils/pre-processor.ts:321
↓ 2 callersMethodpushCaptureConfig
* Push the persisted capture quality (max width / JPEG quality / FPS) to the Rust * backend. Called right before each desktop capture starts so the
app/src/utils/tauriStreamCapture.ts:145
↓ 2 callersFunctionpushTool
(id: string, result: ToolResult, name?: string)
app/src/mcp/runner.ts:114
↓ 2 callersMethodread
Read new frame from the buffer Returns (jpeg_bytes, width, height, timestamp) if new data is available
app/mobile/src/video_frame.rs:163
↓ 2 callersFunctionrenderChips
(chips: { icon: React.ElementType; label: string; icons?: React.ElementType[] }[])
websites/landing/src/AgentDiagram.tsx:187
↓ 2 callersMethodsaveAndFinishClip
()
app/src/utils/recordingManager.ts:81
↓ 2 callersMethodsaveInstallMap
(map: InstallMap)
app/src/utils/localLlm/GemmaModelManager.ts:284
↓ 2 callersMethodsaveToIndexedDB
()
app/src/utils/IterationStore.ts:286
↓ 2 callersFunctionsave_temp_image
Save base64 image to temp storage with compression and return public URL
api/messaging.py:207
↓ 2 callersFunctionsave_temp_video
Save base64 video to temp storage and return public URL. Args: video_b64: Base64-encoded video data max_size_mb: Maximum allowed
api/messaging.py:277
↓ 2 callersFunctionsealDanglingToolCalls
(wire: WireMessage[])
app/src/mcp/runner.ts:87
↓ 2 callersFunctionsendConversation
(allMessages: Message[])
app/src/components/AICreator/MultiAgentCreator.tsx:311
↓ 2 callersMethodsendPrompt
* Send a prompt through the appropriate backend for the given model. * - Local models (browser_local, llama_cpp_local): routed directly, no inferen
app/src/utils/ModelManager.ts:650
↓ 2 callersFunctionset
Store a new capture config. Values are clamped to sane ranges so a stray input field can't hand the capture pipeline a zero width or a 1000fps interva
app/plugins/screen-capture/src/capture_config.rs:20
↓ 2 callersFunctionsetDHashSimilarityThreshold
(threshold: number)
app/src/utils/change_detector.ts:51
↓ 2 callersMethodsetInterimToSubscribers
(text: string)
app/src/utils/whisper/UnifiedTranscriptionService.ts:174
↓ 2 callersMethodsetMcpYoloMode
(value: boolean)
app/src/utils/settings.ts:192
↓ 2 callersMethodsetPCMCallback
* Set PCM callback for unified transcription pipeline. * When set, decoded PCM samples (Float32Array @ 16kHz) are passed to this callback * inst
app/src/utils/tauriStreamCapture.ts:420
↓ 2 callersFunctionsetPixelSimilarityThreshold
(threshold: number)
app/src/utils/change_detector.ts:67
↓ 2 callersFunctionsetSuspiciousSimilarityThreshold
(threshold: number)
app/src/utils/change_detector.ts:59
↓ 2 callersFunctionsetTextSimilarityThreshold
(threshold: number)
app/src/utils/change_detector.ts:43
↓ 2 callersMethodsetUseGpu
* Set whether to use GPU acceleration (Metal) * Must be called BEFORE loading a model to take effect. * Setting is persisted to localStorage.
app/src/utils/localLlm/NativeLlmManager.ts:834
↓ 2 callersFunctionset_audio_channel
Store the audio channel from Tauri command
app/plugins/screen-capture/src/android.rs:236
↓ 2 callersMethodset_audio_channel
Set the audio channel for streaming
app/mobile/src/server.rs:96
↓ 2 callersFunctionset_frame_channel
Store the video channel from Tauri command
app/plugins/screen-capture/src/android.rs:217
↓ 2 callersMethodset_frame_channel
Set the frame channel for streaming
app/mobile/src/server.rs:90
↓ 2 callersFunctionset_log_emitter
Register a function that forwards log lines to the frontend. Call this once during Tauri setup before any engine activity. `f(level, message)` — level
app/plugins/llm_engine/src/lib.rs:18
↓ 2 callersMethodstart
( streamOrType: MediaStream | AudioStreamType, streamType?: AudioStreamType )
app/src/utils/whisper/UnifiedTranscriptionService.ts:67
↓ 2 callersMethodstart
* Start capturing system audio. * Audio is passed to Rust via JNI for resampling and channel delivery. */
app/plugins/screen-capture/android/src/main/java/com/plugin/screencapture/AudioCaptureManager.kt:57
↓ 2 callersMethodstartClip
()
app/src/utils/recordingManager.ts:60
↓ 2 callersMethodstartTranscriptionForStream
(type: AudioStreamType, stream: MediaStream)
app/src/utils/streamManager.ts:681
↓ 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 callersMethodstopClip
()
app/src/utils/recordingManager.ts:69
↓ 2 callersMethodsubscriberKey
* Create subscriber key from agentId and stream type
app/src/utils/streamManager.ts:163
↓ 2 callersMethodswitchCameraDevice
Switch to a different camera device (stops current stream and re-acquires with new device)
app/src/utils/streamManager.ts:296
↓ 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:516
↓ 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 callersMethodteardownCameraStream
()
app/src/utils/streamManager.ts:632
↓ 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 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
↓ 1 callersFunctionApp
()
app/src/web/App.tsx:1308
↓ 1 callersMethod_acquireMasterStreamImpl
* Internal implementation of master stream acquisition
app/src/utils/browserStreamCapture.ts:150
↓ 1 callersMethod_acquireMasterStreamImpl
(type: MasterStreamType)
app/src/utils/tauriStreamCapture.ts:247
↓ 1 callersMethod_convert_gemini_chunk_to_openai
Convert a Gemini streaming chunk to OpenAI format.
api/gemini_handler.py:425
↓ 1 callersMethod_convert_gemini_chunk_to_openai
Convert a Gemini streaming chunk to OpenAI format.
api/gemini_pro_handler.py:393
↓ 1 callersFunction_create_billing_portal
Try new Stripe first, fall back to legacy Stripe for old customers.
api/payments.py:137
↓ 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:281
↓ 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_log_streaming_response
Wrapper that logs complete streaming response with timing metrics. Accumulates content from OpenAI SSE chunks and logs when stream completes.
api/compute.py:238
↓ 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_handler.py:376
↓ 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:344
↓ 1 callersFunction_send_abuse_alert_async
(user_id: str, service: str)
api/quota_manager.py:105
↓ 1 callersMethod_stream_fireworks_response
Stream SSE chunks from Fireworks API.
api/fireworks_handler.py:181
↓ 1 callersMethod_stream_gemini_response
Stream Gemini API response and convert to OpenAI SSE format.
api/gemini_handler.py:263
↓ 1 callersMethod_stream_gemini_response
Stream Gemini API response and convert to OpenAI SSE format.
api/gemini_pro_handler.py:231
↓ 1 callersMethod_stream_openrouter_response
Stream SSE chunks from OpenRouter API.
api/openrouter_handler.py:249
↓ 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 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
← previousnext →301–400 of 1,954, ranked by callers