Keep missing VK counters unknown instead of zero

legacy_parser.py

@@ -418,7 +418,9 @@ def process_vk_batch(batch_items: List[Tuple[str, int, str]]) -> dict:
             result[canonical] = (f"**Ошибка (VK)**: пост не найден — {canonical}", 0)
             continue
 
-        views = post.get("views", {}).get("count", 0)
+        counter = post.get("views")
+        count = counter.get("count") if isinstance(counter, dict) else None
+        views = count if type(count) is int and count >= 0 else None
         post_owner_id = post.get("owner_id", owner_id)
         title = None
         if post_owner_id < 0:

service.py

@@ -17,7 +17,7 @@ from reports import normalize, render
 
 log = logging.getLogger(__name__)
 API_KEY = os.getenv("BRIDGE_API_KEY", "")
-app = FastAPI(title="ReportBridge", version="0.1.1")
+app = FastAPI(title="ReportBridge", version="0.1.2")
 app.add_middleware(CORSMiddleware, allow_origins=["*"], allow_credentials=False,
                    allow_methods=["GET", "POST", "DELETE"], allow_headers=["Content-Type", "X-Bridge-Key"])
 jobs, lock = {}, threading.RLock()
@@ -78,6 +78,8 @@ def run_job(job_id, records):
                     title, views = data.get(record["url"], ("Ошибка: VK_ACCESS_TOKEN не настроен", None))
                     error = ("Не настроен VK_ACCESS_TOKEN в Secrets PR_Tool" if not engine.VK_ACCESS_TOKEN
                              else "Не удалось получить просмотры VK") if "ошибка" in title.lower() else None
+                    if not error and views is None:
+                        error = "VK API не передал счётчик просмотров этого поста; это не подтверждённый ноль"
                     store_result(dict(record, title=title if not error else record["group"], views=None if error else views, error=error))
                 if start + 100 < len(vk):
                     time.sleep(0.4)

tests/test_service.py

@@ -63,6 +63,17 @@ class ServiceTests(unittest.TestCase):
         self.assertIn('<b>4K</b>', job['result']['html'])
         self.assertIn('ещё</a>', job['result']['html'])
 
+    def test_vk_missing_counter_is_reported_separately(self):
+        record = normalize('https://vk.com/wall-123_456')
+        service.jobs['test'] = dict(status='queued', completed=0, total=1, created=time.time())
+        with patch.object(service.engine, 'VK_ACCESS_TOKEN', 'test-only'), patch.object(service.engine, 'process_vk_batch', return_value={record['url']: ('Сообщество', None)}):
+            service.run_job('test', [record])
+        output = service.jobs['test']['result']
+        self.assertIsNone(output['records'][0]['views'])
+        self.assertEqual(len(output['errors']), 1)
+        self.assertIn('не передал счётчик', output['errors'][0])
+        self.assertIn('Неполный итог', output['html'])
+
 
 if __name__ == '__main__':
     unittest.main()

tests/test_vk_counters.py

@@ -0,0 +1,29 @@
+import unittest
+from unittest.mock import Mock, patch
+
+import legacy_parser as engine
+
+
+class VkCountersTests(unittest.TestCase):
+    def test_missing_counter_is_not_fabricated_zero(self):
+        url = 'https://vk.com/wall-123_456'
+        for field in ({}, {'views': {}}, {'views': None}, {'views': {'count': '100'}}):
+            with self.subTest(field=field):
+                post = dict(id=456, owner_id=-123, **field)
+                response = Mock(status_code=200, json=lambda: {'response': {'items': [post], 'groups': [{'id': 123, 'name': 'Сообщество'}]}})
+                with patch.object(engine.requests, 'get', return_value=response):
+                    result = engine.process_vk_batch([(url, -123, '456')])
+                self.assertEqual(result[url], ('Сообщество', None))
+
+    def test_real_zero_and_nonzero_are_preserved(self):
+        url = 'https://vk.com/wall-123_456'
+        for count in (0, 23000):
+            post = {'id': 456, 'owner_id': -123, 'views': {'count': count}}
+            response = Mock(status_code=200, json=lambda: {'response': {'items': [post]}})
+            with patch.object(engine.requests, 'get', return_value=response):
+                result = engine.process_vk_batch([(url, -123, '456')])
+            self.assertEqual(result[url][1], count)
+
+
+if __name__ == '__main__':
+    unittest.main()