fix(rp5): fix rp5 parser

.env-base

@@ -1,6 +1,9 @@
 DOCKER_REPO=git.shmyga.ru
 DOCKER_GROUP=infernalgames
-DOCKER_ROOT="${DOCKER_REPO}/${DOCKER_GROUP}"
+DOCKER_ROOT="$DOCKER_REPO/$DOCKER_GROUP"
+VERSION=$(grep -m 1 'version' ./pyproject.toml | grep -oP 'version\s*=\s*"\K[^"]+')
+PYTHON_VERSION=$(grep -m 1 'python' ./pyproject.toml | grep -oP 'python\s*=\s*"\^?\K[^"]+')
+DOCKER_PROJECTS=("gallery")
 DOCKER_TAG="${DOCKER_TAG:-latest}"
 
 OPENWEATHER_KEY=""

.pm.toml

@@ -1,4 +1,6 @@
-modules = [".", "static"]
+[presets.python.tasks.setup.playwright]
+conditions = ["{{ '.venv/bin/playwright' | file }}"]
+commands = [".venv/bin/playwright install chromium --with-deps --only-shell"]
 
 [presets.locales.tasks.build.locales]
 priority = 1

Dockerfile

@@ -23,19 +23,14 @@ COPY static ./
 RUN npm run build
 
 FROM python:3.14-slim
-
-ENV PLAYWRIGHT_BROWSERS_PATH="/opt/playwright-browsers"
-RUN  --mount=type=cache,target=/var/cache/apt,sharing=locked \
-  --mount=type=cache,target=/var/lib/apt,sharing=locked \
-  pip install playwright && \
-  playwright install --with-deps chromium
-
 ENV PATH="/app/.venv/bin:$PATH"
-ENV TZ="Europe/Moscow"
-
 WORKDIR /app
 
+ENV TZ="Europe/Moscow"
+
 COPY --from=builder /app ./
+RUN .venv/bin/playwright install chromium --with-deps --only-shell
+
 COPY --from=node-builder /app/dist ./static/dist
 
 COPY gallery gallery/

gallery/easel/__init__.py

@@ -1,11 +1,10 @@
 from fastapi import FastAPI
-from fastapi.responses import RedirectResponse
 from fastapi.staticfiles import StaticFiles
 
 from gallery.sketch.bundle import ApiBundle
 from gallery.util import root_path
 
-from .route import api, view
+from .route import api, doc, view
 
 
 def build_app(api_bundle: ApiBundle) -> FastAPI:
@@ -16,12 +15,7 @@ def build_app(api_bundle: ApiBundle) -> FastAPI:
     )
     app.state.api = api_bundle
     app.mount("/static", StaticFiles(directory=root_path / "static/dist"))
-    api.app.state.api = api_bundle
+    doc.mount(app)
-    app.mount("/api", api.app)
+    app.include_router(api.router)
     app.include_router(view.router)
-
-    @app.get("/docs")
-    def get_docs():
-        return RedirectResponse("/api/docs")
-
     return app

gallery/easel/depends/schedule.py

@@ -1,4 +1,4 @@
-from typing import Annotated, NamedTuple
+from typing import Annotated
 
 from fastapi import Depends
 
@@ -7,35 +7,3 @@ from gallery.sketch.schedule.api import ScheduleApi
 from .api import api_resolver
 
 ScheduleApiDepends = Annotated[ScheduleApi, Depends(api_resolver(ScheduleApi))]
-
-
-class ChannelDef(NamedTuple):
-    provider: str
-    id: str
-
-
-GROUP_CANNELS_MAP: dict[str, list[ChannelDef]] = {
-    "central": [
-        ChannelDef("yandextv", "pervyy-16"),
-        ChannelDef("yandextv", "rossiya-1-31"),
-        ChannelDef("yandextv", "ntv-11"),
-        ChannelDef("yandextv", "sts-8"),
-    ],
-    "sport": [
-        ChannelDef("matchtv", "matchtv"),
-        ChannelDef("matchtv", "igra"),
-        ChannelDef("matchtv", "arena"),
-        ChannelDef("matchtv", "futbol-1"),
-        ChannelDef("matchtv", "futbol-2"),
-        ChannelDef("matchtv", "futbol-3"),
-        ChannelDef("matchtv", "strana"),
-        ChannelDef("yandextv", "start-103"),
-    ],
-}
-
-
-def resolve_group_channels(group_id: str) -> list[ChannelDef]:
-    return GROUP_CANNELS_MAP.get(group_id) or [ChannelDef(*item.split(":")) for item in group_id.split(",")]
-
-
-ScheduleGroupChannelsDepends = Annotated[list[ChannelDef], Depends(resolve_group_channels)]

gallery/easel/route/api/__init__.py

@@ -1,21 +1,7 @@
-from fastapi import FastAPI
+from fastapi import APIRouter
-from fastapi.middleware.cors import CORSMiddleware
-
-from gallery.easel.route import doc
 
 from . import schedule, weather
 
-app = FastAPI(
+router = APIRouter(prefix="/api")
-    docs_url=None,
+router.include_router(weather.router)
-    redoc_url=None,
+router.include_router(schedule.router)
-)
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-app.include_router(weather.router)
-app.include_router(schedule.router)
-doc.mount(app, "/api")

gallery/easel/route/api/schedule.py

@@ -1,11 +1,7 @@
 from fastapi import APIRouter
 
 from gallery.easel.core import AppRequest
-from gallery.easel.depends.schedule import (
+from gallery.easel.depends.schedule import ScheduleApiDepends
-    GROUP_CANNELS_MAP,
-    ScheduleApiDepends,
-    ScheduleGroupChannelsDepends,
-)
 from gallery.sketch.schedule.api import ScheduleApi
 from gallery.sketch.schedule.model import Channel, Schedule
 
