--------------------------------------------------------------------------- INTEGRATION TESTS: full DB-backed scenarios ------------------------------

=========================================== Core Template Sending =========================================== sendTemplate renders and sends an email

BuildAppGenerationPrompt builds a prompt for app generation

Classify produces a SignalEnvelope from a user message. focusMode maps to OSA mode. hasProject/hasClient increase genre confidence.

ComposePrompt assembles a complete prompt from layers

IsProduction returns true if running in production environment.

NewEmbeddingCacheService creates a new embedding cache service If redisClient is nil, the service will be disabled pool is optional and only used for

NewOSAStreamingHandler creates a new SSE streaming handler

NewRateLimiter creates a new rate limiter

Build a query string from a plain object, omitting undefined/null values.

createTableSyncHandler creates a handler for a specific table's sync endpoint.

mapStatusForFrontend converts backend status strings to frontend-expected values. Frontend expects: pending, starting, in_progress, completed, failed

Register an error handler.

pgUUIDToUUID converts pgtype.UUID to uuid.UUID

IsFallback reports whether err is (or wraps) a FallbackError. The SORX engine calls this to distinguish degraded-mode situations from hard failures.

NewFastClassifier creates a new FastClassifier.

NewQuotaService creates a new quota management service.

Send publishes a request to SorxMain and blocks until the matching response arrives or the context / send timeout expires. When SorxMain is unavailab

Size returns the current queue size

Stop stops the rate limiter cleanup goroutine

createOSATestApp creates a test OSA generated app for API tests

estimateTokens estimates token count for text

============================================================================ Helper Functions - Credential Loading & Retry Logic =====================

setupTestLogger creates a test logger

setupTestRedis creates a mini-redis instance for testing

testQuotaConfig creates a config for quota tests

testQuotaLogger creates a logger for quota tests

Helper to convert google/uuid to pgtype.UUID

CSRF returns a middleware that provides CSRF protection using the Double Submit Cookie pattern How it works: 1. Generates a random token and stores i

ConfigFromEnv reads CARRIER configuration from environment variables, merging over the supplied base. Missing optional variables retain their base val

Execute runs a function with circuit breaker protection

GetClient returns a single client with its contacts, interactions, and deals

GetEnabledTools returns the list of tools this agent can use

Identity

NewAppContainerManager creates a new app container manager.

NewHTTPRateLimiter creates a new HTTP rate limiter

NewSandboxCleanupService creates a new cleanup service.

NewWorkspaceManager creates a new workspace manager

ProcessChunk processes a chunk of streaming output and returns events

RespondUnauthorizedErr sends a 401. Pass a safe message like "authentication required" or "invalid token".

RetryWithBackoffTimeout executes a function with exponential backoff and configurable timeout

ValidateInput checks input and returns a validation result

computeUnifiedDiff computes a unified diff between two strings

indexFilesByPath creates a map of file path → file info

sanitize fills in default values for optional Request fields and clamps Priority to the valid range. It does not validate required fields.

testAppLogger creates a logger for tests

testCleanupLogger creates a logger for tests

===================================================================== MEMBER MANAGEMENT ==============================================================

============================================================================= GENERIC KEY-VALUE CACHING ==============================================

Connection Management

Configuration

NewArtifactDetector creates a new artifact detector

NewCacheWorkerPool creates a new cache worker pool Parameters: - workers: Number of concurrent workers (recommended: 5-20 depending on load) - queueS

NewE2BError constructs a minimal E2BError.

Release marks a port as available

RoutingKey constructs a dot-separated AMQP topic routing key from a topic and an action. For example, RoutingKey("mcts", "analyze_revenue") returns "m

Status handles GET /api/sync/status. Returns the last push and pull timestamps for the requesting device (or any device when device_id is omitted), a

Stop stops the image warming service

Identity

UpdateStep updates an existing step

createChunk creates a chunk with ID and metadata

* Calculate 3D distance between two hand landmarks

============================================================================= INTERNAL HELPERS =======================================================

newFallback constructs a FallbackError with the given reason and optional underlying error.

setupTestTemplatesDir creates a temporary directory with test templates

Allocate assigns an available port to the given app. Uses Redis SETNX for distributed locking, with database persistence.

CanAccessMemory checks if user can access a specific memory

ComputeDiff compares two snapshots and returns the differences

Connect handles API key connection. Accepts API key and validates it by making a test API call.

===================================================================== WORKSPACE CRUD =================================================================