feat: add proving deadline option view live sectors information

cmd/lotus-miner/proving.go

@@ -197,6 +197,14 @@ var provingInfoCmd = &cli.Command{
 var provingDeadlinesCmd = &cli.Command{
 	Name:  "deadlines",
 	Usage: "View the current proving period deadlines information",
+	Flags: []cli.Flag{
+		&cli.BoolFlag{
+			Name:    "live",
+			Usage:   "View live deadlines information",
+			Value:   false,
+			Aliases: []string{"l"},
+		},
+	},
 	Action: func(cctx *cli.Context) error {
 		api, acloser, err := lcli.GetFullNodeAPI(cctx)
 		if err != nil {
@@ -239,28 +247,53 @@ var provingDeadlinesCmd = &cli.Command{
 
 			sectors := uint64(0)
 			faults := uint64(0)
+			var PartitionSum int
 
-			for _, partition := range partitions {
-				sc, err := partition.AllSectors.Count()
-				if err != nil {
-					return err
-				}
+			if cctx.Bool("live") {
+				for _, partition := range partitions {
+					sc, err := partition.LiveSectors.Count()
+					if err != nil {
+						return err
+					}
 
-				sectors += sc
+					if sc > 0 {
+						PartitionSum++
+					}
+
+					sectors += sc
+
+					fc, err := partition.FaultySectors.Count()
+					if err != nil {
+						return err
+					}
+
+					faults += fc
 
-				fc, err := partition.FaultySectors.Count()
-				if err != nil {
-					return err
 				}
+			} else {
+				for _, partition := range partitions {
+					PartitionSum++
 
-				faults += fc
-			}
+					sc, err := partition.AllSectors.Count()
+					if err != nil {
+						return err
+					}
+
+					sectors += sc
+
+					fc, err := partition.FaultySectors.Count()
+					if err != nil {
+						return err
+					}
 
+					faults += fc
+				}
+			}
 			var cur string
 			if di.Index == uint64(dlIdx) {
 				cur += "\t(current)"
 			}
-			_, _ = fmt.Fprintf(tw, "%d\t%d\t%d (%d)\t%d%s\n", dlIdx, len(partitions), sectors, faults, provenPartitions, cur)
+			_, _ = fmt.Fprintf(tw, "%d\t%d\t%d (%d)\t%d%s\n", dlIdx, PartitionSum, sectors, faults, provenPartitions, cur)
 		}
 
 		return tw.Flush()
@@ -271,6 +304,14 @@ var provingDeadlineInfoCmd = &cli.Command{
 	Name:      "deadline",
 	Usage:     "View the current proving period deadline information by its index ",
 	ArgsUsage: "<deadlineIdx>",
+	Flags: []cli.Flag{
+		&cli.BoolFlag{
+			Name:    "live",
+			Usage:   "View deadline live sectors",
+			Value:   false,
+			Aliases: []string{"l"},
+		},
+	},
 	Action: func(cctx *cli.Context) error {
 
 		if cctx.Args().Len() != 1 {
@@ -320,33 +361,64 @@ var provingDeadlineInfoCmd = &cli.Command{
 		fmt.Printf("Proven Partitions:        %d\n", provenPartitions)
 		fmt.Printf("Current:                  %t\n\n", di.Index == dlIdx)
 
-		for pIdx, partition := range partitions {
-			sectorCount, err := partition.AllSectors.Count()
-			if err != nil {
-				return err
-			}
+		if !cctx.Bool("live") {
+			for pIdx, partition := range partitions {
+				sectorCount, err := partition.AllSectors.Count()
+				if err != nil {
+					return err
+				}
 
-			sectorNumbers, err := partition.AllSectors.All(sectorCount)
-			if err != nil {
-				return err
-			}
+				sectorNumbers, err := partition.AllSectors.All(sectorCount)
+				if err != nil {
+					return err
+				}
 
-			faultsCount, err := partition.FaultySectors.Count()
-			if err != nil {
-				return err
-			}
+				faultsCount, err := partition.FaultySectors.Count()
+				if err != nil {
+					return err
+				}
 
-			fn, err := partition.FaultySectors.All(faultsCount)
-			if err != nil {
-				return err
+				fn, err := partition.FaultySectors.All(faultsCount)
+				if err != nil {
+					return err
+				}
+
+				fmt.Printf("Partition Index:          %d\n", pIdx)
+				fmt.Printf("Sectors:                  %d\n", sectorCount)
+				fmt.Printf("Sector Numbers:           %v\n", sectorNumbers)
+				fmt.Printf("Faults:                   %d\n", faultsCount)
+				fmt.Printf("Faulty Sectors:           %d\n", fn)
 			}
+		} else {
+			for pIdx, partition := range partitions {
+				sectorCount, err := partition.LiveSectors.Count()
+				if err != nil {
+					return err
+				}
 
-			fmt.Printf("Partition Index:          %d\n", pIdx)
-			fmt.Printf("Sectors:                  %d\n", sectorCount)
-			fmt.Printf("Sector Numbers:           %v\n", sectorNumbers)
-			fmt.Printf("Faults:                   %d\n", faultsCount)
-			fmt.Printf("Faulty Sectors:           %d\n", fn)
+				sectorNumbers, err := partition.LiveSectors.All(sectorCount)
+				if err != nil {
+					return err
+				}
+
+				faultsCount, err := partition.FaultySectors.Count()
+				if err != nil {
+					return err
+				}
+
+				fn, err := partition.FaultySectors.All(faultsCount)
+				if err != nil {
+					return err
+				}
+
+				fmt.Printf("Partition Index:          %d\n", pIdx)
+				fmt.Printf("Sectors:                  %d\n", sectorCount)
+				fmt.Printf("Sector Numbers:           %v\n", sectorNumbers)
+				fmt.Printf("Faults:                   %d\n", faultsCount)
+				fmt.Printf("Faulty Sectors:           %d\n", fn)
+			}
 		}
+
 		return nil
 	},
 }