newContext returns a minimal ConversationContext for a given conversation.

newDashboardHandler builds a DashboardCRUDHandler with a nil pool (suitable for unit tests that do NOT need real DB access).

tableUUIDToString converts a pgtype.UUID to string

writeSSEEvent writes a streaming event in SSE format

Get retrieves cached user data for a session token

NewOSAPromptBuilder creates a new prompt builder instance

Register registers a collection point with this metric.

Call in onDestroy to guarantee all resources are released.

createIntTestWorkspace creates a workspace for integration tests

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

Send a POST and return the decoded JSON body.

RegisterSkill adds a skill to the registry.

State returns the current circuit breaker state

createTestApp creates a test generated app in the database

getPoolFromContext extracts pgxpool.Pool from execution context.

setupOSARouter creates a test router with auth for OSA API tests

============================================================================= ERROR RESPONSE HELPERS =================================================

Abort the stream.

setupDashboardRouter returns a test Gin engine with an optional authenticated user injected via middleware. Pass an empty string for userID to simula

NewSmartChunkingService creates a new smart chunking service

crmJsonBody marshals v to a bytes.Reader for use as an HTTP request body.

matchesPattern checks if a target matches a protection pattern. Supports: - Exact match: "users" matches "users" - Prefix match with wildcard: "api/*"

Update block props

GetEmbedding retrieves a cached embedding Returns (embedding, found, error) - embedding: the cached embedding vector (nil if not found) - found: true

NewBuildEventBus creates a new build event bus

ParsePagination reads page/page_size (or legacy limit/offset) from the Gin context and returns normalised PaginationParams. It is always safe to call;

Unsubscribe removes a subscriber from the bus. IMPORTANT: The Events channel is NOT closed here. Closing it while Publish may be holding a reference

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

─── shared test helpers ──────────────────────────────────────────────────── newProjectHandler returns a handler with nil dependencies — safe for requ

newTestCRMHandler returns a CRMHandler backed by a nil pool. Safe for unit tests that do NOT hit the database.

seedContext injects a ConversationContext directly into the in-memory cache.

setTestUser injects a fake user into the gin context, replicating what AuthMiddleware does in production.

Allow checks if a request should be allowed Returns true if allowed, false if rate limit exceeded

Close cleans up session resources

GetActiveProvider returns the currently configured AI provider. Falls back to "ollama_local" when the configured provider lacks credentials and logs a

NewPromptComposer creates a new prompt composer with core layers

Pool returns the database pool.

Reset resets the detector state

── helpers ──────────────────────────────────────────────────────────────── newAuthRouter returns a gin.Engine that injects a valid *middleware.Better

Helper functions for converting pgtype values to JSON-friendly formats

* Resolve a conflict between local and server records

DefaultConfig returns a Config populated with safe defaults. Callers should override URL and OSInstanceID for their environment.

NewPaginatedResponse constructs a PaginatedResponse from a data payload, the total item count, and the pagination parameters used to fetch data.

NewTemplateLoaderService creates a new template loader service

SetEmbedding caches an embedding with specified TTL If ttl is 0, uses default TTL based on embedding type

Helper to create OsaModuleFile for testing

Render a wiki page for a specific audience.

setupCSRFTestContext creates a Gin test context for CSRF middleware testing

Create stores a new session

GetNode returns a single node

LoadTemplate loads and parses a YAML template by name

MobileRespondUnauthorized returns a 401 for auth failures

NewSSEWriter creates a new SSE writer

makeRequest helper for making authenticated requests

makeTransition creates a transition where FromMode spent durationMs before switching to toMode. DurationMs measures time in the *previous* mode (FromM

---- test helpers -----------------------------------------------------------

* Run a raw query

* Run a raw statement

setupSandboxTestRouter creates a test router with sandbox handler

Helper functions imported from osa_api_test_helpers.go - setupOSARouter - createOSATestUser - createOSATestWorkspace - createOSATestApp - createOSABui

Count returns the number of registered skills

Count returns the number of registered agents.

Error logs at error level

NewClient creates a new OSA client for a local/runtime endpoint.

NewContainerMetrics creates a new metrics instance

Submit submits a task to the worker pool Returns error if queue is full or pool is shutting down. This is non-blocking - returns immediately with err

WriteEvent writes a StreamEvent as an SSE event

createIntTestMemory creates a memory for integration tests