43 lines
956 B
Go
43 lines
956 B
Go
package archiver
|
|
|
|
import (
|
|
"os"
|
|
"path/filepath"
|
|
)
|
|
|
|
func NewErrorOnlyArchiver(conf *Config) func(string, error) {
|
|
return func(filePath string, archiveErr error) {
|
|
if archiveErr != nil {
|
|
err := writeErrorFile(conf, filePath, archiveErr)
|
|
logger.Error(err)
|
|
}
|
|
}
|
|
}
|
|
|
|
func writeErrorFile(conf *Config, filePath string, archiveErr error) error {
|
|
if archiveErr != nil {
|
|
baseName := filepath.Base(filePath)
|
|
|
|
destFolder := getDestFolder(conf, ErrorFolder)
|
|
globDir := extractGlobbedDir(conf.Folder, filePath)
|
|
if globDir != "" {
|
|
destFolder = filepath.Join(destFolder, globDir)
|
|
}
|
|
|
|
err := os.MkdirAll(destFolder, os.ModePerm)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
f, err := os.OpenFile(filepath.Join(destFolder, baseName+".err"), os.O_WRONLY|os.O_CREATE|os.O_APPEND, os.ModePerm)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer f.Close()
|
|
_, err = f.Write([]byte(archiveErr.Error() + "\n"))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|