|
@@ -19,18 +19,23 @@ let crawlFn = async () => {
|
|
|
}
|
|
|
|
|
|
ipc.on("global:refresh:done", () => {
|
|
|
- let getProcess = spawn("bash", ["get.sh"], {cwd: path.join(__dirname, 'tmp')})
|
|
|
-
|
|
|
- getProcess.stdout.pipe(process.stdout)
|
|
|
- getProcess.stderr.pipe(process.stderr)
|
|
|
-
|
|
|
- getProcess.on('close', (code) => {
|
|
|
- console.log(`child process exited with code ${code}`);
|
|
|
- if(code == 0){
|
|
|
-
|
|
|
- }
|
|
|
- });
|
|
|
- crawlState = 'off'
|
|
|
+ try {
|
|
|
+ let getProcess = spawn("bash", ["get.sh"], {cwd: path.join(__dirname, 'tmp')})
|
|
|
+
|
|
|
+ getProcess.stdout.pipe(process.stdout)
|
|
|
+ getProcess.stderr.pipe(process.stderr)
|
|
|
+
|
|
|
+ getProcess.on('close', (code) => {
|
|
|
+ console.log(`child process exited with code ${code}`);
|
|
|
+ if(code == 0){
|
|
|
+
|
|
|
+ }
|
|
|
+ });
|
|
|
+ } catch (e) {
|
|
|
+ console.error("erron on refresh handle", e)
|
|
|
+ } finally {
|
|
|
+ crawlState = 'off'
|
|
|
+ }
|
|
|
})
|
|
|
|
|
|
let crawlFnSafe = async () => {
|
|
@@ -39,7 +44,7 @@ let crawlFnSafe = async () => {
|
|
|
await crawlFn()
|
|
|
} catch (e) {
|
|
|
console.error("error on job", e)
|
|
|
- }
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
|