add deal state iterator
This commit is contained in:
parent
2967c4ec10
commit
46fb0e74cd
@ -50,6 +50,7 @@ type BalanceTable interface {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type DealStates interface {
|
type DealStates interface {
|
||||||
|
ForEach(cb func(id abi.DealID, ds DealState) error) error
|
||||||
Get(id abi.DealID) (*DealState, bool, error)
|
Get(id abi.DealID) (*DealState, bool, error)
|
||||||
|
|
||||||
array() adt.Array
|
array() adt.Array
|
||||||
|
@ -126,6 +126,13 @@ func (s *dealStates0) Get(dealID abi.DealID) (*DealState, bool, error) {
|
|||||||
return &deal, true, nil
|
return &deal, true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *dealStates0) ForEach(cb func(dealID abi.DealID, ds DealState) error) error {
|
||||||
|
var ds0 market.DealState
|
||||||
|
return s.Array.ForEach(&ds0, func(idx int64) error {
|
||||||
|
return cb(abi.DealID(idx), fromV0DealState(ds0))
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
func (s *dealStates0) decode(val *cbg.Deferred) (*DealState, error) {
|
func (s *dealStates0) decode(val *cbg.Deferred) (*DealState, error) {
|
||||||
var ds0 market.DealState
|
var ds0 market.DealState
|
||||||
if err := ds0.UnmarshalCBOR(bytes.NewReader(val.Raw)); err != nil {
|
if err := ds0.UnmarshalCBOR(bytes.NewReader(val.Raw)); err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user