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
↓ 243 callersMethoderror
* Convenience method for error logs
app/src/utils/logging.ts:97
↓ 222 callersMethodinfo
* Convenience method for info logs
app/src/utils/logging.ts:83
↓ 93 callersMethodpush
* Add samples to the buffer * * @param samples - Float32Array of audio samples to add
app/src/utils/audio/pcmUtils.ts:162
↓ 81 callersMethoddebug
* Convenience method for debug logs
app/src/utils/logging.ts:76
↓ 69 callersMethodgetInstance
()
app/src/utils/commandSSE.ts:19
↓ 69 callersMethodwarn
* Convenience method for warning logs
app/src/utils/logging.ts:90
↓ 44 callersFunctionisTauri
()
app/src/utils/platform.ts:8
↓ 36 callersMethoddelete
Delete stored tokens
cli/src/auth.rs:81
↓ 29 callersMethodlog
* Add a new log entry
app/src/utils/logging.ts:44
↓ 23 callersFunctionisDesktop
()
app/src/utils/platform.ts:35
↓ 21 callersMethodload
Load tokens from file
cli/src/auth.rs:55
↓ 21 callersMethodread
Read new samples from the ring buffer Returns (samples, sample_rate, timestamp) if new data is available
app/mobile/src/audio_ring.rs:340
↓ 20 callersFunctionwith_engine
Get a reference to the global engine (initializes if needed)
app/plugins/llm_engine/src/lib.rs:739
↓ 18 callersFunctionnow
()
app/mobile/src/server.rs:120
↓ 17 callersMethodall
()
cli/src/config.rs:34
↓ 17 callersMethodstop
()
app/src/utils/commandSSE.ts:41
↓ 16 callersFunctionisWeb
()
app/src/utils/platform.ts:58
↓ 15 callersFunctionopenDB
()
app/src/utils/agent_database.ts:27
↓ 15 callersFunctionplatformFetch
( input: RequestInfo | URL, init?: RequestInit )
app/src/utils/platform.ts:238
↓ 13 callersMethodclear
Clear accumulated transcript (call at end of agent loop)
app/src/utils/whisper/TranscriptionSubscriber.ts:35
↓ 12 callersMethodlistModels
* List all models from all sources (remote + local)
app/src/utils/ModelManager.ts:194
↓ 11 callersMethodaddListener
(listener: StreamListener)
app/src/utils/streamManager.ts:246
↓ 11 callersMethodgetState
()
app/src/utils/localLlm/LocalModelManager.ts:23
↓ 11 callersMethodgetWhisperSettings
()
app/src/utils/settings.ts:61
↓ 10 callersFunctionfetchModels
()
app/src/utils/inferenceServer.ts:97
↓ 10 callersFunctionget_redis
()
api/quota_manager.py:91
↓ 10 callersMethodremoveListener
(listener: StreamListener)
app/src/utils/streamManager.ts:247
↓ 9 callersMethodflush
* Flush and concatenate all samples * * @returns Concatenated Float32Array of all buffered samples
app/src/utils/audio/pcmUtils.ts:193
↓ 9 callersFunctiongetAgentCode
(agentId: string)
app/src/utils/agent_database.ts:255
↓ 9 callersFunctiongetAgentMemory
(agentId: string)
app/src/utils/agent_database.ts:272
↓ 9 callersMethodgetIterationsForAgent
(agentId: string)
app/src/utils/IterationStore.ts:393
↓ 9 callersMethodreleaseStreamsForAgent
Releases all streams used by a specific agent.
app/src/utils/streamManager.ts:148
↓ 9 callersMethodrequestStreamsForAgent
The primary method for acquiring streams, using a "blueprint" approach.
app/src/utils/streamManager.ts:96
↓ 9 callersFunctionsleep
(ms: number = 2000, agentId?: string)
app/src/utils/handlers/utils.ts:754
↓ 8 callersFunction_get_management_api_token
Fetches a fresh access token for the Auth0 Management API. Uses in-memory cache with 4-hour expiration to reduce API calls.
api/auth0_manager.py:22
↓ 8 callersFunctionformatTimestamp
(timestamp: string)
app/src/utils/exportUtils.ts:88
↓ 8 callersMethodgenerate
(messages: LocalLlmMessage[], onToken?: (token: string) => void)
app/src/utils/localLlm/LocalModelManager.ts:20
↓ 8 callersFunctiongetAgent
(agentId: string)
app/src/utils/agent_database.ts:195
↓ 8 callersMethodgetCurrentState
()
app/src/utils/streamManager.ts:249
↓ 8 callersMethodgetInstance
()
app/src/utils/ModelManager.ts:180
↓ 8 callersMethodget_context_params
Get the current context parameters
app/plugins/llm_engine/src/lib.rs:293
↓ 8 callersFunctionget_http_client
Return the shared HTTP client. Requires startup_handlers() to have run.
api/api_handlers.py:20
↓ 8 callersFunctionget_state
()
app/plugins/screen-capture/src/android.rs:210
↓ 8 callersFunctionisIOS
()
app/src/utils/platform.ts:42
↓ 8 callersFunctionisMobile
()
app/src/utils/platform.ts:18
↓ 8 callersMethodisReady
()
app/src/utils/localLlm/LocalModelManager.ts:16
↓ 8 callersMethodnotifyListeners
()
app/src/utils/streamManager.ts:755
↓ 8 callersMethodonStateChange
(listener: (state: any) => void)
app/src/utils/localLlm/LocalModelManager.ts:22
↓ 8 callersMethodsetWhisperSettings
(settings: WhisperSettings)
app/src/utils/settings.ts:111
↓ 7 callersMethodapply
app/mobile/gen/android/buildSrc/src/main/java/com/observer/ai/kotlin/RustPlugin.kt:17
↓ 7 callersFunctioncheck_usage
( user_id: str, service: str, is_pro: bool = False, is_max: bool = False, is_plus: bool = False )
api/quota_manager.py:150
↓ 7 callersFunctionconfirm
(message: string)
app/src/utils/platform.ts:138
↓ 7 callersFunctionfetchAgents
()
app/src/components/CommunityTab.tsx:209
↓ 7 callersFunctionincrement_usage
(user_id: str, service: str)
api/quota_manager.py:122
↓ 7 callersFunctionlistener
(entry: LogEntry)
app/src/components/ModelHub.tsx:231
↓ 7 callersMethodnotify
(type: AudioStreamType)
app/src/utils/whisper/TranscriptionStateManager.ts:142
↓ 7 callersMethodsetState
(updates: Partial<NativeModelState>)
app/src/utils/localLlm/NativeLlmManager.ts:164
↓ 7 callersMethodset_context_params
Set context parameters (takes effect on the next generate() call)
app/plugins/llm_engine/src/lib.rs:298
↓ 7 callersFunctionstopAgentLoop
(agentId: string)
app/src/utils/main_loop.ts:207
↓ 7 callersFunctionuseAuth
()
app/src/contexts/AuthContext.tsx:119
↓ 6 callersMethodformat_duration
Format duration as human-readable string
cli/src/runner.rs:13
↓ 6 callersFunctiongetAgentImageMemory
(agentId: string)
app/src/utils/agent_database.ts:321
↓ 6 callersMethodgetHistoricalSessions
(agentId: string)
app/src/utils/IterationStore.ts:446
↓ 6 callersMethodgetSelfHostedWhisperUrl
()
app/src/utils/settings.ts:177
↓ 6 callersFunctionget_capture_state
()
app/plugins/screen-capture/src/macos.rs:92
↓ 6 callersFunctionhandleQuotaExceeded
* Helper function to handle 429 quota exceeded responses. * Extracts quota type from error response and logs appropriately. * @param response The fe
app/src/utils/handlers/utils.ts:20
↓ 6 callersFunctionlistAgents
()
app/src/utils/agent_database.ts:162
↓ 6 callersMethodloadModel
* Load a model into memory for inference. * If mmprojFilename is omitted, the persisted assignment map is checked. * If neither is set, the mode
app/src/utils/localLlm/NativeLlmManager.ts:523
↓ 6 callersFunctionlogin
Start the device code login flow
cli/src/auth.rs:125
↓ 6 callersMethodrefreshGgufCache
()
app/src/utils/localLlm/NativeLlmManager.ts:382
↓ 6 callersMethodresample
Resample audio from source rate to 16kHz # Arguments `input` - Mono f32 samples at the source sample rate # Returns Resampled mono f32 samples at 16
app/plugins/screen-capture/src/audio_pipeline.rs:76
↓ 6 callersFunctionsaveAgent
( agent: CompleteAgent, code: string )
app/src/utils/agent_database.ts:73
↓ 6 callersMethodsetState
(updates: Partial<WhisperModelState>)
app/src/utils/whisper/WhisperModelManager.ts:55
↓ 6 callersFunctionstop_capture
()
app/plugins/screen-capture/src/audio.rs:353
↓ 6 callersFunctionupdateAgentMemory
(agentId: string, memory: string)
app/src/utils/agent_database.ts:303
↓ 5 callersFunctionclearParam
(key: keyof InferenceParams)
app/src/components/InferenceParamsEditor.tsx:72
↓ 5 callersFunctiondecode_base64_image
Decode a base64 image string to raw bytes
app/plugins/llm_engine/src/lib.rs:798
↓ 5 callersMethodgetDebugInfo
* Get comprehensive debug info including sampler params and metrics
app/src/utils/localLlm/NativeLlmManager.ts:798
↓ 5 callersMethodgetInstallMap
()
app/src/utils/localLlm/GemmaModelManager.ts:246
↓ 5 callersMethodgetMmprojAssignments
()
app/src/utils/localLlm/NativeLlmManager.ts:91
↓ 5 callersMethodgetModelParams
(modelName: string)
app/src/utils/ModelManager.ts:613
↓ 5 callersMethodgetState
(type: AudioStreamType)
app/src/utils/whisper/TranscriptionStateManager.ts:124
↓ 5 callersFunctiongetVideoScale
()
app/src/components/AgentCard/SensorPreviewPanel.tsx:43
↓ 5 callersMethodget_last_metrics
Get the last generation metrics
app/plugins/llm_engine/src/lib.rs:320
↓ 5 callersFunctionhandleParamChange
(key: keyof InferenceParams, value: any)
app/src/components/InferenceParamsEditor.tsx:61
↓ 5 callersFunctioninit_engine
Initialize the global LLM engine
app/plugins/llm_engine/src/lib.rs:719
↓ 5 callersMethodlistGgufFiles
* List all GGUF files in the models directory (async, updates cache). * Both model files and projector files are returned — no filtering.
app/src/utils/localLlm/NativeLlmManager.ts:173
↓ 5 callersMethodloadModelWithSettings
* Load a model with explicit settings. Saves settings for future loads. * Use this when the user explicitly changes settings in the UI.
app/src/utils/localLlm/GemmaModelManager.ts:78
↓ 5 callersMethodload_model
Load a GGUF model from the given path. Loads a model from `model_path`. If `mmproj_path` is provided, the multimodal projector is loaded alongside it;
app/plugins/llm_engine/src/lib.rs:192
↓ 5 callersMethodopenIterationDB
()
app/src/utils/IterationStore.ts:239
↓ 5 callersMethodsend_cors_headers
Send the appropriate CORS headers.
docker/observer-ollama/observer_ollama/cors.py:8
↓ 5 callersFunctionsetMemory
(agentId: string, memory: any)
app/src/utils/handlers/utils.ts:81
↓ 5 callersMethodsetMmprojAssignment
(modelFilename: string, mmprojFilename: string | null)
app/src/utils/localLlm/NativeLlmManager.ts:100
↓ 5 callersMethodsetSamplerParams
* Set sampler parameters for text generation
app/src/utils/localLlm/NativeLlmManager.ts:812
↓ 5 callersMethodsetState
(updates: Partial<GemmaModelState>)
app/src/utils/localLlm/GemmaModelManager.ts:59
↓ 5 callersFunctionstartAgentLoop
(agentId: string, getToken?: TokenProvider, skipWhitelistCheck = false)
app/src/utils/main_loop.ts:78
↓ 5 callersMethodunloadModel
()
app/src/utils/localLlm/LocalModelManager.ts:21
↓ 4 callersFunction_get_subscription_from_metadata
Fast subscription check using JWT app_metadata (kept current by Stripe/Apple webhooks). Returns (has_subscription, subscription_id, provider
api/payments.py:245
↓ 4 callersFunctionagentHasSensor
(systemPrompt: string, sensorKey: string)
app/src/components/AgentCard/agentCapabilities.tsx:192
↓ 4 callersMethoddestroySubscribersForAgent
* Destroy all subscribers for an agent. * Called when an agent stops.
app/src/utils/streamManager.ts:222
next →1–100 of 1,954, ranked by callers