feat(news): Phase 3 feeds — news RSS, seismic/trails scaffold, Beat schedules

Add news/seismic/trails apps with v3 news API and hourly RSS poll, GDPR Beat
migration, consentPolicyVersion on bootstrap, and sao-miguel news flag.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: hc-sousa

src/consent/migrations/0002_periodic_tasks.py

@@ -0,0 +1,49 @@
+"""Register GDPR Celery Beat periodic tasks (idempotent)."""
+
+from django.db import migrations
+
+
+def _daily_schedule(apps):
+    CrontabSchedule = apps.get_model('django_celery_beat', 'CrontabSchedule')
+    schedule, _ = CrontabSchedule.objects.get_or_create(
+        minute='0',
+        hour='3',
+        day_of_week='*',
+        day_of_month='*',
+        month_of_year='*',
+        defaults={'timezone': 'Atlantic/Azores'},
+    )
+    if schedule.timezone != 'Atlantic/Azores':
+        schedule.timezone = 'Atlantic/Azores'
+        schedule.save(update_fields=['timezone'])
+    return schedule
+
+
+def _upsert_task(apps, *, name: str, task: str, schedule) -> None:
+    PeriodicTask = apps.get_model('django_celery_beat', 'PeriodicTask')
+    PeriodicTask.objects.update_or_create(
+        name=name,
+        defaults={
+            'task': task,
+            'crontab': schedule,
+            'enabled': True,
+        },
+    )
+
+
+def register_gdpr_periodic_tasks(apps, schema_editor):
+    daily = _daily_schedule(apps)
+    _upsert_task(apps, name='consent.rotate_session_salt', task='consent.rotate_session_salt', schedule=daily)
+    _upsert_task(apps, name='consent.expire_consent', task='consent.expire_consent', schedule=daily)
+    _upsert_task(apps, name='analytics.anonymize_events', task='analytics.anonymize_events', schedule=daily)
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ('consent', '0001_initial'),
+        ('django_celery_beat', '__latest__'),
+    ]
+
+    operations = [
+        migrations.RunPython(register_gdpr_periodic_tasks, migrations.RunPython.noop),
+    ]

src/news/__init__.py

@@ -0,0 +1,18 @@
+from django.contrib import admin
+
+from news.models import NewsArticle, NewsSource
+
+
+@admin.register(NewsSource)
+class NewsSourceAdmin(admin.ModelAdmin):
+    list_display = ('name', 'island', 'language', 'active', 'rss_url')
+    list_filter = ('active', 'language', 'island')
+    search_fields = ('name', 'rss_url')
+
+
+@admin.register(NewsArticle)
+class NewsArticleAdmin(admin.ModelAdmin):
+    list_display = ('title', 'source', 'island', 'published_at', 'category')
+    list_filter = ('island', 'category', 'source')
+    search_fields = ('title', 'link')
+    date_hierarchy = 'published_at'

src/news/admin.py

@@ -0,0 +1,65 @@
+"""News v3 API."""
+
+from __future__ import annotations
+
+from rest_framework import status
+from rest_framework.decorators import api_view, permission_classes
+from rest_framework.permissions import AllowAny
+from rest_framework.request import Request
+from rest_framework.response import Response
+
+from news.services import get_article, list_articles
+from tenancy.services import for_island
+
+
+def _require_island(request: Request) -> Response | None:
+    if request.island is None:
+        return Response(
+            {'error': {'code': 'island_required', 'message': 'Island context required'}},
+            status=status.HTTP_400_BAD_REQUEST,
+        )
+    return None
+
+
+@api_view(['GET'])
+@permission_classes([AllowAny])
+def news_articles_view(request: Request) -> Response:
+    err = _require_island(request)
+    if err:
+        return err
+
+    category = request.GET.get('category', '').strip()
+    query = request.GET.get('q', '').strip()
+    source_raw = request.GET.get('source', '').strip()
+    source_id = int(source_raw) if source_raw.isdigit() else None
+    limit_raw = request.GET.get('limit', '50').strip()
+    try:
+        limit = int(limit_raw)
+    except ValueError:
+        limit = 50
+
+    with for_island(request.island):
+        articles = list_articles(
+            category=category,
+            source_id=source_id,
+            query=query,
+            limit=limit,
+        )
+    return Response({'articles': articles})
+
+
+@api_view(['GET'])
+@permission_classes([AllowAny])
+def news_article_detail_view(request: Request, article_id: int) -> Response:
+    err = _require_island(request)
+    if err:
+        return err
+
+    with for_island(request.island):
+        payload = get_article(article_id)
+    if payload is None:
+        return Response(
+            {'error': {'code': 'not_found', 'message': 'Article not found'}},
+            status=status.HTTP_404_NOT_FOUND,
+        )
+    return Response(payload)

src/news/api_v3.py

@@ -0,0 +1,7 @@
+from django.apps import AppConfig
+
+
+class NewsConfig(AppConfig):
+    default_auto_field = 'django.db.models.BigAutoField'
+    name = 'news'
+    verbose_name = 'Local news'

src/news/apps.py

