devpage 0.2.5

Live documents from a repository: sites, docs and slides from Markdown, and UI designs drawn from code — with comments, link checking and PDF
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

//! A document's comments over the API — listed, started on the latest
//! version, replied to, resolved — each written through the comments of the
//! latest version, as its own pages write them.

use axum::Json;
use axum::extract::{Path as UrlPath, State};
use axum::http::{HeaderMap, StatusCode};
use axum::response::{IntoResponse, Response};

use super::{author, document_id};
use crate::drive::api_types::{NewThread, Refusal, Reply, Started, Thread};
use crate::drive::server_mode::published::{Mount, Published};

/// `GET /api/documents/<id>/comments`: every thread, oldest first.
pub async fn list(
    State(published): State<Published>,
    UrlPath(id): UrlPath<String>,
) -> Result<Response, Refusal> {
    let threads: Vec<Thread> = published
        .threads(&document_id(&id)?)?
        .into_iter()
        .map(|row| Thread {
            id: row.id,
            page: row.page,
            version: row.version,
            detached: row.detached,
            detached_in: row.detached_in,
            anchor: row.anchor,
            thread: row.thread,
        })
        .collect();
    Ok(Json(threads).into_response())
}

/// `POST /api/documents/<id>/comments`: a thread started on the latest
/// version, on a page that is a file in it, announced to its open pages.
pub async fn create(
    State(published): State<Published>,
    UrlPath(id): UrlPath<String>,
    headers: HeaderMap,
    Json(new): Json<NewThread>,
) -> Result<Response, Refusal> {
    let author = author(&published, &headers)?;
    let latest = published.version(&document_id(&id)?, Mount::Latest).await?;
    let thread = published
        .comments(&latest)?
        .create(&new.page, new.anchor, &author, &new.text)?;
    let started = Started {
        id: thread,
        version: latest.number,
    };
    Ok((StatusCode::CREATED, Json(started)).into_response())
}

/// `POST /api/documents/<id>/comments/<thread>/replies`: by the thread's id
/// alone, detached or not.
pub async fn reply(
    State(published): State<Published>,
    UrlPath((id, thread)): UrlPath<(String, String)>,
    headers: HeaderMap,
    Json(reply): Json<Reply>,
) -> Result<Response, Refusal> {
    let author = author(&published, &headers)?;
    let latest = published.version(&document_id(&id)?, Mount::Latest).await?;
    published
        .comments(&latest)?
        .reply(&thread, &author, &reply.text)?;
    Ok(StatusCode::CREATED.into_response())
}

/// `DELETE /api/documents/<id>/comments/<thread>`: resolved, so gone.
pub async fn resolve(
    State(published): State<Published>,
    UrlPath((id, thread)): UrlPath<(String, String)>,
    headers: HeaderMap,
) -> Result<Response, Refusal> {
    author(&published, &headers)?;
    let latest = published.version(&document_id(&id)?, Mount::Latest).await?;
    published.comments(&latest)?.resolve(&thread)?;
    Ok(StatusCode::NO_CONTENT.into_response())
}