package datacap import ( verifreg9 "github.com/filecoin-project/go-state-types/builtin/v9/verifreg" "golang.org/x/xerrors" "github.com/filecoin-project/go-address" "github.com/filecoin-project/go-state-types/abi" "github.com/filecoin-project/go-state-types/big" "github.com/filecoin-project/lotus/chain/actors" "github.com/filecoin-project/lotus/chain/actors/adt" ) // taking this as a function instead of asking the caller to call it helps reduce some of the error // checking boilerplate. // // "go made me do it" type rootFunc func() (adt.Map, error) func getDataCap(store adt.Store, ver actors.Version, root rootFunc, addr address.Address) (bool, abi.StoragePower, error) { if addr.Protocol() != address.ID { return false, big.Zero(), xerrors.Errorf("can only look up ID addresses") } vh, err := root() if err != nil { return false, big.Zero(), xerrors.Errorf("loading datacap actor: %w", err) } var dcap abi.StoragePower if found, err := vh.Get(abi.IdAddrKey(addr), &dcap); err != nil { return false, big.Zero(), xerrors.Errorf("looking up addr: %w", err) } else if !found { return false, big.Zero(), nil } return true, big.Div(dcap, verifreg9.DataCapGranularity), nil } func forEachCap(store adt.Store, ver actors.Version, root rootFunc, cb func(addr address.Address, dcap abi.StoragePower) error) error { vh, err := root() if err != nil { return xerrors.Errorf("loading verified clients: %w", err) } var dcap abi.StoragePower return vh.ForEach(&dcap, func(key string) error { a, err := address.NewFromBytes([]byte(key)) if err != nil { return err } return cb(a, big.Div(dcap, verifreg9.DataCapGranularity)) }) }