发行 1.7版本

fix:callback url request fail error deal

CHANGELOG.md

@@ -1,3 +1,24 @@
+### Release v1.7
+
+2019.01.24  
+
+- 修复 time 内存  
+- 修复 某些情况下cmd异常导致进程挂掉的问题  
+
+
+
+### Release v1.6
+
+2019.01.19  
+
+- 修复 http 通知失败导致进程崩溃  
+- 增加 includeDirs 参数规则验证  
+- 修改 delayMillSecond 默认值,2000  
+- 增加 贡献者 @jason-gao  
+- 优化 log  
+
+
+
 ### Release v1.5
 
 2019.01.03  

README.md

@@ -28,8 +28,8 @@ go version >=1.10，推荐 1.11
 
 ### 下载二进制文件   
 
-Github: [正式版 v1.5](https://github.com/dengsgo/fileboy/releases)  
-Gitee:  [正式版 v1.5](https://gitee.com/dengsgo/fileboy/releases)  
+Github: [正式版 v1.7](https://github.com/dengsgo/fileboy/releases)  
+Gitee:  [正式版 v1.7](https://gitee.com/dengsgo/fileboy/releases)  
 
 下载已经编译好的对应平台二进制文件，重命名为`fileboy`, 加入系统 Path 中即可。 
 
@@ -111,13 +111,13 @@ command:
         - go version
         - go env
 
-    # 文件变更后命令会在xx毫秒后才会执行，单位为毫秒
+    # 文件变更后命令在xx毫秒后才会执行，单位为毫秒
     # 一个变更事件(A)如果在定义的延迟时间(t)内，又有新的文件变更事件(B)，那么A会取消执行。
     # B及以后的事件均依次类推，直到事件Z在t内没有新事件产生，Z 会执行
     # 合理设置延迟时间，将有效减少冗余和重复任务的执行
     # 如果不需要该特性，设置为 0
-    delayMillSecond: 1000
-	
+    delayMillSecond: 2000
+
 # 通知器
 notifier:
     # 文件更改会向该 url 发送请求（POST 一段 json 文本数据）
@@ -125,10 +125,10 @@ notifier:
     # 请求超时 15 秒
     # POST 格式:
     #    Content-Type: application/json;charset=UTF-8
-    #    User-Agent: FileBoy Net Notifier v1.5
+    #    User-Agent: FileBoy Net Notifier v1.7
     #    Body: {"project_folder":"/watcher-dirs","file":"test.go","changed":1546421173070433800,"ext":".go"}
     # 例: http://example.com/notifier/fileboy-listener
-    # 不启用通知，请留空
+    # 不启用通知，请留空 ""
     callUrl: ""
 ```
 
@@ -163,7 +163,7 @@ notifier:
 
 #### idea 下更改文件，为什么会执行两次或者多次 command ?
 
-由于 idea 系列软件特殊的文件保存策略，他会自动创建一些临时文件，并且在需要时多次重写文件，所以有时反映在文件上就是有多次的更改，所以会出现这种情况。1.5版本增加了 `delayMillSecond` 参数，可以解决这个问题。  
+由于 idea 系列软件特殊的文件保存策略，他会自动创建一些临时文件，并且在需要时多次重写文件，所以有时反映在文件上就是有多次的更改，所以会出现这种情况。1.5之后的版本增加了 `delayMillSecond` 参数，可以解决这个问题。  
 
 #### filegirl.yaml 里面的 command 不支持复杂的命令吗？  
 
@@ -191,7 +191,9 @@ fileboy 目前支持 `命令 + 参数`这种形式的 command，而且 参数中
 
 > 排名不分先后
 
-[@dengsgo](https://www.yoytang.com)  <dengsgo@yoytang.com>  
+[@dengsgo](https://www.yoytang.com)  <dengsgo@gmail.com>  
 
 [@itwesley](https://github.com/itwesley)  <wcshen1126@gmail.com>  
 
+[@jason-gao](https://github.com/jason-gao)  <3048789891@qq.com>  
+

fileboy.go

@@ -9,11 +9,15 @@ import (
 	"math/rand"
 	"os"
 	"path"
+	"strings"
 	"time"
 )
 
 const (
 	Version = 1
+
+	PreError = "ERROR:"
+	PreWarn  = "Warn:"
 )
 
 var (
@@ -36,14 +40,14 @@ func parseConfig() {
 	cfg = new(FileGirl)
 	fc, err := ioutil.ReadFile(projectFolder + "/filegirl.yaml")
 	if err != nil {
-		log.Panicln("read filegirl.yaml file err: ", err)
+		log.Panicln(PreError, "read filegirl.yaml file err: ", err)
 	}
 	err = yaml.Unmarshal(fc, cfg)
 	if err != nil {
-		log.Panicln("parsed filegirl.yaml failed: ", err)
+		log.Panicln(PreError, "parsed filegirl.yaml failed: ", err)
 	}
 	if cfg.Core.Version > Version {
-		log.Panicln("current fileboy support max version : ", Version)
+		log.Panicln(PreError, "current fileboy support max version : ", Version)
 	}
 	log.Println(cfg)
 }
@@ -77,7 +81,10 @@ func addWatcher() {
 	for i := 0; i < len(cfg.Monitor.IncludeDirs); i++ {
 		darr := dirParse2Array(cfg.Monitor.IncludeDirs[i])
 		if len(darr) < 1 || len(darr) > 2 {
-			log.Fatalln("filegirl section monitor dirs is error. ", cfg.Monitor.IncludeDirs[i])
+			log.Fatalln(PreError, "filegirl section monitor dirs is error. ", cfg.Monitor.IncludeDirs[i])
+		}
+		if strings.HasPrefix(darr[0], "/") {
+			log.Fatalln(PreError, "dirs must be relative paths ! err path:", cfg.Monitor.IncludeDirs[i])
 		}
 		if darr[0] == "." {
 			if len(darr) == 2 && darr[1] == "*" {
@@ -143,7 +150,7 @@ func initWatcher() {
 				if !ok {
 					return
 				}
-				log.Println("error:", err)
+				log.Println(PreError, err)
 			}
 		}
 	}()
@@ -156,7 +163,7 @@ func parseArgs() {
 	if l == 1 {
 		_, err := ioutil.ReadFile(projectFolder + "/filegirl.yaml")
 		if err != nil {
-			log.Println("the filegirl.yaml file does not exist! ", err)
+			log.Println(PreError, "the filegirl.yaml file does not exist! ", err)
 			fmt.Print(firstRunHelp)
 			return
 		}
@@ -169,7 +176,7 @@ func parseArgs() {
 		case "init":
 			err := ioutil.WriteFile(projectFolder+"/filegirl.yaml", []byte(exampleFileGirl), 0644)
 			if err != nil {
-				log.Println("error create filegirl.yaml config! ", err)
+				log.Println(PreError, "error create filegirl.yaml config! ", err)
 				return
 			}
 			log.Println("create filegirl.yaml ok")

notifer.go

@@ -34,7 +34,7 @@ func newNetNotifier(callUrl string) *NetNotifier {
 
 func (n *NetNotifier) Put(cf *changedFile) {
 	if !n.CanPost {
-		log.Println("notifier call url ignore. ", n.CallUrl)
+		log.Println(PreWarn, "notifier call url ignore. ", n.CallUrl)
 		return
 	}
 	n.dispatch(&postParams{
@@ -48,7 +48,7 @@ func (n *NetNotifier) Put(cf *changedFile) {
 func (n *NetNotifier) dispatch(params *postParams) {
 	b, err := json.Marshal(params)
 	if err != nil {
-		log.Println("error: json.Marshal n.params. ", err)
+		log.Println(PreError, "json.Marshal n.params. ", err)
 		return
 	}
 	client := &http.Client{
@@ -56,13 +56,21 @@ func (n *NetNotifier) dispatch(params *postParams) {
 	}
 	req, err := http.NewRequest("POST", n.CallUrl, bytes.NewBuffer(b))
 	if err != nil {
-		log.Println("error: http.NewRequest. ", err)
+		log.Println(PreError, "http.NewRequest. ", err)
 		return
 	}
 	req.Header.Set("Content-Type", "application/json;charset=UTF-8")
-	req.Header.Set("User-Agent", "FileBoy Net Notifier v1.5")
+	req.Header.Set("User-Agent", "FileBoy Net Notifier v1.7")
 	resp, err := client.Do(req)
-	defer resp.Body.Close()
+	if err != nil {
+		log.Println(PreError, "notifier call failed. err:", err)
+		return
+	}
+	defer func() {
+		if resp != nil && resp.Body != nil {
+			_ = resp.Body.Close()
+		}
+	}()
 	if resp.StatusCode >= 300 {
 		// todo retry???
 	}

raw.go

@@ -47,12 +47,12 @@ command:
         - go version
         - go env
 
-    # 文件变更后命令会在xx毫秒后才会执行，单位为毫秒
+    # 文件变更后命令在xx毫秒后才会执行，单位为毫秒
     # 一个变更事件(A)如果在定义的延迟时间(t)内，又有新的文件变更事件(B)，那么A会取消执行。
     # B及以后的事件均依次类推，直到事件Z在t内没有新事件产生，Z 会执行
     # 合理设置延迟时间，将有效减少冗余和重复任务的执行
     # 如果不需要该特性，设置为 0
-    delayMillSecond: 1000
+    delayMillSecond: 2000
 
 # 通知器
 notifier:
@@ -61,10 +61,10 @@ notifier:
     # 请求超时 15 秒
     # POST 格式:
     #    Content-Type: application/json;charset=UTF-8
-    #    User-Agent: FileBoy Net Notifier v1.5
+    #    User-Agent: FileBoy Net Notifier v1.7
     #    Body: {"project_folder":"/watcher-dirs","file":"test.go","changed":1546421173070433800,"ext":".go"}
     # 例: http://example.com/notifier/fileboy-listener
-    # 不启用通知，请留空
+    # 不启用通知，请留空 ""
     callUrl: ""
 `
 
@@ -104,13 +104,13 @@ var logo = `
  _____     _  | |      _____   ____)  ) |   | | |___| |
 |  ___)   | | | |     |  ___) |  __  (| |   | |\_____/ 
 | |      _| |_| |_____| |_____| |__)  ) |___| |  ___   
-|_|     (_____)_______)_______)______/ \_____/  (___)   V1.5
+|_|     (_____)_______)_______)______/ \_____/  (___)   V1.7
 `
 var statement = `Dengsgo [dengsgo@gmail.com] Open Source with MIT License`
 
 var versionDesc = `
- Version   fileboy: v1.5    filegirl: v` + strconv.Itoa(Version) + `
-Released   2019.1.3
+ Version   fileboy: v1.7    filegirl: v` + strconv.Itoa(Version) + `
+Released   2019.1.24
  Licence   MIT
   Author   dengsgo [dengsgo@gmail.com]
  Website   https://github.com/dengsgo/fileboy

taskman.go

@@ -36,7 +36,7 @@ func (t *TaskMan) Put(cf *changedFile) {
 	defer t.putLock.Unlock()
 	t.lastTaskId = cf.Changed
 	go func() {
-		<-time.Tick(time.Millisecond * time.Duration(t.delay))
+		<-time.After(time.Millisecond * time.Duration(t.delay))
 		if t.lastTaskId > cf.Changed {
 			return
 		}
@@ -45,12 +45,11 @@ func (t *TaskMan) Put(cf *changedFile) {
 }
 
 func (t *TaskMan) preRun(cf *changedFile) {
-	if t.cmd != nil && t.cmd.Process != nil {
-		err := t.cmd.Process.Kill()
-		if err != nil {
-			log.Println("err: ", err)
-		}
+	if t.cmd != nil && t.cmd.Process != nil && t.cmd.ProcessState != nil && !t.cmd.ProcessState.Exited() {
 		log.Println("stop old process ")
+		if err := t.cmd.Process.Kill(); err != nil {
+			log.Println(PreWarn, "stopped err, reason:", err)
+		}
 	}
 	go t.run(cf)
 }
@@ -71,12 +70,12 @@ func (t *TaskMan) run(cf *changedFile) {
 		t.cmd.Env = os.Environ()
 		stdout, err := t.cmd.StdoutPipe()
 		if err != nil {
-			log.Println("error=>", err.Error())
+			log.Println(PreError, err.Error())
 			return
 		}
 		err = t.cmd.Start()
 		if err != nil {
-			log.Println("run command", carr, "error. ", err)
+			log.Println(PreError, "run command", carr, "error. ", err)
 		}
 		reader := bufio.NewReader(stdout)
 		for {
@@ -88,12 +87,12 @@ func (t *TaskMan) run(cf *changedFile) {
 		}
 		err = t.cmd.Wait()
 		if err != nil {
-			log.Println("cmd wait err ", err)
+			log.Println(PreWarn, "cmd wait err ", err)
 			break
 		}
-		if t.cmd.Process != nil {
+		if t.cmd.Process != nil && t.cmd.ProcessState != nil && !t.cmd.ProcessState.Exited() {
 			if err = t.cmd.Process.Kill(); err != nil {
-				log.Println("cmd cannot kill ", err)
+				log.Println(PreWarn, "cmd cannot kill, reason:", err)
 			}
 		}
 	}