a06673b
use db::conn::sea_orm::*;
use db::repo::repo_watch as watch_entity;
use crate::error::RepoResult;
use crate::features::RepoService;
use super::types::{ListSubscriberQuery, SubscriberPage, SubscriberView};
pub async fn list_subscribers(
svc: &RepoService,
actor: uuid::Uuid,
repo_id: uuid::Uuid,
q: ListSubscriberQuery,
) -> RepoResult<SubscriberPage> {
let _ = actor;
let limit = q.limit.unwrap_or(svc.config.default_pagination);
let offset = q.page.unwrap_or(0).saturating_mul(limit);
let limit = std::cmp::min(limit, svc.config.max_pagination);
let db = svc.db.reader();
let query = watch_entity::Entity::find().filter(watch_entity::Column::RepoId.eq(repo_id));
let total = query.clone().count(&db).await?;
let items = query
.limit(Some(limit))
.offset(Some(offset))
.all(&db)
.await?
.into_iter()
.map(SubscriberView::from)
.collect();
Ok(SubscriberPage {
items,
total: total as i64,
})
}