@@ -0,0 +1,94 @@
+# Generated by Django 4.2.29 on 2026-06-02 13:08
+
+from django.db import migrations, models
+import django.db.models.deletion
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+        ("tenancy", "0005_enable_news_feature_flag"),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name="NewsSource",
+            fields=[
+                (
+                    "id",
+                    models.BigAutoField(
+                        auto_created=True,
+                        primary_key=True,
+                        serialize=False,
+                        verbose_name="ID",
+                    ),
+                ),
+                ("legacy_ref", models.JSONField(blank=True, default=dict)),
+                ("name", models.CharField(max_length=120)),
+                ("rss_url", models.URLField(max_length=500)),
+                ("language", models.CharField(default="pt", max_length=8)),
+                ("active", models.BooleanField(default=True)),
+                (
+                    "island",
+                    models.ForeignKey(
+                        on_delete=django.db.models.deletion.PROTECT, to="tenancy.island"
+                    ),
+                ),
+            ],
+            options={
+                "ordering": ["name"],
+                "unique_together": {("island", "rss_url")},
+            },
+        ),
+        migrations.CreateModel(
+            name="NewsArticle",
+            fields=[
+                (
+                    "id",
+                    models.BigAutoField(
+                        auto_created=True,
+                        primary_key=True,
+                        serialize=False,
+                        verbose_name="ID",
+                    ),
+                ),
+                ("legacy_ref", models.JSONField(blank=True, default=dict)),
+                ("title", models.CharField(max_length=500)),
+                ("summary", models.TextField(blank=True, default="")),
+                ("link", models.URLField(max_length=1000)),
+                ("published_at", models.DateTimeField(db_index=True)),
+                ("category", models.CharField(blank=True, default="", max_length=64)),
+                ("content_hash", models.CharField(db_index=True, max_length=64)),
+                (
+                    "island",
+                    models.ForeignKey(
+                        on_delete=django.db.models.deletion.PROTECT, to="tenancy.island"
+                    ),
+                ),
+                (
+                    "source",
+                    models.ForeignKey(
+                        on_delete=django.db.models.deletion.CASCADE,
+                        related_name="articles",
+                        to="news.newssource",
+                    ),
+                ),
+            ],
+            options={
+                "ordering": ["-published_at"],
+                "indexes": [
+                    models.Index(
+                        fields=["island", "-published_at"],
+                        name="news_newsar_island__239080_idx",
+                    ),
+                    models.Index(
+                        fields=["island", "category"],
+                        name="news_newsar_island__e4cf61_idx",
+                    ),
+                ],
+                "unique_together": {("island", "link")},
+            },
+        ),
+    ]

src/news/migrations/0001_initial.py

@@ -0,0 +1,73 @@
+"""Seed Azores news RSS sources and register hourly poll task."""
+
+from django.db import migrations
+
+DEFAULT_SOURCES = (
+    {
+        'name': 'Açoriano Oriental',
+        'rss_url': 'https://www.acorianooriental.pt/rss/',
+        'language': 'pt',
+    },
+    {
+        'name': 'Jornal dos Açores',
+        'rss_url': 'https://www.jornaldosacores.com/feed/',
+        'language': 'pt',
+    },
+)
+
+
+def _hourly_schedule(apps):
+    CrontabSchedule = apps.get_model('django_celery_beat', 'CrontabSchedule')
+    schedule, _ = CrontabSchedule.objects.get_or_create(
+        minute='0',
+        hour='*',
+        day_of_week='*',
+        day_of_month='*',
+        month_of_year='*',
+        defaults={'timezone': 'Atlantic/Azores'},
+    )
+    if schedule.timezone != 'Atlantic/Azores':
+        schedule.timezone = 'Atlantic/Azores'
+        schedule.save(update_fields=['timezone'])
+    return schedule
+
+
+def seed_sources_and_beat(apps, schema_editor):
+    Island = apps.get_model('tenancy', 'Island')
+    NewsSource = apps.get_model('news', 'NewsSource')
+    PeriodicTask = apps.get_model('django_celery_beat', 'PeriodicTask')
+
+    island = Island.objects.filter(key='sao-miguel').first()
+    if island:
+        for row in DEFAULT_SOURCES:
+            NewsSource.objects.update_or_create(
+                island=island,
+                rss_url=row['rss_url'],
+                defaults={
+                    'name': row['name'],
+                    'language': row['language'],
+                    'active': True,
+                },
+            )
+
+    hourly = _hourly_schedule(apps)
+    PeriodicTask.objects.update_or_create(
+        name='news.poll_sources',
+        defaults={
+            'task': 'news.poll_sources',
+            'crontab': hourly,
+            'enabled': True,
+        },
+    )
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ('news', '0001_initial'),
+        ('tenancy', '0005_enable_news_feature_flag'),
+        ('django_celery_beat', '__latest__'),
+    ]
+
+    operations = [
+        migrations.RunPython(seed_sources_and_beat, migrations.RunPython.noop),
+    ]

src/news/migrations/0002_seed_sources_and_beat.py

@@ -0,0 +1,42 @@
+"""News RSS sources and articles."""
+
+from __future__ import annotations
+
+from django.db import models
+
+from tenancy.models import TenantScopedModel
+
+
+class NewsSource(TenantScopedModel):
+    name = models.CharField(max_length=120)
+    rss_url = models.URLField(max_length=500)
+    language = models.CharField(max_length=8, default='pt')
+    active = models.BooleanField(default=True)
+
+    class Meta:
+        ordering = ['name']
+        unique_together = [('island', 'rss_url')]
+
+    def __str__(self) -> str:
+        return self.name
+
+
+class NewsArticle(TenantScopedModel):
+    source = models.ForeignKey(NewsSource, on_delete=models.CASCADE, related_name='articles')
+    title = models.CharField(max_length=500)
+    summary = models.TextField(blank=True, default='')
+    link = models.URLField(max_length=1000)
+    published_at = models.DateTimeField(db_index=True)
+    category = models.CharField(max_length=64, blank=True, default='')
+    content_hash = models.CharField(max_length=64, db_index=True)
+
+    class Meta:
+        ordering = ['-published_at']
+        unique_together = [('island', 'link')]
+        indexes = [
+            models.Index(fields=['island', '-published_at']),
+            models.Index(fields=['island', 'category']),
+        ]
+
+    def __str__(self) -> str:
+        return self.title[:80]