fix: messages sync is not threadsafe (#784)

electron/handlers/fs.ts

@@ -60,15 +60,11 @@ export function handleFsIPCs() {
   ipcMain.handle(
     'writeFile',
     async (event, path: string, data: string): Promise<void> => {
-      return new Promise((resolve, reject) => {
+      try {
-        fs.writeFile(join(userSpacePath, path), data, 'utf8', (err) => {
+        await fs.writeFileSync(join(userSpacePath, path), data, 'utf8')
-          if (err) {
+      } catch (err) {
-            reject(err)
+        console.error(`writeFile ${path} result: ${err}`)
-          } else {
-            resolve()
       }
-        })
-      })
     }
   )
 
@@ -79,16 +75,12 @@ export function handleFsIPCs() {
    * @returns A promise that resolves when the directory has been created.
    */
   ipcMain.handle('mkdir', async (event, path: string): Promise<void> => {
-    return new Promise((resolve, reject) => {
+    try {
-      fs.mkdir(join(userSpacePath, path), { recursive: true }, (err) => {
+      fs.mkdirSync(join(userSpacePath, path), { recursive: true })
-        if (err) {
+    } catch (err) {
-          reject(err)
+      console.error(`mkdir ${path} result: ${err}`)
-        } else {
-          resolve()
     }
   })
-    })
-  })
 
   /**
    * Removes a directory in the user data directory.
@@ -97,16 +89,12 @@ export function handleFsIPCs() {
    * @returns A promise that resolves when the directory is removed successfully.
    */
   ipcMain.handle('rmdir', async (event, path: string): Promise<void> => {
-    return new Promise((resolve, reject) => {
+    try {
-      fs.rm(join(userSpacePath, path), { recursive: true }, (err) => {
+      await fs.rmSync(join(userSpacePath, path), { recursive: true })
-        if (err) {
+    } catch (err) {
-          reject(err)
+      console.error(`rmdir ${path} result: ${err}`)
-        } else {
-          resolve()
     }
   })
-    })
-  })
 
   /**
    * Lists the files in a directory in the user data directory.
@@ -136,23 +124,11 @@ export function handleFsIPCs() {
    * @returns A string indicating the result of the operation.
    */
   ipcMain.handle('deleteFile', async (_event, filePath) => {
-    const fullPath = join(userSpacePath, filePath)
+    try {
-
+      await fs.unlinkSync(join(userSpacePath, filePath))
-    let result = 'NULL'
+    } catch (err) {
-    fs.unlink(fullPath, function (err) {
+      console.error(`unlink ${filePath} result: ${err}`)
-      if (err && err.code == 'ENOENT') {
-        result = `File not exist: ${err}`
-      } else if (err) {
-        result = `File delete error: ${err}`
-      } else {
-        result = 'File deleted successfully'
     }
-      console.debug(
-        `Delete file ${filePath} from ${fullPath} result: ${result}`
-      )
-    })
-
-    return result
   })
 
   /**
@@ -163,17 +139,19 @@ export function handleFsIPCs() {
    * @returns A promise that resolves when the file has been written.
    */
   ipcMain.handle('appendFile', async (_event, path: string, data: string) => {
-    return new Promise((resolve, reject) => {
+    try {
-      fs.appendFile(join(userSpacePath, path), data, 'utf8', (err) => {
+      await fs.appendFileSync(join(userSpacePath, path), data, 'utf8')
-        if (err) {
+    } catch (err) {
-          reject(err)
+      console.error(`appendFile ${path} result: ${err}`)
-        } else {
-          resolve(data)
     }
   })
-    })
-  })
 
+  /**
+   * Reads a file line by line.
+   * @param event - The event object.
+   * @param path - The path of the file to read.
+   * @returns A promise that resolves with the contents of the file.
+   */
   ipcMain.handle('readLineByLine', async (_event, path: string) => {
     const fullPath = join(userSpacePath, path)
 

electron/package.json

@@ -13,8 +13,7 @@
       "renderer/**/*",
       "build/*.{js,map}",
       "build/**/*.{js,map}",
-      "core/pre-install",
+      "core/pre-install"
-      "core/plugin-manager/facade"
     ],
     "asarUnpack": [
       "core/pre-install"

web/services/coreService.ts

@@ -1,4 +1,4 @@
-import * as cn from './cloudNativeService'
+import * as restAPI from './cloudNativeService'
 import { EventEmitter } from './eventsService'
 export const setupCoreServices = () => {
   if (typeof window === 'undefined') {
@@ -13,11 +13,7 @@ export const setupCoreServices = () => {
     }
     window.coreAPI = {}
     window.coreAPI = window.electronAPI ?? {
-      invokePluginFunc: cn.invokePluginFunc,
+      ...restAPI,
-      downloadFile: cn.downloadFile,
-      deleteFile: cn.deleteFile,
-      appVersion: cn.appVersion,
-      openExternalUrl: cn.openExternalUrl,
     }
   }
 }