Coverage / crates/hub/src/web/repo.rs 92.1%

fn remote_name(base_url: &str) -> String {

    let host = base_url.split("://").nth(1).unwrap_or("").split(['/', ':']).next().unwrap_or("");

    let first = host.split('.').next().unwrap_or("");

    let plain = first.len() <= 20

        && first.starts_with(|c: char| c.is_ascii_lowercase())

        && first.chars().all(|c| c.is_ascii_lowercase() || c.is_ascii_digit());

    if plain && first != "www" && first != "localhost" {

        first.to_string()

        "hub".to_string()

}

    pub fn new(app: &Shared, can_push: bool) -> Quickstart {

        let base = app.config.base_url().trim_end_matches('/').to_string();

        let remote = remote_name(&base);

        let ca_file = format!("~/.config/oxy/{remote}-ca.pem");

        let ca_url = app.config.tls.self_signed.then(|| format!("{base}/.well-known/oxyhub-ca.pem"));

        Quickstart { remote, ca_url, ca_file, can_push }

    }

    pub fn connect(&self, clone_url: &str) -> String {

        let r = &self.remote;

        let mut s = format!("oxy remote add {r} {clone_url}\n");

        if let Some(ca) = &self.ca_url {

        }

        s += &format!("oxy config remote.{r}.token YOUR-TOKEN\n");

        s += &format!("oxy push {r}");

        s

    }

    pub fn fresh(&self, name: &str) -> String {

        format!("mkdir {name} && cd {name}\noxy init\necho \"# {name}\" > README.md\noxy commit -m \"First change\"")

    }

    pub fn git_import(&self, name: &str) -> String {

        format!("oxy git import --branch main path/to/git-checkout {name}\ncd {name}")

    }

pub async fn overview(

    State(app): State<Shared>,

    viewer: Viewer,

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

    Query(q): Query<OverviewQuery>,

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

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

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

    let default = row.default_bookmark.clone();

    let at = q.at.map(|a| a.trim().to_string()).filter(|a| !a.is_empty()).unwrap_or_else(|| default.clone());

    let shown = at.clone();

    let mut o = app

        .repos

        .read(&repo, move |r, cache| view::overview(r, cache, &default, &shown))

        .await

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

    let linked: HashMap<String, String> = crate::db::accounts::identity_accounts(&app.db).await.unwrap_or_default().into_iter().collect();

    let hub_key = app.hub_key.key.to_hex();

    for c in &mut o.contributors {

        c.account = linked.get(&c.key).cloned();

        c.hub = c.key == hub_key;

    }

    if let Some(c) = o.latest.as_mut() {

        c.author.account = linked.get(&c.author.key).cloned();

    }

    let mut merged: Vec<view::Contributor> = Vec::new();

    for c in std::mem::take(&mut o.contributors) {

        match c.account.as_ref().and_then(|a| merged.iter_mut().find(|m| m.account.as_deref() == Some(a))) {

            Some(m) => {

                m.changes += c.changes;

                for (who, n) in c.via {

                m.via.sort_by(|a, b| b.1.cmp(&a.1).then(a.0.cmp(&b.0)));

            None => merged.push(c),

    merged.sort_by(|a, b| b.changes.cmp(&a.changes).then(a.name.cmp(&b.name)));

    o.contributors = merged;

    let rs = RepoShell::new(&app, &row, "code").with_role(role).with_sky(&app, &row).await;

    let readme_html = o.readme_html(&rs, &o.tree.target.label);

    let watching = match viewer.account() {

        Some(a) => crate::db::notify::watching(&app.db, a.id, row.id).await.unwrap_or(false),

        None => false,

    let latest_release = crate::db::releases::latest(&app.db, row.id).await.ok().flatten();

    let quickstart = (o.changes == 0).then(|| Quickstart::new(&app, rs.can(crate::auth::Access::Write)));

    let fork = super::forks::info(&app, &shell, &viewer, &row).await;

    let starred = match viewer.account() {

        Some(a) => crate::db::repos::starred(&app.db, a.id, row.id).await.unwrap_or(false),

        None => false,

    let (stars, watchers) = crate::db::repos::counts(&app.db, row.id).await.unwrap_or((0, 0));

    let topics = row.topic_list().into_iter().map(String::from).collect();

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

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

    Ok(Page(OverviewPage {

        shell,

        repo: rs,

        o,

        readme_html,

        watching,

        latest_release,

        quickstart,

        fork,

        starred,

        stars,

        watchers,

        topics,

        used_by,

        follows,

        at,

    }))

}

    fn readme_html(&self, rs: &RepoShell, r: &str) -> Option<String> {

        self.tree.readme.as_ref().map(|md| {

            let dir = md.path.rsplit_once('/').map(|(d, _)| format!("{d}/")).unwrap_or_default();

            render::markdown::render(&md.text, &format!("{}/file/{r}/{dir}", rs.url), &format!("{}/raw/{r}/{dir}", rs.url))

        })

    }

pub async fn tree_root(Path((owner, name, r)): Path<(String, String, String)>) -> Response {

    axum::response::Redirect::to(&format!("/{owner}/{name}?at={}", super::settings::urlencode(&r))).into_response()

}

pub async fn tree(

    State(app): State<Shared>,

    viewer: Viewer,

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

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

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

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

    let (spec, dir) = (r.clone(), path.clone());

    let t = app

        .repos

        .read(&repo, move |repo, cache| {

            let target = view::resolve(repo, cache, &spec)?;

            view::tree(repo, cache, target, &dir)

        })

        .await

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

    let rs = RepoShell::new(&app, &row, "code").with_role(role);

    let readme_html = t.readme.as_ref().map(|md| {

    Ok(Page(TreePage { shell, repo: rs, t, readme_html }))

}

fn age_step(when: u64, oldest: u64, newest: u64) -> u8 {

    if newest <= oldest {

        return 9;

    }

    (((when.saturating_sub(oldest)) as u128 * 9 / (newest - oldest) as u128) as u8).min(9)

}

fn blame_rows(

    lines: &[oxy_core::repo::BlameLine],

    before: &std::collections::HashMap<oxy_core::hash::ChangeHash, Option<String>>,

) -> Vec<BlameRow> {

    let oldest = lines.iter().map(|l| l.when_ms).min().unwrap_or(0);

    let newest = lines.iter().map(|l| l.when_ms).max().unwrap_or(0);

    let mut rows: Vec<BlameRow> = Vec::with_capacity(lines.len());

    let mut i = 0;

    while i < lines.len() {

        let mut run = 1;

        while i + run < lines.len() && lines[i + run].hash == lines[i].hash {

            run += 1;

        }

        for k in 0..run {

            let l = &lines[i + k];

            rows.push(BlameRow {

                first: k == 0,

                hash: l.hash.to_hex(),

                short: l.hash.short(8),

                author: l.author.clone(),

                when_ms: l.when_ms,

                run,

                age: age_step(l.when_ms, oldest, newest),

                before: before.get(&l.hash).cloned().flatten(),

            });

        }

        i += run;

    rows

}

pub async fn file(

    State(app): State<Shared>,

    viewer: Viewer,

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

    Query(q): Query<FileQuery>,

) -> Result<Response, Error> {

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

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

    if path == super::flow::RUN_LINK && !has_file(&app, &repo, &r, &path).await {

        return Ok(axum::response::Redirect::to(&format!("/{owner}/{name}/flow/at/{r}")).into_response());

    }

    let limit = app.config.limits.render_limit.0;

    if q.plain.is_some() {

        let (spec, p) = (r.clone(), path.clone());

        let (file_name, bytes) = app

            .repos

            .read(&repo, move |repo, cache| view::raw(repo, cache, &view::resolve(repo, cache, &spec)?, &p))

            .await

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

        return Ok(super::raw(bytes, &file_name, true));

    }

    let want_blame = q.blame.is_some();

    let (spec, p) = (r.clone(), path.clone());

    let (f, blame) = app

        .repos

        .read(&repo, move |repo, cache| {

            let target = view::resolve(repo, cache, &spec)?;

            if want_blame {

                let b = view::blame(repo, cache, target, &p, limit)?;

                let rows = blame_rows(&b.lines, &b.before);

                Ok((b.file, Some(rows)))

                Ok((view::file(repo, cache, target, &p, limit)?, None))

        })

        .await

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

    if q.plain.is_some() {

    }

    let rs = RepoShell::new(&app, &row, "code").with_role(role);

    let is_image = super::mime_of(&f.name).starts_with("image/");

    let is_markdown = f.name.to_lowercase().ends_with(".md") || f.name.to_lowercase() == "readme";

    let want_source = q.view.as_deref() == Some("source") || blame.is_some();

    let (lines, language, markdown_html) = match &f.body {

        FileBody::Text(text) if !is_image => {

            if is_markdown && !want_source {

                let dir = f.path.rsplit_once('/').map(|(d, _)| format!("{d}/")).unwrap_or_default();

                let (base, raw) = (format!("{}/file/{r}/{dir}", rs.url), format!("{}/raw/{r}/{dir}", rs.url));

                (vec![], highlight::language(&f.path), Some(render::markdown::render(text, &base, &raw)))

                (highlight::lines(&f.path, text), highlight::language(&f.path), None)

    let permalink = f.target.permalink();

    let functions = match &f.body {

        FileBody::Text(text) if !is_image => crate::repos::functions::functions(&f.path, text),

    Ok(Page(FilePage { shell, repo: rs, f, lines, language, markdown_html, is_image, is_markdown, blame, permalink, functions })

        .into_response())

}

async fn has_file(app: &Shared, repo: &crate::repos::RepoName, r: &str, path: &str) -> bool {

    let (spec, p) = (r.to_string(), path.to_string());

    app.repos

        .read(repo, move |repo, cache| {

            let target = view::resolve(repo, cache, &spec)?;

            Ok(cache.load(repo, &target.heads)?.snapshot.files.get(&p).is_some_and(|f| f.kind != oxy_core::objects::NodeKind::Dir))

        })

        .await

        .unwrap_or(false)

}

pub async fn raw_file(

    State(app): State<Shared>,

    viewer: Viewer,

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

) -> Result<Response, Error> {

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

    let (repo, _row, _role) = lookup(&app, &shell, &viewer, &owner, &name).await?;

    if path == super::flow::STAMP_IMAGE && !has_file(&app, &repo, &r, &path).await {

        return Ok(axum::response::Redirect::to(&format!("/{owner}/{name}/flow/stamp/{r}")).into_response());

    }

    let (spec, p) = (r.clone(), path.clone());

    let (file_name, bytes) = app

        .repos

        .read(&repo, move |repo, cache| {

            let target = view::resolve(repo, cache, &spec)?;

            view::raw(repo, cache, &target, &p)

        })

        .await

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

    Ok(super::raw(bytes, &file_name, true))

}

pub async fn last_changes(

    State(app): State<Shared>,

    viewer: Viewer,

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

    Query(q): Query<LastQuery>,

) -> Result<Response, Error> {

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

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

    let paths: Vec<String> = q.paths.split(',').filter(|p| !p.is_empty()).take(500).map(String::from).collect();

    let spec = r.clone();

    let found = app

        .repos

        .read(&repo, move |repo, cache| {

            let target = view::resolve(repo, cache, &spec)?;

            view::last_changes(repo, cache, &target.heads, &paths)

        })