ProjectAgents returns the agent operations interface scoped to a specific project.

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

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

handleAdminIntegrationByName dispatches requests under api/v1/admin/integrations/{name}[/config|/restart|/health].

CreateScheduledEvent creates a new scheduled event.

CreateSecret creates a new secret. Returns ErrAlreadyExists if a secret with the same key+scope+scopeId exists.

CreateTemplate creates a new template record.

GetNotifications returns notifications for a subscriber. If onlyUnacknowledged is true, only unacknowledged notifications are returned. Results are or

User mappings

Unique configures the query builder to filter duplicate records on query. By default, unique is set to true, and can be disabled using this method.

Validate checks that the channel configuration is valid.

hubManagedProjectPath returns the filesystem path for a hub-managed project workspace. It prefers projects/<slug> and falls back to groves/<slug> for

makeTestCreds creates BrokerCredentials with a base64-encoded secret key.

Client returns a new `ent.Client` from the mutation. If the mutation was executed in a transaction (ent.Tx), a transactional client is returned.

RuntimeError writes a 500 error for runtime failures.

SetSecretBackend sets the secret backend for pluggable secret storage.

UpdateOne returns an update builder for the given entity.

Where appends a list predicates to the UserMutation builder.

delete performs an HTTP DELETE request with fallback.

seedTestHarnessConfig creates a minimal harness-config directory for testing. Creates <scionDir>/harness-configs/<name>/config.yaml with the given har

GetTask retrieves a task by ID.

NewClientWithConfig creates a new Hub client with explicit configuration.

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

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

UpdateProject updates an existing project. Returns ErrNotFound if the project doesn't exist.

scanValues returns the types for scanning values from sql.Rows.

IDs queries the database and returns the entity ids that match the mutation's predicate. That means, if the mutation is applied within a transaction w

ListTemplates returns templates matching the filter criteria.

readAgentInfo is a test helper that reads and parses agent-info.json.

Close shuts down the connection.

Flush implements http.Flusher for streaming support.

Subsystem returns a child logger with the given subsystem attribute. The returned logger inherits the root component attribute and adds a "subsystem"

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

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

UpdateAgent updates an existing agent. Uses optimistic locking via StateVersion. Returns ErrNotFound if agent doesn't exist. Returns ErrVersionConflic

Name returns the channel identifier (e.g., "webhook", "slack").

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

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

setupNotificationTest creates an in-memory SQLite store, event publisher, recording dispatcher, project, watched agent, subscriber agent, and subscrip

testEvaluatorStore creates a fresh in-memory store for evaluator tests.

AddPolicyBinding binds a principal (user, group, or agent) to a policy. Returns ErrAlreadyExists if the binding already exists.

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

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

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

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

AddField adds the value to the field with the given name. It returns an error if the field is not defined in the schema, or if the type mismatched the

GetGroupBySlug retrieves a group by its slug. Returns ErrNotFound if the group doesn't exist.

GetTemplate retrieves a template by ID. Returns ErrNotFound if the template doesn't exist.

GetTemplateBySlug retrieves a template by its slug and scope. Returns ErrNotFound if the template doesn't exist.

LoadHarnessConfigDir loads a harness-config from an on-disk directory.

New creates a new TelegramBroker with the given logger.

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

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

ensureHubMembership adds the given user to the hub-members group. This is best-effort; errors are logged at debug level and ignored.

Count returns the count of the given query.

Delete terminates and removes an agent

Execute performs the action defined in the hook for the given agent and trigger. Implementations MUST NOT panic; panics will be recovered by the evalu

New creates a new Hub API server.

Templates returns the template operations interface.

permSeedUser ensures a user row exists so that group-membership / policy-binding foreign keys resolve. The Ent store enforces user/agent FK edges that

Delete removes an environment variable.

GenerateTokenPair generates an access token and refresh token for a user.

GetDispatcher returns the current agent dispatcher.

GetProjectID looks up the project ID from HubContext or settings. Priority: 1. ProjectID field in HubContext (set by EnsureHubReady) 2. Local project_

Handle processes an event and updates the agent status.

ListHarnessConfigs returns harness configs matching the filter criteria.

New creates a new template cache at the specified base path. If maxSize is 0, DefaultMaxSize is used.

ValidateSettings validates raw settings data (YAML or JSON) against the embedded JSON Schema for the given schema version. The data is first converte

seedLifecycleHook creates a lifecycle hook in the store and returns it.

setupDemoPolicyTest creates a test server with two users and a project. User "alice" is a project member (project creator); user "bob" is not. Both ar

Client returns a Client that binds to current transaction.

Description returns the value of the "description" field in the mutation.

DetectSettingsFormat inspects raw settings data (YAML or JSON) and determines whether it uses the versioned format or the legacy format. Returns: - v

GetAgent retrieves an agent by ID. Returns ErrNotFound if the agent doesn't exist.

GetProjectName returns the slugified name of the project.

NewLifecycleHookEvaluator creates a new evaluator. The executor is injectable; pass nil to use the default LoggingExecutor. The events parameter accep

ScopeID returns the value of the "scope_id" field in the mutation.

SetCreated sets the "created" field.

UpdateActivity writes the activity to the agent-info.json file atomically. Used for runtime activity changes (most events). Preserves the current phas

UpdateStatus sends a status update to the Hub with automatic retry on transient failures.

doRequestNoAuth performs an HTTP request without authentication. Use this for testing unauthenticated access or auth endpoints themselves.

CreatedByCleared returns if the "created_by" field was cleared in this mutation.

Enabled reports whether metrics are backed by a real (non-no-op) MeterProvider. Callers may use this to skip building attribute sets when nothing will