//! Projects (hub spec §8.2): boards of issues, proposals and notes across

//! the repositories of one person or organisation.

use super::settings::csrf;

use super::{filters, Error, Page, Shell};

use crate::auth::{roles, Access, Viewer};

use crate::db::{self, projects as pdb};

use crate::Shared;

use askama::Template;

use axum::extract::{Form, Path, Query, State};

use axum::response::{IntoResponse, Redirect, Response};

use serde::Deserialize;

/// What a caller may do with an owner's projects.

pub struct Rights {

    /// Sees private projects.

    pub member: bool,

    /// Creates and changes projects.

    pub edit: bool,

}

/// Rights of `account` (anonymous when `None`) over `owner`'s projects;

/// `None` when there is no such person or organisation.

pub async fn rights_of(app: &Shared, account: Option<&db::accounts::Account>, owner: &str) -> sqlx::Result<Option<Rights>> {

    let admin = account.is_some_and(|a| a.is_admin);

    if let Some(a) = db::accounts::account_by_name(&app.db, owner).await? {

        let me = account.is_some_and(|v| v.id == a.id);

        return Ok(Some(Rights { member: me || admin, edit: me || admin }));

    }

    if let Some(o) = db::accounts::org_by_name(&app.db, owner).await? {

        let member = match account {

            Some(v) => db::accounts::org_role(&app.db, o.id, v.id).await?.is_some(),

            None => false,

        };

        return Ok(Some(Rights { member: member || admin, edit: member || admin }));

    }

    Ok(None)

}

async fn rights(app: &Shared, shell: &Shell, viewer: &Viewer, owner: &str) -> Result<Rights, Error> {

    rights_of(app, viewer.account(), owner)

        .await

        .map_err(|e| Error::from_db(shell.clone(), e))?

        .ok_or_else(|| Error::not_found(shell.clone()))

}

#[derive(Template)]

#[template(path = "projects.html")]

pub struct ProjectsPage {

    shell: Shell,

    owner: String,

    /// The projects shown: open or closed as `closed` says, matching `q`.

    projects: Vec<pdb::Project>,

    can_edit: bool,

    error: Option<String>,

    /// On your own page, the organisations you belong to: their boards

    /// are one click away, and where a board for one is made (#119).

    orgs: Vec<String>,

    /// The title filter, and whether the closed ones are shown (#124).

    q: String,

    closed: bool,

    open_count: usize,

    closed_count: usize,

}

impl ProjectsPage {

    /// The page for `all` the projects the viewer may see: counted open

    /// and closed among those matching `q`, then the ones asked for.

    #[allow(clippy::too_many_arguments)]

    fn build(

        shell: Shell,

        owner: String,

        all: Vec<pdb::Project>,

        can_edit: bool,

        error: Option<String>,

        orgs: Vec<String>,

        q: Option<String>,

        closed: bool,

    ) -> ProjectsPage {

        let q = q.unwrap_or_default().trim().to_string();

        let needle = q.to_lowercase();

        let matching: Vec<pdb::Project> = all

            .into_iter()

            .filter(|p| needle.is_empty() || p.title.to_lowercase().contains(&needle) || p.description.to_lowercase().contains(&needle))

            .collect();

        let closed_count = matching.iter().filter(|p| p.closed).count();

        let open_count = matching.len() - closed_count;

        let projects = matching.into_iter().filter(|p| p.closed == closed).collect();

        ProjectsPage { shell, owner, projects, can_edit, error, orgs, q, closed, open_count, closed_count }

    }

}

/// `?q=TEXT&state=open|closed` on the Projects page (#124).

#[derive(Deserialize, Default)]

pub struct ProjectsQuery {

    #[serde(default)]

    q: Option<String>,

    #[serde(default)]

    state: Option<String>,

}

/// The organisations the viewer belongs to, when `owner` is the viewer.

async fn own_orgs(app: &Shared, viewer: &Viewer, owner: &str) -> Vec<String> {

    match viewer.account() {

        Some(a) if a.username == owner => {

            crate::db::accounts::orgs_of(&app.db, a.id).await.map(|v| v.into_iter().map(|(o, _)| o.name).collect()).unwrap_or_default()

        }

        _ => vec![],

    }

}

