From 805cc46acec32d3b0d8f6f3dce9feb5af8da0f3b Mon Sep 17 00:00:00 2001
From: Kuba Suder <jakub.suder@gmail.com>
Date: Sun, 24 May 2026 23:59:20 +0200
Subject: [PATCH] detect and show if a post's author has needs-review

---
 src/api/bluesky_api.ts                        | 10 +++++++
 src/components/posts/HiddenRepliesLink.svelte | 30 +++++++++----------
 src/components/posts/PostComponent.svelte     | 14 +++++++++
 src/models/posts.js                           |  6 ++++
 4 files changed, 45 insertions(+), 15 deletions(-)

diff --git a/src/api/bluesky_api.ts b/src/api/bluesky_api.ts
index 9a0fccd..8d4fcdb 100644
--- a/src/api/bluesky_api.ts
+++ b/src/api/bluesky_api.ts
@@ -7,6 +7,8 @@ import { parseBlueskyPostURL } from '../router.js';
 
 export { APIError };
 
+export const blueskyLabellerDID = 'did:plc:ar7c4by46qjdydhdevvrndac';
+
 /**
  * Thrown when the response is technically a "success" one, but the returned data is not what it should be.
  */
@@ -126,6 +128,14 @@ export class BlueskyAPI extends Minisky {
     return await this.getRequest('app.bsky.feed.searchPosts', params);
   }
 
+  async checkIfProfileHasNeedsReview(did: string): Promise<boolean> {
+    let profile = await this.getRequest('app.bsky.actor.getProfile', { actor: did },
+      { headers: { 'atproto-accept-labelers': blueskyLabellerDID }}
+    );
+
+    return profile.labels?.some((x: json) => (x.src == blueskyLabellerDID && x.val == 'needs-review'));
+  }
+
   async loadHiddenReplyURIs(post: Post): Promise<string[]> {
     let [constellationReplies, blueReplies] = await Promise.all([
       constellationAPI.getReplies(post.uri),
diff --git a/src/components/posts/HiddenRepliesLink.svelte b/src/components/posts/HiddenRepliesLink.svelte
index 6f25c93..7abbd23 100644
--- a/src/components/posts/HiddenRepliesLink.svelte
+++ b/src/components/posts/HiddenRepliesLink.svelte
@@ -1,5 +1,5 @@
 <script lang="ts">
-  import { api } from '../../api.js';
+  import { api, appView } from '../../api.js';
   import { showBiohazardDialog } from '../Dialogs.svelte';
   import { settings } from '../../models/settings.svelte.js';
   import { parseThreadPost } from '../../models/posts.js';
@@ -28,19 +28,6 @@
     }
   }
 
-  function threadsFromPromises(responses: PromiseSettledResult<json>[]): AnyPost[] {
-    return responses.flatMap(r => {
-      if (r.status == 'fulfilled') {
-        let json = r.value;
-        let subthread = parseThreadPost(json.thread, post.pageRoot, 1, post.absoluteLevel + 1);
-        subthread.isHiddenReply = true;
-        return [subthread];
-      } else {
-        return [];
-      }
-    });
-  }
-
   async function loadHiddenReplies() {
     loading = true;
 
@@ -49,7 +36,20 @@
 
       let promises = missingReplyURIs.map(uri => api.loadThreadByAtURI(uri));
       let responses = await Promise.allSettled(promises);
-      let replies = threadsFromPromises(responses);
+      let jsons = responses.flatMap(r => (r.status == 'fulfilled') ? [r.value.thread] : []);
+      let replies = jsons.map(json => parseThreadPost(json, post.pageRoot, 1, post.absoluteLevel + 1));
+      replies.forEach(x => { x.isHiddenReply = true });
+
+      if (jsons.length <= 10) {
+        // sanity check - sometimes hidden replies are a big part of a large thread that got truncated
+
+        for (let [i, json] of jsons.entries()) {
+          if (json.parent) {
+            let did = json.post.author.did;
+            replies[i].labelledNeedsReview = await appView.checkIfProfileHasNeedsReview(did);
+          }
+        }
+      }
 
       let unavailableURIs = missingReplyURIs.filter(x => !replies.find(r => r.uri == x));
       let unavailablePromises = unavailableURIs.map(uri => api.loadMiniDocWithStatus(atURI(uri).repo));
diff --git a/src/components/posts/PostComponent.svelte b/src/components/posts/PostComponent.svelte
index 0360f8a..cb051ba 100644
--- a/src/components/posts/PostComponent.svelte
+++ b/src/components/posts/PostComponent.svelte
@@ -143,6 +143,10 @@
     <EdgeMargin bind:collapsed />
   {/if}
 
+  {#if post.labelledNeedsReview}
+    <p class="needs-review">⚠️ account labelled &lsquo;needs-review&rsquo;</p>
+  {/if}
+
   <div class="content">
     {#if post.muted}
       <details>
@@ -254,6 +258,16 @@
     margin-block: 5px;
   }
 
+  .needs-review {
+    font-size: 11pt;
+    border: 1px solid #ff8888;
+    display: inline-block;
+    padding: 3px 4px;
+    border-radius: 8px;
+    background-color: rgba(255, 0, 0, 0.1);
+    margin-bottom: 0;
+  }
+
   .post :global(img.loader) {
     width: 24px;
     animation: rotation 3s infinite linear;
diff --git a/src/models/posts.js b/src/models/posts.js
index cfe7b65..517dfad 100644
--- a/src/models/posts.js
+++ b/src/models/posts.js
@@ -28,6 +28,12 @@ export class BasePost extends ATProtoRecord {
    */
   isHiddenReply = false;
 
+  /**
+   * Set to true if the author of the post has the 'needs-review' label.
+   * @type {boolean}
+   */
+  labelledNeedsReview = false;
+
   /** @returns {string} */
   get didLinkToAuthor() {
     let { repo } = atURI(this.uri);
-- 
2.51.2