Metadata projection ``{id, name, agent_kind, revision, llm_profile_ref, mcp_server_refs}`` per profile — the shape the SDK FK scans and the li

Mark this metrics record as successfully uploaded.

Mark a user as synced to a specific audience. Uses upsert to handle race conditions - if the user is already marked as synced, this i

Process a stats event and update conversation statistics. Args: event: The ConversationStateUpdateEvent with key='stats'

Revoke the instance-level super-admin role from a user. Clears ``user.role_id``. Refuses to remove the **last** remaining super admin

* Save the settings to the server. Only valid settings are saved. * @param settings - the settings to save

Search for event callbacks, optionally filtered by event_id.

Search for sandbox specs.

Search events for a specific shared conversation.

Store session init data.

Store user-repository mappings in database (async version) 1. Make sure to store mappings if they don't exist 2. If a mappin

Unlink from Jira DC and, for integration owners, optionally revoke the hook. A non-owner user is only detached from the workspace (their personal

Update the user's current organization. Args: user_id: The user's ID (Keycloak user ID) org_id: The organization ID t

Update an invitation's status. Args: invitation_id: The invitation ID status: New status (pending, accepted, revoked,

Validate the service API key from the request header. Args: x_service_api_key: The service API key from the X-Service-API-Key header

Validate if the user's organization has an active Jira integration.

Convert skill info from API response to Skill object. Args: skill_info: SkillInfo model from API response Returns: Skill obj

Return the PostHog distinct_id for the given user. In feature/staging environments, prefixes with 'FEATURE_' to keep test traffic sep

Extract owner information from the webhook payload. Different providers structure their payloads differently, so this method

Archive the conversation's workspace, then delete the sandbox if unreferenced. Runs detached (background task) AFTER the delete response was alre

Validate and return the workspace for the webhook. Returns None if: - Workspace not found - Workspace is inactive - R

Get the agent server context for a conversation. This helper retrieves all necessary information to communicate with the agent server for a g

Get all keys for a user from LiteLLM. Returns a list of key info dictionaries containing: - token: the key value (hashed or partial)

Get authentication service URL from environment variable. Reads AUTH_URL from environment. If not set or empty, returns None.

Get bucket name, falling back to environment variable if not set.

Get GitHub app slug from environment variable. Reads GITHUB_APP_SLUG from environment. If set, returns the value. If empty or unset, returns

Extract issue/PR number from a GitHub webhook payload. Supports all event types that can trigger jobs: - Labeled issues: payload['iss

Get maintenance start time from environment variable. Reads MAINTENANCE_START_TIME from environment. If set to a valid ISO 8601 timestamp, re

Get PostHog client key from environment variable. Reads POSTHOG_CLIENT_KEY from environment. If not set or empty, returns the OSS default key

Get multiple runtimes in a single batch request. Args: sandbox_ids: List of sandbox IDs to fetch Returns: Di

Get all keys for a user from LiteLLM. Args: client: The HTTP client to use for the request keycloak_user_id: The user

Load Org objects for a user's org memberships. Uses OrgStore.get_orgs_by_ids() to batch-load all Org objects in a single query, avoiding N+1.

Check if a repository is hosted on Azure DevOps. Args: repo_name: Repository name (e.g., "org/project/repo") user_context: UserCo

Check if a repository is hosted on GitLab. Args: repo_name: Repository name (e.g., "gitlab.com/org/repo" or "org/repo") user_cont

Check if user is the last owner of the organization.

Load persisted conversation settings via the SDK loader.

Create a MeResponse for testing.

Build a MarketplaceRegistration with private-repo defaults.

Post a resolver response comment to the configured GitHub issue.

Convert raw comment data to Comment objects.

Resolve unclaimed events to the bootstrapped default org. Applies only when the default org is enabled (OPENHANDS_DEFAULT_ORG_*) and

Resolve a provider user to their personal OpenHands org. For personal repos (owner type is 'User'), the OpenHands org_id is

Search repositories for a user with optional query filtering. Args: user_auth: The user's authentication context quer

Send error comment before view is created (using payload directly).

Set a cached value in Redis with TTL. Fails silently if Redis is unavailable (graceful degradation).

Profile with the given refs, member pointed at it, member mcp_config with three servers, full load() viable.

Resolve the dashboard-friendly team_alias for an org (its display name, or 'Personal Workspace' for the user's personal org). The org

Convert raw model strings into ``LLMModel`` objects with verified flags. Hidden models (served by the backend but not promoted, e.g. legacy alias

Check if a user exists in LiteLLM. Returns True if the user exists, False otherwise.

Create an async session maker for testing.

Set User.email and email_verified from IDP if they are still NULL. Called during login to gradually fix existing users whose email wa

* Batch get V1 app conversations by their IDs * Returns null for any missing conversations * * @param ids Array of conversation IDs (max 100)

Count conversation start tasks.

Count events matching the given filters.

Count events for a specific shared conversation.

Create multiple organization invitations concurrently. Validates permissions once upfront, then creates invitations in parallel. Arg

Create a new Jira workspace registration.

Create LiteLLM team integration for the organization. Args: org_id: Organization ID user_id: User ID who wil

Helper to create an org in the test database.

Create a new organization.

Helper to create an org member in the test database.

Helper to create a role in the test database.

Helper to create a user in the test database.

Register a user mapping to a Jira DC workspace.

Delete a profile. Returns True if the profile existed. Clears ``active`` if the deleted profile was active.

Delete an API key by its ID. Args: key_id: The ID of the key to delete allow_system: If False (default), system keys

Delete the BYOR key from LiteLLM using the key directly. Also attempts to delete by key alias if the key is not found, to clean up orphaned a

Delete a saved profile, promoting a fallback when it was active. Returns False if the profile didn't exist; True otherwise. When the

Downgrade a migrated user's LiteLLM entries back to the pre-migration state. This reverses the migrate_entries operation: 1. Get the

Names duplicated within ``marketplaces`` or already in ``reserved_names``. ``name`` is the marketplace identity (used by ``plugin@marketplace``