package verifreg import ( "github.com/filecoin-project/go-address" "github.com/filecoin-project/go-state-types/abi" "github.com/ipfs/go-cid" "github.com/filecoin-project/lotus/chain/actors" "github.com/filecoin-project/lotus/chain/actors/adt" "golang.org/x/xerrors" {{if (le .v 7)}} {{if (ge .v 3)}} builtin{{.v}} "github.com/filecoin-project/specs-actors{{.import}}actors/builtin" {{end}} verifreg{{.v}} "github.com/filecoin-project/specs-actors{{.import}}actors/builtin/verifreg" adt{{.v}} "github.com/filecoin-project/specs-actors{{.import}}actors/util/adt" {{else}} verifreg{{.v}} "github.com/filecoin-project/go-state-types/builtin{{.import}}verifreg" adt{{.v}} "github.com/filecoin-project/go-state-types/builtin{{.import}}util/adt" builtin{{.v}} "github.com/filecoin-project/go-state-types/builtin" {{end}} {{if (ge .v 9)}} "github.com/filecoin-project/go-state-types/big" {{else}} verifreg9 "github.com/filecoin-project/go-state-types/builtin/v9/verifreg" {{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, rootKeyAddress address.Address) (State, error) { out := state{{.v}}{store: store} {{if (le .v 2)}} em, err := adt{{.v}}.MakeEmptyMap(store).Root() if err != nil { return nil, err } out.State = *verifreg{{.v}}.ConstructState(em, rootKeyAddress) {{else}} s, err := verifreg{{.v}}.ConstructState(store, rootKeyAddress) if err != nil { return nil, err } out.State = *s {{end}} return &out, nil } type state{{.v}} struct { verifreg{{.v}}.State store adt.Store } func (s *state{{.v}}) RootKey() (address.Address, error) { return s.State.RootKey, nil } func (s *state{{.v}}) VerifiedClientDataCap(addr address.Address) (bool, abi.StoragePower, error) { {{if (le .v 8)}} return getDataCap(s.store, actors.Version{{.v}}, s.verifiedClients, addr) {{else}} return false, big.Zero(), xerrors.Errorf("unsupported in actors v{{.v}}") {{end}} } func (s *state{{.v}}) VerifierDataCap(addr address.Address) (bool, abi.StoragePower, error) { return getDataCap(s.store, actors.Version{{.v}}, s.verifiers, addr) } func (s *state{{.v}}) RemoveDataCapProposalID(verifier address.Address, client address.Address) (bool, uint64, error) { return getRemoveDataCapProposalID(s.store, actors.Version{{.v}}, s.removeDataCapProposalIDs, verifier, client) } func (s *state{{.v}}) ForEachVerifier(cb func(addr address.Address, dcap abi.StoragePower) error) error { return forEachCap(s.store, actors.Version{{.v}}, s.verifiers, cb) } func (s *state{{.v}}) ForEachClient(cb func(addr address.Address, dcap abi.StoragePower) error) error { {{if (le .v 8)}} return forEachCap(s.store, actors.Version{{.v}}, s.verifiedClients, cb) {{else}} return xerrors.Errorf("unsupported in actors v{{.v}}") {{end}} } func (s *state{{.v}}) verifiedClients() (adt.Map, error) { {{if (le .v 8)}} return adt{{.v}}.AsMap(s.store, s.VerifiedClients{{if (ge .v 3)}}, builtin{{.v}}.DefaultHamtBitwidth{{end}}) {{else}} return nil, xerrors.Errorf("unsupported in actors v{{.v}}") {{end}} } func (s *state{{.v}}) verifiers() (adt.Map, error) { return adt{{.v}}.AsMap(s.store, s.Verifiers{{if (ge .v 3)}}, builtin{{.v}}.DefaultHamtBitwidth{{end}}) } func (s *state{{.v}}) removeDataCapProposalIDs() (adt.Map, error) { {{if le .v 6}}return nil, nil {{else}}return adt{{.v}}.AsMap(s.store, s.RemoveDataCapProposalIDs, builtin{{.v}}.DefaultHamtBitwidth){{end}} } func (s *state{{.v}}) GetState() interface{} { return &s.State } func (s *state{{.v}}) GetAllocation(clientIdAddr address.Address, allocationId verifreg9.AllocationId) (*verifreg9.Allocation, bool, error) { {{if (le .v 8)}} return nil, false, xerrors.Errorf("unsupported in actors v{{.v}}") {{else}} return s.FindAllocation(s.store, clientIdAddr, allocationId) {{end}} } func (s *state{{.v}}) GetAllocations(clientIdAddr address.Address) (map[verifreg9.AllocationId]verifreg9.Allocation, error) { {{if (le .v 8)}} return nil, xerrors.Errorf("unsupported in actors v{{.v}}") {{else}} return s.LoadAllocationsToMap(s.store, clientIdAddr) {{end}} } func (s *state{{.v}}) GetClaim(providerIdAddr address.Address, claimId verifreg9.ClaimId) (*verifreg9.Claim, bool, error) { {{if (le .v 8)}} return nil, false, xerrors.Errorf("unsupported in actors v{{.v}}") {{else}} return s.FindClaim(s.store, providerIdAddr, claimId) {{end}} } func (s *state{{.v}}) GetClaims(providerIdAddr address.Address) (map[verifreg9.ClaimId]verifreg9.Claim, error) { {{if (le .v 8)}} return nil, xerrors.Errorf("unsupported in actors v{{.v}}") {{else}} return s.LoadClaimsToMap(s.store, providerIdAddr) {{end}} }