Improve lookup and handle visibility in threads

app/actor.py

@@ -168,6 +168,7 @@ async def save_actor(db_session: AsyncSession, ap_actor: ap.RawObject) -> "Actor
 async def fetch_actor(
     db_session: AsyncSession,
     actor_id: str,
+    save_if_not_found: bool = True,
 ) -> "ActorModel":
     if actor_id == LOCAL_ACTOR.ap_id:
         raise ValueError("local actor should not be fetched")
@@ -180,9 +181,12 @@ async def fetch_actor(
     ).one_or_none()
     if existing_actor:
         return existing_actor
-
+    else:
-    ap_actor = await ap.fetch(actor_id)
+        if save_if_not_found:
-    return await save_actor(db_session, ap_actor)
+            ap_actor = await ap.fetch(actor_id)
+            return await save_actor(db_session, ap_actor)
+        else:
+            raise ap.ObjectNotFoundError
 
 
 @dataclass

app/admin.py

@@ -88,19 +88,6 @@ async def get_lookup(
     ap_object = None
     actors_metadata = {}
     if query:
-        requested_object = await boxes.get_anybox_object_by_ap_id(db_session, query)
-        if requested_object:
-            if (
-                requested_object.ap_type == "Create"
-                and requested_object.relates_to_anybox_object
-            ):
-                query = requested_object.relates_to_anybox_object.ap_id
-            return RedirectResponse(
-                request.url_for("admin_object") + f"?ap_id={query}",
-                status_code=302,
-            )
-        # TODO(ts): redirect to admin_profile if the actor is in DB
-
         try:
             ap_object = await lookup(db_session, query)
         except httpx.TimeoutException:
@@ -112,6 +99,19 @@ async def get_lookup(
             error = ap.FetchErrorTypeEnum.INTERNAL_ERROR
         else:
             if ap_object.ap_type in ap.ACTOR_TYPES:
+                try:
+                    await fetch_actor(
+                        db_session, ap_object.ap_id, save_if_not_found=False
+                    )
+                except ap.NotAnObjectError:
+                    pass
+                else:
+                    return RedirectResponse(
+                        request.url_for("admin_profile")
+                        + f"?actor_id={ap_object.ap_id}",
+                        status_code=302,
+                    )
+
                 actors_metadata = await get_actors_metadata(
                     db_session, [ap_object]  # type: ignore
                 )
@@ -129,6 +129,7 @@ async def get_lookup(
                 actors_metadata = await get_actors_metadata(
                     db_session, [ap_object.actor]  # type: ignore
                 )
+
     return await templates.render_template(
         db_session,
         request,
@@ -717,7 +718,11 @@ async def admin_object(
     if not requested_object:
         raise HTTPException(status_code=404)
 
-    replies_tree = await boxes.get_replies_tree(db_session, requested_object)
+    replies_tree = await boxes.get_replies_tree(
+        db_session,
+        requested_object,
+        is_current_user_admin=True,
+    )
 
     return await templates.render_template(
         db_session,

app/boxes.py

@@ -1865,13 +1865,17 @@ class ReplyTreeNode:
 async def get_replies_tree(
     db_session: AsyncSession,
     requested_object: AnyboxObject,
+    is_current_user_admin: bool,
 ) -> ReplyTreeNode:
     # XXX: PeerTube video don't use context
     tree_nodes: list[AnyboxObject] = []
     if requested_object.conversation is None:
         tree_nodes = [requested_object]
     else:
-        # TODO: handle visibility
+        allowed_visibility = [ap.VisibilityEnum.PUBLIC, ap.VisibilityEnum.UNLISTED]
+        if is_current_user_admin:
+            allowed_visibility = list(ap.VisibilityEnum)
+
         tree_nodes.extend(
             (
                 await db_session.scalars(
@@ -1881,6 +1885,7 @@ async def get_replies_tree(
                         == requested_object.conversation,
                         models.InboxObject.ap_type.in_(["Note", "Page", "Article"]),
                         models.InboxObject.is_deleted.is_(False),
+                        models.InboxObject.visibility.in_(allowed_visibility),
                     )
                     .options(joinedload(models.InboxObject.actor))
                 )
@@ -1897,6 +1902,7 @@ async def get_replies_tree(
                         == requested_object.conversation,
                         models.OutboxObject.is_deleted.is_(False),
                         models.OutboxObject.ap_type.in_(["Note", "Page", "Article"]),
+                        models.OutboxObject.visibility.in_(allowed_visibility),
                     )
                     .options(
                         joinedload(

app/main.py

@@ -585,7 +585,11 @@ async def outbox_by_public_id(
     if is_activitypub_requested(request):
         return ActivityPubResponse(maybe_object.ap_object)
 
-    replies_tree = await boxes.get_replies_tree(db_session, maybe_object)
+    replies_tree = await boxes.get_replies_tree(
+        db_session,
+        maybe_object,
+        is_current_user_admin=is_current_user_admin(request),
+    )
 
     likes = (
         (