cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

state replay: find correct tipset

Browse Source
This commit is contained in:
Łukasz Magiera 2020-02-22 14:31:13 +01:00
parent b8428423a1
commit 03b8ab724a
1 changed files with 34 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
cli/state.go
View File

@ -218,8 +218,8 @@ var stateReplaySetCmd = &cli.Command{
Name: "replay", Name: "replay",
Usage: "Replay a particular message within a tipset", Usage: "Replay a particular message within a tipset",
Action: func(cctx *cli.Context) error { Action: func(cctx *cli.Context) error {
if cctx.Args().Len() < 2 { if cctx.Args().Len() < 1 {
fmt.Println("usage: <tipset> <message cid>") fmt.Println("usage: [tipset] <message cid>")
fmt.Println("The last cid passed will be used as the message CID") fmt.Println("The last cid passed will be used as the message CID")
fmt.Println("All preceding ones will be used as the tipset") fmt.Println("All preceding ones will be used as the tipset")
return nil return nil
@ -231,15 +231,6 @@ var stateReplaySetCmd = &cli.Command{
return fmt.Errorf("message cid was invalid: %s", err) return fmt.Errorf("message cid was invalid: %s", err)
} }
var tscids []cid.Cid
for _, s := range args[:len(args)-1] {
c, err := cid.Decode(s)
if err != nil {
return fmt.Errorf("tipset cid was invalid: %s", err)
}
tscids = append(tscids, c)
}
api, closer, err := GetFullNodeAPI(cctx) api, closer, err := GetFullNodeAPI(cctx)
if err != nil { if err != nil {
return err return err
@ -248,20 +239,44 @@ var stateReplaySetCmd = &cli.Command{
ctx := ReqContext(cctx) ctx := ReqContext(cctx)
var headers []*types.BlockHeader var ts *types.TipSet
for _, c := range tscids { {
h, err := api.ChainGetBlock(ctx, c) var tscids []cid.Cid
for _, s := range args[:len(args)-1] {
c, err := cid.Decode(s)
if err != nil {
return fmt.Errorf("tipset cid was invalid: %s", err)
}
tscids = append(tscids, c)
}
if len(tscids) > 0 {
var headers []*types.BlockHeader
for _, c := range tscids {
h, err := api.ChainGetBlock(ctx, c)
if err != nil {
return err
}
headers = append(headers, h)
}
ts, err = types.NewTipSet(headers)
} else {
r, err := api.StateWaitMsg(ctx, mcid)
if err != nil {
return xerrors.Errorf("finding message in chain: %w", err)
}
ts, err = api.ChainGetTipSet(ctx, r.TipSet.Parents())
}
if err != nil { if err != nil {
return err return err
} }
headers = append(headers, h)
} }
ts, err := types.NewTipSet(headers)
if err != nil {
return err
}
res, err := api.StateReplay(ctx, ts, mcid) res, err := api.StateReplay(ctx, ts, mcid)
if err != nil { if err != nil {