C#からApp Store Connect APIを叩いて売上レポートを取得する

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
57using System.Net.Http.Headers;
using System.Security.Cryptography;
using System.Text;
using System.Web;
using JWT;
using JWT.Algorithms;
using JWT.Serializers;

// https://developer.apple.com/documentation/appstoreconnectapi/creating_api_keys_for_app_store_connect_api
var p8FilePath = "~~~~~~~.p8";
var issuerId = "~~~~~~~";
var keyId = "~~~~~~~";
var vendorNumber = "~~~~~~~~";

var privateKeyString = string.Join("", File.ReadAllLines(p8FilePath, Encoding.UTF8).Skip(1).Take(4));
var key = ECDsa.Create();
key.ImportPkcs8PrivateKey(Convert.FromBase64String(privateKeyString), out _);
var utcNow = DateTimeOffset.UtcNow;

// https://developer.apple.com/documentation/appstoreconnectapi/generating_tokens_for_api_requests
var headers = new Dictionary<string, object>
{
    { "kid", keyId },
    { "typ", "JWT" },
};

var payload = new Dictionary<string, object>
{
    { "aud", "appstoreconnect-v1" },
    { "iat", utcNow.ToUnixTimeSeconds() },
    { "exp", utcNow.AddMinutes(10).ToUnixTimeSeconds() },
    { "iss", issuerId },
};

var algorithm = new ES256Algorithm(ECDsa.Create(), key);
var serializer = new JsonNetSerializer();
var urlEncoder = new JwtBase64UrlEncoder();
var encoder = new JwtEncoder(algorithm, serializer, urlEncoder);
var token = encoder.Encode(headers, payload, "");

var client = new HttpClient();
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);
client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/a-gzip"));

var builder = new UriBuilder($"https://api.appstoreconnect.apple.com/v1/salesReports");
var query = HttpUtility.ParseQueryString(builder.Query);
query[HttpUtility.UrlEncode("filter[version]")] = "1_0";
query[HttpUtility.UrlEncode("filter[frequency]")] = "DAILY";
query[HttpUtility.UrlEncode("filter[reportDate]")] = "2022-10-01";
query[HttpUtility.UrlEncode("filter[reportSubType]")] = "SUMMARY";
query[HttpUtility.UrlEncode("filter[reportType]")] = "SALES";
query[HttpUtility.UrlEncode("filter[vendorNumber]")] = vendorNumber;
builder.Query = query.ToString();

var result = await client.GetAsync(builder.ToString());
var bytes = await result.Content.ReadAsByteArrayAsync();
await File.WriteAllBytesAsync("a.gzip", bytes);

1
2
3
4
5
6
7
8private static string Decompress(byte[] compressed)
{
    using var from = new MemoryStream(compressed);
    using var to = new MemoryStream();
    using var gZipStream = new GZipStream(from, CompressionMode.Decompress);
    gZipStream.CopyTo(to);
    return Encoding.UTF8.GetString(to.ToArray());
}