Use npm as source of truth for updated packages (make publish script rerunnable)

Summary:
Updates `find-and-publish-all-bumped-packages` to use the npm registry as the source of truth, similar to tools like Lerna (`lerna publish from-package`). **This enables safe reruns of the publish script**, and replaces the previous Git-diff-detection implementation.

Changelog: [Internal]

Differential Revision: D53607807

Author: huntie

scripts/monorepo/__tests__/find-and-publish-all-bumped-packages-test.js

@@ -16,14 +16,16 @@ const {
 
 const getPackagesMock = jest.fn();
 const execSync = jest.fn();
-const spawnSync = jest.fn();
 const execMock = jest.fn();
+const fetchMock = jest.fn();
 
-jest.mock('child_process', () => ({execSync, spawnSync}));
+jest.mock('child_process', () => ({execSync}));
 jest.mock('shelljs', () => ({exec: execMock}));
 jest.mock('../../releases/utils/monorepo', () => ({
   getPackages: getPackagesMock,
 }));
+// $FlowIgnore[cannot-write]
+global.fetch = fetchMock;
 
 const BUMP_COMMIT_MESSAGE =
   'bumped packages versions\n\n#publish-packages-to-npm';
@@ -76,7 +78,7 @@ describe('findAndPublishAllBumpedPackages', () => {
     `);
   });
 
-  test('should throw an error if updated version is not 0.x.y', async () => {
+  test('should throw an error if updated version is not 0.x.x', async () => {
     execSync.mockImplementation((command: string) => {
       switch (command) {
         case 'git log -1 --pretty=%B':
@@ -93,16 +95,16 @@ describe('findAndPublishAllBumpedPackages', () => {
       },
     });
 
-    spawnSync.mockImplementationOnce(() => ({
-      stdout: `-  "version": "0.72.0"\n+  "version": "${mockedPackageNewVersion}"\n`,
-    }));
+    fetchMock.mockResolvedValueOnce({
+      json: () => Promise.resolve({versions: {}}),
+    });
 
     await expect(findAndPublishAllBumpedPackages()).rejects.toThrow(
-      `Package version expected to be 0.x.y, but received ${mockedPackageNewVersion}`,
+      `Package version expected to be 0.x.x, but received ${mockedPackageNewVersion}`,
     );
   });
 
-  test('should publish all changed packages', async () => {
+  test('should publish all updated packages', async () => {
     execSync.mockImplementation((command: string) => {
       switch (command) {
         case 'git log -1 --pretty=%B':
@@ -111,39 +113,48 @@ describe('findAndPublishAllBumpedPackages', () => {
     });
     getPackagesMock.mockResolvedValue({
       '@react-native/package-a': {
+        name: '@react-native/package-a',
         path: 'absolute/path/to/package-a',
         packageJson: {
           version: '0.72.1',
         },
       },
       '@react-native/package-b': {
+        name: '@react-native/package-b',
         path: 'absolute/path/to/package-b',
         packageJson: {
           version: '0.72.1',
         },
       },
       '@react-native/package-c': {
+        name: '@react-native/package-c',
         path: 'absolute/path/to/package-c',
         packageJson: {
           version: '0.72.0',
         },
       },
     });
-
-    spawnSync.mockImplementationOnce(() => ({
-      stdout: `-  "version": "0.72.0"\n+  "version": "0.72.1"\n`,
-    }));
-    spawnSync.mockImplementationOnce(() => ({
-      stdout: `-  "version": "0.72.0"\n+  "version": "0.72.1"\n`,
-    }));
-    spawnSync.mockImplementationOnce(() => ({
-      stdout: '\n',
-    }));
-
+    fetchMock.mockResolvedValue({
+      json: () =>
+        Promise.resolve({
+          versions: {'0.72.0': {}},
+        }),
+    });
     execMock.mockImplementation(() => ({code: 0}));
 
+    const consoleLog = jest.spyOn(console, 'log').mockImplementation(() => {});
+
     await findAndPublishAllBumpedPackages();
 
+    expect(consoleLog.mock.calls.flat().join('\n')).toMatchInlineSnapshot(`
+      "Discovering updated packages
+      - Skipping @react-native/package-c (0.72.0 already present on npm)
+      Done ✅
+      Publishing updated packages to npm
+      - Publishing @react-native/package-a (0.72.1)
+      - Publishing @react-native/package-b (0.72.1)
+      Done ✅"
+    `);
     expect(execMock.mock.calls).toMatchInlineSnapshot(`
       Array [
         Array [

scripts/monorepo/find-and-publish-all-bumped-packages.js

@@ -12,10 +12,8 @@
 const {publishPackage} = require('../npm-utils');
 const {getPackages} = require('../releases/utils/monorepo');
 const {PUBLISH_PACKAGES_TAG} = require('./constants');
-const {execSync, spawnSync} = require('child_process');
-const path = require('path');
+const {execSync} = require('child_process');
 
-const ROOT_LOCATION = path.join(__dirname, '..', '..');
 const NPM_CONFIG_OTP = process.env.NPM_CONFIG_OTP;
 
 async function findAndPublishAllBumpedPackages() {
@@ -36,76 +34,66 @@ async function findAndPublishAllBumpedPackages() {
     return;
   }
 
-  const tags = getTagsFromCommitMessage(commitMessage);
-
-  console.log('Traversing all packages inside /packages...');
+  console.log('Discovering updated packages');
 
   const packages = await getPackages({
     includeReactNative: false,
   });
+  const packagesToUpdate = [];
 
-  for (const package of Object.values(packages)) {
-    const {stdout: diff, stderr: commitDiffStderr} = spawnSync(
-      'git',
-      [
-        'log',
-        '-p',
-        '--format=""',
-        'HEAD~1..HEAD',
-        `${package.path}/package.json`,
-      ],
-      {cwd: ROOT_LOCATION, shell: true, stdio: 'pipe', encoding: 'utf-8'},
-    );
+  await Promise.all(
+    Object.values(packages).map(async package => {
+      const version = package.packageJson.version;
 
-    if (commitDiffStderr) {
-      console.log(
-        `\u274c Failed to get latest committed changes for ${package.name}:`,
-      );
-      console.log(commitDiffStderr);
+      if (!version.startsWith('0.')) {
+        throw new Error(
+          `Package version expected to be 0.x.x, but received ${version}`,
+        );
+      }
 
-      process.exit(1);
-    }
+      const response = await fetch(
+        'https://registry.npmjs.org/' + package.name,
+      );
+      const {versions: versionsInRegistry} = await response.json();
 
-    const previousVersionPatternMatches = diff
-      .toString()
-      .match(/- {2}"version": "([0-9]+.[0-9]+.[0-9]+)"/);
+      if (version in versionsInRegistry) {
+        console.log(
+          `- Skipping ${package.name} (${version} already present on npm)`,
+        );
+        return;
+      }
 
-    if (!previousVersionPatternMatches) {
-      console.log(`\uD83D\uDD0E No version bump for ${package.name}`);
+      packagesToUpdate.push(package.name);
+    }),
+  );
 
-      return;
-    }
+  console.log('Done ✅');
+  console.log('Publishing updated packages to npm');
 
-    const [, previousVersion] = previousVersionPatternMatches;
-    const nextVersion = package.packageJson.version;
+  const tags = getTagsFromCommitMessage(commitMessage);
 
+  for (const packageName of packagesToUpdate) {
+    const package = packages[packageName];
     console.log(
-      `\uD83D\uDCA1 ${package.name} was updated: ${previousVersion} -> ${nextVersion}`,
+      `- Publishing ${package.name} (${package.packageJson.version})`,
     );
 
-    if (!nextVersion.startsWith('0.')) {
-      throw new Error(
-        `Package version expected to be 0.x.y, but received ${nextVersion}`,
-      );
-    }
-
     const result = publishPackage(package.path, {
       tags,
       otp: NPM_CONFIG_OTP,
     });
-    if (result.code !== 0) {
-      console.log(
-        `\u274c Failed to publish version ${nextVersion} of ${package.name}. npm publish exited with code ${result.code}:`,
-      );
-      console.log(result.stderr);
 
-      process.exit(1);
-    } else {
-      console.log(
-        `\u2705 Successfully published new version of ${package.name}`,
+    if (result.code !== 0) {
+      console.error(
+        `Failed to publish ${package.name}. npm publish exited with code ${result.code}:`,
       );
+      console.error(result.stderr);
+      process.exitCode = 1;
+      return;
     }
   }
+
+  console.log('Done ✅');
 }
 
 function getTagsFromCommitMessage(msg /*: string */) /*: Array<string> */ {