Merge pull request #201 from Bytom/v0.1

[bytom/vapor.git] / vendor / github.com / ipfs / go-ipfs-api / dag.go

diff --git a/vendor/github.com/ipfs/go-ipfs-api/dag.go b/vendor/github.com/ipfs/go-ipfs-api/dag.go
deleted file mode 100644 (file)
index edfcbac..0000000
--- a/vendor/github.com/ipfs/go-ipfs-api/dag.go
+++ /dev/null
@@ -1,57 +0,0 @@
-package shell
-
-import (
-       "bytes"
-       "context"
-       "fmt"
-       "io"
-       "strings"
-
-       "github.com/ipfs/go-ipfs-api/options"
-       "github.com/ipfs/go-ipfs-files"
-)
-
-func (s *Shell) DagGet(ref string, out interface{}) error {
-       return s.Request("dag/get", ref).Exec(context.Background(), out)
-}
-
-func (s *Shell) DagPut(data interface{}, ienc, kind string) (string, error) {
-       return s.DagPutWithOpts(data, options.Dag.InputEnc(ienc), options.Dag.Kind(kind))
-}
-
-func (s *Shell) DagPutWithOpts(data interface{}, opts ...options.DagPutOption) (string, error) {
-       cfg, err := options.DagPutOptions(opts...)
-       if err != nil {
-               return "", err
-       }
-
-       var r io.Reader
-       switch data := data.(type) {
-       case string:
-               r = strings.NewReader(data)
-       case []byte:
-               r = bytes.NewReader(data)
-       case io.Reader:
-               r = data
-       default:
-               return "", fmt.Errorf("cannot current handle putting values of type %T", data)
-       }
-
-       fr := files.NewReaderFile(r)
-       slf := files.NewSliceDirectory([]files.DirEntry{files.FileEntry("", fr)})
-       fileReader := files.NewMultiFileReader(slf, true)
-
-       var out struct {
-               Cid struct {
-                       Target string `json:"/"`
-               }
-       }
-
-       return out.Cid.Target, s.
-               Request("dag/put").
-               Option("input-enc", cfg.InputEnc).
-               Option("format", cfg.Kind).
-               Option("pin", cfg.Pin).
-               Body(fileReader).
-               Exec(context.Background(), &out)
-}