diff --git a/app/modules/indexer/parser/nexus_audiences.py b/app/modules/indexer/parser/nexus_audiences.py
index 14b2c990..13d747d6 100644
--- a/app/modules/indexer/parser/nexus_audiences.py
+++ b/app/modules/indexer/parser/nexus_audiences.py
@@ -13,6 +13,35 @@ from app.utils.string import StringUtils
class NexusAudiencesSiteUserInfo(NexusPhpSiteUserInfo):
schema = SiteSchema.NexusAudiences
+ def _parse_message_unread(self, html_text):
+ """
+ 解析 Audiences 新版顶部用户栏中的未读消息数。
+ """
+ super()._parse_message_unread(html_text)
+ if self.message_unread:
+ return
+
+ html = etree.HTML(html_text)
+ try:
+ if not StringUtils.is_valid_html_element(html):
+ return
+
+ message_tools = html.xpath(
+ '//a[contains(@class, "site-userbar__compact-tool") and contains(@href, "messages.php") '
+ 'and (contains(@class, "site-userbar__compact-tool--has-unread") '
+ 'or .//*[contains(@class, "site-userbar__compact-tool-badge--unread")])]'
+ '|//a[contains(@href, "messages.php") '
+ 'and (contains(@title, "收件箱") or contains(@aria-label, "收件箱"))]'
+ )
+ for message_link in message_tools:
+ unread = self.__parse_inbox_unread(message_link)
+ if unread is not None:
+ self.message_unread = unread
+ return
+ finally:
+ if html is not None:
+ del html
+
def _parse_user_traffic_info(self, html_text):
"""
解析用户流量信息
@@ -128,6 +157,47 @@ class NexusAudiencesSiteUserInfo(NexusPhpSiteUserInfo):
self.seeding = StringUtils.str_int(active_match.group(1))
self.leeching = StringUtils.str_int(active_match.group(2))
+ def __parse_inbox_unread(self, message_link):
+ """
+ 从 Audiences 收件箱入口提取未读数。
+ """
+ inbox_texts = [
+ message_link.get("title"),
+ message_link.get("aria-label"),
+ *message_link.xpath(
+ './/*[contains(@class, "site-userbar__compact-tool-badge--unread") '
+ 'or contains(@class, "site-userbar__compact-tool-badge")]/text()'
+ )
+ ]
+
+ for inbox_text in inbox_texts:
+ unread = self.__extract_inbox_unread(inbox_text)
+ if unread is not None:
+ return unread
+
+ return None
+
+ @staticmethod
+ def __extract_inbox_unread(text: str):
+ """
+ Audiences 收件箱角标格式为 总数/未读数，例如 1749/172。
+ """
+ if not text:
+ return None
+
+ text = re.sub(r"\s+", " ", text.replace("\xa0", " ")).strip()
+ if not text:
+ return None
+
+ inbox_count = re.search(r"(?:收件箱\s*)?(\d[\d,]*)\s*/\s*(\d[\d,]*)", text)
+ if inbox_count:
+ return StringUtils.str_int(inbox_count.group(2))
+
+ single_count = re.search(r"收件箱\s*(\d[\d,]*)", text)
+ if single_count:
+ return StringUtils.str_int(single_count.group(1))
+ return None
+
def _parse_seeding_pages(self):
if not self._torrent_seeding_page:
return
diff --git a/tests/test_nexus_audiences_parser.py b/tests/test_nexus_audiences_parser.py
index 2ec2f724..b4486c7f 100644
--- a/tests/test_nexus_audiences_parser.py
+++ b/tests/test_nexus_audiences_parser.py
@@ -44,3 +44,89 @@ def test_audiences_userbar_metrics_override_generic_nexus_regex():
assert parser.bonus == 1973896.2
assert parser.seeding == 355
assert parser.leeching == 7
+
+
+def test_audiences_inbox_total_unread_badge_uses_unread_part():
+ parser = NexusAudiencesSiteUserInfo(
+ site_name="Audiences",
+ url="https://audiences.me/",
+ site_cookie="",
+ apikey=None,
+ token=None,
+ )
+ html_text = """
+
+
+
+
+
+ """
+
+ parser._parse_message_unread(html_text)
+
+ assert parser.message_unread == 172
+
+
+def test_audiences_table_unread_links_ignore_content_rows():
+ parser = NexusAudiencesSiteUserInfo(
+ site_name="Audiences",
+ url="https://audiences.me/",
+ site_cookie="",
+ apikey=None,
+ token=None,
+ )
+ html_text = """
+
+
+
+
+
+ """
+ msg_links = []
+
+ next_page = parser._parse_message_unread_links(html_text, msg_links)
+
+ assert msg_links == ["messages.php?action=viewmessage&id=4318225"]
+ assert next_page is None
+