package init import ( "crypto/sha256" "fmt" "github.com/filecoin-project/go-address" "github.com/filecoin-project/go-state-types/abi" "github.com/ipfs/go-cid" cbg "github.com/whyrusleeping/cbor-gen" "golang.org/x/xerrors" "github.com/filecoin-project/lotus/chain/actors" "github.com/filecoin-project/lotus/chain/actors/adt" actorstypes "github.com/filecoin-project/go-state-types/actors" "github.com/filecoin-project/lotus/node/modules/dtypes" "github.com/filecoin-project/go-state-types/manifest" {{if (le .v 7)}} {{if (ge .v 3)}} builtin{{.v}} "github.com/filecoin-project/specs-actors{{.import}}actors/builtin" {{end}} init{{.v}} "github.com/filecoin-project/specs-actors{{.import}}actors/builtin/init" adt{{.v}} "github.com/filecoin-project/specs-actors{{.import}}actors/util/adt" {{else}} init{{.v}} "github.com/filecoin-project/go-state-types/builtin{{.import}}init" adt{{.v}} "github.com/filecoin-project/go-state-types/builtin{{.import}}util/adt" builtin{{.v}} "github.com/filecoin-project/go-state-types/builtin" {{end}} ) var _ State = (*state{{.v}})(nil) func load{{.v}}(store adt.Store, root cid.Cid) (State, error) { out := state{{.v}}{store: store} err := store.Get(store.Context(), root, &out) if err != nil { return nil, err } return &out, nil } func make{{.v}}(store adt.Store, networkName string) (State, error) { out := state{{.v}}{store: store} {{if (le .v 2)}} mr, err := adt{{.v}}.MakeEmptyMap(store).Root() if err != nil { return nil, err } out.State = *init{{.v}}.ConstructState(mr, networkName) {{else}} s, err := init{{.v}}.ConstructState(store, networkName) if err != nil { return nil, err } out.State = *s {{end}} return &out, nil } type state{{.v}} struct { init{{.v}}.State store adt.Store } func (s *state{{.v}}) ResolveAddress(address address.Address) (address.Address, bool, error) { return s.State.ResolveAddress(s.store, address) } func (s *state{{.v}}) MapAddressToNewID(address address.Address) (address.Address, error) { return s.State.MapAddressToNewID(s.store, address) } func (s *state{{.v}}) ForEachActor(cb func(id abi.ActorID, address address.Address) error) error { addrs, err := adt{{.v}}.AsMap(s.store, s.State.AddressMap{{if (ge .v 3)}}, builtin{{.v}}.DefaultHamtBitwidth{{end}}) if err != nil { return err } var actorID cbg.CborInt return addrs.ForEach(&actorID, func(key string) error { addr, err := address.NewFromBytes([]byte(key)) if err != nil { return err } return cb(abi.ActorID(actorID), addr) }) } func (s *state{{.v}}) NetworkName() (dtypes.NetworkName, error) { return dtypes.NetworkName(s.State.NetworkName), nil } func (s *state{{.v}}) SetNetworkName(name string) error { s.State.NetworkName = name return nil } func (s *state{{.v}}) SetNextID(id abi.ActorID) error { s.State.NextID = id return nil } func (s *state{{.v}}) Remove(addrs ...address.Address) (err error) { m, err := adt{{.v}}.AsMap(s.store, s.State.AddressMap{{if (ge .v 3)}}, builtin{{.v}}.DefaultHamtBitwidth{{end}}) if err != nil { return err } for _, addr := range addrs { if err = m.Delete(abi.AddrKey(addr)); err != nil { return xerrors.Errorf("failed to delete entry for address: %s; err: %w", addr, err) } } amr, err := m.Root() if err != nil { return xerrors.Errorf("failed to get address map root: %w", err) } s.State.AddressMap = amr return nil } func (s *state{{.v}}) SetAddressMap(mcid cid.Cid) error { s.State.AddressMap = mcid return nil } func (s *state{{.v}}) GetState() interface{} { return &s.State } func (s *state{{.v}}) AddressMap() (adt.Map, error) { return adt{{.v}}.AsMap(s.store, s.State.AddressMap{{if (ge .v 3)}}, builtin{{.v}}.DefaultHamtBitwidth{{end}}) } func (s *state{{.v}}) AddressMapBitWidth() int { {{- if (ge .v 3)}} return builtin{{.v}}.DefaultHamtBitwidth {{- else}} return 5 {{- end}} } func (s *state{{.v}}) AddressMapHashFunction() func(input []byte) []byte { return func(input []byte) []byte { res := sha256.Sum256(input) return res[:] } } func (s *state{{.v}}) ActorKey() string { return manifest.InitKey } func (s *state{{.v}}) ActorVersion() actorstypes.Version { return actorstypes.Version{{.v}} } func (s *state{{.v}}) Code() cid.Cid { code, ok := actors.GetActorCodeID(s.ActorVersion(), s.ActorKey()) if !ok { panic(fmt.Errorf("didn't find actor %v code id for actor version %d", s.ActorKey(), s.ActorVersion())) } return code }