reorganize structure

Author: Lash-L

src/roborock_local_server/backend.py

@@ -19,6 +19,7 @@ def _resolve_backend_path() -> Path:
     sys.path.insert(0, backend_str)
 
 from https_server.endpoint_rules import default_endpoint_rules, resolve_route  # type: ignore  # noqa: E402
+from https_server.routes.plugin.dispatch import PluginZipDispatchError, dispatch_plugin_zip_request  # type: ignore  # noqa: E402
 from import_web_inventory_from_cloud import (  # type: ignore  # noqa: E402
     _build_inventory,
     _fetch_additional_web_cache,
@@ -59,7 +60,9 @@ def _resolve_backend_path() -> Path:
     "_normalize_value_map",
     "append_jsonl",
     "classify_host",
+    "dispatch_plugin_zip_request",
     "default_endpoint_rules",
+    "PluginZipDispatchError",
     "resolve_route",
     "setup_file_logger",
     "start_broker",

src/roborock_local_server/bundled_backend/https_server/endpoint_rules.py

@@ -0,0 +1,2 @@
+"""URL-tree route modules for HTTPS endpoint handling."""
+

src/roborock_local_server/bundled_backend/https_server/routes/__init__.py

@@ -0,0 +1,2 @@
+"""API route namespaces."""
+

src/roborock_local_server/bundled_backend/https_server/routes/api/__init__.py

@@ -0,0 +1,31 @@
+"""Shared app-config data for v1/v2 appconfig endpoints."""
+
+from __future__ import annotations
+
+from typing import Any
+
+APP_CONFIG_COMMON_DATA: dict[str, Any] = {
+    "version": "4.41.04",
+    "url": "itms-apps://itunes.apple.com/cn/app/id1462875428?mt=8",
+    "required": 0,
+    "description": "<p><br></p>",
+    "minimumVersion": "0.0.0",
+    "mainPictureInfoList": [
+        {
+            "darkModePic": "https://files.roborock.com/iot/doc/bbecbae006b940eab34d200ba809bb72.png",
+            "lightModePic": "https://files.roborock.com/iot/doc/a35d5dfcd6eb41e69dab160fe12f059f.png",
+        },
+        {
+            "darkModePic": "https://files.roborock.com/iot/doc/588414a901d645058c9dce93b5f891c3.png",
+            "lightModePic": "https://files.roborock.com/iot/doc/e38de51323a743628f094358611c6b0d.png",
+        },
+        {
+            "darkModePic": "https://files.roborock.com/iot/doc/576cfc12bed843c9b45bffabceb07259.png",
+            "lightModePic": "https://files.roborock.com/iot/doc/de2f035553f24795a5699279193d312a.png",
+        },
+    ],
+}
+
+
+def app_config_common_payload() -> dict[str, Any]:
+    return dict(APP_CONFIG_COMMON_DATA)

src/roborock_local_server/bundled_backend/https_server/routes/api/appconfig_service.py

@@ -0,0 +1,75 @@
+"""Shared product-state services for /api/v4/product and /api/v5/product."""
+
+from __future__ import annotations
+
+import hashlib
+from typing import Any
+
+from shared.context import ServerContext
+
+from ..user.homes.service import home_payload
+
+_MODEL_PRODUCT_ID_OVERRIDES = {
+    "roborock.vacuum.a87": 110,
+    "roborock.vacuum.a15": 23,
+    "roborock.vacuum.sc05": 10001,
+}
+
+
+def _as_int(value: Any, default: int) -> int:
+    try:
+        return int(value)
+    except (TypeError, ValueError):
+        return default
+
+
+def _default_product_name(model: str) -> str:
+    short_model = model.split(".")[-1].upper() if model else "VACUUM"
+    return f"Roborock {short_model}"
+
+
+def _stable_int(seed: str) -> int:
+    return int(hashlib.sha256(seed.encode("utf-8")).hexdigest()[:12], 16)
+
+
+def build_product_response(ctx: ServerContext) -> dict[str, Any]:
+    home_data = home_payload(ctx)
+    products_value = home_data.get("products")
+    products = products_value if isinstance(products_value, list) else []
+    categories: dict[str, dict[str, Any]] = {}
+    for product in products:
+        if not isinstance(product, dict):
+            continue
+        raw_product_id = str(product.get("id") or "")
+        category_name = str(product.get("category") or "robot.vacuum.cleaner")
+        if category_name not in categories:
+            category_id = len(categories) + 1
+            categories[category_name] = {
+                "category": {
+                    "id": category_id,
+                    "displayName": category_name,
+                    "iconUrl": "",
+                },
+                "productList": [],
+            }
+        model = str(product.get("model") or "roborock.vacuum.a117")
+        model_key = model.strip().lower()
+        product_id = _MODEL_PRODUCT_ID_OVERRIDES.get(
+            model_key,
+            _as_int(raw_product_id, _stable_int(raw_product_id or category_name) % 1_000_000),
+        )
+        product_entry = {
+            "id": product_id,
+            "name": str(product.get("name") or _default_product_name(model)),
+            "model": model,
+            "packagename": f"com.roborock.{model.split('.')[-1]}",
+            "ncMode": "global",
+            "status": 10,
+        }
+        icon_url = product.get("iconUrl")
+        if isinstance(icon_url, str) and icon_url:
+            product_entry["picurl"] = icon_url
+            product_entry["cardPicUrl"] = icon_url
+            product_entry["pluginPicUrl"] = icon_url
+        categories[category_name]["productList"].append(product_entry)
+    return {"categoryDetailList": list(categories.values())}

src/roborock_local_server/bundled_backend/https_server/routes/api/product_service.py

@@ -0,0 +1,2 @@
+"""API v1 route modules."""
+

src/roborock_local_server/bundled_backend/https_server/routes/api/v1/__init__.py

@@ -0,0 +1,24 @@
+"""Route handler for /api/v1/appconfig."""
+
+from __future__ import annotations
+
+from typing import Any
+
+from shared.context import ServerContext
+
+from ...auth.service import ok
+from ..appconfig_service import app_config_common_payload
+
+
+def match(path: str) -> bool:
+    return path.rstrip("/") == "/api/v1/appconfig"
+
+
+def build(
+    ctx: ServerContext,
+    query_params: dict[str, list[str]],
+    body_params: dict[str, list[str]],
+    clean_path: str,
+) -> dict[str, Any]:
+    _ = ctx, query_params, body_params, clean_path
+    return ok(app_config_common_payload())

src/roborock_local_server/bundled_backend/https_server/routes/api/v1/appconfig.py

@@ -0,0 +1,28 @@
+"""Route handler for /api/v1/appfeatureplugin."""
+
+from __future__ import annotations
+
+from typing import Any
+
+from shared.context import ServerContext
+
+from ...plugin.common import APP_FEATURE_PLUGIN_LIST, proxied_plugin_records
+
+
+def _ok(data: Any) -> dict[str, Any]:
+    return {"code": 200, "msg": "success", "data": data}
+
+
+def match(path: str) -> bool:
+    return path.rstrip("/") == "/api/v1/appfeatureplugin"
+
+
+def build(
+    ctx: ServerContext,
+    query_params: dict[str, list[str]],
+    body_params: dict[str, list[str]],
+    clean_path: str,
+) -> dict[str, Any]:
+    _ = query_params, body_params, clean_path
+    return _ok({"plugins": proxied_plugin_records(ctx, APP_FEATURE_PLUGIN_LIST)})
+

src/roborock_local_server/bundled_backend/https_server/routes/api/v1/appfeatureplugin.py

@@ -0,0 +1,28 @@
+"""Route handler for /api/v1/appplugin."""
+
+from __future__ import annotations
+
+from typing import Any
+
+from shared.context import ServerContext
+
+from ...plugin.common import APPPLUGIN_LIST, proxied_plugin_records
+
+
+def _ok(data: Any) -> dict[str, Any]:
+    return {"code": 200, "msg": "success", "data": data}
+
+
+def match(path: str) -> bool:
+    return path.rstrip("/") == "/api/v1/appplugin"
+
+
+def build(
+    ctx: ServerContext,
+    query_params: dict[str, list[str]],
+    body_params: dict[str, list[str]],
+    clean_path: str,
+) -> dict[str, Any]:
+    _ = query_params, body_params, clean_path
+    return _ok(proxied_plugin_records(ctx, APPPLUGIN_LIST))
+