jiazhizhong/polaris
1
0
Fork 0
mirror of https://github.com/simon-ding/polaris.git synced 2026-05-26 20:47:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

add log

Browse Source
This commit is contained in:
Simon Ding
2024-07-20 15:10:15 +08:00
parent e0e6da143b
commit 9adc1f418b
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/storage/local.go
View File

@@ -6,6 +6,7 @@ import (
"io/ioutil" "io/ioutil"
"os" "os"
"path/filepath" "path/filepath"
"polaris/log"
"github.com/pkg/errors" "github.com/pkg/errors"
) )
@@ -17,7 +18,7 @@ type Storage interface {
func NewLocalStorage(dir string) (*LocalStorage, error) { func NewLocalStorage(dir string) (*LocalStorage, error) {
os.MkdirAll(dir, 0655) os.MkdirAll(dir, 0655)
return &LocalStorage{dir: dir}, nil return &LocalStorage{dir: dir}, nil
} }
@@ -32,7 +33,7 @@ func (l *LocalStorage) Move(src, dest string) error {
if err != nil { if err != nil {
return err return err
} }
rel, err := filepath.Rel(src, path) rel, err := filepath.Rel(src, path)
if err != nil { if err != nil {
return errors.Wrapf(err, "relation between %s and %s", src, path) return errors.Wrapf(err, "relation between %s and %s", src, path)
} }
@@ -56,6 +57,7 @@ func (l *LocalStorage) Move(src, dest string) error {
} }
} }
} }
log.Infof("file copy complete: %v", destName)
return nil return nil
}) })
if err != nil { if err != nil {
@@ -65,7 +67,6 @@ func (l *LocalStorage) Move(src, dest string) error {
} }
func (l *LocalStorage) ReadDir(dir string) ([]fs.FileInfo, error) { func (l *LocalStorage) ReadDir(dir string) ([]fs.FileInfo, error) {
return ioutil.ReadDir(filepath.Join(l.dir, dir)) return ioutil.ReadDir(filepath.Join(l.dir, dir))
} }