asc-mcp 0.1.1

MCP server for Apple App Store Connect API — Xcode Cloud operations
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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148

//! Domain-specific endpoint methods for [`AscClient`].
//!
//! Separated from core transport to keep file sizes manageable.

use crate::client::{ApiError, AscClient};
use crate::models::{
    App, CiBuildAction, CiBuildRun, CiProduct, CiWorkflow, CustomerReview, JsonApiResponse,
    SalesReportRow, parse_sales_tsv,
};

impl AscClient {
    // -----------------------------------------------------------------
    // CI endpoints
    // -----------------------------------------------------------------

    /// Lists all Xcode Cloud CI products.
    pub async fn list_products(&self) -> Result<JsonApiResponse<Vec<CiProduct>>, ApiError> {
        self.get("/ciProducts").await
    }

    /// Gets a specific CI product by ID.
    pub async fn get_product(&self, id: &str) -> Result<JsonApiResponse<CiProduct>, ApiError> {
        self.get(&format!("/ciProducts/{id}")).await
    }

    /// Lists workflows for a given CI product.
    pub async fn list_workflows(
        &self,
        product_id: &str,
    ) -> Result<JsonApiResponse<Vec<CiWorkflow>>, ApiError> {
        self.get(&format!("/ciProducts/{product_id}/workflows"))
            .await
    }

    /// Gets a specific workflow by ID.
    pub async fn get_workflow(&self, id: &str) -> Result<JsonApiResponse<CiWorkflow>, ApiError> {
        self.get(&format!("/ciWorkflows/{id}")).await
    }

    /// Lists build runs for a given workflow.
    pub async fn list_build_runs(
        &self,
        workflow_id: &str,
    ) -> Result<JsonApiResponse<Vec<CiBuildRun>>, ApiError> {
        self.get(&format!("/ciWorkflows/{workflow_id}/buildRuns"))
            .await
    }

    /// Gets a specific build run by ID.
    pub async fn get_build_run(&self, id: &str) -> Result<JsonApiResponse<CiBuildRun>, ApiError> {
        self.get(&format!("/ciBuildRuns/{id}")).await
    }

    /// Starts a new build run for a workflow.
    pub async fn start_build(
        &self,
        workflow_id: &str,
        git_reference_id: &str,
    ) -> Result<JsonApiResponse<CiBuildRun>, ApiError> {
        let body = serde_json::json!({
            "data": {
                "type": "ciBuildRuns",
                "relationships": {
                    "workflow": {
                        "data": { "type": "ciWorkflows", "id": workflow_id }
                    },
                    "sourceBranchOrTag": {
                        "data": { "type": "scmGitReferences", "id": git_reference_id }
                    }
                }
            }
        });
        self.post("/ciBuildRuns", &body).await
    }

    /// Lists build actions within a build run.
    pub async fn list_build_actions(
        &self,
        build_run_id: &str,
    ) -> Result<JsonApiResponse<Vec<CiBuildAction>>, ApiError> {
        self.get(&format!("/ciBuildRuns/{build_run_id}/actions"))
            .await
    }

    // -----------------------------------------------------------------
    // App endpoints
    // -----------------------------------------------------------------

    /// Lists all apps in App Store Connect.
    pub async fn list_apps(&self) -> Result<JsonApiResponse<Vec<App>>, ApiError> {
        self.get("/apps").await
    }

    /// Gets a specific app by ID.
    pub async fn get_app(&self, id: &str) -> Result<JsonApiResponse<App>, ApiError> {
        self.get(&format!("/apps/{id}")).await
    }

    // -----------------------------------------------------------------
    // Customer Review endpoints
    // -----------------------------------------------------------------

    /// Lists customer reviews for an app (first page).
    pub async fn list_customer_reviews(
        &self,
        app_id: &str,
    ) -> Result<JsonApiResponse<Vec<CustomerReview>>, ApiError> {
        self.get(&format!("/apps/{app_id}/customerReviews")).await
    }

    /// Lists all customer reviews for an app, following pagination.
    pub async fn list_all_customer_reviews(
        &self,
        app_id: &str,
    ) -> Result<Vec<CustomerReview>, ApiError> {
        self.get_all_pages(&format!("/apps/{app_id}/customerReviews"))
            .await
    }

    // -----------------------------------------------------------------
    // Sales Report endpoints
    // -----------------------------------------------------------------

    /// Downloads and parses a sales report from App Store Connect.
    ///
    /// The API returns gzip-compressed TSV data, which is decompressed
    /// and parsed into structured rows.
    pub async fn get_sales_report(
        &self,
        vendor_number: &str,
        report_type: &str,
        report_sub_type: &str,
        frequency: &str,
        report_date: &str,
    ) -> Result<Vec<SalesReportRow>, ApiError> {
        let query = vec![
            ("filter[vendorNumber]".into(), vendor_number.into()),
            ("filter[reportType]".into(), report_type.into()),
            ("filter[reportSubType]".into(), report_sub_type.into()),
            ("filter[frequency]".into(), frequency.into()),
            ("filter[reportDate]".into(), report_date.into()),
        ];
        let bytes = self
            .get_raw("/salesReports", &query, "application/a-gzip")
            .await?;
        parse_sales_tsv(&bytes).map_err(|e| ApiError::SalesReport(e.to_string()))
    }
}