mirror of
https://github.com/OpenHands/OpenHands.git
synced 2026-10-07 14:47:53 +08:00
refactor: move openhands.core.logger to openhands.app_server.utils.logger (#14235)
Co-authored-by: openhands <openhands@all-hands.dev>
This commit is contained in:
co-authored by
openhands
parent
b55b975458
commit
e94b504eb4
@@ -25,7 +25,7 @@ from storage.bitbucket_webhook_store import BitbucketWebhookStore
|
||||
|
||||
from openhands.app_server.integrations.provider import ProviderToken, ProviderType
|
||||
from openhands.app_server.secrets.secrets_models import Secrets
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
MissingSettingsError,
|
||||
|
||||
@@ -5,7 +5,7 @@ from openhands.app_server.integrations.bitbucket.bitbucket_service import (
|
||||
BitBucketService,
|
||||
)
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class SaaSBitBucketService(BitBucketService):
|
||||
|
||||
@@ -33,7 +33,7 @@ from openhands.app_server.integrations.service_types import Comment
|
||||
from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
OH_LABEL, INLINE_OH_LABEL = get_oh_labels(HOST)
|
||||
|
||||
@@ -26,7 +26,7 @@ from storage.bitbucket_dc_webhook_store import BitbucketDCWebhookStore
|
||||
|
||||
from openhands.app_server.integrations.provider import ProviderToken, ProviderType
|
||||
from openhands.app_server.secrets.secrets_models import Secrets
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
MissingSettingsError,
|
||||
|
||||
@@ -5,7 +5,7 @@ from openhands.app_server.integrations.bitbucket_data_center.bitbucket_dc_servic
|
||||
BitbucketDCService,
|
||||
)
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class SaaSBitbucketDCService(BitbucketDCService):
|
||||
|
||||
@@ -33,7 +33,7 @@ from openhands.app_server.integrations.service_types import Comment
|
||||
from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
OH_LABEL, INLINE_OH_LABEL = get_oh_labels(HOST)
|
||||
|
||||
@@ -23,8 +23,8 @@ from openhands.app_server.conversation_paths import get_conversation_dir
|
||||
from openhands.app_server.file_store import get_file_store
|
||||
from openhands.app_server.integrations.github.github_service import GithubServiceImpl
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.core.config import load_openhands_config
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
|
||||
config = load_openhands_config()
|
||||
file_store = get_file_store(config.file_store, config.file_store_path)
|
||||
|
||||
@@ -34,7 +34,7 @@ from server.auth.token_manager import TokenManager
|
||||
from openhands.app_server.integrations.provider import ProviderToken, ProviderType
|
||||
from openhands.app_server.integrations.service_types import AuthenticationError
|
||||
from openhands.app_server.secrets.secrets_models import Secrets
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
MissingSettingsError,
|
||||
|
||||
@@ -6,7 +6,7 @@ from server.auth.token_manager import TokenManager
|
||||
|
||||
from openhands.app_server.integrations.github.github_service import GitHubService
|
||||
from openhands.app_server.integrations.service_types import ProviderType, Repository
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import AppMode
|
||||
|
||||
|
||||
|
||||
@@ -41,7 +41,7 @@ from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.app_server.utils.async_utils import call_sync_from_async
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
OH_LABEL, INLINE_OH_LABEL = get_oh_labels(HOST)
|
||||
|
||||
@@ -28,7 +28,7 @@ from server.auth.token_manager import TokenManager
|
||||
from openhands.app_server.integrations.gitlab.gitlab_service import GitLabServiceImpl
|
||||
from openhands.app_server.integrations.provider import ProviderToken, ProviderType
|
||||
from openhands.app_server.secrets.secrets_models import Secrets
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
MissingSettingsError,
|
||||
|
||||
@@ -14,7 +14,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
Repository,
|
||||
RequestMethod,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import AppMode
|
||||
|
||||
|
||||
|
||||
@@ -28,7 +28,7 @@ from openhands.app_server.integrations.service_types import Comment
|
||||
from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
OH_LABEL, INLINE_OH_LABEL = get_oh_labels(HOST)
|
||||
|
||||
@@ -14,7 +14,7 @@ from integrations.utils import GITLAB_WEBHOOK_URL
|
||||
from storage.gitlab_webhook import GitlabWebhook, WebhookStatus
|
||||
from storage.gitlab_webhook_store import GitlabWebhookStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
if TYPE_CHECKING:
|
||||
from integrations.gitlab.gitlab_service import SaaSGitLabService
|
||||
|
||||
@@ -44,7 +44,7 @@ from storage.jira_workspace import JiraWorkspace
|
||||
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
MissingSettingsError,
|
||||
|
||||
@@ -8,7 +8,7 @@ from dataclasses import dataclass
|
||||
from enum import Enum
|
||||
from urllib.parse import urlparse
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class JiraEventType(Enum):
|
||||
|
||||
@@ -43,7 +43,7 @@ from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
JIRA_CLOUD_API_URL = 'https://api.atlassian.com/ex/jira'
|
||||
|
||||
@@ -33,7 +33,7 @@ from openhands.app_server.integrations.provider import ProviderHandler
|
||||
from openhands.app_server.integrations.service_types import Repository
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.shared import server_config
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
|
||||
@@ -34,7 +34,7 @@ from openhands.app_server.integrations.provider import ProviderHandler, Provider
|
||||
from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
integration_store = JiraDcIntegrationStore.get_instance()
|
||||
|
||||
@@ -10,7 +10,7 @@ from uuid import UUID
|
||||
from storage.org_git_claim_store import OrgGitClaimStore
|
||||
from storage.org_member_store import OrgMemberStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
async def resolve_org_for_repo(
|
||||
|
||||
@@ -38,7 +38,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
Repository,
|
||||
)
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.shared import config, server_config
|
||||
from openhands.server.types import (
|
||||
LLMAuthenticationError,
|
||||
|
||||
@@ -53,7 +53,7 @@ class SlackMessageView:
|
||||
SlackMessageView if all required fields are available,
|
||||
None if required fields are missing or bot token unavailable.
|
||||
"""
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
team_id = payload.get('team', {}).get('id') or payload.get('team_id')
|
||||
channel_id = (
|
||||
|
||||
@@ -36,7 +36,7 @@ from openhands.app_server.services.injector import InjectorState
|
||||
from openhands.app_server.user.specifiy_user_context import USER_CONTEXT_ATTR
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.app_server.utils.async_utils import GENERAL_TIMEOUT
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk import TextContent
|
||||
|
||||
# =================================================
|
||||
|
||||
@@ -4,7 +4,7 @@ from storage.user_repo_map import UserRepositoryMap
|
||||
from storage.user_repo_map_store import UserRepositoryMapStore
|
||||
|
||||
from openhands.app_server.integrations.service_types import Repository
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
async def store_repositories_in_db(repos: list[Repository], user_id: str) -> None:
|
||||
|
||||
@@ -8,7 +8,7 @@ from server.auth.saas_user_auth import SaasUserAuth
|
||||
from server.auth.token_manager import TokenManager
|
||||
|
||||
from openhands.app_server.user_auth.user_auth import UserAuth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
def is_budget_exceeded_error(error_message: str) -> bool:
|
||||
|
||||
@@ -41,7 +41,7 @@ from storage.role import Role
|
||||
from storage.role_store import RoleStore
|
||||
|
||||
from openhands.app_server.user_auth import get_user_auth, get_user_id
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class Permission(str, Enum):
|
||||
|
||||
@@ -3,7 +3,7 @@ from pydantic import SecretStr
|
||||
from server.auth.auth_utils import user_verifier
|
||||
|
||||
from openhands.app_server.integrations.github.github_types import GitHubUser
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
def is_user_allowed(user_login: str):
|
||||
|
||||
@@ -4,7 +4,7 @@ from pydantic import SecretStr
|
||||
from sqlalchemy import select
|
||||
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import AppMode
|
||||
|
||||
|
||||
|
||||
@@ -11,7 +11,7 @@ from server.auth.constants import (
|
||||
SUSPICIOUS_LABELS,
|
||||
)
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -4,7 +4,7 @@ from typing import Dict, List, Optional, Tuple
|
||||
import gspread
|
||||
from google.auth import default
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GoogleSheetsClient:
|
||||
|
||||
@@ -5,7 +5,7 @@ Email domain validation utilities for enterprise endpoints.
|
||||
from fastapi import Depends, HTTPException, Request, status
|
||||
|
||||
from openhands.app_server.user_auth import get_user_auth, get_user_id
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
async def get_admin_user_id(
|
||||
|
||||
@@ -8,7 +8,7 @@ from typing import TextIO
|
||||
|
||||
from pythonjsonlogger.json import JsonFormatter
|
||||
|
||||
from openhands.core.logger import openhands_logger
|
||||
from openhands.app_server.utils.logger import openhands_logger
|
||||
|
||||
LOG_JSON = os.getenv('LOG_JSON', '1') == '1'
|
||||
LOG_LEVEL = os.getenv('LOG_LEVEL', 'INFO').upper()
|
||||
|
||||
@@ -16,7 +16,7 @@ from server.routes.auth import set_response_cookie
|
||||
from server.utils.url_utils import get_cookie_domain, get_cookie_samesite
|
||||
|
||||
from openhands.app_server.user_auth.user_auth import AuthType, UserAuth, get_user_auth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.shared import config
|
||||
|
||||
|
||||
|
||||
@@ -19,7 +19,7 @@ from starlette.applications import Request, Response, Starlette
|
||||
from starlette.exceptions import HTTPException
|
||||
from storage.redis import get_redis_authed_url
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
def setup_rate_limit_handler(app: Starlette):
|
||||
|
||||
@@ -14,7 +14,7 @@ from storage.user_store import UserStore
|
||||
|
||||
from openhands.app_server.user_auth import get_user_auth, get_user_id
|
||||
from openhands.app_server.user_auth.user_auth import AuthType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
# Helper functions for BYOR API key management
|
||||
|
||||
@@ -55,7 +55,7 @@ from openhands.app_server.integrations.provider import (
|
||||
from openhands.app_server.integrations.service_types import ProviderType, TokenResponse
|
||||
from openhands.app_server.user_auth import get_access_token
|
||||
from openhands.app_server.user_auth.user_auth import get_user_auth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.shared import config
|
||||
|
||||
with warnings.catch_warnings():
|
||||
|
||||
@@ -15,7 +15,7 @@ from storage.user_store import UserStore
|
||||
|
||||
from openhands.app_server.user_auth import get_user_id
|
||||
from openhands.app_server.user_auth.user_auth import get_user_auth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Email validation regex pattern
|
||||
EMAIL_REGEX = re.compile(r'^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}$')
|
||||
|
||||
@@ -13,7 +13,7 @@ from server.auth.token_manager import TokenManager
|
||||
from storage.bitbucket_webhook_store import BitbucketWebhookStore
|
||||
from storage.redis import get_redis_client_async
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
bitbucket_integration_router = APIRouter(prefix='/integration')
|
||||
|
||||
|
||||
@@ -13,7 +13,7 @@ from server.auth.token_manager import TokenManager
|
||||
from storage.bitbucket_dc_webhook_store import BitbucketDCWebhookStore
|
||||
from storage.redis import get_redis_client_async
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
bitbucket_dc_integration_router = APIRouter(prefix='/integration')
|
||||
|
||||
|
||||
@@ -16,7 +16,7 @@ from server.auth.token_manager import TokenManager
|
||||
from server.services.automation_event_service import AutomationEventService
|
||||
|
||||
from openhands.app_server.integrations.provider import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Environment variable to disable GitHub webhooks
|
||||
GITHUB_WEBHOOKS_ENABLED = os.environ.get('GITHUB_WEBHOOKS_ENABLED', '1') in (
|
||||
|
||||
@@ -22,7 +22,7 @@ from storage.redis import get_redis_client_async
|
||||
|
||||
from openhands.app_server.integrations.gitlab.gitlab_service import GitLabServiceImpl
|
||||
from openhands.app_server.user_auth import get_user_id
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
gitlab_integration_router = APIRouter(prefix='/integration')
|
||||
webhook_store = GitlabWebhookStore()
|
||||
|
||||
@@ -21,7 +21,7 @@ from storage.jira_workspace import JiraWorkspace
|
||||
from storage.redis import get_redis_client
|
||||
|
||||
from openhands.app_server.user_auth.user_auth import get_user_auth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Environment variable to disable Jira webhooks
|
||||
JIRA_WEBHOOKS_ENABLED = os.environ.get('JIRA_WEBHOOKS_ENABLED', '0') in (
|
||||
|
||||
@@ -29,7 +29,7 @@ from server.constants import WEB_HOST
|
||||
from storage.redis import get_redis_client
|
||||
|
||||
from openhands.app_server.user_auth.user_auth import get_user_auth
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Environment variable to disable Jira DC webhooks
|
||||
JIRA_DC_WEBHOOKS_ENABLED = os.environ.get('JIRA_DC_WEBHOOKS_ENABLED', '0') in (
|
||||
|
||||
@@ -5,7 +5,7 @@ from fastmcp.client.transports import NpxStdioTransport
|
||||
from fastmcp.server import create_proxy
|
||||
|
||||
from openhands.app_server.mcp.mcp_router import mcp_server
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
ENABLE_MCP_SEARCH_ENGINE = (
|
||||
os.getenv('ENABLE_MCP_SEARCH_ENGINE', 'false').lower() == 'true'
|
||||
|
||||
@@ -11,7 +11,7 @@ from storage.api_key_store import ApiKeyStore
|
||||
from storage.device_code_store import DeviceCodeStore
|
||||
|
||||
from openhands.app_server.user_auth import get_user_id
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# Constants
|
||||
|
||||
@@ -23,7 +23,7 @@ from storage.org_store import OrgStore
|
||||
from storage.role_store import RoleStore
|
||||
|
||||
from openhands.app_server.user_auth import get_user_id
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Router for invitation operations on an organization (requires org_id)
|
||||
invitation_router = APIRouter(prefix='/api/organizations/{org_id}/members')
|
||||
|
||||
@@ -51,7 +51,7 @@ from storage.org_store import OrgStore
|
||||
from storage.user_store import UserStore
|
||||
|
||||
from openhands.app_server.user_auth import get_user_id
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Initialize API router
|
||||
org_router = APIRouter(prefix='/api/organizations', tags=['Orgs'])
|
||||
|
||||
@@ -3,7 +3,7 @@ from sqlalchemy.sql import text
|
||||
from storage.database import a_session_maker
|
||||
from storage.redis import get_redis_client
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
readiness_router = APIRouter()
|
||||
|
||||
|
||||
@@ -17,7 +17,7 @@ from storage.api_key_store import ApiKeyStore
|
||||
from storage.org_member_store import OrgMemberStore
|
||||
from storage.user_store import UserStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Environment variable for the service API key
|
||||
AUTOMATIONS_SERVICE_KEY = os.getenv('AUTOMATIONS_SERVICE_KEY', '').strip()
|
||||
|
||||
@@ -16,7 +16,7 @@ from server.services.user_app_settings_service import (
|
||||
UserAppSettingsServiceInjector,
|
||||
)
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
user_app_settings_router = APIRouter(prefix='/api/users')
|
||||
|
||||
|
||||
@@ -37,7 +37,7 @@ from server.auth.token_manager import TokenManager
|
||||
from storage.redis import get_redis_client_async
|
||||
|
||||
from openhands.app_server.integrations.provider import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Cache TTL constants
|
||||
ORG_CLAIM_CACHE_TTL_SECONDS = 3600 # 1 hour for org claims (rarely change)
|
||||
|
||||
@@ -9,7 +9,7 @@ try:
|
||||
except ImportError:
|
||||
RESEND_AVAILABLE = False
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
DEFAULT_FROM_EMAIL = 'OpenHands <no-reply@openhands.dev>'
|
||||
DEFAULT_WEB_HOST = 'https://app.all-hands.dev'
|
||||
|
||||
@@ -20,7 +20,7 @@ from storage.org_app_settings_store import OrgAppSettingsStore
|
||||
from openhands.app_server.errors import AuthError
|
||||
from openhands.app_server.services.injector import Injector, InjectorState
|
||||
from openhands.app_server.user.user_context import UserContext
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -21,7 +21,7 @@ from storage.org_store import OrgStore
|
||||
from storage.role_store import RoleStore
|
||||
from storage.user_store import UserStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class OrgInvitationService:
|
||||
|
||||
@@ -10,7 +10,7 @@ from server.routes.org_models import (
|
||||
from storage.lite_llm_manager import LiteLlmManager
|
||||
from storage.org_member_store import OrgMemberStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class OrgMemberFinancialService:
|
||||
|
||||
@@ -21,7 +21,7 @@ from storage.org_member_store import OrgMemberStore
|
||||
from storage.role_store import RoleStore
|
||||
from storage.user_store import UserStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class OrgMemberService:
|
||||
|
||||
@@ -19,7 +19,7 @@ from storage.user_app_settings_store import UserAppSettingsStore
|
||||
|
||||
from openhands.app_server.services.injector import Injector, InjectorState
|
||||
from openhands.app_server.user.user_context import UserContext
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
from fastapi import HTTPException, Request, status
|
||||
from storage.redis import get_redis_client_async
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Rate limiting constants
|
||||
RATE_LIMIT_USER_SECONDS = 120 # 2 minutes per user_id
|
||||
|
||||
@@ -22,7 +22,7 @@ from sqlalchemy.orm import Mapped, mapped_column
|
||||
from storage.base import Base
|
||||
|
||||
from openhands.app_server.config import depends_db_session
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class StoredVerifiedModel(Base):
|
||||
|
||||
@@ -11,7 +11,7 @@ from storage.api_key import ApiKey
|
||||
from storage.database import a_session_maker
|
||||
from storage.user_store import UserStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -11,7 +11,7 @@ from storage.auth_tokens import AuthTokens
|
||||
from storage.database import a_session_maker
|
||||
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Time buffer (in seconds) before actual expiration to consider token expired
|
||||
# This ensures tokens are refreshed before they actually expire. The
|
||||
|
||||
@@ -8,7 +8,7 @@ from sqlalchemy.dialects.postgresql import insert
|
||||
from storage.database import a_session_maker
|
||||
from storage.gitlab_webhook import GitlabWebhook
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -9,7 +9,7 @@ from storage.jira_dc_conversation import JiraDcConversation
|
||||
from storage.jira_dc_user import JiraDcUser
|
||||
from storage.jira_dc_workspace import JiraDcWorkspace
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -9,7 +9,7 @@ from storage.jira_conversation import JiraConversation
|
||||
from storage.jira_user import JiraUser
|
||||
from storage.jira_workspace import JiraWorkspace
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -9,7 +9,7 @@ from storage.linear_conversation import LinearConversation
|
||||
from storage.linear_user import LinearUser
|
||||
from storage.linear_workspace import LinearWorkspace
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -6,8 +6,8 @@ from sqlalchemy import select
|
||||
from storage.database import a_session_maker
|
||||
from storage.stored_offline_token import StoredOfflineToken
|
||||
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.core.config.openhands_config import OpenHandsConfig
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -7,7 +7,7 @@ from storage.database import a_session_maker
|
||||
from storage.openhands_pr import OpenhandsPR
|
||||
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class OpenhandsPRStore:
|
||||
|
||||
@@ -10,7 +10,7 @@ from sqlalchemy import and_, select
|
||||
from storage.database import a_session_maker
|
||||
from storage.org_git_claim import OrgGitClaim
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class OrgGitClaimStore:
|
||||
|
||||
@@ -13,7 +13,7 @@ from sqlalchemy.orm import joinedload
|
||||
from storage.database import a_session_maker
|
||||
from storage.org_invitation import OrgInvitation
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Invitation token configuration
|
||||
INVITATION_TOKEN_PREFIX = 'inv-'
|
||||
|
||||
@@ -25,7 +25,7 @@ from storage.role_store import RoleStore
|
||||
from storage.user_store import UserStore
|
||||
|
||||
from openhands.app_server.settings.settings_models import Settings
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk.settings import AgentSettings, ConversationSettings
|
||||
|
||||
|
||||
|
||||
@@ -27,7 +27,7 @@ from storage.user_settings import UserSettings
|
||||
from openhands.app_server.settings.settings_models import Settings
|
||||
from openhands.app_server.utils.jsonpatch_compat import deep_merge
|
||||
from openhands.app_server.utils.llm import is_openhands_model
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.sdk.settings import AgentSettings, ConversationSettings
|
||||
|
||||
_ORG_SETTINGS_EXCLUDED_FIELDS = {
|
||||
|
||||
@@ -14,7 +14,7 @@ from storage.database import a_session_maker
|
||||
from storage.proactive_convos import ProactiveConversation
|
||||
|
||||
from openhands.app_server.integrations.service_types import ProviderType
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -12,8 +12,8 @@ from storage.user_store import UserStore
|
||||
|
||||
from openhands.app_server.secrets.secrets_models import Secrets
|
||||
from openhands.app_server.secrets.secrets_store import SecretsStore
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.core.config.openhands_config import OpenHandsConfig
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -3,7 +3,7 @@ import asyncio # noqa: I001
|
||||
# This must be before the import of storage
|
||||
# to set up logging and prevent alembic from
|
||||
# running its mouth.
|
||||
from openhands.core.logger import openhands_logger
|
||||
from openhands.app_server.utils.logger import openhands_logger
|
||||
|
||||
from storage.proactive_conversation_store import (
|
||||
ProactiveConversationStore,
|
||||
|
||||
@@ -4,7 +4,7 @@ from integrations.github.data_collector import GitHubDataCollector
|
||||
from storage.openhands_pr import OpenhandsPR
|
||||
from storage.openhands_pr_store import OpenhandsPRStore
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
PROCESS_AMOUNT = 50
|
||||
MAX_RETRIES = 3
|
||||
|
||||
@@ -16,7 +16,7 @@ from storage.gitlab_webhook import GitlabWebhook, WebhookStatus
|
||||
from storage.gitlab_webhook_store import GitlabWebhookStore
|
||||
|
||||
from openhands.app_server.integrations.gitlab.gitlab_service import GitLabServiceImpl
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
if TYPE_CHECKING:
|
||||
from integrations.gitlab.gitlab_service import SaaSGitLabService
|
||||
|
||||
@@ -43,7 +43,7 @@ from tenacity import (
|
||||
wait_exponential,
|
||||
)
|
||||
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
# Get Keycloak configuration from environment variables
|
||||
KEYCLOAK_SERVER_URL = os.environ.get('KEYCLOAK_SERVER_URL', '')
|
||||
@@ -52,7 +52,7 @@ KEYCLOAK_CLIENT_ID = os.environ.get('KEYCLOAK_CLIENT_ID', '')
|
||||
KEYCLOAK_CLIENT_SECRET = os.environ.get('KEYCLOAK_CLIENT_SECRET', '')
|
||||
KEYCLOAK_ADMIN_PASSWORD = os.environ.get('KEYCLOAK_ADMIN_PASSWORD', '')
|
||||
|
||||
# Logger is imported from openhands.core.logger
|
||||
# Logger is imported from openhands.app_server.utils.logger
|
||||
|
||||
# Get configuration from environment variables
|
||||
RESEND_API_KEY = os.environ.get('RESEND_API_KEY')
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
from server.auth.sheets_client import GoogleSheetsClient
|
||||
|
||||
from openhands.core.logger import openhands_logger
|
||||
from openhands.app_server.utils.logger import openhands_logger
|
||||
|
||||
|
||||
def test_import():
|
||||
|
||||
@@ -8,7 +8,7 @@ import pytest
|
||||
from freezegun import freeze_time
|
||||
from server.logger import format_stack, setup_json_logger
|
||||
|
||||
from openhands.core.logger import openhands_logger
|
||||
from openhands.app_server.utils.logger import openhands_logger
|
||||
|
||||
FROZEN_TIMESTAMP = '2024-01-15T10:30:00+00:00'
|
||||
# datetime.now().isoformat() doesn't include timezone info
|
||||
|
||||
@@ -5,7 +5,7 @@ import threading
|
||||
from pydantic import model_validator
|
||||
|
||||
from openhands.app_server.file_store.files import FileStore
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class LocalFileStore(FileStore):
|
||||
|
||||
@@ -3,7 +3,7 @@ import os
|
||||
from pydantic import Field
|
||||
|
||||
from openhands.app_server.file_store.files import FileStore
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class InMemoryFileStore(FileStore):
|
||||
|
||||
@@ -6,7 +6,7 @@ from openhands.app_server.integrations.azure_devops.service.base import (
|
||||
AzureDevOpsMixinBase,
|
||||
)
|
||||
from openhands.app_server.integrations.service_types import Comment, RequestMethod
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class AzureDevOpsPRsMixin(AzureDevOpsMixinBase):
|
||||
|
||||
@@ -4,7 +4,7 @@ from openhands.app_server.integrations.azure_devops.service.base import (
|
||||
AzureDevOpsMixinBase,
|
||||
)
|
||||
from openhands.app_server.integrations.service_types import Comment
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class AzureDevOpsResolverMixin(AzureDevOpsMixinBase):
|
||||
|
||||
@@ -6,7 +6,7 @@ from openhands.app_server.integrations.azure_devops.service.base import (
|
||||
AzureDevOpsMixinBase,
|
||||
)
|
||||
from openhands.app_server.integrations.service_types import Comment, RequestMethod
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class AzureDevOpsWorkItemsMixin(AzureDevOpsMixinBase):
|
||||
|
||||
@@ -14,7 +14,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
User,
|
||||
)
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class BitBucketMixinBase(BaseGitService, HTTPClient):
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
from openhands.app_server.integrations.bitbucket.service.base import BitBucketMixinBase
|
||||
from openhands.app_server.integrations.service_types import RequestMethod
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class BitBucketPRsMixin(BitBucketMixinBase):
|
||||
|
||||
@@ -15,7 +15,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
User,
|
||||
)
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class BitbucketDCMixinBase(BaseGitService, HTTPClient):
|
||||
|
||||
@@ -4,7 +4,7 @@ from openhands.app_server.integrations.bitbucket_data_center.service.base import
|
||||
BitbucketDCMixinBase,
|
||||
)
|
||||
from openhands.app_server.integrations.service_types import RequestMethod
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class BitbucketDCPRsMixin(BitbucketDCMixinBase):
|
||||
|
||||
@@ -18,7 +18,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
User,
|
||||
)
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class ForgejoMixinBase(BaseGitService, HTTPClient):
|
||||
|
||||
@@ -7,7 +7,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
RequestMethod,
|
||||
UnknownException,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class ForgejoPRsMixin(ForgejoMixinBase):
|
||||
|
||||
@@ -12,7 +12,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
User,
|
||||
)
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GitHubMixinBase(BaseGitService, HTTPClient):
|
||||
|
||||
@@ -6,7 +6,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
Branch,
|
||||
PaginatedBranchesResponse,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GitHubBranchesMixin(GitHubMixinBase):
|
||||
|
||||
@@ -8,7 +8,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
SuggestedTask,
|
||||
TaskType,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GitHubFeaturesMixin(GitHubMixinBase):
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
from openhands.app_server.integrations.github.service.base import GitHubMixinBase
|
||||
from openhands.app_server.integrations.service_types import RequestMethod
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GitHubPRsMixin(GitHubMixinBase):
|
||||
|
||||
@@ -6,7 +6,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
ProviderType,
|
||||
Repository,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import AppMode
|
||||
|
||||
|
||||
|
||||
@@ -8,7 +8,7 @@ from openhands.app_server.integrations.github.queries import (
|
||||
)
|
||||
from openhands.app_server.integrations.github.service.base import GitHubMixinBase
|
||||
from openhands.app_server.integrations.service_types import Comment
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GitHubResolverMixin(GitHubMixinBase):
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
from openhands.app_server.integrations.gitlab.service.base import GitLabMixinBase
|
||||
from openhands.app_server.integrations.service_types import RequestMethod
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class GitLabPRsMixin(GitLabMixinBase):
|
||||
|
||||
@@ -4,7 +4,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
ProviderType,
|
||||
Repository,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import AppMode
|
||||
|
||||
|
||||
|
||||
@@ -14,7 +14,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
ResourceNotFoundError,
|
||||
UnknownException,
|
||||
)
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
|
||||
|
||||
class HTTPClient(ABC):
|
||||
|
||||
@@ -41,7 +41,7 @@ from openhands.app_server.integrations.service_types import (
|
||||
User,
|
||||
)
|
||||
from openhands.app_server.utils.http_session import httpx_verify_option
|
||||
from openhands.core.logger import openhands_logger as logger
|
||||
from openhands.app_server.utils.logger import openhands_logger as logger
|
||||
from openhands.server.types import AppMode
|
||||
|
||||
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user