feat(stats): fold reactions into daily aggregate and cache stats API

リアクションは 1 タップ = 1 行で大量に溜まるため、ルーム終了時に日次×種別へ
畳み込み、生データは破棄する集計モデルを導入する。あわせて統計 API のレスポンスを
Redis にキャッシュし、毎リクエストの DB 集計を避ける。

- models.ReactionStat: (date, reaction_type) 一意の日次集計（count 加算）
- cron.fold_room_reactions: ルーム終了（host削除/猶予削除/保持期間切れ）時に
  当該ルームのリアクションを ReactionStat へ加算し、AnimeReaction を hard delete
- consumers: ルーム終了経路で畳み込みを呼ぶ
- api/views: 統計 API を ReactionStat 参照＋キャッシュ化
- settings.CACHES: channel layer(DB0) と分けて Redis DB1 を使用
- .env.django: STATS_CACHE_SECONDS を追加、不要になった REACTION_HARD_DIVIDE_DAY を削除
- tests: test_stats_folding.py 追加、api/streamer のテストを拡充

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

Author: Uno-Takashi

.env.django

@@ -8,6 +8,7 @@ REDIS_PORT=6379
 CHROME_EXTENSION_REQUIRED_VERSION=1.0.0
 LOGICAL_DIVIDE_DAY=3
 HARD_DIVIDE_DAY=365
-REACTION_HARD_DIVIDE_DAY=90
+# 統計 API のレスポンスキャッシュ TTL（秒）。
+STATS_CACHE_SECONDS=300
 # Retention cleanup schedule (system cron in the container). Every minute in dev.
 CRON_SCHEDULE=* * * * *

api/tests.py

@@ -1,10 +1,25 @@
+import datetime
 import os
 
 import pytest
+from django.utils import timezone
 from rest_framework import status
 from rest_framework.test import APIClient, APITestCase
 
-from streamer.factories import AnimeRoomFactory
+from streamer.factories import AnimeRoomFactory, AnimeUserFactory
+from streamer.models import AnimeReaction, ReactionStat
+
+
+def _clear_reaction_tables() -> None:
+    """Drop reaction rows so reaction-count assertions are deterministic.
+
+    The test DB uses a ``MIRROR`` config, so rows committed by ``transaction=True``
+    tests (e.g. the consumer folding test) are not flushed between runs. Called in
+    ``setUp`` it runs inside the per-test transaction and is rolled back afterwards,
+    so it only hides that committed pollution for the duration of one test.
+    """
+    ReactionStat.objects.all().delete()
+    AnimeReaction.objects.all().delete(hard=True)
 
 
 class TestVersionCheckAPI(APITestCase):
@@ -102,3 +117,106 @@ def test_lobby_resolve_not_found_404(self):
 
         response = self.client.get(self.endpoint(uuid.uuid4()))
         assert response.status_code == status.HTTP_404_NOT_FOUND
+
+
+class TestStatsDaysParam(APITestCase):
+    """``?days=N`` の検証（未指定→既定、範囲外→400）。"""
+
+    def setUp(self) -> None:
+        self.client = APIClient()
+        self.endpoint = "/api/v1/statistics/anime-store/active-user-per-day"
+
+    @pytest.mark.django_db
+    def test_missing_days_defaults_ok_200(self):
+        response = self.client.get(self.endpoint)
+        assert response.status_code == status.HTTP_200_OK
+
+    @pytest.mark.django_db
+    def test_days_out_of_range_400(self):
+        for bad in ("0", "366", "-1", "abc", "1.5"):
+            response = self.client.get(self.endpoint, {"days": bad})
+            assert response.status_code == status.HTTP_400_BAD_REQUEST, bad
+
+    @pytest.mark.django_db
+    def test_days_in_range_ok_200(self):
+        for ok in ("1", "30", "365"):
+            response = self.client.get(self.endpoint, {"days": ok})
+            assert response.status_code == status.HTTP_200_OK, ok
+
+
+class TestStatsPeriodScope(APITestCase):
+    """期間スコープ（累計・リアクション）が days に従うことを確認。"""
+
+    def setUp(self) -> None:
+        self.client = APIClient()
+        _clear_reaction_tables()
+
+    @staticmethod
+    def _make_reaction(room, reaction_type, when):
+        reaction = AnimeReaction.objects.create(
+            room_id=room, reaction_type=reaction_type
+        )
+        AnimeReaction.objects.filter(pk=reaction.pk).update(created_at=when)
+        return reaction
+
+    @pytest.mark.django_db
+    def test_user_all_count_respects_days(self):
+        """40 日前のユーザーは 30 日窓では数えず 365 日窓では数える。
+
+        テスト DB は ``MIRROR`` 設定で他テストの行が残りうるため、絶対値ではなく
+        「40 日前ユーザーを 1 人足すと 365 日窓だけ +1 される」差分で検証する。
+        """
+        from streamer.models import AnimeUser
+
+        AnimeUserFactory()  # recent（auto_now_add で created_at=now）
+        old = AnimeUserFactory()
+        AnimeUser.objects.filter(pk=old.pk).update(
+            created_at=timezone.now() - datetime.timedelta(days=40)
+        )
+        endpoint = "/api/v1/statistics/anime-store/anime-user-all-count"
+
+        c30 = self.client.get(endpoint, {"days": "30"}).data["data"]["count"]
+        c365 = self.client.get(endpoint, {"days": "365"}).data["data"]["count"]
+        assert c30 >= 1  # recent は 30 日窓に入る
+        assert c365 - c30 >= 1  # 40 日前ユーザーは 365 日窓のみに入る
+
+    @pytest.mark.django_db
+    def test_reaction_counts_come_from_reactionstat_and_live(self):
+        """リアクション集計は ReactionStat（畳み込み済み）と alive ルームの合算。"""
+        today = timezone.now().date()
+        ReactionStat.objects.create(date=today, reaction_type="S", count=5)
+        live_room = AnimeRoomFactory()  # alive
+        self._make_reaction(live_room, "S", timezone.now())
+
+        by_type = self.client.get(
+            "/api/v1/statistics/anime-store/anime-reaction-count", {"days": "30"}
+        )
+        smile = next(r for r in by_type.data["data"] if r["reaction_type"] == "smile")
+        assert smile["count"] == 6  # 5 (folded) + 1 (live)
+
+        total = self.client.get(
+            "/api/v1/statistics/anime-store/anime-reaction-all-count", {"days": "30"}
+        )
+        assert total.data["data"]["count"] == 6
+
+
+class TestStatsCache(APITestCase):
+    """キャッシュヒット時に DB の変化が TTL 内では反映されないこと。"""
+
+    def setUp(self) -> None:
+        self.client = APIClient()
+        self.endpoint = "/api/v1/statistics/anime-store/anime-reaction-all-count"
+        _clear_reaction_tables()
+
+    @pytest.mark.django_db
+    def test_response_is_cached(self):
+        today = timezone.now().date()
+        ReactionStat.objects.create(date=today, reaction_type="S", count=3)
+
+        first = self.client.get(self.endpoint, {"days": "30"})
+        assert first.data["data"]["count"] == 3
+
+        # キャッシュ後に DB を増やしても、同一キーは TTL 内でキャッシュ値を返す。
+        ReactionStat.objects.filter(date=today, reaction_type="S").update(count=99)
+        second = self.client.get(self.endpoint, {"days": "30"})
+        assert second.data["data"]["count"] == 3  # キャッシュヒット