Add eveonline integration

.strict-typing

@@ -199,6 +199,7 @@ homeassistant.components.enphase_envoy.*
 homeassistant.components.eq3btsmart.*
 homeassistant.components.esphome.*
 homeassistant.components.event.*
+homeassistant.components.eveonline.*
 homeassistant.components.evil_genius_labs.*
 homeassistant.components.evohome.*
 homeassistant.components.faa_delays.*

homeassistant/components/eveonline/__init__.py

@@ -0,0 +1,55 @@
+"""The Eve Online integration."""
+
+from __future__ import annotations
+
+from eveonline import EveOnlineClient
+
+from homeassistant.const import Platform
+from homeassistant.core import HomeAssistant
+from homeassistant.exceptions import ConfigEntryNotReady
+from homeassistant.helpers import aiohttp_client
+from homeassistant.helpers.config_entry_oauth2_flow import (
+    ImplementationUnavailableError,
+    OAuth2Session,
+    async_get_config_entry_implementation,
+)
+
+from .api import AsyncConfigEntryAuth
+from .const import CONF_CHARACTER_ID, CONF_CHARACTER_NAME, DOMAIN
+from .coordinator import EveOnlineConfigEntry, EveOnlineCoordinator
+
+PLATFORMS: list[Platform] = [Platform.SENSOR]
+
+
+async def async_setup_entry(hass: HomeAssistant, entry: EveOnlineConfigEntry) -> bool:
+    """Set up Eve Online from a config entry."""
+    try:
+        implementation = await async_get_config_entry_implementation(hass, entry)
+    except ImplementationUnavailableError as err:
+        raise ConfigEntryNotReady(
+            translation_domain=DOMAIN,
+            translation_key="oauth2_implementation_unavailable",
+        ) from err
+
+    session = OAuth2Session(hass, entry, implementation)
+
+    auth = AsyncConfigEntryAuth(aiohttp_client.async_get_clientsession(hass), session)
+    client = EveOnlineClient(auth=auth)
+
+    character_id: int = entry.data[CONF_CHARACTER_ID]
+    character_name: str = entry.data[CONF_CHARACTER_NAME]
+
+    coordinator = EveOnlineCoordinator(
+        hass, entry, client, character_id, character_name
+    )
+    await coordinator.async_config_entry_first_refresh()
+
+    entry.runtime_data = coordinator
+
+    await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)
+    return True
+
+
+async def async_unload_entry(hass: HomeAssistant, entry: EveOnlineConfigEntry) -> bool:
+    """Unload a config entry."""
+    return await hass.config_entries.async_unload_platforms(entry, PLATFORMS)

homeassistant/components/eveonline/api.py

@@ -0,0 +1,48 @@
+"""API helpers for the Eve Online integration."""
+
+from __future__ import annotations
+
+from typing import cast
+
+from aiohttp import ClientError, ClientSession
+from eveonline.auth import AbstractAuth
+
+from homeassistant.exceptions import (
+    ConfigEntryAuthFailed,
+    ConfigEntryNotReady,
+    OAuth2TokenRequestReauthError,
+    OAuth2TokenRequestTransientError,
+)
+from homeassistant.helpers.config_entry_oauth2_flow import OAuth2Session
+
+from .const import DOMAIN
+
+
+class AsyncConfigEntryAuth(AbstractAuth):
+    """Provide Eve Online authentication tied to an OAuth2 based config entry."""
+
+    def __init__(
+        self,
+        websession: ClientSession,
+        oauth_session: OAuth2Session,
+    ) -> None:
+        """Initialize Eve Online auth."""
+        super().__init__(websession)
+        self._oauth_session = oauth_session
+
+    async def async_get_access_token(self) -> str:
+        """Return a valid access token."""
+        try:
+            await self._oauth_session.async_ensure_token_valid()
+        except OAuth2TokenRequestReauthError as err:
+            raise ConfigEntryAuthFailed(
+                translation_domain=DOMAIN,
+                translation_key="authentication_failed",
+            ) from err
+        except (OAuth2TokenRequestTransientError, ClientError) as err:
+            raise ConfigEntryNotReady(
+                translation_domain=DOMAIN,
+                translation_key="token_refresh_failed",
+                translation_placeholders={"error": str(err)},
+            ) from err
+        return cast(str, self._oauth_session.token["access_token"])

homeassistant/components/eveonline/application_credentials.py

