Functions — github.com/ZingerLittleBee/ServerBee

hub / github.com/ZingerLittleBee/ServerBee / functions

Functions6,739 in github.com/ZingerLittleBee/ServerBee

⨍ Functions 6,739◇ Types & classes 1,185

↓ 12 callersFunctionregister_once

( config: &AgentConfig, fingerprint: &str, )

crates/agent/src/register.rs:91

↓ 12 callersFunctionresolve_scope

Resolve the in-scope server IDs by intersecting the admin-selected list with the live, non-hidden `servers` rows.

crates/server/src/service/public_status.rs:353

↓ 12 callersFunctionsample_create_ping_task

()

crates/server/src/service/ping.rs:327

↓ 12 callersFunctionseed_server

Seed a minimal `servers` row so tag rows have a valid parent id.

crates/server/src/service/server_tag.rs:191

↓ 12 callersFunctionset_tags

( db: &DatabaseConnection, server_id: &str, tags: Vec<String>, )

crates/server/src/service/server_tag.rs:49

↓ 12 callersFunctionuseDashboardEditor

()

apps/web/src/hooks/use-dashboard-editor.ts:37

↓ 12 callersFunctionvalidate_tags

(raw: &[String])

crates/server/src/service/server_tag.rs:12

↓ 11 callersMethodadd_job

