@@ -0,0 +19,4 @@
+
+def upgrade() -> None:
+    """Add the featured media reference to articles."""
+    op.execute("ALTER TABLE articles ADD COLUMN featured_media_id INTEGER REFERENCES media(id)")

@@ -125,0 +133,4 @@
+
+    """
+    cursor = conn.cursor()
+    cursor.execute("UPDATE articles SET featured_media_id = ? WHERE id = ?", (media_id, article_id))

@@ -68,32 +70,41 @@ def fetch_full_text(url: str) -> str | None:
         logger.info(f"Full-text fetch skipped for {url}: non-HTML content type {content_type!r}")

@@ -100,0 +107,4 @@
+            )
+            download_featured_image(conn, article.id)
+        except Exception:
+            logger.error(f"Featured image selection failed for {article.url}", exc_info=True)

@@ -348,0 +380,4 @@
+    media_dir = _media_directory(conn)
+    media_dir.mkdir(parents=True, exist_ok=True)
+
+    filename = _download_one(record, media_dir, max_bytes)

@@ -125,0 +153,4 @@
+    )
+    conn.commit()
+
+    return cursor.rowcount > 0

@@ -61,3 +82,3 @@
         response = _fetch_feed_response(url)
     except FetchError as exc:
-        logger.warning(f"Full-text fetch skipped for {url}: {exc}")
+        logger.warning(f"Full-text fetch skipped for {_log_safe(url)}: {exc}")

@@ -348,0 +373,4 @@
+    if article is None or article.featured_media_id is None:
+        return False
+
+    record = media_db.get_media(conn, article.featured_media_id)

@@ -198,0 +209,4 @@
+        assert _log_safe("https://x.example/a\r\nFAKE ERROR b") == "https://x.example/a FAKE ERROR b"
+
+    def test_log_safe_keeps_normal_urls(self) -> None:
+        assert _log_safe("https://x.example/a?b=1&c=2") == "https://x.example/a?b=1&c=2"

@@ -138,3 +138,3 @@
 
 
-def _fetch_feed_response(url: str) -> httpx2.Response:
+def _fetch_feed_response(url: str, headers: dict[str, str] | None = None) -> httpx2.Response:

@@ -96,3 +99,3 @@
 class TestFetchAndStoreFullText:
     def test_stores_extracted_markdown_and_timestamp(self, db_conn_with_article, db_conn: sqlite3.Connection) -> None:
-        with patch.object(full_text, "fetch_full_text", return_value="# Wind project approved\n\nBody text."):
+        with patch.object(full_text, "fetch_article_page", return_value=ARTICLE_HTML):