🔨 refactor(sync): update sync script

Author: Lxxyx

.github/workflows/sync.yml

@@ -0,0 +1,28 @@
+# This workflow will do a clean install of node dependencies, build the source code and run tests across different versions of node
+# For more information see: https://help.github.com/actions/language-and-framework-guides/using-nodejs-with-github-actions
+
+name: cnpm sync
+
+on:
+  schedule:
+    - cron: 0 */6 * * *
+  push:
+    branches: [ master ]
+  pull_request:
+    branches: [ master ]
+
+jobs:
+  sync:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: [14.x]
+    steps:
+    - uses: actions/checkout@v2
+    - name: Use Node.js ${{ matrix.node-version }}
+      uses: actions/setup-node@v1
+      with:
+        node-version: ${{ matrix.node-version }}
+    - run: yarn
+    - run: npm i cnpm -g
+    - run: node scripts/sync cnpm

scripts/sync.js

@@ -1,30 +1,34 @@
 const { execSync } = require('child_process')
 const execa = require('execa')
 const { resolve } = require('path')
+const check = require('./sync_status')
 
 const originData = execSync('npx lerna ls --json').toString()
 const data = JSON.parse(originData)
 const finished = []
 
-async function syncPackage(pkg) {
-  await Promise.all([execa('tnpm', ['sync', pkg]), execa('cnpm', ['sync', pkg])])
+const clients = process.argv.slice(2)
+
+async function syncPackage(pkg, clients) {
+  const tasks = clients.map((client) => execa(client, ['sync', pkg]))
+  await Promise.all(tasks)
+
   finished.push(pkg)
   console.log(`[${finished.length}/${data.length}] ${pkg} sync finished`)
 }
 
-async function sync() {
+async function sync(clients) {
   console.log('\n=== start sync ===\n')
   const packages = data.map((item) => item.name)
 
   console.log(`sync ${packages.length} packages:\n${packages.join('\n')}\n`)
-  const task = packages.map((pkg) => syncPackage(pkg))
+  const task = packages.map((pkg) => syncPackage(pkg, clients))
   await Promise.all(task)
 
   console.log('\n=== check sync status ===\n')
-  await execa('node', [resolve(__dirname, 'sync_status.js')], { stdio: 'inherit' })
+  await check(packages, clients)
 
   console.log('\n=== sync finished ===')
-  process.exit(1)
 }
 
-sync()
+sync(clients)

scripts/sync_status.js

@@ -1,34 +1,23 @@
-const { execSync } = require('child_process')
 const execa = require('execa')
 
-const originData = execSync('npx lerna ls --json').toString()
-const data = JSON.parse(originData)
-
 const failed = []
 const finished = []
 
-async function checkSyncStatus(pkg) {
-  const npmVersion = await execa('npm', ['show', pkg, 'version'])
-  const tnpmVersion = await execa('tnpm', ['show', pkg, 'version'])
-  const cnpmVersion = await execa('cnpm', ['show', pkg, 'version'])
+async function checkSyncStatus(packages, pkg, clients) {
+  const versions = await Promise.all(clients.map((client) => execa(client, ['show', pkg, 'version'])))
 
   finished.push(pkg)
-  console.log(`[${finished.length}/${data.length}] ---->`, pkg)
-  if (npmVersion.stdout !== tnpmVersion.stdout || npmVersion.stdout !== cnpmVersion.stdout) {
-    console.log(`===> npm: ${npmVersion.stdout}, tnpm: ${tnpmVersion.stdout}, cnpm: ${cnpmVersion.stdout}`)
+  console.log(`[${finished.length}/${packages.length}] ---->`, pkg)
+
+  const isSuccess = versions.every((version) => version.stdout === versions[0].stdout)
+
+  if (!isSuccess) {
+    console.log(`===> ${clients.map((client, i) => `${client}: ${versions[i].stdout}`).join(' ')}`)
     failed.push(pkg)
   }
 }
 
-async function start() {
-  const packages = data.filter((item) => item.private === false).map((item) => item.name)
-
-  const task = packages.map((pkg) => checkSyncStatus(pkg))
+module.exports = async function check(packages, clients) {
+  const task = packages.map((pkg) => checkSyncStatus(packages, pkg, ['npm', ...clients]))
   await Promise.all(task)
-
-  if (failed.length) {
-    console.log(`output command => tnpm sync ${failed.join(' ')}`)
-  }
 }
-
-start()