path.go 2.34 KB
Newer Older
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
1 2 3 4
package path

import (
	"fmt"
5 6 7
	"path"
	"strings"

8
	mh "github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multihash"
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
9 10 11 12
	merkledag "github.com/jbenet/go-ipfs/merkledag"
	u "github.com/jbenet/go-ipfs/util"
)

Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
13
var log = u.Logger("path")
14

Juan Batiz-Benet's avatar
go lint  
Juan Batiz-Benet committed
15 16
// Resolver provides path resolution to IPFS
// It has a pointer to a DAGService, which is uses to resolve nodes.
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
17 18 19 20
type Resolver struct {
	DAG *merkledag.DAGService
}

Juan Batiz-Benet's avatar
go lint  
Juan Batiz-Benet committed
21 22 23
// ResolvePath fetches the node for given path. It uses the first
// path component as a hash (key) of the first node, then resolves
// all other components walking the links, with ResolveLinks.
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
24
func (s *Resolver) ResolvePath(fpath string) (*merkledag.Node, error) {
25
	log.Debug("Resolve: '%s'", fpath)
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
26 27 28 29 30 31 32 33 34 35 36
	fpath = path.Clean(fpath)

	parts := strings.Split(fpath, "/")

	// skip over empty first elem
	if len(parts[0]) == 0 {
		parts = parts[1:]
	}

	// if nothing, bail.
	if len(parts) == 0 {
Juan Batiz-Benet's avatar
go lint  
Juan Batiz-Benet committed
37
		return nil, fmt.Errorf("ipfs path must contain at least one component")
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
38 39 40 41 42
	}

	// first element in the path is a b58 hash (for now)
	h, err := mh.FromB58String(parts[0])
	if err != nil {
43
		u.DOut("given path element is not a base58 string.\n")
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
44 45 46
		return nil, err
	}

47
	u.DOut("Resolve dag get.\n")
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
48 49 50 51 52 53 54 55
	nd, err := s.DAG.Get(u.Key(h))
	if err != nil {
		return nil, err
	}

	return s.ResolveLinks(nd, parts[1:])
}

Juan Batiz-Benet's avatar
go lint  
Juan Batiz-Benet committed
56 57 58 59 60 61
// ResolveLinks iteratively resolves names by walking the link hierarchy.
// Every node is fetched from the DAGService, resolving the next name.
// Returns the last node found.
//
// ResolveLinks(nd, []string{"foo", "bar", "baz"})
// would retrieve "baz" in ("bar" in ("foo" in nd.Links).Links).Links
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
62 63 64 65 66 67 68 69 70
func (s *Resolver) ResolveLinks(ndd *merkledag.Node, names []string) (
	nd *merkledag.Node, err error) {

	nd = ndd // dup arg workaround

	// for each of the path components
	for _, name := range names {

		var next u.Key
71
		var nlink *merkledag.Link
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
72 73 74 75
		// for each of the links in nd, the current object
		for _, link := range nd.Links {
			if link.Name == name {
				next = u.Key(link.Hash)
76
				nlink = link
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
77 78 79 80 81 82 83
				break
			}
		}

		if next == "" {
			h1, _ := nd.Multihash()
			h2 := h1.B58String()
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
84
			return nil, fmt.Errorf("no link named %q under %s", name, h2)
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
85 86
		}

87 88 89 90 91 92 93 94 95
		if nlink.Node == nil {
			// fetch object for link and assign to nd
			nd, err = s.DAG.Get(next)
			if err != nil {
				return nd, err
			}
			nlink.Node = nd
		} else {
			nd = nlink.Node
Juan Batiz-Benet's avatar
Juan Batiz-Benet committed
96 97 98 99
		}
	}
	return
}