pub async fn list(

    State(app): State<Shared>,

    viewer: Viewer,

    Path(owner): Path<String>,

    Query(query): Query<ProjectsQuery>,

) -> Result<Page<ProjectsPage>, Error> {

    let shell = Shell::new(&app, &format!("/projects/{owner}"), &viewer);

    let r = rights(&app, &shell, &viewer, &owner).await?;

    let projects = pdb::of_owner(&app.db, &owner)

        .await

        .map_err(|e| Error::from_db(shell.clone(), e))?

        .into_iter()

        .filter(|p| p.public || r.member)

        .collect();

    let orgs = own_orgs(&app, &viewer, &owner).await;

    let closed = query.state.as_deref() == Some("closed");

    Ok(Page(ProjectsPage::build(shell, owner, projects, r.edit, None, orgs, query.q, closed)))

}

#[derive(Deserialize)]

pub struct NewProjectForm {

    #[serde(rename = "_csrf")]

    csrf_token: String,

    title: String,

    #[serde(default)]

    description: String,

    #[serde(default)]

    private: Option<String>,

}

pub async fn create(

    State(app): State<Shared>,

    viewer: Viewer,

    Path(owner): Path<String>,

    Form(f): Form<NewProjectForm>,

) -> Result<Response, Error> {

    let shell = Shell::new(&app, &format!("/projects/{owner}"), &viewer);

    csrf(&viewer, &f.csrf_token, &shell)?;

    let r = rights(&app, &shell, &viewer, &owner).await?;

    if !r.edit {

        return Err(Error::not_found(shell));

    }

    let title = f.title.trim();

    if title.is_empty() || title.len() > 100 {

        let projects = pdb::of_owner(&app.db, &owner).await.map_err(|e| Error::from_db(shell.clone(), e))?;

        let orgs = own_orgs(&app, &viewer, &owner).await;

        return Ok(Page(ProjectsPage::build(

            shell,

            owner,

            projects,

            true,

            Some("A project needs a title of up to 100 characters.".into()),

            orgs,

            None,

            false,

        ))

        .into_response());

    }

    let p = pdb::create(&app.db, &owner, title, f.description.trim(), f.private.is_none())

        .await

        .map_err(|e| Error::from_db(shell.clone(), e))?;

    db::accounts::audit(&app.db, viewer.account(), "project.created", &format!("{owner}/{}", p.number), title).await.ok();

    Ok(Redirect::to(&format!("/projects/{owner}/{}", p.number)).into_response())

}

/// A card as the board shows it.

pub struct CardView {

    pub card: pdb::Card,

    /// `owner/name#N`, for issue and proposal cards.

    pub reference: String,

    pub url: String,

    pub title: String,

    /// `open`, `closed`, `landed`, `draft`… for issues and proposals.

    pub state: String,

}

pub struct ColumnView {

    pub column: pdb::Column,

    pub cards: Vec<CardView>,

    /// Cards the page leaves out (#293): the oldest of a long column, or

    /// those a filter does not match; `total` is how many it holds.

    pub hidden: usize,

    pub total: usize,

}

/// A column longer than this shows its newest cards only, with "show all"

/// (#293): a board's Done column otherwise grows without end.

pub const COLUMN_SHOWN: usize = 30;

/// How the board page shows its cards (#293).

#[derive(Deserialize, Default)]

pub struct BoardQuery {

    /// The column shown whole.

    #[serde(default)]

    all: Option<i64>,

    /// Only cards whose title or reference holds this.

    #[serde(default)]

    q: Option<String>,

    /// Only cards in this state (`open`, `closed`, `landed`…).

    #[serde(default)]

    state: Option<String>,

}

impl BoardQuery {

    fn text(&self) -> String {

        self.q.as_deref().map(str::trim).unwrap_or("").to_string()

    }

    fn state(&self) -> String {

        self.state.as_deref().map(str::trim).unwrap_or("").to_ascii_lowercase()

    }

}

/// Filter and cut the columns as `view` says.

fn shape(columns: &mut [ColumnView], view: &BoardQuery) {

    let (q, state) = (view.text().to_lowercase(), view.state());

    for col in columns.iter_mut() {

        col.total = col.cards.len();

        if !q.is_empty() || !state.is_empty() {

            col.cards.retain(|c| {

                (q.is_empty() || c.title.to_lowercase().contains(&q) || c.reference.to_lowercase().contains(&q))

                    && (state.is_empty() || c.state.eq_ignore_ascii_case(&state))

            });

        } else if col.cards.len() > COLUMN_SHOWN && view.all != Some(col.column.id) {

            // Cards join a column at its end: the newest are the last.

            let cut = col.cards.len() - COLUMN_SHOWN;

            col.cards.drain(..cut);

        }

        col.hidden = col.total - col.cards.len();

    }

}

#[derive(Template)]

