diff --git a/app/main.py b/app/main.py index c46fae6..bda63b4 100644 --- a/app/main.py +++ b/app/main.py @@ -379,6 +379,73 @@ class ReplyTreeNode: is_root: bool = False +def get_replies_tree( + db: Session, + requested_object: boxes.AnyboxObject, +) -> ReplyTreeNode: + # TODO: handle visibility + tree_nodes: list[boxes.AnyboxObject] = [] + tree_nodes.extend( + db.query(models.InboxObject) + .filter( + models.InboxObject.ap_context == requested_object.ap_context, + ) + .all() + ) + tree_nodes.extend( + db.query(models.OutboxObject) + .filter( + models.OutboxObject.ap_context == requested_object.ap_context, + models.OutboxObject.is_deleted.is_(False), + ) + .all() + ) + nodes_by_in_reply_to = defaultdict(list) + for node in tree_nodes: + nodes_by_in_reply_to[node.in_reply_to].append(node) + logger.info(nodes_by_in_reply_to) + + # TODO: get oldest if we cannot get to root? + if len(nodes_by_in_reply_to.get(None, [])) != 1: + raise ValueError("Failed to compute replies tree") + + def _get_reply_node_children( + node: ReplyTreeNode, + index: defaultdict[str | None, list[boxes.AnyboxObject]], + ) -> list[ReplyTreeNode]: + children = [] + for child in index.get(node.ap_object.ap_id, []): # type: ignore + child_node = ReplyTreeNode( + ap_object=child, + is_requested=child.ap_id == requested_object.ap_id, # type: ignore + children=[], + ) + child_node.children = _get_reply_node_children(child_node, index) + children.append(child_node) + + return sorted( + children, + key=lambda node: node.ap_object.ap_published_at, # type: ignore + ) + + if None in nodes_by_in_reply_to: + root_ap_object = nodes_by_in_reply_to[None][0] + else: + root_ap_object = sorted( + tree_nodes, + lambda ap_obj: ap_obj.ap_published_at, # type: ignore + )[0] + + root_node = ReplyTreeNode( + ap_object=root_ap_object, + is_root=True, + is_requested=root_ap_object.ap_id == requested_object.ap_id, + children=[], + ) + root_node.children = _get_reply_node_children(root_node, nodes_by_in_reply_to) + return root_node + + @app.get("/o/{public_id}") def outbox_by_public_id( public_id: str, @@ -402,75 +469,18 @@ def outbox_by_public_id( ) if not maybe_object: raise HTTPException(status_code=404) - # + if is_activitypub_requested(request): return ActivityPubResponse(maybe_object.ap_object) - # TODO: handle visibility - tree_nodes: list[boxes.AnyboxObject] = [maybe_object] - tree_nodes.extend( - db.query(models.InboxObject) - .filter( - models.InboxObject.ap_context == maybe_object.ap_context, - ) - .all() - ) - tree_nodes.extend( - db.query(models.OutboxObject) - .filter( - models.OutboxObject.ap_context == maybe_object.ap_context, - models.OutboxObject.is_deleted.is_(False), - models.OutboxObject.id != maybe_object.id, - ) - .all() - ) - logger.info(f"root={maybe_object.ap_id}") - nodes_by_in_reply_to = defaultdict(list) - for node in tree_nodes: - nodes_by_in_reply_to[node.in_reply_to].append(node) - logger.info(f"in_reply_to={node.in_reply_to}") - logger.info(nodes_by_in_reply_to) - - # TODO: get oldest if we cannot get to root? - if len(nodes_by_in_reply_to.get(None, [])) != 1: - raise ValueError("Failed to compute replies tree") - - def _get_reply_node_children( - node: ReplyTreeNode, - index: defaultdict[str | None, list[boxes.AnyboxObject]], - ) -> list[ReplyTreeNode]: - children = [] - for child in index.get(node.ap_object.ap_id, []): # type: ignore - logger.info(f"{child=}") - child_node = ReplyTreeNode( - ap_object=child, - is_requested=child.ap_id == maybe_object.ap_id, # type: ignore - children=[], - ) - child_node.children = _get_reply_node_children(child_node, index) - children.append(child_node) - - return sorted( - children, - key=lambda node: node.ap_object.ap_published_at, # type: ignore - ) - - root_node = ReplyTreeNode( - ap_object=nodes_by_in_reply_to[None][0], - # ap_object=maybe_object, - is_root=True, - is_requested=nodes_by_in_reply_to[None][0].ap_id == maybe_object.ap_id, - children=[], - ) - root_node.children = _get_reply_node_children(root_node, nodes_by_in_reply_to) - logger.info(root_node.ap_object.ap_id) - logger.info(root_node) + replies_tree = get_replies_tree(db, maybe_object) return templates.render_template( db, request, "object.html", { + "replies_tree": replies_tree, "outbox_object": maybe_object, }, ) diff --git a/app/templates/object.html b/app/templates/object.html index 4cabb02..65daa80 100644 --- a/app/templates/object.html +++ b/app/templates/object.html @@ -3,6 +3,15 @@ {% block content %} {% include "header.html" %} -{{ utils.display_object(outbox_object) }} +{% macro display_replies_tree(replies_tree_node) %} + +{{ utils.display_object(replies_tree_node.ap_object) }} +{% for child in replies_tree_node.children %} + {{ display_replies_tree(child) }} +{% endfor %} + +{% endmacro %} + +{{ display_replies_tree(replies_tree) }} {% endblock %}