This repository has been archived by the owner on Jun 20, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 10
/
resolve.go
60 lines (50 loc) · 1.52 KB
/
resolve.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
package resolve
import (
"context"
"errors"
"fmt"
"strings"
"github.com/ipfs/go-path"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/trace"
"github.com/ipfs/go-namesys"
)
// ErrNoNamesys is an explicit error for when an IPFS node doesn't
// (yet) have a name system
//
// Deprecated: use github.com/ipfs/boxo/namesys/resolve.ErrNoNamesys
var ErrNoNamesys = errors.New(
"core/resolve: no Namesys on IpfsNode - can't resolve ipns entry")
// ResolveIPNS resolves /ipns paths
//
// Deprecated: use github.com/ipfs/boxo/namesys/resolve.ResolveIPNS
func ResolveIPNS(ctx context.Context, nsys namesys.NameSystem, p path.Path) (path.Path, error) {
ctx, span := namesys.StartSpan(ctx, "ResolveIPNS", trace.WithAttributes(attribute.String("Path", p.String())))
defer span.End()
if strings.HasPrefix(p.String(), "/ipns/") {
// TODO(cryptix): we should be able to query the local cache for the path
if nsys == nil {
return "", ErrNoNamesys
}
seg := p.Segments()
if len(seg) < 2 || seg[1] == "" { // just "/<protocol/>" without further segments
err := fmt.Errorf("invalid path %q: ipns path missing IPNS ID", p)
return "", err
}
extensions := seg[2:]
resolvable, err := path.FromSegments("/", seg[0], seg[1])
if err != nil {
return "", err
}
respath, err := nsys.Resolve(ctx, resolvable.String())
if err != nil {
return "", err
}
segments := append(respath.Segments(), extensions...)
p, err = path.FromSegments("/", segments...)
if err != nil {
return "", err
}
}
return p, nil
}