MCPcopy Create free account

hub / github.com/ZingerLittleBee/ServerBee / functions

Functions6,739 in github.com/ZingerLittleBee/ServerBee

↓ 5 callersFunctionformatSpeed
(bytesPerSec: number)
apps/web/src/lib/utils.ts:59
↓ 5 callersFunctionfresh_db
()
crates/server/tests/notification_update_integration.rs:10
↓ 5 callersFunctiongarbage_config
Build a config that always fails client creation (garbage PEM key).
crates/server/src/service/apns.rs:120
↓ 5 callersFunctiongetCombinedBarColor
(input: CombinedSeverityInput)
apps/web/src/lib/network-latency-constants.ts:96
↓ 5 callersFunctiongetIsDateRange
(value: DateSelection)
apps/web/src/components/data-table/data-table-date-filter.tsx:16
↓ 5 callersFunctiongetLatencyTextClass
(input: LatencyStatusInput)
apps/web/src/lib/network-latency-constants.ts:38
↓ 5 callersFunctiongetTotal
(s: TrafficOverviewItem)
apps/web/src/routes/_authed/traffic/index.tsx:53
↓ 5 callersMethodget_agent_local_capabilities
(&self, server_id: &str)
crates/server/src/service/agent_manager.rs:545
↓ 5 callersMethodget_latest_report
Get the latest cached report for a server.
crates/server/src/service/agent_manager.rs:297
↓ 5 callersFunctionget_memory_stats
(stats: &Stats)
crates/agent/src/docker/containers.rs:156
↓ 5 callersMethodget_remote_addr
Get the remote address of a connected agent.
crates/server/src/service/agent_manager.rs:354
↓ 5 callersFunctionguard_probe_target
SSRF guard for server-pushed probe targets. Resolves `host` and rejects loopback / link-local (incl. the 169.254.169.254 cloud-metadata endpoint) / NA
crates/agent/src/probe_utils.rs:43
↓ 5 callersFunctionhandle_agent_message
(state: &Arc<AppState>, server_id: &str, msg: AgentMessage)
crates/server/src/router/ws/agent.rs:406
↓ 5 callersMethodhandle_server_message
Dispatch a Docker-related server message.
crates/agent/src/docker/mod.rs:95
↓ 5 callersFunctionheaders_with_xff
(xff: &str)
crates/server/src/router/utils.rs:80
↓ 5 callersFunctioninsert_probe
Helper: insert a network probe record with optional latency.
crates/server/src/service/alert.rs:3226
↓ 5 callersFunctioninsert_record
Insert a raw record at the given time with a fixed cpu value so the hourly average is deterministic.
crates/server/src/task/aggregator.rs:107
↓ 5 callersFunctioninsert_test_session
( db: &DatabaseConnection, id: &str, user_id: &str, expires_at: chrono::DateTi
crates/server/src/task/session_cleaner.rs:96
↓ 5 callersFunctioninstall_rustls_crypto_provider
()
crates/agent/src/main.rs:33
↓ 5 callersFunctionis_first_connect_noise
Drain the first-connect pushes the server emits to a default agent. These (ping/network sync + firewall blocklist messages) are unrelated to the docke
crates/server/tests/agent_docker_extra.rs:74
↓ 5 callersFunctionis_monitor_safe_addr
Returns `true` if `addr` is safe for the **service-monitor checkers** to connect to. Unlike [`is_global_addr`], this intentionally ALLOWS RFC1918 pri
crates/common/src/ssrf.rs:191
↓ 5 callersFunctionlist_servers
List all in-scope servers with their summary metrics + uptime band.
crates/server/src/service/public_status.rs:479
↓ 5 callersFunctionlist_targets
( State(state): State<Arc<AppState>>, )
crates/server/src/router/api/network_probe.rs:47
↓ 5 callersMethodlog
Log an audit event.
crates/server/src/service/audit.rs:23
↓ 5 callersFunctionlogin_admin
(client: &reqwest::Client, base_url: &str)
crates/server/tests/cost_integration.rs:93
↓ 5 callersFunctionlogin_audit_detail
Build the `detail` string for login audit rows (failed / rate-limited). The username is attacker-controlled on the public login endpoints, so it is tr
crates/server/src/router/api/auth.rs:745
↓ 5 callersFunctionlogin_member
(client: &reqwest::Client, base_url: &str)
crates/server/tests/ip_quality_integration.rs:115
↓ 5 callersFunctionlogout
( State(state): State<Arc<AppState>>, headers: HeaderMap, )
crates/server/src/router/api/auth.rs:249
↓ 5 callersFunctionmakeEntry
(overrides: Partial<ServerCostOverview> = {})
apps/web/src/components/server/cost-cell.test.tsx:10
↓ 5 callersFunctionmakeServer
(overrides: Partial<ServerMetrics> = {})
apps/web/src/components/dashboard/widget-renderer.test.tsx:88
↓ 5 callersFunctionmakeServer
(overrides: Partial<ServerMetrics> = {})
apps/web/src/components/dashboard/widgets/metric-card.test.tsx:31
↓ 5 callersFunctionmakeSummary
(overrides: Partial<NetworkServerSummary> = {})
apps/web/src/components/server/server-card-network-data.test.ts:5
↓ 5 callersFunctionmake_states
( state: &str, provider: &str, nonce: &str, age_min: i64, )
crates/server/src/router/api/oauth.rs:334
↓ 5 callersFunctionmake_tracker
()
crates/server/src/task/upgrade_timeout.rs:48
↓ 5 callersFunctionmobile_login
Perform a mobile login as the seeded admin and return the parsed `{ "data": MobileTokenResponse }` body.
crates/server/tests/router_mobile.rs:21
↓ 5 callersFunctionmoduleEntry
(id: string, entryPath: string, manifestOverrides: Partial<WidgetManifest> = {})
apps/web/src/widgets-runtime/loader.test.ts:38
↓ 5 callersFunctionno_redirect_client
Helper: fetch a path with a fresh client that does NOT follow redirects, so we observe the handler's own status directly. The SPA handler always retur
crates/server/tests/router_static_and_misc.rs:30
↓ 5 callersMethodnotify_ip_changed
Notify the scheduler that the agent's egress IP has changed. If the new IP differs from the last known value the scheduler will immediately trigger a
crates/agent/src/ip_quality/mod.rs:152
↓ 5 callersMethodobserve
()
apps/web/src/components/server/network-square-grid.test.tsx:21
↓ 5 callersFunctiononline_agent
Bring a mock agent fully online: connect, drain the `welcome` frame, and complete the SystemInfo handshake with the supplied capability bitmask (`None
crates/server/tests/router_probes_extra.rs:28
↓ 5 callersFunctionparseDiskIoJson
(raw: string | null | undefined)
apps/web/src/lib/disk-io.ts:28
↓ 5 callersFunctionparseExistingRules
(service: UnlockService | null | undefined)
apps/web/src/components/ip-quality/custom-service-dialog-utils.ts:47
↓ 5 callersFunctionport_direction_for
(proto: Protocol)
crates/agent/src/traceroute.rs:28
↓ 5 callersFunctionpublic_router
Public routes (no auth required).
crates/server/src/router/api/auth.rs:92
↓ 5 callersFunctionrec
(cap: &str, expires_at: i64)
crates/agent/src/capability_grants/store.rs:170
↓ 5 callersFunctionreconcile_file_capability
Reconcile the `file` capability bit against the file subsystem config. File management is a two-layer feature: the `file` capability bit advertises t
crates/agent/src/capability_policy.rs:67
↓ 5 callersFunctionrecv_browser_until
Read browser frames until one with `type == expected` arrives (5s budget), ignoring other interleaved frames. Panics on timeout.
crates/server/tests/ws_terminal_relay.rs:127
↓ 5 callersFunctionrecv_until
Wait until the agent receives a frame whose `type` is `expected`, ignoring the first-connect noise (ping/network-probe sync + blocklist reset/sync). R
crates/server/tests/router_probes_extra.rs:39
↓ 5 callersFunctionregister_agent_with_backoff
Retry registration with category-aware backoff. Returns immediately on permanent auth failure so the caller can exit with [`EXIT_CODE_PERMANENT_AUTH_F
crates/agent/src/register.rs:159
↓ 5 callersFunctionregister_all
(db: &DatabaseConnection)
crates/server/src/service/widget_module/builtin.rs:23
↓ 5 callersMethodregister_pending_request_with_ttl
Register a pending request for HTTP→WS relay with a custom TTL. Returns a oneshot receiver that will receive the agent's response.
crates/server/src/service/agent_manager.rs:448
↓ 5 callersMethodremove_job
(&self, task_id: &str)
crates/server/src/service/task_scheduler.rs:87
↓ 5 callersMethodrename_path
Rename/move a file or directory. Both paths must be validated.
crates/agent/src/file_manager.rs:353
↓ 5 callersMethodresize
Resize a terminal session.
crates/agent/src/terminal.rs:210
↓ 5 callersFunctionresolveInitialServersView
({ isMobile, searchView, storedView }: ResolveInitialServersViewInput)
apps/web/src/routes/_authed/servers/components/mobile-view.ts:13
↓ 5 callersFunctionrouter
(state: Arc<AppState>)
crates/server/src/router/api/mod.rs:45
↓ 5 callersMethodrun_now
Trigger an immediate check outside the regular schedule.
crates/agent/src/ip_quality/mod.rs:137
↓ 5 callersFunctionrun_ping_task
(config: PingTaskConfig, tx: mpsc::Sender<PingResult>)
crates/agent/src/pinger.rs:97
↓ 5 callersFunctionrunning_job
(server_id: &str, started_at: DateTime<Utc>)
crates/server/src/task/upgrade_timeout.rs:53
↓ 5 callersFunctionseed_demo_data
(db: &DatabaseConnection)
crates/server/src/dev_demo.rs:328
↓ 5 callersFunctionseed_mobile_chain
Seed a mobile session plus a session row + device token that reference it.
crates/server/src/service/auth.rs:1903
↓ 5 callersFunctionseed_task
Insert a scheduled task row targeting `server_ids`.
crates/server/src/task/task_scheduler.rs:561
↓ 5 callersFunctionsend_agent_frame
Send a single agent frame as a JSON text message.
crates/server/tests/router_admin_extra.rs:86
↓ 5 callersFunctionserver
(overrides: Partial<ServerMetrics> = {})
apps/web/src/hooks/use-metric-series.test.ts:22
↓ 5 callersFunctionsetMatch
(next: UnlockMatch)
apps/web/src/components/ip-quality/custom-service-dialog.tsx:156
↓ 5 callersMethodsimulateMessage
(data: unknown)
apps/web/src/hooks/use-terminal-ws.test.ts:30
↓ 5 callersFunctionstart_webhook_sink
Start a tiny webhook sink that captures the first inbound HTTP request.
crates/server/src/service/security.rs:491
↓ 5 callersMethodstat
Get metadata for a single file or directory.
crates/agent/src/file_manager.rs:249
↓ 5 callersMethodsystem_info
(&self)
crates/agent/src/collector/mod.rs:99
↓ 5 callersFunctiontarget
(id: &str, probe_type: &str, addr: &str)
crates/agent/src/network_prober.rs:405
↓ 5 callersFunctiontest_agent_manager
()
crates/server/src/service/cost.rs:812
↓ 5 callersMethodtimezone
(&self)
crates/server/src/service/task_scheduler.rs:40
↓ 5 callersMethodto_bit
(self)
crates/common/src/constants.rs:90
↓ 5 callersMethodupdate_job
( &self, task_model: &crate::entity::task::Model, state: std::sync::Arc<crate::state::
crates/server/src/service/task_scheduler.rs:98
↓ 5 callersMethodupdate_size
(&self, transfer_id: &str, size: u64)
crates/server/src/service/file_transfer.rs:157
↓ 5 callersMethodupdate_temporary_grants
(&self, server_id: &str, grants: Vec<TemporaryGrant>)
crates/server/src/service/agent_manager.rs:579
↓ 5 callersFunctionuseSidebar
()
apps/web/src/components/ui/sidebar.tsx:38
↓ 5 callersFunctionuseTraffic
(serverId: string)
apps/web/src/hooks/use-traffic.ts:22
↓ 5 callersFunctionwith_serverbee_token_env
(value: Option<&str>, test: impl FnOnce() -> T)
crates/agent/src/config.rs:334
↓ 5 callersFunctionwrap
(node: ReactNode)
apps/web/src/components/dashboard/widgets/metric-card.test.tsx:51
↓ 5 callersMethodwrite_file
Write base64-encoded content to a file atomically (via .sb-tmp rename).
crates/agent/src/file_manager.rs:301
↓ 5 callersMethodwrite_input
Write input data (base64 encoded) to a terminal session.
crates/agent/src/terminal.rs:185
↓ 4 callersFunctionactiveLocale
()
apps/web/src/lib/format.ts:11
↓ 4 callersFunctionadd_element
(exec: &dyn NftExecutor, entry: &BlockEntry)
crates/agent/src/firewall/nft.rs:209
↓ 4 callersFunctionadd_months
(date: NaiveDate, months: u32)
crates/server/src/service/traffic.rs:662
↓ 4 callersFunctionaggregate_disk_io
(records: &[&record::Model])
crates/server/src/service/record.rs:28
↓ 4 callersFunctionapplyServerEdit
( prev: ServerMetrics[], serverId: string, edited: { name: string; group_id: string | null; country_code
apps/web/src/hooks/use-servers-ws.ts:271
↓ 4 callersFunctionapply_external_ip
Overlay an externally-observed IP on top of interface-derived primaries. Replaces whichever stack the external IP belongs to.
crates/agent/src/reporter.rs:1476
↓ 4 callersFunctionaverage
(values: readonly number[])
apps/web/src/components/server/server-card-network-data.ts:36
↓ 4 callersFunctionbearer
(token: &str)
crates/server/tests/mobile_push_integration.rs:95
↓ 4 callersFunctionbring_up_agent
Bring up a mock agent with the given capability bitmask and drain the first-connect noise. Returns `(server_id, sink, reader)`.
crates/server/tests/ws_terminal_relay.rs:176
↓ 4 callersFunctionbuild_collection_zip
Build a valid collection zip from `(folder, id)` pairs plus an embedded collection.json listing every entry.
crates/server/src/service/widget_module/service.rs:553
↓ 4 callersFunctionbuild_deps
Build the granular dependencies the extracted tick needs without an `AppState`: a fresh agent manager, an empty alert-state manager and a default conf
crates/server/src/task/alert_evaluator.rs:56
↓ 4 callersFunctioncleanup_once
Deletes all sessions whose `expires_at` is strictly before `now`. Returns the number of rows removed so callers can log it. Extracted from the `run`
crates/server/src/task/session_cleaner.rs:15
↓ 4 callersFunctioncollect_disks
On macOS, APFS exposes the same disk (e.g. "Macintosh HD") at both `/` and `/System/Volumes/Data`, causing double-counting. Deduplicate by name only o
crates/agent/src/collector/disk.rs:7
↓ 4 callersMethodcollect_dynamic_allow
Tier-2.5 runtime allow-list. Merges `[server] trusted_proxies` with each connected agent's most recently reported external IP, both of which we must n
crates/server/src/service/firewall.rs:131
↓ 4 callersFunctionconfig
(id: &str, probe_type: &str, target: &str, interval: u32)
crates/agent/src/pinger.rs:182
↓ 4 callersMethodconnected_server_ids
Get all connected agent server IDs.
crates/server/src/service/agent_manager.rs:339
↓ 4 callersFunctioncount_lines
(path: &str)
crates/agent/src/collector/process.rs:38
↓ 4 callersFunctioncreateWrapper
()
apps/web/src/hooks/use-auth.test.tsx:7
← previousnext →501–600 of 6,739, ranked by callers