DefaultCircuitBreakerConfig returns sensible defaults

DefaultCleanupConfig returns the default cleanup configuration.

DefaultMonitorConfig returns default monitoring configuration

Execute runs the skill with the given parameters params should be a JSON-serializable map of parameters Returns the result as a JSON-serializable valu

============================================================================= GENERIC QUERY CACHING ==================================================

GetAgent creates an agent of the specified type

GetCurrentUser retrieves the authenticated user from context

NewImageWarmerService creates a new image warmer service

NewMemoryHandler creates a new MemoryHandler

NewOSAAppsHandler creates a new OSA apps handler

NewSandboxPortAllocator creates a new port allocator with the given configuration.

NewSelfImprovementEngine constructs a SelfImprovementEngine. redisClient may be nil; in that case reward-weight loads fall back to defaults and Q-tabl

Register adds a skill to the registry

Security logs security-relevant events

SendToUser sends an event to all connections for a user with timeout and health tracking

checkSchemaProtection validates changes against protected schemas

containsType reports whether the slice contains the given type string

createOSATestUser creates a test user and session for OSA API tests

dashboardJsonBody serialises v and returns a *bytes.Buffer for HTTP requests.

============================================================================ Helpers =================================================================

--------------------------------------------------------------------------- UNIT TESTS: auth-only handler paths — no database required ---------------

============================================================================= POINTER HELPERS ========================================================

seedUserAndWorkspace inserts a minimal user and workspace so FK constraints on custom_modules / module_installations are satisfied.

setupTestRedis creates a Redis client for testing Set REDIS_URL environment variable or use default localhost:6379

ActiveHintsForUser returns hints scoped to a specific user. Falls back to ActiveHints() if userID is empty.

AddConnection increments connection count for a user Returns true if connection is allowed, false if limit exceeded

Close cleans up the test Redis instance

ConnectedCount returns number of connected users

CreateTestCredentials creates test credentials map

DeleteWorkspace deletes a workspace (only owner can do this)

Enabled reports whether the client will actually issue requests.

Extract detects patterns from the current turn's messages.

Flush returns any remaining buffered content

Generate processes an app generation request with full production patterns

GenerateApp generates an app with full resilience

GetContext returns a single context

GetLastMode returns the last known mode for a conversation from cache. Returns empty string if no mode is cached.

GetLogger returns the global sanitized logger

GetSubscriberCount returns the current number of active subscribers

HealthCheck checks if OSA is healthy and reachable.

IsContainerized returns true if this session is running in a Docker container

NewCacheService creates a new cache service instance

NewRegistry creates a new skill registry

NewSandboxHealthMonitor creates a new health monitor.

NewSnapshotDiffService creates a new snapshot diff service

ObserveSync runs the pipeline synchronously. Used for testing.

RecordCorrectionResult records whether a single-loop correction worked. Called by the homeostatic loop after each correction attempt.

RegisterContainer registers a new container with the monitor

===================================================================== HANDLER REGISTRATION ===========================================================

Set stores a generic value in cache with TTL

Shutdown gracefully shuts down the worker pool Waits for all workers to finish processing current tasks. Parameters: - timeout: Maximum time to wait

Start begins processing tasks with the configured number of workers This is non-blocking - workers run in background goroutines.

Stop stops the cleanup goroutine

checkFileProtection validates changes against protected files

Helper functions containsSubstring checks if a string contains a substring (case-insensitive)

createModuleFromFixture creates a module in the DB using a named fixture file.

extractEntitiesFromText extracts entities from text

Helper functions

generateSessionBoundState creates a state bound to the user's session ID. This prevents CSRF attacks where an attacker uses their own state parameter.

newNoAuthRouter returns a gin.Engine with no user injected (simulates unauthenticated requests).

requireDocker skips the test if no Docker daemon is reachable. All ImageWarmerService tests require a live Docker daemon.

sendEvent safely sends an event to the channel

setupTestRedis creates a test Redis instance using miniredis

============================================================================= TEST HELPERS ===========================================================

tableMapToJSONBytes converts a map to JSON bytes

testConfig creates a config for tests

testHealthLogger creates a logger for tests

testLogger creates a logger for tests

userSessionsKey generates a secure Redis key for user's session set using HMAC-SHA256 This prevents user ID enumeration and links session hashes to us

uuidString formats a UUID byte array as the canonical hex form. Avoids pulling the uuid package at this layer just for a tiny formatter.

validateSessionBoundState validates that the state matches the session.

APIRequest makes an authenticated request to the Notion API.

AllowMessage checks if a message is allowed under rate limiting

DefaultChunkOptions returns sensible defaults

---- Exec / Checkpoint / Restore --------------------------------------------- ExecCommand executes a command inside a running Sprite and returns its

GetCalendarAPI returns a Google Calendar API service for a user.