//! Diffusion's views (#150, docs/diffusion.md): a repository's Diffusion

//! tab (the consumers that pin it, and what it follows itself), and Admin ›

//! Diffusion across the hub. Each consumer shows green, amber, red, grey

//! or up to date (`diffusion::Colour`).

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

use crate::auth::Viewer;

use crate::db::repos::RepoRow;

use crate::diffusion::Consumer;

use crate::Shared;

use askama::Template;

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

#[derive(Template)]

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

pub struct DiffusionPage {

    shell: Shell,

    repo: RepoShell,

    used_by: Vec<Consumer>,

    follows: Vec<(RepoRow, Consumer)>,

    /// This repository has no checks of its own: its bumps are amber.

    unverified: bool,

}

/// `GET /{owner}/{name}/diffusion`.

pub async fn page(

    State(app): State<Shared>,

    viewer: Viewer,

    Path((owner, name)): Path<(String, String)>,

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

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

    let (_, row, role) = lookup(&app, &shell, &viewer, &owner, &name).await?;

    let used_by = crate::diffusion::consumers(&app, &row, viewer.account()).await.unwrap_or_default();

    let follows = crate::diffusion::follows(&app, &row, viewer.account()).await;

    let unverified = crate::diffusion::unverified(&app, &row).await;

    Ok(Page(DiffusionPage { shell, repo: RepoShell::new(&app, &row, "diffusion").with_role(role), used_by, follows, unverified }))

}

#[derive(Template)]

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

pub struct AdminPage {

    shell: Shell,

    upstreams: Vec<(RepoRow, Vec<Consumer>, bool)>,

}

/// `GET /admin/diffusion`: every upstream on the hub and its consumers.

pub async fn admin(State(app): State<Shared>, viewer: Viewer) -> Result<Page<AdminPage>, Error> {

    let shell = Shell::new(&app, "/admin/diffusion", &viewer);

    if !viewer.is_admin() {

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

    }

    let upstreams = crate::diffusion::everything(&app, viewer.account()).await;

    Ok(Page(AdminPage { shell, upstreams }))

}