@@ -14,19 +10,6 @@ from ...depends.date import DateDepends
 router = APIRouter(prefix="/schedule", tags=["Schedule"])
 
 
-@router.get("/groups")
-async def get_api_schedule_groups():
-    return list(GROUP_CANNELS_MAP.keys())
-
-
-@router.get("/group/{group_id}/{date}")
-async def get_api_schedule_group_schedule(
-    request: AppRequest, channels: ScheduleGroupChannelsDepends, date: DateDepends
-) -> list[Schedule]:
-    api = request.app.state.api
-    return [await api.get_api(ScheduleApi, channel.provider).get_schedule(channel.id, date) for channel in channels]
-
-
 @router.get("/providers")
 async def get_api_weather_providers(request: AppRequest) -> list[str]:
     return request.app.state.api.get_api_providers(ScheduleApi)

gallery/easel/route/doc/__init__.py

@@ -8,8 +8,7 @@ from fastapi.openapi.docs import (
 from fastapi.staticfiles import StaticFiles
 
 
-def mount(app: FastAPI, prefix: str | None = None):
+def mount(app: FastAPI):
-    openapi_url = prefix + app.openapi_url if prefix else app.openapi_url
     app.mount(
         "/docs/static",
         StaticFiles(directory=Path(__file__).parent / "static"),
@@ -18,7 +17,7 @@ def mount(app: FastAPI, prefix: str | None = None):
     @app.get("/docs", include_in_schema=False)
     async def custom_swagger_ui_html():
         return get_swagger_ui_html(
-            openapi_url=openapi_url,
+            openapi_url=app.openapi_url,
             title=app.title + " - Swagger UI",
             oauth2_redirect_url=app.swagger_ui_oauth2_redirect_url,
             swagger_js_url="docs/static/swagger-ui-bundle.js",
@@ -32,7 +31,7 @@ def mount(app: FastAPI, prefix: str | None = None):
     @app.get("/redoc", include_in_schema=False)
     async def redoc_html():
         return get_redoc_html(
-            openapi_url=openapi_url,
+            openapi_url=app.openapi_url,
             title=app.title + " - ReDoc",
             redoc_js_url="docs/static/redoc.standalone.js",
         )

gallery/easel/route/view/common/utils/template.py

@@ -45,7 +45,7 @@ def build_url(
     if query:
         query_dict = {**dict(parse_qsl(parts.query)), **query}
         parts = parts._replace(query=urlencode(query_dict))
-    return "/".join([""] + parts.geturl().split("/")[3:])
+    return parts.geturl()
 
 
 def build_templates(

gallery/easel/route/view/root/templates/root_index.html

@@ -17,13 +17,13 @@
 </div>
 <h1>{{_("Docs")}}</h1>
 <div class="list-group mb-3">
-  <app-link href="/api/docs"
+  <app-link href="/docs"
             target="_blank"
             icon="file-earmark-text"
             class="list-group-item list-group-item-action">
     Swagger UI
   </app-link>
-  <app-link href="/api/redoc"
+  <app-link href="/redoc"
             target="_blank"
             icon="file-earmark-text"
             class="list-group-item list-group-item-action">

gallery/easel/route/view/schedule/bundle.py

@@ -0,0 +1,18 @@
+GROUP_MAP = {
+    "central": [
+        ("yandextv", "146"),  # pervyy
+        ("yandextv", "587"),  # rossya-1
+        ("yandextv", "162"),  # ntv
+        ("yandextv", "79"),  # sts
+    ],
+    "sport": [
+        ("matchtv", "matchtv"),
+        ("matchtv", "igra"),
+        ("matchtv", "arena"),
+        ("matchtv", "futbol-1"),
+        ("matchtv", "futbol-2"),
+        ("matchtv", "futbol-3"),
+        ("matchtv", "strana"),
+        ("yandextv", "1799"),  # start
+    ],
+}

gallery/easel/route/view/schedule/route.py

@@ -8,16 +8,13 @@ from fastapi.responses import HTMLResponse, RedirectResponse
 from gallery.easel.core import AppRequest
 from gallery.easel.depends.api import api_resolver
 from gallery.easel.depends.date import DateDepends
-from gallery.easel.depends.schedule import (
+from gallery.easel.depends.schedule import ScheduleApiDepends
-    GROUP_CANNELS_MAP,
-    ScheduleApiDepends,
-    ScheduleGroupChannelsDepends,
-)
 from gallery.sketch.bundle import ApiBundle
 from gallery.sketch.schedule.api import ScheduleApi
 from gallery.sketch.schedule.model import Schedule
 
 from ..common.utils.template import build_templates
+from .bundle import GROUP_MAP
 from .filters import timedelta_format
 
 
@@ -48,7 +45,7 @@ async def get_schedule_index(request: AppRequest, provider: str | None = None, q
     return templates.TemplateResponse(
         request=request,
         name="index.html",
-        context={"channels": [item.model_dump() for item in channels], "groups": GROUP_CANNELS_MAP.keys()},
+        context={"channels": [item.model_dump() for item in channels], "groups": GROUP_MAP.keys()},
     )
 
 
@@ -64,11 +61,9 @@ async def get_group_default(group_id: str):
 
 
 @router.get("/group/{group_id}/{date}", response_class=HTMLResponse)
-async def get_group(request: AppRequest, channels: ScheduleGroupChannelsDepends, date: DateDepends):
+async def get_group(request: AppRequest, group_id: str, date: DateDepends):
-    responses = [
+    channels = GROUP_MAP.get(group_id, [tuple(item.split(":")) for item in group_id.split(",")])
-        await request.app.state.api.get_api(ScheduleApi, channel.provider).get_schedule(channel.id, date)
+    responses = await _get_group_schedule(request.app.state.api, channels, date)
-        for channel in channels
-    ]
     return templates.TemplateResponse(
         request=request,
         name="group.html",

gallery/easel/route/view/weather/filters.py

@@ -7,15 +7,17 @@ from gallery.sketch.weather.model import (
     Precipitation,
     Sky,
     WindDirection,
+    WindDirectionDeg,
 )
 from gallery.util import root_path
 
 
-def wind_direction_icon(wind_direction: WindDirection | None) -> str:
+def wind_direction_icon(wind_direction_deg: float) -> str:
-    if wind_direction is None:
+    wind_direction = WindDirectionDeg(wind_direction_deg).direction
+    if wind_direction == WindDirection.CALM:
         return "wind-calm"
     else:
-        return f"wind-from-{wind_direction.lower()}"
+        return f"wind-from-{wind_direction.name.lower()}"
 
 
 def cloudness_icon(sky: Sky, date: datetime.datetime, period: str) -> list[str]:

gallery/easel/route/view/weather/templates/weather.html

@@ -107,8 +107,8 @@ locale=request.state.language)}}{% endblock %}
         {% for value in response.values %}
         <td class="wind"
             data-bs-toggle="tooltip"
-            data-bs-title="{{ value.wind.direction }}">
+            data-bs-title="{{ value.wind_direction }}">
-          <div class="wi-svg wi-s wi-{{value.wind.direction | wind_direction_icon}}"
+          <div class="wi-svg wi-s wi-{{value.wind_direction | wind_direction_icon}}"
                style="margin: 0 auto;">{{ 'wind-deg' | weather_icon_svg }}</div>
         </td>
         {% endfor %}
@@ -123,11 +123,11 @@ locale=request.state.language)}}{% endblock %}
       <tr>
         {% for value in response.values %}
         <td class="wind"
-            style="background-color: rgba(128, 128, 128, {{value.wind.speed * 0.05}});">
+            style="background-color: rgba(128, 128, 128, {{value.wind_speed * 0.05}});">
-          <span class="speed">{{value.wind.speed}}</span>
+          <span class="speed">{{value.wind_speed}}</span>
-          {% if value.wind.gust != value.wind.speed and value.wind.gust > 0 %}
+          {% if value.wind_gust != value.wind_speed and value.wind_gust > 0 %}
           <span class="gust">
-            ({{value.wind.gust}})
+            ({{value.wind_gust}})
           </span>
           {% endif %}
         </td>

gallery/painting/gismeteo/api.py

@@ -12,31 +12,12 @@ from gallery.sketch.weather.api import WeatherApi
 from gallery.sketch.weather.model import Location, WeatherResponse, WeatherValue
 from gallery.sketch.weather.util import merge_weather_values
 
+from . import datehelp
 from .parser import DAYS_PARSER, LOCATION_PARSER, ONE_DAY_PARSER, ROW_PARSERS
 
 logger = logging.getLogger("gismeteo")
 
 
-def format_date(date: datetime.date) -> str:
-    today = datetime.date.today()
-    days = (date - today).days
-    if days == 0:
-        return "today"
-    elif days == 1:
-        return "tomorrow"
-    else:
-        return f"{days + 1}-day"
-
-
-def set_dict_nested_value(target: dict, key: str, value: Any):
-    parts = key.split(".")
-    for part in parts[:-1]:
-        if part not in target:
-            target[part] = {}
-        target = target[part]
-    target[parts[-1]] = value
-
-
 class GismeteoApi(WeatherApi):
     PROVIDER = "gismeteo"
 
@@ -55,7 +36,7 @@ class GismeteoApi(WeatherApi):
             for index, value in enumerate(parser.parse_row(widget)):
                 while len(result) < index + 1:
                     result.append({})
-                set_dict_nested_value(result[index], parser.KEY, value)
+                result[index][parser.KEY] = value
         values = [WeatherValue(**item) for item in result]
         # group values by 3 hours
         if len(values) > 8:
@@ -79,7 +60,7 @@ class GismeteoApi(WeatherApi):
             for index, value in enumerate(parser.parse_row(widget)):
                 while len(result) < index + 1:
                     result.append({})
-                set_dict_nested_value(result[index], parser.KEY, value)
+                result[index][parser.KEY] = value
         values = [WeatherValue(**item) for item in result]
         return WeatherResponse(
             location=location or "n/a",
@@ -126,7 +107,7 @@ class GismeteoApi(WeatherApi):
             raise HTTPException(
                 status_code=status.HTTP_400_BAD_REQUEST, detail={"max_date": max_date.strftime("%Y-%m-%d")}
             )
-        data = await self.source.request(f"weather-{location_id}/{format_date(date)}")
+        data = await self.source.request(f"weather-{location_id}/{datehelp.dump(date)}")
         return self._parse_oneday(date, data)
 
     async def get_days(self, location_id: str, days: int) -> WeatherResponse:

gallery/painting/gismeteo/core.py

@@ -0,0 +1,31 @@
+from typing import Generic, Iterable, Optional, TypeVar
+
+from bs4 import Tag
+
+T = TypeVar("T")
+
+
+class WidgetParser:
+    def parse_widget(self, tag: Tag) -> Tag:
+        raise NotImplementedError
+
+
+class BaseWidgetParser(WidgetParser):
+    SELECT: str
+
+    def __init__(self, select: Optional[str] = None):
+        super().__init__()
+        self._select = select or self.SELECT
+
+    def parse_widget(self, tag: Tag) -> Tag:
+        widget = tag.select_one(self._select)
+        if widget is None:
+            raise ValueError(self._select)
+        return widget
+
+
+class RowParser(Generic[T]):
+    KEY: str
+
+    def parse_row(self, tag: Tag) -> Iterable[T]:
+        raise NotImplementedError

gallery/painting/gismeteo/datehelp.py

@@ -0,0 +1,39 @@
+import datetime
+from enum import Enum
+
+import dateparser
+import dateparser.date_parser
+
+
+class Day(str, Enum):
+    TODAY = "today"
+    TOMORROW = "tomorrow"
+    DAY_3 = "3-day"
+    DAY_4 = "4-day"
+    DAY_5 = "5-day"
+
+
+def parse(value: str) -> datetime.date:
+    if value in ["today", "mock"]:
+        return datetime.date.today()
+    elif value == "tomorrow":
+        return datetime.date.today() + datetime.timedelta(days=1)
+    elif value.endswith("-day"):
+        days = int(value.split("-")[0]) - 1
+        return datetime.date.today() + datetime.timedelta(days=days)
+    else:
+        date = dateparser.parse(value)
+        if date is None:
+            raise ValueError(value)
+        return date.date()
+
+
+def dump(date: datetime.date) -> str:
+    today = datetime.date.today()
+    days = (date - today).days
+    if days == 0:
+        return "today"
+    elif days == 1:
+        return "tomorrow"
+    else:
+        return f"{days + 1}-day"

gallery/painting/gismeteo/parser.py

@@ -1,7 +1,7 @@
 import datetime
 import logging
 import re
-from typing import Generic, Iterable, Optional, TypeVar
+from typing import Iterable
 
 import dateparser
 from bs4 import Tag
@@ -14,37 +14,10 @@ from gallery.sketch.weather.model import (
 )
 from gallery.sketch.weather.parser import ParseError, parse_wind_direction
 
+from .core import BaseWidgetParser, RowParser
+
 logger = logging.getLogger("gismeteo")
 
-T = TypeVar("T")
-
-
-class WidgetParser:
-    def parse_widget(self, tag: Tag) -> Tag:
-        raise NotImplementedError
-
-
-class BaseWidgetParser(WidgetParser):
-    SELECT: str
-
-    def __init__(self, select: Optional[str] = None):
-        super().__init__()
-        self._select = select or self.SELECT
-
-    def parse_widget(self, tag: Tag) -> Tag:
-        widget = tag.select_one(self._select)
-        if widget is None:
-            raise ValueError(self._select)
-        return widget
-
-
-class RowParser(Generic[T]):
-    KEY: str
-
-    def parse_row(self, tag: Tag) -> Iterable[T]:
-        raise NotImplementedError
-
-
 ONE_DAY_PARSER = BaseWidgetParser(".widget.widget-oneday .widget-items")
 DAYS_PARSER = BaseWidgetParser(".widget.widget-days .widget-items")
 
@@ -161,7 +134,7 @@ class TemperatureParser(RowParser[list[int]]):
 
 
 class WindSpeedParser(RowParser[int]):
-    KEY = "wind.speed"
+    KEY = "wind_speed"
 
     def parse_row(self, tag: Tag) -> Iterable[int]:
         for item in tag.select(".widget-row-wind > .row-item > .wind-speed > speed-value"):
@@ -169,7 +142,7 @@ class WindSpeedParser(RowParser[int]):
 
 
 class WindGustParser(RowParser[int]):
-    KEY = "wind.gust"
+    KEY = "wind_gust"
 
     def parse_row(self, tag: Tag) -> Iterable[int]:
         for item in tag.select(".widget-row-wind > .row-item > .wind-gust"):
@@ -178,7 +151,7 @@ class WindGustParser(RowParser[int]):
 
 
 class WindDirectionParser(RowParser[WindDirection]):
-    KEY = "wind.direction"
+    KEY = "wind_direction"
 
     def parse_row(self, tag: Tag) -> Iterable[float]:
         for item in tag.select(".widget-row-wind > .row-item > .wind-speed > .wind-direction"):

gallery/painting/openweather/parser.py

@@ -3,7 +3,6 @@ import datetime
 from gallery.sketch.weather.model import Cloudness, Precipitation, WeatherValue
 from gallery.sketch.weather.util import build_weather_value
 
-from ...sketch.weather.parser import parse_wind_direction
 from .openweather import ForecastItem
 
 
@@ -32,9 +31,9 @@ class ForecastItemParser:
         # value.temperature = [round(item.main.temp_max), round(item.main.temp_min)]
         value.pressure = [round(item.main.pressure * 0.75006)]
         value.humidity = item.main.humidity
-        value.wind.speed = round(item.wind.speed)
+        value.wind_speed = round(item.wind.speed)
-        value.wind.gust = round(item.wind.gust)
+        value.wind_gust = round(item.wind.gust)
-        value.wind.direction = parse_wind_direction(item.wind.deg)
+        value.wind_direction = item.wind.deg
         value.sky.cloudness = self.CLOUDNESS_MAP.get(item.weather[0].description, Cloudness.CLEAR)
         value.sky.precipitation = self.PRECIPITATION_MAP.get(item.weather[0].description, Precipitation.NO)
         if item.rain:

gallery/painting/rp5/parser.py

@@ -1,6 +1,4 @@
 import re
-from enum import Enum, auto
-from typing import Iterable
 
 import dateparser
 from bs4 import BeautifulSoup, Tag
@@ -38,109 +36,72 @@ def _parse_wind_speed(cell: Tag) -> int:
     return 0
 
 
-class RowType(Enum):
-    DATE = auto()
-    TIME = auto()
-    CLOUDNESS = auto()
-    PRECIPITATION = auto()
-    TEMPERATURE = auto()
-    PRESSURE = auto()
-    WIND_SPEED = auto()
-    WIND_GUST = auto()
-    WIND_DIRECTION = auto()
-    HUMIDITY = auto()
-
-
-def _iter_table_rows(table: Tag) -> Iterable[tuple[RowType, Tag]]:
-    for row in table.select("tr"):
-        title = row.select_one("td").text.strip().lower()
-        if "сегодня" in title or "завтра" in title:
-            yield RowType.DATE, row
-        elif "местное время" in title:
-            yield RowType.TIME, row
-        elif "облачность" in title:
-            yield RowType.CLOUDNESS, row
-        elif "осадки" in title:
-            yield RowType.PRECIPITATION, row
-        elif "температура" in title:
-            yield RowType.TEMPERATURE, row
-        elif "давление" in title:
-            yield RowType.PRESSURE, row
-        elif "скорость" in title:
-            yield RowType.WIND_SPEED, row
-        elif "порывы" in title:
-            yield RowType.WIND_GUST, row
-        elif "направление" in title:
-            yield RowType.WIND_DIRECTION, row
-        elif "влажность" in title:
-            yield RowType.HUMIDITY, row
-
-
 # pylint:disable=too-many-branches
 def parse_page(page: BeautifulSoup) -> list[WeatherResponse]:
     location = page.select(".intoLeftNavi > .verticalBottom > a")[-1].text.strip()
     table = page.select_one("#forecastTable")
     if table is None:
         raise ParseError("#forecastTable not found")
+    (
+        date_row,
+        time_row,
+        cloudness_row,
+        precipitation_row,
+        temperature_row,
+        pressure_row,
+        wind_speed_row,
+        wind_gust_row,
+        wind_direction_row,
+        humidity_row,
+        *_,
+    ) = table.select("tr")
     result: list[WeatherResponse] = []
     values: list[WeatherValue] = []
-    for row_type, row in _iter_table_rows(table):
+    for index, cell in enumerate(date_row.select("td")):
-        match row_type:
+        colspan = int(cell.attrs["colspan"])
-            case RowType.DATE:
+        if index == 0:
-                for index, cell in enumerate(row.select("td")):
+            colspan -= 1
-                    colspan = int(cell.attrs["colspan"])
+        date_str = ",".join(cell.text.strip().split(",")[-2:])
-                    if index == 0:
+        date = dateparser.parse(date_str, languages=["ru"])
-                        colspan -= 1
+        if date is None:
-                    date_str = ",".join(cell.text.strip().split(",")[-2:])
+            raise ParseError.invalid_date(date_str)
-                    date = dateparser.parse(date_str, languages=["ru"])
+        item_values = [build_weather_value(date) for _ in range(colspan)]
-                    if date is None:
+        result.append(
-                        raise ParseError.invalid_date(date_str)
+            WeatherResponse(
-                    item_values = [build_weather_value(date) for _ in range(colspan)]
+                location=location,
-                    result.append(
+                date=date.date(),
-                        WeatherResponse(
+                period="day",
-                            location=location,
+                values=item_values,
-                            date=date.date(),
+            )
-                            period="day",
+        )
-                            values=item_values,
+        values += item_values
-                        )
+    for index, cell in enumerate(time_row.select("td")[1:]):
-                    )
+        hour = int(cell.text.strip())
-                    values += item_values
+        values[index].date = values[index].date.replace(hour=hour)
-            case RowType.TIME:
+    for index, cell in enumerate(cloudness_row.select("td")[1:]):
-                for index, cell in enumerate(row.select("td")[1:]):
+        onmouseover = cell.select_one(".cc_0").next_element.attrs["onmouseover"]
-                    hour = int(cell.text.strip())
+        cloudness_str = re.compile("<b>(.*?)</b>").search(onmouseover).group(1).strip()
-                    values[index].date = values[index].date.replace(hour=hour)
+        values[index].sky.cloudness = CLOUDNESS_MAP[cloudness_str]
-            case RowType.CLOUDNESS:
+    for index, cell in enumerate(precipitation_row.select("td")[1:]):
-                for index, cell in enumerate(row.select("td")[1:]):
+        onmouseover = cell.select_one(".pr_0").attrs["onmouseover"]
-                    onmouseover = cell.select_one(".cc_0").next_element.attrs["onmouseover"]
+        precipitation_str = onmouseover.split(",")[1].strip(" '")
-                    cloudness_str = re.compile("<b>(.*?)</b>").search(onmouseover).group(1).strip()
+        precipitation_value_matched = re.compile("(\\d+\\.\\d+) мм").search(precipitation_str)
-                    values[index].sky.cloudness = CLOUDNESS_MAP[cloudness_str]
+        if precipitation_value_matched:
-            case RowType.PRECIPITATION:
+            # one hour value
-                for index, cell in enumerate(row.select("td")[1:]):
+            values[index].precipitation = float(precipitation_value_matched.group(1)) * 6
-                    onmouseover = cell.select_one(".pr_0").attrs["onmouseover"]
+        if "(" in precipitation_str:
-                    precipitation_str = onmouseover.split(",")[1].strip(" '")
+            precipitation_str = precipitation_str.split(" (")[0]
-                    precipitation_value_matched = re.compile("(\\d+\\.\\d+) мм").search(precipitation_str)
+        values[index].sky.precipitation = PRECIPITATION_MAP[precipitation_str]
-                    if precipitation_value_matched:
+    for index, cell in enumerate(temperature_row.select("td")[1:]):
-                        # one hour value
+        values[index].temperature = [int(cell.select_one(".t_0").text.lstrip("+").strip())]
-                        values[index].precipitation = float(precipitation_value_matched.group(1)) * 6
+    for index, cell in enumerate(pressure_row.select("td")[1:]):
-                    if "(" in precipitation_str:
+        values[index].pressure = [int(cell.select_one(".p_0").text.strip())]
-                        precipitation_str = precipitation_str.split(" (")[0]
+    for index, cell in enumerate(wind_speed_row.select("td")[1:]):
-                    values[index].sky.precipitation = PRECIPITATION_MAP[precipitation_str]
+        values[index].wind_speed = _parse_wind_speed(cell)
-            case RowType.TEMPERATURE:
+    for index, cell in enumerate(wind_gust_row.select("td")[1:]):
-                for index, cell in enumerate(row.select("td")[1:]):
+        values[index].wind_gust = _parse_wind_speed(cell)
-                    values[index].temperature = [int(cell.select_one(".t_0").text.lstrip("+").strip())]
+    for index, cell in enumerate(wind_direction_row.select("td")[1:]):
-            case RowType.PRESSURE:
+        values[index].wind_direction = parse_wind_direction(cell.text.strip())
-                for index, cell in enumerate(row.select("td")[1:]):
+    for index, cell in enumerate(humidity_row.select("td")[1:]):
-                    values[index].pressure = [int(cell.select_one(".p_0").text.strip())]
+        values[index].humidity = int(cell.text.strip())
-            case RowType.WIND_SPEED:
-                for index, cell in enumerate(row.select("td")[1:]):
-                    values[index].wind.speed = _parse_wind_speed(cell)
-            case RowType.WIND_GUST:
-                for index, cell in enumerate(row.select("td")[1:]):
-                    values[index].wind.gust = _parse_wind_speed(cell)
-            case RowType.WIND_DIRECTION:
-                for index, cell in enumerate(row.select("td")[1:]):
-                    values[index].wind.direction = parse_wind_direction(cell.text.strip())
-            case RowType.HUMIDITY:
-                for index, cell in enumerate(row.select("td")[1:]):
-                    values[index].humidity = int(cell.text.strip())
     return result

gallery/painting/yandextv/api.py

@@ -16,15 +16,13 @@ logger = logging.getLogger("matchtv")
 class YandexTvApi(ScheduleApi):
     PROVIDER = "yandextv"
 
-    lr = 213  # magic id
-
     def _build_source(self) -> ApiSource:
         return ApiSource("https://tv.yandex.ru", headers=build_headers("tv.yandex.ru"))
 
     async def find_channels(self, query: str) -> list[Channel]:
         url = (
             "https://suggest-multi.yandex.ru/suggest-tv2?"
-            f"v=4&uil=ru&lr={self.lr}&count_channels=4&count_programs=4&sn=50&part={query}"
+            f"v=4&uil=ru&lr=10&count_channels=4&count_programs=4&sn=50&part={query}"
         )
         _, values = json.loads(await self.source.request(url))
         result = []
@@ -35,7 +33,7 @@ class YandexTvApi(ScheduleApi):
         return result
 
     async def get_schedule(self, channel_id: str, date: datetime.date) -> Schedule:
-        endpoint = f"{self.lr}/channel/{channel_id}?date={date:%Y-%m-%d}"
+        endpoint = f"channels/{channel_id}?date={date:%Y-%m-%d}"
         data = await self.source.request(endpoint)
         soup = BeautifulSoup(data, features="html.parser")
         if soup.select_one(".CheckboxCaptcha") is not None:

gallery/painting/yandexweather/parser.py

@@ -72,10 +72,10 @@ def parse_article(article: Tag, location: str) -> WeatherResponse:
         value.temperature.append(temperature)
         wind_speed_tag = temperature_tag.next_element.next_element
         wind_speed = int(wind_speed_tag.text.strip())
-        value.wind.speed = wind_speed
+        value.wind_speed = wind_speed
         wind_direction_tag = wind_speed_tag.next_element.next_element.next_element.next_element
         wind_direction_str = wind_direction_tag.text.strip()
-        value.wind.direction = parse_wind_direction(wind_direction_str)
+        value.wind_direction = parse_wind_direction(wind_direction_str)
         humidity_tag = wind_direction_tag.next_element.next_element.next_element.next_element
         humidity = int(humidity_tag.text.strip().rstrip("%"))
         value.humidity = humidity

gallery/sketch/weather/model.py

@@ -58,6 +58,7 @@ class Sky(Model):
 
 
 class WindDirection(StrEnum):
+    CALM = auto()
     N = auto()
     NE = auto()
     E = auto()
@@ -68,17 +69,62 @@ class WindDirection(StrEnum):
     NW = auto()
 
 
-class Wind(Model):
+class WindDirectionDeg(float):
-    speed: int
+    @property
-    gust: int
+    def direction(self) -> WindDirection:
-    direction: WindDirection | None = None
+        return self.to_direction()
+
+    @property
+    def value(self) -> float:
+        return self
+
+    # pylint:disable=too-many-return-statements
+    def to_direction(self) -> WindDirection:
+        if self == -1:
+            return WindDirection.CALM
+        elif self > 337.5 or self <= 22.25:
+            return WindDirection.N
+        elif self <= 67.5:
+            return WindDirection.NE
+        elif self <= 112.5:
+            return WindDirection.E
+        elif self <= 157.5:
+            return WindDirection.SE
+        elif self <= 202.5:
+            return WindDirection.S
+        elif self <= 247.5:
+            return WindDirection.SW
+        elif self <= 292.5:
+            return WindDirection.W
+        elif self <= 337.5:
+            return WindDirection.NW
+        else:
+            raise ValueError(self)
+
+    @classmethod
+    def from_direction(cls, direction: WindDirection) -> Self:
+        return cls(
+            {
+                WindDirection.CALM: -1,
+                WindDirection.N: 0,
+                WindDirection.NE: 45,
+                WindDirection.E: 90,
+                WindDirection.SE: 135,
+                WindDirection.S: 180,
+                WindDirection.SW: 225,
+                WindDirection.W: 270,
+                WindDirection.NW: 315,
+            }[direction]
+        )
 
 
 class WeatherValue(Model):
     date: datetime.datetime
     sky: Sky
-    wind: Wind
     temperature: list[int]
+    wind_speed: int
+    wind_gust: int
+    wind_direction: float
     precipitation: float
     pressure: list[int] = Field(default=[])
     humidity: int = Field(default=-1)

gallery/sketch/weather/parser.py

@@ -1,6 +1,6 @@
 from typing import Self
 
-from gallery.sketch.weather.model import WindDirection
+from gallery.sketch.weather.model import WindDirection, WindDirectionDeg
 
 
 class ParseError(Exception):
@@ -9,7 +9,11 @@ class ParseError(Exception):
         return cls("Invalid date string", date_str)
 
 
-WIND_DIRECTION_MAP: dict[str, WindDirection | None] = {
+WIND_DIRECTION_MAP: dict[str, WindDirection] = {
+    "—": WindDirection.CALM,
+    "": WindDirection.CALM,
+    "штиль": WindDirection.CALM,
+    "штл": WindDirection.CALM,
     "с": WindDirection.N,
     "св": WindDirection.NE,
     "в": WindDirection.E,
@@ -21,34 +25,5 @@ WIND_DIRECTION_MAP: dict[str, WindDirection | None] = {
 }
 
 
-# pylint:disable=too-many-return-statements
+def parse_wind_direction(value: str) -> WindDirectionDeg:
-def _parse_wind_direction_number(value: int | float) -> WindDirection | None:
+    return WindDirectionDeg.from_direction(WIND_DIRECTION_MAP[value.replace("-", "").lower()])
-    if value > 337.5 or value <= 22.25:
-        return WindDirection.N
-    elif value <= 67.5:
-        return WindDirection.NE
-    elif value <= 112.5:
-        return WindDirection.E
-    elif value <= 157.5:
-        return WindDirection.SE
-    elif value <= 202.5:
-        return WindDirection.S
-    elif value <= 247.5:
-        return WindDirection.SW
-    elif value <= 292.5:
-        return WindDirection.W
-    elif value <= 337.5:
-        return WindDirection.NW
-    else:
-        return None
-
-
-def _parse_wind_direction_str(value: str) -> WindDirection | None:
-    return WIND_DIRECTION_MAP.get(value.replace("-", "").lower())
-
-
-def parse_wind_direction(value: str | int | float) -> WindDirection | None:
-    if isinstance(value, str):
-        return _parse_wind_direction_str(value)
-    else:
-        return _parse_wind_direction_number(value)

gallery/sketch/weather/util.py

@@ -1,8 +1,8 @@
 import datetime
 import statistics
-from typing import Counter, Literal
+from typing import Literal
 
-from .model import Cloudness, Precipitation, Sky, WeatherValue, Wind
+from .model import Cloudness, Precipitation, Sky, WeatherValue, WindDirectionDeg
 
 MergeMode = Literal["interval", "average"]
 
@@ -16,12 +16,10 @@ def build_weather_value(date: datetime.datetime) -> WeatherValue:
             thunder=False,
             fog=False,
         ),
-        wind=Wind(
-            speed=0,
-            gust=0,
-            direction=None,
-        ),
         temperature=[],
+        wind_speed=0,
+        wind_gust=0,
+        wind_direction=WindDirectionDeg(-1),
         precipitation=0,
         pressure=[],
         humidity=-1,
@@ -57,18 +55,18 @@ def merge_weather_values(
         temperatures += value.temperature
         pressures += value.pressure
         humidities.append(value.humidity)
-        wind_speeds.append(value.wind.speed)
+        wind_speeds.append(value.wind_speed)
-        wind_gusts.append(value.wind.gust)
+        wind_gusts.append(value.wind_gust)
-        wind_directions.append(value.wind.direction)
+        wind_directions.append(value.wind_direction)
         cloudnesses.append(value.sky.cloudness)
         precipitations.append(value.sky.precipitation)
         precipitation += value.precipitation
     result.temperature = _merge_values(temperatures, mode)
     result.pressure = _merge_values(pressures, mode)
     result.humidity = round(statistics.mean(humidities))
-    result.wind.speed = round(statistics.mean(wind_speeds))
+    result.wind_speed = round(statistics.mean(wind_speeds))
-    result.wind.gust = round(statistics.mean(wind_gusts))
+    result.wind_gust = round(statistics.mean(wind_gusts))
-    result.wind.direction = Counter(wind_directions).most_common(1)[0][0]
+    result.wind_direction = statistics.mean(wind_directions)
     for item in cloudnesses:
         if Cloudness.values.index(item) > Cloudness.values.index(result.sky.cloudness):
             result.sky.cloudness = item

pyproject.toml

@@ -1,7 +1,7 @@
 [project]
 name = "gallery"
 description = ""
-version = "0.9.0"
+version = "0.7.0"
 readme = "README.md"
 authors = [{ name = "shmyga", email = "shmyga.z@gmail.com" }]
 requires-python = '>=3.14,<4.0'

scripts/develop

@@ -0,0 +1,5 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+docker compose -f docker-compose-develop.yaml up --build --watch

scripts/docker-action

@@ -0,0 +1,55 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+. .env
+
+build () {
+  echo "build: $1"
+  . "$1/.env"
+  for PROJECT in "${DOCKER_PROJECTS[@]}"; do
+    IFS=: read -r PROJECT_NAME PROJECT_TARGET <<< "$PROJECT"
+    ARGS=("build")
+    for ARG in ${DOCKER_ARGS[@]}; do
+      ARGS+=("--build-arg" "$ARG")
+    done
+    if [ -n "$PROJECT_TARGET" ]; then
+      ARGS+=("--target" "$PROJECT_TARGET")
+    fi
+    ARGS+=("-t" "$DOCKER_GROUP/$PROJECT_NAME" ".")
+    ARGS+=("-f" "$1/Dockerfile")
+    echo "${ARGS[@]}"
+    docker "${ARGS[@]}"
+  done
+}
+
+publish () {
+  echo "publish: $1"
+  . "$1/.env"
+  for PROJECT in "${DOCKER_PROJECTS[@]}"; do
+    IFS=: read -r PROJECT_NAME PROJECT_TARGET <<< "$PROJECT"
+    docker tag $DOCKER_GROUP/$PROJECT_NAME $DOCKER_ROOT/$PROJECT_NAME:$VERSION
+    docker tag $DOCKER_GROUP/$PROJECT_NAME $DOCKER_ROOT/$PROJECT_NAME:$DOCKER_TAG
+    docker push $DOCKER_ROOT/$PROJECT_NAME:$VERSION
+    docker push $DOCKER_ROOT/$PROJECT_NAME:$DOCKER_TAG
+  done
+}
+
+save () {
+  echo "save: $1"
+  . "$1/.env"
+  mkdir -p "$1/dist"
+  for PROJECT in "${DOCKER_PROJECTS[@]}"; do
+    IFS=: read -r PROJECT_NAME PROJECT_TARGET <<< "$PROJECT"
+    docker save --output "$1/dist/$PROJECT_NAME-$VERSION.tar" "$DOCKER_GROUP/$PROJECT_NAME"
+  done
+}
+
+DEFAULT_TARGETS="."
+TARGETS="${@-$DEFAULT_TARGETS}"
+
+DOCKER_ACTION="${DOCKER_ACTION-build}"
+
+for TARGET in $TARGETS; do
+  $DOCKER_ACTION "$TARGET"
+done

scripts/format

@@ -0,0 +1,8 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+TARGET="gallery"
+
+poetry run isort $TARGET
+poetry run black $TARGET -q

scripts/lint

@@ -0,0 +1,9 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+TARGET="gallery"
+
+poetry run pylint $TARGET -sn
+poetry run isort $TARGET --check-only
+poetry run black $TARGET -q --check --diff

scripts/locales

@@ -0,0 +1,6 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+cd locales/ru/LC_MESSAGES || exit
+msgfmt messages.po

scripts/setup

@@ -0,0 +1,23 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+# env
+if [[ ! -f .env ]]; then
+  cp .env-base .env
+fi
+source .env
+
+# python
+poetry env use ${PYTHON_VERSION}
+poetry install
+.venv/bin/playwright install chromium --with-deps --only-shell
+
+# static
+cd static || exit
+
+if [[ -f $HOME/.nvm/nvm.sh ]]; then
+  source "$HOME/.nvm/nvm.sh"
+  nvm use
+fi
+npm ci

scripts/test

@@ -0,0 +1,5 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+OPENWEATHER_KEY="" poetry run pytest tests

scripts/version

@@ -0,0 +1,19 @@
+#!/usr/bin/env bash
+set -e
+cd "$(dirname $(dirname "$0"))" || exit
+
+if [ -z "$1" ]; then
+  echo "Usage: $0 [version]"
+  exit 1
+fi
+
+if [[ ! -z "$(git status -s)" ]]; then
+  echo "Uncomitted changes"
+  exit 1
+fi
+
+poetry version $1
+(cd static && npm version $1 --allow-same-version)
+git add .
+git commit -m "ci(version): $1"
+git tag $1

static/package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "gallery",
-  "version": "0.9.0",
+  "version": "0.7.0",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "gallery",
-      "version": "0.9.0",
+      "version": "0.7.0",
       "license": "ISC",
       "dependencies": {
         "@popperjs/core": "^2.11.8",

static/package.json

@@ -1,6 +1,6 @@
 {
   "name": "gallery",
-  "version": "0.9.0",
+  "version": "0.7.0",
   "type": "module",
   "scripts": {
     "build": "webpack --mode production",

static/src/app/schedule/component.ts

@@ -32,6 +32,10 @@ export class ScheduleChannelItem extends ListItemElement<Channel> {
     <span class="text-primary">${value.name}</span>
     `;
   }
+
+  getBadge(value: Channel): string | null {
+    return value.provider;
+  }
 }
 
 export class ScheduleChannelList extends ListElement<Channel, ScheduleChannelItem> {

static/src/app/weather/component.ts

@@ -16,6 +16,10 @@ export class WheatherLocationItem extends ListItemElement<Location> {
     </span>
     `;
   }
+
+  getBadge(value: Location): string | null {
+    return value.provider;
+  }
 }
 
 export class WeatherLocationList extends ListElement<Location, WheatherLocationItem> {

tests/test_rp5.py

@@ -18,10 +18,10 @@ async def test_search(rp5_api: RP5WeatherApi):
 
 
 async def test_day(rp5_api: RP5WeatherApi):
-    result = await rp5_api.get_day("test", datetime.date(2026, 9, 11))
+    result = await rp5_api.get_day("test", datetime.date(2026, 9, 2))
     assert len(result.values) == 4
 
 
 async def test_days(rp5_api: RP5WeatherApi):
     result = await rp5_api.get_days("test", 10)
-    assert len(result.values) == 8
+    assert len(result.values) == 7

tests/test_yandexweather_api.py

@@ -18,7 +18,7 @@ async def test_search(yandexweather_api: YandexWeatherApi):
 
 
 async def test_day(yandexweather_api: YandexWeatherApi):
-    result = await yandexweather_api.get_day("test", datetime.date(2026, 9, 1))
+    result = await yandexweather_api.get_day("test", datetime.date.today())
     assert len(result.values) == 4