bug: remove .lock file when abe restart to unlock processes

src/cli/extend/index.js

@@ -1,9 +1,11 @@
 import hooks from './hooks'
 import plugins from './plugins'
 import process from './process'
+import * as lock from './lock'
 
 export {
 	hooks
 	,plugins
 	,process
+	,lock
 }

src/cli/extend/lock.js

@@ -0,0 +1,46 @@
+import process from 'child_process'
+import path from 'path'
+import fs from 'fs'
+
+import {
+  config
+  ,abeExtend
+} from '../'
+
+export function create(name) {
+  let lockFile = path.join(config.root, `abe-process-${name}.lock`)
+  try {
+    var stats = fs.statSync(lockFile)
+    if (stats.isFile()) {
+      console.log(`cannot lock process ${name} already running`)
+      return false
+    }
+  }catch(err) {
+    fs.writeFileSync(lockFile, '', {encoding: 'utf8'})
+  }
+
+  return true
+}
+
+export function remove(name) {
+  let lockFile = path.join(config.root, `abe-process-${name}.lock`)
+  try {
+    var stats = fs.statSync(lockFile)
+    if (stats.isFile()) {
+      fs.unlinkSync(lockFile)
+      return true
+    }
+  }catch(err) {
+
+  }
+  return false
+}
+
+export function deleteAll() {
+  var files = fs.readdirSync(config.root)
+  Array.prototype.forEach.call(files, (file) => {
+    if (file.indexOf('abe-process') > -1 && file.indexOf('.lock') > -1) {
+      fs.unlinkSync(path.join(config.root, file))
+    }
+  })
+}

src/cli/extend/process.js

@@ -18,15 +18,8 @@ var abeProcess = function(name, args = []) {
   args = prepend(`ABE_WEBSITE=${config.root}`, args)
   args = prepend(`ABEJS_PATH=${__dirname}/../../../dist`, args)
 
-  let lockFile = path.join(config.root, `abe-process-${name}.lock`)
-  try {
-    var stats = fse.statSync(lockFile)
-    if (stats.isFile()) {
-      console.log(`cannot start process ${name} already running`)
-      return false
-    }
-  }catch(err) {
-    fs.writeFileSync(lockFile, '', {encoding: 'utf8'})
+  if (!abeExtend.lock.create(name)) {
+    return false
   }
 
   var proc
@@ -50,7 +43,7 @@ var abeProcess = function(name, args = []) {
 
   if(typeof proc !== 'undefined' && proc !== null) {
     proc.on('message', function( msg ) {
-      fs.unlinkSync(lockFile)
+      abeExtend.lock.remove(name)
       proc.kill()
     });
     return true

src/server/app.js

@@ -45,6 +45,8 @@ if(config.port) abePort = config.port
 if(process.env.PORT) abePort = process.env.PORT
 config.set({webport: process.env.WEBPORT ? process.env.WEBPORT : 8081})
 
+abeExtend.lock.deleteAll() // delete all process .lock when abe start
+
 process.env['NODE_TLS_REJECT_UNAUTHORIZED'] = '0'
 
 var html = exphbs.create({