feat(market): support yarn json output (#294)

Co-authored-by: Shigma <[email protected]>

plugins/market/src/node/installer.ts

@@ -32,6 +32,20 @@ export interface Dependency {
   latest?: string
 }
 
+export interface YarnLog {
+  type: 'warning' | 'info' | 'error' | string
+  name: number | null
+  displayName: string
+  indent?: string
+  data: string
+}
+
+const levelMap = {
+  'info': 'info',
+  'warning': 'debug',
+  'error': 'warn',
+}
+
 export interface LocalPackage extends PackageJson {
   private?: boolean
   $workspace?: boolean
@@ -172,22 +186,40 @@ class Installer extends Service {
   }
 
   async exec(command: string, args: string[]) {
+    const useJson = command === 'yarn'
     return new Promise<number>((resolve) => {
+      if (useJson) args.push('--json')
       const child = spawn(command, args, { cwd: this.cwd })
       child.on('exit', (code) => resolve(code))
       child.on('error', () => resolve(-1))
+
+      let stderr = ''
       child.stderr.on('data', (data) => {
-        data = data.toString().trim()
-        if (!data) return
-        for (const line of data.split('\n')) {
+        data = stderr + data.toString()
+        const lines = data.split('\n')
+        stderr = lines.pop()!
+        for (const line of lines) {
           logger.warn(line)
         }
       })
+
+      let stdout = ''
       child.stdout.on('data', (data) => {
-        data = data.toString().trim()
-        if (!data) return
-        for (const line of data.split('\n')) {
-          logger.info(line)
+        data = stdout + data.toString()
+        const lines = data.split('\n')
+        stdout = lines.pop()!
+        for (const line of lines) {
+          if (!useJson) {
+            logger.info(line)
+            continue
+          }
+          try {
+            const { type, data } = JSON.parse(line) as YarnLog
+            logger[levelMap[type] ?? 'info'](data)
+          } catch (error) {
+            logger.warn(line)
+            logger.warn(error)
+          }
         }
       })
     })