wsb 0.186.4098

Workspace - A tool suite for file operations, version management, and development workflow automation
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
115
116
117
118
119
120
121
122
123

use crate::prelude::*;
use axum::{
    extract::{Path, State},
    http::StatusCode,
    Json,
};
use serde_json::json;

use super::sessions::ErrorResponse;
use crate::web::github::{CreateGistRequest, UpdateGistRequest};
use crate::web::state::WebState;

fn no_github() -> (StatusCode, Json<ErrorResponse>) {
    (
        StatusCode::UNAUTHORIZED,
        Json(ErrorResponse {
            error: "GitHub token not configured".to_string(),
        }),
    )
}

fn github_error(e: anyhow::Error) -> (StatusCode, Json<ErrorResponse>) {
    let message = e.to_string();
    if message.contains("status 401") || message.contains("status 403") {
        return (
            StatusCode::UNAUTHORIZED,
            Json(ErrorResponse {
                error: "GitHub token is invalid or lacks required access".to_string(),
            }),
        );
    }
    (
        StatusCode::BAD_GATEWAY,
        Json(ErrorResponse { error: message }),
    )
}

pub async fn list_gists(
    State(state): State<WebState>,
) -> Result<Json<serde_json::Value>, (StatusCode, Json<ErrorResponse>)> {
    let github = state.github.read().await;
    let client = github.as_ref().ok_or_else(no_github)?;
    let gists = client.list_gists().await.map_err(github_error)?;
    Ok(Json(json!({ "gists": gists })))
}

pub async fn get_gist(
    State(state): State<WebState>,
    Path(gist_id): Path<String>,
) -> Result<Json<serde_json::Value>, (StatusCode, Json<ErrorResponse>)> {
    let github = state.github.read().await;
    let client = github.as_ref().ok_or_else(no_github)?;
    let gist = client.get_gist(&gist_id).await.map_err(github_error)?;
    Ok(Json(json!({ "gist": gist })))
}

pub async fn create_gist(
    State(state): State<WebState>,
    Json(body): Json<CreateGistRequest>,
) -> Result<Json<serde_json::Value>, (StatusCode, Json<ErrorResponse>)> {
    let github = state.github.read().await;
    let client = github.as_ref().ok_or_else(no_github)?;
    let gist = client.create_gist(&body).await.map_err(github_error)?;
    Ok(Json(json!({ "gist": gist })))
}

pub async fn update_gist(
    State(state): State<WebState>,
    Path(gist_id): Path<String>,
    Json(body): Json<UpdateGistRequest>,
) -> Result<Json<serde_json::Value>, (StatusCode, Json<ErrorResponse>)> {
    let github = state.github.read().await;
    let client = github.as_ref().ok_or_else(no_github)?;
    let gist = client
        .update_gist(&gist_id, &body)
        .await
        .map_err(github_error)?;
    Ok(Json(json!({ "gist": gist })))
}

#[cfg(test)]
mod tests {
    use super::github_error;
    use axum::http::StatusCode;

    #[test]
    fn list_gists_response_shape_wraps_gists() {
        let payload = serde_json::json!({
            "gists": [{
                "id": "123",
                "description": "notes"
            }]
        });

        assert!(payload.get("gists").unwrap().is_array());
    }

    #[test]
    fn get_gist_response_shape_wraps_gist() {
        let payload = serde_json::json!({
            "gist": {
                "id": "123",
                "files": {
                    "notes.md": {
                        "content": "hello"
                    }
                }
            }
        });

        assert!(payload.get("gist").unwrap().is_object());
    }

    #[test]
    fn github_auth_errors_map_to_unauthorized() {
        let (status, body) = github_error(anyhow::anyhow!("failed with GitHub API status 401"));
        assert_eq!(status, StatusCode::UNAUTHORIZED);
        assert_eq!(
            body.0.error,
            "GitHub token is invalid or lacks required access"
        );
    }
}