import { exec } from 'child_process'; import { remove, pathExists, readJSON } from 'fs-extra'; import chalk from 'chalk'; import path from 'path'; import program from 'commander'; import { runServer, parseConfigFile } from 'verdaccio'; import pLimit from 'p-limit'; import type { Server } from 'http'; // @ts-expect-error (Converted from ts-ignore) import { maxConcurrentTasks } from './utils/concurrency'; import { listOfPackages } from './utils/list-packages'; program .option('-O, --open', 'keep process open') .option('-P, --publish', 'should publish packages'); program.parse(process.argv); const logger = console; const startVerdaccio = async () => { let resolved = false; return Promise.race([ new Promise((resolve) => { const cache = path.join(__dirname, '..', '.verdaccio-cache'); const config = { ...parseConfigFile(path.join(__dirname, 'verdaccio.yaml')), self_path: cache, }; runServer(config).then((app: Server) => { app.listen(6001, () => { resolved = true; resolve(app); }); }); }), new Promise((_, rej) => { setTimeout(() => { if (!resolved) { resolved = true; rej(new Error(`TIMEOUT - verdaccio didn't start within 10s`)); } }, 10000); }), ]) as Promise; }; const currentVersion = async () => { const { version } = await readJSON(path.join(__dirname, '..', 'code', 'package.json')); return version; }; const publish = (packages: { name: string; location: string }[], url: string) => { logger.log(`Publishing packages with a concurrency of ${maxConcurrentTasks}`); const limit = pLimit(maxConcurrentTasks); let i = 0; return Promise.all( packages.map(({ name, location }) => limit( () => new Promise((res, rej) => { logger.log( `🛫 publishing ${name} (${location.replace( path.resolve(path.join(__dirname, '..')), '.' )})` ); const command = `cd ${location} && npm publish --registry ${url} --force --access restricted --ignore-scripts`; exec(command, (e) => { if (e) { rej(e); } else { i += 1; logger.log(`${i}/${packages.length} 🛬 successful publish of ${name}!`); res(undefined); } }); }) ) ) ); }; const addUser = (url: string) => new Promise((res, rej) => { logger.log(`👤 add temp user to verdaccio`); exec(`npx npm-cli-adduser -r "${url}" -a -u user -p password -e user@example.com`, (e) => { if (e) { rej(e); } else { res(); } }); }); const run = async () => { const verdaccioUrl = `http://localhost:6001`; logger.log(`📐 reading version of storybook`); logger.log(`🚛 listing storybook packages`); if (!process.env.CI) { // when running e2e locally, clear cache to avoid EPUBLISHCONFLICT errors const verdaccioCache = path.resolve(__dirname, '..', '.verdaccio-cache'); if (await pathExists(verdaccioCache)) { logger.log(`🗑 cleaning up cache`); await remove(verdaccioCache); } } logger.log(`🎬 starting verdaccio (this takes ±5 seconds, so be patient)`); const [verdaccioServer, packages, version] = await Promise.all([ startVerdaccio(), listOfPackages(), currentVersion(), ]); logger.log(`🌿 verdaccio running on ${verdaccioUrl}`); // in some environments you need to add a dummy user. always try to add & catch on failure try { await addUser(verdaccioUrl); } catch (e) { // } logger.log(`📦 found ${packages.length} storybook packages at version ${chalk.blue(version)}`); if (program.publish) { await publish(packages, verdaccioUrl); } if (!program.open) { verdaccioServer.close(); } }; run().catch((e) => { logger.error(e); process.exit(1); });