Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Roy3838/Observer
/ functions
Functions
1,954 in github.com/Roy3838/Observer
⨍
Functions
1,954
◇
Types & classes
422
↳
Endpoints
41
↓ 4 callers
Method
downloadModel
* Download a GGUF model from a HuggingFace URL with progress reporting * @param url Full URL to the GGUF file (e.g., https://huggingface.co/user/re
app/src/utils/localLlm/NativeLlmManager.ts:391
↓ 4 callers
Method
fetchModels
* Fetch models from all sources (remote servers + refresh local cache)
app/src/utils/ModelManager.ts:261
↓ 4 callers
Method
getFilteredLogs
* Get logs filtered by criteria
app/src/utils/logging.ts:111
↓ 4 callers
Method
getInstance
(progress_callback?: (data: any) => void)
app/src/utils/whisper/whisper.worker.ts:56
↓ 4 callers
Function
getJupyterConfig
()
app/src/utils/handlers/JupyterConfig.ts:42
↓ 4 callers
Method
getLatestBase64Frame
* Get the latest base64 frame directly (for pre-processor). * Computes base64 lazily from raw bytes when needed.
app/src/utils/tauriStreamCapture.ts:433
↓ 4 callers
Method
getRuntimeSettings
()
app/src/utils/localLlm/GemmaModelManager.ts:315
↓ 4 callers
Function
get_audio_state
()
app/plugins/screen-capture/src/audio.rs:51
↓ 4 callers
Function
get_base_url
(client_url: str | None)
api/payments.py:119
↓ 4 callers
Method
get_sampler_params
Get the current sampler parameters
app/plugins/llm_engine/src/lib.rs:283
↓ 4 callers
Function
handleApiAction
(endpoint: 'create-checkout-session' | 'create-checkout-session-plus' | 'create-checkout-session-max' | 'creat
app/src/components/ObServerTab.tsx:47
↓ 4 callers
Function
handleApiAction
(endpoint: 'create-checkout-session' | 'create-checkout-session-plus' | 'create-checkout-session-max' | 'creat
app/src/components/UpgradeModal.tsx:116
↓ 4 callers
Method
isLocalModel
* Check if a server string represents a local model
app/src/utils/ModelManager.ts:707
↓ 4 callers
Method
is_loaded
Check if a model is loaded
app/plugins/llm_engine/src/lib.rs:273
↓ 4 callers
Function
is_whitelisted
Check if phone number (or key) is whitelisted for messaging. Uses Redis so all workers share the same state. TTL-based expiry is handled
api/messaging.py:122
↓ 4 callers
Method
listLocalModels
()
app/src/utils/localLlm/LocalModelManager.ts:24
↓ 4 callers
Method
listNativeModels
* Logical-model view of the registry. * * One entry per non-mmproj file (model). Each entry pairs that file with its * assigned projector (if
app/src/utils/localLlm/NativeLlmManager.ts:223
↓ 4 callers
Function
loadMemories
()
app/src/components/MemoryStoreTab.tsx:37
↓ 4 callers
Method
removeServer
* Remove an inference server address
app/src/utils/ModelManager.ts:341
↓ 4 callers
Method
save
Save tokens to file
cli/src/auth.rs:62
↓ 4 callers
Method
saveCustomServersToStorage
()
app/src/utils/ModelManager.ts:374
↓ 4 callers
Method
sendMessages
* Send messages to a model by name. Routes local models directly, remote models via fetchResponse.
app/src/utils/ModelManager.ts:731
↓ 4 callers
Method
set_sampler_params
Set the sampler parameters
app/plugins/llm_engine/src/lib.rs:288
↓ 4 callers
Method
set_use_gpu
Set whether to use GPU acceleration (Metal) Must be called before load_model to take effect
app/plugins/llm_engine/src/lib.rs:314
↓ 4 callers
Method
start
(getToken?: TokenProvider)
app/src/utils/commandSSE.ts:26
↓ 4 callers
Function
stop_audio
()
app/plugins/screen-capture/src/audio.rs:397
↓ 4 callers
Method
stop_capture
(&self)
app/plugins/screen-capture/src/mobile.rs:56
↓ 4 callers
Method
subscribe
(type: AudioStreamType, callback: StateListener)
app/src/utils/whisper/TranscriptionStateManager.ts:128
↓ 4 callers
Method
teardownMasterStream
* Teardown a specific master stream
app/src/utils/tauriStreamCapture.ts:322
↓ 4 callers
Method
unload
Unload the current model and free memory
app/plugins/llm_engine/src/lib.rs:260
↓ 4 callers
Function
updateAgentImageMemory
(agentId: string, images: string[])
app/src/utils/agent_database.ts:352
↓ 4 callers
Function
update_user_subscription_status
Updates a user's app_metadata in Auth0 to set their subscription status and link their payment provider IDs (Stripe or Apple). To CLEAR
api/auth0_manager.py:63
↓ 4 callers
Function
uploadAgentToServer
(agentData: AgentUpload)
app/src/components/CommunityTab.tsx:706
↓ 4 callers
Function
useApplePayments
()
app/src/hooks/useApplePayments.ts:79
↓ 3 callers
Function
abortError
()
app/src/mcp/useMCP.ts:48
↓ 3 callers
Method
acquireMasterStream
(type: MasterStreamType, captureImpl: typeof browserStreamCapture | typeof tauriStreamCapture)
app/src/utils/streamManager.ts:485
↓ 3 callers
Function
addInferenceAddress
(address: string)
app/src/utils/inferenceServer.ts:28
↓ 3 callers
Method
addServer
* Add an inference server address
app/src/utils/ModelManager.ts:332
↓ 3 callers
Function
add_to_whitelist
Add phone number to appropriate whitelist with 24h expiry in Redis. Optionally map a user-chosen key (like "pizza" or "Hey, I'm Roy") to the
api/messaging.py:143
↓ 3 callers
Method
captureFrame
* Capture a frame from a video stream. Returns base64 PNG or null. * * For Tauri screen capture: uses raw frame bytes from the channel directly.
app/src/utils/streamManager.ts:386
↓ 3 callers
Function
checkForSensitiveData
( code: string, agent: CompleteAgent, memory: string, uploadType: 'existing' | 'file' | 'edit'
app/src/components/CommunityTab.tsx:268
↓ 3 callers
Function
checkLocalServer
()
app/src/components/AppHeader.tsx:299
↓ 3 callers
Method
chunkRecordingStarted
( type: AudioStreamType, chunkDurationMs: number )
app/src/utils/whisper/TranscriptionStateManager.ts:49
↓ 3 callers
Method
chunkTranscriptionEnded
( type: AudioStreamType, text: string, chunkId: number )
app/src/utils/whisper/TranscriptionStateManager.ts:83
↓ 3 callers
Function
clear_audio_channel
Clear the audio channel
app/plugins/screen-capture/src/android.rs:245
↓ 3 callers
Function
clear_frame_channel
Clear the video channel
app/plugins/screen-capture/src/android.rs:228
↓ 3 callers
Method
commitToSubscribers
(text: string)
app/src/utils/whisper/UnifiedTranscriptionService.ts:180
↓ 3 callers
Method
configure
(config: WhisperModelConfig)
app/src/utils/whisper/whisper.worker.ts:50
↓ 3 callers
Function
ensure_capture_running
Ensure the unified capture is running
app/plugins/screen-capture/src/macos.rs:332
↓ 3 callers
Function
fetchResponse
( serverAddress: string, messages: Array<{role: string, content: any}>, modelName: string, token?: str
app/src/utils/sendApi.ts:324
↓ 3 callers
Function
find_mmproj_for_model
Find an mmproj file for a given model file
app/plugins/llm_engine/src/lib.rs:763
↓ 3 callers
Function
finish_selection
Hide the selector window and complete the awaiting request with a selection.
app/desktop/src/lib.rs:287
↓ 3 callers
Method
getActiveService
* Get the active service for a stream type without acquiring it. * Returns undefined if no service is active.
app/src/utils/whisper/TranscriptionRouter.ts:140
↓ 3 callers
Method
getInstance
()
app/src/utils/localLlm/NativeLlmManager.ts:146
↓ 3 callers
Method
getMcpYoloMode
()
app/src/utils/settings.ts:188
↓ 3 callers
Method
getOrCreateSubscriber
* Get or create a subscriber for an agent and stream type. * The subscriber accumulates transcripts independently for each agent.
app/src/utils/streamManager.ts:171
↓ 3 callers
Function
getRunningAgentIds
()
app/src/utils/main_loop.ts:455
↓ 3 callers
Method
getState
()
app/src/utils/localLlm/NativeLlmManager.ts:153
↓ 3 callers
Function
getSystemPrompt
()
app/src/utils/system_prompt.ts:4
↓ 3 callers
Method
getTranscript
()
app/src/utils/whisper/TranscriptionSubscriber.ts:63
↓ 3 callers
Function
get_capture_state
()
app/plugins/screen-capture/src/desktop.rs:53
↓ 3 callers
Method
get_models
Return the list of models supported by this handler.
api/api_handlers.py:70
↓ 3 callers
Function
get_or_create_stripe_customer
Get existing Stripe customer ID or create a new one with the Auth0 email. This ensures the Stripe customer always has the Auth0 email, preve
api/payments.py:265
↓ 3 callers
Function
get_tier_from_apple_product
Returns (is_pro, is_max, is_plus) for a given Apple product_id.
api/apple_payments.py:60
↓ 3 callers
Function
has_active_subscription
Single source-of-truth check for active subscriptions across all providers. - Apple: queries Auth0 metadata by email (cache of client-verifi
api/payments.py:61
↓ 3 callers
Function
isAgentLoopRunning
(agentId: string)
app/src/utils/main_loop.ts:448
↓ 3 callers
Function
listModels
()
app/src/utils/inferenceServer.ts:89
↓ 3 callers
Method
onModelsChange
* Subscribe to model list changes
app/src/utils/ModelManager.ts:716
↓ 3 callers
Method
optimisticUpdateQuota
()
app/src/utils/ModelManager.ts:805
↓ 3 callers
Method
prompt_channel_secret_interactive
Prompt for the secret/config value for a given channel using TUI
cli/src/config.rs:154
↓ 3 callers
Function
removeInferenceAddress
(address: string)
app/src/utils/inferenceServer.ts:32
↓ 3 callers
Function
resetState
()
app/src/utils/pullModelManager.ts:44
↓ 3 callers
Function
resolve_to_phone
Resolve a key or phone number to an actual whitelisted phone number. First checks if the input is a key in the Redis key_to_phone mapping.
api/messaging.py:98
↓ 3 callers
Function
save_config_to_disk
(app_handle: &AppHandle, config: &AppConfig)
app/desktop/src/shortcuts.rs:204
↓ 3 callers
Function
sendEmail
(message: string, emailAddress: string, authToken: string, images?: string[], videos?: string[])
app/src/utils/handlers/utils.ts:286
↓ 3 callers
Function
setAgentCrop
(agentId: string, streamType: 'camera' | 'screen', cropConfig: CropConfig | null)
app/src/utils/screenCapture.ts:27
↓ 3 callers
Method
setContextParams
(params: Partial<ContextParams>)
app/src/utils/localLlm/NativeLlmManager.ts:893
↓ 3 callers
Function
setImageMemory
(agentId: string, images: string[])
app/src/utils/handlers/utils.ts:104
↓ 3 callers
Method
setInterimText
Set interim text (replaces previous interim, for streaming services)
app/src/utils/whisper/TranscriptionSubscriber.ts:29
↓ 3 callers
Function
setState
(newState: Partial<PullState>)
app/src/utils/pullModelManager.ts:39
↓ 3 callers
Function
set_app_group_path
Set the App Group container path (called from Swift/iOS side)
app/mobile/src/audio_ring.rs:171
↓ 3 callers
Function
shouldPulse
(shortcutKey: string)
app/src/desktop/OverlayWindow.tsx:160
↓ 3 callers
Method
startNewBuffer
()
app/src/utils/recordingManager.ts:141
↓ 3 callers
Function
start_audio_stream
(on_audio: Channel<AudioData>)
app/plugins/screen-capture/src/audio.rs:381
↓ 3 callers
Function
start_capture_stream
Start video capture stream If capture is already running (for audio), reuses the existing stream
app/plugins/screen-capture/src/macos.rs:217
↓ 3 callers
Method
stopCloudStreamTimer
()
app/src/utils/whisper/UnifiedTranscriptionService.ts:365
↓ 3 callers
Function
stopMic
()
app/src/components/AICreator/MCP.tsx:481
↓ 3 callers
Method
stopTranscriptionForStream
(type: AudioStreamType)
app/src/utils/streamManager.ts:736
↓ 3 callers
Function
useMCPContext
()
app/src/mcp/MCPContext.tsx:46
↓ 3 callers
Function
useSubscriberText
( agentId: string, streamType: AudioStreamType )
app/src/hooks/useTranscriptionState.ts:42
↓ 3 callers
Function
verify_and_decode_jws
Verify and decode a JWS signed by Apple (StoreKit 2 transaction or notification). Apple StoreKit 2 uses certificate chain validation (x5c he
api/apple_payments.py:114
↓ 2 callers
Method
__init__
(self, message)
api/api_handlers.py:51
↓ 2 callers
Method
_convert_messages_to_gemini_format
Convert OpenAI format messages to Gemini API format. Returns: (system_instruction_dict or None, contents_list)
api/gemini_handler.py:330
↓ 2 callers
Method
_convert_messages_to_gemini_format
Convert OpenAI format messages to Gemini API format. Returns: (system_instruction_dict or None, contents_list)
api/gemini_pro_handler.py:298
↓ 2 callers
Method
_handle_modern_proxy
A pure, simple proxy that streams requests and responses directly.
docker/observer-ollama/observer_ollama/handler.py:55
↓ 2 callers
Function
_seconds_until_midnight
()
api/quota_manager.py:98
↓ 2 callers
Method
addSubscriber
(subscriber: TranscriptionSubscriber)
app/src/utils/whisper/UnifiedTranscriptionService.ts:164
↓ 2 callers
Method
buildDecorations
(_view: EditorView)
app/src/components/AgentCard/ToolsModal.tsx:625
↓ 2 callers
Method
cancelDownload
* Cancel an ongoing download - signals Rust to stop and delete partial file
app/src/utils/localLlm/NativeLlmManager.ts:469
↓ 2 callers
Function
checkPhoneWhitelist
( agentCode: string, getToken?: TokenProvider )
app/src/utils/pre-flight.ts:15
← previous
next →
101–200 of 1,954, ranked by callers