alemi/upub
alemi/upub
1
0
Fork 1
Code Issues 4 Pull requests Projects Releases Packages 1 Wiki Activity Actions

fix: replies and context dont wrap obj with View

Browse source
This commit is contained in:
əlemi 2024-12-26 17:15:29 +01:00
parent 3baa8ed839
commit 35776558f1
Signed by: alemi
GPG key ID: A4895B84D311642C
2 changed files with 28 additions and 58 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
upub/routes/src/activitypub/object/mod.rs
View file

@ -1,10 +1,10 @@
pub mod replies;
pub mod context;
use apb::{BaseMut, Object, ObjectMut, LD};
use apb::LD;
use axum::extract::{Path, Query, State};
use sea_orm::{ColumnTrait, QueryFilter, TransactionTrait};
use upub::{model, selector::{BatchFillable, RichActivity}, traits::Fetcher, Context};
use upub::{model, selector::{BatchFillable, RichObject}, traits::Fetcher, Context};
use crate::{builders::JsonLD, AuthIdentity};
@ -27,12 +27,10 @@ pub async fn view(
}
}
let replies_url = upub::url!(ctx, "/objects/{id}/replies");
let item_model = upub::Query::objects(auth.my_id())
let item = upub::Query::objects(auth.my_id())
.filter(auth.filter_objects())
.filter(model::object::Column::Id.eq(&oid))
.into_model::<RichActivity>()
.into_model::<RichObject>()
.one(ctx.db())
.await?
.ok_or_else(crate::ApiError::not_found)?
@ -43,17 +41,5 @@ pub async fn view(
.with_batched::<upub::model::hashtag::Entity>(ctx.db())
.await?;
let mut item = ctx.ap(item_model);
let replies_patched =
apb::Node::object(
item.replies()
.into_inner()
.unwrap()
.set_id(Some(replies_url))
);
item = item.set_replies(replies_patched);
Ok(JsonLD(item.ld_context()))
Ok(JsonLD(ctx.ap(item).ld_context()))
}

62
upub/routes/src/activitypub/object/replies.rs
View file

@ -1,9 +1,9 @@
use apb::{BaseMut, CollectionMut, CollectionPageMut, LD};
use apb::{BaseMut, CollectionMut, LD};
use axum::extract::{Path, Query, State};
use sea_orm::{ColumnTrait, ConnectionTrait, PaginatorTrait, QueryFilter, QuerySelect, SelectColumns};
use upub::{model, traits::Fetcher, Context};
use sea_orm::{ColumnTrait, PaginatorTrait, QueryFilter, QuerySelect};
use upub::{model, selector::RichObject, traits::Fetcher, Context};
use crate::{activitypub::{Pagination, TryFetch}, builders::JsonLD, ApiResult, AuthIdentity, Identity};
use crate::{activitypub::{Pagination, TryFetch}, builders::JsonLD, AuthIdentity};
pub async fn get(
State(ctx): State<Context>,
@ -21,21 +21,18 @@ pub async fn get(
ctx.fetch_thread(&oid, ctx.db()).await?;
}
let replies_count = total_replies(&oid, &auth, ctx.db()).await?;
let replies_ids = replies_ids(&oid, &auth, ctx.db(), 20, 0).await?;
let first = apb::new()
.set_id(Some(upub::url!(ctx, "/objects/{id}/replies/page")))
.set_collection_type(Some(apb::CollectionType::OrderedCollectionPage))
.set_next(apb::Node::link(upub::url!(ctx, "/objects/{id}/replies/page?offset=20")))
.set_ordered_items(apb::Node::links(replies_ids));
let total_replies = upub::Query::objects(None)
.filter(auth.filter_objects())
.filter(model::object::Column::InReplyTo.eq(&oid))
.count(ctx.db())
.await?;
Ok(JsonLD(
apb::new()
.set_id(Some(upub::url!(ctx, "/objects/{id}/replies")))
.set_collection_type(Some(apb::CollectionType::Collection))
.set_total_items(Some(replies_count))
.set_first(apb::Node::object(first))
.set_total_items(Some(total_replies))
.set_first(apb::Node::link(upub::url!(ctx, "/objects/{id}/replies/page")))
.ld_context()
))
}
@ -53,35 +50,22 @@ pub async fn page(
// TODO kinda weird ignoring this but its weirder to exclude replies from replies view...
page.replies = Some(true);
let replies_ids = replies_ids(&oid, &auth, ctx.db(), limit, offset).await?;
crate::builders::collection_page(
&page_id,
offset,
limit,
apb::Node::links(replies_ids)
)
}
async fn replies_ids(oid: &str, auth: &Identity, db: &impl ConnectionTrait, limit: u64, offset: u64) -> ApiResult<Vec<String>> {
let res = upub::Query::objects(auth.my_id())
.limit(limit)
.offset(offset)
.filter(auth.filter_objects())
.filter(model::object::Column::InReplyTo.eq(oid))
.select_only()
.select_column(model::object::Column::Id)
.into_tuple::<String>()
.all(db)
.await?;
Ok(res)
}
.into_model::<RichObject>()
.all(ctx.db())
.await?
.into_iter()
.map(|x| ctx.ap(x))
.collect();
async fn total_replies(oid: &str, auth: &Identity, db: &impl ConnectionTrait) -> ApiResult<u64> {
let count = upub::Query::objects(None)
.filter(auth.filter_objects())
.filter(model::object::Column::InReplyTo.eq(oid))
.count(db)
.await?;
Ok(count)
crate::builders::collection_page(
&page_id,
offset,
limit,
apb::Node::array(res)
)
}