feat(spcli): add --all-deals to lotus-miner actor settle-deal (#13243)

* add --all-deals to `lotus-miner actor settle-deal`

* update CHANGELOG.md

Author: beck-8

CHANGELOG.md

@@ -44,6 +44,7 @@ This is the Lotus v1.33.1 release, which introduces performance improvements and
 - chore: bump the pubsub validation queue length to 256 ([filecoin-project/lotus#13176](https://github.com/filecoin-project/lotus/pull/13176))
 - chore(deps): update of critical underlying dependencies with go-libp2p to v0.42.0 (filecoin-project/lotus#13190) and boxo to v0.32.0 ([filecoin-project/lotus#13202](https://github.com/filecoin-project/lotus/pull/13202)) and boxo v0.33.0([filecoin-project/lotus#13226](https://github.com/filecoin-project/lotus/pull/13226))
 - feat(spcli): correctly handle the batch logic of `lotus-miner actor settle-deal`; replace the dealid data source ([filecoin-project/lotus#13189](https://github.com/filecoin-project/lotus/pull/13189))
+- feat(spcli): add `--all-deals` to `lotus-miner actor settle-deal`. By default, only expired deals are processed ([filecoin-project/lotus#13243](https://github.com/filecoin-project/lotus/pull/13243))
 
 ## 📝 Changelog
 

cli/spcli/actor.go

@@ -65,6 +65,10 @@ func ActorDealSettlementCmd(getActor ActorAddressGetter) *cli.Command {
 				Name:  "skip-wait-msg",
 				Usage: "skip to check the message status",
 			},
+			&cli.BoolFlag{
+				Name:  "all-deals",
+				Usage: "settle all deals. only expired deals are calculated by default",
+			},
 			&cli.BoolFlag{
 				Name:  "really-do-it",
 				Usage: "Actually send transaction performing the action",
@@ -97,6 +101,12 @@ func ActorDealSettlementCmd(getActor ActorAddressGetter) *cli.Command {
 				}
 			}
 
+			head, err := api.ChainHead(ctx)
+			if err != nil {
+				return err
+			}
+			alldeals := cctx.Bool("all-deals")
+
 			var (
 				dealIDs []uint64
 				dealId  uint64
@@ -152,7 +162,13 @@ func ActorDealSettlementCmd(getActor ActorAddressGetter) *cli.Command {
 						return xerrors.Errorf("Error getting all deals for miner: %w", err)
 					}
 					for _, deal := range data {
-						dealIDs = append(dealIDs, uint64(deal))
+						marketDeal, err := api.StateMarketStorageDeal(ctx, deal, types.EmptyTSK)
+						if err != nil {
+							continue
+						}
+						if marketDeal.Proposal.EndEpoch < head.Height() || alldeals {
+							dealIDs = append(dealIDs, uint64(deal))
+						}
 					}
 				}
 			}