Compare commits
153 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 081f277b92 | |||
| 28b86e19e1 | |||
| e863677428 | |||
| 3f6da60c0d | |||
| 8ac0ef103c | |||
| 6a0132a25c | |||
| 60c46aa121 | |||
| 1caad401f6 | |||
| 5684c3d5f1 | |||
| f3863ee227 | |||
| e867e82a2d | |||
| 2770e56219 | |||
| 25b9c79114 | |||
| 2c50765d66 | |||
| 1837ed4a13 | |||
| c4f0f94a6f | |||
| 1dbffcc27c | |||
| a2d123abbf | |||
| 0e6088070e | |||
| dc32010bf9 | |||
| 3ed6a1a18c | |||
| 8ff5ab2e31 | |||
| 2a0dc9d66c | |||
| fbfc2e3a6e | |||
| 19a5c0fecb | |||
| c0ec7b1797 | |||
| 25f966853a | |||
| 3edeab514b | |||
| d713bf779f | |||
| 2b78feeadf | |||
| a940c68e9e | |||
| 6c3cdcde61 | |||
| 1fc274bf7c | |||
| 4ff94bc185 | |||
| b95b3f5626 | |||
| 30d47b775b | |||
| bedf6b6bf8 | |||
| e2f8b4625a | |||
| bb340108e2 | |||
| a617ca6709 | |||
| 7789430d4a | |||
| 4e8116265d | |||
| 06796cf57b | |||
| dbcac9df86 | |||
| 6ca193580d | |||
| 3773b07650 | |||
| 24dcc92c00 | |||
| 596491f885 | |||
| 97c9f01a0a | |||
| c39a948c59 | |||
| 4fd0a6ec48 | |||
| b84ab944b3 | |||
| ce4bd4f4f1 | |||
| 2dce858a51 | |||
| 2c8da4a049 | |||
| 692f0b47da | |||
| 106872063a | |||
| 597d1556ff | |||
| c4d9f7b393 | |||
| f15d932d54 | |||
| ec60211339 | |||
| 1305656d10 | |||
| 1c8a83effc | |||
| 066d1ff2a4 | |||
| d1a8526d2d | |||
| f60b3a8730 | |||
| b5e98898e0 | |||
| 236099e562 | |||
| 08a59ec56e | |||
| 5cf8e6d40f | |||
| 8b21d070f3 | |||
| 7219f82e7f | |||
| c91a4ecba2 | |||
| 2b0bfb4caa | |||
| e10b23a44a | |||
| 6d273cc182 | |||
| 35839d9c65 | |||
| 6f0f588b03 | |||
| 5b56b59ae8 | |||
| 8ab487f00a | |||
| 0ea9319ba4 | |||
| 46508f1c34 | |||
| 12f4aec1f7 | |||
| 225442f549 | |||
| 714ced5d2c | |||
| 64835b719f | |||
| acb01b9768 | |||
| bf29faab04 | |||
| adb117672c | |||
| 8cee9e5e4d | |||
| 77b4522e3c | |||
| bae4d0b84f | |||
| c022b90fb5 | |||
| 97c2672119 | |||
| 47e1524aef | |||
| 0bc824fe4a | |||
| c500234e1d | |||
| d27782ea9c | |||
| 6088d0a935 | |||
| fbdc8aed0f | |||
| 3723c403c7 | |||
| 95a7a0689b | |||
| 9d04aeaa58 | |||
| f65819ffab | |||
| ad9c4ea421 | |||
| e0cecfcc68 | |||
| fbac0ac57f | |||
| daa51cd59c | |||
| 3a88d2c402 | |||
| 9ff89d18f3 | |||
| 93ace71a12 | |||
| 30a4daa884 | |||
| b40e509362 | |||
| d04bf2a3f1 | |||
| c490c7856c | |||
| bd274faf88 | |||
| 638ac9a7ec | |||
| 3eb6d24439 | |||
| 013b0baa83 | |||
| b4b6b2b987 | |||
| d226edaac8 | |||
| 0e081e8cce | |||
| bd50c487b1 | |||
| 58e62b864e | |||
| 41fc0da76c | |||
| ce52920c6d | |||
| 5c47479f45 | |||
| 80eefabbc2 | |||
| 0339ad4ecb | |||
| 3f07c09c36 | |||
| dd634fca32 | |||
| 2aebc45707 | |||
| 4f3a7fb436 | |||
| 8e01de3440 | |||
| b7ed65b49d | |||
| 15349d93a2 | |||
| 124693e545 | |||
| 3aee3886b1 | |||
| 199bda2e0f | |||
| 8d1ed31431 | |||
| c36321db43 | |||
| 806524ad33 | |||
| 2da0cfe07d | |||
| 603277d6f5 | |||
| a1bdf9dd40 | |||
| 2746c5295a | |||
| 7bac73a37f | |||
| 96cdf234db | |||
| 184b8f9a1d | |||
| 936b5d9e7f | |||
| 04ba73a29c | |||
| 5ded45c3f8 | |||
| 7b748a0f0b |
95
CHANGELOG.md
Normal file
95
CHANGELOG.md
Normal file
@@ -0,0 +1,95 @@
|
|||||||
|
# Changelog
|
||||||
|
|
||||||
|
All notable changes to this repository will be documented in this file.
|
||||||
|
|
||||||
|
Sections:
|
||||||
|
- Added
|
||||||
|
- Changed
|
||||||
|
- Fixed
|
||||||
|
- Removed
|
||||||
|
- Security
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## [0.4.0] - 2026-01-15
|
||||||
|
|
||||||
|
### Added
|
||||||
|
- Repository detail view (second page) in the Store UI.
|
||||||
|
- README rendering using Home Assistant's `ha-markdown` element.
|
||||||
|
- Floating action buttons (FAB):
|
||||||
|
- Open repository
|
||||||
|
- Reload README
|
||||||
|
- Install (coming soon)
|
||||||
|
- Update (coming soon)
|
||||||
|
- Search field and category filter on the repository list page.
|
||||||
|
- New authenticated API endpoint:
|
||||||
|
- `GET /api/bcs/readme?repo_id=<id>` returns README markdown (best-effort).
|
||||||
|
|
||||||
|
### Changed
|
||||||
|
- Repository cards are now clickable to open the detail view.
|
||||||
|
|
||||||
|
## [0.3.2] - 2026-01-15
|
||||||
|
|
||||||
|
### Added
|
||||||
|
- Metadata resolver:
|
||||||
|
- Reads `bcs.yaml` (preferred), then `hacs.yaml`, then `hacs.json` from repository root.
|
||||||
|
- Extracts `name`, `description`, `category`, `author`, `maintainer` (best-effort).
|
||||||
|
- UI now prefers metadata description over provider description.
|
||||||
|
- Provider repository name is now only used as a fallback if no metadata name is provided.
|
||||||
|
|
||||||
|
### Changed
|
||||||
|
- Repo display name priority:
|
||||||
|
1) metadata (`bcs.yaml` / `hacs.*`)
|
||||||
|
2) store index name (store.yaml)
|
||||||
|
3) provider repo name
|
||||||
|
4) repository URL
|
||||||
|
|
||||||
|
## [0.3.1] - 2026-01-15
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
- Panel header version is now derived from `manifest.json` via backend API (no more hardcoded version strings).
|
||||||
|
- Mobile navigation/header visibility improved by explicitly disabling iframe embedding for the custom panel.
|
||||||
|
- When adding a custom repository without a display name, the name is now fetched from the git provider (GitHub/Gitea) and shown automatically.
|
||||||
|
|
||||||
|
## [0.3.0] - 2026-01-15
|
||||||
|
|
||||||
|
### Added
|
||||||
|
- Repository enrichment for the Store UI:
|
||||||
|
- GitHub: fetch owner and description via GitHub REST API.
|
||||||
|
- Gitea: fetch owner and description via Gitea REST API (`/api/v1`).
|
||||||
|
- Provider detection for GitHub/GitLab/Gitea (best-effort).
|
||||||
|
- Automatic UI description line populated from provider data (when available).
|
||||||
|
|
||||||
|
### Changed
|
||||||
|
- Panel module URL cache-busting updated to avoid stale frontend assets.
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
- Store "Refresh" now triggers immediate backend refresh (from 0.2.0).
|
||||||
|
- Avoided circular imports by using TYPE_CHECKING for type references.
|
||||||
|
|
||||||
|
### Notes
|
||||||
|
- Installation/README details view/update entities will be added in later versions.
|
||||||
|
|
||||||
|
|
||||||
|
## [0.2.0] - 2026-01-15
|
||||||
|
|
||||||
|
### Added
|
||||||
|
- Foundation architecture for BCS (Bahmcloud Component Store) inside a Home Assistant custom component.
|
||||||
|
- Custom panel (no iframe) using `hass.callApi()` to avoid authentication issues.
|
||||||
|
- Store index loader (`store.yaml`) with periodic refresh (data only).
|
||||||
|
- Manual repository management:
|
||||||
|
- Add repository
|
||||||
|
- List repositories
|
||||||
|
- Remove repository
|
||||||
|
Persisted via Home Assistant storage (`.storage/bcs_store`).
|
||||||
|
- Public static asset endpoint for panel JS (`/api/bahmcloud_store_static/...`) without auth (required for HA custom panels).
|
||||||
|
- Initial API namespace:
|
||||||
|
- `GET /api/bcs` list merged repositories (index + custom)
|
||||||
|
- `POST /api/bcs` add custom repository
|
||||||
|
- `DELETE /api/bcs/custom_repo` remove custom repository
|
||||||
|
|
||||||
|
### Changed
|
||||||
|
- Store API/UI terminology standardized to "BCS" (Bahmcloud Component Store), while integration domain remains `bahmcloud_store` for compatibility.
|
||||||
|
|
||||||
|
### Notes
|
||||||
|
- Installation, README rendering, provider enrichment (GitHub/Gitea/GitLab), and Update entities will be implemented in later versions.
|
||||||
@@ -1,3 +1,3 @@
|
|||||||
# bahmcloud_store
|
# bahmcloud_store
|
||||||
|
|
||||||
Bahmcloud Store für installing costum_components to Homeassistant
|
Bahmcloud Store for installing costum_components to Homeassistant
|
||||||
@@ -5,11 +5,11 @@ from datetime import timedelta
|
|||||||
|
|
||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.const import Platform
|
from homeassistant.const import Platform
|
||||||
from homeassistant.helpers.event import async_track_time_interval
|
|
||||||
from homeassistant.helpers.discovery import async_load_platform
|
from homeassistant.helpers.discovery import async_load_platform
|
||||||
|
from homeassistant.helpers.event import async_track_time_interval
|
||||||
from homeassistant.components.panel_custom import async_register_panel
|
from homeassistant.components.panel_custom import async_register_panel
|
||||||
|
|
||||||
from .store import BahmcloudStore, StoreConfig, StoreError
|
from .core import BCSCore, BCSConfig, BCSError
|
||||||
|
|
||||||
_LOGGER = logging.getLogger(__name__)
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
@@ -23,43 +23,37 @@ async def async_setup(hass: HomeAssistant, config: dict) -> bool:
|
|||||||
cfg = config.get(DOMAIN, {})
|
cfg = config.get(DOMAIN, {})
|
||||||
store_url = cfg.get(CONF_STORE_URL, DEFAULT_STORE_URL)
|
store_url = cfg.get(CONF_STORE_URL, DEFAULT_STORE_URL)
|
||||||
|
|
||||||
store = BahmcloudStore(hass, StoreConfig(store_url=store_url))
|
core = BCSCore(hass, BCSConfig(store_url=store_url))
|
||||||
hass.data[DOMAIN] = store
|
hass.data[DOMAIN] = core
|
||||||
|
|
||||||
# HTTP Views (Panel static + JSON API)
|
await core.register_http_views()
|
||||||
await store.register_http_views()
|
|
||||||
|
|
||||||
# Sidebar Panel (Custom Panel + JS module)
|
# RESTORE: keep the module_url pattern that worked for you
|
||||||
await async_register_panel(
|
await async_register_panel(
|
||||||
hass,
|
hass,
|
||||||
frontend_url_path="bahmcloud-store",
|
frontend_url_path="bahmcloud-store",
|
||||||
webcomponent_name="bahmcloud-store-panel",
|
webcomponent_name="bahmcloud-store-panel",
|
||||||
module_url="/api/bahmcloud_store_static/panel.js",
|
module_url="/api/bahmcloud_store_static/panel.js?v=42",
|
||||||
sidebar_title="Bahmcloud Store",
|
sidebar_title="Bahmcloud Store",
|
||||||
sidebar_icon="mdi:store",
|
sidebar_icon="mdi:store",
|
||||||
require_admin=True,
|
require_admin=True,
|
||||||
config={},
|
config={},
|
||||||
)
|
)
|
||||||
|
|
||||||
# Initialer Index-Load
|
|
||||||
try:
|
try:
|
||||||
await store.refresh()
|
await core.refresh()
|
||||||
except StoreError as e:
|
except BCSError as e:
|
||||||
_LOGGER.error("Initial store refresh failed: %s", e)
|
_LOGGER.error("Initial refresh failed: %s", e)
|
||||||
|
|
||||||
# Nur Liste + Latest-Versionen regelmäßig aktualisieren (keine Auto-Install)
|
|
||||||
async def periodic(_now) -> None:
|
async def periodic(_now) -> None:
|
||||||
try:
|
try:
|
||||||
await store.refresh()
|
await core.refresh()
|
||||||
store.signal_entities_updated()
|
core.signal_updated()
|
||||||
except StoreError as e:
|
except BCSError as e:
|
||||||
_LOGGER.warning("Periodic refresh failed: %s", e)
|
_LOGGER.warning("Periodic refresh failed: %s", e)
|
||||||
|
|
||||||
# Falls store.yaml refresh_seconds enthält, nutze das, sonst 300s
|
interval = timedelta(seconds=int(core.refresh_seconds or 300))
|
||||||
interval_seconds = store.refresh_seconds if getattr(store, "refresh_seconds", None) else 300
|
async_track_time_interval(hass, periodic, interval)
|
||||||
async_track_time_interval(hass, periodic, timedelta(seconds=int(interval_seconds)))
|
|
||||||
|
|
||||||
# Update platform laden (damit Updates in Settings erscheinen)
|
|
||||||
await async_load_platform(hass, Platform.UPDATE, DOMAIN, {}, config)
|
await async_load_platform(hass, Platform.UPDATE, DOMAIN, {}, config)
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|||||||
361
custom_components/bahmcloud_store/core.py
Normal file
361
custom_components/bahmcloud_store/core.py
Normal file
@@ -0,0 +1,361 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import asyncio
|
||||||
|
import json
|
||||||
|
import logging
|
||||||
|
from dataclasses import dataclass
|
||||||
|
from pathlib import Path
|
||||||
|
from typing import Any
|
||||||
|
from urllib.parse import urlparse
|
||||||
|
|
||||||
|
from homeassistant.core import HomeAssistant
|
||||||
|
from homeassistant.helpers.aiohttp_client import async_get_clientsession
|
||||||
|
from homeassistant.util import yaml as ha_yaml
|
||||||
|
|
||||||
|
from .storage import BCSStorage, CustomRepo
|
||||||
|
from .views import StaticAssetsView, BCSApiView, BCSReadmeView
|
||||||
|
from .custom_repo_view import BCSCustomRepoView
|
||||||
|
from .providers import fetch_repo_info, detect_provider, RepoInfo
|
||||||
|
from .metadata import fetch_repo_metadata, RepoMetadata
|
||||||
|
|
||||||
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
DOMAIN = "bahmcloud_store"
|
||||||
|
|
||||||
|
|
||||||
|
class BCSError(Exception):
|
||||||
|
"""BCS core error."""
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class BCSConfig:
|
||||||
|
store_url: str
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class RepoItem:
|
||||||
|
id: str
|
||||||
|
name: str
|
||||||
|
url: str
|
||||||
|
source: str # "index" | "custom"
|
||||||
|
|
||||||
|
owner: str | None = None
|
||||||
|
provider: str | None = None
|
||||||
|
provider_repo_name: str | None = None
|
||||||
|
provider_description: str | None = None
|
||||||
|
default_branch: str | None = None
|
||||||
|
|
||||||
|
latest_version: str | None = None
|
||||||
|
latest_version_source: str | None = None # "release" | "tag" | None
|
||||||
|
|
||||||
|
meta_source: str | None = None
|
||||||
|
meta_name: str | None = None
|
||||||
|
meta_description: str | None = None
|
||||||
|
meta_category: str | None = None
|
||||||
|
meta_author: str | None = None
|
||||||
|
meta_maintainer: str | None = None
|
||||||
|
|
||||||
|
|
||||||
|
class BCSCore:
|
||||||
|
def __init__(self, hass: HomeAssistant, config: BCSConfig) -> None:
|
||||||
|
self.hass = hass
|
||||||
|
self.config = config
|
||||||
|
self.storage = BCSStorage(hass)
|
||||||
|
|
||||||
|
self.refresh_seconds: int = 300
|
||||||
|
self.repos: dict[str, RepoItem] = {}
|
||||||
|
self._listeners: list[callable] = []
|
||||||
|
|
||||||
|
self.version: str = self._read_manifest_version()
|
||||||
|
|
||||||
|
def _read_manifest_version(self) -> str:
|
||||||
|
try:
|
||||||
|
manifest_path = Path(__file__).resolve().parent / "manifest.json"
|
||||||
|
data = json.loads(manifest_path.read_text(encoding="utf-8"))
|
||||||
|
v = data.get("version")
|
||||||
|
return str(v) if v else "unknown"
|
||||||
|
except Exception:
|
||||||
|
return "unknown"
|
||||||
|
|
||||||
|
def add_listener(self, cb) -> None:
|
||||||
|
self._listeners.append(cb)
|
||||||
|
|
||||||
|
def signal_updated(self) -> None:
|
||||||
|
for cb in list(self._listeners):
|
||||||
|
try:
|
||||||
|
cb()
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
|
||||||
|
async def register_http_views(self) -> None:
|
||||||
|
self.hass.http.register_view(StaticAssetsView())
|
||||||
|
self.hass.http.register_view(BCSApiView(self))
|
||||||
|
self.hass.http.register_view(BCSReadmeView(self))
|
||||||
|
self.hass.http.register_view(BCSCustomRepoView(self))
|
||||||
|
|
||||||
|
def get_repo(self, repo_id: str) -> RepoItem | None:
|
||||||
|
return self.repos.get(repo_id)
|
||||||
|
|
||||||
|
async def refresh(self) -> None:
|
||||||
|
index_repos, refresh_seconds = await self._load_index_repos()
|
||||||
|
self.refresh_seconds = refresh_seconds
|
||||||
|
|
||||||
|
custom_repos = await self.storage.list_custom_repos()
|
||||||
|
|
||||||
|
merged: dict[str, RepoItem] = {}
|
||||||
|
|
||||||
|
for item in index_repos:
|
||||||
|
merged[item.id] = item
|
||||||
|
|
||||||
|
for c in custom_repos:
|
||||||
|
merged[c.id] = RepoItem(
|
||||||
|
id=c.id,
|
||||||
|
name=(c.name or c.url),
|
||||||
|
url=c.url,
|
||||||
|
source="custom",
|
||||||
|
)
|
||||||
|
|
||||||
|
for r in merged.values():
|
||||||
|
r.provider = detect_provider(r.url)
|
||||||
|
|
||||||
|
await self._enrich_and_resolve(merged)
|
||||||
|
self.repos = merged
|
||||||
|
|
||||||
|
async def _enrich_and_resolve(self, merged: dict[str, RepoItem]) -> None:
|
||||||
|
sem = asyncio.Semaphore(6)
|
||||||
|
|
||||||
|
async def process_one(r: RepoItem) -> None:
|
||||||
|
async with sem:
|
||||||
|
info: RepoInfo = await fetch_repo_info(self.hass, r.url)
|
||||||
|
|
||||||
|
r.provider = info.provider or r.provider
|
||||||
|
r.owner = info.owner or r.owner
|
||||||
|
r.provider_repo_name = info.repo_name
|
||||||
|
r.provider_description = info.description
|
||||||
|
r.default_branch = info.default_branch or r.default_branch
|
||||||
|
|
||||||
|
r.latest_version = info.latest_version
|
||||||
|
r.latest_version_source = info.latest_version_source
|
||||||
|
|
||||||
|
md: RepoMetadata = await fetch_repo_metadata(self.hass, r.url, r.default_branch)
|
||||||
|
r.meta_source = md.source
|
||||||
|
r.meta_name = md.name
|
||||||
|
r.meta_description = md.description
|
||||||
|
r.meta_category = md.category
|
||||||
|
r.meta_author = md.author
|
||||||
|
r.meta_maintainer = md.maintainer
|
||||||
|
|
||||||
|
has_user_or_index_name = bool(r.name) and (r.name != r.url) and (not str(r.name).startswith("http"))
|
||||||
|
if r.meta_name:
|
||||||
|
r.name = r.meta_name
|
||||||
|
elif not has_user_or_index_name and r.provider_repo_name:
|
||||||
|
r.name = r.provider_repo_name
|
||||||
|
elif not r.name:
|
||||||
|
r.name = r.url
|
||||||
|
|
||||||
|
await asyncio.gather(*(process_one(r) for r in merged.values()), return_exceptions=True)
|
||||||
|
|
||||||
|
async def _load_index_repos(self) -> tuple[list[RepoItem], int]:
|
||||||
|
session = async_get_clientsession(self.hass)
|
||||||
|
try:
|
||||||
|
async with session.get(self.config.store_url, timeout=20) as resp:
|
||||||
|
if resp.status != 200:
|
||||||
|
raise BCSError(f"store_url returned {resp.status}")
|
||||||
|
raw = await resp.text()
|
||||||
|
except Exception as e:
|
||||||
|
raise BCSError(f"Failed fetching store index: {e}") from e
|
||||||
|
|
||||||
|
try:
|
||||||
|
data = ha_yaml.parse_yaml(raw)
|
||||||
|
if not isinstance(data, dict):
|
||||||
|
raise BCSError("store.yaml must be a mapping")
|
||||||
|
|
||||||
|
refresh_seconds = int(data.get("refresh_seconds", 300))
|
||||||
|
repos = data.get("repos", [])
|
||||||
|
if not isinstance(repos, list):
|
||||||
|
raise BCSError("store.yaml 'repos' must be a list")
|
||||||
|
|
||||||
|
items: list[RepoItem] = []
|
||||||
|
for i, r in enumerate(repos):
|
||||||
|
if not isinstance(r, dict):
|
||||||
|
continue
|
||||||
|
url = str(r.get("url", "")).strip()
|
||||||
|
if not url:
|
||||||
|
continue
|
||||||
|
name = str(r.get("name") or url).strip()
|
||||||
|
|
||||||
|
items.append(
|
||||||
|
RepoItem(
|
||||||
|
id=f"index:{i}",
|
||||||
|
name=name,
|
||||||
|
url=url,
|
||||||
|
source="index",
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
return items, refresh_seconds
|
||||||
|
except Exception as e:
|
||||||
|
raise BCSError(f"Invalid store.yaml: {e}") from e
|
||||||
|
|
||||||
|
async def add_custom_repo(self, url: str, name: str | None) -> CustomRepo:
|
||||||
|
url = str(url or "").strip()
|
||||||
|
if not url:
|
||||||
|
raise BCSError("Missing url")
|
||||||
|
|
||||||
|
c = await self.storage.add_custom_repo(url, name)
|
||||||
|
await self.refresh()
|
||||||
|
self.signal_updated()
|
||||||
|
return c
|
||||||
|
|
||||||
|
async def remove_custom_repo(self, repo_id: str) -> None:
|
||||||
|
await self.storage.remove_custom_repo(repo_id)
|
||||||
|
await self.refresh()
|
||||||
|
self.signal_updated()
|
||||||
|
|
||||||
|
async def list_custom_repos(self) -> list[CustomRepo]:
|
||||||
|
return await self.storage.list_custom_repos()
|
||||||
|
|
||||||
|
def list_repos_public(self) -> list[dict[str, Any]]:
|
||||||
|
out: list[dict[str, Any]] = []
|
||||||
|
for r in self.repos.values():
|
||||||
|
out.append(
|
||||||
|
{
|
||||||
|
"id": r.id,
|
||||||
|
"name": r.name,
|
||||||
|
"url": r.url,
|
||||||
|
"source": r.source,
|
||||||
|
"owner": r.owner,
|
||||||
|
"provider": r.provider,
|
||||||
|
"repo_name": r.provider_repo_name,
|
||||||
|
"description": r.provider_description or r.meta_description,
|
||||||
|
"default_branch": r.default_branch,
|
||||||
|
"latest_version": r.latest_version,
|
||||||
|
"latest_version_source": r.latest_version_source,
|
||||||
|
"category": r.meta_category,
|
||||||
|
"meta_author": r.meta_author,
|
||||||
|
"meta_maintainer": r.meta_maintainer,
|
||||||
|
"meta_source": r.meta_source,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
return out
|
||||||
|
|
||||||
|
def _split_owner_repo(self, repo_url: str) -> tuple[str | None, str | None]:
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
parts = [p for p in u.path.strip("/").split("/") if p]
|
||||||
|
if len(parts) < 2:
|
||||||
|
return None, None
|
||||||
|
owner = parts[0].strip() or None
|
||||||
|
name = parts[1].strip()
|
||||||
|
if name.endswith(".git"):
|
||||||
|
name = name[:-4]
|
||||||
|
name = name.strip() or None
|
||||||
|
return owner, name
|
||||||
|
|
||||||
|
def _is_github(self, repo_url: str) -> bool:
|
||||||
|
return "github.com" in urlparse(repo_url).netloc.lower()
|
||||||
|
|
||||||
|
def _is_gitea(self, repo_url: str) -> bool:
|
||||||
|
host = urlparse(repo_url).netloc.lower()
|
||||||
|
return host and "github.com" not in host and "gitlab.com" not in host
|
||||||
|
|
||||||
|
async def _fetch_text(self, url: str) -> str | None:
|
||||||
|
session = async_get_clientsession(self.hass)
|
||||||
|
try:
|
||||||
|
async with session.get(url, timeout=20) as resp:
|
||||||
|
if resp.status != 200:
|
||||||
|
return None
|
||||||
|
return await resp.text()
|
||||||
|
except Exception:
|
||||||
|
return None
|
||||||
|
|
||||||
|
async def fetch_readme_markdown(self, repo_id: str) -> str | None:
|
||||||
|
"""Fetch README markdown from GitHub, Gitea or GitLab.
|
||||||
|
|
||||||
|
Defensive behavior:
|
||||||
|
- tries multiple common filenames
|
||||||
|
- tries multiple branches (default, main, master)
|
||||||
|
- uses public raw endpoints (no tokens required for public repositories)
|
||||||
|
"""
|
||||||
|
repo = self.get_repo(repo_id)
|
||||||
|
if not repo:
|
||||||
|
return None
|
||||||
|
|
||||||
|
repo_url = (repo.url or "").strip()
|
||||||
|
if not repo_url:
|
||||||
|
return None
|
||||||
|
|
||||||
|
# Branch fallbacks
|
||||||
|
branch_candidates: list[str] = []
|
||||||
|
if repo.default_branch and str(repo.default_branch).strip():
|
||||||
|
branch_candidates.append(str(repo.default_branch).strip())
|
||||||
|
for b in ("main", "master"):
|
||||||
|
if b not in branch_candidates:
|
||||||
|
branch_candidates.append(b)
|
||||||
|
|
||||||
|
# Filename fallbacks
|
||||||
|
filenames = ["README.md", "readme.md", "README.MD", "README.rst", "README"]
|
||||||
|
|
||||||
|
provider = (repo.provider or "").strip().lower()
|
||||||
|
if not provider:
|
||||||
|
provider = detect_provider(repo_url) or ""
|
||||||
|
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
host = (u.netloc or "").lower()
|
||||||
|
|
||||||
|
candidates: list[str] = []
|
||||||
|
|
||||||
|
if self._is_github(repo_url):
|
||||||
|
owner, name = self._split_owner_repo(repo_url)
|
||||||
|
if not owner or not name:
|
||||||
|
return None
|
||||||
|
for branch in branch_candidates:
|
||||||
|
base = f"https://raw.githubusercontent.com/{owner}/{name}/{branch}"
|
||||||
|
candidates.extend([f"{base}/{fn}" for fn in filenames])
|
||||||
|
|
||||||
|
elif provider == "gitlab" or "gitlab" in host:
|
||||||
|
# GitLab can have nested groups: /group/subgroup/repo
|
||||||
|
parts = [p for p in u.path.strip("/").split("/") if p]
|
||||||
|
if len(parts) < 2:
|
||||||
|
return None
|
||||||
|
|
||||||
|
repo_name = parts[-1].strip()
|
||||||
|
if repo_name.endswith(".git"):
|
||||||
|
repo_name = repo_name[:-4]
|
||||||
|
group_path = "/".join(parts[:-1]).strip("/")
|
||||||
|
if not group_path or not repo_name:
|
||||||
|
return None
|
||||||
|
|
||||||
|
root = f"{u.scheme}://{u.netloc}/{group_path}/{repo_name}"
|
||||||
|
for branch in branch_candidates:
|
||||||
|
bases = [
|
||||||
|
f"{root}/-/raw/{branch}",
|
||||||
|
# Some instances may expose /raw/<branch> as well
|
||||||
|
f"{root}/raw/{branch}",
|
||||||
|
]
|
||||||
|
for b in bases:
|
||||||
|
candidates.extend([f"{b}/{fn}" for fn in filenames])
|
||||||
|
|
||||||
|
elif self._is_gitea(repo_url):
|
||||||
|
owner, name = self._split_owner_repo(repo_url)
|
||||||
|
if not owner or not name:
|
||||||
|
return None
|
||||||
|
|
||||||
|
root = f"{u.scheme}://{u.netloc}/{owner}/{name}"
|
||||||
|
|
||||||
|
for branch in branch_candidates:
|
||||||
|
bases = [
|
||||||
|
f"{root}/raw/branch/{branch}",
|
||||||
|
f"{root}/raw/{branch}",
|
||||||
|
]
|
||||||
|
for b in bases:
|
||||||
|
candidates.extend([f"{b}/{fn}" for fn in filenames])
|
||||||
|
|
||||||
|
else:
|
||||||
|
return None
|
||||||
|
|
||||||
|
for url in candidates:
|
||||||
|
txt = await self._fetch_text(url)
|
||||||
|
if txt and txt.strip():
|
||||||
|
return txt
|
||||||
|
|
||||||
|
return None
|
||||||
28
custom_components/bahmcloud_store/custom_repo_view.py
Normal file
28
custom_components/bahmcloud_store/custom_repo_view.py
Normal file
@@ -0,0 +1,28 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
from typing import TYPE_CHECKING
|
||||||
|
|
||||||
|
from homeassistant.components.http import HomeAssistantView
|
||||||
|
|
||||||
|
if TYPE_CHECKING:
|
||||||
|
from .core import BCSCore
|
||||||
|
|
||||||
|
|
||||||
|
class BCSCustomRepoView(HomeAssistantView):
|
||||||
|
"""
|
||||||
|
DELETE /api/bcs/custom_repo?id=...
|
||||||
|
"""
|
||||||
|
requires_auth = True
|
||||||
|
name = "bcs_custom_repo_api"
|
||||||
|
url = "/api/bcs/custom_repo"
|
||||||
|
|
||||||
|
def __init__(self, core: "BCSCore") -> None:
|
||||||
|
self.core = core
|
||||||
|
|
||||||
|
async def delete(self, request):
|
||||||
|
repo_id = request.query.get("id", "").strip()
|
||||||
|
if not repo_id:
|
||||||
|
return self.json({"error": "id missing"}, status_code=400)
|
||||||
|
|
||||||
|
await self.core.remove_custom_repo(repo_id)
|
||||||
|
return self.json({"ok": True})
|
||||||
@@ -1,8 +1,8 @@
|
|||||||
{
|
{
|
||||||
"domain": "bahmcloud_store",
|
"domain": "bahmcloud_store",
|
||||||
"name": "Bahmcloud Store",
|
"name": "Bahmcloud Store",
|
||||||
"version": "0.1.0",
|
"version": "0.4.0",
|
||||||
"documentation": "https://git.bahmcloud.de/bahmcloud/ha_store",
|
"documentation": "https://git.bahmcloud.de/bahmcloud/bahmcloud_store",
|
||||||
"requirements": [],
|
"requirements": [],
|
||||||
"codeowners": [],
|
"codeowners": [],
|
||||||
"iot_class": "local_polling"
|
"iot_class": "local_polling"
|
||||||
|
|||||||
168
custom_components/bahmcloud_store/metadata.py
Normal file
168
custom_components/bahmcloud_store/metadata.py
Normal file
@@ -0,0 +1,168 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import json
|
||||||
|
import logging
|
||||||
|
from dataclasses import dataclass
|
||||||
|
from urllib.parse import urlparse
|
||||||
|
|
||||||
|
from homeassistant.core import HomeAssistant
|
||||||
|
from homeassistant.helpers.aiohttp_client import async_get_clientsession
|
||||||
|
from homeassistant.util import yaml as ha_yaml
|
||||||
|
|
||||||
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class RepoMetadata:
|
||||||
|
source: str | None = None # "bcs.yaml" | "hacs.yaml" | "hacs.json" | None
|
||||||
|
name: str | None = None
|
||||||
|
description: str | None = None
|
||||||
|
category: str | None = None
|
||||||
|
author: str | None = None
|
||||||
|
maintainer: str | None = None
|
||||||
|
|
||||||
|
|
||||||
|
def _normalize_repo_name(name: str | None) -> str | None:
|
||||||
|
if not name:
|
||||||
|
return None
|
||||||
|
n = name.strip()
|
||||||
|
if n.endswith(".git"):
|
||||||
|
n = n[:-4]
|
||||||
|
return n or None
|
||||||
|
|
||||||
|
|
||||||
|
def _split_owner_repo(repo_url: str) -> tuple[str | None, str | None]:
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
parts = [p for p in u.path.strip("/").split("/") if p]
|
||||||
|
if len(parts) < 2:
|
||||||
|
return None, None
|
||||||
|
owner = parts[0].strip() or None
|
||||||
|
repo = _normalize_repo_name(parts[1])
|
||||||
|
return owner, repo
|
||||||
|
|
||||||
|
|
||||||
|
def _is_github(repo_url: str) -> bool:
|
||||||
|
return "github.com" in urlparse(repo_url).netloc.lower()
|
||||||
|
|
||||||
|
|
||||||
|
def _is_gitlab(repo_url: str) -> bool:
|
||||||
|
return "gitlab" in urlparse(repo_url).netloc.lower()
|
||||||
|
|
||||||
|
|
||||||
|
def _is_gitea(repo_url: str) -> bool:
|
||||||
|
host = urlparse(repo_url).netloc.lower()
|
||||||
|
return host and ("github.com" not in host) and ("gitlab" not in host)
|
||||||
|
|
||||||
|
|
||||||
|
async def _fetch_text(hass: HomeAssistant, url: str) -> str | None:
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
try:
|
||||||
|
async with session.get(url, timeout=20) as resp:
|
||||||
|
if resp.status != 200:
|
||||||
|
return None
|
||||||
|
return await resp.text()
|
||||||
|
except Exception:
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
def _parse_meta_yaml(raw: str, source: str) -> RepoMetadata:
|
||||||
|
try:
|
||||||
|
data = ha_yaml.parse_yaml(raw)
|
||||||
|
if not isinstance(data, dict):
|
||||||
|
return RepoMetadata(source=source)
|
||||||
|
|
||||||
|
return RepoMetadata(
|
||||||
|
source=source,
|
||||||
|
name=data.get("name"),
|
||||||
|
description=data.get("description"),
|
||||||
|
category=data.get("category"),
|
||||||
|
author=data.get("author"),
|
||||||
|
maintainer=data.get("maintainer"),
|
||||||
|
)
|
||||||
|
except Exception:
|
||||||
|
return RepoMetadata(source=source)
|
||||||
|
|
||||||
|
|
||||||
|
def _parse_meta_hacs_json(raw: str) -> RepoMetadata:
|
||||||
|
try:
|
||||||
|
data = json.loads(raw)
|
||||||
|
if not isinstance(data, dict):
|
||||||
|
return RepoMetadata(source="hacs.json")
|
||||||
|
|
||||||
|
name = data.get("name")
|
||||||
|
description = data.get("description")
|
||||||
|
author = data.get("author")
|
||||||
|
maintainer = data.get("maintainer")
|
||||||
|
category = data.get("category") or data.get("type")
|
||||||
|
|
||||||
|
return RepoMetadata(
|
||||||
|
source="hacs.json",
|
||||||
|
name=name if isinstance(name, str) else None,
|
||||||
|
description=description if isinstance(description, str) else None,
|
||||||
|
category=category if isinstance(category, str) else None,
|
||||||
|
author=author if isinstance(author, str) else None,
|
||||||
|
maintainer=maintainer if isinstance(maintainer, str) else None,
|
||||||
|
)
|
||||||
|
except Exception:
|
||||||
|
return RepoMetadata(source="hacs.json")
|
||||||
|
|
||||||
|
|
||||||
|
async def fetch_repo_metadata(hass: HomeAssistant, repo_url: str, default_branch: str | None) -> RepoMetadata:
|
||||||
|
owner, repo = _split_owner_repo(repo_url)
|
||||||
|
if not owner or not repo:
|
||||||
|
return RepoMetadata()
|
||||||
|
|
||||||
|
branch = default_branch or "main"
|
||||||
|
|
||||||
|
# Priority:
|
||||||
|
# 1) bcs.yaml
|
||||||
|
# 2) hacs.yaml
|
||||||
|
# 3) hacs.json
|
||||||
|
filenames = ["bcs.yaml", "hacs.yaml", "hacs.json"]
|
||||||
|
|
||||||
|
candidates: list[tuple[str, str]] = []
|
||||||
|
|
||||||
|
if _is_github(repo_url):
|
||||||
|
base = f"https://raw.githubusercontent.com/{owner}/{repo}/{branch}"
|
||||||
|
for fn in filenames:
|
||||||
|
candidates.append((fn, f"{base}/{fn}"))
|
||||||
|
|
||||||
|
elif _is_gitlab(repo_url):
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
root = f"{u.scheme}://{u.netloc}/{owner}/{repo}"
|
||||||
|
# GitLab raw format
|
||||||
|
# https://gitlab.com/<owner>/<repo>/-/raw/<branch>/<file>
|
||||||
|
for fn in filenames:
|
||||||
|
candidates.append((fn, f"{root}/-/raw/{branch}/{fn}"))
|
||||||
|
|
||||||
|
elif _is_gitea(repo_url):
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
root = f"{u.scheme}://{u.netloc}/{owner}/{repo}"
|
||||||
|
|
||||||
|
bases = [
|
||||||
|
f"{root}/raw/branch/{branch}",
|
||||||
|
f"{root}/raw/{branch}",
|
||||||
|
]
|
||||||
|
for fn in filenames:
|
||||||
|
for b in bases:
|
||||||
|
candidates.append((fn, f"{b}/{fn}"))
|
||||||
|
|
||||||
|
else:
|
||||||
|
return RepoMetadata()
|
||||||
|
|
||||||
|
for fn, url in candidates:
|
||||||
|
raw = await _fetch_text(hass, url)
|
||||||
|
if not raw:
|
||||||
|
continue
|
||||||
|
|
||||||
|
if fn.endswith(".json"):
|
||||||
|
meta = _parse_meta_hacs_json(raw)
|
||||||
|
if meta.source:
|
||||||
|
return meta
|
||||||
|
continue
|
||||||
|
|
||||||
|
meta = _parse_meta_yaml(raw, fn)
|
||||||
|
if meta.source:
|
||||||
|
return meta
|
||||||
|
|
||||||
|
return RepoMetadata()
|
||||||
@@ -1,29 +1,86 @@
|
|||||||
async function load() {
|
async function apiGet() {
|
||||||
const r = await fetch("/api/bahmcloud_store", { credentials: "same-origin" });
|
const r = await fetch("/api/bahmcloud_store", { credentials: "same-origin" });
|
||||||
const data = await r.json();
|
return await r.json();
|
||||||
|
}
|
||||||
|
|
||||||
|
async function apiPost(payload) {
|
||||||
|
const r = await fetch("/api/bahmcloud_store", {
|
||||||
|
method: "POST",
|
||||||
|
headers: { "Content-Type": "application/json" },
|
||||||
|
credentials: "same-origin",
|
||||||
|
body: JSON.stringify(payload),
|
||||||
|
});
|
||||||
|
return await r.json();
|
||||||
|
}
|
||||||
|
|
||||||
|
function el(tag, attrs = {}, children = []) {
|
||||||
|
const n = document.createElement(tag);
|
||||||
|
for (const [k, v] of Object.entries(attrs)) {
|
||||||
|
if (k === "class") n.className = v;
|
||||||
|
else if (k === "onclick") n.onclick = v;
|
||||||
|
else n.setAttribute(k, v);
|
||||||
|
}
|
||||||
|
for (const c of children) {
|
||||||
|
n.appendChild(typeof c === "string" ? document.createTextNode(c) : c);
|
||||||
|
}
|
||||||
|
return n;
|
||||||
|
}
|
||||||
|
|
||||||
|
function card(pkg) {
|
||||||
|
const installedBadge = el("span", { class: "badge" }, [pkg.installed ? "Installed" : "Not installed"]);
|
||||||
|
|
||||||
|
const title = el("div", {}, [
|
||||||
|
el("strong", {}, [pkg.name]),
|
||||||
|
el("div", { class: "muted" }, [pkg.repo]),
|
||||||
|
]);
|
||||||
|
|
||||||
|
const ver = el("div", { class: "muted" }, [
|
||||||
|
`Installed: ${pkg.installed_version || "-"} | Latest: ${pkg.latest_version || "-"}`
|
||||||
|
]);
|
||||||
|
|
||||||
|
const btnInstall = el("button", {
|
||||||
|
onclick: async () => {
|
||||||
|
btnInstall.disabled = true;
|
||||||
|
btnInstall.textContent = "Working...";
|
||||||
|
await apiPost({ op: "install", package_id: pkg.id });
|
||||||
|
await load();
|
||||||
|
}
|
||||||
|
}, [pkg.installed ? "Reinstall" : "Install"]);
|
||||||
|
|
||||||
|
const btnUpdate = el("button", {
|
||||||
|
onclick: async () => {
|
||||||
|
btnUpdate.disabled = true;
|
||||||
|
btnUpdate.textContent = "Working...";
|
||||||
|
await apiPost({ op: "update", package_id: pkg.id });
|
||||||
|
await load();
|
||||||
|
}
|
||||||
|
}, ["Update"]);
|
||||||
|
|
||||||
|
// Update-Button nur wenn installiert
|
||||||
|
btnUpdate.disabled = !pkg.installed;
|
||||||
|
|
||||||
|
const actions = el("div", { class: "actions" }, [btnInstall, btnUpdate]);
|
||||||
|
|
||||||
|
return el("div", { class: "card" }, [
|
||||||
|
el("div", { class: "row" }, [title, installedBadge]),
|
||||||
|
ver,
|
||||||
|
actions
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
async function load() {
|
||||||
|
const status = document.getElementById("status");
|
||||||
const list = document.getElementById("list");
|
const list = document.getElementById("list");
|
||||||
|
|
||||||
|
status.textContent = "Loading...";
|
||||||
list.innerHTML = "";
|
list.innerHTML = "";
|
||||||
|
|
||||||
data.packages.forEach(p => {
|
const data = await apiGet();
|
||||||
const div = document.createElement("div");
|
status.textContent = `Store: ${data.store_url}`;
|
||||||
div.className = "card";
|
|
||||||
div.innerHTML = `
|
for (const pkg of data.packages) {
|
||||||
<div class="row">
|
list.appendChild(card(pkg));
|
||||||
<div>
|
}
|
||||||
<b>${p.name}</b>
|
|
||||||
<div class="muted">${p.repo}</div>
|
|
||||||
</div>
|
|
||||||
<div class="badge">${p.installed ? "Installed" : "Not installed"}</div>
|
|
||||||
</div>
|
|
||||||
<div class="muted">
|
|
||||||
Installed: ${p.installed_version || "-"} |
|
|
||||||
Latest: ${p.latest_version || "-"}
|
|
||||||
${p.release_url ? `| <a href="${p.release_url}" target="_blank">Release</a>` : ""}
|
|
||||||
</div>
|
|
||||||
`;
|
|
||||||
list.appendChild(div);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
document.getElementById("refresh").onclick = load;
|
document.getElementById("refresh").onclick = load;
|
||||||
|
|||||||
@@ -9,12 +9,18 @@
|
|||||||
<div class="wrap">
|
<div class="wrap">
|
||||||
<h1>Bahmcloud Store</h1>
|
<h1>Bahmcloud Store</h1>
|
||||||
<p class="muted">
|
<p class="muted">
|
||||||
Installation & Updates laufen manuell über <b>Einstellungen → System → Updates</b>.<br/>
|
Installation erfolgt hier im Store (Buttons).<br/>
|
||||||
Diese Seite zeigt nur die Paketliste aus store.yaml (auto-refresh).
|
Updates erscheinen danach zusätzlich unter <b>Einstellungen → System → Updates</b>.
|
||||||
</p>
|
</p>
|
||||||
|
|
||||||
|
<div class="actions">
|
||||||
<button id="refresh">Refresh</button>
|
<button id="refresh">Refresh</button>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div id="status" class="muted"></div>
|
||||||
<div id="list"></div>
|
<div id="list"></div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<script src="/api/bahmcloud_store_static/app.js"></script>
|
<script src="/api/bahmcloud_store_static/app.js"></script>
|
||||||
</body>
|
</body>
|
||||||
</html>
|
</html>
|
||||||
|
|||||||
@@ -1,24 +1,945 @@
|
|||||||
class BahmcloudStorePanel extends HTMLElement {
|
class BahmcloudStorePanel extends HTMLElement {
|
||||||
|
constructor() {
|
||||||
|
super();
|
||||||
|
this.attachShadow({ mode: "open" });
|
||||||
|
|
||||||
|
this._hass = null;
|
||||||
|
|
||||||
|
this._view = "store"; // store | manage | about | detail
|
||||||
|
this._data = null;
|
||||||
|
this._loading = true;
|
||||||
|
this._error = null;
|
||||||
|
|
||||||
|
this._customAddUrl = "";
|
||||||
|
this._customAddName = "";
|
||||||
|
|
||||||
|
this._search = "";
|
||||||
|
this._category = "all";
|
||||||
|
this._provider = "all"; // all|github|gitea|gitlab|other|custom
|
||||||
|
|
||||||
|
this._detailRepoId = null;
|
||||||
|
this._detailRepo = null;
|
||||||
|
|
||||||
|
this._readmeLoading = false;
|
||||||
|
this._readmeText = null;
|
||||||
|
this._readmeHtml = null;
|
||||||
|
this._readmeError = null;
|
||||||
|
}
|
||||||
|
|
||||||
set hass(hass) {
|
set hass(hass) {
|
||||||
if (this._rendered) return;
|
this._hass = hass;
|
||||||
|
if (!this._rendered) {
|
||||||
this._rendered = true;
|
this._rendered = true;
|
||||||
|
this._render();
|
||||||
|
this._load();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
const root = this.attachShadow({ mode: "open" });
|
async _load() {
|
||||||
const iframe = document.createElement("iframe");
|
if (!this._hass) return;
|
||||||
|
|
||||||
iframe.src = "/api/bahmcloud_store_static/index.html";
|
this._loading = true;
|
||||||
iframe.style.width = "100%";
|
this._error = null;
|
||||||
iframe.style.height = "100%";
|
this._update();
|
||||||
iframe.style.border = "0";
|
|
||||||
iframe.style.display = "block";
|
|
||||||
|
|
||||||
const style = document.createElement("style");
|
try {
|
||||||
style.textContent = `
|
const data = await this._hass.callApi("get", "bcs");
|
||||||
:host { display: block; height: 100vh; }
|
this._data = data;
|
||||||
|
} catch (e) {
|
||||||
|
this._error = e?.message ? String(e.message) : String(e);
|
||||||
|
} finally {
|
||||||
|
this._loading = false;
|
||||||
|
this._update();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
_isDesktop() {
|
||||||
|
return window.matchMedia && window.matchMedia("(min-width: 1024px)").matches;
|
||||||
|
}
|
||||||
|
|
||||||
|
_toggleMenu() {
|
||||||
|
if (this._isDesktop()) return;
|
||||||
|
try {
|
||||||
|
const ev = new Event("hass-toggle-menu", { bubbles: true, composed: true });
|
||||||
|
this.dispatchEvent(ev);
|
||||||
|
} catch (_) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
_goBack() {
|
||||||
|
if (this._view === "detail") {
|
||||||
|
this._view = "store";
|
||||||
|
this._detailRepoId = null;
|
||||||
|
this._detailRepo = null;
|
||||||
|
this._readmeText = null;
|
||||||
|
this._readmeHtml = null;
|
||||||
|
this._readmeError = null;
|
||||||
|
this._update();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
history.back();
|
||||||
|
} catch (_) {
|
||||||
|
window.location.href = "/";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async _addCustomRepo() {
|
||||||
|
if (!this._hass) return;
|
||||||
|
|
||||||
|
const url = (this._customAddUrl || "").trim();
|
||||||
|
const name = (this._customAddName || "").trim() || null;
|
||||||
|
|
||||||
|
if (!url) {
|
||||||
|
this._error = "Please enter a repository URL.";
|
||||||
|
this._update();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
this._error = null;
|
||||||
|
this._update();
|
||||||
|
|
||||||
|
try {
|
||||||
|
await this._hass.callApi("post", "bcs", { op: "add_custom_repo", url, name });
|
||||||
|
this._customAddUrl = "";
|
||||||
|
this._customAddName = "";
|
||||||
|
await this._load();
|
||||||
|
this._view = "manage";
|
||||||
|
this._update();
|
||||||
|
} catch (e) {
|
||||||
|
this._error = e?.message ? String(e.message) : String(e);
|
||||||
|
this._update();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async _removeCustomRepo(id) {
|
||||||
|
if (!this._hass) return;
|
||||||
|
|
||||||
|
try {
|
||||||
|
await this._hass.callApi("delete", `bcs/custom_repo?id=${encodeURIComponent(id)}`);
|
||||||
|
await this._load();
|
||||||
|
this._view = "manage";
|
||||||
|
this._update();
|
||||||
|
} catch (e) {
|
||||||
|
this._error = e?.message ? String(e.message) : String(e);
|
||||||
|
this._update();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
_openRepoDetail(repoId) {
|
||||||
|
const repos = Array.isArray(this._data?.repos) ? this._data.repos : [];
|
||||||
|
const repo = repos.find((r) => this._safeId(r?.id) === repoId);
|
||||||
|
if (!repo) return;
|
||||||
|
|
||||||
|
this._view = "detail";
|
||||||
|
this._detailRepoId = repoId;
|
||||||
|
this._detailRepo = repo;
|
||||||
|
|
||||||
|
this._readmeText = null;
|
||||||
|
this._readmeHtml = null;
|
||||||
|
this._readmeError = null;
|
||||||
|
|
||||||
|
this._update();
|
||||||
|
this._loadReadme(repoId);
|
||||||
|
}
|
||||||
|
|
||||||
|
async _loadReadme(repoId) {
|
||||||
|
if (!this._hass) return;
|
||||||
|
this._readmeLoading = true;
|
||||||
|
this._readmeError = null;
|
||||||
|
this._update();
|
||||||
|
|
||||||
|
try {
|
||||||
|
const resp = await this._hass.callApi(
|
||||||
|
"get",
|
||||||
|
`bcs/readme?repo_id=${encodeURIComponent(repoId)}`
|
||||||
|
);
|
||||||
|
|
||||||
|
if (resp?.ok && typeof resp.readme === "string" && resp.readme.trim()) {
|
||||||
|
this._readmeText = resp.readme;
|
||||||
|
this._readmeHtml = typeof resp.html === "string" && resp.html.trim() ? resp.html : null;
|
||||||
|
} else {
|
||||||
|
this._readmeText = null;
|
||||||
|
this._readmeHtml = null;
|
||||||
|
this._readmeError = this._safeText(resp?.message) || "README not found.";
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
this._readmeText = null;
|
||||||
|
this._readmeHtml = null;
|
||||||
|
this._readmeError = e?.message ? String(e.message) : String(e);
|
||||||
|
} finally {
|
||||||
|
this._readmeLoading = false;
|
||||||
|
this._update();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
_render() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
|
||||||
|
root.innerHTML = `
|
||||||
|
<style>
|
||||||
|
:host { display:block; min-height:100%; --bcs-accent:#1E88E5; }
|
||||||
|
|
||||||
|
.mobilebar{
|
||||||
|
position:sticky; top:0; z-index:50;
|
||||||
|
display:flex; align-items:center; justify-content:space-between;
|
||||||
|
gap:10px; padding:10px 12px;
|
||||||
|
background: var(--app-header-background-color, var(--card-background-color));
|
||||||
|
color: var(--app-header-text-color, var(--primary-text-color));
|
||||||
|
border-bottom:1px solid var(--divider-color);
|
||||||
|
}
|
||||||
|
.mobilebar .left, .mobilebar .right { display:flex; align-items:center; gap:10px; }
|
||||||
|
|
||||||
|
.iconbtn{
|
||||||
|
width:40px; height:40px; border-radius:14px;
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
background: color-mix(in srgb, var(--card-background-color) 82%, transparent);
|
||||||
|
color:inherit; display:inline-flex; align-items:center; justify-content:center;
|
||||||
|
cursor:pointer; user-select:none; font-weight:900; font-size:18px; line-height:1;
|
||||||
|
}
|
||||||
|
.iconbtn:hover{ box-shadow: 0 10px 30px rgba(0,0,0,0.10); transform: translateY(-1px); }
|
||||||
|
.iconbtn:active{ transform: translateY(0px); box-shadow:none; }
|
||||||
|
@media (min-width: 1024px) { .iconbtn.menu { display:none; } }
|
||||||
|
|
||||||
|
.brandtitle{ display:flex; flex-direction:column; line-height:1.2; }
|
||||||
|
.brandtitle .t{ font-size:16px; font-weight:900; letter-spacing: .2px; }
|
||||||
|
.brandtitle .s{ font-size:12px; color:var(--secondary-text-color); margin-top:2px; }
|
||||||
|
|
||||||
|
.wrap{
|
||||||
|
padding:16px; max-width:1100px; margin:0 auto;
|
||||||
|
font-family: system-ui,-apple-system,Segoe UI,Roboto,sans-serif;
|
||||||
|
color:var(--primary-text-color);
|
||||||
|
}
|
||||||
|
|
||||||
|
.tabs{ display:flex; gap:8px; flex-wrap:wrap; margin-bottom:12px; }
|
||||||
|
.tab{
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
background:var(--card-background-color);
|
||||||
|
color:var(--primary-text-color);
|
||||||
|
padding:8px 12px; border-radius:999px;
|
||||||
|
cursor:pointer; font-weight:800; font-size:13px;
|
||||||
|
}
|
||||||
|
.tab.active{
|
||||||
|
border-color:var(--bcs-accent);
|
||||||
|
box-shadow:0 0 0 2px color-mix(in srgb, var(--bcs-accent) 20%, transparent);
|
||||||
|
}
|
||||||
|
|
||||||
|
button{
|
||||||
|
padding:10px 12px; border-radius:14px;
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
background:var(--card-background-color);
|
||||||
|
color:var(--primary-text-color);
|
||||||
|
cursor:pointer; font-weight:900;
|
||||||
|
}
|
||||||
|
button.primary{
|
||||||
|
border-color:var(--bcs-accent);
|
||||||
|
background: color-mix(in srgb, var(--bcs-accent) 16%, var(--card-background-color));
|
||||||
|
}
|
||||||
|
button:hover{ box-shadow: 0 10px 30px rgba(0,0,0,0.10); transform: translateY(-1px); }
|
||||||
|
button:active{ transform: translateY(0px); box-shadow:none; }
|
||||||
|
button:disabled{ opacity: 0.55; cursor: not-allowed; }
|
||||||
|
|
||||||
|
.card{
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
background:var(--card-background-color);
|
||||||
|
border-radius:18px; padding:12px; margin:10px 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
.card.clickable{
|
||||||
|
cursor:pointer;
|
||||||
|
transition: transform 120ms ease, box-shadow 120ms ease;
|
||||||
|
}
|
||||||
|
.card.clickable:hover{
|
||||||
|
transform: translateY(-1px);
|
||||||
|
box-shadow: 0 12px 34px rgba(0,0,0,0.10);
|
||||||
|
}
|
||||||
|
|
||||||
|
.row{ display:flex; justify-content:space-between; gap:10px; align-items:flex-start; }
|
||||||
|
.muted{ color:var(--secondary-text-color); font-size:13px; margin-top:4px; }
|
||||||
|
.small{ font-size:12px; }
|
||||||
|
|
||||||
|
.badge{
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
border-radius:999px; padding:2px 10px;
|
||||||
|
font-size:12px; font-weight:900; height:fit-content;
|
||||||
|
}
|
||||||
|
.badge.custom{ border-color:var(--bcs-accent); color:var(--bcs-accent); }
|
||||||
|
|
||||||
|
.error{ color:#b00020; white-space:pre-wrap; margin-top:10px; }
|
||||||
|
|
||||||
|
.grid2{ display:grid; grid-template-columns: 1fr; gap: 12px; }
|
||||||
|
@media (min-width: 900px){ .grid2{ grid-template-columns: 1.2fr 0.8fr; } }
|
||||||
|
|
||||||
|
.filters{ display:flex; gap:10px; flex-wrap:wrap; align-items:center; margin-bottom:12px; }
|
||||||
|
.chips{ display:flex; gap:8px; flex-wrap:wrap; margin-bottom:12px; }
|
||||||
|
|
||||||
|
.chip{
|
||||||
|
display:inline-flex; align-items:center; gap:8px;
|
||||||
|
padding:6px 10px; border-radius:999px;
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
background:var(--card-background-color);
|
||||||
|
cursor:pointer; user-select:none; font-weight:800; font-size:12px;
|
||||||
|
}
|
||||||
|
.chip strong{ font-size:12px; }
|
||||||
|
.chip.active{
|
||||||
|
border-color:var(--bcs-accent);
|
||||||
|
box-shadow:0 0 0 2px color-mix(in srgb, var(--bcs-accent) 18%, transparent);
|
||||||
|
}
|
||||||
|
|
||||||
|
input, select{
|
||||||
|
padding:10px 12px; border-radius:14px;
|
||||||
|
border:1px solid var(--divider-color);
|
||||||
|
background:var(--card-background-color);
|
||||||
|
color:var(--primary-text-color);
|
||||||
|
outline:none;
|
||||||
|
}
|
||||||
|
input:focus, select:focus{
|
||||||
|
border-color:var(--bcs-accent);
|
||||||
|
box-shadow:0 0 0 2px color-mix(in srgb, var(--bcs-accent) 20%, transparent);
|
||||||
|
}
|
||||||
|
|
||||||
|
a{ color:var(--bcs-accent); text-decoration:none; }
|
||||||
|
a:hover{ text-decoration:underline; }
|
||||||
|
|
||||||
|
.fabs{
|
||||||
|
position: fixed;
|
||||||
|
right: 18px;
|
||||||
|
bottom: 18px;
|
||||||
|
display: grid;
|
||||||
|
gap: 10px;
|
||||||
|
z-index: 100;
|
||||||
|
}
|
||||||
|
.fab{
|
||||||
|
width: 56px;
|
||||||
|
height: 56px;
|
||||||
|
border-radius: 18px;
|
||||||
|
border: 1px solid var(--divider-color);
|
||||||
|
background: var(--card-background-color);
|
||||||
|
box-shadow: 0 12px 30px rgba(0,0,0,0.14);
|
||||||
|
display: inline-flex;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: center;
|
||||||
|
font-size: 18px;
|
||||||
|
font-weight: 900;
|
||||||
|
cursor: pointer;
|
||||||
|
user-select: none;
|
||||||
|
}
|
||||||
|
.fab.primary{
|
||||||
|
border-color: var(--bcs-accent);
|
||||||
|
background: color-mix(in srgb, var(--bcs-accent) 18%, var(--card-background-color));
|
||||||
|
}
|
||||||
|
.fab[disabled]{ opacity: .55; cursor: not-allowed; }
|
||||||
|
|
||||||
|
pre.readme{
|
||||||
|
white-space: pre-wrap;
|
||||||
|
word-break: break-word;
|
||||||
|
margin: 0;
|
||||||
|
font-family: ui-monospace, SFMono-Regular, Menlo, Monaco, Consolas, "Liberation Mono", "Courier New", monospace;
|
||||||
|
font-size: 12.5px;
|
||||||
|
line-height: 1.5;
|
||||||
|
}
|
||||||
|
details{ margin-top: 10px; }
|
||||||
|
summary{ cursor:pointer; color: var(--bcs-accent); font-weight: 900; }
|
||||||
|
|
||||||
|
.md { line-height: 1.65; font-size: 14px; }
|
||||||
|
.md :is(h1,h2,h3){ margin: 18px 0 10px; }
|
||||||
|
.md :is(p,ul,ol,pre,blockquote,table){ margin: 10px 0; }
|
||||||
|
.md pre { overflow:auto; padding:12px; border-radius:14px; border:1px solid var(--divider-color); }
|
||||||
|
.md code { padding:2px 6px; border-radius:8px; border:1px solid var(--divider-color); }
|
||||||
|
.md blockquote { border-left:4px solid var(--bcs-accent); padding:8px 12px; border-radius:12px;
|
||||||
|
background: color-mix(in srgb, var(--bcs-accent) 8%, var(--card-background-color)); }
|
||||||
|
.md table{ width:100%; border-collapse: collapse; }
|
||||||
|
.md th,.md td{ border:1px solid var(--divider-color); padding:8px; text-align:left; }
|
||||||
|
.md img{ max-width:100%; height:auto; border-radius:12px; }
|
||||||
|
</style>
|
||||||
|
|
||||||
|
<div class="mobilebar">
|
||||||
|
<div class="left">
|
||||||
|
<div class="iconbtn menu" id="menuBtn" title="Menu">☰</div>
|
||||||
|
<div class="iconbtn" id="backBtn" title="Back">←</div>
|
||||||
|
<div class="brandtitle">
|
||||||
|
<div class="t">Bahmcloud Store</div>
|
||||||
|
<div class="s" id="subtitle">BCS — loading…</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div class="right">
|
||||||
|
<button id="refreshBtn" class="primary">Refresh</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="wrap">
|
||||||
|
<div class="tabs" id="tabs">
|
||||||
|
<div class="tab" data-view="store">Store</div>
|
||||||
|
<div class="tab" data-view="manage">Manage repositories</div>
|
||||||
|
<div class="tab" data-view="about">Settings / About</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div id="content"></div>
|
||||||
|
<div id="error" class="error"></div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div id="fabs"></div>
|
||||||
`;
|
`;
|
||||||
|
|
||||||
root.appendChild(style);
|
root.getElementById("refreshBtn").addEventListener("click", () => this._load());
|
||||||
root.appendChild(iframe);
|
root.getElementById("menuBtn").addEventListener("click", () => this._toggleMenu());
|
||||||
|
root.getElementById("backBtn").addEventListener("click", () => this._goBack());
|
||||||
|
|
||||||
|
for (const tab of root.querySelectorAll(".tab")) {
|
||||||
|
tab.addEventListener("click", () => {
|
||||||
|
this._view = tab.getAttribute("data-view");
|
||||||
|
this._update();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
// prevent HA global shortcuts while typing
|
||||||
|
const stopIfFormField = (e) => {
|
||||||
|
const t = e.composedPath ? e.composedPath()[0] : e.target;
|
||||||
|
if (!t) return;
|
||||||
|
const tag = (t.tagName || "").toLowerCase();
|
||||||
|
const isEditable =
|
||||||
|
tag === "input" || tag === "textarea" || tag === "select" || t.isContentEditable;
|
||||||
|
if (isEditable) e.stopPropagation();
|
||||||
|
};
|
||||||
|
root.addEventListener("keydown", stopIfFormField, true);
|
||||||
|
root.addEventListener("keyup", stopIfFormField, true);
|
||||||
|
root.addEventListener("keypress", stopIfFormField, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
_captureFocusState() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
const ae = root.activeElement;
|
||||||
|
if (!ae || !ae.id) return null;
|
||||||
|
|
||||||
|
const supported = new Set(["searchInput", "categorySelect", "addUrl", "addName"]);
|
||||||
|
if (!supported.has(ae.id)) return null;
|
||||||
|
|
||||||
|
return {
|
||||||
|
id: ae.id,
|
||||||
|
value: ae.value,
|
||||||
|
selectionStart: typeof ae.selectionStart === "number" ? ae.selectionStart : null,
|
||||||
|
selectionEnd: typeof ae.selectionEnd === "number" ? ae.selectionEnd : null,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
_restoreFocusState(state) {
|
||||||
|
if (!state) return;
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
const el = root.getElementById(state.id);
|
||||||
|
if (!el) return;
|
||||||
|
|
||||||
|
try {
|
||||||
|
el.focus({ preventScroll: true });
|
||||||
|
if (
|
||||||
|
state.selectionStart !== null &&
|
||||||
|
state.selectionEnd !== null &&
|
||||||
|
typeof el.setSelectionRange === "function"
|
||||||
|
) {
|
||||||
|
el.setSelectionRange(state.selectionStart, state.selectionEnd);
|
||||||
|
}
|
||||||
|
} catch (_) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
_update() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
const focusState = this._captureFocusState();
|
||||||
|
|
||||||
|
const content = root.getElementById("content");
|
||||||
|
const err = root.getElementById("error");
|
||||||
|
const subtitle = root.getElementById("subtitle");
|
||||||
|
const fabs = root.getElementById("fabs");
|
||||||
|
|
||||||
|
const v = this._safeText(this._data?.version);
|
||||||
|
subtitle.textContent = v ? `BCS ${v}` : "BCS — loading…";
|
||||||
|
|
||||||
|
for (const tab of root.querySelectorAll(".tab")) {
|
||||||
|
tab.classList.toggle("active", tab.getAttribute("data-view") === this._view);
|
||||||
|
}
|
||||||
|
|
||||||
|
err.textContent = this._error ? `Error: ${this._error}` : "";
|
||||||
|
|
||||||
|
fabs.innerHTML = this._view === "detail" ? this._renderFabs() : "";
|
||||||
|
this._wireFabs();
|
||||||
|
|
||||||
|
if (this._loading) {
|
||||||
|
content.innerHTML = `<div class="card">Loading…</div>`;
|
||||||
|
this._restoreFocusState(focusState);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!this._data) {
|
||||||
|
content.innerHTML = `<div class="card">No data.</div>`;
|
||||||
|
this._restoreFocusState(focusState);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this._view === "store") {
|
||||||
|
content.innerHTML = this._renderStore();
|
||||||
|
this._wireStore();
|
||||||
|
this._restoreFocusState(focusState);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this._view === "manage") {
|
||||||
|
content.innerHTML = this._renderManage();
|
||||||
|
this._wireManage();
|
||||||
|
this._restoreFocusState(focusState);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this._view === "about") {
|
||||||
|
content.innerHTML = this._renderAbout();
|
||||||
|
this._restoreFocusState(focusState);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
content.innerHTML = this._renderDetail();
|
||||||
|
this._wireDetail();
|
||||||
|
this._restoreFocusState(focusState);
|
||||||
|
}
|
||||||
|
|
||||||
|
_renderStore() {
|
||||||
|
const repos = Array.isArray(this._data.repos) ? this._data.repos : [];
|
||||||
|
const categories = this._computeCategories(repos);
|
||||||
|
const stats = this._computeProviderStats(repos);
|
||||||
|
|
||||||
|
const filtered = repos
|
||||||
|
.filter((r) => {
|
||||||
|
const q = (this._search || "").trim().toLowerCase();
|
||||||
|
if (!q) return true;
|
||||||
|
const hay = `${this._safeText(r?.name)} ${this._safeText(r?.description)} ${this._safeText(r?.url)} ${this._safeText(r?.owner)}`.toLowerCase();
|
||||||
|
return hay.includes(q);
|
||||||
|
})
|
||||||
|
.filter((r) => {
|
||||||
|
if (this._category === "all") return true;
|
||||||
|
return this._safeLower(r?.category) === this._category;
|
||||||
|
})
|
||||||
|
.filter((r) => {
|
||||||
|
if (this._provider === "all") return true;
|
||||||
|
if (this._provider === "custom") return r?.source === "custom";
|
||||||
|
return this._safeLower(r?.provider) === this._provider;
|
||||||
|
});
|
||||||
|
|
||||||
|
const options = [
|
||||||
|
`<option value="all"${this._category === "all" ? " selected" : ""}>All categories</option>`,
|
||||||
|
...categories.map(
|
||||||
|
(c) =>
|
||||||
|
`<option value="${this._esc(c)}"${
|
||||||
|
this._category === c ? " selected" : ""
|
||||||
|
}>${this._esc(c)}</option>`
|
||||||
|
),
|
||||||
|
].join("");
|
||||||
|
|
||||||
|
const providerChips = this._renderProviderChips(stats);
|
||||||
|
|
||||||
|
const rows = filtered
|
||||||
|
.map((r) => {
|
||||||
|
const id = this._safeId(r?.id);
|
||||||
|
const name = this._safeText(r?.name) || "Unnamed repository";
|
||||||
|
const desc = this._safeText(r?.description) || "No description available.";
|
||||||
|
|
||||||
|
const badge =
|
||||||
|
r?.source === "custom"
|
||||||
|
? `<span class="badge custom">Custom</span>`
|
||||||
|
: `<span class="badge">Index</span>`;
|
||||||
|
|
||||||
|
const creator = this._safeText(r?.owner) ? `Creator: ${this._safeText(r?.owner)}` : "Creator: -";
|
||||||
|
const latest = this._safeText(r?.latest_version) ? `Latest: ${this._safeText(r?.latest_version)}` : "Latest: unknown";
|
||||||
|
const cat = this._safeText(r?.category) ? `Category: ${this._safeText(r?.category)}` : null;
|
||||||
|
const metaSrc = this._safeText(r?.meta_source) ? `Meta: ${this._safeText(r?.meta_source)}` : null;
|
||||||
|
|
||||||
|
const lineBits = [creator, latest, cat, metaSrc].filter(Boolean);
|
||||||
|
|
||||||
|
return `
|
||||||
|
<div class="card clickable" data-repo="${this._esc(id)}">
|
||||||
|
<div class="row">
|
||||||
|
<div>
|
||||||
|
<div><strong>${this._esc(name)}</strong></div>
|
||||||
|
<div class="muted">${this._esc(desc)}</div>
|
||||||
|
<div class="muted small">${this._esc(lineBits.join(" · "))}</div>
|
||||||
|
</div>
|
||||||
|
${badge}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
})
|
||||||
|
.join("");
|
||||||
|
|
||||||
|
return `
|
||||||
|
<div class="card">
|
||||||
|
<div><strong>Providers</strong></div>
|
||||||
|
<div class="chips" id="providerChips">${providerChips}</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="filters">
|
||||||
|
<input id="searchInput" placeholder="Search repositories…" value="${this._esc(this._search)}" />
|
||||||
|
<select id="categorySelect">${options}</select>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
${rows || `<div class="card">No repositories match this filter.</div>`}
|
||||||
|
`;
|
||||||
|
}
|
||||||
|
|
||||||
|
_wireStore() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
const search = root.getElementById("searchInput");
|
||||||
|
const cat = root.getElementById("categorySelect");
|
||||||
|
const chips = root.getElementById("providerChips");
|
||||||
|
|
||||||
|
if (search) {
|
||||||
|
search.addEventListener("input", (e) => {
|
||||||
|
this._search = e.target.value;
|
||||||
|
this._update();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (cat) {
|
||||||
|
cat.addEventListener("change", (e) => {
|
||||||
|
this._category = String(e.target.value || "all");
|
||||||
|
this._update();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (chips) {
|
||||||
|
for (const c of chips.querySelectorAll("[data-prov]")) {
|
||||||
|
c.addEventListener("click", () => {
|
||||||
|
const key = c.getAttribute("data-prov");
|
||||||
|
if (!key) return;
|
||||||
|
this._provider = key;
|
||||||
|
this._update();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for (const card of root.querySelectorAll("[data-repo]")) {
|
||||||
|
card.addEventListener("click", () => {
|
||||||
|
const id = card.getAttribute("data-repo");
|
||||||
|
if (id) this._openRepoDetail(id);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
_renderProviderChips(stats) {
|
||||||
|
const order = ["all", "github", "gitea", "gitlab", "other", "custom"];
|
||||||
|
const labels = {
|
||||||
|
all: "All",
|
||||||
|
github: "GitHub",
|
||||||
|
gitea: "Gitea",
|
||||||
|
gitlab: "GitLab",
|
||||||
|
other: "Other",
|
||||||
|
custom: "Custom",
|
||||||
|
};
|
||||||
|
const values = {
|
||||||
|
all: stats.total,
|
||||||
|
github: stats.github,
|
||||||
|
gitea: stats.gitea,
|
||||||
|
gitlab: stats.gitlab,
|
||||||
|
other: stats.other,
|
||||||
|
custom: stats.custom,
|
||||||
|
};
|
||||||
|
|
||||||
|
return order
|
||||||
|
.map((key) => {
|
||||||
|
const count = values[key] ?? 0;
|
||||||
|
const active = this._provider === key ? " active" : "";
|
||||||
|
return `<div class="chip${active}" data-prov="${key}"><strong>${labels[key]}</strong> ${count}</div>`;
|
||||||
|
})
|
||||||
|
.join("");
|
||||||
|
}
|
||||||
|
|
||||||
|
_computeProviderStats(repos) {
|
||||||
|
const s = { total: 0, github: 0, gitea: 0, gitlab: 0, other: 0, custom: 0 };
|
||||||
|
if (!Array.isArray(repos)) return s;
|
||||||
|
|
||||||
|
for (const r of repos) {
|
||||||
|
s.total += 1;
|
||||||
|
|
||||||
|
if (r?.source === "custom") s.custom += 1;
|
||||||
|
|
||||||
|
const p = this._safeLower(r?.provider) || "other";
|
||||||
|
if (p === "github") s.github += 1;
|
||||||
|
else if (p === "gitea") s.gitea += 1;
|
||||||
|
else if (p === "gitlab") s.gitlab += 1;
|
||||||
|
else s.other += 1;
|
||||||
|
}
|
||||||
|
return s;
|
||||||
|
}
|
||||||
|
|
||||||
|
_renderDetail() {
|
||||||
|
const r = this._detailRepo;
|
||||||
|
if (!r) return `<div class="card">Repository not found.</div>`;
|
||||||
|
|
||||||
|
const name = this._safeText(r?.name) || "Unnamed repository";
|
||||||
|
const desc = this._safeText(r?.description) || "No description available.";
|
||||||
|
const url = this._safeText(r?.url) || "#";
|
||||||
|
|
||||||
|
const badge =
|
||||||
|
r?.source === "custom"
|
||||||
|
? `<span class="badge custom">Custom</span>`
|
||||||
|
: `<span class="badge">Index</span>`;
|
||||||
|
|
||||||
|
const latest = this._safeText(r?.latest_version) ? `Latest: ${this._safeText(r?.latest_version)}` : "Latest: unknown";
|
||||||
|
|
||||||
|
const infoBits = [
|
||||||
|
this._safeText(r?.owner) ? `Creator: ${this._safeText(r?.owner)}` : "Creator: -",
|
||||||
|
latest,
|
||||||
|
this._safeText(r?.provider) ? `Provider: ${this._safeText(r?.provider)}` : null,
|
||||||
|
this._safeText(r?.category) ? `Category: ${this._safeText(r?.category)}` : null,
|
||||||
|
this._safeText(r?.meta_author) ? `Author: ${this._safeText(r?.meta_author)}` : null,
|
||||||
|
this._safeText(r?.meta_maintainer) ? `Maintainer: ${this._safeText(r?.meta_maintainer)}` : null,
|
||||||
|
this._safeText(r?.meta_source) ? `Meta: ${this._safeText(r?.meta_source)}` : null,
|
||||||
|
].filter(Boolean);
|
||||||
|
|
||||||
|
const readmeBlock = this._readmeLoading
|
||||||
|
? `<div class="card">Loading README…</div>`
|
||||||
|
: this._readmeText
|
||||||
|
? `
|
||||||
|
<div class="card">
|
||||||
|
<div class="row" style="align-items:center;">
|
||||||
|
<div><strong>README</strong></div>
|
||||||
|
<div class="muted small">Rendered Markdown</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div id="readmePretty" class="md" style="margin-top:12px;"></div>
|
||||||
|
|
||||||
|
<details>
|
||||||
|
<summary>Show raw Markdown</summary>
|
||||||
|
<div style="margin-top:10px;">
|
||||||
|
<pre class="readme">${this._esc(this._readmeText)}</pre>
|
||||||
|
</div>
|
||||||
|
</details>
|
||||||
|
</div>
|
||||||
|
`
|
||||||
|
: `
|
||||||
|
<div class="card">
|
||||||
|
<div><strong>README</strong></div>
|
||||||
|
<div class="muted">${this._esc(this._readmeError || "README not found.")}</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
|
||||||
|
return `
|
||||||
|
<div class="grid2">
|
||||||
|
<div>
|
||||||
|
<div class="card">
|
||||||
|
<div class="row">
|
||||||
|
<div>
|
||||||
|
<div><strong style="font-size:16px;">${this._esc(name)}</strong></div>
|
||||||
|
<div class="muted">${this._esc(desc)}</div>
|
||||||
|
<div class="muted small" style="margin-top:8px;">${this._esc(infoBits.join(" · "))}</div>
|
||||||
|
<div class="muted small" style="margin-top:8px;">
|
||||||
|
<a href="${this._esc(url)}" target="_blank" rel="noreferrer">Open repository</a>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
${badge}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
${readmeBlock}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div>
|
||||||
|
<div class="card">
|
||||||
|
<div><strong>Installation & Updates</strong></div>
|
||||||
|
<div class="muted">
|
||||||
|
Installation and updates are performed manually via <strong>Settings → System → Updates</strong>.
|
||||||
|
The Store UI is used to browse repositories and trigger installation/update actions.
|
||||||
|
</div>
|
||||||
|
<div class="muted small" style="margin-top:10px;">
|
||||||
|
Updates remain manual (like HACS).
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
}
|
||||||
|
|
||||||
|
_wireDetail() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
const mount = root.getElementById("readmePretty");
|
||||||
|
if (!mount) return;
|
||||||
|
|
||||||
|
if (this._readmeText) {
|
||||||
|
// Client renderer may be unavailable; prefer server-provided HTML
|
||||||
|
if (this._readmeHtml) {
|
||||||
|
mount.innerHTML = this._readmeHtml;
|
||||||
|
this._postprocessRenderedMarkdown(mount);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
mount.innerHTML = `<div class="muted">Rendered HTML not available. Use “Show raw Markdown”.</div>`;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
mount.innerHTML = "";
|
||||||
|
}
|
||||||
|
|
||||||
|
_postprocessRenderedMarkdown(container) {
|
||||||
|
if (!container) return;
|
||||||
|
try {
|
||||||
|
const links = container.querySelectorAll("a[href]");
|
||||||
|
links.forEach((a) => {
|
||||||
|
a.setAttribute("target", "_blank");
|
||||||
|
a.setAttribute("rel", "noreferrer noopener");
|
||||||
|
});
|
||||||
|
} catch (_) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
_renderFabs() {
|
||||||
|
const r = this._detailRepo;
|
||||||
|
if (!r) return "";
|
||||||
|
|
||||||
|
return `
|
||||||
|
<div class="fabs">
|
||||||
|
<div class="fab primary" id="fabOpen" title="Open repository">↗</div>
|
||||||
|
<div class="fab" id="fabReload" title="Reload README">⟳</div>
|
||||||
|
<div class="fab" id="fabInstall" title="Install (coming soon)" disabled>+</div>
|
||||||
|
<div class="fab" id="fabUpdate" title="Update (coming soon)" disabled>↑</div>
|
||||||
|
<div class="fab" id="fabInfo" title="About">i</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
}
|
||||||
|
|
||||||
|
_wireFabs() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
const r = this._detailRepo;
|
||||||
|
if (!r) return;
|
||||||
|
|
||||||
|
const url = this._safeText(r?.url);
|
||||||
|
|
||||||
|
const open = root.getElementById("fabOpen");
|
||||||
|
const reload = root.getElementById("fabReload");
|
||||||
|
const info = root.getElementById("fabInfo");
|
||||||
|
|
||||||
|
if (open) open.addEventListener("click", () => url && window.open(url, "_blank", "noreferrer"));
|
||||||
|
if (reload) {
|
||||||
|
reload.addEventListener("click", () => {
|
||||||
|
if (this._detailRepoId) this._loadReadme(this._detailRepoId);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (info) {
|
||||||
|
info.addEventListener("click", () => {
|
||||||
|
this._view = "about";
|
||||||
|
this._update();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
_renderManage() {
|
||||||
|
const repos = Array.isArray(this._data.repos) ? this._data.repos : [];
|
||||||
|
const custom = repos.filter((r) => r?.source === "custom");
|
||||||
|
|
||||||
|
const list = custom
|
||||||
|
.map((r) => {
|
||||||
|
const id = this._safeId(r?.id);
|
||||||
|
const name = this._safeText(r?.name) || "Unnamed repository";
|
||||||
|
const url = this._safeText(r?.url) || "";
|
||||||
|
return `
|
||||||
|
<div class="card">
|
||||||
|
<div class="row">
|
||||||
|
<div>
|
||||||
|
<div><strong>${this._esc(name)}</strong></div>
|
||||||
|
<div class="muted">${this._esc(url)}</div>
|
||||||
|
</div>
|
||||||
|
<div>
|
||||||
|
<button class="primary" data-remove="${this._esc(id)}">Remove</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
})
|
||||||
|
.join("");
|
||||||
|
|
||||||
|
return `
|
||||||
|
<div class="card">
|
||||||
|
<div><strong>Manage repositories</strong></div>
|
||||||
|
<div class="muted">Add public repositories from any git provider.</div>
|
||||||
|
|
||||||
|
<div style="display:grid; gap:10px; margin-top:12px;">
|
||||||
|
<div>
|
||||||
|
<div class="muted small">Repository URL</div>
|
||||||
|
<input id="addUrl" placeholder="https://github.com/user/repo" value="${this._esc(this._customAddUrl)}" />
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div>
|
||||||
|
<div class="muted small">Display name (optional)</div>
|
||||||
|
<input id="addName" placeholder="My Integration" value="${this._esc(this._customAddName)}" />
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div>
|
||||||
|
<button id="addBtn" class="primary">Add repository</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
${list || `<div class="card">No custom repositories added yet.</div>`}
|
||||||
|
`;
|
||||||
|
}
|
||||||
|
|
||||||
|
_wireManage() {
|
||||||
|
const root = this.shadowRoot;
|
||||||
|
|
||||||
|
const addUrl = root.getElementById("addUrl");
|
||||||
|
const addName = root.getElementById("addName");
|
||||||
|
const addBtn = root.getElementById("addBtn");
|
||||||
|
|
||||||
|
if (addUrl) addUrl.addEventListener("input", (e) => (this._customAddUrl = e.target.value));
|
||||||
|
if (addName) addName.addEventListener("input", (e) => (this._customAddName = e.target.value));
|
||||||
|
if (addBtn) addBtn.addEventListener("click", () => this._addCustomRepo());
|
||||||
|
|
||||||
|
for (const btn of root.querySelectorAll("[data-remove]")) {
|
||||||
|
btn.addEventListener("click", () => {
|
||||||
|
const id = btn.getAttribute("data-remove");
|
||||||
|
if (id) this._removeCustomRepo(id);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
_renderAbout() {
|
||||||
|
const v = this._safeText(this._data?.version) || "-";
|
||||||
|
return `
|
||||||
|
<div class="card">
|
||||||
|
<div><strong>Settings / About</strong></div>
|
||||||
|
<div class="muted">Language: English (v1). i18n will be added later.</div>
|
||||||
|
<div class="muted">Theme: follows Home Assistant light/dark automatically.</div>
|
||||||
|
<div class="muted">Accent: Bahmcloud Blue.</div>
|
||||||
|
<div class="muted small" style="margin-top: 10px;">BCS version: ${this._esc(v)}</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
}
|
||||||
|
|
||||||
|
_computeCategories(repos) {
|
||||||
|
const set = new Set();
|
||||||
|
for (const r of repos) {
|
||||||
|
const c = this._safeLower(r?.category);
|
||||||
|
if (c) set.add(c);
|
||||||
|
}
|
||||||
|
return Array.from(set).sort();
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- HARDENING HELPERS (fixes [object Object]) ---
|
||||||
|
_safeText(v) {
|
||||||
|
if (v === null || v === undefined) return "";
|
||||||
|
const t = typeof v;
|
||||||
|
if (t === "string") return v;
|
||||||
|
if (t === "number" || t === "boolean") return String(v);
|
||||||
|
return ""; // objects/arrays/functions => empty (prevents [object Object])
|
||||||
|
}
|
||||||
|
|
||||||
|
_safeLower(v) {
|
||||||
|
const s = this._safeText(v);
|
||||||
|
return s ? s.trim().toLowerCase() : "";
|
||||||
|
}
|
||||||
|
|
||||||
|
_safeId(v) {
|
||||||
|
const s = this._safeText(v);
|
||||||
|
return s || "";
|
||||||
|
}
|
||||||
|
|
||||||
|
_esc(s) {
|
||||||
|
return String(s ?? "")
|
||||||
|
.replaceAll("&", "&")
|
||||||
|
.replaceAll("<", "<")
|
||||||
|
.replaceAll(">", ">")
|
||||||
|
.replaceAll('"', """)
|
||||||
|
.replaceAll("'", "'");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,8 +1,10 @@
|
|||||||
body { font-family: system-ui, sans-serif; margin:0; }
|
body { font-family: system-ui, sans-serif; margin:0; }
|
||||||
.wrap { padding: 16px; max-width: 1000px; margin: 0 auto; }
|
.wrap { padding: 16px; max-width: 1000px; margin: 0 auto; }
|
||||||
.card { border: 1px solid #ddd; border-radius: 10px; padding: 12px; margin: 10px 0; }
|
.card { border: 1px solid #ddd; border-radius: 10px; padding: 12px; margin: 10px 0; }
|
||||||
.row { display:flex; justify-content:space-between; gap: 12px; }
|
.row { display:flex; justify-content:space-between; gap: 12px; align-items: flex-start; }
|
||||||
.badge { border: 1px solid #bbb; border-radius: 999px; padding: 2px 8px; font-size: 12px; }
|
.badge { border: 1px solid #bbb; border-radius: 999px; padding: 2px 8px; font-size: 12px; height: fit-content; }
|
||||||
.muted { color: #666; font-size: 13px; }
|
.muted { color: #666; font-size: 13px; margin-top: 4px; }
|
||||||
|
.actions { display:flex; gap: 8px; margin-top: 10px; }
|
||||||
button { padding: 8px 12px; cursor:pointer; }
|
button { padding: 8px 12px; cursor:pointer; }
|
||||||
|
button[disabled] { opacity: 0.6; cursor: not-allowed; }
|
||||||
a { color: inherit; }
|
a { color: inherit; }
|
||||||
|
|||||||
378
custom_components/bahmcloud_store/providers.py
Normal file
378
custom_components/bahmcloud_store/providers.py
Normal file
@@ -0,0 +1,378 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import logging
|
||||||
|
import re
|
||||||
|
import xml.etree.ElementTree as ET
|
||||||
|
from dataclasses import dataclass
|
||||||
|
from urllib.parse import quote_plus, urlparse
|
||||||
|
|
||||||
|
from homeassistant.core import HomeAssistant
|
||||||
|
from homeassistant.helpers.aiohttp_client import async_get_clientsession
|
||||||
|
|
||||||
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
UA = "BahmcloudStore (Home Assistant)"
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class RepoInfo:
|
||||||
|
owner: str | None = None
|
||||||
|
repo_name: str | None = None
|
||||||
|
description: str | None = None
|
||||||
|
provider: str | None = None
|
||||||
|
default_branch: str | None = None
|
||||||
|
|
||||||
|
latest_version: str | None = None
|
||||||
|
latest_version_source: str | None = None # "release" | "tag" | "atom" | None
|
||||||
|
|
||||||
|
|
||||||
|
def _normalize_repo_name(name: str | None) -> str | None:
|
||||||
|
if not name:
|
||||||
|
return None
|
||||||
|
n = name.strip()
|
||||||
|
if n.endswith(".git"):
|
||||||
|
n = n[:-4]
|
||||||
|
return n or None
|
||||||
|
|
||||||
|
|
||||||
|
def _split_owner_repo(repo_url: str) -> tuple[str | None, str | None]:
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
parts = [p for p in u.path.strip("/").split("/") if p]
|
||||||
|
if len(parts) < 2:
|
||||||
|
return None, None
|
||||||
|
owner = parts[0].strip() or None
|
||||||
|
repo = _normalize_repo_name(parts[1])
|
||||||
|
return owner, repo
|
||||||
|
|
||||||
|
|
||||||
|
def detect_provider(repo_url: str) -> str:
|
||||||
|
host = urlparse(repo_url).netloc.lower()
|
||||||
|
if "github.com" in host:
|
||||||
|
return "github"
|
||||||
|
if "gitlab" in host:
|
||||||
|
return "gitlab"
|
||||||
|
|
||||||
|
owner, repo = _split_owner_repo(repo_url)
|
||||||
|
if owner and repo:
|
||||||
|
return "gitea"
|
||||||
|
|
||||||
|
return "generic"
|
||||||
|
|
||||||
|
|
||||||
|
async def _safe_json(session, url: str, *, headers: dict | None = None, timeout: int = 20):
|
||||||
|
try:
|
||||||
|
async with session.get(url, timeout=timeout, headers=headers) as resp:
|
||||||
|
status = resp.status
|
||||||
|
if status != 200:
|
||||||
|
return None, status
|
||||||
|
return await resp.json(), status
|
||||||
|
except Exception:
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
async def _safe_text(session, url: str, *, headers: dict | None = None, timeout: int = 20):
|
||||||
|
try:
|
||||||
|
async with session.get(url, timeout=timeout, headers=headers) as resp:
|
||||||
|
status = resp.status
|
||||||
|
if status != 200:
|
||||||
|
return None, status
|
||||||
|
return await resp.text(), status
|
||||||
|
except Exception:
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
def _extract_tag_from_github_url(url: str) -> str | None:
|
||||||
|
m = re.search(r"/releases/tag/([^/?#]+)", url)
|
||||||
|
if m:
|
||||||
|
return m.group(1)
|
||||||
|
m = re.search(r"/tag/([^/?#]+)", url)
|
||||||
|
if m:
|
||||||
|
return m.group(1)
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
def _strip_html(s: str) -> str:
|
||||||
|
# minimal HTML entity cleanup for meta descriptions
|
||||||
|
out = (
|
||||||
|
s.replace("&", "&")
|
||||||
|
.replace(""", '"')
|
||||||
|
.replace("'", "'")
|
||||||
|
.replace("<", "<")
|
||||||
|
.replace(">", ">")
|
||||||
|
)
|
||||||
|
return re.sub(r"\s+", " ", out).strip()
|
||||||
|
|
||||||
|
|
||||||
|
def _extract_meta(html: str, *, prop: str | None = None, name: str | None = None) -> str | None:
|
||||||
|
# Extract <meta property="og:description" content="...">
|
||||||
|
# or <meta name="description" content="...">
|
||||||
|
if prop:
|
||||||
|
# property="..." content="..."
|
||||||
|
m = re.search(
|
||||||
|
r'<meta[^>]+property=["\']' + re.escape(prop) + r'["\'][^>]+content=["\']([^"\']+)["\']',
|
||||||
|
html,
|
||||||
|
flags=re.IGNORECASE,
|
||||||
|
)
|
||||||
|
if m:
|
||||||
|
return _strip_html(m.group(1))
|
||||||
|
m = re.search(
|
||||||
|
r'<meta[^>]+content=["\']([^"\']+)["\'][^>]+property=["\']' + re.escape(prop) + r'["\']',
|
||||||
|
html,
|
||||||
|
flags=re.IGNORECASE,
|
||||||
|
)
|
||||||
|
if m:
|
||||||
|
return _strip_html(m.group(1))
|
||||||
|
|
||||||
|
if name:
|
||||||
|
m = re.search(
|
||||||
|
r'<meta[^>]+name=["\']' + re.escape(name) + r'["\'][^>]+content=["\']([^"\']+)["\']',
|
||||||
|
html,
|
||||||
|
flags=re.IGNORECASE,
|
||||||
|
)
|
||||||
|
if m:
|
||||||
|
return _strip_html(m.group(1))
|
||||||
|
m = re.search(
|
||||||
|
r'<meta[^>]+content=["\']([^"\']+)["\'][^>]+name=["\']' + re.escape(name) + r'["\']',
|
||||||
|
html,
|
||||||
|
flags=re.IGNORECASE,
|
||||||
|
)
|
||||||
|
if m:
|
||||||
|
return _strip_html(m.group(1))
|
||||||
|
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
async def _github_description_html(hass: HomeAssistant, owner: str, repo: str) -> str | None:
|
||||||
|
"""
|
||||||
|
GitHub API may be rate-limited; fetch public HTML and read meta description.
|
||||||
|
"""
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
headers = {
|
||||||
|
"User-Agent": UA,
|
||||||
|
"Accept": "text/html,application/xhtml+xml",
|
||||||
|
}
|
||||||
|
|
||||||
|
html, status = await _safe_text(session, f"https://github.com/{owner}/{repo}", headers=headers)
|
||||||
|
if not html or status != 200:
|
||||||
|
return None
|
||||||
|
|
||||||
|
desc = _extract_meta(html, prop="og:description")
|
||||||
|
if desc:
|
||||||
|
return desc
|
||||||
|
|
||||||
|
desc = _extract_meta(html, name="description")
|
||||||
|
if desc:
|
||||||
|
return desc
|
||||||
|
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
async def _github_latest_version_atom(hass: HomeAssistant, owner: str, repo: str) -> tuple[str | None, str | None]:
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
headers = {"User-Agent": UA, "Accept": "application/atom+xml,text/xml;q=0.9,*/*;q=0.8"}
|
||||||
|
|
||||||
|
xml_text, _ = await _safe_text(session, f"https://github.com/{owner}/{repo}/releases.atom", headers=headers)
|
||||||
|
if not xml_text:
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
try:
|
||||||
|
root = ET.fromstring(xml_text)
|
||||||
|
except Exception:
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
for entry in root.findall(".//{*}entry"):
|
||||||
|
for link in entry.findall(".//{*}link"):
|
||||||
|
href = link.attrib.get("href")
|
||||||
|
if not href:
|
||||||
|
continue
|
||||||
|
tag = _extract_tag_from_github_url(href)
|
||||||
|
if tag:
|
||||||
|
return tag, "atom"
|
||||||
|
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
async def _github_latest_version_redirect(hass: HomeAssistant, owner: str, repo: str) -> tuple[str | None, str | None]:
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
headers = {"User-Agent": UA}
|
||||||
|
url = f"https://github.com/{owner}/{repo}/releases/latest"
|
||||||
|
try:
|
||||||
|
async with session.head(url, allow_redirects=False, timeout=15, headers=headers) as resp:
|
||||||
|
if resp.status in (301, 302, 303, 307, 308):
|
||||||
|
loc = resp.headers.get("Location")
|
||||||
|
if loc:
|
||||||
|
tag = _extract_tag_from_github_url(loc)
|
||||||
|
if tag:
|
||||||
|
return tag, "release"
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
async def _github_latest_version_api(hass: HomeAssistant, owner: str, repo: str) -> tuple[str | None, str | None]:
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
headers = {"Accept": "application/vnd.github+json", "User-Agent": UA}
|
||||||
|
|
||||||
|
data, _ = await _safe_json(session, f"https://api.github.com/repos/{owner}/{repo}/releases/latest", headers=headers)
|
||||||
|
if isinstance(data, dict):
|
||||||
|
tag = data.get("tag_name") or data.get("name")
|
||||||
|
if isinstance(tag, str) and tag.strip():
|
||||||
|
return tag.strip(), "release"
|
||||||
|
|
||||||
|
data, _ = await _safe_json(session, f"https://api.github.com/repos/{owner}/{repo}/tags?per_page=1", headers=headers)
|
||||||
|
if isinstance(data, list) and data:
|
||||||
|
tag = data[0].get("name")
|
||||||
|
if isinstance(tag, str) and tag.strip():
|
||||||
|
return tag.strip(), "tag"
|
||||||
|
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
async def _github_latest_version(hass: HomeAssistant, owner: str, repo: str) -> tuple[str | None, str | None]:
|
||||||
|
tag, src = await _github_latest_version_atom(hass, owner, repo)
|
||||||
|
if tag:
|
||||||
|
return tag, src
|
||||||
|
|
||||||
|
tag, src = await _github_latest_version_redirect(hass, owner, repo)
|
||||||
|
if tag:
|
||||||
|
return tag, src
|
||||||
|
|
||||||
|
return await _github_latest_version_api(hass, owner, repo)
|
||||||
|
|
||||||
|
|
||||||
|
async def _gitea_latest_version(hass: HomeAssistant, base: str, owner: str, repo: str) -> tuple[str | None, str | None]:
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
|
||||||
|
data, _ = await _safe_json(session, f"{base}/api/v1/repos/{owner}/{repo}/releases?limit=1")
|
||||||
|
if isinstance(data, list) and data:
|
||||||
|
tag = data[0].get("tag_name") or data[0].get("name")
|
||||||
|
if isinstance(tag, str) and tag.strip():
|
||||||
|
return tag.strip(), "release"
|
||||||
|
|
||||||
|
data, _ = await _safe_json(session, f"{base}/api/v1/repos/{owner}/{repo}/tags?limit=1")
|
||||||
|
if isinstance(data, list) and data:
|
||||||
|
tag = data[0].get("name")
|
||||||
|
if isinstance(tag, str) and tag.strip():
|
||||||
|
return tag.strip(), "tag"
|
||||||
|
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
async def _gitlab_latest_version(hass: HomeAssistant, base: str, owner: str, repo: str) -> tuple[str | None, str | None]:
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
headers = {"User-Agent": UA}
|
||||||
|
project = quote_plus(f"{owner}/{repo}")
|
||||||
|
|
||||||
|
data, _ = await _safe_json(
|
||||||
|
session,
|
||||||
|
f"{base}/api/v4/projects/{project}/releases?per_page=1&order_by=released_at&sort=desc",
|
||||||
|
headers=headers,
|
||||||
|
)
|
||||||
|
if isinstance(data, list) and data:
|
||||||
|
tag = data[0].get("tag_name") or data[0].get("name")
|
||||||
|
if isinstance(tag, str) and tag.strip():
|
||||||
|
return tag.strip(), "release"
|
||||||
|
|
||||||
|
data, _ = await _safe_json(
|
||||||
|
session,
|
||||||
|
f"{base}/api/v4/projects/{project}/repository/tags?per_page=1&order_by=updated&sort=desc",
|
||||||
|
headers=headers,
|
||||||
|
)
|
||||||
|
if isinstance(data, list) and data:
|
||||||
|
tag = data[0].get("name")
|
||||||
|
if isinstance(tag, str) and tag.strip():
|
||||||
|
return tag.strip(), "tag"
|
||||||
|
|
||||||
|
return None, None
|
||||||
|
|
||||||
|
|
||||||
|
async def fetch_repo_info(hass: HomeAssistant, repo_url: str) -> RepoInfo:
|
||||||
|
provider = detect_provider(repo_url)
|
||||||
|
owner, repo = _split_owner_repo(repo_url)
|
||||||
|
|
||||||
|
info = RepoInfo(
|
||||||
|
owner=owner,
|
||||||
|
repo_name=repo,
|
||||||
|
description=None,
|
||||||
|
provider=provider,
|
||||||
|
default_branch=None,
|
||||||
|
latest_version=None,
|
||||||
|
latest_version_source=None,
|
||||||
|
)
|
||||||
|
|
||||||
|
if not owner or not repo:
|
||||||
|
return info
|
||||||
|
|
||||||
|
session = async_get_clientsession(hass)
|
||||||
|
|
||||||
|
try:
|
||||||
|
if provider == "github":
|
||||||
|
# Try API repo details (may be rate-limited)
|
||||||
|
headers = {"Accept": "application/vnd.github+json", "User-Agent": UA}
|
||||||
|
data, status = await _safe_json(session, f"https://api.github.com/repos/{owner}/{repo}", headers=headers)
|
||||||
|
|
||||||
|
if isinstance(data, dict):
|
||||||
|
info.description = data.get("description")
|
||||||
|
info.repo_name = _normalize_repo_name(data.get("name")) or repo
|
||||||
|
info.default_branch = data.get("default_branch") or "main"
|
||||||
|
if isinstance(data.get("owner"), dict) and data["owner"].get("login"):
|
||||||
|
info.owner = data["owner"]["login"]
|
||||||
|
else:
|
||||||
|
# If API blocked, still set reasonable defaults
|
||||||
|
if status == 403:
|
||||||
|
_LOGGER.debug("GitHub API blocked/rate-limited for repo info %s/%s", owner, repo)
|
||||||
|
info.default_branch = "main"
|
||||||
|
|
||||||
|
# If description missing, fetch from GitHub HTML
|
||||||
|
if not info.description:
|
||||||
|
desc = await _github_description_html(hass, owner, repo)
|
||||||
|
if desc:
|
||||||
|
info.description = desc
|
||||||
|
|
||||||
|
ver, src = await _github_latest_version(hass, owner, repo)
|
||||||
|
info.latest_version = ver
|
||||||
|
info.latest_version_source = src
|
||||||
|
return info
|
||||||
|
|
||||||
|
if provider == "gitlab":
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
base = f"{u.scheme}://{u.netloc}"
|
||||||
|
headers = {"User-Agent": UA}
|
||||||
|
project = quote_plus(f"{owner}/{repo}")
|
||||||
|
|
||||||
|
data, _ = await _safe_json(session, f"{base}/api/v4/projects/{project}", headers=headers)
|
||||||
|
if isinstance(data, dict):
|
||||||
|
info.description = data.get("description")
|
||||||
|
info.repo_name = _normalize_repo_name(data.get("path")) or repo
|
||||||
|
info.default_branch = data.get("default_branch") or "main"
|
||||||
|
ns = data.get("namespace")
|
||||||
|
if isinstance(ns, dict) and ns.get("path"):
|
||||||
|
info.owner = ns.get("path")
|
||||||
|
|
||||||
|
ver, src = await _gitlab_latest_version(hass, base, owner, repo)
|
||||||
|
info.latest_version = ver
|
||||||
|
info.latest_version_source = src
|
||||||
|
return info
|
||||||
|
|
||||||
|
if provider == "gitea":
|
||||||
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
|
base = f"{u.scheme}://{u.netloc}"
|
||||||
|
|
||||||
|
data, _ = await _safe_json(session, f"{base}/api/v1/repos/{owner}/{repo}")
|
||||||
|
if isinstance(data, dict):
|
||||||
|
info.description = data.get("description")
|
||||||
|
info.repo_name = _normalize_repo_name(data.get("name")) or repo
|
||||||
|
info.default_branch = data.get("default_branch") or "main"
|
||||||
|
if isinstance(data.get("owner"), dict) and data["owner"].get("login"):
|
||||||
|
info.owner = data["owner"]["login"]
|
||||||
|
|
||||||
|
ver, src = await _gitea_latest_version(hass, base, owner, repo)
|
||||||
|
info.latest_version = ver
|
||||||
|
info.latest_version_source = src
|
||||||
|
return info
|
||||||
|
|
||||||
|
return info
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
_LOGGER.debug("Provider fetch failed for %s: %s", repo_url, e)
|
||||||
|
return info
|
||||||
78
custom_components/bahmcloud_store/storage.py
Normal file
78
custom_components/bahmcloud_store/storage.py
Normal file
@@ -0,0 +1,78 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import uuid
|
||||||
|
from dataclasses import dataclass
|
||||||
|
from typing import Any
|
||||||
|
|
||||||
|
from homeassistant.core import HomeAssistant
|
||||||
|
from homeassistant.helpers.storage import Store
|
||||||
|
|
||||||
|
_STORAGE_VERSION = 1
|
||||||
|
_STORAGE_KEY = "bcs_store"
|
||||||
|
|
||||||
|
|
||||||
|
@dataclass
|
||||||
|
class CustomRepo:
|
||||||
|
id: str
|
||||||
|
url: str
|
||||||
|
name: str | None = None
|
||||||
|
|
||||||
|
|
||||||
|
class BCSStorage:
|
||||||
|
"""Persistent storage for manually added repositories."""
|
||||||
|
|
||||||
|
def __init__(self, hass: HomeAssistant) -> None:
|
||||||
|
self.hass = hass
|
||||||
|
self._store = Store(hass, _STORAGE_VERSION, _STORAGE_KEY)
|
||||||
|
|
||||||
|
async def _load(self) -> dict[str, Any]:
|
||||||
|
data = await self._store.async_load()
|
||||||
|
if not data:
|
||||||
|
return {"custom_repos": []}
|
||||||
|
if "custom_repos" not in data:
|
||||||
|
data["custom_repos"] = []
|
||||||
|
return data
|
||||||
|
|
||||||
|
async def _save(self, data: dict[str, Any]) -> None:
|
||||||
|
await self._store.async_save(data)
|
||||||
|
|
||||||
|
async def list_custom_repos(self) -> list[CustomRepo]:
|
||||||
|
data = await self._load()
|
||||||
|
repos = data.get("custom_repos", [])
|
||||||
|
out: list[CustomRepo] = []
|
||||||
|
for r in repos:
|
||||||
|
if not isinstance(r, dict):
|
||||||
|
continue
|
||||||
|
rid = str(r.get("id") or "")
|
||||||
|
url = str(r.get("url") or "")
|
||||||
|
name = r.get("name")
|
||||||
|
if rid and url:
|
||||||
|
out.append(CustomRepo(id=rid, url=url, name=str(name) if name else None))
|
||||||
|
return out
|
||||||
|
|
||||||
|
async def add_custom_repo(self, url: str, name: str | None) -> CustomRepo:
|
||||||
|
data = await self._load()
|
||||||
|
repos = data.get("custom_repos", [])
|
||||||
|
|
||||||
|
# Deduplicate by URL
|
||||||
|
for r in repos:
|
||||||
|
if isinstance(r, dict) and str(r.get("url", "")).strip() == url.strip():
|
||||||
|
# Update name if provided
|
||||||
|
if name:
|
||||||
|
r["name"] = name
|
||||||
|
await self._save(data)
|
||||||
|
return CustomRepo(id=str(r["id"]), url=str(r["url"]), name=r.get("name"))
|
||||||
|
|
||||||
|
rid = f"custom:{uuid.uuid4().hex[:10]}"
|
||||||
|
entry = {"id": rid, "url": url.strip(), "name": name.strip() if name else None}
|
||||||
|
repos.append(entry)
|
||||||
|
data["custom_repos"] = repos
|
||||||
|
await self._save(data)
|
||||||
|
return CustomRepo(id=rid, url=entry["url"], name=entry["name"])
|
||||||
|
|
||||||
|
async def remove_custom_repo(self, repo_id: str) -> None:
|
||||||
|
data = await self._load()
|
||||||
|
repos = data.get("custom_repos", [])
|
||||||
|
data["custom_repos"] = [r for r in repos if not (isinstance(r, dict) and r.get("id") == repo_id)]
|
||||||
|
await self._save(data)
|
||||||
|
|
||||||
@@ -35,7 +35,7 @@ class StoreConfig:
|
|||||||
class Package:
|
class Package:
|
||||||
id: str
|
id: str
|
||||||
name: str
|
name: str
|
||||||
type: str
|
type: str # "integration" | "store"
|
||||||
domain: str
|
domain: str
|
||||||
repo: str
|
repo: str
|
||||||
owner: str
|
owner: str
|
||||||
@@ -76,12 +76,19 @@ class BahmcloudStore:
|
|||||||
u = urlparse(repo_url.rstrip("/"))
|
u = urlparse(repo_url.rstrip("/"))
|
||||||
return f"{u.scheme}://{u.netloc}"
|
return f"{u.scheme}://{u.netloc}"
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def _raw_manifest_url(repo: str, branch: str, source_path: str) -> str:
|
||||||
|
# Example:
|
||||||
|
# https://git.bahmcloud.de/bahmcloud/easy_proxmox/raw/branch/main/custom_components/easy_proxmox/manifest.json
|
||||||
|
return f"{repo.rstrip('/')}/raw/branch/{branch}/{source_path.rstrip('/')}/manifest.json"
|
||||||
|
|
||||||
async def _fetch_latest_version(self, pkg: Package) -> tuple[str | None, str | None]:
|
async def _fetch_latest_version(self, pkg: Package) -> tuple[str | None, str | None]:
|
||||||
"""
|
"""
|
||||||
Returns (latest_version, release_url)
|
Returns (latest_version, release_url)
|
||||||
Strategy:
|
Strategy:
|
||||||
1) releases/latest -> tag_name
|
1) releases/latest -> tag_name
|
||||||
2) tags?limit=1 -> first tag name
|
2) tags?limit=1 -> first tag name
|
||||||
|
3) fallback: read manifest.json from repo (version field)
|
||||||
"""
|
"""
|
||||||
session = async_get_clientsession(self.hass)
|
session = async_get_clientsession(self.hass)
|
||||||
base = self._base_from_repo(pkg.repo)
|
base = self._base_from_repo(pkg.repo)
|
||||||
@@ -94,7 +101,8 @@ class BahmcloudStore:
|
|||||||
data = await resp.json()
|
data = await resp.json()
|
||||||
tag = data.get("tag_name")
|
tag = data.get("tag_name")
|
||||||
html_url = data.get("html_url")
|
html_url = data.get("html_url")
|
||||||
return (str(tag) if tag else None, str(html_url) if html_url else None)
|
if tag:
|
||||||
|
return (str(tag), str(html_url) if html_url else None)
|
||||||
except Exception:
|
except Exception:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@@ -106,7 +114,21 @@ class BahmcloudStore:
|
|||||||
tags = await resp.json()
|
tags = await resp.json()
|
||||||
if tags and isinstance(tags, list):
|
if tags and isinstance(tags, list):
|
||||||
name = tags[0].get("name")
|
name = tags[0].get("name")
|
||||||
return (str(name) if name else None, None)
|
if name:
|
||||||
|
return (str(name), None)
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
|
||||||
|
# 3) fallback: manifest.json version from repo
|
||||||
|
try:
|
||||||
|
manifest_url = self._raw_manifest_url(pkg.repo, pkg.branch, pkg.source_path)
|
||||||
|
async with session.get(manifest_url, timeout=20) as resp:
|
||||||
|
if resp.status == 200:
|
||||||
|
text = await resp.text()
|
||||||
|
data = json.loads(text)
|
||||||
|
ver = data.get("version")
|
||||||
|
if ver:
|
||||||
|
return (str(ver), None)
|
||||||
except Exception:
|
except Exception:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@@ -198,6 +220,9 @@ class BahmcloudStore:
|
|||||||
shutil.rmtree(target)
|
shutil.rmtree(target)
|
||||||
shutil.copytree(src, target)
|
shutil.copytree(src, target)
|
||||||
|
|
||||||
|
# Nach Installation: Entities neu aufbauen (damit es als Update auftaucht)
|
||||||
|
self.signal_entities_updated()
|
||||||
|
|
||||||
persistent_notification.async_create(
|
persistent_notification.async_create(
|
||||||
self.hass,
|
self.hass,
|
||||||
(
|
(
|
||||||
@@ -228,7 +253,7 @@ class BahmcloudStore:
|
|||||||
async def register_http_views(self) -> None:
|
async def register_http_views(self) -> None:
|
||||||
"""Register HTTP views for static panel assets and JSON API."""
|
"""Register HTTP views for static panel assets and JSON API."""
|
||||||
self.hass.http.register_view(_StaticView())
|
self.hass.http.register_view(_StaticView())
|
||||||
self.hass.http.register_view(_APIListView(self))
|
self.hass.http.register_view(_APIView(self))
|
||||||
|
|
||||||
|
|
||||||
class _StaticView(HomeAssistantView):
|
class _StaticView(HomeAssistantView):
|
||||||
@@ -236,12 +261,6 @@ class _StaticView(HomeAssistantView):
|
|||||||
IMPORTANT:
|
IMPORTANT:
|
||||||
Custom Panel JS modules are loaded WITHOUT Authorization headers.
|
Custom Panel JS modules are loaded WITHOUT Authorization headers.
|
||||||
Therefore static panel assets must be publicly accessible (no auth).
|
Therefore static panel assets must be publicly accessible (no auth).
|
||||||
|
|
||||||
Serves:
|
|
||||||
/api/bahmcloud_store_static/index.html
|
|
||||||
/api/bahmcloud_store_static/panel.js
|
|
||||||
/api/bahmcloud_store_static/app.js
|
|
||||||
/api/bahmcloud_store_static/styles.css
|
|
||||||
"""
|
"""
|
||||||
requires_auth = False
|
requires_auth = False
|
||||||
name = "bahmcloud_store_static"
|
name = "bahmcloud_store_static"
|
||||||
@@ -254,7 +273,6 @@ class _StaticView(HomeAssistantView):
|
|||||||
|
|
||||||
f = (base / path).resolve()
|
f = (base / path).resolve()
|
||||||
|
|
||||||
# Prevent path traversal
|
|
||||||
if not str(f).startswith(str(base)) or not f.exists() or not f.is_file():
|
if not str(f).startswith(str(base)) or not f.exists() or not f.is_file():
|
||||||
return web.Response(status=404, text="Not found")
|
return web.Response(status=404, text="Not found")
|
||||||
|
|
||||||
@@ -269,10 +287,11 @@ class _StaticView(HomeAssistantView):
|
|||||||
return web.Response(body=f.read_bytes(), content_type="application/octet-stream")
|
return web.Response(body=f.read_bytes(), content_type="application/octet-stream")
|
||||||
|
|
||||||
|
|
||||||
class _APIListView(HomeAssistantView):
|
class _APIView(HomeAssistantView):
|
||||||
"""
|
"""
|
||||||
Store API MUST stay protected.
|
Auth-protected API:
|
||||||
UI loads data via fetch() with HA auth handled by frontend.
|
GET /api/bahmcloud_store -> list packages
|
||||||
|
POST /api/bahmcloud_store {op:...} -> install/update a package
|
||||||
"""
|
"""
|
||||||
requires_auth = True
|
requires_auth = True
|
||||||
name = "bahmcloud_store_api"
|
name = "bahmcloud_store_api"
|
||||||
@@ -300,3 +319,20 @@ class _APIListView(HomeAssistantView):
|
|||||||
}
|
}
|
||||||
)
|
)
|
||||||
return self.json({"packages": items, "store_url": self.store.config.store_url})
|
return self.json({"packages": items, "store_url": self.store.config.store_url})
|
||||||
|
|
||||||
|
async def post(self, request):
|
||||||
|
data = await request.json()
|
||||||
|
op = data.get("op")
|
||||||
|
package_id = data.get("package_id")
|
||||||
|
|
||||||
|
if op not in ("install", "update"):
|
||||||
|
return self.json({"error": "unknown op"}, status_code=400)
|
||||||
|
if not package_id:
|
||||||
|
return self.json({"error": "package_id missing"}, status_code=400)
|
||||||
|
|
||||||
|
pkg = self.store.packages.get(package_id)
|
||||||
|
if not pkg:
|
||||||
|
return self.json({"error": "unknown package_id"}, status_code=404)
|
||||||
|
|
||||||
|
await self.store.install_from_zip(pkg)
|
||||||
|
return self.json({"ok": True})
|
||||||
|
|||||||
@@ -1,12 +1,12 @@
|
|||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
from homeassistant.components.update import UpdateEntity, UpdateEntityFeature
|
# NOTE:
|
||||||
|
# Update entities will be implemented once installation/provider resolution is in place.
|
||||||
|
# This stub prevents platform load errors and keeps the integration stable in 0.3.0.
|
||||||
|
|
||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
|
|
||||||
from . import DOMAIN
|
|
||||||
from .store import BahmcloudStore, Package
|
|
||||||
|
|
||||||
|
|
||||||
async def async_setup_platform(
|
async def async_setup_platform(
|
||||||
hass: HomeAssistant,
|
hass: HomeAssistant,
|
||||||
@@ -14,71 +14,4 @@ async def async_setup_platform(
|
|||||||
async_add_entities: AddEntitiesCallback,
|
async_add_entities: AddEntitiesCallback,
|
||||||
discovery_info=None,
|
discovery_info=None,
|
||||||
):
|
):
|
||||||
store: BahmcloudStore = hass.data[DOMAIN]
|
|
||||||
entities: dict[str, BahmcloudPackageUpdate] = {}
|
|
||||||
|
|
||||||
def rebuild_entities() -> None:
|
|
||||||
# create entities for any new package in store.yaml
|
|
||||||
for pkg in store.packages.values():
|
|
||||||
uid = f"{DOMAIN}:{pkg.id}"
|
|
||||||
if uid not in entities:
|
|
||||||
ent = BahmcloudPackageUpdate(store, pkg.id)
|
|
||||||
entities[uid] = ent
|
|
||||||
async_add_entities([ent], update_before_add=True)
|
|
||||||
|
|
||||||
# refresh states
|
|
||||||
for ent in entities.values():
|
|
||||||
ent.async_write_ha_state()
|
|
||||||
|
|
||||||
store.add_listener(rebuild_entities)
|
|
||||||
rebuild_entities()
|
|
||||||
|
|
||||||
|
|
||||||
class BahmcloudPackageUpdate(UpdateEntity):
|
|
||||||
_attr_supported_features = UpdateEntityFeature.INSTALL
|
|
||||||
|
|
||||||
def __init__(self, store: BahmcloudStore, package_id: str) -> None:
|
|
||||||
self.store = store
|
|
||||||
self.package_id = package_id
|
|
||||||
|
|
||||||
self._attr_unique_id = f"{DOMAIN}_{package_id}"
|
|
||||||
self._attr_name = f"{package_id} update"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def _pkg(self) -> Package | None:
|
|
||||||
return self.store.packages.get(self.package_id)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def title(self) -> str | None:
|
|
||||||
pkg = self._pkg
|
|
||||||
return pkg.name if pkg else None
|
|
||||||
|
|
||||||
@property
|
|
||||||
def installed_version(self) -> str | None:
|
|
||||||
pkg = self._pkg
|
|
||||||
if not pkg:
|
|
||||||
return None
|
|
||||||
if not self.store.is_installed(pkg.domain):
|
|
||||||
return None
|
|
||||||
return self.store.installed_version(pkg.domain)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def latest_version(self) -> str | None:
|
|
||||||
pkg = self._pkg
|
|
||||||
return pkg.latest_version if pkg else None
|
|
||||||
|
|
||||||
@property
|
|
||||||
def release_summary(self) -> str | None:
|
|
||||||
pkg = self._pkg
|
|
||||||
if not pkg:
|
|
||||||
return None
|
|
||||||
if pkg.release_url:
|
|
||||||
return f"Release: {pkg.release_url}"
|
|
||||||
return f"Repo: {pkg.repo}"
|
|
||||||
|
|
||||||
async def async_install(self, version: str | None, backup: bool, **kwargs) -> None:
|
|
||||||
pkg = self._pkg
|
|
||||||
if not pkg:
|
|
||||||
return
|
return
|
||||||
await self.store.install_from_zip(pkg)
|
|
||||||
self.async_write_ha_state()
|
|
||||||
|
|||||||
316
custom_components/bahmcloud_store/views.py
Normal file
316
custom_components/bahmcloud_store/views.py
Normal file
@@ -0,0 +1,316 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import base64
|
||||||
|
import logging
|
||||||
|
from dataclasses import asdict
|
||||||
|
from pathlib import Path
|
||||||
|
from typing import Any, TYPE_CHECKING
|
||||||
|
|
||||||
|
from aiohttp import web
|
||||||
|
from homeassistant.components.http import HomeAssistantView
|
||||||
|
|
||||||
|
if TYPE_CHECKING:
|
||||||
|
from .core import BCSCore # typing only
|
||||||
|
|
||||||
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
def _render_markdown_server_side(md: str) -> str | None:
|
||||||
|
"""Render Markdown -> sanitized HTML (server-side)."""
|
||||||
|
text = (md or "").strip()
|
||||||
|
if not text:
|
||||||
|
return None
|
||||||
|
|
||||||
|
html: str | None = None
|
||||||
|
|
||||||
|
# 1) python-markdown
|
||||||
|
try:
|
||||||
|
import markdown as mdlib # type: ignore
|
||||||
|
|
||||||
|
html = mdlib.markdown(
|
||||||
|
text,
|
||||||
|
extensions=["fenced_code", "tables", "sane_lists", "toc"],
|
||||||
|
output_format="html5",
|
||||||
|
)
|
||||||
|
except Exception as e:
|
||||||
|
_LOGGER.debug("python-markdown render failed: %s", e)
|
||||||
|
html = None
|
||||||
|
|
||||||
|
if not html:
|
||||||
|
return None
|
||||||
|
|
||||||
|
# 2) Sanitize via bleach
|
||||||
|
try:
|
||||||
|
import bleach # type: ignore
|
||||||
|
|
||||||
|
allowed_tags = [
|
||||||
|
"p",
|
||||||
|
"br",
|
||||||
|
"hr",
|
||||||
|
"div",
|
||||||
|
"span",
|
||||||
|
"blockquote",
|
||||||
|
"pre",
|
||||||
|
"code",
|
||||||
|
"h1",
|
||||||
|
"h2",
|
||||||
|
"h3",
|
||||||
|
"h4",
|
||||||
|
"h5",
|
||||||
|
"h6",
|
||||||
|
"ul",
|
||||||
|
"ol",
|
||||||
|
"li",
|
||||||
|
"strong",
|
||||||
|
"em",
|
||||||
|
"b",
|
||||||
|
"i",
|
||||||
|
"u",
|
||||||
|
"s",
|
||||||
|
"a",
|
||||||
|
"img",
|
||||||
|
"table",
|
||||||
|
"thead",
|
||||||
|
"tbody",
|
||||||
|
"tr",
|
||||||
|
"th",
|
||||||
|
"td",
|
||||||
|
]
|
||||||
|
|
||||||
|
allowed_attrs = {
|
||||||
|
"a": ["href", "title", "target", "rel"],
|
||||||
|
"img": ["src", "alt", "title"],
|
||||||
|
"th": ["align"],
|
||||||
|
"td": ["align"],
|
||||||
|
"*": ["class"],
|
||||||
|
}
|
||||||
|
|
||||||
|
sanitized = bleach.clean(
|
||||||
|
html,
|
||||||
|
tags=allowed_tags,
|
||||||
|
attributes=allowed_attrs,
|
||||||
|
protocols=["http", "https", "mailto"],
|
||||||
|
strip=True,
|
||||||
|
)
|
||||||
|
|
||||||
|
sanitized = sanitized.replace(
|
||||||
|
'<a href="',
|
||||||
|
'<a rel="noreferrer noopener" target="_blank" href="',
|
||||||
|
)
|
||||||
|
return sanitized
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
_LOGGER.debug("bleach sanitize failed/unavailable: %s", e)
|
||||||
|
|
||||||
|
return html
|
||||||
|
|
||||||
|
|
||||||
|
_TEXT_KEYS = ("readme", "markdown", "text", "content", "data", "body")
|
||||||
|
|
||||||
|
|
||||||
|
def _maybe_decode_base64(content: str, encoding: Any) -> str | None:
|
||||||
|
if not isinstance(content, str):
|
||||||
|
return None
|
||||||
|
enc = ""
|
||||||
|
if isinstance(encoding, str):
|
||||||
|
enc = encoding.strip().lower()
|
||||||
|
if "base64" not in enc:
|
||||||
|
return None
|
||||||
|
try:
|
||||||
|
raw = base64.b64decode(content.encode("utf-8"), validate=False)
|
||||||
|
return raw.decode("utf-8", errors="replace")
|
||||||
|
except Exception:
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
def _extract_text_recursive(obj: Any, depth: int = 0) -> str | None:
|
||||||
|
"""
|
||||||
|
Robust extraction for README markdown.
|
||||||
|
|
||||||
|
Handles:
|
||||||
|
- str / bytes
|
||||||
|
- dict with:
|
||||||
|
- {content: "...", encoding: "base64"} (possibly nested)
|
||||||
|
- {readme: "..."} etc.
|
||||||
|
- list of dicts (pick first matching)
|
||||||
|
"""
|
||||||
|
if obj is None:
|
||||||
|
return None
|
||||||
|
|
||||||
|
if isinstance(obj, bytes):
|
||||||
|
try:
|
||||||
|
return obj.decode("utf-8", errors="replace")
|
||||||
|
except Exception:
|
||||||
|
return None
|
||||||
|
|
||||||
|
if isinstance(obj, str):
|
||||||
|
return obj
|
||||||
|
|
||||||
|
if depth > 8:
|
||||||
|
return None
|
||||||
|
|
||||||
|
if isinstance(obj, dict):
|
||||||
|
# 1) If it looks like "file content"
|
||||||
|
content = obj.get("content")
|
||||||
|
encoding = obj.get("encoding")
|
||||||
|
|
||||||
|
# Base64 decode if possible
|
||||||
|
decoded = _maybe_decode_base64(content, encoding)
|
||||||
|
if decoded:
|
||||||
|
return decoded
|
||||||
|
|
||||||
|
# content may already be plain text
|
||||||
|
if isinstance(content, str) and (not isinstance(encoding, str) or not encoding.strip()):
|
||||||
|
# Heuristic: treat as markdown if it has typical markdown chars, otherwise still return
|
||||||
|
return content
|
||||||
|
|
||||||
|
# 2) direct text keys (readme/markdown/text/body/data)
|
||||||
|
for k in _TEXT_KEYS:
|
||||||
|
v = obj.get(k)
|
||||||
|
if isinstance(v, str):
|
||||||
|
return v
|
||||||
|
if isinstance(v, bytes):
|
||||||
|
try:
|
||||||
|
return v.decode("utf-8", errors="replace")
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
|
||||||
|
# 3) Sometimes nested under "file" / "result" / "payload" etc.
|
||||||
|
for v in obj.values():
|
||||||
|
out = _extract_text_recursive(v, depth + 1)
|
||||||
|
if out:
|
||||||
|
return out
|
||||||
|
|
||||||
|
return None
|
||||||
|
|
||||||
|
if isinstance(obj, list):
|
||||||
|
for item in obj:
|
||||||
|
out = _extract_text_recursive(item, depth + 1)
|
||||||
|
if out:
|
||||||
|
return out
|
||||||
|
return None
|
||||||
|
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
class StaticAssetsView(HomeAssistantView):
|
||||||
|
url = "/api/bahmcloud_store_static/{path:.*}"
|
||||||
|
name = "api:bahmcloud_store_static"
|
||||||
|
requires_auth = False
|
||||||
|
|
||||||
|
async def get(self, request: web.Request, path: str) -> web.Response:
|
||||||
|
base = Path(__file__).resolve().parent / "panel"
|
||||||
|
base_resolved = base.resolve()
|
||||||
|
|
||||||
|
req_path = (path or "").lstrip("/")
|
||||||
|
if req_path == "":
|
||||||
|
req_path = "index.html"
|
||||||
|
|
||||||
|
target = (base / req_path).resolve()
|
||||||
|
|
||||||
|
if not str(target).startswith(str(base_resolved)):
|
||||||
|
return web.Response(status=404)
|
||||||
|
|
||||||
|
if target.is_dir():
|
||||||
|
target = (target / "index.html").resolve()
|
||||||
|
|
||||||
|
if not target.exists():
|
||||||
|
_LOGGER.error("BCS static asset not found: %s", target)
|
||||||
|
return web.Response(status=404)
|
||||||
|
|
||||||
|
content_type = "text/plain"
|
||||||
|
charset = None
|
||||||
|
|
||||||
|
if target.suffix == ".js":
|
||||||
|
content_type = "application/javascript"
|
||||||
|
charset = "utf-8"
|
||||||
|
elif target.suffix == ".html":
|
||||||
|
content_type = "text/html"
|
||||||
|
charset = "utf-8"
|
||||||
|
elif target.suffix == ".css":
|
||||||
|
content_type = "text/css"
|
||||||
|
charset = "utf-8"
|
||||||
|
elif target.suffix == ".svg":
|
||||||
|
content_type = "image/svg+xml"
|
||||||
|
elif target.suffix == ".png":
|
||||||
|
content_type = "image/png"
|
||||||
|
|
||||||
|
resp = web.Response(body=target.read_bytes(), content_type=content_type, charset=charset)
|
||||||
|
resp.headers["Cache-Control"] = "no-store, no-cache, must-revalidate, max-age=0"
|
||||||
|
resp.headers["Pragma"] = "no-cache"
|
||||||
|
return resp
|
||||||
|
|
||||||
|
|
||||||
|
class BCSApiView(HomeAssistantView):
|
||||||
|
url = "/api/bcs"
|
||||||
|
name = "api:bcs"
|
||||||
|
requires_auth = True
|
||||||
|
|
||||||
|
def __init__(self, core: Any) -> None:
|
||||||
|
self.core = core
|
||||||
|
|
||||||
|
async def get(self, request: web.Request) -> web.Response:
|
||||||
|
return web.json_response(
|
||||||
|
{"ok": True, "version": self.core.version, "repos": self.core.list_repos_public()}
|
||||||
|
)
|
||||||
|
|
||||||
|
async def post(self, request: web.Request) -> web.Response:
|
||||||
|
data = await request.json()
|
||||||
|
op = data.get("op")
|
||||||
|
|
||||||
|
if op == "add_custom_repo":
|
||||||
|
url = str(data.get("url") or "").strip()
|
||||||
|
name = data.get("name")
|
||||||
|
name = str(name).strip() if name else None
|
||||||
|
if not url:
|
||||||
|
return web.json_response({"ok": False, "message": "Missing url"}, status=400)
|
||||||
|
repo = await self.core.add_custom_repo(url=url, name=name)
|
||||||
|
return web.json_response({"ok": True, "repo": asdict(repo)})
|
||||||
|
|
||||||
|
return web.json_response({"ok": False, "message": "Unknown operation"}, status=400)
|
||||||
|
|
||||||
|
|
||||||
|
class BCSCustomRepoView(HomeAssistantView):
|
||||||
|
url = "/api/bcs/custom_repo"
|
||||||
|
name = "api:bcs_custom_repo"
|
||||||
|
requires_auth = True
|
||||||
|
|
||||||
|
def __init__(self, core: Any) -> None:
|
||||||
|
self.core = core
|
||||||
|
|
||||||
|
async def delete(self, request: web.Request) -> web.Response:
|
||||||
|
repo_id = request.query.get("id")
|
||||||
|
if not repo_id:
|
||||||
|
return web.json_response({"ok": False, "message": "Missing id"}, status=400)
|
||||||
|
await self.core.remove_custom_repo(repo_id)
|
||||||
|
return web.json_response({"ok": True})
|
||||||
|
|
||||||
|
|
||||||
|
class BCSReadmeView(HomeAssistantView):
|
||||||
|
url = "/api/bcs/readme"
|
||||||
|
name = "api:bcs_readme"
|
||||||
|
requires_auth = True
|
||||||
|
|
||||||
|
def __init__(self, core: Any) -> None:
|
||||||
|
self.core = core
|
||||||
|
|
||||||
|
async def get(self, request: web.Request) -> web.Response:
|
||||||
|
repo_id = request.query.get("repo_id")
|
||||||
|
if not repo_id:
|
||||||
|
return web.json_response({"ok": False, "message": "Missing repo_id"}, status=400)
|
||||||
|
|
||||||
|
maybe_md = await self.core.fetch_readme_markdown(repo_id)
|
||||||
|
|
||||||
|
md = _extract_text_recursive(maybe_md)
|
||||||
|
if not md or not md.strip():
|
||||||
|
t = type(maybe_md).__name__
|
||||||
|
return web.json_response(
|
||||||
|
{"ok": False, "message": f"README not found or unsupported format (got {t})."},
|
||||||
|
status=404,
|
||||||
|
)
|
||||||
|
|
||||||
|
# Ensure strict JSON string output (avoid accidental objects)
|
||||||
|
md_str = str(md)
|
||||||
|
|
||||||
|
html = _render_markdown_server_side(md_str)
|
||||||
|
return web.json_response({"ok": True, "readme": md_str, "html": html})
|
||||||
Reference in New Issue
Block a user