Run executes the renewal reminder job Sends reminders at 7 days, 3 days, and 1 day before expiry

Error implements the error interface.

Close releases transport-internal resources.

Add adds a log entry to the buffer.

waitFor polls a condition function every 10ms until it returns true or timeout

Run starts the runner with a suture Supervisor tree and blocks until context is cancelled. All core components (gRPC connection, MCP server, Monitor,

setupTestService creates a test service with seeded plans

Write writes data to the terminal stdin.

ResolveOrgScope reads org_slug from a Connect request, validates the caller's membership in that organization, and returns a context carrying a fully-

Feed processes raw PTY data with proper UTF-8 support. Returns the current screen lines for downstream consumers (single-direction data flow). This av

New creates a new Updater instance.

Set assigns a variable value.

newTestRepo creates a BillingRepository from *gorm.DB for tests.

NewVirtualTerminal creates a new virtual terminal

setupTestDB creates an in-memory SQLite database for testing. Delegates to testkit.SetupTestDB for shared schema.

newTestLogger creates a test logger that only logs errors

--------------------------------------------------------------------------- Helpers ------------------------------------------------------------------

Parse tokenizes the input and parses it into a Program AST.

NewMockConnection creates a new mock connection for testing.

NewInMemoryPodStore creates a new in-memory pod store.

* Execute cleanup SQL (typically DELETE statements).

NewRunnerMessageHandler creates a new message handler.

setupTestDB creates an in-memory SQLite database for testing.

SendMessage sends a raw RunnerMessage to the server. Used for Autopilot events and other custom messages.

newTestService creates a channel Service backed by an in-memory DB for testing.

NewHTTPServer creates a new MCP HTTP server. rpcClient is used for MCP tool calls over the gRPC bidirectional stream.

CallToolText returns the raw text payload from a tool. Use this for tools that return human-readable strings (get_pod_status, send_pod_input) rather t

NewContext creates a Context with platform-injected values.

WithReleaseDetector sets a custom release detector (for testing).

Parse collects token usage from session files. sandboxPath is the pod's sandbox root directory. podStartedAt is the pod's start time; only files modif

RegisterPod registers a pod with the MCP server.

NewMultiSignalDetector creates a new multi-signal detector.

Pod returns a logger for pod operations.

SetReadDeadline sets a deadline for Read operations. After the deadline, Read returns os.ErrDeadlineExceeded.

Put stores a pod.

setupTestDB creates an in-memory SQLite database for testing. Delegates to testkit.SetupTestDB for shared schema.

Pre-defined module loggers for common components. These provide convenient access to module-specific loggers. GRPC returns a logger for gRPC-related l

setupTestDB creates an in-memory SQLite database for testing. Delegates to testkit.SetupTestDB for shared schema.

handleMCP handles MCP JSON-RPC requests.

newTestService creates a Service with an in-memory DB and nil redis