@@ -0,0 +1,14 @@
+"""Application credentials for the Eve Online integration."""
+
+from homeassistant.components.application_credentials import AuthorizationServer
+from homeassistant.core import HomeAssistant
+
+from .const import OAUTH2_AUTHORIZE, OAUTH2_TOKEN
+
+
+async def async_get_authorization_server(hass: HomeAssistant) -> AuthorizationServer:
+    """Return the Eve Online authorization server."""
+    return AuthorizationServer(
+        authorize_url=OAUTH2_AUTHORIZE,
+        token_url=OAUTH2_TOKEN,
+    )

homeassistant/components/eveonline/config_flow.py

@@ -0,0 +1,74 @@
+"""Config flow for the Eve Online integration."""
+
+from __future__ import annotations
+
+import logging
+from typing import Any
+
+import jwt
+
+from homeassistant.config_entries import ConfigFlowResult
+from homeassistant.helpers.config_entry_oauth2_flow import AbstractOAuth2FlowHandler
+
+from .const import CONF_CHARACTER_ID, CONF_CHARACTER_NAME, DOMAIN, SCOPES
+
+_LOGGER = logging.getLogger(__name__)
+
+
+class OAuth2FlowHandler(AbstractOAuth2FlowHandler, domain=DOMAIN):
+    """Handle OAuth2 config flow for Eve Online.
+
+    Each config entry represents one authenticated character.
+    Multiple characters can be added as separate entries.
+    """
+
+    DOMAIN = DOMAIN
+
+    @property
+    def logger(self) -> logging.Logger:
+        """Return logger."""
+        return _LOGGER
+
+    @property
+    def extra_authorize_data(self) -> dict[str, Any]:
+        """Extra data to include in the authorize URL."""
+        return {"scope": " ".join(SCOPES)}
+
+    async def async_oauth_create_entry(self, data: dict[str, Any]) -> ConfigFlowResult:
+        """Create an entry for the flow.
+
+        Decode the Eve SSO JWT access token to extract character_id and
+        character_name, then create a config entry for that character.
+        """
+        try:
+            token = data["token"]["access_token"]
+            character_info = _decode_eve_jwt(token)
+        except ValueError, KeyError, jwt.DecodeError:
+            return self.async_abort(reason="oauth_error")
+
+        character_id = character_info[CONF_CHARACTER_ID]
+        character_name = character_info[CONF_CHARACTER_NAME]
+
+        await self.async_set_unique_id(str(character_id))
+        self._abort_if_unique_id_configured()
+
+        data[CONF_CHARACTER_ID] = character_id
+        data[CONF_CHARACTER_NAME] = character_name
+
+        return self.async_create_entry(
+            title=character_name,
+            data=data,
+        )
+
+
+def _decode_eve_jwt(token: str) -> dict[str, Any]:
+    """Decode an Eve SSO JWT to extract character info."""
+    decoded = jwt.decode(token, options={"verify_signature": False})
+    sub = decoded.get("sub", "")
+    sub_parts = sub.split(":")
+    if len(sub_parts) != 3 or sub_parts[0] != "CHARACTER" or sub_parts[1] != "EVE":
+        raise ValueError(sub)
+    return {
+        CONF_CHARACTER_ID: int(sub_parts[2]),
+        CONF_CHARACTER_NAME: decoded.get("name", "Unknown"),
+    }

homeassistant/components/eveonline/const.py

@@ -0,0 +1,24 @@
+"""Constants for the Eve Online integration."""
+
+from typing import Final
+
+DOMAIN: Final = "eveonline"
+
+CONF_CHARACTER_ID: Final = "character_id"
+CONF_CHARACTER_NAME: Final = "character_name"
+
+OAUTH2_AUTHORIZE: Final = "https://login.eveonline.com/v2/oauth/authorize"
+OAUTH2_TOKEN: Final = "https://login.eveonline.com/v2/oauth/token"
+
+SCOPES: Final[list[str]] = [
+    "esi-characters.read_fatigue.v1",
+    "esi-industry.read_character_jobs.v1",
+    "esi-location.read_location.v1",
+    "esi-location.read_online.v1",
+    "esi-location.read_ship_type.v1",
+    "esi-mail.read_mail.v1",
+    "esi-markets.read_character_orders.v1",
+    "esi-skills.read_skillqueue.v1",
+    "esi-skills.read_skills.v1",
+    "esi-wallet.read_character_wallet.v1",
+]