aboutsummaryrefslogtreecommitdiffstats
path: root/cmd
diff options
context:
space:
mode:
authorLouis Holbrook <nolash@users.noreply.github.com>2017-04-06 20:21:16 +0800
committerFelix Lange <fjl@users.noreply.github.com>2017-04-06 20:21:16 +0800
commit0ec1104ba92c226c279389bbeb88ca515208f030 (patch)
treede5d5d03371702e5f9bb248c4b9f1a1289cf1876 /cmd
parentc76ad944920300be58446ddd1a50c8d693957774 (diff)
downloaddexon-0ec1104ba92c226c279389bbeb88ca515208f030.tar
dexon-0ec1104ba92c226c279389bbeb88ca515208f030.tar.gz
dexon-0ec1104ba92c226c279389bbeb88ca515208f030.tar.bz2
dexon-0ec1104ba92c226c279389bbeb88ca515208f030.tar.lz
dexon-0ec1104ba92c226c279389bbeb88ca515208f030.tar.xz
dexon-0ec1104ba92c226c279389bbeb88ca515208f030.tar.zst
dexon-0ec1104ba92c226c279389bbeb88ca515208f030.zip
cmd/swarm: allow uploading from stdin (#3744)
- intended to be a swarm alternative to termbin.com - added --stdin flag to swarm executable. if set, swarm will read data from stdin and postRaw it.
Diffstat (limited to 'cmd')
-rw-r--r--cmd/swarm/main.go10
-rw-r--r--cmd/swarm/upload.go35
2 files changed, 39 insertions, 6 deletions
diff --git a/cmd/swarm/main.go b/cmd/swarm/main.go
index 731c300f8..47ed662d4 100644
--- a/cmd/swarm/main.go
+++ b/cmd/swarm/main.go
@@ -112,6 +112,14 @@ var (
Name: "defaultpath",
Usage: "path to file served for empty url path (none)",
}
+ SwarmUpFromStdinFlag = cli.BoolFlag{
+ Name: "stdin",
+ Usage: "reads data to be uploaded from stdin",
+ }
+ SwarmUploadMimeType = cli.StringFlag{
+ Name: "mime",
+ Usage: "force mime type",
+ }
CorsStringFlag = cli.StringFlag{
Name: "corsdomain",
Usage: "Domain on which to send Access-Control-Allow-Origin header (multiple domains can be supplied separated by a ',')",
@@ -244,6 +252,8 @@ Cleans database of corrupted entries.
SwarmRecursiveUploadFlag,
SwarmWantManifestFlag,
SwarmUploadDefaultPath,
+ SwarmUpFromStdinFlag,
+ SwarmUploadMimeType,
}
app.Flags = append(app.Flags, debug.Flags...)
app.Before = func(ctx *cli.Context) error {
diff --git a/cmd/swarm/upload.go b/cmd/swarm/upload.go
index 696b907d2..46f10c4be 100644
--- a/cmd/swarm/upload.go
+++ b/cmd/swarm/upload.go
@@ -20,6 +20,8 @@ package main
import (
"encoding/json"
"fmt"
+ "io"
+ "io/ioutil"
"os"
"os/user"
"path"
@@ -31,21 +33,42 @@ import (
)
func upload(ctx *cli.Context) {
+
args := ctx.Args()
var (
bzzapi = strings.TrimRight(ctx.GlobalString(SwarmApiFlag.Name), "/")
recursive = ctx.GlobalBool(SwarmRecursiveUploadFlag.Name)
wantManifest = ctx.GlobalBoolT(SwarmWantManifestFlag.Name)
defaultPath = ctx.GlobalString(SwarmUploadDefaultPath.Name)
+ fromStdin = ctx.GlobalBool(SwarmUpFromStdinFlag.Name)
+ mimeType = ctx.GlobalString(SwarmUploadMimeType.Name)
)
+
+ var client = swarm.NewClient(bzzapi)
+ var entry swarm.ManifestEntry
+ var file string
+
if len(args) != 1 {
- utils.Fatalf("Need filename as the first and only argument")
+ if fromStdin {
+ tmp, err := ioutil.TempFile("", "swarm-stdin")
+ if err != nil {
+ utils.Fatalf("error create tempfile: %s", err)
+ }
+ defer os.Remove(tmp.Name())
+ n, err := io.Copy(tmp, os.Stdin)
+ if err != nil {
+ utils.Fatalf("error copying stdin to tempfile: %s", err)
+ } else if n == 0 {
+ utils.Fatalf("error reading from stdin: zero length")
+ }
+ file = tmp.Name()
+ } else {
+ utils.Fatalf("Need filename as the first and only argument")
+ }
+ } else {
+ file = args[0]
}
- var (
- file = args[0]
- client = swarm.NewClient(bzzapi)
- )
fi, err := os.Stat(expandPath(file))
if err != nil {
utils.Fatalf("Failed to stat file: %v", err)
@@ -64,7 +87,7 @@ func upload(ctx *cli.Context) {
fmt.Println(mhash)
return
}
- entry, err := client.UploadFile(file, fi)
+ entry, err = client.UploadFile(file, fi, mimeType)
if err != nil {
utils.Fatalf("Upload failed: %v", err)
}