MCPcopy Create free account

hub / github.com/ZingerLittleBee/ServerBee / functions

Functions6,739 in github.com/ZingerLittleBee/ServerBee

⨍ Functions 6,739◇ Types & classes 1,185
↓ 4 callersFunctioncreate_api_key
Create an admin API key (admin-only endpoint) and return the raw key.
crates/server/tests/ws_terminal_relay.rs:74
↓ 4 callersFunctioncreate_api_key
(client: &reqwest::Client, base_url: &str)
crates/server/tests/integration.rs:131
↓ 4 callersFunctiondecode_cursor
(c: &str)
crates/server/src/router/api/security.rs:101
↓ 4 callersFunctiondefaultRule
()
apps/web/src/components/ip-quality/custom-service-dialog-utils.ts:12
↓ 4 callersFunctiondelete_element
(exec: &dyn NftExecutor, entry: &BlockEntry)
crates/agent/src/firewall/nft.rs:223
↓ 4 callersFunctiondelete_target
( State(state): State<Arc<AppState>>, Path(id): Path<String>, )
crates/server/src/router/api/network_probe.rs:146
↓ 4 callersFunctionderive_interface_ips
Pure interface-list scan. Synchronous and fast — never touches the network. Prefers the first public (routable) address; remembers the first private o
crates/agent/src/reporter.rs:1441
↓ 4 callersFunctiondivide_positive
(numerator: f64, denominator: Option<f64>)
crates/server/src/service/cost.rs:757
↓ 4 callersFunctiondocker_unavailable_error
()
crates/server/src/router/api/docker.rs:56
↓ 4 callersFunctiondrain_first_connect_pushes
Drain any frames the server pushes right after the SystemInfo handshake. Returns once the inbound stream is quiet for `quiet_ms`.
crates/server/tests/agent_ws_dispatch.rs:81
↓ 4 callersFunctiondrain_journalctl_json
Read journalctl JSON lines from an arbitrary async reader, parse them, and forward decoded `AuthAttempt`s on `out_tx`. Made public for tests; the pro
crates/agent/src/security/journal_watcher.rs:111
↓ 4 callersFunctiondrain_through_ack
Drain messages from `reader` until a `system_info` `Ack` for `msg_id` is observed. Returns every non-ack message read along the way (in order) so the
crates/server/tests/integration.rs:4364
↓ 4 callersFunctionemit_upgrade_failure
( tx: &mpsc::Sender<AgentMessage>, job_id: Option<String>, version: String, stage: UpgradeStag
crates/agent/src/reporter.rs:3997
↓ 4 callersMethodenrich
Fill in `hostname` (via PTR) and `asn` (via MMDB) for every hop with an IP. Best-effort; failures leave the field at whatever value the agent sent. AS
crates/server/src/service/traceroute_enrich.rs:38
↓ 4 callersFunctionexecute_check
Execute a single monitor check: run the checker, insert the record, update state, and send notifications if needed.
crates/server/src/task/service_monitor_checker.rs:136
↓ 4 callersFunctionfallback_outcome
(status: u16, body: &str)
crates/agent/src/ip_quality/detectors/chatgpt.rs:153
↓ 4 callersFunctionfind_existing_ancestor
Walk up the directory tree to find the closest existing ancestor.
crates/agent/src/file_manager.rs:528
↓ 4 callersFunctionfixed_now
Fixed instant used for all deterministic assertions (2026-03-17 10:30:00 UTC).
crates/server/src/task/record_writer.rs:133
↓ 4 callersFunctionformatDate
(date: Date | string | number | undefined, opts: Intl.DateTimeFormatOptions = {})
apps/web/src/lib/format.ts:16
↓ 4 callersFunctionformatOklch
(v: OklchValue)
apps/web/src/lib/oklch.ts:44
↓ 4 callersFunctionformatPacketLoss
(loss: number)
apps/web/src/lib/network-types.ts:72
↓ 4 callersFunctionformatValue
(metric: string, value: number)
apps/web/src/components/dashboard/widgets/top-n.tsx:13
↓ 4 callersFunctionfresh_db
()
crates/server/src/service/traceroute.rs:171
↓ 4 callersFunctiongate_scope_id
Ensure the requested `id` is part of the public scope; otherwise 404.
crates/server/src/router/api/status.rs:177
↓ 4 callersMethodget
(&self, server_id: &str)
crates/server/src/service/upgrade_tracker.rs:226
↓ 4 callersFunctiongetCostAdvisoryKey
(advisory: CostAdvisory)
apps/web/src/lib/cost.ts:41
↓ 4 callersFunctiongetExtension
(filename: string)
apps/web/src/lib/file-utils.ts:73
↓ 4 callersFunctiongetLatencyBarColor
(input: LatencyStatusInput)
apps/web/src/lib/network-latency-constants.ts:53
↓ 4 callersFunctiongetRingColor
(pct: number, brandColor: string)
apps/web/src/components/server/server-card.tsx:59
↓ 4 callersFunctiongetRingColor
(pct: number, brandColor: string)
apps/web/src/components/status/server-summary-card.tsx:22
↓ 4 callersFunctionget_group
( State(state): State<Arc<AppState>>, Path(id): Path<String>, )
crates/server/src/router/api/notification.rs:170
↓ 4 callersMethodget_info
( &self, rule_id: &str, server_id: &str, event_key: &str, )
crates/server/src/service/alert.rs:302
↓ 4 callersFunctionget_temperature
()
crates/agent/src/collector/temperature.rs:3
↓ 4 callersFunctionhandleWsMessage
(raw: unknown, queryClient: QueryClient)
apps/web/src/hooks/use-servers-ws.ts:655
↓ 4 callersFunctionhandle_current_connection_frame
( state: &Arc<AppState>, server_id: &str, connection_id: u64, frame: CurrentConnectionFrame, )
crates/server/src/router/ws/agent.rs:373
↓ 4 callersMethodhandle_remove
(&self, id: String)
crates/agent/src/firewall/manager.rs:205
↓ 4 callersFunctionhexToOklch
(hex: string)
apps/web/src/lib/oklch.ts:68
↓ 4 callersFunctionhttp_client
()
crates/server/tests/cost_integration.rs:85
↓ 4 callersFunctioninsert_audit_log
Insert an `audit_log` at `days_ago` (no FK on this table).
crates/server/src/task/cleanup.rs:250
↓ 4 callersFunctioninsert_cache
Insert an `ip_risk_cache` row with the given `checked_at` offset.
crates/server/src/task/cleanup.rs:357
↓ 4 callersFunctioninsert_event
Insert an `unlock_event` with the given `changed_at` offset (negative = in the past).
crates/server/src/task/cleanup.rs:325
↓ 4 callersFunctioninsert_event
( db: &DatabaseConnection, id: &str, server_id: &str, event_type: &str,
crates/server/src/router/api/security.rs:350
↓ 4 callersFunctioninsert_incident
( db: &DatabaseConnection, id: &str, status: &str, is_public: bool, re
crates/server/src/service/public_status.rs:1555
↓ 4 callersFunctioninsert_maintenance
( db: &DatabaseConnection, id: &str, is_public: bool, active: bool, en
crates/server/src/service/public_status.rs:1641
↓ 4 callersFunctioninsert_ping_record
Insert a `ping_record` at `days_ago` (no FK on this table).
crates/server/src/task/cleanup.rs:233
↓ 4 callersFunctioninsert_security_event
Insert a `security_event` at `days_ago` (no FK on this table).
crates/server/src/task/cleanup.rs:266
↓ 4 callersFunctioninsert_server
(db: &DatabaseConnection, id: &str)
crates/server/src/router/api/security.rs:330
↓ 4 callersFunctioninsert_test_server
Insert a parent `server` row so FK-constrained record/traffic writes succeed.
crates/server/src/task/record_writer.rs:138
↓ 4 callersFunctioninsert_webhook_group
(db: &DatabaseConnection, port: u16)
crates/server/src/service/security.rs:525
↓ 4 callersFunctioninstallRuntime
(overrides: Partial<Parameters<typeof createWidgetRuntime>[0]> = {})
packages/widget-sdk/tests/actions.test.tsx:7
↓ 4 callersFunctionisCleanupCandidate
(server: OrphanServerCandidate)
apps/web/src/lib/orphan-server-utils.ts:9
↓ 4 callersFunctionisLatencyFailure
(packetLossRatio: number | null | undefined)
apps/web/src/lib/network-latency-constants.ts:21
↓ 4 callersFunctionlatencyColorClass
(ms: number | null, options?: { failed?: boolean })
apps/web/src/lib/network-types.ts:158
↓ 4 callersFunctionlist_api_keys
( State(state): State<Arc<AppState>>, Extension(current_user): Extension<CurrentUser>, )
crates/server/src/router/api/auth.rs:357
↓ 4 callersFunctionmakeWidget
(overrides: Partial<DashboardWidget>)
apps/web/src/components/dashboard/dashboard-layout.test.ts:5
↓ 4 callersFunctionmake_manager_simple
()
crates/server/src/service/agent_manager.rs:808
↓ 4 callersFunctionmake_user
Build a deterministic `user` ActiveModel with a caller-supplied id and username.
crates/server/src/service/db_error.rs:17
↓ 4 callersMethodmark
Return true if `(user, ip)` has *not* been seen before; record the observation and (lazily) flush on next call to `flush`.
crates/agent/src/security/first_seen_store.rs:70
↓ 4 callersFunctionmergeNetworkChartRecords
({ historical, isRealtime, realtime, seed, serverId }: MergeArgs)
apps/web/src/lib/network-chart-records.ts:15
↓ 4 callersFunctionmetricLabel
(metric: string, t: (key: string) => string)
apps/web/src/lib/widget-helpers.ts:28
↓ 4 callersMethodmkdir
Create a directory and all parent directories.
crates/agent/src/file_manager.rs:334
↓ 4 callersFunctionmockFetchModules
(entries: TestListEntry[])
apps/web/src/widgets-runtime/loader.test.ts:15
↓ 4 callersFunctionnextUid
()
apps/web/src/components/ip-quality/custom-service-dialog.tsx:32
↓ 4 callersFunctionno_cli
()
crates/agent/src/capability_policy.rs:149
↓ 4 callersFunctionoklchToHex
(s: string)
apps/web/src/lib/oklch.ts:56
↓ 4 callersFunctionprovider_for_config
( config: &IpQualityConfig, provider_name: &str, )
crates/server/src/service/ip_risk.rs:511
↓ 4 callersFunctionreadRecentCommands
(historyPath = HISTORY_PATH)
scripts/make-menu.ts:510
↓ 4 callersFunctionreconcile_firewall_capability
Reconcile the firewall-block capability bit against the runtime nft probe. The reported capability must mean "operator allows it AND the subsystem ca
crates/agent/src/capability_policy.rs:84
↓ 4 callersFunctionrecordRecentCommand
(historyPath: string, key: string, timestamp: number)
scripts/make-menu.ts:536
↓ 4 callersMethodrecord_ack
Update `apply_state`, write an audit row, and fan out a `FirewallApplyStateChanged` to subscribed browsers when an agent acks the apply of a single bl
crates/server/src/service/firewall.rs:328
↓ 4 callersMethodrecords
(&self)
crates/agent/src/capability_grants/store.rs:75
↓ 4 callersFunctionrecv_browser_text
Receive the next text frame from the browser socket, parsed as JSON (5s timeout).
crates/server/tests/browser_ws.rs:70
↓ 4 callersFunctionrecv_until_types
( reader: &mut futures_util::stream::SplitStream< tokio_tungstenite::WebSocketStream<
crates/server/tests/docker_integration.rs:335
↓ 4 callersFunctionregister_agent
(client: &reqwest::Client, base_url: &str)
crates/server/tests/ip_quality_integration.rs:125
↓ 4 callersFunctionregister_for_admin
Register an agent and return (client cookied as admin, server_id, token).
crates/server/tests/integration.rs:4430
↓ 4 callersFunctionreject_literal_unsafe_target
Server-side, DNS-free guard for probe/monitor targets. Rejects targets whose host is a **literal** non-monitor-safe IP (loopback / link-local incl. cl
crates/common/src/ssrf.rs:308
↓ 4 callersMethodremoveHeader
(name: string)
apps/web/vite/dev-proxy.ts:15
↓ 4 callersMethodremove_connection_if_current
( &self, server_id: &str, expected_connection_id: u64, )
crates/server/src/service/agent_manager.rs:187
↓ 4 callersFunctionrequest
(method: string, path: string, body?: unknown)
apps/web/src/lib/api-client.ts:13
↓ 4 callersFunctionresolve_and_check_monitor
Like [`resolve_and_check`] but uses [`is_monitor_safe_addr`] (allows private ranges; blocks loopback/link-local/metadata/NAT64). For the service-monit
crates/common/src/ssrf.rs:251
↓ 4 callersFunctionresolve_record
( resolver: &TokioResolver, target: &str, record_type: &str, )
crates/server/src/service/checker/dns.rs:136
↓ 4 callersFunctionroundComponent
(value: number)
apps/web/src/lib/oklch.ts:16
↓ 4 callersMethodrun
(&mut self)
crates/agent/src/reporter.rs:58
↓ 4 callersFunctionrunAction
(action: DockerActionBody)
apps/web/src/routes/_authed/servers/$serverId/docker/components/container-detail-dialog.tsx:113
↓ 4 callersFunctionrun_list
(config: &AgentConfig, now: i64)
crates/agent/src/capability_grants/cli.rs:75
↓ 4 callersFunctionrun_revoke
(config: &AgentConfig, cap: &str, now: i64)
crates/agent/src/capability_grants/cli.rs:60
↓ 4 callersFunctionsave_token
(token: &str)
crates/agent/src/register.rs:199
↓ 4 callersMethodscore_ip
Score an IP address: 1. Check `ip_risk_cache` — if fresh (< 24h), return the cached snapshot. 2. On cache miss / expired: look up GeoIP baseline + cal
crates/server/src/service/ip_risk.rs:274
↓ 4 callersFunctionseed_mobile_session
(state: &AppState, id: &str, user_id: &str, installation_id: &str)
crates/server/tests/mobile_push_integration.rs:59
↓ 4 callersFunctionseed_module
(db: &DatabaseConnection, id: &str)
crates/server/tests/widget_module_integration.rs:128
↓ 4 callersFunctionseed_session
(state: &AppState, id: &str, user_id: &str, token: &str, mobile_id: &str)
crates/server/tests/mobile_push_integration.rs:76
↓ 4 callersFunctionselectedServerScope
(serverIds: unknown, snapshot: ServerSnapshotKind, metric?: string)
apps/web/src/components/dashboard/widget-render-dependencies.ts:32
↓ 4 callersFunctionsend_docker_system_info
( sink: &mut futures_util::stream::SplitSink< tokio_tungstenite::WebSocketStream< toki
crates/server/tests/docker_integration.rs:240
↓ 4 callersFunctionsend_raw_text
Send a raw text frame verbatim. Used for hand-rolled JSON (entries whose constructor shape we don't want to depend on) and for deliberately malformed
crates/agent/src/reporter.rs:3083
↓ 4 callersFunctionsend_system_info_pv
Send a `SystemInfo` with a caller-chosen `protocol_version` so the "old agent" scenario can pin v1.
crates/server/tests/integration.rs:4324
↓ 4 callersFunctionserverListSnapshot
( servers: ServerMetrics[], ids: string[], snapshot: ServerSnapshotKind, metric?: string )
apps/web/src/components/dashboard/widget-render-dependencies.ts:112
↓ 4 callersFunctionsetServerCapabilities
( prev: ServerMetrics[], serverId: string, capabilities: number, agentLocalCapabilities: number | null
apps/web/src/hooks/use-servers-ws.ts:283
↓ 4 callersFunctionsetServerOnlineStatus
(prev: ServerMetrics[], serverId: string, online: boolean)
apps/web/src/hooks/use-servers-ws.ts:247
↓ 4 callersMethodset_protocol_version
(&self, server_id: &str, version: u32)
crates/server/src/service/agent_manager.rs:419
↓ 4 callersFunctionsingleServerScope
(serverId: unknown, snapshot: ServerSnapshotKind, metric?: string)
apps/web/src/components/dashboard/widget-render-dependencies.ts:27
← previousnext →601–700 of 6,739, ranked by callers