Bulk fetch webhooks for multiple resources. This is more efficient than fetching one at a time in a loop. Args: project_

Handle callback processing errors with appropriate logging and user messages. This centralizes the error handling logic for V1 callback processor

Extract repository names as 'owner/repo' from URLs and direct mentions. Supports cloud and self-hosted Git providers: GitHub / GitHub Enterprise,

Check if a key name indicates a system key.

Check if an invitation token has expired. Args: invitation: The invitation to check Returns: bool: True if e

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'

Refresh the managed OpenHands LiteLLM key for the current user/org. Delegates the full managed-key lifecycle (effective-config classification,

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.

Like ``_patched`` but also patches ``get_instance`` to return a real ``SaasSettingsStore`` bound to the test DB, so the route exercises the

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.