cmd/swarm: improve uploader output and add defaultpath option

pull/3421/head
zelig 8 years ago
parent 080699f7df
commit 485748c416
  1. 5
      cmd/swarm/main.go
  2. 75
      cmd/swarm/upload.go

@ -108,6 +108,10 @@ var (
Name: "manifest", Name: "manifest",
Usage: "Automatic manifest upload", Usage: "Automatic manifest upload",
} }
SwarmUploadDefaultPath = cli.StringFlag{
Name: "defaultpath",
Usage: "path to file served for empty url path (none)",
}
) )
func init() { func init() {
@ -179,6 +183,7 @@ Prints the swarm hash of file or directory.
SwarmApiFlag, SwarmApiFlag,
SwarmRecursiveUploadFlag, SwarmRecursiveUploadFlag,
SwarmWantManifestFlag, SwarmWantManifestFlag,
SwarmUploadDefaultPath,
} }
app.Flags = append(app.Flags, debug.Flags...) app.Flags = append(app.Flags, debug.Flags...)
app.Before = func(ctx *cli.Context) error { app.Before = func(ctx *cli.Context) error {

@ -27,6 +27,8 @@ import (
"mime" "mime"
"net/http" "net/http"
"os" "os"
"os/user"
"path"
"path/filepath" "path/filepath"
"strings" "strings"
@ -39,6 +41,7 @@ func upload(ctx *cli.Context) {
bzzapi = strings.TrimRight(ctx.GlobalString(SwarmApiFlag.Name), "/") bzzapi = strings.TrimRight(ctx.GlobalString(SwarmApiFlag.Name), "/")
recursive = ctx.GlobalBool(SwarmRecursiveUploadFlag.Name) recursive = ctx.GlobalBool(SwarmRecursiveUploadFlag.Name)
wantManifest = ctx.GlobalBoolT(SwarmWantManifestFlag.Name) wantManifest = ctx.GlobalBoolT(SwarmWantManifestFlag.Name)
defaultPath = ctx.GlobalString(SwarmUploadDefaultPath.Name)
) )
if len(args) != 1 { if len(args) != 1 {
log.Fatal("need filename as the first and only argument") log.Fatal("need filename as the first and only argument")
@ -48,8 +51,9 @@ func upload(ctx *cli.Context) {
file = args[0] file = args[0]
client = &client{api: bzzapi} client = &client{api: bzzapi}
mroot manifest mroot manifest
entry manifestEntry
) )
fi, err := os.Stat(file) fi, err := os.Stat(expandPath(file))
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
@ -57,28 +61,49 @@ func upload(ctx *cli.Context) {
if !recursive { if !recursive {
log.Fatal("argument is a directory and recursive upload is disabled") log.Fatal("argument is a directory and recursive upload is disabled")
} }
mroot, err = client.uploadDirectory(file) mroot, err = client.uploadDirectory(file, defaultPath)
} else { } else {
mroot, err = client.uploadFile(file, fi) entry, err = client.uploadFile(file, fi)
if wantManifest { mroot = manifest{[]manifestEntry{entry}}
// Wrap the raw file entry in a proper manifest so both hashes get printed.
mroot = manifest{Entries: []manifest{mroot}}
}
} }
if err != nil { if err != nil {
log.Fatalln("upload failed:", err) log.Fatalln("upload failed:", err)
} }
if wantManifest { if !wantManifest {
// Print the manifest. This is the only output to stdout.
mrootJSON, _ := json.MarshalIndent(mroot, "", " ")
fmt.Println(string(mrootJSON))
return
}
hash, err := client.uploadManifest(mroot) hash, err := client.uploadManifest(mroot)
if err != nil { if err != nil {
log.Fatalln("manifest upload failed:", err) log.Fatalln("manifest upload failed:", err)
} }
mroot.Hash = hash fmt.Println(hash)
} }
// Print the manifest. This is the only output to stdout. // Expands a file path
mrootJSON, _ := json.MarshalIndent(mroot, "", " ") // 1. replace tilde with users home dir
fmt.Println(string(mrootJSON)) // 2. expands embedded environment variables
// 3. cleans the path, e.g. /a/b/../c -> /a/c
// Note, it has limitations, e.g. ~someuser/tmp will not be expanded
func expandPath(p string) string {
if strings.HasPrefix(p, "~/") || strings.HasPrefix(p, "~\\") {
if home := homeDir(); home != "" {
p = home + p[1:]
}
}
return path.Clean(os.ExpandEnv(p))
}
func homeDir() string {
if home := os.Getenv("HOME"); home != "" {
return home
}
if usr, err := user.Current(); err == nil {
return usr.HomeDir
}
return ""
} }
// client wraps interaction with the swarm HTTP gateway. // client wraps interaction with the swarm HTTP gateway.
@ -87,24 +112,40 @@ type client struct {
} }
// manifest is the JSON representation of a swarm manifest. // manifest is the JSON representation of a swarm manifest.
type manifest struct { type manifestEntry struct {
Hash string `json:"hash,omitempty"` Hash string `json:"hash,omitempty"`
ContentType string `json:"contentType,omitempty"` ContentType string `json:"contentType,omitempty"`
Path string `json:"path,omitempty"` Path string `json:"path,omitempty"`
Entries []manifest `json:"entries,omitempty"`
} }
func (c *client) uploadFile(file string, fi os.FileInfo) (manifest, error) { // manifest is the JSON representation of a swarm manifest.
type manifest struct {
Entries []manifestEntry `json:"entries,omitempty"`
}
func (c *client) uploadFile(file string, fi os.FileInfo) (manifestEntry, error) {
hash, err := c.uploadFileContent(file, fi) hash, err := c.uploadFileContent(file, fi)
m := manifest{ m := manifestEntry{
Hash: hash, Hash: hash,
ContentType: mime.TypeByExtension(filepath.Ext(fi.Name())), ContentType: mime.TypeByExtension(filepath.Ext(fi.Name())),
} }
return m, err return m, err
} }
func (c *client) uploadDirectory(dir string) (manifest, error) { func (c *client) uploadDirectory(dir string, defaultPath string) (manifest, error) {
dirm := manifest{} dirm := manifest{}
if len(defaultPath) > 0 {
fi, err := os.Stat(defaultPath)
if err != nil {
log.Fatal(err)
}
entry, err := c.uploadFile(defaultPath, fi)
if err != nil {
log.Fatal(err)
}
entry.Path = ""
dirm.Entries = append(dirm.Entries, entry)
}
prefix := filepath.ToSlash(filepath.Clean(dir)) + "/" prefix := filepath.ToSlash(filepath.Clean(dir)) + "/"
err := filepath.Walk(dir, func(path string, fi os.FileInfo, err error) error { err := filepath.Walk(dir, func(path string, fi os.FileInfo, err error) error {
if err != nil || fi.IsDir() { if err != nil || fi.IsDir() {

Loading…
Cancel
Save