feature/add-detecting-and-handling-zcashd-unresponsive-state (#146)

* feature/add-detecting-and-handling-zcashd-unresponsive-state

* remove leftover

* check rescanning status

* add missed dependencies

* change check order

Co-authored-by: jk <Janusz Kornaga>

Author: jkdev601

package-lock.json

@@ -197,6 +197,7 @@
     "material-ui-formik-components": "^0.5.2",
     "notistack": "^0.8.2",
     "prop-types": "^15.7.1",
+    "ps-node": "^0.1.6",
     "qrcode.react": "^0.9.3",
     "ramda": "^0.26.1",
     "react": "^16.9.0",
@@ -220,9 +221,9 @@
     "request": "^2.88.0",
     "request-progress": "^3.0.0",
     "reselect": "^4.0.0",
+    "sanitize-html": "^1.27.0",
     "touch": "^3.1.0",
     "typeface-roboto": "0.0.54",
-    "yup": "^0.27.0",
-    "sanitize-html": "^1.27.0"
+    "yup": "^0.27.0"
   }
 }

package.json

@@ -21,13 +21,18 @@ import convert from 'convert-seconds'
 import R from 'ramda'
 import findInFiles from 'find-in-files'
 import readLastLines from 'read-last-lines'
+import find from 'find-process'
+import ps from 'ps-node'
+import util from 'util'
 
 import { createRpcCredentials } from '../renderer/zcash'
 import config from './config'
 import { spawnZcashNode } from './zcash/bootstrap'
 import electronStore from '../shared/electronStore'
 import recoveryHandlers from './zcash/recover'
 
+const _killProcess = util.promisify(ps.kill)
+
 const osPathsBlockchainCustom = {
   darwin: `${process.env.HOME ||
     process.env.USERPROFILE}/Library/Application Support/ZbayData/`,
@@ -443,9 +448,56 @@ const fetchBlockchain = async (win, torUrl) => {
 
 let powerSleepId
 
+const killZcashdProcess = async () => {
+  const zcashProcess = await find('name', 'zcashd')
+  if (zcashProcess.length > 0) {
+    const [ processDetails ] = zcashProcess
+    const { pid } = processDetails
+    await _killProcess(pid)
+  }
+}
+
+const checkZcashdStatus = async () => {
+  const isBlockchainRescanned = electronStore.get('AppStatus.blockchain.isRescanned')
+  if (mainWindow && isBlockchainRescanned && !isDev) {
+    const zcashProcess = await find('name', 'zcashd')
+    if (zcashProcess.length > 0) {
+      mainWindow.webContents.send('checkNodeStatus', {
+        status: 'up'
+      })
+    } else {
+      mainWindow.webContents.send('checkNodeStatus', {
+        status: 'down'
+      })
+    }
+  }
+  setTimeout(checkZcashdStatus, 1200000)
+}
+
+setTimeout(() => {
+  const isBlockchainRescanned = electronStore.get('AppStatus.blockchain.isRescanned')
+  if (isBlockchainRescanned && !isDev) {
+    checkZcashdStatus()
+  }
+}, 1200000)
+
+ipcMain.on('restart-node-proc', async (event, arg) => {
+  await killZcashdProcess()
+  spawnZcashNode(process.platform, isTestnet)
+})
+
 const createZcashNode = async (win, torUrl) => {
+  const updateStatus = electronStore.get('updateStatus')
+  const blockchainConfiguration = electronStore.get('blockchainConfiguration')
+  if (updateStatus !== config.UPDATE_STATUSES.NO_UPDATE || (blockchainConfiguration === config.BLOCKCHAIN_STATUSES.WAITING_FOR_USER_DECISION && isFetchedFromExternalSource)) {
+    setTimeout(() => {
+      createZcashNode(win, torUrl)
+    }, 5000)
+    return
+  }
   const isBlockchainRescanned = electronStore.get('AppStatus.blockchain.isRescanned')
   if (isBlockchainRescanned && !isDev) {
+    await killZcashdProcess()
     setTimeout(() => {
       recoveryHandlers.checkIfProcessIsRunning((status) => {
         if (!status) {
@@ -456,14 +508,6 @@ const createZcashNode = async (win, torUrl) => {
       })
     }, 180000)
   }
-  const updateStatus = electronStore.get('updateStatus')
-  const blockchainConfiguration = electronStore.get('blockchainConfiguration')
-  if (updateStatus !== config.UPDATE_STATUSES.NO_UPDATE || (blockchainConfiguration === config.BLOCKCHAIN_STATUSES.WAITING_FOR_USER_DECISION && isFetchedFromExternalSource)) {
-    setTimeout(() => {
-      createZcashNode(win, torUrl)
-    }, 5000)
-    return
-  }
   let AppStatus = electronStore.get('AppStatus')
   const vaultStatus = electronStore.get('vaultStatus')
   if (!isDev && (!isFetchedFromExternalSource || blockchainConfiguration === config.BLOCKCHAIN_STATUSES.TO_FETCH)) {

src/main/main.js

@@ -108,6 +108,10 @@ ipcRenderer.on('load-logs-to-store', (event, { transactions, debug, applicationL
   store.dispatch(logsHandlers.actions.setApplicationLogs(applicationLogs))
 })
 
+ipcRenderer.on('checkNodeStatus', (event, { status }) => {
+  store.dispatch(nodeHandlers.epics.checkNodeStatus(status))
+})
+
 ipcRenderer.on('newChannel', (event, { channelParams }) => {
   if (nodeSelectors.status(store.getState()) === 'healthy') {
     store.dispatch(

src/renderer/index.js

@@ -6,6 +6,7 @@ import { createAction, handleActions } from 'redux-actions'
 import { typeRejected, LoaderState, FetchingState } from './utils'
 import { getClient } from '../../zcash'
 import { actionTypes } from '../../../shared/static'
+import nodeSelectors from '../selectors/node'
 
 const DEFAULT_ADDRESS_TYPE = 'sapling'
 
@@ -81,6 +82,13 @@ export const disablePowerSaveMode = () => async (dispatch, getState) => {
   ipcRenderer.send('disable-sleep-prevention')
 }
 
+export const checkNodeStatus = (nodeProcessStatus) => async (dispatch, getState) => {
+  const nodeResponseStatus = nodeSelectors.status(getState())
+  if (nodeProcessStatus === 'up' && nodeResponseStatus === 'down') {
+    ipcRenderer.send('restart-node-proc')
+  }
+}
+
 const getStatus = () => async (dispatch) => {
   try {
     const info = await getClient({ timeout: 200 }).status.info()
@@ -106,7 +114,8 @@ const epics = {
   togglePower,
   startRescanningMonitor,
   disablePowerSaveMode,
-  setRescanningInitialized
+  setRescanningInitialized,
+  checkNodeStatus
 }
 
 export const reducer = handleActions({