MCPcopy Create free account

hub / github.com/ZingerLittleBee/ServerBee / functions

Functions6,739 in github.com/ZingerLittleBee/ServerBee

⨍ Functions 6,739◇ Types & classes 1,185
↓ 8 callersFunctionbaseServer
(overrides: Partial<ServerMetrics> = {})
apps/web/src/hooks/use-servers-ws.test.ts:265
↓ 8 callersFunctionbuild_test_state
Build an `Arc<AppState>` backed by a fresh migrated test DB. The two returned `TempDir` guards must outlive the test: one owns the SQLite file, the ot
crates/server/src/task/task_scheduler.rs:497
↓ 8 callersMethodcapability_denied_reason
Returns `Some(reason)` when `cap_bit` is NOT available on the agent, or `None` when it is allowed. `mirror_caps` is the persisted `servers.capabilitie
crates/server/src/service/agent_manager.rs:561
↓ 8 callersFunctionclassify
Classify a Disney+ probe response. - Redirect to a URL containing "not-available" or "unavailable" => `Blocked` - Body contains "notInSupportedLocati
crates/agent/src/ip_quality/detectors/disney_plus.rs:49
↓ 8 callersFunctionclassify
Classify a Spotify probe response.
crates/agent/src/ip_quality/detectors/spotify.rs:39
↓ 8 callersFunctioncompute_local_capabilities
Compute the agent's local capability bitmask. The config file is the source of truth (`[capabilities]` allow/deny over `CAP_DEFAULT`); CLI `--allow-ca
crates/agent/src/capability_policy.rs:46
↓ 8 callersFunctionconnect_agent
Register a connected agent with a real mpsc sender so `get_sender` returns `Some`. Returns the receiver so the channel stays open and we can inspect d
crates/server/src/service/ping.rs:495
↓ 8 callersFunctioncreateTestQueryClient
()
apps/web/src/hooks/use-dashboard.test.tsx:14
↓ 8 callersFunctioncreateWrapper
(queryClient: QueryClient)
apps/web/src/hooks/use-dashboard.test.tsx:23
↓ 8 callersFunctioncreate_api_key
( State(state): State<Arc<AppState>>, Extension(current_user): Extension<CurrentUser>, ConnectInfo
crates/server/src/router/api/auth.rs:309
↓ 8 callersFunctiondefineWidget
( input: DefineWidgetInput<TSchema> )
packages/widget-sdk/src/define-widget.ts:40
↓ 8 callersFunctiondrain_messages
Drain all currently-buffered messages from the agent's receiver.
crates/server/src/service/ping.rs:752
↓ 8 callersFunctionexecute_scheduled_task
Called by cron trigger or manual /run endpoint. `skip_retry`: if true, executes once without retry (used by manual trigger). Returns true if execution
crates/server/src/task/task_scheduler.rs:27
↓ 8 callersFunctionformatUptime
(seconds: number)
apps/web/src/lib/utils.ts:63
↓ 8 callersFunctiongetLatencySquareColor
({ latencyMs, lossRatio }: CombinedSeverityInput)
apps/web/src/lib/network-latency-constants.ts:123
↓ 8 callersFunctiongetLossSquareColor
(lossRatio: number | null | undefined)
apps/web/src/lib/network-latency-constants.ts:136
↓ 8 callersFunctionget_overview
( State(state): State<Arc<AppState>>, )
crates/server/src/router/api/ip_quality.rs:134
↓ 8 callersFunctionget_server_summary
( State(state): State<Arc<AppState>>, Path(id): Path<String>, )
crates/server/src/router/api/ip_quality.rs:152
↓ 8 callersFunctioninsert_block
Insert a `block_list` row and return its persisted Model.
crates/server/src/service/firewall.rs:987
↓ 8 callersFunctioninsert_completed_record
( db: &DatabaseConnection, record: NewTracerouteRecord, )
crates/server/src/service/traceroute.rs:141
↓ 8 callersFunctioninsert_server_with_billing
( db: &DatabaseConnection, id: &str, billing_cycle: Option<&str>, billing_star
crates/server/src/service/traffic.rs:1011
↓ 8 callersFunctioninsert_test_server
Seed a minimal `servers` row with the given capabilities mirror.
crates/server/src/service/ping.rs:439
↓ 8 callersMethodlatest
(&self)
crates/server/src/service/upgrade_release.rs:78
↓ 8 callersFunctionmakeSummary
(latency_sparkline: (number | null)[], loss_sparkline: (number | null)[])
apps/web/src/lib/sparkline.test.ts:15
↓ 8 callersMethodmark_triggered
( &self, db: &DatabaseConnection, rule_id: &str, server_id: &str, even
crates/server/src/service/alert.rs:317
↓ 8 callersFunctionmk
(online: boolean, targets: [number | null, number][])
apps/web/src/components/status/network-overview-content.test.ts:5
↓ 8 callersMethodon
(event: 'proxyReq', handler: (...args: DevProxyHookEventMap['proxyReq']) => void)
apps/web/vite/dev-proxy.ts:45
↓ 8 callersFunctionoutcome
(status: u16, body: &str, final_url: &str, redirects: Vec<&str>)
crates/agent/src/ip_quality/detectors/disney_plus.rs:99
↓ 8 callersFunctionoutcome
(status: u16, body: &str, final_url: &str, redirects: Vec<&str>)
crates/agent/src/ip_quality/detectors/spotify.rs:86
↓ 8 callersFunctionparseInlineTokens
(input: string, keyPrefix: string)
apps/web/src/components/dashboard/markdown-content.tsx:102
↓ 8 callersFunctionpersist_rebind_token_impl
(path: impl AsRef<Path>, token: &str)
crates/agent/src/rebind.rs:45
↓ 8 callersFunctionping_tasks_from
(msgs: &[ServerMessage])
crates/server/src/service/ping.rs:760
↓ 8 callersFunctionprobe_http
Perform an HTTP GET probe to `url`.
crates/agent/src/probe_utils.rs:159
↓ 8 callersFunctionrun_connect_once
Drive `connect_and_report` to completion (or error) with no external stream, bounded by `dur`. Returns the loop's result; `Elapsed` on the outer timeo
crates/agent/src/reporter.rs:3126
↓ 8 callersFunctionsend_agent_frame
Send a single agent frame as a JSON text message.
crates/server/tests/ws_agent_dispatch2.rs:63
↓ 8 callersFunctionsend_system_info
( sink: &mut futures_util::stream::SplitSink< tokio_tungstenite::WebSocketStream< toki
crates/server/tests/integration.rs:269
↓ 8 callersMethodserver_cleanup_lock
(&self, server_id: &str)
crates/server/src/service/agent_manager.rs:283
↓ 8 callersMethodstart_job
( &self, server_id: impl Into<String>, target_version: impl Into<String>, )
crates/server/src/service/upgrade_tracker.rs:103
↓ 8 callersMethodstop_all
(&mut self)
crates/agent/src/pinger.rs:89
↓ 8 callersFunctiontest_agent_manager
()
crates/server/src/service/network_probe.rs:1371
↓ 8 callersFunctionuseServer
(id: string)
apps/web/src/hooks/use-api.ts:7
↓ 8 callersFunctionvalidate_and_consume_state
Validate and atomically consume the stored OAuth flow state. `remove` makes the state single-use (replay-safe). Returns the flow state on success, or
crates/server/src/router/api/oauth.rs:102
↓ 8 callersFunctionwire_agent
Wire an online agent into the manager with a ServerMessage receiver, a negotiated protocol version, and an effective capability bitmask.
crates/server/src/service/firewall.rs:1050
↓ 7 callersFunctionapplyStrategy
(strategy: SizingStrategy, measuredFineH?: number)
apps/web/src/components/dashboard/sizing-strategies/index.ts:65
↓ 7 callersMethodas_str
(&self)
crates/server/src/router/api/rate_limit.rs:41
↓ 7 callersMethodauto_block
Insert a `block_list` row from a matched security rule's `block_source_ip` action, push the new entry to covered agents, and audit/broadcast the chang
crates/server/src/service/firewall.rs:377
↓ 7 callersFunctionblock_model
(id: &str, target: &str, cover_type: &str, server_ids_json: Option<&str>)
crates/server/src/service/firewall.rs:1065
↓ 7 callersFunctioncategoryLabel
(category: string)
apps/web/src/lib/ip-quality-constants.ts:15
↓ 7 callersFunctioncheck
(target_cidr: &str, own_external_ip: Option<IpAddr>)
crates/agent/src/firewall/guardrail.rs:9
↓ 7 callersFunctionclassify
Classify a Max (HBO Max) probe response.
crates/agent/src/ip_quality/detectors/hbo_max.rs:37
↓ 7 callersFunctionclassify
Classify a Google Gemini probe response.
crates/agent/src/ip_quality/detectors/gemini.rs:43
↓ 7 callersFunctionclassify_fallback
Classify a ChatGPT fallback (homepage) response.
crates/agent/src/ip_quality/detectors/chatgpt.rs:99
↓ 7 callersFunctioncomputeAggregateUptime
(days: UptimeDailyEntry[])
apps/web/src/lib/widget-helpers.ts:181
↓ 7 callersFunctionconnect_agent
( base_url: &str, token: &str, )
crates/server/tests/docker_integration.rs:192
↓ 7 callersFunctionevaluate
Pure: given the previous active-grant bits and a freshly-loaded store, compute new effective caps, new active bits, the active-grant DTOs, and the cha
crates/agent/src/capability_grants/supervisor.rs:18
↓ 7 callersFunctionformatCountdown
(secs: number)
apps/web/src/hooks/use-countdown.ts:20
↓ 7 callersFunctiongate_subpage
Verify the relevant `show_*` toggle on top of `enabled` (already checked).
crates/server/src/router/api/status.rs:166
↓ 7 callersFunctiongenerate
Generate a machine fingerprint from stable host identity. Returns empty string if machine_id is unavailable (caller should skip fingerprint).
crates/agent/src/fingerprint.rs:5
↓ 7 callersFunctiongetLossDotBgClass
(lossRatio: number | null | undefined)
apps/web/src/lib/network-latency-constants.ts:110
↓ 7 callersFunctioninsert_test_rule
Helper: insert an alert rule into the database.
crates/server/src/service/alert.rs:1678
↓ 7 callersFunctionis_ignorable_push
First-connect pushes the server emits to a default agent that the file flow has no interest in. Ignore them so protocol drift on the real commands sti
crates/server/tests/router_file_extra.rs:52
↓ 7 callersFunctionlist_audit_entries
(client: &reqwest::Client, base_url: &str)
crates/server/tests/integration.rs:147
↓ 7 callersFunctionlogin_admin
(client: &Client, base_url: &str)
crates/server/tests/docker_integration.rs:98
↓ 7 callersFunctionmakeServer
(id: string)
apps/web/src/widgets-runtime/runtime-bridge.test.ts:8
↓ 7 callersFunctionmakeServer
(id: string, overrides: Partial<ServerMetrics> = {})
apps/web/src/components/dashboard/widgets/gauge.test.tsx:6
↓ 7 callersFunctionmake_manager
()
crates/server/src/service/public_status.rs:980
↓ 7 callersMethodname
(&self)
crates/server/src/service/ip_risk.rs:585
↓ 7 callersFunctionnew_record
(server_id: &str, request_id: &str, target: &str)
crates/server/src/service/traceroute.rs:179
↓ 7 callersMethodnotify_unavailable
(&self, msg_id: Option<String>)
crates/agent/src/docker/mod.rs:407
↓ 7 callersFunctionoutcome
(status: u16, body: &str, final_url: &str, redirects: Vec<&str>)
crates/agent/src/ip_quality/detectors/hbo_max.rs:89
↓ 7 callersFunctionoutcome
(status: u16, body: &str, final_url: &str, redirects: Vec<&str>)
crates/agent/src/ip_quality/detectors/gemini.rs:98
↓ 7 callersFunctionparse_log_output
(output: &bollard::container::LogOutput)
crates/agent/src/docker/logs.rs:120
↓ 7 callersFunctionprobe_tcp
Perform a TCP connect probe to `host` (format `host:port`). If no port is specified, port 80 is used.
crates/agent/src/probe_utils.rs:116
↓ 7 callersMethodread_file
Read a file and return its content as base64-encoded string.
crates/agent/src/file_manager.rs:288
↓ 7 callersMethodreceive_chunk
Receive a chunk for an active upload. Returns the new written offset.
crates/agent/src/file_manager.rs:488
↓ 7 callersMethodrender
()
apps/web/src/components/dashboard/widget-renderer.tsx:69
↓ 7 callersFunctionrender_html
(ctx: &NotifyContext)
crates/server/src/service/notification.rs:101
↓ 7 callersFunctionreq
(url: &str)
crates/agent/src/ip_quality/http.rs:307
↓ 7 callersFunctionrun_once
Run a single complete unlock check for all configured services. Returns the per-service results and the timestamp at which the run completed. The egr
crates/agent/src/ip_quality/mod.rs:170
↓ 7 callersMethodscore_ip_with
Score an IP using explicitly provided primary and fallback risk providers. `score_ip` delegates here after resolving providers from config; tests inj
crates/server/src/service/ip_risk.rs:301
↓ 7 callersFunctionseed_must_change_admin
(db: &DatabaseConnection)
crates/server/src/service/auth.rs:1090
↓ 7 callersFunctionseed_pending_server
(db: &DatabaseConnection)
crates/server/src/service/enrollment.rs:171
↓ 7 callersFunctionseed_user
(db: &DatabaseConnection)
crates/server/src/service/enrollment.rs:151
↓ 7 callersFunctionselect_due_monitors
Update the per-monitor `schedule` against the current monitor set and return the monitors that are due for a check at `now`. This is the deterministi
crates/server/src/task/service_monitor_checker.rs:80
↓ 7 callersFunctionsend_client_text
Send a JSON text frame on a generic client socket.
crates/server/tests/ws_docker_browser.rs:202
↓ 7 callersMethodstart_download
Start a background download task that streams file chunks.
crates/agent/src/file_manager.rs:385
↓ 7 callersFunctionstripAnsi
(input: string)
apps/web/src/lib/ansi.ts:19
↓ 7 callersMethodupdate_progress
(&self, transfer_id: &str, bytes: u64)
crates/server/src/service/file_transfer.rs:164
↓ 7 callersFunctionuseServerRecords
(id: string, hours: number, interval: string, options?: { enabled?: boolean })
apps/web/src/hooks/use-api.ts:15
↓ 7 callersFunctionvalidate_alert_rule_items
Validate the shape of `AlertRuleItem`s for create/update paths. Security rule types are restricted to one item per rule and may not be mixed with oth
crates/server/src/service/alert.rs:133
↓ 7 callersFunctionwidgetsToLayout
(widgets: DashboardWidget[])
apps/web/src/components/dashboard/dashboard-layout.ts:35
↓ 6 callersFunctionapplyCoarsePatch
(item: LayoutItem, patch: SnapPatch)
apps/web/src/components/dashboard/sizing-strategies/index.ts:20
↓ 6 callersFunctionbring_up_docker_agent
Bring up a mock agent advertising the `docker` feature plus the given capability bitmask, then drain first-connect noise. Returns `(server_id, sink, r
crates/server/tests/ws_docker_browser.rs:110
↓ 6 callersFunctionbroadcast_ip_quality_sync
Re-send `IpQualitySync` to every currently-online agent. Spec §4 requires `IpQualitySync` to be pushed on connect, on catalog change, and on settings
crates/server/src/router/api/ip_quality.rs:55
↓ 6 callersFunctionbuildServerCardNetworkState
( summary: Pick<NetworkServerSummary, 'latency_sparkline' | 'loss_sparkline' | 'targets' | 'last_probe_at'>
apps/web/src/components/server/server-card-network-data.ts:277
↓ 6 callersFunctioncalculate_cpu_percent
(stats: &Stats)
crates/agent/src/docker/containers.rs:138
↓ 6 callersFunctionclassify
Classify an Amazon Prime Video probe response.
crates/agent/src/ip_quality/detectors/amazon_prime.rs:41
↓ 6 callersFunctionclassify
Classify the pair of Netflix responses: - `non_orig`: outcome for the non-original title probe. - `orig`: outcome for the Netflix-original title p
crates/agent/src/ip_quality/detectors/netflix.rs:51
↓ 6 callersFunctionclassify
Classify a YouTube Premium probe response.
crates/agent/src/ip_quality/detectors/youtube_premium.rs:36
↓ 6 callersFunctioncompute_delta
Compute per-direction independent delta. If a direction's current value < previous, treat as restart (use raw value).
crates/server/src/service/traffic.rs:571
← previousnext →301–400 of 6,739, ranked by callers