138 lines
3.2 KiB
Go
138 lines
3.2 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"encoding/hex"
|
|
"fmt"
|
|
"os"
|
|
"text/tabwriter"
|
|
|
|
"github.com/ipfs/go-cid"
|
|
cbor "github.com/ipfs/go-ipld-cbor"
|
|
"github.com/ipld/go-car"
|
|
mh "github.com/multiformats/go-multihash"
|
|
"github.com/urfave/cli/v2"
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/go-state-types/abi"
|
|
|
|
"github.com/filecoin-project/lotus/blockstore"
|
|
"github.com/filecoin-project/lotus/chain/actors"
|
|
"github.com/filecoin-project/lotus/chain/actors/adt"
|
|
)
|
|
|
|
var cidCmd = &cli.Command{
|
|
Name: "cid",
|
|
Usage: "Cid command",
|
|
Subcommands: cli.Commands{
|
|
cidIdCmd,
|
|
inspectBundleCmd,
|
|
},
|
|
}
|
|
|
|
var cidIdCmd = &cli.Command{
|
|
Name: "id",
|
|
Usage: "Create identity CID from hex or base64 data",
|
|
ArgsUsage: "[data]",
|
|
Flags: []cli.Flag{
|
|
&cli.StringFlag{
|
|
Name: "encoding",
|
|
Aliases: []string{"e"},
|
|
Value: "base64",
|
|
Usage: "specify input encoding to parse",
|
|
},
|
|
&cli.StringFlag{
|
|
Name: "codec",
|
|
Value: "id",
|
|
Usage: "multicodec-packed content types: abi or id",
|
|
},
|
|
},
|
|
Action: func(cctx *cli.Context) error {
|
|
if !cctx.Args().Present() {
|
|
return fmt.Errorf("must specify data")
|
|
}
|
|
|
|
var dec []byte
|
|
switch cctx.String("encoding") {
|
|
case "base64":
|
|
data, err := base64.StdEncoding.DecodeString(cctx.Args().First())
|
|
if err != nil {
|
|
return xerrors.Errorf("decoding base64 value: %w", err)
|
|
}
|
|
dec = data
|
|
case "hex", "x":
|
|
data, err := hex.DecodeString(cctx.Args().First())
|
|
if err != nil {
|
|
return xerrors.Errorf("decoding hex value: %w", err)
|
|
}
|
|
dec = data
|
|
case "raw", "r":
|
|
dec = []byte(cctx.Args().First())
|
|
default:
|
|
return xerrors.Errorf("unrecognized encoding: %s", cctx.String("encoding"))
|
|
}
|
|
|
|
switch cctx.String("codec") {
|
|
case "abi":
|
|
aCid, err := abi.CidBuilder.Sum(dec)
|
|
if err != nil {
|
|
return xerrors.Errorf("cidBuilder abi: %w", err)
|
|
}
|
|
fmt.Println(aCid)
|
|
case "id":
|
|
builder := cid.V1Builder{Codec: cid.Raw, MhType: mh.IDENTITY}
|
|
rCid, err := builder.Sum(dec)
|
|
if err != nil {
|
|
return xerrors.Errorf("cidBuilder raw: %w", err)
|
|
}
|
|
fmt.Println(rCid)
|
|
default:
|
|
return xerrors.Errorf("unrecognized codec: %s", cctx.String("codec"))
|
|
}
|
|
|
|
return nil
|
|
},
|
|
}
|
|
|
|
var inspectBundleCmd = &cli.Command{
|
|
Name: "inspect-bundle",
|
|
Usage: "Get the manifest CID from a car file, as well as the actor code CIDs",
|
|
ArgsUsage: "[path]",
|
|
Action: func(cctx *cli.Context) error {
|
|
ctx := cctx.Context
|
|
|
|
cf := cctx.Args().Get(0)
|
|
f, err := os.OpenFile(cf, os.O_RDONLY, 0664)
|
|
if err != nil {
|
|
return xerrors.Errorf("opening the car file: %w", err)
|
|
}
|
|
|
|
bs := blockstore.NewMemory()
|
|
wrapBs := adt.WrapStore(ctx, cbor.NewCborStore(bs))
|
|
|
|
hdr, err := car.LoadCar(ctx, bs, f)
|
|
if err != nil {
|
|
return xerrors.Errorf("error loading car file: %w", err)
|
|
}
|
|
|
|
manifestCid := hdr.Roots[0]
|
|
|
|
fmt.Printf("Manifest CID: %s\n", manifestCid.String())
|
|
|
|
entries, err := actors.ReadManifest(ctx, wrapBs, manifestCid)
|
|
if err != nil {
|
|
return xerrors.Errorf("error loading manifest: %w", err)
|
|
}
|
|
|
|
tw := tabwriter.NewWriter(os.Stdout, 2, 4, 2, ' ', 0)
|
|
_, _ = fmt.Fprintln(tw, "\nActor\tCID\t")
|
|
|
|
for name, cid := range entries {
|
|
_, _ = fmt.Fprintf(tw, "%v\t%v\n", name, cid)
|
|
|
|
}
|
|
|
|
return tw.Flush()
|
|
},
|
|
}
|