mirror of
https://github.com/filecoin-project/lotus.git
synced 2025-08-24 01:08:42 +08:00
f13dace466
* feat: add settle deal command for lotus miner [WIP] * feat: allow settlement of all deals for the miner and fix ci jobs * fix: address comments * fix: address comment
42 lines
931 B
Go
42 lines
931 B
Go
package spcli
|
|
|
|
import (
|
|
"context"
|
|
"strconv"
|
|
|
|
"github.com/urfave/cli/v2"
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/go-address"
|
|
|
|
"github.com/filecoin-project/lotus/api"
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
)
|
|
|
|
type ActorAddressGetter func(cctx *cli.Context) (address address.Address, err error)
|
|
|
|
// GetMinerAllDeals returns all deals for a miner
|
|
func GetMinerAllDeals(ctx context.Context, full api.FullNode, maddr address.Address, key types.TipSetKey) (dealIDs []uint64, err error) {
|
|
allDeals, err := full.StateMarketDeals(ctx, key)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// filter the deals for the miner
|
|
var dealId uint64
|
|
for k, d := range allDeals {
|
|
if d.Proposal.Provider != maddr {
|
|
continue
|
|
}
|
|
|
|
dealId, err = strconv.ParseUint(k, 10, 64)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("Error parsing deal id: %w", err)
|
|
}
|
|
|
|
dealIDs = append(dealIDs, dealId)
|
|
}
|
|
|
|
return dealIDs, nil
|
|
}
|