|
| 1 | +import { mkdir, mkdtemp, rm, writeFile } from 'node:fs/promises'; |
| 2 | +import { tmpdir } from 'node:os'; |
| 3 | +import { join } from 'node:path'; |
| 4 | + |
| 5 | +import { afterEach, describe, expect, test, vi } from 'vitest'; |
| 6 | + |
| 7 | +import { getPublicPackages, getUnavailablePackages, waitForPackagesOnNpm } from './wait-for-packages-on-npm.mjs'; |
| 8 | + |
| 9 | +const roots = []; |
| 10 | + |
| 11 | +async function createManifest(root, directory, packageJson) { |
| 12 | + const packageDirectory = join(root, directory); |
| 13 | + await mkdir(packageDirectory, { recursive: true }); |
| 14 | + await writeFile(join(packageDirectory, 'package.json'), `${JSON.stringify(packageJson)}\n`); |
| 15 | +} |
| 16 | + |
| 17 | +afterEach(async () => { |
| 18 | + await Promise.all(roots.splice(0).map(root => rm(root, { force: true, recursive: true }))); |
| 19 | +}); |
| 20 | + |
| 21 | +describe('getPublicPackages', () => { |
| 22 | + test('returns sorted public package versions', async () => { |
| 23 | + const root = await mkdtemp(join(tmpdir(), 'npm-availability-')); |
| 24 | + roots.push(root); |
| 25 | + |
| 26 | + await createManifest(root, 'packages/zeta', { name: '@clerk/zeta', version: '2.0.0' }); |
| 27 | + await createManifest(root, 'packages/alpha', { name: '@clerk/alpha', version: '1.0.0' }); |
| 28 | + await createManifest(root, 'packages/private', { name: '@clerk/private', private: true, version: '1.0.0' }); |
| 29 | + |
| 30 | + await expect(getPublicPackages([join(root, 'packages/*/package.json')])).resolves.toEqual([ |
| 31 | + { name: '@clerk/alpha', version: '1.0.0' }, |
| 32 | + { name: '@clerk/zeta', version: '2.0.0' }, |
| 33 | + ]); |
| 34 | + }); |
| 35 | +}); |
| 36 | + |
| 37 | +describe('getUnavailablePackages', () => { |
| 38 | + test('returns failed responses and network errors', async () => { |
| 39 | + const packages = [ |
| 40 | + { name: '@clerk/available', version: '1.0.0' }, |
| 41 | + { name: '@clerk/missing', version: '2.0.0' }, |
| 42 | + { name: '@clerk/error', version: '3.0.0' }, |
| 43 | + ]; |
| 44 | + const fetchPackage = vi.fn(url => { |
| 45 | + if (url.includes('/available/')) { |
| 46 | + return { ok: true, status: 200 }; |
| 47 | + } |
| 48 | + if (url.includes('/missing/')) { |
| 49 | + return { ok: false, status: 404 }; |
| 50 | + } |
| 51 | + throw new Error('network unavailable'); |
| 52 | + }); |
| 53 | + |
| 54 | + await expect(getUnavailablePackages(packages, fetchPackage)).resolves.toEqual([ |
| 55 | + { name: '@clerk/missing', version: '2.0.0', status: 404 }, |
| 56 | + { name: '@clerk/error', version: '3.0.0', error: 'network unavailable' }, |
| 57 | + ]); |
| 58 | + }); |
| 59 | +}); |
| 60 | + |
| 61 | +describe('waitForPackagesOnNpm', () => { |
| 62 | + test('retries only unavailable packages', async () => { |
| 63 | + const packages = [ |
| 64 | + { name: '@clerk/available', version: '1.0.0' }, |
| 65 | + { name: '@clerk/delayed', version: '2.0.0' }, |
| 66 | + ]; |
| 67 | + const attempts = new Map(); |
| 68 | + const fetchPackage = vi.fn(url => { |
| 69 | + const count = (attempts.get(url) ?? 0) + 1; |
| 70 | + attempts.set(url, count); |
| 71 | + return { ok: !url.includes('/delayed/') || count === 2, status: 200 }; |
| 72 | + }); |
| 73 | + const sleep = vi.fn(); |
| 74 | + const log = vi.fn(); |
| 75 | + |
| 76 | + await waitForPackagesOnNpm(packages, { fetchPackage, maxAttempts: 3, delayMs: 1, sleep, log }); |
| 77 | + |
| 78 | + expect(fetchPackage).toHaveBeenCalledTimes(3); |
| 79 | + expect(sleep).toHaveBeenCalledTimes(1); |
| 80 | + expect(sleep).toHaveBeenCalledWith(1); |
| 81 | + expect(log).toHaveBeenLastCalledWith('All 2 public package versions are available on npm.'); |
| 82 | + }); |
| 83 | + |
| 84 | + test('throws after exhausting retries', async () => { |
| 85 | + const packages = [{ name: '@clerk/missing', version: '1.0.0' }]; |
| 86 | + const fetchPackage = vi.fn().mockResolvedValue({ ok: false, status: 404 }); |
| 87 | + const sleep = vi.fn(); |
| 88 | + |
| 89 | + await expect( |
| 90 | + waitForPackagesOnNpm(packages, { fetchPackage, maxAttempts: 2, delayMs: 1, sleep, log: vi.fn() }), |
| 91 | + ).rejects.toThrow('Package versions did not become available on npm after 2 attempts: @clerk/missing@1.0.0'); |
| 92 | + expect(fetchPackage).toHaveBeenCalledTimes(2); |
| 93 | + expect(sleep).toHaveBeenCalledTimes(1); |
| 94 | + expect(sleep).toHaveBeenCalledWith(1); |
| 95 | + }); |
| 96 | +}); |
0 commit comments