Merge branch 'feature/ui' into feature/ui-use-users-own-browser

packages/ui/src/main/flow/CHECK_AND_DOWNLOAD_DEPENDENCIES/index.ts

@@ -3,7 +3,7 @@ import checkAndDownloadPuppeteerExecutable, {
   checkCachedPuppeteerExecutable,
   getExpectCachedPuppeteerExecutablePath
 } from './check-and-download-puppeteer-executable'
-import * as net from 'net'
+import * as fs from 'fs'
 import { pipeWriteRegardlessError } from '../utils/pipe'
 import {
   removeLastUsedAndAvailableBrowserPath,
@@ -42,10 +42,10 @@ export const getAnyAvailablePuppeteerExecutablePath = async (): Promise<string |
 
 export const checkAndDownloadDependenciesForInit = async () => {
   process.on('disconnect', () => app.exit())
-  app.dock.hide()
-  let pipe: null | net.Socket = null
+  app.dock?.hide()
+  let pipe: null | fs.WriteStream = null
   try {
-    pipe = new net.Socket({ fd: 3 })
+    pipe = fs.createWriteStream(null, { fd: 3 })
   } catch {
     console.warn('pipe is not available')
   }
@@ -59,37 +59,65 @@ export const checkAndDownloadDependenciesForInit = async () => {
 
   try {
     let timeoutTimer = 0
-    await new Promise((resolve, reject) => {
-      checkAndDownloadPuppeteerExecutable({
-        downloadProgressCallback(downloadedBytes: number, totalBytes: number) {
-          clearTimeout(timeoutTimer)
-          if (downloadedBytes !== totalBytes) {
-            timeoutTimer = setTimeout(() => {
-              // will encounter this when network disconnected when downloading
-              reject(new Error('PROGRESS_NOT_CHANGED_TOO_LONG'))
-            }, 30 * 1000)
-          }
-          console.log(downloadedBytes / totalBytes)
+    const promiseWithResolver = (() => {
+      const o = {} as unknown as {
+        promise: Promise<unknown>
+        resolve: (result: unknown) => void
+        reject: (reason: unknown) => void
+      }
+      o.promise = new Promise((resolve, reject) => {
+        o.resolve = resolve
+        o.reject = reject
+      })
+      return o
+    })()
+
+    let throttleProgressTimer: number | null = null
+    checkAndDownloadPuppeteerExecutable({
+      downloadProgressCallback(downloadedBytes: number, totalBytes: number) {
+        clearTimeout(timeoutTimer)
+        if (downloadedBytes !== totalBytes) {
+          timeoutTimer = setTimeout(() => {
+            // will encounter this when network disconnected when downloading
+            promiseWithResolver.reject(new Error('PROGRESS_NOT_CHANGED_TOO_LONG'))
+          }, 5 * 1000)
+        } else {
+          clearTimeout(throttleProgressTimer)
+          throttleProgressTimer = null
+        }
+
+        if (!throttleProgressTimer) {
+          // console.log(JSON.stringify({
+          //   type: 'DOWNLOAD_PROGRESS_UPDATE',
+          //   level: 'DEBUG',
+          //   percent: downloadedBytes / totalBytes
+          // }))
+
           pipeWriteRegardlessError(
             pipe,
             JSON.stringify({
               type: 'PUPPETEER_DOWNLOAD_PROGRESS',
               totalBytes,
               downloadedBytes
-            })
-          ) + '\r\n'
+            }) + '\r\n'
+          )
+          throttleProgressTimer = setTimeout(() => {
+            throttleProgressTimer = null
+          }, 2500)
         }
-      }).then(
-        () => {
-          resolve(void 0)
-        },
-        (err) => {
-          reject(err)
-        }
-      )
+      }
     })
+      .then(() => {
+        promiseWithResolver.resolve(void 0)
+      })
+      .catch((err) => {
+        promiseWithResolver.reject(err)
+      })
+
+    await promiseWithResolver.promise
     app.exit(DOWNLOAD_ERROR_EXIT_CODE.NO_ERROR)
   } catch (err) {
+    console.error(err)
     app.exit(DOWNLOAD_ERROR_EXIT_CODE.DOWNLOAD_ERROR)
   }
 }

packages/ui/src/main/flow/GEEK_AUTO_START_CHAT_WITH_BOSS.ts

@@ -2,7 +2,10 @@ import DingtalkPlugin from '@geekgeekrun/dingtalk-plugin/index.mjs'
 import { app } from 'electron'
 import { SyncHook, AsyncSeriesHook } from 'tapable'
 import { readConfigFile } from '@geekgeekrun/geek-auto-start-chat-with-boss/runtime-file-utils.mjs'
-import * as net from 'net'
+import * as fs from 'fs'
+import {
+  checkPuppeteerExecutable,
+} from './CHECK_AND_DOWNLOAD_DEPENDENCIES/check-and-download-puppeteer-executable'
 import { pipeWriteRegardlessError } from './utils/pipe'
 import { getAnyAvailablePuppeteerExecutablePath } from './CHECK_AND_DOWNLOAD_DEPENDENCIES'
 
@@ -23,11 +26,11 @@ export const runAutoChat = async () => {
     closeBrowserWindow()
     app.exit()
   })
-  app.dock.hide()
-  let pipe: null | net.Socket = null
+  app.dock?.hide()
+  let pipe: null | fs.WriteStream = null
   try {
-    pipe = new net.Socket({ fd: 3 })
-  } catch (err) {
+    pipe = fs.createWriteStream(null, { fd: 3 })
+  } catch {
     console.warn('pipe is not available')
   }
   pipeWriteRegardlessError(

packages/ui/src/main/flow/utils/pipe.ts

@@ -1,12 +1,17 @@
-import * as net from 'net'
+import * as fs from 'fs'
 
-export const pipeWriteRegardlessError = (
-  pipe: net.Socket | null,
-  ...writeArgs: Parameters<net.Socket['write']>
+export const pipeWriteRegardlessError = async (
+  pipe: fs.WriteStream | null,
+  chunk: unknown,
+  option?
 ) => {
-  try {
-    pipe?.write(...writeArgs)
-  } catch (error) {
-    console.log('pipe.write Error', error)
-  }
+  return new Promise((resolve) => {
+    // debugger
+    pipe?.write(chunk, option, (error) => {
+      if (error) {
+        console.log('pipe.write Error', error)
+      }
+      resolve(undefined)
+    })
+  })
 }