Documentation
¶
Index ¶
- func SetFeishuRegistrationEndpointForTesting(endpoint string) func()
- type AuthInfo
- type DBPinger
- type Deps
- type OIDCDeps
- type Server
- func (s *Server) AbandonGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ActivateGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) AddEdge(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) AddGroupMember(w http.ResponseWriter, r *http.Request, groupId string)
- func (s *Server) AddProfileConstraint(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) ApprovePlan(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) AssignAgentUser(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) BeginDrain()
- func (s *Server) BeginFeishuRegistration(w http.ResponseWriter, r *http.Request)
- func (s *Server) BeginWeixinRegistration(w http.ResponseWriter, r *http.Request)
- func (s *Server) CancelGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ChangePassword(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateAgent(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateAgentSkill(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) CreateChannel(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateFeed(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateFeedEntry(w http.ResponseWriter, r *http.Request, feedId string)
- func (s *Server) CreateGoal(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateGoalTimelineEvent(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) CreateGroup(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateOAuthClient(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreatePersonalAccessToken(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) CreateProject(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) CreateProvider(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateSchedulerJob(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) CreateScopedMCPServer(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateScopedSkill(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateSession(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) CreateShare(w http.ResponseWriter, r *http.Request)
- func (s *Server) CreateWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) DeleteAgent(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, ...)
- func (s *Server) DeleteAgentSkillFile(w http.ResponseWriter, r *http.Request, id string, skillId string, ...)
- func (s *Server) DeleteArticle(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteAuthSession(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteAuthUserIdentity(w http.ResponseWriter, r *http.Request, id string, identityId string)
- func (s *Server) DeleteChannel(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteFeed(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteGroup(w http.ResponseWriter, r *http.Request, groupId string)
- func (s *Server) DeleteOAuthProviderConfig(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteProfileConstraint(w http.ResponseWriter, r *http.Request, agentID string, constraintID string)
- func (s *Server) DeleteProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, factID string)
- func (s *Server) DeleteProfileMemory(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) DeleteProject(w http.ResponseWriter, r *http.Request, agentID string, projectID string)
- func (s *Server) DeleteProvider(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteSchedulerJob(w http.ResponseWriter, r *http.Request, agentID string, jobID string)
- func (s *Server) DeleteScopedMCPServer(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) DeleteScopedSkill(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteScopedSkillFile(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) DeleteScopedVaultEntry(w http.ResponseWriter, r *http.Request, name string, ...)
- func (s *Server) DeleteSession(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) DeleteUserMemory(w http.ResponseWriter, r *http.Request, id string, agentID string)
- func (s *Server) DeleteWorkflow(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) DeleteWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) DisableOAuthClient(w http.ResponseWriter, r *http.Request, clientId string)
- func (s *Server) DisconnectOAuth(w http.ResponseWriter, r *http.Request, provider string)
- func (s *Server) FetchProviderModels(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GenerateLinkCode(w http.ResponseWriter, r *http.Request)
- func (s *Server) GetAgent(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, ...)
- func (s *Server) GetAgentSkillFile(w http.ResponseWriter, r *http.Request, id string, skillId string, ...)
- func (s *Server) GetArticle(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) GetAttempt(w http.ResponseWriter, r *http.Request, id string, attemptId string)
- func (s *Server) GetAuthUser(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetBuiltinResource(w http.ResponseWriter, r *http.Request, kindStr string, id string)
- func (s *Server) GetChannel(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetClawhubSkill(w http.ResponseWriter, r *http.Request, slug string)
- func (s *Server) GetCliToolLatest(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) GetDigest(w http.ResponseWriter, r *http.Request)
- func (s *Server) GetEmailMessage(w http.ResponseWriter, r *http.Request, uid int, ...)
- func (s *Server) GetEmbeddingSettings(w http.ResponseWriter, r *http.Request)
- func (s *Server) GetFeed(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetGoalHealth(w http.ResponseWriter, r *http.Request, params apiserver.GetGoalHealthParams)
- func (s *Server) GetGoalReadiness(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetGroup(w http.ResponseWriter, r *http.Request, groupId string)
- func (s *Server) GetMe(w http.ResponseWriter, r *http.Request)
- func (s *Server) GetOAuthConnected(w http.ResponseWriter, r *http.Request, provider string)
- func (s *Server) GetOAuthProviderConfig(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetPersonalAccessToken(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetPluginConfig(w http.ResponseWriter, r *http.Request, kind string, name string)
- func (s *Server) GetPluginConfigSchema(w http.ResponseWriter, r *http.Request, kind string, name string)
- func (s *Server) GetPluginStatus(w http.ResponseWriter, r *http.Request, kind string, name string)
- func (s *Server) GetProfileMemory(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) GetProject(w http.ResponseWriter, r *http.Request, agentID string, projectID string)
- func (s *Server) GetProvider(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetSchedulerJob(w http.ResponseWriter, r *http.Request, agentID string, jobID string)
- func (s *Server) GetScopedSkill(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetScopedSkillFile(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) GetScopedVaultEntry(w http.ResponseWriter, r *http.Request, name string, ...)
- func (s *Server) GetSession(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) GetSessionContextItems(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) GetSessionMessages(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) GetSessionSummary(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) GetSessionSystemPrompt(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) GetSessionWorkspace(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) GetShareContent(w http.ResponseWriter, r *http.Request, token string)
- func (s *Server) GetStatus(w http.ResponseWriter, r *http.Request)
- func (s *Server) GetStoredDigest(w http.ResponseWriter, r *http.Request, date string)
- func (s *Server) GetWorkflow(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) GetWorkspaceFileContent(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) Handler() http.Handler
- func (s *Server) InitFeishuRegistration(w http.ResponseWriter, r *http.Request)
- func (s *Server) InstallAgentSkill(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) InstallScopedSkill(w http.ResponseWriter, r *http.Request)
- func (s *Server) InstantiateWorkflow(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) LinkAuthUserLoginIdentity(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) LinkCodes() *auth.LinkCodeStore
- func (s *Server) ListAcceptanceEvents(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAgentSkills(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) ListAgentTools(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAgentUsers(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAgents(w http.ResponseWriter, r *http.Request, params apiserver.ListAgentsParams)
- func (s *Server) ListArticles(w http.ResponseWriter, r *http.Request, params apiserver.ListArticlesParams)
- func (s *Server) ListAttempts(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAuthProviders(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListAuthSessions(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListAuthUserAgents(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAuthUserChannelIdentities(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAuthUserLoginIdentities(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListAuthUsers(w http.ResponseWriter, r *http.Request, params apiserver.ListAuthUsersParams)
- func (s *Server) ListAuthorizedApps(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListBuiltinResources(w http.ResponseWriter, r *http.Request, kindStr string)
- func (s *Server) ListChannels(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListClawhubSkills(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListEdges(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListEmailAccounts(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListEmailFolders(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListEmailMessages(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListFeedEntries(w http.ResponseWriter, r *http.Request, feedId string, ...)
- func (s *Server) ListFeeds(w http.ResponseWriter, r *http.Request, params apiserver.ListFeedsParams)
- func (s *Server) ListGoalChildren(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListGoalTimeline(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) ListGoals(w http.ResponseWriter, r *http.Request, params apiserver.ListGoalsParams)
- func (s *Server) ListGroupMembers(w http.ResponseWriter, r *http.Request, groupId string)
- func (s *Server) ListGroupMessages(w http.ResponseWriter, r *http.Request, groupId string, ...)
- func (s *Server) ListGroups(w http.ResponseWriter, r *http.Request, params apiserver.ListGroupsParams)
- func (s *Server) ListInbox(w http.ResponseWriter, r *http.Request, params apiserver.ListInboxParams)
- func (s *Server) ListJobTemplates(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListManifestPlugins(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListModels(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListOAuthClientScopes(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListOAuthClients(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListOAuthProviders(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListPersonalAccessTokens(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListPlugins(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListProfileChangelog(w http.ResponseWriter, r *http.Request, agentID string, ...)
- func (s *Server) ListProfileConstraints(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) ListProfileIdentities(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, ...)
- func (s *Server) ListProfileMemories(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListProjects(w http.ResponseWriter, r *http.Request, agentID string, ...)
- func (s *Server) ListProviderModels(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListProviderTypes(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListProviders(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListPublicChannels(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListSchedulerJobRuns(w http.ResponseWriter, r *http.Request, agentID string, jobID string, ...)
- func (s *Server) ListSchedulerJobs(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) ListScopedMCPServers(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListScopedSkills(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListScopedVaultEntries(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListSessions(w http.ResponseWriter, r *http.Request, agentID string, ...)
- func (s *Server) ListShares(w http.ResponseWriter, r *http.Request, params apiserver.ListSharesParams)
- func (s *Server) ListStoredDigests(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) ListTokenScopes(w http.ResponseWriter, r *http.Request)
- func (s *Server) ListUserMemories(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) ListWorkflowRuns(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) ListWorkflows(w http.ResponseWriter, r *http.Request, params apiserver.ListWorkflowsParams)
- func (s *Server) LoginLocal(w http.ResponseWriter, r *http.Request)
- func (s *Server) Logout(w http.ResponseWriter, r *http.Request)
- func (s *Server) MarkEmailMessage(w http.ResponseWriter, r *http.Request, uid int, ...)
- func (s *Server) MarkStartupComplete()
- func (s *Server) MoveWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) OauthCallback(w http.ResponseWriter, r *http.Request, provider string, ...)
- func (s *Server) OauthCallbackLegacy(w http.ResponseWriter, r *http.Request, provider string, ...)
- func (s *Server) PollFeed(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) PollFeishuRegistration(w http.ResponseWriter, r *http.Request)
- func (s *Server) PollOAuthFlow(w http.ResponseWriter, r *http.Request, provider string, flowID string)
- func (s *Server) PollWeixinQRStatus(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) PollWeixinRegistration(w http.ResponseWriter, r *http.Request)
- func (s *Server) ReattemptGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) RegisterLocal(w http.ResponseWriter, r *http.Request)
- func (s *Server) RejectPlan(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) RemoveAgentUser(w http.ResponseWriter, r *http.Request, id string, userId string)
- func (s *Server) RemoveGroupMember(w http.ResponseWriter, r *http.Request, groupId string, agentId string)
- func (s *Server) RestoreProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, factID string)
- func (s *Server) RevokeAuthorizedApp(w http.ResponseWriter, r *http.Request, clientId string)
- func (s *Server) RevokePersonalAccessToken(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) RevokeShare(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) RotateOAuthClientSecret(w http.ResponseWriter, r *http.Request, clientId string)
- func (s *Server) SaveArticle(w http.ResponseWriter, r *http.Request)
- func (s *Server) SaveDigest(w http.ResponseWriter, r *http.Request)
- func (s *Server) SaveGoalAsWorkflow(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) SaveManifestPlugins(w http.ResponseWriter, r *http.Request)
- func (s *Server) SearchCliToolRegistry(w http.ResponseWriter, r *http.Request, ...)
- func (s *Server) SearchSkills(w http.ResponseWriter, r *http.Request, params apiserver.SearchSkillsParams)
- func (s *Server) SendEmail(w http.ResponseWriter, r *http.Request, params apiserver.SendEmailParams)
- func (s *Server) SendGroupMessage(w http.ResponseWriter, r *http.Request, groupId string)
- func (s *Server) SendSessionMessage(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) SetOAuthProviderConfig(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) SetProfileMemory(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) SetProfileSoul(w http.ResponseWriter, r *http.Request, agentID string)
- func (s *Server) SetScopedVaultEntry(w http.ResponseWriter, r *http.Request, name string)
- func (s *Server) SetUserMemory(w http.ResponseWriter, r *http.Request, id string, agentID string)
- func (s *Server) StartOAuthFlow(w http.ResponseWriter, r *http.Request, provider string)
- func (s *Server) StartWeixinQR(w http.ResponseWriter, r *http.Request)
- func (s *Server) StreamSessionEvents(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) SubmitVerdict(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) SyncManifestPlugins(w http.ResponseWriter, r *http.Request)
- func (s *Server) TogglePlugin(w http.ResponseWriter, r *http.Request, kind string, name string)
- func (s *Server) TriggerSchedulerJob(w http.ResponseWriter, r *http.Request, agentID string, jobID string)
- func (s *Server) UnarchiveGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UnlinkProfileIdentity(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateAgent(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, ...)
- func (s *Server) UpdateAgentTool(w http.ResponseWriter, r *http.Request, id string, toolName string)
- func (s *Server) UpdateArticle(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateAuthUserActive(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateAuthUserAgents(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateAuthUserRole(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateChannel(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateEmbeddingSettings(w http.ResponseWriter, r *http.Request)
- func (s *Server) UpdateFeed(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateFeedEntry(w http.ResponseWriter, r *http.Request, feedId string, id string)
- func (s *Server) UpdateGoal(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateGroup(w http.ResponseWriter, r *http.Request, groupId string)
- func (s *Server) UpdatePluginConfig(w http.ResponseWriter, r *http.Request, kind string, name string)
- func (s *Server) UpdateProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, factID string)
- func (s *Server) UpdateProject(w http.ResponseWriter, r *http.Request, agentID string, projectID string)
- func (s *Server) UpdateProvider(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateSchedulerJob(w http.ResponseWriter, r *http.Request, agentID string, jobID string)
- func (s *Server) UpdateScopedMCPServer(w http.ResponseWriter, r *http.Request, id string, ...)
- func (s *Server) UpdateScopedSkill(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateSession(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) UpdateUserDefaultAgent(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateUserNotifyIdentity(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UpdateWorkspaceFileContent(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, ...)
- func (s *Server) UpgradeAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, ...)
- func (s *Server) UploadAgentSkill(w http.ResponseWriter, r *http.Request, id string)
- func (s *Server) UploadScopedSkill(w http.ResponseWriter, r *http.Request)
- func (s *Server) UploadWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
- func (s *Server) WaiveEdge(w http.ResponseWriter, r *http.Request, id string, upstreamId string)
- func (s *Server) WebhookIngressHandler() http.Handler
- type WeixinQRCode
- type WeixinQRCodeStatus
- type WeixinRegistrar
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetFeishuRegistrationEndpointForTesting ¶ added in v0.48.0
func SetFeishuRegistrationEndpointForTesting(endpoint string) func()
Types ¶
type AuthInfo ¶
type AuthInfo struct {
UserID string `json:"user_id"`
Username string `json:"username"`
Role string `json:"role"`
IsAdmin bool `json:"is_admin"`
// OIDC principal fields; empty for legacy (password-based) sessions.
Email string `json:"email,omitempty"`
Name string `json:"name,omitempty"`
AvatarURL string `json:"avatar_url,omitempty"`
// contains filtered or unexported fields
}
AuthInfo carries authenticated user data through request context.
func UserFromContext ¶
UserFromContext extracts the AuthInfo from a request context. Returns nil if the user is not authenticated.
type DBPinger ¶ added in v0.60.0
DBPinger is the minimal database liveness surface the /healthz, /readyz, and admin status probes need. *pgxpool.Pool satisfies it; the composition root injects the pool as this narrow port so the probes can ping the database but never reach an application query. Tests inject a fake to exercise the failure branch without a real database.
type Deps ¶ added in v0.60.0
type Deps struct {
// Pinger is the narrow database-liveness port backing the /healthz, /readyz,
// and admin status probes. The composition root injects the pool as this
// narrow port so the transport can never reach an application query — every
// data access is routed through a domain service below.
Pinger DBPinger
// ChannelResolver is the narrow runtime read port for webhook/channel and
// agent-name lookups, replacing the aggregate config.Store on the transport.
ChannelResolver *channel.RuntimeResolver
// Account owns the user-account application boundary: admin/self user
// reads/mutations, login/channel identities, sessions, password credential,
// and agent assignments, with the role/deactivation revocation invariants.
Account *account.Service
// Profile owns the per-(user, agent) memory application boundary: profile,
// soul, constraints, changelog, list, and reset, with the Agent-access gate
// and change-source audit. The transport no longer reaches memory.Provider,
// memorywrite, or the query layer for these.
Profile *memprofile.Service
// ProjectStore owns the Authority-bound project use cases (list/create/get/
// update/delete) with the Agent gate, ownership, route-agent binding, and
// workspace-containment invariant. Inbox is the cross-Goal/Scheduler inbox
// read model. Both keep the query layer out of the transport.
ProjectStore *agent.ProjectStore
Inbox *inbox.Service
// Authorization. AgentAccess and SessionAccess own their domain rules over
// trusted Authority values and durable state.
AgentAccess *agentaccess.Service
SessionAccess *sessionaccess.Service
// AgentManagement owns the Agent write use cases (create/update/delete, admin
// assignment, conversation-activity read model). It layers on AgentAccess for
// authorization and holds the durable write + runtime-reload ports so the HTTP
// transport no longer orchestrates them.
AgentManagement *agentaccess.Management
// ToolOverrides persists per-agent tool-visibility overrides. The transport
// holds this narrow domain store instead of the aggregate query handle.
ToolOverrides *agent.ToolOverrideStore
// SkillAccess is the DB-backed Skill enforcement point. When nil the
// skill endpoints report 503 through the centralized unavailable mapping.
SkillAccess *skillaccess.Service
LinkCodes *auth.LinkCodeStore
OIDC OIDCDeps
// Agent runtime + plugins.
PoolManager *agent.PoolManager
PluginHost *pluginhost.Host
BuiltinTools []agent.BuiltinTool
// WeixinRegistrar reaches the iLink API for the WeChat QR/registration
// handlers. The composition root supplies the concrete adapter (which wraps
// the weixin plugin client) so internal/server never imports the plugin.
WeixinRegistrar WeixinRegistrar
// Public addressing, resolved once at the startup boundary. Never a
// localhost placeholder mutated later.
BaseURL string
// Shared domain services — single, fully-wired instances built by the
// composition root. The same instances back both the agent tools and the
// HTTP endpoints, so there is one source of truth per capability.
Credentials *connections.Service
ControlPlane *controlplane.Service
Email *email.Service
Recally *recally.Service
CredentialFrontDoor *credential.Service
OAuthAuthServer *oidc.Service
// Group owns the Web group/channel application boundary: authorized CRUD,
// membership with the last-member invariant, message list, and the send path
// (command interception, dedup append + outbox claim, synchronous dispatch).
// It holds the event log and group dispatcher internally, so the transport no
// longer reaches the query layer or sqlc for groups.
Group *channel.GroupService
// Assets is the authoritative asset persistence service. Session workspace
// handlers use its narrow durable-write/restore/move/delete ports instead of a
// raw blob store, so the HTTP transport never holds process-global blob state.
Assets *asset.Store
// Optional capabilities. A nil field is a supported configuration: the
// matching endpoints report 503 through the centralized unavailable mapping
// (see capabilityUnavailable). Presence is never inferred from the
// environment inside the server.
Vault *vault.Service
VaultRecipient *age.X25519Recipient
MCP *mcp.Service
Scheduler *scheduler.Service
Goal *goal.Service
Workflow *workflowpkg.Service
}
Deps is the immutable, validated dependency set for the admin Server. The composition root constructs every value exactly once — including the single shared credentials/email/share/recally instances and the credential front door, already resolved against the final base URL — and hands them here. Server.New reads no environment, constructs no shadow service, and chooses no implementation; it only wires these into HTTP routes. The struct is copied into the Server at construction and never mutated afterward: there are no post-construction setters.
type OIDCDeps ¶ added in v0.60.0
type OIDCDeps struct {
Providers []auth.AuthProvider
AuthSvc *auth.AuthService
SessionMgr *auth.SessionManager
StateMgr *authoidc.StateManager
LocalAuth *local.Service
}
OIDCDeps groups the login-authentication components produced by oidc.Setup. The account identity stores no longer live here: they are composed inside the Account service (Deps.Account). LocalAuth is nil in external-OIDC mode.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server provides HTTP handlers for the admin API and embedded web UI.
func New ¶
New creates an admin server with all API routes mounted. It validates deps and returns an error if any required dependency is missing. It reads no environment, constructs no shared/shadow service, and installs no setters — every dependency arrives through the immutable Deps. The server does not own the lifecycle of any injected dependency and never closes one.
func (*Server) AbandonGoal ¶ added in v0.49.4
AbandonGoal is the human give-up on a budget-exhausted block.
func (*Server) ActivateGoal ¶ added in v0.38.0
ActivateGoal runs the plan gate (draft → ready).
func (*Server) AddEdge ¶ added in v0.49.4
AddEdge inserts an upstream dependency edge (cycle-checked).
func (*Server) AddGroupMember ¶ added in v0.43.0
func (*Server) AddProfileConstraint ¶ added in v0.39.1
AddProfileConstraint handles POST /api/users/me/memories/{agentID}/constraints.
func (*Server) ApprovePlan ¶ added in v0.50.0
ApprovePlan approves a composite's proposed plan (blocked(needs_plan_approval)), materializing its children and resuming the tree.
func (*Server) AssignAgentUser ¶
func (*Server) BeginDrain ¶ added in v0.60.0
func (s *Server) BeginDrain()
BeginDrain starts graceful shutdown from the server's side: /readyz flips to 503 and streaming handlers unwind. The shutdown orchestrator calls it before it touches the HTTP listener.
func (*Server) BeginFeishuRegistration ¶ added in v0.48.0
func (s *Server) BeginFeishuRegistration(w http.ResponseWriter, r *http.Request)
func (*Server) BeginWeixinRegistration ¶ added in v0.48.0
func (s *Server) BeginWeixinRegistration(w http.ResponseWriter, r *http.Request)
func (*Server) CancelGoal ¶ added in v0.38.0
CancelGoal cancels a goal, cascading over its non-terminal subtree.
func (*Server) ChangePassword ¶
func (s *Server) ChangePassword(w http.ResponseWriter, r *http.Request)
ChangePassword handles PATCH /api/users/me/password.
func (*Server) CreateAgent ¶
func (s *Server) CreateAgent(w http.ResponseWriter, r *http.Request)
func (*Server) CreateAgentSkill ¶ added in v0.38.0
func (*Server) CreateChannel ¶
func (s *Server) CreateChannel(w http.ResponseWriter, r *http.Request)
func (*Server) CreateFeed ¶
func (s *Server) CreateFeed(w http.ResponseWriter, r *http.Request)
func (*Server) CreateFeedEntry ¶ added in v0.43.0
func (*Server) CreateGoal ¶ added in v0.38.0
func (s *Server) CreateGoal(w http.ResponseWriter, r *http.Request)
CreateGoal mints a root goal (goal). With activate=true a leaf is activated immediately (direct run); the flag is ignored for a composite, which is decomposed and materialized by the dispatcher first.
func (*Server) CreateGoalTimelineEvent ¶ added in v0.60.0
CreateGoalTimelineEvent appends a human message and reattempts non-dep blocks.
func (*Server) CreateGroup ¶ added in v0.43.0
func (s *Server) CreateGroup(w http.ResponseWriter, r *http.Request)
func (*Server) CreateOAuthClient ¶ added in v0.60.0
func (s *Server) CreateOAuthClient(w http.ResponseWriter, r *http.Request)
CreateOAuthClient handles POST /api/users/me/oauth-clients. The plaintext secret is returned exactly once (empty for public clients).
func (*Server) CreatePersonalAccessToken ¶ added in v0.60.0
func (s *Server) CreatePersonalAccessToken(w http.ResponseWriter, r *http.Request)
CreatePersonalAccessToken handles POST /api/users/me/tokens. The plaintext token is returned exactly once here and is never retrievable again.
func (*Server) CreateProfileKnowledge ¶ added in v0.60.0
CreateProfileKnowledge handles POST /api/users/me/memories/{agentId}/knowledge.
func (*Server) CreateProject ¶ added in v0.34.0
func (*Server) CreateProvider ¶
func (s *Server) CreateProvider(w http.ResponseWriter, r *http.Request)
func (*Server) CreateSchedulerJob ¶
func (*Server) CreateScopedMCPServer ¶ added in v0.60.0
func (s *Server) CreateScopedMCPServer(w http.ResponseWriter, r *http.Request)
CreateScopedMCPServer handles POST /api/mcp/servers.
func (*Server) CreateScopedSkill ¶ added in v0.48.0
func (s *Server) CreateScopedSkill(w http.ResponseWriter, r *http.Request)
CreateScopedSkill handles POST /api/skills.
func (*Server) CreateSession ¶
func (*Server) CreateShare ¶ added in v0.35.0
func (s *Server) CreateShare(w http.ResponseWriter, r *http.Request)
func (*Server) CreateWorkspaceFile ¶
func (s *Server) CreateWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.CreateWorkspaceFileParams)
func (*Server) DeleteAgent ¶
func (*Server) DeleteAgentSkill ¶
func (s *Server) DeleteAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, params apiserver.DeleteAgentSkillParams)
func (*Server) DeleteAgentSkillFile ¶
func (s *Server) DeleteAgentSkillFile(w http.ResponseWriter, r *http.Request, id string, skillId string, params apiserver.DeleteAgentSkillFileParams)
func (*Server) DeleteArticle ¶
func (*Server) DeleteAuthSession ¶ added in v0.38.0
DeleteAuthSession handles DELETE /api/auth/sessions/{id}.
func (*Server) DeleteAuthUserIdentity ¶
func (s *Server) DeleteAuthUserIdentity(w http.ResponseWriter, r *http.Request, id string, identityId string)
DeleteAuthUserIdentity handles DELETE /api/users/{id}/identities/{identityId}.
func (*Server) DeleteChannel ¶
func (*Server) DeleteFeed ¶
func (*Server) DeleteGoal ¶ added in v0.49.4
DeleteGoal archives a goal (audit-safe delete).
func (*Server) DeleteGroup ¶ added in v0.43.0
func (*Server) DeleteOAuthProviderConfig ¶
DeleteOAuthProviderConfig handles DELETE /api/admin/oauth-providers/{id}/config.
func (*Server) DeleteProfileConstraint ¶ added in v0.39.1
func (s *Server) DeleteProfileConstraint(w http.ResponseWriter, r *http.Request, agentID string, constraintID string)
DeleteProfileConstraint handles DELETE /api/users/me/memories/{agentID}/constraints/{constraintID}.
func (*Server) DeleteProfileKnowledge ¶ added in v0.60.0
func (s *Server) DeleteProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, factID string)
DeleteProfileKnowledge handles DELETE /api/users/me/memories/{agentId}/knowledge/{factId}.
func (*Server) DeleteProfileMemory ¶
DeleteProfileMemory handles DELETE /api/users/me/memories/{agentID}.
func (*Server) DeleteProject ¶ added in v0.34.0
func (*Server) DeleteProvider ¶
func (*Server) DeleteSchedulerJob ¶
func (*Server) DeleteScopedMCPServer ¶ added in v0.60.0
func (s *Server) DeleteScopedMCPServer(w http.ResponseWriter, r *http.Request, id string, params apiserver.DeleteScopedMCPServerParams)
DeleteScopedMCPServer handles DELETE /api/mcp/servers/{id}.
func (*Server) DeleteScopedSkill ¶ added in v0.48.0
DeleteScopedSkill handles DELETE /api/skills/{id}.
func (*Server) DeleteScopedSkillFile ¶ added in v0.48.0
func (s *Server) DeleteScopedSkillFile(w http.ResponseWriter, r *http.Request, id string, params apiserver.DeleteScopedSkillFileParams)
DeleteScopedSkillFile handles DELETE /api/skills/{id}/file.
func (*Server) DeleteScopedVaultEntry ¶ added in v0.48.0
func (s *Server) DeleteScopedVaultEntry(w http.ResponseWriter, r *http.Request, name string, params apiserver.DeleteScopedVaultEntryParams)
DeleteScopedVaultEntry handles DELETE /api/vault/{name}.
func (*Server) DeleteSession ¶ added in v0.46.0
func (*Server) DeleteUserMemory ¶
func (*Server) DeleteWorkflow ¶ added in v0.60.0
func (*Server) DeleteWorkspaceFile ¶
func (s *Server) DeleteWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.DeleteWorkspaceFileParams)
func (*Server) DisableOAuthClient ¶ added in v0.60.0
DisableOAuthClient handles DELETE /api/users/me/oauth-clients/{clientId}.
func (*Server) DisconnectOAuth ¶
DisconnectOAuth handles DELETE /api/users/me/oauth/{provider}.
func (*Server) FetchProviderModels ¶
func (*Server) GenerateLinkCode ¶
func (s *Server) GenerateLinkCode(w http.ResponseWriter, r *http.Request)
GenerateLinkCode handles POST /api/users/me/link-code.
func (*Server) GetAgentSkill ¶
func (s *Server) GetAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, params apiserver.GetAgentSkillParams)
func (*Server) GetAgentSkillFile ¶
func (s *Server) GetAgentSkillFile(w http.ResponseWriter, r *http.Request, id string, skillId string, params apiserver.GetAgentSkillFileParams)
func (*Server) GetArticle ¶
func (s *Server) GetArticle(w http.ResponseWriter, r *http.Request, id string, params apiserver.GetArticleParams)
func (*Server) GetAttempt ¶ added in v0.49.4
GetAttempt returns one attempt, scoped to its goal.
func (*Server) GetAuthUser ¶
GetAuthUser handles GET /api/users/{id}.
func (*Server) GetBuiltinResource ¶
func (*Server) GetChannel ¶
func (*Server) GetClawhubSkill ¶ added in v0.47.0
GetClawhubSkill handles GET /api/clawhub/skills/{slug}, returning a single skill's metadata together with its README and file list (downloaded from ClawHub on demand).
func (*Server) GetCliToolLatest ¶ added in v0.45.0
func (s *Server) GetCliToolLatest(w http.ResponseWriter, r *http.Request, params apiserver.GetCliToolLatestParams)
GetCliToolLatest resolves the latest installable version for a mise tool key, letting the UI pin a tool to its current latest without the admin running mise.
func (*Server) GetEmailMessage ¶ added in v0.43.0
func (s *Server) GetEmailMessage(w http.ResponseWriter, r *http.Request, uid int, params apiserver.GetEmailMessageParams)
GetEmailMessage handles GET /api/email/messages/{uid}.
func (*Server) GetEmbeddingSettings ¶ added in v0.50.3
func (s *Server) GetEmbeddingSettings(w http.ResponseWriter, r *http.Request)
GetEmbeddingSettings returns the deployment-wide embedding configuration. The API key is never returned; has_api_key reports whether one is stored.
func (*Server) GetGoalHealth ¶ added in v0.60.0
func (s *Server) GetGoalHealth(w http.ResponseWriter, r *http.Request, params apiserver.GetGoalHealthParams)
GetGoalHealth returns the aggregated execution health report for a time window. The report is computed only over goals the caller may read (Access.HealthReport authorizes every row under one evaluation), so a per-resource deny never leaks a hidden goal into the totals.
func (*Server) GetGoalReadiness ¶ added in v0.49.4
GetGoalReadiness returns the computed dispatchability view.
func (*Server) GetMe ¶
func (s *Server) GetMe(w http.ResponseWriter, r *http.Request)
GetMe handles GET /api/auth/me.
func (*Server) GetOAuthConnected ¶
GetOAuthConnected handles GET /api/users/me/oauth/{provider}/connected.
func (*Server) GetOAuthProviderConfig ¶
GetOAuthProviderConfig handles GET /api/admin/oauth-providers/{id}/config.
func (*Server) GetPersonalAccessToken ¶ added in v0.60.0
GetPersonalAccessToken handles GET /api/users/me/tokens/{id}. The lookup is scoped to the caller, so a token owned by another user is indistinguishable from a missing one (404) -- ownership is checked before existence is revealed.
func (*Server) GetPluginConfig ¶
func (*Server) GetPluginConfigSchema ¶
func (*Server) GetPluginStatus ¶
func (*Server) GetProfileMemory ¶ added in v0.39.1
GetProfileMemory handles GET /api/users/me/memories/{agentID}.
func (*Server) GetProject ¶ added in v0.34.0
func (*Server) GetProvider ¶
func (*Server) GetSchedulerJob ¶ added in v0.36.0
func (*Server) GetScopedSkill ¶ added in v0.48.0
GetScopedSkill handles GET /api/skills/{id}.
func (*Server) GetScopedSkillFile ¶ added in v0.48.0
func (s *Server) GetScopedSkillFile(w http.ResponseWriter, r *http.Request, id string, params apiserver.GetScopedSkillFileParams)
GetScopedSkillFile handles GET /api/skills/{id}/file.
func (*Server) GetScopedVaultEntry ¶ added in v0.48.0
func (s *Server) GetScopedVaultEntry(w http.ResponseWriter, r *http.Request, name string, params apiserver.GetScopedVaultEntryParams)
GetScopedVaultEntry handles GET /api/vault/{name}.
func (*Server) GetSession ¶
func (*Server) GetSessionContextItems ¶ added in v0.46.0
func (s *Server) GetSessionContextItems(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.GetSessionContextItemsParams)
func (*Server) GetSessionMessages ¶
func (s *Server) GetSessionMessages(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.GetSessionMessagesParams)
func (*Server) GetSessionSummary ¶ added in v0.46.0
func (*Server) GetSessionSystemPrompt ¶
func (*Server) GetSessionWorkspace ¶
func (s *Server) GetSessionWorkspace(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.GetSessionWorkspaceParams)
func (*Server) GetShareContent ¶ added in v0.35.0
func (*Server) GetStoredDigest ¶
func (*Server) GetWorkflow ¶ added in v0.60.0
func (*Server) GetWorkspaceFileContent ¶
func (s *Server) GetWorkspaceFileContent(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.GetWorkspaceFileContentParams)
func (*Server) Handler ¶
Handler returns the HTTP handler with OTel instrumentation wrapping the access-log, CORS, JSON, and auth middleware chain. The OTel wrap is unconditional: it is a no-op when tracing is disabled. The access log sits directly inside it so log lines can carry the request's trace_id.
func (*Server) InitFeishuRegistration ¶ added in v0.48.0
func (s *Server) InitFeishuRegistration(w http.ResponseWriter, r *http.Request)
func (*Server) InstallAgentSkill ¶
func (*Server) InstallScopedSkill ¶ added in v0.48.0
func (s *Server) InstallScopedSkill(w http.ResponseWriter, r *http.Request)
InstallScopedSkill handles POST /api/skills/install.
func (*Server) InstantiateWorkflow ¶ added in v0.60.0
func (*Server) LinkAuthUserLoginIdentity ¶ added in v0.38.0
LinkAuthUserLoginIdentity handles POST /api/users/{id}/identities/login.
func (*Server) LinkCodes ¶
func (s *Server) LinkCodes() *auth.LinkCodeStore
LinkCodes returns the link code store for use by channel handlers.
func (*Server) ListAcceptanceEvents ¶ added in v0.49.4
ListAcceptanceEvents lists the acceptance ledger (audit trail, in fold order).
func (*Server) ListAgentSkills ¶
func (s *Server) ListAgentSkills(w http.ResponseWriter, r *http.Request, id string, params apiserver.ListAgentSkillsParams)
func (*Server) ListAgentTools ¶ added in v0.60.0
func (*Server) ListAgentUsers ¶
func (*Server) ListAgents ¶
func (s *Server) ListAgents(w http.ResponseWriter, r *http.Request, params apiserver.ListAgentsParams)
func (*Server) ListArticles ¶
func (s *Server) ListArticles(w http.ResponseWriter, r *http.Request, params apiserver.ListArticlesParams)
func (*Server) ListAttempts ¶ added in v0.49.4
ListAttempts lists a goal's attempts (newest first).
func (*Server) ListAuthProviders ¶ added in v0.38.0
func (s *Server) ListAuthProviders(w http.ResponseWriter, r *http.Request)
ListAuthProviders handles GET /api/auth/providers. Returns the list of configured OIDC providers so the frontend can build login buttons. Public endpoint — no authentication required.
func (*Server) ListAuthSessions ¶ added in v0.38.0
func (s *Server) ListAuthSessions(w http.ResponseWriter, r *http.Request)
ListAuthSessions handles GET /api/auth/sessions.
func (*Server) ListAuthUserAgents ¶
ListAuthUserAgents handles GET /api/users/{id}/agents.
func (*Server) ListAuthUserChannelIdentities ¶ added in v0.38.0
ListAuthUserChannelIdentities handles GET /api/users/{id}/identities/channel.
func (*Server) ListAuthUserLoginIdentities ¶ added in v0.38.0
ListAuthUserLoginIdentities handles GET /api/users/{id}/identities/login.
func (*Server) ListAuthUsers ¶
func (s *Server) ListAuthUsers(w http.ResponseWriter, r *http.Request, params apiserver.ListAuthUsersParams)
ListAuthUsers handles GET /api/users.
func (*Server) ListAuthorizedApps ¶ added in v0.60.0
func (s *Server) ListAuthorizedApps(w http.ResponseWriter, r *http.Request)
ListAuthorizedApps handles GET /api/users/me/authorized-apps.
func (*Server) ListBuiltinResources ¶
func (*Server) ListChannels ¶
func (s *Server) ListChannels(w http.ResponseWriter, r *http.Request)
func (*Server) ListClawhubSkills ¶ added in v0.47.0
func (s *Server) ListClawhubSkills(w http.ResponseWriter, r *http.Request, params apiserver.ListClawhubSkillsParams)
ListClawhubSkills handles GET /api/clawhub/skills. When q is absent it browses popular skills (paginated); when q is set it searches.
func (*Server) ListEmailAccounts ¶ added in v0.60.0
func (s *Server) ListEmailAccounts(w http.ResponseWriter, r *http.Request)
ListEmailAccounts handles GET /api/email/accounts.
func (*Server) ListEmailFolders ¶ added in v0.43.0
func (s *Server) ListEmailFolders(w http.ResponseWriter, r *http.Request, params apiserver.ListEmailFoldersParams)
ListEmailFolders handles GET /api/email/folders.
func (*Server) ListEmailMessages ¶ added in v0.43.0
func (s *Server) ListEmailMessages(w http.ResponseWriter, r *http.Request, params apiserver.ListEmailMessagesParams)
ListEmailMessages handles GET /api/email/messages.
func (*Server) ListFeedEntries ¶
func (s *Server) ListFeedEntries(w http.ResponseWriter, r *http.Request, feedId string, params apiserver.ListFeedEntriesParams)
func (*Server) ListFeeds ¶
func (s *Server) ListFeeds(w http.ResponseWriter, r *http.Request, params apiserver.ListFeedsParams)
func (*Server) ListGoalChildren ¶ added in v0.49.4
ListGoalChildren lists a composite's direct children.
func (*Server) ListGoalTimeline ¶ added in v0.60.0
func (s *Server) ListGoalTimeline(w http.ResponseWriter, r *http.Request, id string, params apiserver.ListGoalTimelineParams)
ListGoalTimeline lists a goal's L3 timeline in chronological order.
func (*Server) ListGoals ¶ added in v0.38.0
func (s *Server) ListGoals(w http.ResponseWriter, r *http.Request, params apiserver.ListGoalsParams)
ListGoals lists root goals (goals) by default; `?parent={id}` lists a composite's children and `?root={id}` lists a whole tree.
func (*Server) ListGroupMembers ¶ added in v0.43.0
func (*Server) ListGroupMessages ¶ added in v0.43.0
func (s *Server) ListGroupMessages(w http.ResponseWriter, r *http.Request, groupId string, params apiserver.ListGroupMessagesParams)
func (*Server) ListGroups ¶ added in v0.43.0
func (s *Server) ListGroups(w http.ResponseWriter, r *http.Request, params apiserver.ListGroupsParams)
func (*Server) ListInbox ¶ added in v0.46.0
func (s *Server) ListInbox(w http.ResponseWriter, r *http.Request, params apiserver.ListInboxParams)
func (*Server) ListJobTemplates ¶ added in v0.46.0
func (s *Server) ListJobTemplates(w http.ResponseWriter, r *http.Request)
ListJobTemplates returns all registered job templates with subscription status resolved for the current user. Returns 503 when the scheduler service is not available.
func (*Server) ListManifestPlugins ¶
func (s *Server) ListManifestPlugins(w http.ResponseWriter, r *http.Request)
func (*Server) ListModels ¶
func (s *Server) ListModels(w http.ResponseWriter, r *http.Request)
ListModels returns the models available for selection: enabled models from enabled providers plus the fetched cache, computed by the control-plane catalog read model. No provider API calls — reads only from the DB.
func (*Server) ListOAuthClientScopes ¶ added in v0.60.0
func (s *Server) ListOAuthClientScopes(w http.ResponseWriter, r *http.Request)
ListOAuthClientScopes handles GET /api/users/me/oauth-client-scopes: the single source of truth for the client-registration UI (catalog + OAuth exposability policy).
func (*Server) ListOAuthClients ¶ added in v0.60.0
func (s *Server) ListOAuthClients(w http.ResponseWriter, r *http.Request)
ListOAuthClients handles GET /api/users/me/oauth-clients.
func (*Server) ListOAuthProviders ¶
func (s *Server) ListOAuthProviders(w http.ResponseWriter, r *http.Request)
ListOAuthProviders handles GET /api/users/me/oauth/providers.
func (*Server) ListPersonalAccessTokens ¶ added in v0.60.0
func (s *Server) ListPersonalAccessTokens(w http.ResponseWriter, r *http.Request)
ListPersonalAccessTokens handles GET /api/users/me/tokens.
func (*Server) ListPlugins ¶
func (s *Server) ListPlugins(w http.ResponseWriter, r *http.Request)
func (*Server) ListProfileChangelog ¶ added in v0.39.1
func (s *Server) ListProfileChangelog(w http.ResponseWriter, r *http.Request, agentID string, params apiserver.ListProfileChangelogParams)
ListProfileChangelog handles GET /api/users/me/memories/{agentID}/changelog.
func (*Server) ListProfileConstraints ¶ added in v0.39.1
ListProfileConstraints handles GET /api/users/me/memories/{agentID}/constraints.
func (*Server) ListProfileIdentities ¶
func (s *Server) ListProfileIdentities(w http.ResponseWriter, r *http.Request)
ListProfileIdentities handles GET /api/users/me/identities.
func (*Server) ListProfileKnowledge ¶ added in v0.60.0
func (s *Server) ListProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, params apiserver.ListProfileKnowledgeParams)
ListProfileKnowledge handles GET /api/users/me/memories/{agentId}/knowledge.
func (*Server) ListProfileMemories ¶
func (s *Server) ListProfileMemories(w http.ResponseWriter, r *http.Request)
ListProfileMemories handles GET /api/users/me/memories.
func (*Server) ListProjects ¶ added in v0.34.0
func (s *Server) ListProjects(w http.ResponseWriter, r *http.Request, agentID string, params apiserver.ListProjectsParams)
func (*Server) ListProviderModels ¶
func (*Server) ListProviderTypes ¶
func (s *Server) ListProviderTypes(w http.ResponseWriter, r *http.Request)
func (*Server) ListProviders ¶
func (s *Server) ListProviders(w http.ResponseWriter, r *http.Request)
func (*Server) ListPublicChannels ¶
func (s *Server) ListPublicChannels(w http.ResponseWriter, r *http.Request)
func (*Server) ListSchedulerJobRuns ¶
func (s *Server) ListSchedulerJobRuns(w http.ResponseWriter, r *http.Request, agentID string, jobID string, params apiserver.ListSchedulerJobRunsParams)
func (*Server) ListSchedulerJobs ¶
func (*Server) ListScopedMCPServers ¶ added in v0.60.0
func (s *Server) ListScopedMCPServers(w http.ResponseWriter, r *http.Request, params apiserver.ListScopedMCPServersParams)
ListScopedMCPServers handles GET /api/mcp/servers.
func (*Server) ListScopedSkills ¶ added in v0.48.0
func (s *Server) ListScopedSkills(w http.ResponseWriter, r *http.Request, params apiserver.ListScopedSkillsParams)
ListScopedSkills handles GET /api/skills.
func (*Server) ListScopedVaultEntries ¶ added in v0.48.0
func (s *Server) ListScopedVaultEntries(w http.ResponseWriter, r *http.Request, params apiserver.ListScopedVaultEntriesParams)
ListScopedVaultEntries handles GET /api/vault.
func (*Server) ListSessions ¶
func (s *Server) ListSessions(w http.ResponseWriter, r *http.Request, agentID string, params apiserver.ListSessionsParams)
func (*Server) ListShares ¶ added in v0.35.0
func (s *Server) ListShares(w http.ResponseWriter, r *http.Request, params apiserver.ListSharesParams)
func (*Server) ListStoredDigests ¶
func (s *Server) ListStoredDigests(w http.ResponseWriter, r *http.Request, params apiserver.ListStoredDigestsParams)
func (*Server) ListTokenScopes ¶ added in v0.60.0
func (s *Server) ListTokenScopes(w http.ResponseWriter, r *http.Request)
ListTokenScopes handles GET /api/token-scopes. The grantable-scope catalog is global metadata (identical for every user), so it lives at the top level. It is the single source of truth for the PAT creation UI: server-side catalog + exposability policy.
func (*Server) ListUserMemories ¶
func (*Server) ListWorkflowRuns ¶ added in v0.60.0
func (s *Server) ListWorkflowRuns(w http.ResponseWriter, r *http.Request, id string, params apiserver.ListWorkflowRunsParams)
func (*Server) ListWorkflows ¶ added in v0.60.0
func (s *Server) ListWorkflows(w http.ResponseWriter, r *http.Request, params apiserver.ListWorkflowsParams)
func (*Server) LoginLocal ¶ added in v0.39.1
func (s *Server) LoginLocal(w http.ResponseWriter, r *http.Request)
func (*Server) Logout ¶
func (s *Server) Logout(w http.ResponseWriter, r *http.Request)
Logout handles POST /api/auth/logout.
func (*Server) MarkEmailMessage ¶ added in v0.43.0
func (s *Server) MarkEmailMessage(w http.ResponseWriter, r *http.Request, uid int, params apiserver.MarkEmailMessageParams)
MarkEmailMessage handles POST /api/email/messages/{uid}/mark.
func (*Server) MarkStartupComplete ¶ added in v0.60.0
func (s *Server) MarkStartupComplete()
MarkStartupComplete makes /readyz eligible to report ready. The gateway calls it once every subsystem has started, just before it blocks on shutdown.
func (*Server) MoveWorkspaceFile ¶
func (s *Server) MoveWorkspaceFile(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.MoveWorkspaceFileParams)
func (*Server) OauthCallback ¶
func (s *Server) OauthCallback(w http.ResponseWriter, r *http.Request, provider string, params apiserver.OauthCallbackParams)
OauthCallback handles GET /api/auth/oauth/{provider}/callback. This is intentionally a pass-through to the unexported helper so the generated interface signature is satisfied.
func (*Server) OauthCallbackLegacy ¶ added in v0.38.0
func (s *Server) OauthCallbackLegacy(w http.ResponseWriter, r *http.Request, provider string, params apiserver.OauthCallbackLegacyParams)
OauthCallbackLegacy handles the deprecated /api/auth/profile/oauth/{provider}/callback alias.
func (*Server) PollFeed ¶
func (s *Server) PollFeed(w http.ResponseWriter, r *http.Request, id string, params apiserver.PollFeedParams)
func (*Server) PollFeishuRegistration ¶ added in v0.48.0
func (s *Server) PollFeishuRegistration(w http.ResponseWriter, r *http.Request)
func (*Server) PollOAuthFlow ¶
func (s *Server) PollOAuthFlow(w http.ResponseWriter, r *http.Request, provider string, flowID string)
PollOAuthFlow handles GET /api/users/me/oauth/{provider}/status/{flowID}.
func (*Server) PollWeixinQRStatus ¶
func (s *Server) PollWeixinQRStatus(w http.ResponseWriter, r *http.Request, params apiserver.PollWeixinQRStatusParams)
PollWeixinQRStatus polls the QR code scan status. On confirmed, it links the current user's identity to the weixin account. Provisioning the singleton channel credentials is an admin-only concern (see BeginWeixinRegistration / PollWeixinRegistration), so the credential write only happens for admins; a non-admin linking their identity must not overwrite the global channel. GET /api/channels/weixin/qr/status?qrcode=...
func (*Server) PollWeixinRegistration ¶ added in v0.48.0
func (s *Server) PollWeixinRegistration(w http.ResponseWriter, r *http.Request)
func (*Server) ReattemptGoal ¶ added in v0.49.4
ReattemptGoal raises the budget on a blocked goal and resumes it.
func (*Server) RegisterLocal ¶ added in v0.39.1
func (s *Server) RegisterLocal(w http.ResponseWriter, r *http.Request)
func (*Server) RejectPlan ¶ added in v0.50.0
RejectPlan rejects a composite's proposed plan, returning it to draft so the dispatcher re-decomposes it.
func (*Server) RemoveAgentUser ¶
func (*Server) RemoveGroupMember ¶ added in v0.43.0
func (*Server) RestoreProfileKnowledge ¶ added in v0.60.0
func (s *Server) RestoreProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, factID string)
RestoreProfileKnowledge handles POST /api/users/me/memories/{agentId}/knowledge/{factId}/restore.
func (*Server) RevokeAuthorizedApp ¶ added in v0.60.0
RevokeAuthorizedApp handles DELETE /api/users/me/authorized-apps/{clientId}.
func (*Server) RevokePersonalAccessToken ¶ added in v0.60.0
RevokePersonalAccessToken handles DELETE /api/users/me/tokens/{id}.
func (*Server) RevokeShare ¶ added in v0.35.0
func (*Server) RotateOAuthClientSecret ¶ added in v0.60.0
RotateOAuthClientSecret handles POST /api/users/me/oauth-clients/{clientId}/rotate-secret.
func (*Server) SaveArticle ¶
func (s *Server) SaveArticle(w http.ResponseWriter, r *http.Request)
func (*Server) SaveDigest ¶
func (s *Server) SaveDigest(w http.ResponseWriter, r *http.Request)
func (*Server) SaveGoalAsWorkflow ¶ added in v0.60.0
func (*Server) SaveManifestPlugins ¶
func (s *Server) SaveManifestPlugins(w http.ResponseWriter, r *http.Request)
func (*Server) SearchCliToolRegistry ¶ added in v0.45.0
func (s *Server) SearchCliToolRegistry(w http.ResponseWriter, r *http.Request, params apiserver.SearchCliToolRegistryParams)
SearchCliToolRegistry searches the mise tool registry so the UI can add a CLI tool by picking a name instead of hand-writing its mise backend key.
func (*Server) SearchSkills ¶
func (s *Server) SearchSkills(w http.ResponseWriter, r *http.Request, params apiserver.SearchSkillsParams)
SearchSkills handles GET /api/skills/search?q=<query>&limit=<n>.
func (*Server) SendEmail ¶ added in v0.43.0
func (s *Server) SendEmail(w http.ResponseWriter, r *http.Request, params apiserver.SendEmailParams)
SendEmail handles POST /api/email/send.
func (*Server) SendGroupMessage ¶ added in v0.43.0
func (*Server) SendSessionMessage ¶
func (*Server) SetOAuthProviderConfig ¶
SetOAuthProviderConfig handles PUT /api/admin/oauth-providers/{id}/config.
func (*Server) SetProfileMemory ¶
SetProfileMemory handles PATCH /api/users/me/memories/{agentID}.
func (*Server) SetProfileSoul ¶
SetProfileSoul handles PATCH /api/users/me/soul/{agentID}.
func (*Server) SetScopedVaultEntry ¶ added in v0.48.0
SetScopedVaultEntry handles PUT /api/vault/{name}.
func (*Server) SetUserMemory ¶
func (*Server) StartOAuthFlow ¶
StartOAuthFlow handles POST /api/users/me/oauth/{provider}/start.
func (*Server) StartWeixinQR ¶
func (s *Server) StartWeixinQR(w http.ResponseWriter, r *http.Request)
StartWeixinQR initiates the WeChat QR login flow by requesting a QR code from the iLink API. Any authenticated user can call this. POST /api/channels/weixin/qr
func (*Server) StreamSessionEvents ¶ added in v0.49.3
func (s *Server) StreamSessionEvents(w http.ResponseWriter, r *http.Request, agentID string, sessionID string)
StreamSessionEvents subscribes to a session's in-flight turn and streams its events read-only, regardless of who initiated the turn. This lets the web UI watch server-driven turns (scheduler/task/delegate) or a turn started in another tab in real time, since those turns carry no HTTP request of their own.
func (*Server) SubmitVerdict ¶ added in v0.49.4
SubmitVerdict appends a human verdict against a contract item and re-folds.
func (*Server) SyncManifestPlugins ¶
func (s *Server) SyncManifestPlugins(w http.ResponseWriter, r *http.Request)
func (*Server) TogglePlugin ¶
func (*Server) TriggerSchedulerJob ¶
func (*Server) UnarchiveGoal ¶ added in v0.49.4
UnarchiveGoal restores an archived goal to default lists.
func (*Server) UnlinkProfileIdentity ¶
UnlinkProfileIdentity handles DELETE /api/users/me/identities/{id}.
func (*Server) UpdateAgent ¶
func (*Server) UpdateAgentSkill ¶
func (s *Server) UpdateAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, params apiserver.UpdateAgentSkillParams)
func (*Server) UpdateAgentTool ¶ added in v0.60.0
func (*Server) UpdateArticle ¶
func (*Server) UpdateAuthUserActive ¶
UpdateAuthUserActive handles PATCH /api/users/{id}/active.
func (*Server) UpdateAuthUserAgents ¶
UpdateAuthUserAgents handles PATCH /api/users/{id}/agents.
func (*Server) UpdateAuthUserRole ¶
UpdateAuthUserRole handles PATCH /api/users/{id}/role.
func (*Server) UpdateChannel ¶
func (*Server) UpdateEmbeddingSettings ¶ added in v0.50.3
func (s *Server) UpdateEmbeddingSettings(w http.ResponseWriter, r *http.Request)
UpdateEmbeddingSettings persists the embedding configuration. The change takes effect at runtime: the embedding service re-reads this config on its next query and backfill pass, so no restart is needed. The api_key is write-only — an omitted or empty key keeps the stored one, since the GET never echoes it back.
func (*Server) UpdateFeed ¶
func (*Server) UpdateFeedEntry ¶
func (*Server) UpdateGoal ¶ added in v0.49.4
UpdateGoal applies a partial metadata edit (PATCH).
func (*Server) UpdateGroup ¶ added in v0.43.0
func (*Server) UpdatePluginConfig ¶
func (*Server) UpdateProfileKnowledge ¶ added in v0.60.0
func (s *Server) UpdateProfileKnowledge(w http.ResponseWriter, r *http.Request, agentID string, factID string)
UpdateProfileKnowledge handles PATCH /api/users/me/memories/{agentId}/knowledge/{factId}.
func (*Server) UpdateProject ¶ added in v0.34.0
func (*Server) UpdateProvider ¶
func (*Server) UpdateSchedulerJob ¶
func (*Server) UpdateScopedMCPServer ¶ added in v0.60.0
func (s *Server) UpdateScopedMCPServer(w http.ResponseWriter, r *http.Request, id string, params apiserver.UpdateScopedMCPServerParams)
UpdateScopedMCPServer handles PATCH /api/mcp/servers/{id}.
func (*Server) UpdateScopedSkill ¶ added in v0.48.0
UpdateScopedSkill handles PATCH /api/skills/{id}.
func (*Server) UpdateSession ¶ added in v0.46.0
func (*Server) UpdateUserDefaultAgent ¶
func (*Server) UpdateUserNotifyIdentity ¶
func (*Server) UpdateWorkspaceFileContent ¶
func (s *Server) UpdateWorkspaceFileContent(w http.ResponseWriter, r *http.Request, agentID string, sessionID string, params apiserver.UpdateWorkspaceFileContentParams)
func (*Server) UpgradeAgentSkill ¶ added in v0.49.0
func (s *Server) UpgradeAgentSkill(w http.ResponseWriter, r *http.Request, id string, skillId string, params apiserver.UpgradeAgentSkillParams)
UpgradeAgentSkill re-fetches a DB-backed skill from its recorded install source and updates it in place when the source has a newer version. It is the check-and-update behind the inspector's "check for updates" button.
func (*Server) UploadAgentSkill ¶
func (*Server) UploadScopedSkill ¶ added in v0.48.0
func (s *Server) UploadScopedSkill(w http.ResponseWriter, r *http.Request)
UploadScopedSkill handles POST /api/skills/upload.
func (*Server) UploadWorkspaceFile ¶
func (*Server) WaiveEdge ¶ added in v0.49.4
WaiveEdge waives a hard edge so a blocked(dep) downstream can proceed.
func (*Server) WebhookIngressHandler ¶ added in v0.60.0
WebhookIngressHandler returns the auth-exempt inbound webhook ingress handler (POST /webhooks/{id}). The composition root mounts it at the HTTP root, in front of the admin middleware chain, because the handler authenticates itself via the caller's personal access token and must never be wrapped by the session authMiddleware. It stays in internal/server, with its Server-field dependencies, because it is transport code — not a plugin implementation.
type WeixinQRCode ¶ added in v0.60.0
type WeixinQRCode struct {
QRCode string `json:"qrcode,omitempty"`
QRCodeImgContent string `json:"qrcode_img_content,omitempty"`
}
WeixinQRCode is the server-local result of a WeChat (iLink) QR-code request. Its JSON tags mirror the wire contract the QR endpoints have always emitted so the HTTP response body is unchanged after routing through the registrar port.
type WeixinQRCodeStatus ¶ added in v0.60.0
type WeixinQRCodeStatus struct {
Status string `json:"status,omitempty"`
BotToken string `json:"bot_token,omitempty"`
ILinkBotID string `json:"ilink_bot_id,omitempty"`
ILinkUserID string `json:"ilink_user_id,omitempty"`
BaseURL string `json:"baseurl,omitempty"`
}
WeixinQRCodeStatus is the server-local result of a WeChat (iLink) QR-code scan poll. Its JSON tags mirror the existing wire contract for PollWeixinQRStatus.
type WeixinRegistrar ¶ added in v0.60.0
type WeixinRegistrar interface {
// GetQRCode requests a fresh login QR code from the iLink API.
GetQRCode() (WeixinQRCode, error)
// GetQRCodeStatus polls the scan status of a previously issued QR code.
GetQRCodeStatus(qrcode string) (WeixinQRCodeStatus, error)
}
WeixinRegistrar is the narrow port the WeChat registration/QR handlers use to reach the iLink API. The concrete adapter lives in the composition root (it wraps the weixin plugin's client), so internal/server never imports the plugin. Results are mapped to the server-local types above at the boundary.
Source Files
¶
- account.go
- agent_access.go
- agent_helpers.go
- agent_tools.go
- agent_users.go
- agents.go
- auth.go
- auth_users.go
- builtin.go
- capabilities.go
- changelog.go
- channels.go
- clawhub.go
- cli_tools.go
- control_plane.go
- docs.go
- email.go
- embedding.go
- feishu_registration.go
- goals.go
- group_publisher.go
- groups.go
- http.go
- inbox.go
- knowledge.go
- manifest_plugins.go
- mcp.go
- middleware.go
- models.go
- oauth.go
- oauth_as.go
- oauth_clients.go
- oauth_providers.go
- oidc.go
- pagination.go
- pat.go
- plugins.go
- profile.go
- profile_memory.go
- projects.go
- providers.go
- readiness.go
- recally_handlers.go
- response.go
- routes.go
- scheduler.go
- server.go
- sessions.go
- shares.go
- skills.go
- skills_manage.go
- skills_scoped.go
- skills_upload.go
- status.go
- time.go
- users.go
- vault.go
- webhook_ingress.go
- webhook_ratelimit.go
- weixin_qr.go
- weixin_registrar.go
- weixin_registration.go
- workflows.go