#[template(path = "project.html")]

pub struct BoardPage {

    shell: Shell,

    project: pdb::Project,

    columns: Vec<ColumnView>,

    /// The owner's repositories the viewer can read, for adding cards.

    repos: Vec<String>,

    /// Changes cards and columns (an open project).

    can_edit: bool,

    /// Changes the settings (to reopen a closed project too).

    can_manage: bool,

    notice: Option<String>,

    error: Option<String>,

    /// Owners the viewer may move the project to (#125): themselves and the

    /// organisations they belong to, but not its owner now.

    transfer_to: Vec<String>,

    /// The filter the page shows (#293), and whether one is set.

    q: String,

    state: String,

    filtered: bool,

}

#[allow(clippy::too_many_arguments)]

async fn board(

    app: &Shared,

    shell: Shell,

    viewer: &Viewer,

    owner: &str,

    number: i64,

    notice: Option<String>,

    error: Option<String>,

    view: &BoardQuery,

) -> Result<Page<BoardPage>, Error> {

    let e = |e| Error::from_db(shell.clone(), e);

    let r = rights(app, &shell, viewer, owner).await?;

    let project = pdb::get(&app.db, owner, number)

        .await

        .map_err(e)?

        .filter(|p| p.public || r.member)

        .ok_or_else(|| Error::not_found(shell.clone()))?;

    let (mut columns, repos) = board_columns(app, viewer.account(), owner, &project).await.map_err(e)?;

    shape(&mut columns, view);

    let can_edit = r.edit && !project.closed;

    let mut transfer_to = Vec::new();

    if let (true, Some(a)) = (r.edit, viewer.account()) {

        transfer_to.push(a.username.clone());

        let orgs = db::accounts::orgs_of(&app.db, a.id).await.map_err(e)?;

        transfer_to.extend(orgs.into_iter().map(|(o, _)| o.name));

        transfer_to.retain(|o| o != owner);

    }

    let (q, state) = (view.text(), view.state());

    let filtered = !q.is_empty() || !state.is_empty();

    Ok(Page(BoardPage { shell, project, columns, repos, can_edit, can_manage: r.edit, notice, error, transfer_to, q, state, filtered }))

}

/// A project's columns with the cards `account` may see, and the owner's

/// repositories it can read (for adding cards).

pub async fn board_columns(

    app: &Shared,

    account: Option<&db::accounts::Account>,

    owner: &str,

    project: &pdb::Project,

) -> sqlx::Result<(Vec<ColumnView>, Vec<String>)> {

    let mut readable: std::collections::HashMap<i64, db::repos::RepoRow> = Default::default();

    for row in db::repos::list_by_owner(&app.db, owner).await? {

        let role = roles::role_for(&app.db, account, &row).await?;

        if roles::allows(role, Access::Read) {

            readable.insert(row.id, row);

        }

    }

    let cards = pdb::cards(&app.db, project.id).await?;

    let mut columns = Vec::new();

    for column in pdb::columns(&app.db, project.id).await? {

        let mut views = Vec::new();

        for card in cards.iter().filter(|c| c.column_id == column.id) {

            match (card.kind.as_str(), card.repo_id, card.number) {

                ("note", _, _) => views.push(CardView {

                    card: card.clone(),

                    reference: String::new(),

                    url: String::new(),

                    title: card.note.clone(),

                    state: String::new(),

                }),

                (kind, Some(rid), Some(n)) => {

                    // Cards of repositories the viewer cannot read are not shown at all.

                    let Some(row) = readable.get(&rid) else { continue };

                    let (title, state) = if kind == "issue" {

                        match db::issues::get(&app.db, rid, n).await? {

                            Some(i) => (i.title, i.state),

                            None => continue,

                        }

                    } else {

                        match db::proposals::get(&app.db, rid, n).await? {

                            Some(p) => (p.title, p.state),

                            None => continue,

                        }

                    };

                    let slug = format!("{}/{}", row.owner, row.name);

                    views.push(CardView {

                        card: card.clone(),

                        reference: format!("{slug}#{n}"),

                        url: format!("/{slug}/{kind}/{n}"),

                        title,

                        state,

                    });

                }

                _ => {}

            }

        }

        let total = views.len();

        columns.push(ColumnView { column, cards: views, hidden: 0, total });

    }

    let mut repos: Vec<String> = readable.values().map(|r| r.name.clone()).collect();

    repos.sort();

    Ok((columns, repos))

}

