Release 202506102027

pyworker/pyworker/tasks/tos_review.py

@@ -3,7 +3,9 @@ Task for retrieving Terms of Service (TOS) text.
 """
 
 import hashlib
-from typing import Any, Dict, Optional, Literal
+from typing import Any, Dict, Optional
+
+import requests
 
 from pyworker.database import TosReviewType, save_tos_review, update_kyc_level
 from pyworker.tasks.base import Task
@@ -53,13 +55,37 @@ class TosReviewTask(Task):
         self.logger.info(f"TOS URLs: {tos_urls}")
 
         review = self.get_tos_review(tos_urls, service.get("tosReview"))
+
+        # Always update the processed timestamp, even if review is None
         save_tos_review(service_id, review)
 
-        # Update the KYC level based on the review
+        if review is None:
+            self.logger.warning(
+                f"TOS review could not be generated for service {service_name} (ID: {service_id})"
+            )
+            return None
+
+        # Update the KYC level based on the review, when present
         if "kycLevel" in review:
-            kyc_level = review["kycLevel"]
-            self.logger.info(f"Updating KYC level to {kyc_level} for service {service_name}")
-            update_kyc_level(service_id, kyc_level)
+            new_level = review["kycLevel"]
+            old_level = service.get("kycLevel")
+
+            # Update DB
+            if update_kyc_level(service_id, new_level):
+                msg = f"{service.get('slug', service_name)}: kycLevel {old_level} -> {new_level}"
+
+                # Log to console
+                self.logger.info(msg)
+
+                # Send notification via ntfy
+                try:
+                    requests.post(
+                        "https://ntfy.sh/knm-kyc-lvl-changes-knm", data=msg.encode()
+                    )
+                except requests.RequestException as e:
+                    self.logger.error(
+                        f"Failed to send ntfy notification for KYC level change: {e}"
+                    )
 
         return review
 
@@ -87,7 +113,9 @@ class TosReviewTask(Task):
             content = fetch_markdown(api_url)
 
             if not content:
-                self.logger.warning(f"Failed to retrieve TOS content for URL: {tos_url}")
+                self.logger.warning(
+                    f"Failed to retrieve TOS content for URL: {tos_url}"
+                )
                 all_skipped = False
                 continue
 

pyworker/pyworker/utils/ai.py

@@ -173,12 +173,12 @@ type TosReview = {
         /** In regards to KYC, Privacy, Anonymity, Self-Sovereignity, etc. */
         /** anything that could harm the user's privacy, identity, self-sovereignity or anonymity is negative, anything that otherwise helps is positive. else it is neutral. */
         rating: 'negative' | 'neutral' | 'positive'
-    }[]
+    }[] // max 8 highlights, try to provide at least 3.
 }
 
 The rating is a number between 0 and 2, where 0 is informative, 1 is warning, and 2 is critical.
 
-Do not provide more than 8 highlights. Focus on the most important information for the user. Be concise but thorough, and make sure your output is properly formatted JSON.
+Focus on the most important information for the user. Be concise and thorough, and make sure your output is properly formatted JSON.
 """
 
 PROMPT_COMMENT_SENTIMENT_SUMMARY = """

web/prisma/migrations/20250610171300_required_feed_id/migration.sql

@@ -0,0 +1,8 @@
+/*
+  Warnings:
+
+  - Made the column `feedId` on table `User` required. This step will fail if there are existing NULL values in that column.
+
+*/
+-- AlterTable
+ALTER TABLE "User" ALTER COLUMN "feedId" SET NOT NULL;

web/prisma/schema.prisma

@@ -498,7 +498,7 @@ model User {
   moderator       Boolean @default(false)
   verifiedLink    String?
   secretTokenHash String  @unique
-  feedId          String? @unique @default(cuid(2))
+  feedId          String  @unique @default(cuid(2))
   /// Computed via trigger. Do not update through prisma.
   totalKarma      Int     @default(0)