4593d0a641
- script/vendor received an update in order to work with Glide - import paths have been rewritten to work with GO15VENDOREXPERIMENT
82 lines
1.5 KiB
Go
82 lines
1.5 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/cheggaaa/pb"
|
|
"io"
|
|
"net/http"
|
|
"os"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
func main() {
|
|
// check args
|
|
if len(os.Args) < 3 {
|
|
printUsage()
|
|
return
|
|
}
|
|
sourceName, destName := os.Args[1], os.Args[2]
|
|
|
|
// check source
|
|
var source io.Reader
|
|
var sourceSize int64
|
|
if strings.HasPrefix(sourceName, "http://") {
|
|
// open as url
|
|
resp, err := http.Get(sourceName)
|
|
if err != nil {
|
|
fmt.Printf("Can't get %s: %v\n", sourceName, err)
|
|
return
|
|
}
|
|
defer resp.Body.Close()
|
|
if resp.StatusCode != http.StatusOK {
|
|
fmt.Printf("Server return non-200 status: %v\n", resp.Status)
|
|
return
|
|
}
|
|
i, _ := strconv.Atoi(resp.Header.Get("Content-Length"))
|
|
sourceSize = int64(i)
|
|
source = resp.Body
|
|
} else {
|
|
// open as file
|
|
s, err := os.Open(sourceName)
|
|
if err != nil {
|
|
fmt.Printf("Can't open %s: %v\n", sourceName, err)
|
|
return
|
|
}
|
|
defer s.Close()
|
|
// get source size
|
|
sourceStat, err := s.Stat()
|
|
if err != nil {
|
|
fmt.Printf("Can't stat %s: %v\n", sourceName, err)
|
|
return
|
|
}
|
|
sourceSize = sourceStat.Size()
|
|
source = s
|
|
}
|
|
|
|
// create dest
|
|
dest, err := os.Create(destName)
|
|
if err != nil {
|
|
fmt.Printf("Can't create %s: %v\n", destName, err)
|
|
return
|
|
}
|
|
defer dest.Close()
|
|
|
|
// create bar
|
|
bar := pb.New(int(sourceSize)).SetUnits(pb.U_BYTES).SetRefreshRate(time.Millisecond * 10)
|
|
bar.ShowSpeed = true
|
|
bar.Start()
|
|
|
|
// create multi writer
|
|
writer := io.MultiWriter(dest, bar)
|
|
|
|
// and copy
|
|
io.Copy(writer, source)
|
|
bar.Finish()
|
|
}
|
|
|
|
func printUsage() {
|
|
fmt.Println("copy [source file or url] [dest file]")
|
|
}
|