fix: allow querying distinct by object

upub/core/src/selector/query.rs

@@ -4,11 +4,15 @@ use crate::model;
 pub struct Query;
 
 impl Query {
-	pub fn feed(my_id: Option<i64>) -> Select<model::addressing::Entity> {
+	pub fn feed(my_id: Option<i64>, by_object: bool) -> Select<model::addressing::Entity> {
 		let mut select = model::addressing::Entity::find()
 			.distinct_on([
 				(model::addressing::Entity, model::addressing::Column::Published).into_column_ref(),
-				(model::activity::Entity, model::activity::Column::Internal).into_column_ref(),
+				if by_object {
+					(model::object::Entity, model::object::Column::Internal).into_column_ref()
+				} else {
+					(model::activity::Entity, model::activity::Column::Internal).into_column_ref()
+				},
 			])
 			.join(sea_orm::JoinType::LeftJoin, model::addressing::Relation::Activities.def())
 			.join(sea_orm::JoinType::LeftJoin, model::addressing::Relation::Objects.def())
@@ -18,9 +22,13 @@ impl Query {
 					.add(model::activity::Column::Id.is_not_null())
 					.add(model::object::Column::Id.is_not_null())
 			)
-			.order_by(model::addressing::Column::Published, Order::Desc)
+			.order_by(model::addressing::Column::Published, Order::Desc);
-			.order_by(model::activity::Column::Internal, Order::Desc)
+
-			.select_only();
+		select = if by_object {
+			select.order_by(model::object::Column::Internal, Order::Desc).select_only()
+		} else {
+			select.order_by(model::activity::Column::Internal, Order::Desc).select_only()
+		};
 
 		for col in model::activity::Column::iter() {
 			select = select.select_column_as(col, format!("{}{}", model::activity::Entity.table_name(), col.to_string()));

upub/routes/src/activitypub/activity.rs

@@ -23,7 +23,7 @@ pub async fn view(
 		}
 	}
 
-	let row = upub::Query::feed(auth.my_id())
+	let row = upub::Query::feed(auth.my_id(), false)
 		.filter(model::activity::Column::Id.eq(&aid))
 		.filter(auth.filter())
 		.into_model::<RichActivity>()

upub/routes/src/activitypub/object/context.rs

@@ -11,7 +11,7 @@ pub async fn get(
 ) -> crate::ApiResult<JsonLD<serde_json::Value>> {
 	let context = ctx.oid(&id);
 
-	let count = upub::Query::feed(auth.my_id())
+	let count = upub::Query::feed(auth.my_id(), true)
 		.filter(auth.filter())
 		.filter(model::object::Column::Context.eq(&context))
 		.count(ctx.db())

upub/routes/src/activitypub/object/mod.rs

@@ -27,7 +27,7 @@ pub async fn view(
 		}
 	}
 
-	let item = upub::Query::feed(auth.my_id())
+	let item = upub::Query::feed(auth.my_id(), true)
 		.filter(model::object::Column::Id.eq(&oid))
 		.filter(auth.filter())
 		.into_model::<RichActivity>()
@@ -44,7 +44,7 @@ pub async fn view(
 	let mut replies = apb::Node::Empty;
 	
 	if ctx.cfg().security.show_reply_ids {
-		let replies_ids = upub::Query::feed(auth.my_id())
+		let replies_ids = upub::Query::feed(auth.my_id(), true)
 			.filter(model::object::Column::InReplyTo.eq(oid))
 			.filter(auth.filter())
 			.select_only()

upub/routes/src/activitypub/object/replies.rs

@@ -15,7 +15,7 @@ pub async fn get(
 	// 	ctx.fetch_thread(&oid).await?;
 	// }
 
-	let replies_ids = upub::Query::feed(auth.my_id())
+	let replies_ids = upub::Query::feed(auth.my_id(), true)
 		.filter(model::object::Column::InReplyTo.eq(ctx.oid(&id)))
 		.filter(auth.filter())
 		.select_only()

upub/routes/src/builders.rs

@@ -5,7 +5,7 @@ use upub::selector::{BatchFillable, RichActivity};
 
 use crate::activitypub::Pagination;
 
-#[deprecated = "just query directly maybe?"]
+//#[deprecated = "just query directly maybe?"]
 pub async fn paginate_feed(
 	id: String,
 	filter: Condition,
@@ -17,7 +17,7 @@ pub async fn paginate_feed(
 	let limit = page.batch.unwrap_or(20).min(50);
 	let offset = page.offset.unwrap_or(0);
 
-	let mut select = upub::Query::feed(my_id);
+	let mut select = upub::Query::feed(my_id, false);
 
 	if with_users {
 		select = select