pub async fn show(

    State(app): State<Shared>,

    viewer: Viewer,

    Path((owner, number)): Path<(String, i64)>,

    Query(view): Query<BoardQuery>,

) -> Result<Response, Error> {

    let shell = Shell::new(&app, &format!("/projects/{owner}/{number}"), &viewer);

    // A board transferred away (#125): its old address goes to its new one.

    let e = |e| Error::from_db(shell.clone(), e);

    if pdb::get(&app.db, &owner, number).await.map_err(e)?.is_none() {

        if let Some(p) = pdb::redirected(&app.db, &owner, number).await.map_err(e)? {

            return Ok(Redirect::permanent(&format!("/projects/{}/{}", p.owner, p.number)).into_response());

        }

    }

    Ok(board(&app, shell, &viewer, &owner, number, None, None, &view).await?.into_response())

}

#[derive(Deserialize)]

pub struct BoardForm {

    #[serde(rename = "_csrf")]

    csrf_token: String,

    action: String,

    #[serde(default)]

    card: Option<i64>,

    #[serde(default)]

    column: Option<i64>,

    #[serde(default)]

    name: String,

    /// `repo#12`, or `#12` with `repo`.

    #[serde(default)]

    reference: String,

    #[serde(default)]

    repo: String,

    #[serde(default)]

    note: String,

    #[serde(default)]

    title: String,

    #[serde(default)]

    description: String,

    #[serde(default)]

    private: Option<String>,

    #[serde(default)]

    closed: Option<String>,

    /// The owner to transfer the project to (#125).

    #[serde(default)]

    to: String,

}

/// `repo#12` or `#12` (with a repository chosen) to (repository, number).

/// `repo#12`, `#12` with `repo`, or `owner/repo#12` when `owner` is the

/// board's (the form the board itself shows, oxygenhub#118). `Err` says

/// what is wrong.

fn parse_reference(reference: &str, repo: &str, owner: &str) -> Result<(String, i64), String> {

    let bad = || "Name an issue or proposal as repo#12, or write a note.".to_string();

    let r = reference.trim();

    let (name, n) = r.split_once('#').ok_or_else(bad)?;

    let name = if name.is_empty() { repo.trim() } else { name.trim() };

    let name = match name.split_once('/') {

        Some((o, rest)) if o.eq_ignore_ascii_case(owner) => rest,

        Some((o, _)) => return Err(format!("This board holds only {owner}'s issues and proposals, not {o}'s.")),

        None => name,

    };

    let n: i64 = n.trim().parse().map_err(|_| bad())?;

    if name.is_empty() || n <= 0 || name.contains('/') {

        return Err(bad());

    }

    Ok((name.to_string(), n))

}

/// Add a note, or the issue or proposal `reference` names (`repo#12`, or

/// `#12` with `repo`), to a column. `Ok(Err(why))` for what the caller

/// should be told: an unknown repository or number, or a card already there.

#[allow(clippy::too_many_arguments)]

pub async fn add_card(

    app: &Shared,

    account: Option<&db::accounts::Account>,

    owner: &str,

    project_id: i64,

    column_id: i64,

    reference: &str,

    repo: &str,

    note: &str,

    actor: &str,

) -> sqlx::Result<Result<pdb::Card, String>> {

    if !note.trim().is_empty() {

        let note: String = note.trim().chars().take(500).collect();

        pdb::add_card(

            &app.db,

            project_id,

            pdb::NewCard { column_id, kind: "note", repo_id: None, number: None, note: &note, added_by: actor },

        )

        .await?;

        return Ok(Ok(newest_card(app, project_id).await?));

    }

    let (repo, n) = match parse_reference(reference, repo, owner) {

        Ok(r) => r,

        Err(why) => return Ok(Err(why)),

    };

    let Some(row) = db::repos::get(&app.db, owner, &repo).await? else { return Ok(Err(format!("{owner} has no repository {repo}."))) };

    let role = roles::role_for(&app.db, account, &row).await?;

    let (issues, proposals) = db::issues::numbers(&app.db, row.id).await?;

    let kind = if issues.contains(&n) {

        "issue"

    } else if proposals.contains(&n) {

        "proposal"

    } else {

        return Ok(Err(format!("{repo} has no issue or proposal #{n}.")));

    };

    if !roles::allows(role, Access::Read) {

        return Ok(Err(format!("{repo} has no issue or proposal #{n}.")));

    }

    if !pdb::add_card(

        &app.db,

        project_id,

        pdb::NewCard { column_id, kind, repo_id: Some(row.id), number: Some(n), note: "", added_by: actor },

    )

    .await?