nipaw_github 1.9.7

Github provider for nipaw_core
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

use crate::GitHubClientInner;
use async_trait::async_trait;
use crate::common::JsonValue;
use http::header;
use nipaw_core::types::repo::{CollaboratorPermission, CollaboratorResult, RepoInfo, RepoPath};
use nipaw_core::{Repo, Result};
use std::sync::Arc;

pub struct GitHubRepo(pub(crate) Arc<GitHubClientInner>);

#[async_trait]
impl Repo for GitHubRepo {
	async fn info(&self, repo_path: RepoPath) -> Result<RepoInfo> {
		let (token, api_url) = (&self.0.config.token, &self.0.config.api_url);
		let url = format!("{}/repos/{}/{}", api_url, repo_path.owner, repo_path.repo);
		let client = self.0.client.read().await;
		let mut request = client.get(url);
		if let Some(token) = token {
			request = request.bearer_auth(token);
		}
		let resp = request.send().await?;
		let repo_info: JsonValue = resp.json().await?;
		Ok(repo_info.into())
	}

	async fn add_repo_collaborator(
		&self,
		repo_path: RepoPath,
		user_name: &str,
		permission: Option<CollaboratorPermission>,
	) -> Result<CollaboratorResult> {
		let (token, api_url) = (&self.0.config.token, &self.0.config.api_url);
		let url = format!(
			"{}/repos/{}/{}/collaborators/{}",
			api_url, repo_path.owner, repo_path.repo, user_name
		);
		let client = self.0.client.read().await;
		let mut request = client.put(url);
		if let Some(token) = token {
			request = request.bearer_auth(token);
		}
		let permission = match permission {
			Some(permission) => match permission {
				CollaboratorPermission::Admin => "admin".to_string(),
				CollaboratorPermission::Push => "push".to_string(),
				CollaboratorPermission::Pull => "pull".to_string(),
			},
			None => "pull".to_string(),
		};

		let body = serde_json::json!({
			"permission": permission,
		});
		let resp = request
			.header(header::CONTENT_TYPE, "application/json")
			.body(body.to_string())
			.send()
			.await?;
		let collaborator_result: JsonValue = resp.json().await?;
		Ok(collaborator_result.into())
	}
}