Best-effort 👀 acknowledgement on the triggering PR comment. Mirrors ``GithubManager._add_reaction``: posted once we've decided the re

Add a reaction to the GitHub issue, PR, or comment. Args: github_view: The GitHub view object containing issue/PR/comment info

Add system-generated MCP servers (default OpenHands server). The default server includes the Tavily search proxy if configured. Tavil

Query params for GET /api/file/archive. The tar.gz is the SELF-CONTAINED full capture, so disable the endpoint's default excludes for it: oth

Archive one workspace via the in-pod agent-server; return may-proceed. Returns True when the workspace was captured, when there was nothing t

Send a message to the agent server via the V1 API and return response text.

Send a message to the agent server via the V1 API and return response text.

Return a callable that yields ``value`` as an async context manager. Mirrors ``get_*_service(state)``, which is used as ``async with get_x(st

Backfill the synced_users table with contacts already in Resend. This ensures that users who were added to Resend before the tracking table e

Build the final data structure for JSON storage

Image URL of the bundled agent-server: ``<repo>:<version>-python``.

Whether BYOK is on. Read from the resolved web-client config so discovery and the UI gate agree on the same value.

Return the global skill-repo paths for an owner, by provider convention. GitHub-style providers expose two independent repos (``.openhands`` and

Check if the agent server is responding to health checks. Args: sandbox: The sandbox info containing exposed URLs htt

Returns error message if token type doesn't match, None otherwise.

Atomically claim a repo selection form interaction. Slack can deliver multiple button click payloads when a user clicks the form repe

Classify conversation error into broad categories for dashboard filtering. Categories: budget_exceeded, model_error, runtime_error, timeout, user

Drop empty nested diffs and collapse empty diff payloads to ``None``.

Clear cached data that depends on the effective organization.

Yield a TestClient scoped to a specific user_id + settings store. Used by multi-user isolation tests; the module-level ``test_client`` fixtur

Validate a raw entry into a model, or None (logged) if invalid.

Recursively coerce SecretStr / MCPConfig leaves to plain values.

Walk the AST to find 0-indexed line numbers where splitting is appropriate. A "split-after" line is the last line of a top-level AST child: split

Check commenter permissions using the installer's Bitbucket DC token. The check confirms whether the commenter has ``REPO_WRITE`` or

Build the base property dict included on every event.

Configure LLM settings. Starts from the user's saved LLM configuration and overrides only the fields that the server needs to resolve

Consume the remaining items from an async iterator

Count all event files in the conversation directory without filtering.

Count OpenHands commits, review comments, and general PR comments

Create or update agent with skills in its context. Args: agent: The agent to update skills: List of Skill objects to

Create a new user authorization rule.

Create semantically-aware chunks from a tree-sitter parse tree. Args: tree: A tree_sitter.Tree returned by parser.parse(). text:

Create a GithubIssue instance for testing.

Create a V1 callback processor for GitHub integration.

Create a V1 callback processor for GitLab integration.

Create a V1 callback processor for Jira DC integration.

Provision org-scoped LiteLLM access and return the member API key.

Create a mock event that is not a ConversationStateUpdateEvent.

Build a ProviderHandler for the user, or None if no provider is linked.

Create a ProviderHandler for the user.

Create a SlackV1CallbackProcessor for V1 conversation handling.

Create conversation using the V1 app conversation system.

Create conversation using the new V1 app conversation system.

Create conversation using the new V1 app conversation system.

Create conversation using the new V1 app conversation system.

Attempt Fernet decryption using every known key. The legacy Fernet key is derived as ``b64encode(sha256(secret).digest())``, matching

Remove duplicate repositories based on full_name.

Delete an authorization rule by ID.

Delete all sub-conversations of a parent conversation. This method handles errors gracefully, continuing to delete remaining sub-conv

Best-effort marketplace name from a source string. ``github:owner/repo`` / ``.../owner/repo`` -> ``repo``. Falls back to the raw source when

Collect skill-repo owners for a provider: the user's login plus their orgs. Failures are swallowed so that a single provider error never prevents