server

package
v0.17.1 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2026 License: MIT Imports: 37 Imported by: 0

Documentation

Overview

ABOUTME: Manages server state files so CLI commands can detect ABOUTME: a running agentsview server instance.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FindAvailablePort 

func FindAvailablePort(host string, start int) int

FindAvailablePort finds an available port starting from the given port, binding to the specified host.

func IsServerActive added in v0.15.0 

func IsServerActive(dataDir string) bool

IsServerActive reports whether a server process is managing the database in dataDir. Returns true if:

  • a state file with a live PID exists (even if the port probe fails due to a transient issue), or
  • a startup lock with a live PID exists (server is still syncing / binding its port).

This is the check CLI commands should use to decide whether to skip on-demand sync.

func IsStartupLocked added in v0.15.0 

func IsStartupLocked(dataDir string) bool

IsStartupLocked reports whether the startup lock file exists with a live PID. Callers use this to distinguish "server is starting up" from "server is running but TCP probe failed".

func RemoveStartupLock added in v0.15.0 

func RemoveStartupLock(dataDir string)

RemoveStartupLock removes the startup lock file for the current process.

func RemoveStateFile added in v0.15.0 

func RemoveStateFile(dataDir string, port int)

RemoveStateFile removes the state file for the given port.

func WaitForStartup added in v0.15.0 

func WaitForStartup(dataDir string, timeout time.Duration) bool

WaitForStartup polls until the startup lock clears or a running server is detected, up to the given timeout. Returns true if a server became ready, false on timeout.

func WriteStartupLock added in v0.15.0 

func WriteStartupLock(dataDir string)

WriteStartupLock creates a lock file indicating a server is starting up (syncing, binding port). Each server uses a PID-specific filename so concurrent startups on different ports don't clobber each other. Written via a temp file and atomic rename to prevent partial reads.

func WriteStateFile added in v0.15.0 

func WriteStateFile(
	dataDir string, host string, port int, version string,
) (string, error)

WriteStateFile writes a state file to dataDir for the running server. Returns the path written. StartedAt is set to the actual process creation time so it passes processStartTime validation even when startup is slow.

Types

type Opener added in v0.12.0 

type Opener struct {
	ID   string `json:"id"`
	Name string `json:"name"`
	Kind string `json:"kind"` // "editor", "terminal", "files", "action"
	Bin  string `json:"bin"`
}

Opener represents an application that can open a project directory.

type Option 

type Option func(*Server)

Option configures a Server.

func WithBaseContext added in v0.13.0 

func WithBaseContext(ctx context.Context) Option

WithBaseContext sets the base context for all incoming HTTP requests. When this context is cancelled, request contexts are also cancelled, causing long-lived handlers (SSE) to exit and unblocking graceful shutdown.

func WithBasePath added in v0.16.0 

func WithBasePath(path string) Option

WithBasePath sets a URL prefix for reverse-proxy deployments. The path must start with "/" and not end with "/" (e.g. "/agentsview"). When set, the server strips this prefix from incoming requests and injects a <base href> tag into the SPA.

func WithDataDir added in v0.12.0 

func WithDataDir(dir string) Option

WithDataDir sets the data directory used for update caching.

func WithGenerateFunc added in v0.4.0 

func WithGenerateFunc(f insight.GenerateFunc) Option

WithGenerateFunc overrides the insight generation function, allowing tests to substitute a stub. Nil is ignored.

func WithGenerateStreamFunc added in v0.10.0 

func WithGenerateStreamFunc(f insight.GenerateStreamFunc) Option

WithGenerateStreamFunc overrides the streaming insight generation function used by the SSE handler. Nil is ignored.

func WithUpdateChecker added in v0.12.0 

func WithUpdateChecker(f UpdateCheckFunc) Option

WithUpdateChecker overrides the update check function, allowing tests to substitute a deterministic stub.

func WithVersion 

func WithVersion(v VersionInfo) Option

WithVersion sets the build-time version metadata.

type SSEStream 

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

SSEStream manages a Server-Sent Events connection.

func NewSSEStream 

func NewSSEStream(w http.ResponseWriter) (*SSEStream, error)

NewSSEStream initializes an SSE connection by setting the required headers and flushing them to the client. Returns an error if the ResponseWriter does not support streaming.

func (*SSEStream) ForceWriteDeadlineNow added in v0.10.0 

func (s *SSEStream) ForceWriteDeadlineNow()

ForceWriteDeadlineNow asks the underlying writer (when supported) to expire write deadlines immediately. This is used during shutdown to unblock stalled writes.

func (*SSEStream) Send 

func (s *SSEStream) Send(event, data string) bool

Send writes an SSE event with the given name and string data. It returns false when the write fails.

func (*SSEStream) SendJSON 

func (s *SSEStream) SendJSON(event string, v any) bool

SendJSON writes an SSE event with JSON-serialized data. Logs and skips the event if marshaling fails.

type Server 

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

Server is the HTTP server that serves the SPA and REST API.

func New 

func New(
	cfg config.Config, database db.Store, engine *sync.Engine,
	opts ...Option,
) *Server

New creates a new Server.

func (*Server) Handler 

func (s *Server) Handler() http.Handler

Handler returns the http.Handler with middleware applied.

func (*Server) ListenAndServe 

func (s *Server) ListenAndServe() error

ListenAndServe starts the HTTP server.

func (*Server) SetGithubToken 

func (s *Server) SetGithubToken(token string)

SetGithubToken updates the GitHub token for testing.

func (*Server) SetPort 

func (s *Server) SetPort(port int)

SetPort updates the listen port (for testing).

func (*Server) Shutdown 

func (s *Server) Shutdown(ctx context.Context) error

Shutdown gracefully shuts down the HTTP server.

type StateFile added in v0.15.0 

type StateFile struct {
	PID       int    `json:"pid"`
	Port      int    `json:"port"`
	Host      string `json:"host"`
	Version   string `json:"version"`
	StartedAt string `json:"started_at"`
}

StateFile records a running server instance.

func FindRunningServer added in v0.15.0 

func FindRunningServer(dataDir string) *StateFile

FindRunningServer scans dataDir for server state files and returns the first one whose process is still alive and whose port is accepting connections. Stale state files are cleaned up automatically.

type UpdateCheckFunc added in v0.12.0 

type UpdateCheckFunc func(
	currentVersion string,
	forceCheck bool,
	cacheDir string,
) (*update.UpdateInfo, error)

UpdateCheckFunc is the signature for functions that check for available updates. The default is update.CheckForUpdate.

type VersionInfo 

type VersionInfo struct {
	Version   string `json:"version"`
	Commit    string `json:"commit"`
	BuildDate string `json:"build_date"`
	ReadOnly  bool   `json:"read_only,omitempty"`
}

VersionInfo holds build-time version metadata.

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.