Merge pull request #5549 from filecoin-project/feat/cli-pending-publish

Output more info in pending-publish CLI

cmd/lotus-storage-miner/market.go

@@ -858,18 +858,26 @@ var dealsPendingPublish = &cli.Command{
 			return xerrors.Errorf("getting pending deals: %w", err)
 		}
 
-		w := tabwriter.NewWriter(os.Stdout, 2, 4, 2, ' ', 0)
-		_, _ = fmt.Fprintf(w, "ProposalCID\tClient\tSize\n")
+		if len(pending.Deals) > 0 {
+			endsIn := pending.PublishPeriodStart.Add(pending.PublishPeriod).Sub(time.Now())
+			w := tabwriter.NewWriter(os.Stdout, 2, 4, 2, ' ', 0)
+			_, _ = fmt.Fprintf(w, "Publish period:             %s (ends in %s)\n", pending.PublishPeriod, endsIn.Round(time.Second))
+			_, _ = fmt.Fprintf(w, "First deal queued at:       %s\n", pending.PublishPeriodStart)
+			_, _ = fmt.Fprintf(w, "Deals will be published at: %s\n", pending.PublishPeriodStart.Add(pending.PublishPeriod))
+			_, _ = fmt.Fprintf(w, "%d deals queued to be published:\n", len(pending.Deals))
+			_, _ = fmt.Fprintf(w, "ProposalCID\tClient\tSize\n")
+			for _, deal := range pending.Deals {
+				proposalNd, err := cborutil.AsIpld(&deal) // nolint
+				if err != nil {
+					return err
+				}
 
-		for _, deal := range pending.Deals {
-			proposalNd, err := cborutil.AsIpld(&deal) // nolint
-			if err != nil {
-				return err
+				_, _ = fmt.Fprintf(w, "%s\t%s\t%s\n", proposalNd.Cid(), deal.Proposal.Client, units.BytesSize(float64(deal.Proposal.PieceSize)))
 			}
-
-			_, _ = fmt.Fprintf(w, "%s\t%s\t%s\n", proposalNd.Cid(), deal.Proposal.Client, units.BytesSize(float64(deal.Proposal.PieceSize)))
+			return w.Flush()
 		}
 
-		return w.Flush()
+		fmt.Println("No deals queued to be published")
+		return nil
 	},
 }