Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 416f435

Browse files
committedMay 4, 2015
http gw: remove newDagEmptyDir helper
1 parent 9b60a42 commit 416f435

File tree

1 file changed

+5
-8
lines changed

1 file changed

+5
-8
lines changed
 

‎core/corehttp/gateway_handler.go

+5-8
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ import (
1818
dag "github.com/ipfs/go-ipfs/merkledag"
1919
path "github.com/ipfs/go-ipfs/path"
2020
"github.com/ipfs/go-ipfs/routing"
21-
ufs "github.com/ipfs/go-ipfs/unixfs"
2221
uio "github.com/ipfs/go-ipfs/unixfs/io"
2322
u "github.com/ipfs/go-ipfs/util"
2423
)
@@ -70,14 +69,12 @@ func (i *gatewayHandler) loadTemplate() error {
7069

7170
// TODO(cryptix): find these helpers somewhere else
7271
func (i *gatewayHandler) newDagFromReader(r io.Reader) (*dag.Node, error) {
72+
// TODO(cryptix): change and remove this helper once PR1136 is merged
73+
// return ufs.AddFromReader(i.node, r.Body)
7374
return importer.BuildDagFromReader(
7475
r, i.node.DAG, i.node.Pinning.GetManual(), chunk.DefaultSplitter)
7576
}
7677

77-
func newDagEmptyDir() *dag.Node {
78-
return &dag.Node{Data: ufs.FolderPBData()}
79-
}
80-
8178
// TODO(btc): break this apart into separate handlers using a more expressive muxer
8279
func (i *gatewayHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
8380
if i.config.Writable {
@@ -242,7 +239,7 @@ func (i *gatewayHandler) postHandler(w http.ResponseWriter, r *http.Request) {
242239
}
243240

244241
func (i *gatewayHandler) putEmptyDirHandler(w http.ResponseWriter, r *http.Request) {
245-
newnode := newDagEmptyDir()
242+
newnode := uio.NewDirectory(i.node.DAG).GetNode()
246243

247244
key, err := i.node.DAG.Add(newnode)
248245
if err != nil {
@@ -265,7 +262,7 @@ func (i *gatewayHandler) putHandler(w http.ResponseWriter, r *http.Request) {
265262

266263
var newnode *dag.Node
267264
if pathext[len(pathext)-1] == '/' {
268-
newnode = newDagEmptyDir()
265+
newnode = uio.NewDirectory(i.node.DAG).GetNode()
269266
} else {
270267
newnode, err = i.newDagFromReader(r.Body)
271268
if err != nil {
@@ -317,7 +314,7 @@ func (i *gatewayHandler) putHandler(w http.ResponseWriter, r *http.Request) {
317314
if _, ok := err.(path.ErrNoLink); ok {
318315
// Create empty directories, links will be made further down the code
319316
for len(pathNodes) < len(components) {
320-
pathNodes = append(pathNodes, newDagEmptyDir())
317+
pathNodes = append(pathNodes, uio.NewDirectory(i.node.DAG).GetNode())
321318
}
322319
} else if err != nil {
323320
webError(w, "Could not resolve parent object", err, http.StatusBadRequest)

0 commit comments

Comments
 (0)
Please sign in to comment.