diff options
Diffstat (limited to 'rhimport/fetcher.go')
| -rw-r--r-- | rhimport/fetcher.go | 26 |
1 files changed, 17 insertions, 9 deletions
diff --git a/rhimport/fetcher.go b/rhimport/fetcher.go index a253eb4..1f1e84f 100644 --- a/rhimport/fetcher.go +++ b/rhimport/fetcher.go @@ -149,8 +149,10 @@ func fetchFileCurl(ctx *Context, res *Result, uri *url.URL) (err error) { } ctx.SourceFile = cbdata.filename - ctx.DeleteSourceFile = true - ctx.DeleteSourceDir = true + if ctx.SourceFilePolicy == Auto { + ctx.DeleteSourceFile = true + ctx.DeleteSourceDir = true + } } else { err = fmt.Errorf("Error initializing libcurl") } @@ -251,8 +253,10 @@ func fetchFileArchiv(ctx *Context, res *Result, uri *url.URL) (err error) { } ctx.SourceFile = cbdata.filename - ctx.DeleteSourceFile = true - ctx.DeleteSourceDir = true + if ctx.SourceFilePolicy == Auto { + ctx.DeleteSourceFile = true + ctx.DeleteSourceDir = true + } } else { err = fmt.Errorf("Error initializing libcurl") } @@ -292,8 +296,10 @@ func fetchFileLocal(ctx *Context, res *Result, uri *url.URL) (err error) { ctx.ProgressCallBack = nil } } - ctx.DeleteSourceFile = false - ctx.DeleteSourceDir = false + if ctx.SourceFilePolicy == Auto { + ctx.DeleteSourceFile = false + ctx.DeleteSourceDir = false + } return } @@ -325,8 +331,10 @@ func fetchFileFake(ctx *Context, res *Result, uri *url.URL) error { } } ctx.SourceFile = "/nonexistend/fake.mp3" - ctx.DeleteSourceFile = false - ctx.DeleteSourceDir = false + if ctx.SourceFilePolicy == Auto { + ctx.DeleteSourceFile = false + ctx.DeleteSourceDir = false + } } return nil } @@ -370,7 +378,7 @@ func fetcherInit() { } } if !archiveEnabled { - rhl.Printf("archiv: fetcher is disabled because the installed curl library version doesn't support scp!") + rhl.Printf("archiv: fetcher is disabled because the installed curl library version doesn't support sFTP!") } } |