feat: catch and log electron-store.set errors

src/automatic-gc.js

@@ -4,6 +4,7 @@ const store = require('./common/store')
 const { AUTO_GARBAGE_COLLECTOR: CONFIG_KEY } = require('./common/config-keys')
 const { ipcMain } = require('electron')
 const ipcMainEvents = require('./common/ipc-main-events')
+const safeStoreSet = require('./utils/safe-store-set')
 
 const gcFlag = '--enable-gc'
 const isEnabled = flags => flags.some(f => f === gcFlag)
@@ -24,9 +25,14 @@ function disable () {
   }
 }
 
+/**
+ *
+ * @param {string[]} newFlags
+ */
 function applyConfig (newFlags) {
-  store.set('ipfsConfig.flags', newFlags)
-  ipcMain.emit(ipcMainEvents.IPFS_CONFIG_CHANGED) // trigger node restart
+  safeStoreSet('ipfsConfig.flags', newFlags, () => {
+    ipcMain.emit(ipcMainEvents.IPFS_CONFIG_CHANGED) // trigger node restart
+  })
 }
 
 module.exports = async function () {

src/common/config-keys.js

@@ -1,7 +1,6 @@
 /**
  * Configuration key constants for the features in IPFS Desktop.
- *
- * @type {Object.<string, string>}
+ * @constant
  */
 const CONFIG_KEYS = {
   AUTO_LAUNCH: 'autoLaunch',

src/common/logger.js

@@ -57,7 +57,7 @@ logger.info(`[meta] logs can be found on ${logsPath}`)
 
 /**
  *
- * @param {AnalyticsTimeOptions & import('countly-sdk-nodejs').CountlyAddEventOptions}
+ * @param {AnalyticsTimeOptions & Omit<import('countly-sdk-nodejs').CountlyAddEventOptions, 'key'>} opts
  *
  * @returns {void} void
  */
@@ -78,11 +78,11 @@ module.exports = Object.freeze({
   /**
    *
    * @param {string} msg
-   * @param {AnalyticsTimeOptions} opts
+   * @param {AnalyticsTimeOptions & Omit<import('countly-sdk-nodejs').CountlyAddEventOptions, 'key'>} opts
    *
    * @returns {AnalyticsTimeReturnValue} AnalyticsTimeReturnValue
    */
-  start: (msg, opts = {}) => {
+  start: (msg, opts) => {
     const start = performance.now()
     logger.info(`${msg} STARTED`)
 
@@ -106,21 +106,41 @@ module.exports = Object.freeze({
   /**
    *
    * @param {string} msg
-   * @param {AnalyticsTimeOptions & import('countly-sdk-nodejs').CountlyAddEventOptions} opts
+   * @param {AnalyticsTimeOptions & Omit<import('countly-sdk-nodejs').CountlyAddEventOptions, 'key'>} [opts]
    *
    * @returns {void} void
    */
-  info: (msg, opts = {}) => {
-    addAnalyticsEvent({ count: 1, ...opts })
+  info: (msg, opts) => {
+    if (opts) {
+      addAnalyticsEvent({ count: 1, ...opts })
+    }
 
     logger.info(msg)
   },
 
-  error: (err) => {
-    Countly.log_error(err)
-    logger.error(err)
+  /**
+   *
+   * @param {Error|string} errMsg
+   * @param {Error|unknown} [error]
+   */
+  error: (errMsg, error) => {
+    if (errMsg instanceof Error) {
+      Countly.log_error(errMsg)
+      logger.error(errMsg)
+    } else if (error != null && error instanceof Error) {
+      // errorMessage is not an instance of an error, but error is
+      Countly.log_error(error)
+      logger.error(errMsg, error)
+    } else {
+      Countly.log_error(new Error(errMsg))
+      logger.error(errMsg, error)
+    }
   },
 
   logsPath,
-  addAnalyticsEvent
+  addAnalyticsEvent,
+  /**
+   * For when you want to log something without potentially emitting it to countly
+   */
+  fileLogger: logger
 })

src/common/store.js

@@ -1,22 +1,28 @@
-const electron = require('electron')
+const { app } = require('electron')
 const Store = require('electron-store')
 
+const { fileLogger } = require('./logger')
+
+/**
+ * @type {import('./types').DesktopPersistentStore}
+ */
 const defaults = {
   ipfsConfig: {
-    type: 'go',
     path: '',
     flags: [
       '--agent-version-suffix=desktop',
       '--migrate',
       '--enable-gc'
     ]
   },
-  language: (electron.app || electron.remote.app).getLocale(),
-  experiments: {}
+  language: app.getLocale(),
+  experiments: {},
+  binaryPath: ''
 }
 
 const migrations = {
   '>=0.11.0': store => {
+    fileLogger.info('Running migration: >=0.11.0')
     store.delete('version')
 
     const flags = store.get('ipfsConfig.flags', [])
@@ -26,6 +32,7 @@ const migrations = {
     }
   },
   '>0.13.2': store => {
+    fileLogger.info('Running migration: >0.13.2')
     const flags = store.get('ipfsConfig.flags', [])
     const automaticGC = store.get('automaticGC', false)
     // ensure checkbox follows cli flag config
@@ -34,6 +41,7 @@ const migrations = {
     }
   },
   '>=0.17.0': store => {
+    fileLogger.info('Running migration: >=0.17.0')
     let flags = store.get('ipfsConfig.flags', [])
 
     // make sure version suffix is always present and normalized
@@ -53,6 +61,7 @@ const migrations = {
     }
   },
   '>=0.20.6': store => {
+    fileLogger.info('Running migration: >=0.20.6')
     let flags = store.get('ipfsConfig.flags', [])
 
     // use default instead of hard-coded dhtclient

src/common/types.ts

@@ -0,0 +1,12 @@
+export interface DesktopPersistentStore_IpfsdConfig {
+  path: string,
+  flags: string[]
+}
+
+export interface DesktopPersistentStore {
+
+  ipfsConfig: DesktopPersistentStore_IpfsdConfig,
+  language: string,
+  experiments: Record<string, boolean>,
+  binaryPath?: string
+}

src/custom-ipfs-binary.js

@@ -4,6 +4,7 @@ const { showDialog } = require('./dialogs')
 const logger = require('./common/logger')
 const store = require('./common/store')
 const dock = require('./utils/dock')
+const safeStoreSet = require('./utils/safe-store-set')
 
 const SETTINGS_KEY = 'binaryPath'
 
@@ -37,23 +38,23 @@ async function setCustomBinary (ctx) {
       return
     }
 
-    store.set(SETTINGS_KEY, filePaths[0])
+    safeStoreSet(SETTINGS_KEY, filePaths[0], () => {
+      opt = showDialog({
+        showDock: false,
+        title: i18n.t('setCustomIpfsBinarySuccess.title'),
+        message: i18n.t('setCustomIpfsBinarySuccess.message', { path: filePaths[0] }),
+        buttons: [
+          i18n.t('restart'),
+          i18n.t('close')
+        ]
+      })
 
-    opt = showDialog({
-      showDock: false,
-      title: i18n.t('setCustomIpfsBinarySuccess.title'),
-      message: i18n.t('setCustomIpfsBinarySuccess.message', { path: filePaths[0] }),
-      buttons: [
-        i18n.t('restart'),
-        i18n.t('close')
-      ]
-    })
+      logger.info(`[custom binary] updated to ${filePaths[0]}`)
 
-    logger.info(`[custom binary] updated to ${filePaths[0]}`)
-
-    if (opt === 0) {
-      ctx.restartIpfs()
-    }
+      if (opt === 0) {
+        ctx.restartIpfs()
+      }
+    })
   })
 }
 

src/daemon/config.js

@@ -7,6 +7,7 @@ const { shell } = require('electron')
 const store = require('../common/store')
 const logger = require('../common/logger')
 const dialogs = require('./dialogs')
+const safeStoreSet = require('../utils/safe-store-set')
 
 /**
  * Get repository configuration file path.
@@ -234,13 +235,13 @@ function migrateConfig (ipfsd) {
   if (changed) {
     try {
       writeConfigFile(ipfsd, config)
-      store.set(REVISION_KEY, REVISION)
+      safeStoreSet(REVISION_KEY, REVISION)
     } catch (err) {
       logger.error(`[daemon] migrateConfig: error writing config file: ${err.message || err}`)
       return
     }
   }
-  store.set(REVISION_KEY, REVISION)
+  safeStoreSet(REVISION_KEY, REVISION)
 }
 
 /**

src/daemon/index.js

@@ -8,6 +8,7 @@ const { STATUS } = require('./consts')
 const createDaemon = require('./daemon')
 const ipcMainEvents = require('../common/ipc-main-events')
 const { analyticsKeys } = require('../analytics/keys')
+const safeStoreSet = require('../utils/safe-store-set')
 
 async function setupDaemon (ctx) {
   let ipfsd = null
@@ -63,7 +64,7 @@ async function setupDaemon (ctx) {
     // not set.
     if (!config.path || typeof config.path !== 'string') {
       config.path = ipfsd.path
-      store.set('ipfsConfig', config)
+      safeStoreSet('ipfsConfig', config)
     }
 
     log.end()

src/enable-namesys-pubsub.js

@@ -4,6 +4,7 @@ const store = require('./common/store')
 const { EXPERIMENT_PUBSUB_NAMESYS: CONFIG_KEY } = require('./common/config-keys')
 const { ipcMain } = require('electron')
 const ipcMainEvents = require('./common/ipc-main-events')
+const safeStoreSet = require('./utils/safe-store-set')
 
 const namesysPubsubFlag = '--enable-namesys-pubsub'
 const isEnabled = flags => flags.some(f => f === namesysPubsubFlag)
@@ -25,12 +26,13 @@ function disable () {
 }
 
 function applyConfig (newFlags) {
-  store.set('ipfsConfig.flags', newFlags)
-  ipcMain.emit(ipcMainEvents.IPFS_CONFIG_CHANGED) // trigger node restart
+  safeStoreSet('ipfsConfig.flags', newFlags, () => {
+    ipcMain.emit(ipcMainEvents.IPFS_CONFIG_CHANGED) // trigger node restart
+  })
 }
 
 module.exports = async function () {
-  const activate = ({ newValue, oldValue }) => {
+  const activate = ({ newValue, oldValue = null }) => {
     if (newValue === oldValue) return
 
     try {

src/enable-pubsub.js

@@ -4,6 +4,7 @@ const store = require('./common/store')
 const { EXPERIMENT_PUBSUB: CONFIG_KEY } = require('./common/config-keys')
 const { ipcMain } = require('electron')
 const ipcMainEvents = require('./common/ipc-main-events')
+const safeStoreSet = require('./utils/safe-store-set')
 
 const pubsubFlag = '--enable-pubsub-experiment'
 const isEnabled = flags => flags.some(f => f === pubsubFlag)
@@ -25,12 +26,13 @@ function disable () {
 }
 
 function applyConfig (newFlags) {
-  store.set('ipfsConfig.flags', newFlags)
-  ipcMain.emit(ipcMainEvents.IPFS_CONFIG_CHANGED) // trigger node restart
+  safeStoreSet('ipfsConfig.flags', newFlags, () => {
+    ipcMain.emit(ipcMainEvents.IPFS_CONFIG_CHANGED) // trigger node restart
+  })
 }
 
 module.exports = async function () {
-  const activate = ({ newValue, oldValue }) => {
+  const activate = ({ newValue, oldValue = null }) => {
     if (newValue === oldValue) return
 
     try {

src/i18n.js

@@ -5,6 +5,7 @@ const ICU = require('i18next-icu')
 const Backend = require('i18next-fs-backend')
 const store = require('./common/store')
 const ipcMainEvents = require('./common/ipc-main-events')
+const safeStoreSet = require('./utils/safe-store-set')
 
 module.exports = async function () {
   await i18n
@@ -28,7 +29,7 @@ module.exports = async function () {
       return
     }
 
-    store.set('language', lang)
+    safeStoreSet('language', lang)
 
     await i18n.changeLanguage(lang)
     ipcMain.emit(ipcMainEvents.LANG_UPDATED, lang)

src/move-repository-location.js

@@ -6,6 +6,7 @@ const logger = require('./common/logger')
 const { showDialog, recoverableErrorDialog, selectDirectory } = require('./dialogs')
 const dock = require('./utils/dock')
 const { analyticsKeys } = require('./analytics/keys')
+const safeStoreSet = require('./utils/safe-store-set')
 
 module.exports = function ({ stopIpfs, startIpfs }) {
   dock.run(async () => {
@@ -69,23 +70,25 @@ module.exports = function ({ stopIpfs, startIpfs }) {
       await fs.move(currDir, newDir)
       logger.info(`[move repository] moved from ${currDir} to ${newDir}`)
     } catch (err) {
-      logger.error(`[move repository] ${err.toString()}`)
+      logger.error(`[move repository] error moving from '${currDir}' to '${newDir}'`, err)
       return recoverableErrorDialog(err, {
         title: i18n.t('moveRepositoryFailed.title'),
         message: i18n.t('moveRepositoryFailed.message', { currDir, newDir })
       })
     }
 
     config.path = newDir
-    store.set('ipfsConfig', config)
-    logger.info('[move repository] configuration updated', { withAnalytics: analyticsKeys.MOVE_REPOSITORY })
 
-    showDialog({
-      title: i18n.t('moveRepositorySuccessDialog.title'),
-      message: i18n.t('moveRepositorySuccessDialog.message', { location: newDir }),
-      showDock: false
-    })
+    await safeStoreSet('ipfsConfig', config, async () => {
+      logger.info('[move repository] configuration updated', { withAnalytics: analyticsKeys.MOVE_REPOSITORY })
+
+      showDialog({
+        title: i18n.t('moveRepositorySuccessDialog.title'),
+        message: i18n.t('moveRepositorySuccessDialog.message', { location: newDir }),
+        showDock: false
+      })
 
-    await startIpfs()
+      await startIpfs()
+    })
   })
 }

src/tray.js

@@ -16,6 +16,7 @@ const CONFIG_KEYS = require('./common/config-keys')
 const { SHORTCUT: SCREENSHOT_SHORTCUT, takeScreenshot } = require('./take-screenshot')
 const { isSupported: supportsLaunchAtLogin } = require('./auto-launch')
 const createToggler = require('./utils/create-toggler')
+const safeStoreSet = require('./utils/safe-store-set')
 
 function buildCheckbox (key, label) {
   return {
@@ -372,8 +373,7 @@ module.exports = function (ctx) {
   setupMenu()
 
   createToggler(CONFIG_KEYS.MONOCHROME_TRAY_ICON, async ({ newValue }) => {
-    store.set(CONFIG_KEYS.MONOCHROME_TRAY_ICON, newValue)
-    return true
+    return safeStoreSet(CONFIG_KEYS.MONOCHROME_TRAY_ICON, newValue, () => true)
   })
 
   ctx.tray = tray