Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DagCmd = &cmds.Command{ Helptext: cmdkit.HelpText{ Tagline: "Interact with ipld dag objects.", ShortDescription: ` 'ipfs dag' is used for creating and manipulating dag objects. This subcommand is currently an experimental feature, but it is intended to deprecate and replace the existing 'ipfs object' command moving forward. `, }, Subcommands: map[string]*cmds.Command{ "put": DagPutCmd, "get": DagGetCmd, "resolve": DagResolveCmd, }, }
View Source
var DagGetCmd = &cmds.Command{ Helptext: cmdkit.HelpText{ Tagline: "Get a dag node from ipfs.", ShortDescription: ` 'ipfs dag get' fetches a dag node from ipfs and prints it out in the specified format. `, }, Arguments: []cmdkit.Argument{ cmdkit.StringArg("ref", true, false, "The object to get").EnableStdin(), }, Run: func(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment) error { nd, err := cmdenv.GetNode(env) if err != nil { return err } p, err := path.ParsePath(req.Arguments[0]) if err != nil { return err } lastCid, rem, err := nd.Resolver.ResolveToLastNode(req.Context, p) if err != nil { return err } obj, err := nd.DAG.Get(req.Context, lastCid) if err != nil { return err } var out interface{} = obj if len(rem) > 0 { final, _, err := obj.Resolve(rem) if err != nil { return err } out = final } return cmds.EmitOnce(res, &out) }, }
View Source
var DagPutCmd = &cmds.Command{ Helptext: cmdkit.HelpText{ Tagline: "Add a dag node to ipfs.", ShortDescription: ` 'ipfs dag put' accepts input from a file or stdin and parses it into an object of the specified format. `, }, Arguments: []cmdkit.Argument{ cmdkit.FileArg("object data", true, true, "The object to put").EnableStdin(), }, Options: []cmdkit.Option{ cmdkit.StringOption("format", "f", "Format that the object will be added as.").WithDefault("cbor"), cmdkit.StringOption("input-enc", "Format that the input object will be.").WithDefault("json"), cmdkit.BoolOption("pin", "Pin this object when adding."), cmdkit.StringOption("hash", "Hash function to use").WithDefault(""), }, Run: func(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment) error { nd, err := cmdenv.GetNode(env) if err != nil { return err } ienc, _ := req.Options["input-enc"].(string) format, _ := req.Options["format"].(string) hash, _ := req.Options["hash"].(string) dopin, _ := req.Options["pin"].(bool) mhType := uint64(math.MaxUint64) if hash != "" { var ok bool mhType, ok = mh.Names[hash] if !ok { return fmt.Errorf("%s in not a valid multihash name", hash) } } cids := cid.NewSet() b := ipld.NewBatch(req.Context, nd.DAG) if dopin { defer nd.Blockstore.PinLock().Unlock() } it := req.Files.Entries() for it.Next() { file := files.FileFromEntry(it) if file == nil { return fmt.Errorf("expected a regular file") } nds, err := coredag.ParseInputs(ienc, format, file, mhType, -1) if err != nil { return err } if len(nds) == 0 { return fmt.Errorf("no node returned from ParseInputs") } for _, nd := range nds { err := b.Add(req.Context, nd) if err != nil { return err } } cid := nds[0].Cid() cids.Add(cid) if err := res.Emit(&OutputObject{Cid: cid}); err != nil { return err } } if it.Err() != nil { return it.Err() } if err := b.Commit(); err != nil { return err } if dopin { cids.ForEach(func(c cid.Cid) error { nd.Pinning.PinWithMode(c, pin.Recursive) return nil }) err := nd.Pinning.Flush() if err != nil { return err } } return nil }, Type: OutputObject{}, Encoders: cmds.EncoderMap{ cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *OutputObject) error { fmt.Fprintln(w, out.Cid.String()) return nil }), }, }
View Source
var DagResolveCmd = &cmds.Command{ Helptext: cmdkit.HelpText{ Tagline: "Resolve ipld block", ShortDescription: ` 'ipfs dag resolve' fetches a dag node from ipfs, prints it's address and remaining path. `, }, Arguments: []cmdkit.Argument{ cmdkit.StringArg("ref", true, false, "The path to resolve").EnableStdin(), }, Run: func(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment) error { nd, err := cmdenv.GetNode(env) if err != nil { return err } p, err := path.ParsePath(req.Arguments[0]) if err != nil { return err } lastCid, rem, err := nd.Resolver.ResolveToLastNode(req.Context, p) if err != nil { return err } return cmds.EmitOnce(res, &ResolveOutput{ Cid: lastCid, RemPath: path.Join(rem), }) }, Encoders: cmds.EncoderMap{ cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *ResolveOutput) error { p := out.Cid.String() if out.RemPath != "" { p = path.Join([]string{p, out.RemPath}) } fmt.Fprint(w, p) return nil }), }, Type: ResolveOutput{}, }
DagResolveCmd returns address of highest block within a path and a path remainder
Functions ¶
This section is empty.
Types ¶
type OutputObject ¶
OutputObject is the output type of 'dag put' command
type ResolveOutput ¶
ResolveOutput is the output type of 'dag resolve' command
Click to show internal directories.
Click to hide internal directories.