fix: fix publish error situation

1. local tag existing
2. remote tag existing
3. package version existing
4. stop publish while error happen

Author: 雅影

src/built-in-plugins/command-publish/plugin/run-publish.ts

@@ -217,54 +217,48 @@ async function publishPackageAndItsMonoPackage(
     });
   }
 
-  // async publish queue & add tag and push
-  const publishQueue = depMonoPackages.map(item => {
-    return new Promise(async resolve => {
-      await buildComponent(item);
-
-      if (options.bundle) {
-        await commandBundle({ skipLint: true });
-      }
-
-      await moveSourceFilesToTempFolderAndPublish(
-        item.name,
-        options,
-        item.config,
-        item.rootPath,
-        depMap,
-        isDevelopBranch,
-      );
-
-      await addTagAndPush(generateTag(item.name, item.packageJson), item.packageJson);
-      resolve();
+  try {
+    const publishQueue = [];
+    // async publish & add tag and push
+    depMonoPackages.map(item => {
+      publishQueue.push(buildComponentAndPublish(item, options, depMap, isDevelopBranch));
     });
-  });
 
-  // push current package into publishQueue
-  publishQueue.push(
-    new Promise(async resolve => {
-      await buildComponent(targetPackageInfo);
+    // publish current package
+    publishQueue.push(buildComponentAndPublish(targetPackageInfo, options, depMap, isDevelopBranch));
 
-      if (options.bundle) {
-        await commandBundle({ skipLint: true });
-      }
-
-      await moveSourceFilesToTempFolderAndPublish(
-        sourceType,
-        options,
-        targetConfig,
-        targetRoot,
-        depMap,
-        isDevelopBranch,
-      );
+    return Promise.all(publishQueue);
+  } catch (e) {
+    logInfo(`publish error ${e} stop publish`);
+    await fs.remove(path.join(pri.projectRootPath, tempPath.dir, declarationPath.dir));
+    await exec(`git push origin ${currentBranchName}`);
+    return process.exit(0);
+  }
+}
 
-      await addTagAndPush(generateTag(sourceType, targetPackageJson), targetPackageJson);
+async function buildComponentAndPublish(
+  packageInfo: PackageInfo,
+  options: PublishOption,
+  depMap: DepMap,
+  isDevelopBranch: boolean,
+) {
+  return new Promise(async resolve => {
+    await buildComponent(packageInfo);
 
-      resolve();
-    }),
-  );
+    if (options.bundle) {
+      await commandBundle({ skipLint: true });
+    }
 
-  await spinner(`Publish`, async () => {
-    await Promise.all(publishQueue);
+    await moveSourceFilesToTempFolderAndPublish(
+      packageInfo.name,
+      options,
+      packageInfo.config,
+      packageInfo.rootPath,
+      depMap,
+      isDevelopBranch,
+    );
+
+    await addTagAndPush(generateTag(packageInfo.name, packageInfo.packageJson), packageInfo.packageJson);
+    resolve();
   });
 }

src/built-in-plugins/command-publish/plugin/utils.ts

@@ -61,12 +61,9 @@ export async function checkEnvBeforePublish(targetPackageJson: Partial<PackageJs
 }
 
 export async function addTagAndPush(tagName: string, targetPackageJson: Partial<PackageJson>) {
-  await spinner(`Add tag`, async () => {
-    await exec(`git tag -a ${tagName} -m "release"`);
-  });
-
-  await spinner(`Push tag`, async () => {
-    await exec(`git push origin ${tagName}`);
+  await spinner(`Add and push tag`, async () => {
+    await exec(`git tag -a ${tagName} -m "release" -f`);
+    await exec(`git push origin ${tagName} -f`);
   });
 
   logText(`+ ${targetPackageJson.name}@${targetPackageJson.version}`);
@@ -115,6 +112,15 @@ export async function generateVersion(
         'prerelease',
         currentBranchName.replace(/\//g, '').replace(/\./g, ''),
       );
+      let checkBetaVersionResult;
+      version = targetPackageJson.version;
+      // check the package verion and if it existing auto increase it
+      do {
+        version = (semver.inc as any)(version, 'prerelease', currentBranchName.replace(/\//g, '').replace(/\./g, ''));
+        checkBetaVersionResult = execSync(`${targetConfig.npmClient} view ${targetPackageJson.name}@${version} version`)
+          .toString()
+          .trim();
+      } while (checkBetaVersionResult);
     } else if (versionResult) {
       if (!options.semver) {
         const versionPrompt = await inquirer.prompt([