Compare commits
2 commits
f5d794824e
...
baaaa55e9d
Author | SHA1 | Date | |
---|---|---|---|
baaaa55e9d | |||
8a3211d07b |
6 changed files with 24 additions and 7 deletions
|
@ -1,4 +1,4 @@
|
|||
use apb::{BaseMut, CollectionMut, DocumentMut, Object, ObjectMut, ObjectType};
|
||||
use apb::{BaseMut, CollectionMut, DocumentMut, ObjectMut, ObjectType};
|
||||
use sea_orm::{entity::prelude::*, QuerySelect, SelectColumns};
|
||||
|
||||
use crate::ext::JsonVec;
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
use axum::{http::StatusCode, extract::{Path, Query, State}, Json};
|
||||
use sea_orm::{sea_query::IntoCondition, ColumnTrait};
|
||||
use sea_orm::{ColumnTrait, Condition};
|
||||
|
||||
use upub::Context;
|
||||
|
||||
|
@ -37,7 +37,10 @@ pub async fn page(
|
|||
|
||||
crate::builders::paginate_feed(
|
||||
upub::url!(ctx, "/actors/{id}/inbox/page"),
|
||||
upub::model::addressing::Column::Actor.eq(*internal).into_condition(),
|
||||
Condition::any()
|
||||
.add(upub::model::addressing::Column::Actor.eq(*internal))
|
||||
.add(upub::model::activity::Column::Actor.eq(uid))
|
||||
.add(upub::model::object::Column::AttributedTo.eq(uid)),
|
||||
ctx.db(),
|
||||
page,
|
||||
auth.my_id(),
|
||||
|
|
|
@ -4,7 +4,7 @@ use reqwest::Method;
|
|||
use sea_orm::{Condition, ColumnTrait};
|
||||
use upub::{traits::{Cloaker, Fetcher}, Context};
|
||||
|
||||
use crate::{builders::JsonLD, ApiError, AuthIdentity, Identity};
|
||||
use crate::{builders::JsonLD, ApiError, AuthIdentity};
|
||||
|
||||
use super::{PaginatedSearch, Pagination};
|
||||
|
||||
|
@ -56,9 +56,11 @@ pub async fn search(
|
|||
.add(upub::model::object::Column::Content.like(format!("%{}%", page.q)));
|
||||
|
||||
// TODO lmao rethink this all
|
||||
// still haven't redone this gg me
|
||||
let page = Pagination {
|
||||
offset: page.offset,
|
||||
batch: page.batch,
|
||||
replies: Some(true),
|
||||
};
|
||||
|
||||
crate::builders::paginate_feed(
|
||||
|
|
|
@ -90,6 +90,7 @@ pub struct TryFetch {
|
|||
pub struct Pagination {
|
||||
pub offset: Option<u64>,
|
||||
pub batch: Option<u64>,
|
||||
pub replies: Option<bool>,
|
||||
}
|
||||
|
||||
#[derive(Debug, serde::Deserialize)]
|
||||
|
|
|
@ -38,12 +38,15 @@ pub async fn get(
|
|||
pub async fn page(
|
||||
State(ctx): State<Context>,
|
||||
Path(id): Path<String>,
|
||||
Query(page): Query<Pagination>,
|
||||
Query(mut page): Query<Pagination>,
|
||||
AuthIdentity(auth): AuthIdentity,
|
||||
) -> crate::ApiResult<JsonLD<serde_json::Value>> {
|
||||
let page_id = upub::url!(ctx, "/objects/{id}/replies/page");
|
||||
let oid = ctx.oid(&id);
|
||||
|
||||
// TODO kinda weird ignoring this but its weirder to exclude replies from replies view...
|
||||
page.replies = Some(true);
|
||||
|
||||
crate::builders::paginate_feed(
|
||||
page_id,
|
||||
Condition::all()
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
use apb::{BaseMut, CollectionMut, CollectionPageMut, LD};
|
||||
use sea_orm::{Condition, ConnectionTrait, QueryFilter, QuerySelect, RelationTrait};
|
||||
use sea_orm::{Condition, ConnectionTrait, QueryFilter, QuerySelect, RelationTrait, ColumnTrait};
|
||||
use axum::response::{IntoResponse, Response};
|
||||
use upub::selector::{BatchFillable, RichActivity};
|
||||
|
||||
|
@ -17,6 +17,14 @@ pub async fn paginate_feed(
|
|||
let limit = page.batch.unwrap_or(20).min(50);
|
||||
let offset = page.offset.unwrap_or(0);
|
||||
|
||||
let mut conditions = Condition::all()
|
||||
.add(filter);
|
||||
|
||||
// by default we want replies because servers don't know about our api and want everything
|
||||
if !page.replies.unwrap_or(true) {
|
||||
conditions = conditions.add(upub::model::object::Column::InReplyTo.is_null());
|
||||
}
|
||||
|
||||
let mut select = upub::Query::feed(my_id);
|
||||
|
||||
if with_users {
|
||||
|
@ -25,7 +33,7 @@ pub async fn paginate_feed(
|
|||
}
|
||||
|
||||
let items = select
|
||||
.filter(filter)
|
||||
.filter(conditions)
|
||||
// TODO also limit to only local activities
|
||||
.limit(limit)
|
||||
.offset(offset)
|
||||
|
|
Loading…
Reference in a new issue