cratesio-mcp 0.1.4

MCP server for querying crates.io - the Rust package registry
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

//! Crate owner management endpoints.

use super::CratesIoClient;
use super::error::Error;
use super::types::{OkResponse, OwnerInvitation, User};
use super::wire::{
    HandleInvitationRequest, InvitationTokenResponse, OwnerInvitationsResponse, OwnersRequest,
    OwnersResponse,
};

impl CratesIoClient {
    /// Get owners/maintainers of a crate.
    pub async fn crate_owners(&self, name: &str) -> Result<Vec<User>, Error> {
        let resp: OwnersResponse = self.get_json(&format!("/crates/{name}/owners")).await?;
        Ok(resp.users)
    }

    /// Get user owners of a crate.
    pub async fn crate_user_owners(&self, name: &str) -> Result<Vec<User>, Error> {
        let resp: OwnersResponse = self.get_json(&format!("/crates/{name}/owner_user")).await?;
        Ok(resp.users)
    }

    /// Get team owners of a crate.
    pub async fn crate_team_owners(&self, name: &str) -> Result<Vec<User>, Error> {
        let resp: OwnersResponse = self.get_json(&format!("/crates/{name}/owner_team")).await?;
        Ok(resp.users)
    }

    // ── Authenticated endpoints ─────────────────────────────────────────

    /// Add owners to a crate.
    ///
    /// Requires authentication. `logins` are GitHub usernames or team names.
    pub async fn add_owners(&self, name: &str, logins: Vec<String>) -> Result<OkResponse, Error> {
        let body = OwnersRequest { users: logins };
        self.put_json(&format!("/crates/{name}/owners"), &body)
            .await
    }

    /// Remove owners from a crate.
    ///
    /// Requires authentication. `logins` are GitHub usernames or team names.
    pub async fn remove_owners(
        &self,
        name: &str,
        logins: Vec<String>,
    ) -> Result<OkResponse, Error> {
        let body = OwnersRequest { users: logins };
        self.delete_json_with_body(&format!("/crates/{name}/owners"), &body)
            .await
    }

    /// List owner invitations for a specific crate.
    ///
    /// Requires authentication.
    pub async fn crate_owner_invitations(&self, name: &str) -> Result<Vec<OwnerInvitation>, Error> {
        let resp: OwnerInvitationsResponse = self
            .get_json_auth(&format!("/crates/{name}/owner_invitations"))
            .await?;
        Ok(resp.crate_owner_invitations)
    }

    /// List the authenticated user's pending owner invitations.
    ///
    /// Requires authentication.
    pub async fn my_owner_invitations(&self) -> Result<Vec<OwnerInvitation>, Error> {
        let resp: OwnerInvitationsResponse =
            self.get_json_auth("/me/crate_owner_invitations").await?;
        Ok(resp.crate_owner_invitations)
    }

    /// Accept or decline an owner invitation.
    ///
    /// Requires authentication.
    pub async fn handle_owner_invitation(
        &self,
        crate_id: u64,
        accept: bool,
    ) -> Result<OkResponse, Error> {
        let body = HandleInvitationRequest {
            accepted: accept,
            crate_id,
        };
        self.put_json(&format!("/me/crate_owner_invitations/{crate_id}"), &body)
            .await
    }

    /// Accept an owner invitation using a token (from email link).
    pub async fn accept_invitation_by_token(&self, token: &str) -> Result<u64, Error> {
        let resp: InvitationTokenResponse = self
            .put_empty_json(&format!("/crate_owner_invitations/{token}"))
            .await?;
        Ok(resp.crate_owner_invitation.crate_id)
    }
}