Adjust downloader functions

This commit is contained in:
Tom Neuber 2024-03-02 10:55:27 +01:00
parent 06eaff6503
commit ca09e5efc5
Signed by: tom
GPG key ID: F17EFE4272D89FF6
2 changed files with 39 additions and 24 deletions

View file

@ -24,8 +24,13 @@ func main() {
} }
handleGracefulShutdown() handleGracefulShutdown()
if !downloader.FileExists(appSettings.DataFile) {
downloader.DownloadFile(appSettings.DataFile, appSettings.DataURL) ctx := downloader.NewContext(appSettings.DataFile, appSettings.DataURL)
if !ctx.FileExists() {
if err := ctx.Download(); err != nil {
panic(err)
}
fmt.Printf("Saved file to %s\n", ctx.Filename)
} }
fmt.Printf("Import data from file...\r") fmt.Printf("Import data from file...\r")

View file

@ -11,34 +11,44 @@ import (
"github.com/schollz/progressbar/v3" "github.com/schollz/progressbar/v3"
) )
func handleError(err error) { type Context struct {
fmt.Println(err.Error()) Filename string
os.Exit(0) Link string
} }
func DownloadFile(path, url string) { func NewContext(filename, link string) *Context {
resp, err := req.Head(url, nil) return &Context{
Filename: filename,
Link: link,
}
}
func (c *Context) Download() error {
resp, err := req.Head(c.Link, nil)
if err != nil { if err != nil {
if strings.Contains(err.Error(), "no such host") { if strings.Contains(err.Error(), "no such host") {
handleError(errors.New("invalid url")) return fmt.Errorf("invalid url")
} else if strings.Contains(err.Error(), "certificate signed by unknown authority") {
handleError(errors.New("certificate from unknown authority"))
} }
handleError(err) if strings.Contains(err.Error(), "certificate signed by unknown authority") {
return fmt.Errorf("certificate from unknown authority")
}
return err
} }
defer resp.Close() defer resp.Close()
if resp.StatusCode == 404 { if resp.StatusCode == 404 {
handleError(errors.New("invalid url")) return fmt.Errorf("invalid url")
} else if resp.StatusCode == 401 { }
handleError(errors.New("restricted access (credentials required)")) if resp.StatusCode == 401 {
} else if resp.StatusCode != 200 { return fmt.Errorf("restricted access (credentials required)")
handleError(errors.New(resp.RawResponse.Status)) }
if resp.StatusCode != 200 {
return fmt.Errorf(resp.RawResponse.Status)
} }
resp.Close() resp.Close()
resp, err = req.Get(url, nil) resp, err = req.Get(c.Link, nil)
if err != nil { if err != nil {
handleError(err) return err
} }
var filesize int64 var filesize int64
@ -46,9 +56,9 @@ func DownloadFile(path, url string) {
filesize = resp.RawResponse.ContentLength filesize = resp.RawResponse.ContentLength
} }
destFile, err := os.OpenFile(path, os.O_CREATE|os.O_WRONLY, 0644) destFile, err := os.OpenFile(c.Filename, os.O_CREATE|os.O_WRONLY, 0644)
if err != nil { if err != nil {
handleError(err) return err
} }
defer destFile.Close() defer destFile.Close()
@ -59,13 +69,13 @@ func DownloadFile(path, url string) {
_, err = io.Copy(io.MultiWriter(destFile, bar), resp.RawResponse.Body) _, err = io.Copy(io.MultiWriter(destFile, bar), resp.RawResponse.Body)
if err != nil { if err != nil {
handleError(err) return err
} }
fmt.Println("Saved file to", path) return nil
} }
func FileExists(path string) bool { func (c *Context) FileExists() bool {
_, err := os.Stat(path) _, err := os.Stat(c.Filename)
return !errors.Is(err, os.ErrNotExist) return !errors.Is(err, os.ErrNotExist)
} }