OXYGENHUB

Coverage / crates/hub/src/web/diffusion.rs 100.0%

35 of 35 lines run, 8 of 16 functions · run #492 on proposal/340 · run missed

1
//! Diffusion's views (#150, docs/diffusion.md): a repository's Diffusion
2
//! tab (the consumers that pin it, and what it follows itself), and Admin ›
3
//! Diffusion across the hub. Each consumer shows green, amber, red, grey
4
//! or up to date (`diffusion::Colour`).
5
6
use super::{filters, lookup, Error, Page, RepoShell, Shell};
7
use crate::auth::Viewer;
8
use crate::db::repos::RepoRow;
9
use crate::diffusion::Consumer;
10
use crate::Shared;
11
use askama::Template;
12
use axum::extract::{Path, State};
13
14
#[derive(Template)]
15
#[template(path = "diffusion.html")]
16
pub struct DiffusionPage {
17
    shell: Shell,
18
    repo: RepoShell,
19
    used_by: Vec<Consumer>,
20
    follows: Vec<(RepoRow, Consumer)>,
21
    /// This repository has no checks of its own: its bumps are amber.
22
    unverified: bool,
23
    /// The ripples backdrop's data (docs/backgrounds.md §2): this page's
24
    /// own repositories and pill tones, JSON safe in a script.
25
    backdrop: String,
26
}
27
28
/// The ripples' data: the repository, the upstreams it takes from (each in
29
/// its upstream half's tone) and the consumers it diffuses to (each in its
30
/// own half's tone), as `{scene, repo, upstreams: [[name, tone]],
31
/// consumers: [[name, tone]]}`.
323×
fn ripples_json(slug: &str, used_by: &[Consumer], follows: &[(RepoRow, Consumer)]) -> String {
333×
    let tone = |class: &str| class.trim_start_matches("df-").to_string();
343×
    let upstreams: Vec<(String, String)> =
353×
        follows.iter().map(|(up, c)| (format!("{}/{}", up.owner, up.name), tone(c.upstream.class))).collect();
363×
    let consumers: Vec<(String, String)> = used_by.iter().map(|c| (format!("{}/{}", c.owner, c.name), tone(c.downstream.class))).collect();
373×
    serde_json::json!({ "scene": "ripples", "repo": slug, "upstreams": upstreams, "consumers": consumers })
383×
        .to_string()
393×
        .replace('<', "\\u003c")
403×
}
41
42
/// `GET /{owner}/{name}/diffusion`.
433×
pub async fn page(
443×
    State(app): State<Shared>,
453×
    viewer: Viewer,
463×
    Path((owner, name)): Path<(String, String)>,
473×
) -> Result<Page<DiffusionPage>, Error> {
483×
    let shell = Shell::new(&app, &format!("/{owner}/{name}/diffusion"), &viewer);
493×
    let (_, row, role) = lookup(&app, &shell, &viewer, &owner, &name).await?;
503×
    let used_by = crate::diffusion::consumers(&app, &row, viewer.account()).await.unwrap_or_default();
513×
    let follows = crate::diffusion::follows(&app, &row, viewer.account()).await;
523×
    let unverified = crate::diffusion::unverified(&app, &row).await;
533×
    let backdrop = ripples_json(&format!("{owner}/{name}"), &used_by, &follows);
543×
    Ok(Page(DiffusionPage { shell, repo: RepoShell::new(&app, &row, "diffusion").with_role(role), used_by, follows, unverified, backdrop }))
553×
}
56
57
#[derive(Template)]
58
#[template(path = "admin_diffusion.html")]
59
pub struct AdminPage {
60
    shell: Shell,
61
    upstreams: Vec<(RepoRow, Vec<Consumer>, bool)>,
62
}
63
64
/// `GET /admin/diffusion`: every upstream on the hub and its consumers.
652×
pub async fn admin(State(app): State<Shared>, viewer: Viewer) -> Result<Page<AdminPage>, Error> {
662×
    let shell = Shell::new(&app, "/admin/diffusion", &viewer);
672×
    if !viewer.is_admin() {
681×
        return Err(Error::not_found(shell));
691×
    }
701×
    let upstreams = crate::diffusion::everything(&app, viewer.account()).await;
711×
    Ok(Page(AdminPage { shell, upstreams }))
722×
}