From bea20cf98d14155074486904571a38d3cd68a59e Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Wed, 5 Feb 2014 14:08:49 +0200 Subject: [PATCH] fixed history files creation --- history/file_scribe.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/history/file_scribe.go b/history/file_scribe.go index 5694a97dc..a4140d115 100644 --- a/history/file_scribe.go +++ b/history/file_scribe.go @@ -24,6 +24,7 @@ import ( "errors" "fmt" "io" + "log" "os" "os/exec" "path/filepath" @@ -48,9 +49,10 @@ func NewFileScribe(fileRoot string, saveInterval time.Duration) (*FileScribe, er } s := &FileScribe{fileRoot: fileRoot, gitCommand: gitCommand, savePeriod: saveInterval} s.loopChecker = make(chan int) - s.gitInit() + files := []string{DESTINATIONS_FN, RATING_PLANS_FN, RATING_PROFILES_FN} + s.gitInit(files) - for _, fn := range []string{DESTINATIONS_FN, RATING_PLANS_FN, RATING_PROFILES_FN} { + for _, fn := range files { if err := s.load(fn); err != nil { return nil, err } @@ -90,7 +92,7 @@ func (s *FileScribe) Record(rec Record, out *int) error { return nil } -func (s *FileScribe) gitInit() error { +func (s *FileScribe) gitInit(files []string) error { s.mu.Lock() defer s.mu.Unlock() if _, err := os.Stat(s.fileRoot); os.IsNotExist(err) { @@ -104,7 +106,9 @@ func (s *FileScribe) gitInit() error { if out, err := cmd.Output(); err != nil { return errors.New(string(out) + " " + err.Error()) } - for fn, _ := range recordsMap { + log.Print("CREATING FILES") + for _, fn := range files { + log.Print("FILE: ", fn) if f, err := os.Create(filepath.Join(s.fileRoot, fn)); err != nil { return fmt.Errorf(" Error writing %s file: %s", fn, err.Error()) } else {