korrosync 0.4.0

A KOReader Sync Server
Documentation 
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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114

use axum::{
    Extension, Json, Router,
    extract::{Path, State},
    response::IntoResponse,
    routing::{get, put},
};
use axum_extra::extract::WithRejection;
use serde::{Deserialize, Serialize};
use serde_json::json;
use tracing::{debug, info};

use crate::{
    api::{error::ApiError, middleware::auth::AuthenticatedUser, state::AppState},
    model::Progress,
};

/// Create the syncs progress routes
pub fn create_route() -> Router<AppState> {
    Router::new()
        .route("/syncs/progress", put(update_progress))
        .route("/syncs/progress/{doc}", get(get_progress))
}

/// Request body for updating sync progress
#[derive(Debug, Deserialize)]
struct UpdateProgressRequest {
    pub device_id: String,
    pub device: String,
    pub document: String,
    pub percentage: f32,
    pub progress: String,
}

/// Response for sync progress
#[derive(Serialize)]
struct ProgressResponse {
    pub device_id: String,
    pub device: String,
    pub document: String,
    pub percentage: f32,
    pub progress: String,
    pub timestamp: u64,
}

/// Handler for PUT /syncs/progress
///
/// Updates the synchronization progress for a document
#[tracing::instrument(level = tracing::Level::DEBUG, skip(state))]
async fn update_progress(
    State(state): State<AppState>,
    Extension(AuthenticatedUser(user, _)): Extension<AuthenticatedUser>,
    WithRejection(Json(payload), _): WithRejection<Json<UpdateProgressRequest>, ApiError>,
) -> Result<impl IntoResponse, ApiError> {
    debug!("Updating sync progress");

    let (doc, ts) = state
        .sync
        .update_progress(user, payload.document.clone(), payload.into())?;

    Ok(Json(json!({
        "document": doc,
        "timestamp": ts,
    }))
    .into_response())
}

/// Handler for GET /syncs/progress/{doc}
///
/// Returns the synchronization progress for a specific document
#[tracing::instrument(level = tracing::Level::DEBUG, skip(state))]
async fn get_progress(
    State(state): State<AppState>,
    Extension(AuthenticatedUser(user, _)): Extension<AuthenticatedUser>,
    WithRejection(Path(doc), _): WithRejection<Path<String>, ApiError>,
) -> Result<impl IntoResponse, ApiError> {
    info!("Getting sync progress for doc: {}", doc);

    let progress = state.sync.get_progress(user, doc.clone());

    match progress {
        Ok(Some(progress)) => Ok(Json(ProgressResponse {
            document: doc,
            ..progress.into()
        })
        .into_response()),
        Ok(None) => Ok(Json(json!({})).into_response()),
        Err(e) => Err(e.into()),
    }
}

impl From<UpdateProgressRequest> for Progress {
    fn from(value: UpdateProgressRequest) -> Self {
        Self {
            device_id: value.device_id,
            device: value.device,
            percentage: value.percentage,
            progress: value.progress,
            timestamp: chrono::Utc::now().timestamp_millis() as u64,
        }
    }
}

impl From<Progress> for ProgressResponse {
    fn from(value: Progress) -> Self {
        Self {
            device_id: value.device_id,
            device: value.device,
            document: "".to_string(),
            percentage: value.percentage,
            progress: value.progress,
            timestamp: value.timestamp,
        }
    }
}