add new line every telegram

This commit is contained in:
zhiqiang feng
2020-12-28 16:58:36 +08:00
parent 7375808704
commit ad2cccc3f9
2 changed files with 9 additions and 6 deletions
+3 -1
View File
@@ -96,7 +96,9 @@ func start() {
if lograw { if lograw {
fmt.Print(string(buffer)) fmt.Print(string(buffer))
} }
utils.Append(buffer) if utils.Append(buffer) {
fmt.Println()
}
} }
} }
<-done <-done
+6 -5
View File
@@ -9,21 +9,21 @@ import (
const ( const (
EndTag = "NNNN" EndTag = "NNNN"
Expression = "(?s)ZCZC.*NNNN[\n]" Expression = "(?s)ZCZC.*NNNN"
) )
var buffer []byte var buffer []byte
var RawLog *rotatelogs.RotateLogs var RawLog *rotatelogs.RotateLogs
func Append(data []byte) { func Append(data []byte) bool {
buffer = append(buffer, data...) buffer = append(buffer, data...)
if buffer[len(buffer)-1] == '\r' { if buffer[len(buffer)-1] == '\r' {
buffer = append(buffer, '\n') buffer = append(buffer, '\n')
} }
check() return check()
} }
func check() { func check() bool {
teleString := string(buffer) teleString := string(buffer)
if strings.Index(teleString, EndTag) > 0 { if strings.Index(teleString, EndTag) > 0 {
exp, _ := regexp.Compile(Expression) exp, _ := regexp.Compile(Expression)
@@ -35,9 +35,10 @@ func check() {
RawLog.Write([]byte(telegram)) RawLog.Write([]byte(telegram))
buffer = nil buffer = nil
InsertTelegram(telegram) InsertTelegram(telegram)
return true
} }
} }
return false
} }
func removeEmpty(s string) string { func removeEmpty(s string) string {