mesa_dev/client/
repos.rs

1use crate::low_level::apis::{repos_api, Error};
2use crate::models;
3
4use super::pagination::{paginate, PaginatedResponse};
5use super::{OrgClient, RepoClient};
6
7use futures_core::Stream;
8
9impl PaginatedResponse for models::GetByOrgRepos200Response {
10    type Item = models::GetByOrgRepos200ResponseReposInner;
11
12    fn items(self) -> Vec<Self::Item> {
13        self.repos
14    }
15
16    fn next_cursor(&self) -> Option<&str> {
17        self.next_cursor.as_deref()
18    }
19
20    fn has_more(&self) -> bool {
21        self.has_more
22    }
23}
24
25/// Client for listing and creating repositories (`/{org}/repos`).
26#[derive(Clone, Debug)]
27pub struct ReposClient<'a> {
28    pub(super) org: &'a OrgClient<'a>,
29}
30
31impl<'a> ReposClient<'a> {
32    /// List repositories in the organization.
33    ///
34    /// Returns an async stream that automatically paginates through all results,
35    /// yielding one repository at a time. Pass `limit` to control the page size
36    /// of each underlying API request, or `None` for the server default.
37    pub fn list(
38        &self,
39        limit: Option<u8>,
40    ) -> impl Stream<
41        Item = Result<
42            models::GetByOrgRepos200ResponseReposInner,
43            Error<repos_api::GetByOrgReposError>,
44        >,
45    > + 'a {
46        let config = self.org.config;
47        let org = self.org.org;
48
49        paginate(limit, move |cursor, lim| async move {
50            repos_api::get_by_org_repos(config, org, cursor.as_deref(), lim).await
51        })
52    }
53
54    /// Create a new repository.
55    ///
56    /// # Errors
57    ///
58    /// Returns an error if the API request fails.
59    pub async fn create(
60        &self,
61        request: models::PostByOrgReposRequest,
62    ) -> Result<models::PostByOrgRepos201Response, Error<repos_api::PostByOrgReposError>> {
63        repos_api::post_by_org_repos(self.org.config, self.org.org, Some(request)).await
64    }
65
66    /// Navigate to a specific repository.
67    #[must_use]
68    pub fn at(&self, name: &'a str) -> RepoClient<'a> {
69        RepoClient {
70            org: self.org,
71            repo: name,
72        }
73    }
74}
mesa_dev/client/repos.rs

mesa_dev/client/
repos.rs
