feat: add settle-deal to lotus-shed

Author: beck-8

CHANGELOG.md

@@ -31,6 +31,7 @@
   - default to ProveCommit aggregation
   - remove config options: AggregateCommits, AggregateAboveBaseFee, BatchPreCommitAboveBaseFee
 - feat(paych): add EnablePaymentChannelManager config option and disable payment channel manager by default ([filecoin-project/lotus#13139](https://github.com/filecoin-project/lotus/pull/13139))
+- feat: add `lotus-shed market settle-deal` CLI command
 
 # Node v1.33.0 / 2025-05-08
 The Lotus v1.33.0 release introduces experimental v2 APIs with F3 awareness, featuring a new TipSet selection mechanism that significantly enhances how applications interact with the Filecoin blockchain. This release candidate also adds F3-aware Ethereum APIs via the /v2 endpoint.  All of the /v2 APIs implement intelligent fallback mechanisms between F3 and Expected Consensus and are exposed through the Lotus Gateway.

cmd/lotus-shed/market.go

@@ -6,27 +6,35 @@ import (
 	"fmt"
 	"os"
 	"path"
+	"strconv"
+	"strings"
 
 	"github.com/ipfs/go-datastore"
 	dsq "github.com/ipfs/go-datastore/query"
 	levelds "github.com/ipfs/go-ds-leveldb"
 	ipldcbor "github.com/ipfs/go-ipld-cbor"
 	logging "github.com/ipfs/go-log/v2"
+	"github.com/samber/lo"
 	ldbopts "github.com/syndtr/goleveldb/leveldb/opt"
 	"github.com/urfave/cli/v2"
 	cbg "github.com/whyrusleeping/cbor-gen"
+	"golang.org/x/sync/errgroup"
 	"golang.org/x/xerrors"
 
 	"github.com/filecoin-project/go-address"
+	"github.com/filecoin-project/go-bitfield"
 	"github.com/filecoin-project/go-state-types/abi"
 	"github.com/filecoin-project/go-state-types/big"
 	"github.com/filecoin-project/go-state-types/builtin"
 	market14 "github.com/filecoin-project/go-state-types/builtin/v14/market"
 	"github.com/filecoin-project/go-state-types/builtin/v14/util/adt"
 
+	"github.com/filecoin-project/lotus/chain/actors"
 	"github.com/filecoin-project/lotus/chain/actors/builtin/market"
+	marketactor "github.com/filecoin-project/lotus/chain/actors/builtin/market"
 	"github.com/filecoin-project/lotus/chain/types"
 	lcli "github.com/filecoin-project/lotus/cli"
+	"github.com/filecoin-project/lotus/cli/spcli"
 	"github.com/filecoin-project/lotus/lib/backupds"
 	"github.com/filecoin-project/lotus/node/repo"
 )
@@ -41,6 +49,7 @@ var marketCmd = &cli.Command{
 		marketImportDatastoreCmd,
 		marketDealsTotalStorageCmd,
 		marketCronStateCmd,
+		marketDealSettlementCmd,
 	},
 }
 
@@ -426,3 +435,142 @@ func openLockedRepo(path string) (repo.LockedRepo, error) {
 
 	return lr, nil
 }
+
+var marketDealSettlementCmd = &cli.Command{
+	Name:      "settle-deal",
+	Usage:     "Settle deals manually, if dealIds are not provided all deals will be settled. Deal IDs can be specified as individual numbers or ranges (e.g., '123 124 125-200 220')",
+	ArgsUsage: "[...dealIds]",
+	Flags: []cli.Flag{
+		&cli.StringFlag{
+			Name:  "miner",
+			Usage: "specify the miner address",
+		},
+		&cli.StringFlag{
+			Name:     "from",
+			Usage:    "specify where to send the message from (any address)",
+			Required: true,
+		},
+		&cli.IntFlag{
+			Name:  "concurrent",
+			Usage: "specify the number of concurrent messages to send",
+			Value: 1,
+		},
+		&cli.IntFlag{
+			Name:  "max-deals",
+			Usage: "the maximum number of deals contained in each message",
+			Value: 500,
+		},
+	},
+
+	Action: func(cctx *cli.Context) error {
+		api, acloser, err := lcli.GetFullNodeAPIV1(cctx)
+		if err != nil {
+			return err
+		}
+		defer acloser()
+
+		ctx := lcli.ReqContext(cctx)
+
+		fromAddr, err := address.NewFromString(cctx.String("from"))
+		if err != nil {
+			return err
+		}
+		var maddr address.Address
+		if len(cctx.Args().Slice()) == 0 && !cctx.IsSet("miner") {
+			return xerrors.Errorf("If the dealIds is not provided, you must set the --miner")
+		} else {
+			maddr, err = address.NewFromString(cctx.String("miner"))
+			if err != nil {
+				return err
+			}
+		}
+
+		var (
+			dealIDs []uint64
+			dealId  uint64
+		)
+
+		// if no deal ids are provided, get all the deals for the miner
+		if dealsIdArgs := cctx.Args().Slice(); len(dealsIdArgs) != 0 {
+			for _, d := range dealsIdArgs {
+				// Check if it's a range (e.g., "125-200")
+				if strings.Contains(d, "-") {
+					parts := strings.Split(d, "-")
+					if len(parts) != 2 {
+						return xerrors.Errorf("Invalid range format: %s (expected format: start-end)", d)
+					}
+
+					start, err := strconv.ParseUint(strings.TrimSpace(parts[0]), 10, 64)
+					if err != nil {
+						return xerrors.Errorf("Error parsing start of range %s: %w", d, err)
+					}
+
+					end, err := strconv.ParseUint(strings.TrimSpace(parts[1]), 10, 64)
+					if err != nil {
+						return xerrors.Errorf("Error parsing end of range %s: %w", d, err)
+					}
+
+					if start > end {
+						return xerrors.Errorf("Invalid range %s: start must be less than or equal to end", d)
+					}
+
+					// Add all deal IDs in the range (inclusive)
+					for id := start; id <= end; id++ {
+						dealIDs = append(dealIDs, id)
+					}
+				} else {
+					// Parse as a single deal ID
+					dealId, err = strconv.ParseUint(d, 10, 64)
+					if err != nil {
+						return xerrors.Errorf("Error parsing deal id: %w", err)
+					}
+
+					dealIDs = append(dealIDs, dealId)
+				}
+			}
+		} else {
+			if dealIDs, err = spcli.GetMinerAllDeals(ctx, api, maddr, types.EmptyTSK); err != nil {
+				return xerrors.Errorf("Error getting all deals for miner: %w", err)
+			}
+		}
+
+		dealChucks := lo.Chunk(dealIDs, cctx.Int("max-deals"))
+		g, ctx := errgroup.WithContext(ctx)
+		g.SetLimit(cctx.Int("concurrent"))
+
+		for _, deals := range dealChucks {
+			deals := deals
+			g.Go(func() error {
+				dealParams := bitfield.NewFromSet(deals)
+				var err error
+				params, err := actors.SerializeParams(&dealParams)
+				if err != nil {
+					return err
+				}
+
+				smsg, err := api.MpoolPushMessage(ctx, &types.Message{
+					To:     marketactor.Address,
+					From:   fromAddr,
+					Value:  types.NewInt(0),
+					Method: marketactor.Methods.SettleDealPaymentsExported,
+					Params: params,
+				}, nil)
+				if err != nil {
+					return err
+				}
+
+				res := smsg.Cid()
+
+				fmt.Printf("Requested deal settlement in message: %s\n", res)
+				return nil
+			})
+
+		}
+		err = g.Wait()
+		if err != nil {
+			return err
+		}
+
+		return nil
+	},
+}