Tests pass

package.json

@@ -48,7 +48,7 @@
     "overrides": [
       {
         "files": [
-          "*.ts"
+          "**/*.ts"
         ],
         "rules": {
           "@typescript-eslint/object-curly-spacing": [

source/index.ts

@@ -0,0 +1,150 @@
+/* eslint-disable @typescript-eslint/naming-convention */
+// API documentation:
+// https://developer.chrome.com/docs/webstore/api
+// https://developer.chrome.com/docs/webstore/using-api
+
+import { type JsonObject } from 'type-fest';
+
+const rootURI = 'https://www.googleapis.com';
+export const refreshTokenURI = 'https://www.googleapis.com/oauth2/v4/token';
+const uploadExistingURI = (id: string) =>
+    `${rootURI}/upload/chromewebstore/v1.1/items/${id}`;
+const publishURI = (id: string, target: string) =>
+    `${rootURI}/chromewebstore/v1.1/items/${id}/publish?publishTarget=${target}`;
+const getURI = (id: string, projection: string) =>
+    `${rootURI}/chromewebstore/v1.1/items/${id}?projection=${projection}`;
+
+const requiredFields = ['extensionId', 'clientId', 'refreshToken'] as const;
+
+export type APIClientOptions = {
+    extensionId: string;
+    clientId: string;
+    refreshToken: string;
+    clientSecret: string | undefined;
+};
+
+function throwIfNotOk(request: Response, response: JsonObject) {
+    if (!request.ok) {
+        const error = new Error(request.statusText ?? 'Unknown error');
+        (error as any).response = response;
+        throw error;
+    }
+}
+
+class APIClient {
+    extensionId: string;
+    clientId: string;
+    refreshToken: string;
+    clientSecret: string | undefined;
+
+    constructor(options: APIClientOptions) {
+        if (typeof fetch !== 'function') {
+            throw new TypeError('`chrome-webstore-upload` requires Node.js 18.17 or newer because it relies on the global `fetch` function.');
+        }
+
+        if (typeof options !== 'object') {
+            throw new TypeError('The options object is required');
+        }
+
+        for (const field of requiredFields) {
+            if (!options[field]) {
+                throw new Error(`Option "${field}" is required`);
+            }
+        }
+
+        this.extensionId = options.extensionId;
+        this.clientId = options.clientId;
+        this.refreshToken = options.refreshToken;
+        this.clientSecret = options.clientSecret;
+    }
+
+    async uploadExisting(readStream: ReadableStream, token = this.fetchToken()): Promise<JsonObject> {
+        if (!readStream) {
+            throw new Error('Read stream missing');
+        }
+
+        const { extensionId } = this;
+
+        const request = await fetch(uploadExistingURI(extensionId), {
+            method: 'PUT',
+            headers: this._headers(await token),
+            // @ts-expect-error Node extension? 🤷‍♂️ Required
+            duplex: 'half',
+            body: readStream,
+        });
+
+        const response = await request.json() as JsonObject;
+
+        throwIfNotOk(request, response);
+
+        return response;
+    }
+
+    async publish(target = 'default', token = this.fetchToken()): Promise<JsonObject> {
+        const { extensionId } = this;
+
+        const request = await fetch(publishURI(extensionId, target), {
+            method: 'POST',
+            headers: this._headers(await token),
+        });
+
+        const response = await request.json() as JsonObject;
+
+        throwIfNotOk(request, response);
+
+        return response;
+    }
+
+    async get(projection = 'DRAFT', token = this.fetchToken()): Promise<JsonObject> {
+        const { extensionId } = this;
+
+        const request = await fetch(getURI(extensionId, projection), {
+            method: 'GET',
+            headers: this._headers(await token),
+        });
+
+        const response = await request.json() as JsonObject;
+
+        throwIfNotOk(request, response);
+
+        return response;
+    }
+
+    async fetchToken(): Promise<string> {
+        const { clientId, clientSecret, refreshToken } = this;
+        const json = {
+            client_id: clientId,
+            refresh_token: refreshToken,
+            grant_type: 'refresh_token',
+            client_secret: clientSecret,
+        };
+
+        if (!clientSecret) {
+            delete json.client_secret;
+        }
+
+        const request = await fetch(refreshTokenURI, {
+            method: 'POST',
+            body: JSON.stringify(json),
+            headers: {
+                'Content-Type': 'application/json',
+            },
+        });
+
+        const response = await request.json() as JsonObject;
+        throwIfNotOk(request, response);
+
+        return response['access_token'] as string;
+    }
+
+    _headers(token: string): { Authorization: string; 'x-goog-api-version': string } {
+        return {
+            Authorization: `Bearer ${token}`,
+            'x-goog-api-version': '2',
+        };
+    }
+}
+
+export default function chromeWebstoreUpload(options: APIClientOptions) {
+    return new APIClient(options);
+}

test/fetch-token.test.js

@@ -1,6 +1,6 @@
 import { test, assert, beforeEach } from 'vitest';
 import fetchMock from 'fetch-mock';
-import { refreshTokenURI } from '../index.js';
+import { refreshTokenURI } from '../source/index.ts';
 import getClient from './helpers/get-client.js';
 
 beforeEach(context => {

test/helpers/get-client.js

@@ -1,4 +1,4 @@
-import webStoreUpload from '../../index.js';
+import webStoreUpload from '../../source/index.ts';
 
 export default function getClient() {
     return webStoreUpload({

test/live-test.js

@@ -1,6 +1,6 @@
 import fs from 'node:fs';
 import process from 'node:process';
-import chromeWebstoreUpload from '../index.js';
+import chromeWebstoreUpload from '../source/index.js';
 
 const myZipFile = fs.createReadStream('./web-ext-artifacts/live-test.zip');
 

tsconfig.json

@@ -4,6 +4,6 @@
     "outDir": ".",
   },
   "files": [
-    "index.ts"
+    "source/index.ts"
   ]
 }