61 lines
1.2 KiB
Go
61 lines
1.2 KiB
Go
package eve
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
|
|
"github.com/starkers/safer-eve/pkg/evelogs"
|
|
)
|
|
|
|
type logDirs []*evelogs.LogDir
|
|
type logfiles []*evelogs.LogFile
|
|
|
|
func Init() error {
|
|
fmt.Println("searching")
|
|
|
|
//fmt.Println(a)
|
|
//fileList := FileSearchUnix()
|
|
dirlist, err := GetLogDirectories()
|
|
if err != nil {
|
|
log.Fatal(fmt.Sprintf("Failed getting log directories %v", err))
|
|
}
|
|
logDirs, err := evelogs.DirsToLogDirs(dirlist)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
log.Println("Found logdirs: ")
|
|
for _, logdir := range logDirs {
|
|
log.Println(logdir.Path)
|
|
}
|
|
|
|
//List := eve.GetActiveChannels(fileList)
|
|
var logfiles []*evelogs.LogFile
|
|
for _, logdir := range logDirs {
|
|
logfilelist, err := logdir.GetLogFiles()
|
|
if err != nil {
|
|
log.Printf("Warning: %s", err)
|
|
}
|
|
logfiles = append(logfiles, logfilelist...)
|
|
|
|
}
|
|
|
|
//for _, d := range logDirs {
|
|
// fmt.Println(d)
|
|
// go eve.WatchPath(d)
|
|
//}
|
|
|
|
// for _, f := range fileList {
|
|
// if eve.IsCurrentLog(f) {
|
|
// //if strings.Contains(f, "delve.imperium") {
|
|
// // fmt.Printf("tailing file: %v\n", f)
|
|
// go eve.Tail(f)
|
|
// //}
|
|
// }
|
|
// //else {
|
|
// // fmt.Println(f)
|
|
// //}
|
|
// }
|
|
// time.Sleep(9999 * time.Hour)
|
|
return nil
|
|
}
|