Function getChanged

packages/publish/src/changed.ts:12–45

(ctx: Context)

// Iterate through all packages in directory and return a list of changed packages
const getChanged = async (ctx: Context) => {
	const changedList: ChangedList = [];
	const queue = new PQueue({ concurrency: 4 });

	const handleHash = async (packagePath: string, packageJson: PackageJson) => {
		// Get hash of current package and compare with old hash
		const hash = await getHash(packagePath);
		if (packageJson.publishHash !== hash || ctx.force) {
			changedList.push({
				name: packageJson.name,
				hash,
				path: packagePath,
				version: packageJson.version,
			});
		}
	};

	for (const packageDir of ctx.packages) {
		const packages = await getPackages(packageDir);
		for (const packageName of packages) {
			const packagePath = path.join(packageDir, packageName);

			// Check if package.json exists
			const packageJson: PackageJson = await fs.readJson(
				path.join(process.cwd(), packagePath, 'package.json'),
			);

			void queue.add(() => handleHash(packagePath, packageJson));
		}
	}

	await queue.onIdle();
	return changedList;
};

const changed = async (options: ChangedFlags) => {
	consola.info(colors.bold(colors.blue('Checking packages...')));