getEnvVar returns the value of an environment variable from a list of KEY=VALUE strings. Returns empty string if the key is not found.

Addr returns the address the server is listening on.

AgentID returns the value of the "agent_id" field in the mutation.

CreateLifecycleHook creates a new lifecycle hook record. Returns ErrAlreadyExists if a hook with the same ID exists.

GetType returns the value of the "type" field in the mutation.

GetUserByEmail retrieves a user by email. Returns ErrNotFound if the user doesn't exist.

LoadEffectiveSettings is a unified entry point that detects the settings format and loads using the appropriate path. - If any user file is versioned

NewClient creates a new transfer client.

NewMaintenanceState creates a MaintenanceState with the given initial values.

NormalizeGitRemote normalizes a git remote URL to a canonical form for consistent matching. It removes protocols (https, http, ssh, git), strips user

Send enqueues a message and blocks until it is sent (or fails). It returns the Telegram API response or an error.

SetEmail sets the "email" field.

Start subscribes to agent lifecycle events and sets up broker subscriptions for existing running agents.

handleTestLogin handles POST /api/v1/auth/test-login. It provisions a test user and creates a web session, bypassing OAuth. Gated behind --enable-test

newTestLoginWebServer creates a WebServer for test-login tests and returns the UserTokenService so callers can mint challenge tokens.

nfsTestBackend creates an nfsBackend with a temp directory as the mount root and returns the backend, config, and project paths.

parseGetID parses a primary-key identifier for a get-by-id lookup. A malformed identifier cannot match any UUID primary key, so it is reported as stor

setupBrokerTestAgent creates a running agent and returns it.

updateStatusViaAPI updates an agent's status through the HTTP API, which triggers an event publication through the event publisher. The status paramet

utf16Extract extracts a substring from s using UTF-16 code unit offset and length, as provided by the Telegram Bot API entity fields. BMP characters (

Close shuts down the event bus and all subscriber goroutines.

FindHarnessConfigDir resolves a harness-config by name, checking template-level, project-level, then global directories. Optional templatePaths specif

TopicDefault — per-topic default agent overrides for forum groups

ListPolicies returns policies matching the filter criteria.

Message sends a message to an agent's harness via tmux. projectID scopes delivery to a specific project, preventing cross-project collision when agent

New creates a new RefBroker with the given logger.

NotFound writes a 404 Not Found response.

Publish sends a message to the remote broker.

ReadProjectID reads the project-id file from a git project's .scion directory. Checks project-id first, then falls back to grove-id for legacy project

SetDescription sets the "description" field.

SetOwnerID sets the "owner_id" field.

Stop signals the proxy to shut down and waits for goroutines to finish.

Update allows overriding fields `UPDATE` values. See the NotificationCreate.OnConflict documentation for more info.

Update allows overriding fields `UPDATE` values. See the NotificationCreateBulk.OnConflict documentation for more info.

Update allows overriding fields `UPDATE` values. See the InviteCodeCreate.OnConflict documentation for more info.

Update allows overriding fields `UPDATE` values. See the InviteCodeCreateBulk.OnConflict documentation for more info.

createHubConnection creates a HubConnection from credentials.

newMockMessage creates a MessageCreate with the given content and user mentions.

newTestServerWithProjectPath creates a test server with a temporary project path that has versioned settings with declared env vars.

populateAgentConfig enriches an agent's AppliedConfig with project-derived and template-derived fields after the initial config block has been set up.

resolveTargetAgents determines which agents a message should be routed to. Returns a deduplicated list of agent slugs and whether @all was used. Tier

seedTask inserts a task into the store for testing.

setupBrokerTestProject creates a project and a runtime broker, returns the project ID.

ComputeCapabilitiesBatch evaluates capabilities for a list of resources, optimized for batch operation by expanding groups and fetching policies once.

ComputeHarnessConfigRevision returns a content hash uniquely identifying the on-disk state of a harness-config directory. The hash combines the SHA-25

--- Tasks --- CreateTask inserts a new task record.

DefaultGlobalConfig returns the default global configuration.

FieldCleared returns a boolean indicating if a field with the given name was cleared in this mutation.

FormatStateChangeCard converts a state-change StructuredMessage into an HTML-formatted status card for Telegram. The card shows the agent name, state

GetAgentBySlug retrieves an agent by its slug within a project. Returns ErrNotFound if the agent doesn't exist.

GetHubProjectID returns the hub-side project ID if configured. This is the ID of the project on the Hub, which may differ from the local project_id st

GetScheduledEvent retrieves a scheduled event by ID. Returns ErrNotFound if the event doesn't exist.

GetUser retrieves a user by ID. Returns ErrNotFound if the user doesn't exist.

ListMessages returns messages matching the given filter. Results are ordered by created_at DESC.

MigrateSettingsFile migrates a single legacy settings file in dir to versioned format. If a server.yaml exists in the same directory, it is also merge

NewNFSMountReconciler creates a reconciler for the given NFS config. The checker abstracts mount syscalls for testability.

NewV2 creates a new TelegramBrokerV2 with the given logger.

Update allows overriding fields `UPDATE` values. See the PolicyBindingCreate.OnConflict documentation for more info.

Update allows overriding fields `UPDATE` values. See the PolicyBindingCreateBulk.OnConflict documentation for more info.

UpdateTemplate updates an existing template. Returns ErrNotFound if the template doesn't exist.

ValidateHook validates a LifecycleHook for correctness before persist or update. It checks structural well-formedness, trigger/action validity, execut

extractAgentFromBotMessage parses a FormatMessageV2 output and extracts the target agent slug. For agent-to-agent observer messages it returns the rec

newTestServerWithInMemoryCreds creates a server with in-memory credentials for a "local" connection.

recordFailure tracks a flush failure and opens the circuit if the threshold is reached.

redactToken removes the bot token from error messages to prevent accidental credential leakage in logs.

save persists the given entries snapshot to disk atomically. Best-effort.

setupWorkspaceProject creates a server, store, project, and workspace temp dir linked via an embedded broker provider. Returns the server, store, proj

testWorkspaceServer creates a test server for workspace handler tests.

CreateWorktree creates a new git worktree at the specified path with a new branch.

DescriptionCleared returns if the "description" field was cleared in this mutation.

Exists checks if an object exists.

ExternalProjectPath returns the absolute path to the external project config directory: ~/.scion/project-configs/<project-slug>__<short-uuid>/.scion/

GatherAuthWithEnv is like GatherAuth but checks the provided env overlay before falling back to os.Getenv for each key. This allows hub-resolved or CL

GetBrokerIdentityFromContext returns the BrokerIdentity from the context, if present.

GetGitHubInstallation retrieves a GitHub App installation by installation ID. Returns ErrNotFound if the installation doesn't exist.