Method Run

cmd/super/dev/dig/frames/command.go:50–79

(args []string)

}

func (c *Command) Run(args []string) error {
	ctx, cleanup, err := c.Init(&c.outputFlags)
	if err != nil {
		return err
	}
	defer cleanup()
	if len(args) != 1 {
		return errors.New("a single file required")
	}
	uri, err := storage.ParseURI(args[0])
	if err != nil {
		return err
	}
	engine := storage.NewLocalEngine()
	r, err := engine.Get(ctx, uri)
	if err != nil {
		return err
	}
	defer r.Close()
	writer, err := c.outputFlags.Open(ctx, engine)
	if err != nil {
		return err
	}
	sctx := super.NewContext()
	meta := newMetaReader(sctx, r)
	if err := vio.Copy(writer, sbuf.NewDematerializer(sctx, sbuf.NewPuller(meta))); err != nil {
		return err
	}
	return writer.Close()
}

type metaReader struct {
	reader    *reader