use db::project::project_activities as activity_entity;
use db::project::project_activities::Column as Ac;
use sea_orm::{ColumnTrait, EntityTrait, QueryFilter, QueryOrder, PaginatorTrait};
use uuid::Uuid;

use crate::error::ProjectResult;
use crate::features::ProjectService;
use crate::permission;

use super::{ActivityPage, ActivityView, ListActivityQuery};

pub async fn list_activities(
    svc: &ProjectService,
    actor: Uuid,
    space_id: Uuid,
    project_id: Uuid,
    q: ListActivityQuery,
) -> ProjectResult<ActivityPage> {
    crate::features::authz::require(svc, actor, space_id, project_id, permission::VIEW_PROJECT)
        .await?;

    let page = q.page.max(1);
    let per_page = q.per_page.clamp(1, svc.config.max_page_size);
    let offset = (page - 1) * per_page;

    let mut query = activity_entity::Entity::find()
        .filter(Ac::ProjectId.eq(project_id))
        .order_by_desc(Ac::CreatedAt);

    if let Some(verb) = q.verb {
        query = query.filter(Ac::Verb.eq(verb));
    }

    let reader = svc.db.reader();
    let paginator = query.paginate(&reader, per_page);
    let total = paginator.num_items().await?;
    let rows = paginator.fetch_page(offset / per_page).await?;
    let items = rows.iter().map(activity_view).collect();
    Ok(ActivityPage { total, items })
}

fn activity_view(m: &activity_entity::Model) -> ActivityView {
    ActivityView {
        id: m.id,
        project_id: m.project_id,
        actor_id: m.actor_id,
        verb: m.verb.clone(),
        target_kind: m.target_kind.clone(),
        target_id: m.target_id,
        payload: m.payload.clone(),
        created_at: m.created_at,
    }
}