( &self, task_model: &crate::entity::task::Model, state: std::sync::Arc<crate::state::

crates/server/src/service/task_scheduler.rs:52

↓ 11 callersMethodadd_viewer

Add a viewer. Returns true if this is the first viewer for this server.

crates/server/src/service/docker_viewer.rs:22

↓ 11 callersFunctionbucket_start

(timestamp: DateTime<Utc>, bucket_seconds: i64)

crates/server/src/service/network_probe.rs:1332

↓ 11 callersFunctionbuild_headers

Build a `HeaderMap` from the config's `headers` object.

crates/server/src/service/checker/http_keyword.rs:262

↓ 11 callersFunctioncomputeTrafficQuota

({ entry, netInTransfer, netOutTransfer }: ComputeInput)

apps/web/src/lib/traffic.ts:17

↓ 11 callersFunctioncreate_group

( State(state): State<Arc<AppState>>, Json(input): Json<CreateNotificationGroup>, )

crates/server/src/router/api/notification.rs:189

↓ 11 callersFunctionfetch_audits

( db: &sea_orm::DatabaseConnection, action: &str, )

crates/server/src/service/firewall.rs:667

↓ 11 callersFunctionformatDateShort

( date: Date | string | number | null | undefined, opts: Intl.DateTimeFormatOptions = {} )

apps/web/src/lib/format.ts:34

↓ 11 callersMethodfrom

(user: crate::entity::user::Model)

crates/server/src/middleware/auth.rs:23

↓ 11 callersFunctioninsert_record

Helper: insert a single metric record for a server at a given time.

crates/server/src/service/alert.rs:3192

↓ 11 callersMethodis_enabled

Check if file management is enabled via both config and capability.

crates/agent/src/file_manager.rs:100

↓ 11 callersFunctionmakeEntries

(count: number, overrides: Partial<UptimeDailyEntry> = {})

apps/web/src/components/uptime/uptime-timeline.test.tsx:45

↓ 11 callersFunctionmakeMockRes

()

apps/web/vite/dev-proxy.test.ts:110

↓ 11 callersFunctionmake_caps

(bits: u32)

crates/agent/src/ip_quality/mod.rs:417

↓ 11 callersFunctionmake_task

Construct a minimal scheduled-task model. The caller controls the fields that drive scheduling branches (cron, enabled).

crates/server/src/service/task_scheduler.rs:178

↓ 11 callersFunctionoptionalNumber

(value: unknown)

apps/web/src/hooks/use-traceroute-stream.ts:43

↓ 11 callersFunctionparse_capability_args

(args: I)

crates/agent/src/capability_policy.rs:92

↓ 11 callersMethodrender

(&self, template: &str)

crates/server/src/service/notification.rs:67

↓ 11 callersFunctionsend_agent_frame

Send a single agent frame as a JSON text message.

crates/server/tests/agent_messages.rs:41

↓ 11 callersMethodto

()

crates/server/src/entity/user.rs:32

↓ 11 callersFunctionupdate_input

()

crates/server/src/service/server.rs:378

↓ 11 callersFunctionupdate_server

( State(state): State<Arc<AppState>>, Path(id): Path<String>, Json(input): Json<UpdateServerInput>

crates/server/src/router/api/server.rs:909

↓ 11 callersFunctionupdate_user

( State(state): State<Arc<AppState>>, Extension(actor): Extension<CurrentUser>, ConnectInfo(addr):

crates/server/src/router/api/user.rs:121

↓ 11 callersFunctionvalidate_url

Validate that a URL is safe to fetch on the strict (global-only) path: - scheme must be `http` or `https` - port must be 80, 443, or absent (scheme de

crates/common/src/ssrf.rs:48

↓ 11 callersFunctionwait_for_event

Drain the event channel until an event matching `pred` is received, or the bounded timeout elapses. Non-matching events (e.g. PTY `Output` noise from

crates/agent/src/terminal.rs:317

↓ 11 callersFunctionwave

(seed: usize, sample: usize, modulo: usize)

crates/server/src/dev_demo.rs:913

↓ 10 callersFunctionbring_up_agent

Standard mock-agent bring-up with the default capability set (which includes CAP_UPGRADE + CAP_SECURITY_EVENTS + firewall blocklist), features empty.

crates/server/tests/agent_ws_dispatch.rs:110

↓ 10 callersFunctionbring_up_agent

Standard mock-agent bring-up: register, connect, consume Welcome, complete the SystemInfo handshake with the default capability set, and drain the fir

crates/server/tests/agent_messages.rs:92

↓ 10 callersFunctionbuild_resolver

(nameserver: Option<&str>)

crates/server/src/service/checker/dns.rs:114

↓ 10 callersFunctionbuild_test_state

Build an `Arc<AppState>` backed by a fresh migrated test DB. The returned `TempDir` guards must be kept alive for the test duration: one owns the SQLi

crates/server/src/service/task_scheduler.rs:161

↓ 10 callersFunctionchange_password

( State(state): State<Arc<AppState>>, ConnectInfo(addr): ConnectInfo<SocketAddr>, Extension(curren

crates/server/src/router/api/auth.rs:424

↓ 10 callersFunctionclassify_trace

Classify a ChatGPT trace-endpoint response. The trace body format is: ```text fl=... h=chat.openai.com ip=1.2.3.4 ts=... visit_scheme=https uag=... c

crates/agent/src/ip_quality/detectors/chatgpt.rs:78

↓ 10 callersFunctionconfig_with

(dir: &std::path::Path)

crates/agent/src/capability_grants/cli.rs:108

↓ 10 callersMethodflush

Persist current state. Uses an atomic temp-file + rename. No-op if nothing has changed since open or last flush.

crates/agent/src/security/first_seen_store.rs:89

↓ 10 callersMethodhandle_add

(&self, entry: BlockEntry)

crates/agent/src/firewall/manager.rs:163

↓ 10 callersFunctioninsert_test_state

Helper: insert an alert state into the database.

crates/server/src/service/alert.rs:1701

↓ 10 callersFunctionisImageFile

(filename: string)

apps/web/src/lib/file-utils.ts:127

↓ 10 callersFunctionmakeServer

(overrides: Partial<Parameters<typeof ServerCard>[0]['server']> = {})

apps/web/src/components/server/server-card.test.tsx:42

↓ 10 callersFunctionmakeService

(overrides: Partial<UnlockService> = {})

apps/web/src/components/ip-quality/custom-service-dialog.test.tsx:28

↓ 10 callersFunctionmakeWidget

( widgetType: string, config: Record<string, unknown> = {}, extra: Partial<DashboardWidget> = {} )

apps/web/src/components/dashboard/widget-renderer.test.tsx:67

↓ 10 callersFunctionmake_event

Build a DockerEventInfo with the given timestamp and a single attribute.

crates/server/src/service/docker.rs:77

↓ 10 callersFunctionmap_event

Pure mapping from a bollard `EventMessage` to our `DockerEventInfo` DTO. Extracted so the transformation can be unit-tested without a live daemon.

crates/agent/src/docker/events.rs:17

↓ 10 callersFunctionmergeServerUpdate

(prev: ServerMetrics[], incoming: ServerMetrics[])

apps/web/src/hooks/use-servers-ws.ts:156

↓ 10 callersFunctionmint_enrollment_code

(client: &reqwest::Client, base_url: &str)

crates/server/tests/integration.rs:162

↓ 10 callersFunctionnearestTier

(value: number, tiers: readonly number[])

apps/web/src/components/dashboard/sizing-strategies/index.ts:9

↓ 10 callersFunctionparseServerIds

(raw: string | null | undefined)

apps/web/src/routes/_authed/settings/status-page-config-utils.ts:18

↓ 10 callersFunctionremove_ids_from_json

(json: &str, orphan_ids: &[String])

crates/server/src/router/api/server.rs:1394

↓ 10 callersFunctionrenderCard

(server: CardProps['server'], extra: Omit<CardProps, 'server'> = {})

apps/web/src/components/server/server-card.test.tsx:34

↓ 10 callersFunctionrenderMarkdown

(input: string)

apps/web/src/lib/markdown.ts:16

↓ 10 callersFunctionresolve_and_check

Resolve `host` to its socket addresses (on `port`) and reject if **any resolved address is non-global. This is the DNS-rebinding defense: if any addre

crates/common/src/ssrf.rs:161

↓ 10 callersMethodsimulateOpen

()

apps/web/src/hooks/use-terminal-ws.test.ts:26

↓ 10 callersFunctionspawn_single_response

Spawn a responder that waits for one forwarded request whose `type` equals `request_type`, then sends `build_response(msg_id)` back to the server.

crates/server/tests/router_file_extra.rs:66

↓ 10 callersMethodstart_upload

Start an upload: create the .sb-part temporary file.

crates/agent/src/file_manager.rs:437

↓ 10 callersMethodsync

Absorb a fresh `IpQualitySync` service list + interval. If `CAP_IP_QUALITY` is not effective this is a no-op (the server only sends the sync when the

crates/agent/src/ip_quality/mod.rs:112

↓ 10 callersMethodupdate_agent_local_capabilities

(&self, server_id: &str, caps: u32)

crates/server/src/service/agent_manager.rs:540

↓ 10 callersMethodupdate_report

Update the latest report for a server and broadcast an Update to browsers.

crates/server/src/service/agent_manager.rs:210

↓ 10 callersMethodupsert

Insert/replace a grant and prune expired records (CLI writer path).

crates/agent/src/capability_grants/store.rs:125

↓ 10 callersFunctionuseRealtimeMetrics

(serverId: string)

apps/web/src/hooks/use-realtime-metrics.ts:101

↓ 9 callersFunctioncountryCodeToFlag

(code: string | null | undefined)

apps/web/src/lib/utils.ts:8

↓ 9 callersFunctioncreateTestEnv

()

apps/web/src/hooks/use-realtime-metrics.test.tsx:94

↓ 9 callersFunctioncreate_target

( State(state): State<Arc<AppState>>, Json(input): Json<CreateNetworkProbeTarget>, )

crates/server/src/router/api/network_probe.rs:106

↓ 9 callersFunctionderiveServerStatus

(s: { has_token?: boolean; online: boolean })

apps/web/src/components/server/status-dot-utils.ts:3

↓ 9 callersFunctionemail_config_value

()

crates/server/src/service/notification.rs:1064

↓ 9 callersFunctionformatCostAmount

(amount: number, currency: string | null | undefined, options?: CostFormatOptions)

apps/web/src/lib/cost.ts:22

↓ 9 callersMethodget

(&self, transfer_id: &str)

crates/server/src/service/file_transfer.rs:143

↓ 9 callersFunctionget_records

( State(state): State<Arc<AppState>>, Path(task_id): Path<String>, Query(q): Query<RecordsQuery>,

crates/server/src/router/api/ping.rs:150

↓ 9 callersFunctionget_user

( State(state): State<Arc<AppState>>, Path(id): Path<String>, )

crates/server/src/router/api/user.rs:55

↓ 9 callersMethodlist_dir

List directory entries, sorted with directories first, then alphabetically. When path is outside root_paths but is an ancestor of one or more root_pat

crates/agent/src/file_manager.rs:137

↓ 9 callersFunctionlist_events

( State(state): State<Arc<AppState>>, Query(params): Query<ListEventsParams>, )

crates/server/src/router/api/security.rs:126

↓ 9 callersFunctionload_config

Load the singleton `status_page` row. The migration guarantees exactly one row exists; this helper is the canonical reader. Returns `NotFound` if the

crates/server/src/service/public_status.rs:326

↓ 9 callersFunctionmake_record

Build a minimal `record::Model` with the given field values.

crates/server/src/service/alert.rs:1334

↓ 9 callersFunctionmap_container

Pure mapping from a bollard `ContainerSummary` to our `DockerContainer` DTO. Extracted so the transformation can be unit-tested without a live daemon:

crates/agent/src/docker/containers.rs:12

↓ 9 callersMethodmark_ready

(&self, transfer_id: &str)

crates/server/src/service/file_transfer.rs:178

↓ 9 callersFunctionmobile_admin_token

crates/server/tests/router_mobile.rs:42

↓ 9 callersFunctionnormalizeRenderItem

(item: LayoutItem, strategy: SizingStrategy, ctx: NormalizeContext)

apps/web/src/components/dashboard/sizing-strategies/normalize.ts:25

↓ 9 callersFunctionoutcome

(status: u16, body: &str, final_url: &str, redirects: Vec<&str>)

crates/agent/src/ip_quality/detectors/tiktok.rs:94

↓ 9 callersFunctionparseOklch

(s: string)

apps/web/src/lib/oklch.ts:22

↓ 9 callersFunctionpixelSquareFineH

(wCoarse: number, containerWidth: number)

apps/web/src/components/dashboard/sizing-strategies/normalize.ts:13

↓ 9 callersMethodremove_connection

Unregister an agent connection and broadcast ServerOffline to browsers.

crates/server/src/service/agent_manager.rs:181

↓ 9 callersFunctionresolve_enabled_scope

Resolve the public scope and verify the top-level `enabled` toggle.

crates/server/src/router/api/status.rs:157

↓ 9 callersFunctionrun

Periodically cleans up expired records based on retention config. Runs every 3600 seconds, offset by 60s from the aggregator.

crates/server/src/task/cleanup.rs:18

↓ 9 callersFunctionrun_grant

Temporarily enable `cap`. `base` is the agent's permanent (config-computed) capability set; granting an already-on cap is rejected.

crates/agent/src/capability_grants/cli.rs:17

↓ 9 callersFunctionseedFromSummary

(summary: SparklineSummaryLike)

apps/web/src/lib/sparkline.ts:17

↓ 9 callersFunctionserve_asset

( State(state): State<Arc<AppState>>, Path((id, asset_path)): Path<(String, String)>, )

crates/server/src/router/api/widget_module.rs:74

↓ 9 callersFunctionserverHealth

(summary: NetworkOverviewSummary)

apps/web/src/components/status/network-overview-health.ts:21

↓ 9 callersFunctionspawn_single_response

Spawn a responder that waits for a single forwarded request whose `type` equals `request_type`, then sends `build_response(msg_id)` back to the server

crates/server/tests/agent_file_ops.rs:61

↓ 9 callersMethodstop_all

Abort all running probe tasks.

crates/agent/src/network_prober.rs:116

↓ 9 callersFunctiontoNumber

(value: string)

apps/web/src/components/ip-quality/custom-service-dialog-utils.ts:19

↓ 9 callersFunctionuseApiQuery

( path: string, opts?: { params?: Record<string, string | number | undefined> enabled?: boolean

packages/widget-sdk/src/hooks/escape-hatch.ts:24

↓ 9 callersFunctionvalidate_file_access

Validate that the server exists, has CAP_FILE capability, and is online. Returns the server model on success.

crates/server/src/router/api/file.rs:169

↓ 8 callersFunctionadvisories_from

Pure advisory rules over already-derived primitives. Kept separate from `compute_advisories` so the decision logic is unit-testable without a DB. `Sl

crates/server/src/service/cost.rs:630

↓ 8 callersFunctionagent_error

Map agent-side error messages to the appropriate HTTP error type.

crates/server/src/router/api/file.rs:143

↓ 8 callersFunctionaggregate_results

Build a [`NetworkProbeResultData`] from raw per-probe measurements.

crates/agent/src/network_prober.rs:231

← previous next →201–300 of 6,739, ranked by callers