CRT
b4d924b132
A live run where only the token exchange, edit insert / delete and Reporting :query were let through: - health / validate: errorIssues:search answered 400 "Unsupported timezone" for America/Los_Angeles (it takes hour-aligned UTC only); the failure dropped the crash and ANR rates and the reason was cut off in the query string. Issues are asked in UTC; a failing issues search is a vitals-issues warning; Reporting errors leave out the query. - play listing --dry / play images --dry wrote into the edit (PUT details and listings, image clears and uploads, :validate) before discarding it. Now one throwaway edit is read (details, listings, image sha256) and compared with the local copy, then deleted. - play.read(): one helper for read-only edits (status, next-version-code), always deleted, warns if the delete fails; next-version-code counts distinct codes. - tests on sanitized recorded answers (tests/play-post-reads.test.ts)
33 lines
1.9 KiB
TypeScript
33 lines
1.9 KiB
TypeScript
// Small client for the other Google APIs storebound reads with the same Play service account: the Play Developer
|
|
// Reporting API (vitals) and Cloud Storage (Play statistics exports). Read-only callers; retries 429 / 5xx.
|
|
import { playServiceAccount } from '../lib/credentials';
|
|
import { tokenSource } from '../lib/google-auth';
|
|
import { errorBody } from '../lib/http';
|
|
|
|
export const REPORTING_API = 'https://playdeveloperreporting.googleapis.com/v1beta1';
|
|
|
|
export function googleClient(root: string, scope: string) {
|
|
const token = tokenSource(playServiceAccount(root), scope);
|
|
async function send(method: string, url: string, body?: unknown): Promise<Response> {
|
|
for (let attempt = 0; ; attempt++) {
|
|
const r = await fetch(url, { method, headers: { Authorization: 'Bearer ' + (await token()), ...(body === undefined ? {} : { 'Content-Type': 'application/json' }) },
|
|
body: body === undefined ? undefined : JSON.stringify(body) });
|
|
if ((r.status === 429 || r.status >= 500) && attempt < 4) { await r.body?.cancel(); await Bun.sleep(2000 * (attempt + 1)); continue; }
|
|
return r;
|
|
}
|
|
}
|
|
return {
|
|
async json<T = unknown>(method: string, url: string, body?: unknown): Promise<T> {
|
|
const r = await send(method, url, body);
|
|
const t = await r.text();
|
|
// path without the query: a long query string (errorIssues:search) pushed the API's reason out of tables
|
|
if (!r.ok) throw new Error(`${method} ${url.replace(/^https:\/\/[^/]+/, '').replace(/\?.*$/, '')} -> ${r.status} ${errorBody(t, 800)}`);
|
|
return (t ? JSON.parse(t) : {}) as T;
|
|
},
|
|
async bytes(url: string): Promise<Uint8Array> {
|
|
const r = await send('GET', url);
|
|
if (!r.ok) throw new Error(`GET ${url.replace(/^https:\/\/[^/]+/, '').replace(/\?.*$/, '')} -> ${r.status} ${errorBody(await r.text(), 300)}`);
|
|
return new Uint8Array(await r.arrayBuffer());
|
|
},
|
|
};
|
|
}
|