web

package
v0.0.0-nightly.20260727 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2026 License: AGPL-3.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SessionActive   = "active"
	SessionArchived = "archived"
)
View Source 
const (
	DomainEventScanStarted    = "scan_started"
	DomainEventScanProgress   = "scan_progress"
	DomainEventScanComplete   = "scan_complete"
	DomainEventAgentJoined    = "agent_joined"
	DomainEventSessionCleared = "session_cleared"
)
View Source 
const (
	SysNoRunningTask     = "no_running_task"
	SysPaused            = "paused"
	SysFileUploaded      = "file_uploaded" // params: filename, path
	SysNoAgentsConnected = "no_agents_connected"
	SysAgentsList        = "agents_list" // params: count, agents[]
	SysAgentNotConnected = "agent_not_connected"
)

System message codes. A backend-generated system message carries a stable Code (+ optional Params) so the client can localize it via i18n; Content holds an English fallback for non-i18n consumers, logs and tests. Keys are mirrored under `sys.*` in web/frontend/src/i18n/locales/*/chat.ts.

Variables

This section is empty.

Functions

func AccessKeyAuth added in v0.3.0 

func AccessKeyAuth(key string) func(http.Handler) http.Handler

AccessKeyAuth returns middleware that gates requests behind access-key credentials. Browser logins exchange the access key for an HttpOnly session cookie so the key never needs to live in JavaScript or appear in a URL. Requests without a valid credential get a 401. An empty key disables auth (dev mode).

func ServeSSE 

func ServeSSE(w http.ResponseWriter, r *http.Request, hub *Hub, id string, terminalEvents ...string)

func ServeSSEWithInitial 

func ServeSSEWithInitial(w http.ResponseWriter, r *http.Request, hub *Hub, id string, initial []HubEvent, terminalEvents ...string)

func ValidateLLMConfig 

func ValidateLLMConfig(cfg webproto.LLMConfig) error

ValidateLLMConfig accepts zero as "use the model default" and rejects negative limits before an invalid configuration can be persisted.

func ValidateMode 

func ValidateMode(mode string) (string, error)

func ValidateTarget 

func ValidateTarget(raw string) (string, error)

Types

type AgentInfo 

type AgentInfo struct {
	ID           string                 `json:"id"`
	Name         string                 `json:"name"`
	Commands     []string               `json:"commands,omitempty"`
	CommandsMenu []webproto.CommandSpec `json:"commands_menu,omitempty"`
	Busy         bool                   `json:"busy"`
	ConnectAt    time.Time              `json:"connected_at"`
	Node         protocols.NodeRef      `json:"node"`
	Runtime      webproto.AgentRuntime  `json:"runtime,omitempty"`
	Status       webproto.AgentStatus   `json:"status,omitempty"`
	Stats        webproto.AgentStats    `json:"stats,omitempty"`
}

AgentInfo is the public view of a connected agent.

type AgentPool 

type AgentPool struct {
	// contains filtered or unexported fields
}

AgentPool manages connected remote aiscan agents via WebSocket.

func NewAgentPool 

func NewAgentPool(hub *Hub, allowedOrigins ...string) *AgentPool

func (*AgentPool) BroadcastConfigReload added in v0.3.0 

func (p *AgentPool) BroadcastConfigReload() int

BroadcastConfigReload notifies every connected agent that the hub config changed so each re-fetches and hot-swaps its LLM provider without a restart. Config notifications use a dedicated control channel so task output cannot starve or silently drop a provider change. A full channel already contains a pending reload, so the latest persisted config will still be fetched.

func (*AgentPool) CancelPTY 

func (p *AgentPool) CancelPTY(agentID, terminalID string)

func (*AgentPool) CancelTask 

func (p *AgentPool) CancelTask(agentID, taskID string)

func (*AgentPool) CloseTerminal 

func (p *AgentPool) CloseTerminal(agentID, terminalID string)

func (*AgentPool) Count 

func (p *AgentPool) Count() int

func (*AgentPool) DispatchChat added in v0.2.8 

func (p *AgentPool) DispatchChat(agentID, taskID, prompt string) (<-chan taskResult, error)

DispatchChat sends a natural-language prompt to an LLM-capable agent.

func (*AgentPool) DispatchCommand 

func (p *AgentPool) DispatchCommand(agentID, taskID string, command webproto.CommandPayload) (<-chan taskResult, error)

func (*AgentPool) DispatchRun 

func (p *AgentPool) DispatchRun(agentID, turnID string, run webproto.RunPayload) (<-chan taskResult, error)

func (*AgentPool) DispatchToolCall 

func (p *AgentPool) DispatchToolCall(agentID, taskID string, call aop.ToolCallData) (<-chan taskResult, error)

DispatchToolCall sends a canonical AOP tool.call to a tool-capable node. The task completes only on the matching AOP tool.result.

func (*AgentPool) HandleTerminalWS 

func (p *AgentPool) HandleTerminalWS(agentID string, w http.ResponseWriter, r *http.Request)

HandleTerminalWS bridges one browser terminal WebSocket to one remote agent. The browser sends transport-neutral PTY frames; the pool assigns a stream_id, wraps them for the mixed agent connection, and unwraps matching responses.

func (*AgentPool) HandleWS 

func (p *AgentPool) HandleWS(w http.ResponseWriter, r *http.Request)

HandleWS upgrades to WebSocket and manages the agent lifecycle. This single endpoint replaces register + stream + output + complete.

func (*AgentPool) List 

func (p *AgentPool) List() []AgentInfo

func (*AgentPool) Pick 

func (p *AgentPool) Pick() *remoteAgent

Pick selects an idle agent, or any agent if none idle.

func (*AgentPool) PickChat added in v0.2.8 

func (p *AgentPool) PickChat() *remoteAgent

PickChat selects an idle LLM-capable agent, or any LLM-capable agent if all are busy.

func (*AgentPool) SendAgentMessage 

func (p *AgentPool) SendAgentMessage(agentID string, msg webproto.Message) error

func (*AgentPool) SetRecordStore added in v0.2.8 

func (p *AgentPool) SetRecordStore(rs RecordStore)

func (*AgentPool) SetSCOStore 

func (p *AgentPool) SetSCOStore(store SCOStore)

func (*AgentPool) SetSessionLookup added in v0.2.8 

func (p *AgentPool) SetSessionLookup(sl SessionLookup)

type ChatMessage added in v0.2.8 

type ChatMessage struct {
	ID        string          `json:"id"`
	SessionID string          `json:"session_id"`
	Role      string          `json:"role"`
	AgentID   string          `json:"agent_id,omitempty"`
	AgentName string          `json:"agent_name,omitempty"`
	Content   string          `json:"content"`
	Metadata  json.RawMessage `json:"metadata,omitempty"`
	CreatedAt time.Time       `json:"created_at"`
	// Queued is a transient send-time hint: true when the message was accepted
	// while another chat task is still running on the session, so the client
	// can render it as pending-in-queue rather than in-flight.
	Queued bool `json:"queued,omitempty"`
}

type ChatSession added in v0.2.8 

type ChatSession struct {
	ID        string    `json:"id"`
	AgentID   string    `json:"agent_id"`
	AgentName string    `json:"agent_name,omitempty"`
	Title     string    `json:"title"`
	Status    string    `json:"status"`
	TopicID   string    `json:"topic_id,omitempty"`
	ScanIDs   []string  `json:"scan_ids,omitempty"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type ConfigStatus added in v0.2.8 

type ConfigStatus struct {
	ConfigPath   string `json:"config_path,omitempty"`
	ConfigLoaded bool   `json:"config_loaded"`
	LLM          struct {
		Provider         string             `json:"provider"`
		BaseURL          string             `json:"base_url"`
		APIKeyConfigured bool               `json:"api_key_configured"`
		Model            string             `json:"model"`
		Proxy            string             `json:"proxy"`
		MaxTokens        int                `json:"max_tokens,omitempty"`
		ContextWindow    int                `json:"context_window,omitempty"`
		ActiveProfile    string             `json:"active_profile,omitempty"`
		Profiles         []LLMProfileStatus `json:"profiles,omitempty"`
	} `json:"llm"`
	Cyberhub struct {
		URL           string `json:"url"`
		KeyConfigured bool   `json:"key_configured"`
		Mode          string `json:"mode"`
		Proxy         string `json:"proxy"`
	} `json:"cyberhub"`
	Recon struct {
		FofaEmail              string `json:"fofa_email"`
		FofaKeyConfigured      bool   `json:"fofa_key_configured"`
		HunterTokenConfigured  bool   `json:"hunter_token_configured"`
		HunterAPIKeyConfigured bool   `json:"hunter_api_key_configured"`
		Proxy                  string `json:"proxy"`
		Limit                  *int   `json:"limit,omitempty"`
	} `json:"recon"`
	Scan struct {
		Verify string `json:"verify"`
	} `json:"scan"`
	Search struct {
		TavilyKeysConfigured bool `json:"tavily_keys_configured"`
	} `json:"search"`
	IOA struct {
		URL             string `json:"url"`
		TokenConfigured bool   `json:"token_configured"`
		NodeName        string `json:"node_name"`
		Space           string `json:"space"`
	} `json:"ioa"`
	Agent struct {
		Tools       []string `json:"tools,omitempty"`
		Timeout     int      `json:"timeout"`
		SaveSession bool     `json:"save_session"`
	} `json:"agent"`
}

ConfigStatus is the response for GET /api/config — secrets masked, *_configured booleans indicate whether a secret is set.

func ConfigStatusFromDistribute added in v0.2.8 

func ConfigStatusFromDistribute(d *webproto.DistributeConfig, path string, loaded bool) ConfigStatus

ConfigStatusFromDistribute builds a masked ConfigStatus from raw config.

type ConfigStore added in v0.2.8 

type ConfigStore interface {
	GetDistributeConfig(ctx context.Context) (path string, loaded bool, cfg webproto.DistributeConfig, err error)
	SaveDistributeConfig(ctx context.Context, cfg webproto.DistributeConfig) error
}

type CreateSessionRequest added in v0.2.8 

type CreateSessionRequest struct {
	AgentID string `json:"agent_id"`
	Title   string `json:"title,omitempty"`
}

type DomainEvent 

type DomainEvent struct {
	Type      string         `json:"type"`
	SessionID string         `json:"session_id"`
	AgentID   string         `json:"agent_id,omitempty"`
	AgentName string         `json:"agent_name,omitempty"`
	ScanID    string         `json:"scan_id,omitempty"`
	Result    *output.Result `json:"result,omitempty"`
	Data      string         `json:"data,omitempty"`
	Transient bool           `json:"-"`
}

type Handler 

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler 

func NewHandler(service *Service, agents *AgentPool, local *LocalAgents, ioaHandler http.Handler, static http.Handler, accessKey string, ioaConsole ...IOAConsoleReader) *Handler

func (*Handler) ServeHTTP 

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Hub 

type Hub struct {
	// contains filtered or unexported fields
}

func NewHub 

func NewHub() *Hub

func (*Hub) Broadcast 

func (h *Hub) Broadcast(id string, event HubEvent)

func (*Hub) Subscribe 

func (h *Hub) Subscribe(id string) (<-chan HubEvent, func())

type HubEvent 

type HubEvent struct {
	Type string
	Data json.RawMessage
	// Reliable marks a terminal event that Broadcast must not drop under
	// backpressure: on a full buffer it evicts the oldest queued event to seat
	// one, rather than shedding it like a token delta. See isTerminalDomainEvent
	// for which events qualify and why a lost one strands the UI.
	Reliable bool
}

HubEvent is the unit broadcast through the SSE hub. Type is the SSE event name, Data is pre-serialized JSON written directly to the stream.

type IOAConsoleReader 

type IOAConsoleReader interface {
	ListNodes(context.Context) ([]protocols.Node, error)
	ListSpaces(context.Context) ([]protocols.SpaceInfo, error)
	ListMessages(context.Context, protocols.MessageFilter) ([]protocols.Message, error)
}

IOAConsoleReader is the read-only IOA projection exposed to the authenticated AIScan web console. Agent registration and message writes still go through the native IOA API and its per-node authentication.

type LLMProfileStatus 

type LLMProfileStatus struct {
	ID               string `json:"id"`
	Name             string `json:"name"`
	Provider         string `json:"provider"`
	BaseURL          string `json:"base_url"`
	APIKeyConfigured bool   `json:"api_key_configured"`
	Model            string `json:"model"`
	Proxy            string `json:"proxy"`
	MaxTokens        int    `json:"max_tokens,omitempty"`
	ContextWindow    int    `json:"context_window,omitempty"`
}

type LocalAgentView added in v0.3.0 

type LocalAgentView struct {
	Name       string `json:"name"`
	PID        int    `json:"pid"`
	Registered bool   `json:"registered"` // has connected back to the hub pool
	Busy       bool   `json:"busy,omitempty"`
}

LocalAgentView is the API-facing view of a hub-hosted agent, cross-referenced with the live pool for connection state.

type LocalAgents added in v0.3.0 

type LocalAgents struct {
	// contains filtered or unexported fields
}

LocalAgents launches and tracks `aiscan agent` subprocesses on the hub host so they register in the pool and can be listed/stopped from the UI. Each child dials the hub's own loopback web + IOA endpoints, so it shows up in the pool like any node. The hub holds the only handle to these processes, so StopAll kills them on shutdown rather than leaving orphans.

func NewLocalAgents added in v0.3.0 

func NewLocalAgents(hubURL, ioaToken, configFile string, pool *AgentPool) *LocalAgents

NewLocalAgents builds a launcher. hubURL is the loopback base the children dial (e.g. http://127.0.0.1:8080); ioaToken is embedded into the child's IOA URL. Children are launched from the current aiscan executable.

func (*LocalAgents) Launch added in v0.3.0 

func (l *LocalAgents) Launch(ctx context.Context) (*LocalAgentView, error)

Launch spawns an `aiscan agent` on the hub host wired to the hub's loopback web + IOA endpoints, and tracks it. The LLM provider/model/key arrive via the hub's config push on registration, so nothing about the model is passed here.

func (*LocalAgents) List added in v0.3.0 

func (l *LocalAgents) List() []LocalAgentView

List returns the tracked local agents (launch order), cross-referenced with the pool for connection state.

func (*LocalAgents) Stop added in v0.3.0 

func (l *LocalAgents) Stop(name string) error

Stop kills a tracked local agent by name and drops it from the roster.

func (*LocalAgents) StopAll added in v0.3.0 

func (l *LocalAgents) StopAll()

StopAll kills every tracked local agent (hub shutdown), so none are left orphaned once the hub — which holds the only handle to them — exits.

type RecordStore added in v0.2.8 

type RecordStore interface {
	InsertRecord(ctx context.Context, rec *output.Record) error
	InsertRecords(ctx context.Context, recs []*output.Record) error
}

RecordStore is the subset of Store needed for record persistence.

type SCOStore 

type SCOStore interface {
	UpsertSCONodes(ctx context.Context, scanID string, nodes []json.RawMessage) error
}

SCOStore persists libcstx nodes emitted by a connected agent process.

type SQLiteStore 

type SQLiteStore struct {
	// contains filtered or unexported fields
}

func NewSQLiteStore 

func NewSQLiteStore(dbPath string) (*SQLiteStore, error)

func (*SQLiteStore) AddAOPEvent 

func (s *SQLiteStore) AddAOPEvent(ctx context.Context, sessionID string, event aop.Event) error

func (*SQLiteStore) AddMessage added in v0.2.8 

func (s *SQLiteStore) AddMessage(ctx context.Context, msg *ChatMessage) error

func (*SQLiteStore) ClearMessages added in v0.3.0 

func (s *SQLiteStore) ClearMessages(ctx context.Context, sessionID string) error

ClearMessages deletes every message in a session without removing the session itself — the store half of web /clear ("clear conversation"). Messages are leaf rows (nothing references them), so a single delete suffices.

func (*SQLiteStore) Close 

func (s *SQLiteStore) Close() error

func (*SQLiteStore) Create 

func (s *SQLiteStore) Create(ctx context.Context, job *ScanJob) error

func (*SQLiteStore) CreateSession added in v0.2.8 

func (s *SQLiteStore) CreateSession(ctx context.Context, session *ChatSession) error

func (*SQLiteStore) Delete 

func (s *SQLiteStore) Delete(ctx context.Context, id string) error

func (*SQLiteStore) DeleteSCONodesByScan added in v0.3.0 

func (s *SQLiteStore) DeleteSCONodesByScan(ctx context.Context, scanID string) error

func (*SQLiteStore) DeleteSession added in v0.2.8 

func (s *SQLiteStore) DeleteSession(ctx context.Context, id string) error

func (*SQLiteStore) Get 

func (s *SQLiteStore) Get(ctx context.Context, id string) (*ScanJob, error)

func (*SQLiteStore) GetSCONode added in v0.3.0 

func (s *SQLiteStore) GetSCONode(ctx context.Context, cstxID string) (json.RawMessage, error)

func (*SQLiteStore) GetSession added in v0.2.8 

func (s *SQLiteStore) GetSession(ctx context.Context, id string) (*ChatSession, error)

func (*SQLiteStore) InsertRecord added in v0.2.8 

func (s *SQLiteStore) InsertRecord(ctx context.Context, rec *output.Record) error

func (*SQLiteStore) InsertRecords added in v0.2.8 

func (s *SQLiteStore) InsertRecords(ctx context.Context, recs []*output.Record) error

func (*SQLiteStore) LinkScanToSession added in v0.2.8 

func (s *SQLiteStore) LinkScanToSession(ctx context.Context, sessionID, scanID string) error

func (*SQLiteStore) List 

func (s *SQLiteStore) List(ctx context.Context, limit int) ([]*ScanJob, error)

func (*SQLiteStore) ListAOPEvents 

func (s *SQLiteStore) ListAOPEvents(ctx context.Context, sessionID string, limit int) ([]aop.Event, error)

func (*SQLiteStore) ListMessages added in v0.2.8 

func (s *SQLiteStore) ListMessages(ctx context.Context, sessionID string, limit int) ([]*ChatMessage, error)

func (*SQLiteStore) ListSCONodes added in v0.3.0 

func (s *SQLiteStore) ListSCONodes(ctx context.Context, nodeType string, limit int) ([]json.RawMessage, error)

func (*SQLiteStore) ListSCONodesByScanID added in v0.3.0 

func (s *SQLiteStore) ListSCONodesByScanID(ctx context.Context, scanID, nodeType string, limit int) ([]json.RawMessage, error)

func (*SQLiteStore) ListSessions added in v0.2.8 

func (s *SQLiteStore) ListSessions(ctx context.Context, limit int) ([]*ChatSession, error)

func (*SQLiteStore) SCONodeStats added in v0.3.0 

func (s *SQLiteStore) SCONodeStats(ctx context.Context) (map[string]int, error)

func (*SQLiteStore) SessionScanIDs added in v0.2.8 

func (s *SQLiteStore) SessionScanIDs(ctx context.Context, sessionID string) ([]string, error)

func (*SQLiteStore) Update 

func (s *SQLiteStore) Update(ctx context.Context, job *ScanJob) error

func (*SQLiteStore) UpdateSession added in v0.2.8 

func (s *SQLiteStore) UpdateSession(ctx context.Context, session *ChatSession) error

func (*SQLiteStore) UpsertSCONodes added in v0.3.0 

func (s *SQLiteStore) UpsertSCONodes(ctx context.Context, scanID string, nodes []json.RawMessage) error

type ScanJob 

type ScanJob struct {
	ID        string         `json:"id"`
	Target    string         `json:"target"`
	Mode      string         `json:"mode"`
	Verify    bool           `json:"verify,omitempty"`
	Sniper    bool           `json:"sniper,omitempty"`
	Deep      bool           `json:"deep,omitempty"`
	Status    ScanStatus     `json:"status"`
	Progress  string         `json:"progress,omitempty"`
	Report    string         `json:"report,omitempty"`
	Result    *output.Result `json:"result,omitempty"`
	Error     string         `json:"error,omitempty"`
	CreatedAt time.Time      `json:"created_at"`
	UpdatedAt time.Time      `json:"updated_at"`
}

type ScanRequest 

type ScanRequest struct {
	Target string `json:"target"`
	Mode   string `json:"mode"`
	Verify bool   `json:"verify,omitempty"`
	Sniper bool   `json:"sniper,omitempty"`
	Deep   bool   `json:"deep,omitempty"`
}

type ScanStatus 

type ScanStatus string
const (
	StatusQueued    ScanStatus = "queued"
	StatusRunning   ScanStatus = "running"
	StatusCompleted ScanStatus = "completed"
	StatusFailed    ScanStatus = "failed"
	StatusCanceled  ScanStatus = "canceled"
)

type SendMessageRequest added in v0.2.8 

type SendMessageRequest struct {
	Content string `json:"content"`
	// Goal-mode run controls (optional). The frontend sends these when the user
	// enables the Goal panel; a plain chat send leaves them zero.
	EvalCriteria    string `json:"eval_criteria,omitempty"`
	EvalMaxRounds   int    `json:"eval_max_rounds,omitempty"`
	PersistMaxTurns int    `json:"persist_max_turns,omitempty"`
}

type Service 

type Service struct {
	// contains filtered or unexported fields
}

func NewService 

func NewService(cfg ServiceConfig) *Service

func (*Service) ActivateLLMProfile 

func (s *Service) ActivateLLMProfile(ctx context.Context, id string) (ConfigStatus, error)

func (*Service) BroadcastAOPEvent 

func (s *Service) BroadcastAOPEvent(sessionID string, event aop.Event)

func (*Service) BroadcastDomainEvent 

func (s *Service) BroadcastDomainEvent(sessionID string, event DomainEvent)

func (*Service) CancelScan 

func (s *Service) CancelScan(id string) error

func (*Service) CancelSession added in v0.2.8 

func (s *Service) CancelSession(ctx context.Context, sessionID string) error

func (*Service) Close 

func (s *Service) Close()

func (*Service) CreateSession added in v0.2.8 

func (s *Service) CreateSession(ctx context.Context, agentID, title string) (*ChatSession, error)

func (*Service) DeleteSession added in v0.2.8 

func (s *Service) DeleteSession(ctx context.Context, id string) error

func (*Service) GetAOPEvents 

func (s *Service) GetAOPEvents(ctx context.Context, sessionID string) ([]aop.Event, error)

func (*Service) GetConfigStatus added in v0.2.8 

func (s *Service) GetConfigStatus(ctx context.Context) (ConfigStatus, error)

func (*Service) GetDistributeConfig added in v0.2.8 

func (s *Service) GetDistributeConfig(ctx context.Context) (webproto.DistributeConfig, error)

func (*Service) GetMessages added in v0.2.8 

func (s *Service) GetMessages(ctx context.Context, sessionID string) ([]*ChatMessage, error)

func (*Service) GetReport 

func (s *Service) GetReport(ctx context.Context, id, lang string) (string, error)

GetReport re-renders the report in the requested language from the stored structured result, so a zh user gets a zh report even though the scan ran once. It falls back to the report frozen at scan time when the structured result is no longer around.

func (*Service) GetScan 

func (s *Service) GetScan(ctx context.Context, id string) (*ScanJob, error)

func (*Service) GetSession added in v0.2.8 

func (s *Service) GetSession(ctx context.Context, id string) (*ChatSession, error)

func (*Service) HandleFileUpload added in v0.2.8 

func (s *Service) HandleFileUpload(ctx context.Context, sessionID, filename string, data []byte) (*webproto.FileUploadResult, error)

func (*Service) HandleUserMessage added in v0.2.8 

func (s *Service) HandleUserMessage(ctx context.Context, sessionID, content string, opts webproto.GoalExt) (*ChatMessage, error)

func (*Service) Hub 

func (s *Service) Hub() *Hub

func (*Service) ListLLMModels added in v0.3.0 

func (s *Service) ListLLMModels(ctx context.Context, req probe.LLMProbeRequest) (probe.LLMModelsResult, error)

ListLLMModels enumerates the models the supplied LLM endpoint advertises, falling back to the stored API key when the request leaves it blank, then delegates to pkg/probe.

func (*Service) ListScans 

func (s *Service) ListScans(ctx context.Context) ([]*ScanJob, error)

func (*Service) ListSessions added in v0.2.8 

func (s *Service) ListSessions(ctx context.Context) ([]*ChatSession, error)

func (*Service) SaveConfig added in v0.2.8 

func (s *Service) SaveConfig(ctx context.Context, cfg webproto.DistributeConfig) (ConfigStatus, error)

func (*Service) SessionMenu added in v0.3.0 

func (s *Service) SessionMenu(sessionID string) []webproto.CommandSpec

SessionMenu is the web "/" command catalog for a session: the hub-scope commands plus the bound agent's reported agent-scope commands (its skills included). It falls back to the static agent-scope menu when no agent is bound, so the menu is populated even before an agent connects. This is the single source both the "/" menu (GET .../commands) and /help render from.

func (*Service) SetAgentPool 

func (s *Service) SetAgentPool(pool *AgentPool)

func (*Service) Status 

func (s *Service) Status() ServiceStatus

func (*Service) SubmitScan 

func (s *Service) SubmitScan(ctx context.Context, target, mode string, verify, sniper, deep bool) (*ScanJob, error)

func (*Service) TaskSession added in v0.2.8 

func (s *Service) TaskSession(taskID string) (string, bool)

func (*Service) TestConn added in v0.3.0 

func (s *Service) TestConn(ctx context.Context, section string, in webproto.DistributeConfig) ([]probe.ConnCheck, error)

TestConn probes one settings section's external dependencies, resolving blank secrets against the stored config, then delegates to pkg/probe. Probe failures live inside the response; a returned error only signals an untestable section.

func (*Service) TestLLM added in v0.3.0 

func (s *Service) TestLLM(ctx context.Context, req probe.LLMProbeRequest) (probe.LLMTestResult, error)

TestLLM probes the supplied LLM settings, falling back to the stored API key when the request leaves it blank, then delegates to pkg/probe.

type ServiceConfig 

type ServiceConfig struct {
	Store         *SQLiteStore
	App           *runner.App
	ConfigStore   ConfigStore
	AppFactory    func(ctx context.Context) (*runner.App, error)
	AgentPool     *AgentPool
	MaxConcurrent int
	ScanTimeout   time.Duration
}

type ServiceStatus 

type ServiceStatus struct {
	Version             string `json:"version"`
	LLMAvailable        bool   `json:"llm_available"`
	LLMProvider         string `json:"llm_provider,omitempty"`
	LLMModel            string `json:"llm_model,omitempty"`
	LLMAPIKeyConfigured bool   `json:"llm_api_key_configured,omitempty"`
	ConfigPath          string `json:"config_path,omitempty"`
	ConfigLoaded        bool   `json:"config_loaded"`
	Agents              int    `json:"agents"`
	IOAURL              string `json:"ioa_url,omitempty"`
}

type SessionLookup added in v0.2.8 

type SessionLookup interface {
	TaskSession(taskID string) (sessionID string, ok bool)
	BroadcastDomainEvent(sessionID string, event DomainEvent)
	BroadcastAOPEvent(sessionID string, event aop.Event)
}

SessionLookup resolves a task ID to its owning chat session.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.