feat:sectors CLI to create a new sector

api/api_storage.go

@@ -67,6 +67,9 @@ type StorageMiner interface {
 	// sectors can be created.
 	SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPieceSize, r storage.Data, d PieceDealInfo) (SectorOffset, error) //perm:admin
 
+	// Add a new unassigned sector
+	SectorTryCreateNewSector(ctx context.Context) (abi.SectorNumber, error) //perm:admin
+
 	SectorsUnsealPiece(ctx context.Context, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize, randomness abi.SealRandomness, commd *cid.Cid) error //perm:admin
 
 	// List all staged sectors

cmd/lotus-miner/sectors.go

@@ -55,6 +55,7 @@ var sectorsCmd = &cli.Command{
 		sectorsSnapAbortCmd,
 		sectorsStartSealCmd,
 		sectorsSealDelayCmd,
+		sectorsNewSector,
 		sectorsCapacityCollateralCmd,
 		sectorsBatching,
 		sectorsRefreshPieceMatchingCmd,
@@ -1588,6 +1589,25 @@ var sectorsStartSealCmd = &cli.Command{
 	},
 }
 
+var sectorsNewSector = &cli.Command{
+	Name:  "new-sector",
+	Usage: "Manually create a new sector",
+	Action: func(cctx *cli.Context) error {
+		nodeApi, closer, err := lcli.GetStorageMinerAPI(cctx)
+		if err != nil {
+			return err
+		}
+		defer closer()
+		ctx := lcli.ReqContext(cctx)
+
+		sector, err := nodeApi.SectorTryCreateNewSector(ctx) //.SectorStartSealing(ctx, abi.SectorNumber(id))
+		println("new sector creation is in progress %s", sector)
+		println("errro: %s", err)
+
+		return err
+	},
+}
+
 var sectorsSealDelayCmd = &cli.Command{
 	Name:      "set-seal-delay",
 	Usage:     "Set the time, in minutes, that a new sector waits for deals before sealing starts",

extern/storage-sealing/input.go

@@ -641,6 +641,21 @@ func (m *Sealing) createSector(ctx context.Context, cfg sealiface.Config, sp abi
 	return sid, err
 }
 
+func (m *Sealing) SectorTryCreateNewSector(ctx context.Context) (abi.SectorNumber, error) {
+	sp, err := m.currentSealProof(ctx)
+	if err != nil {
+		return 0, xerrors.Errorf("failed to get current seal proof: %w", err)
+	}
+
+	cfg, err := m.getConfig()
+	if err != nil {
+		return 0, xerrors.Errorf("getting storage config: %w", err)
+	}
+	sid, err := m.createSector(ctx, cfg, sp)
+
+	return sid, err
+}
+
 func (m *Sealing) tryGetDealSector(ctx context.Context, sp abi.RegisteredSealProof, ef expFn) error {
 	m.startupWait.Wait()
 
@@ -710,7 +725,7 @@ func (m *Sealing) tryGetDealSector(ctx context.Context, sp abi.RegisteredSealPro
 
 func (m *Sealing) StartPacking(sid abi.SectorNumber) error {
 	m.startupWait.Wait()
-
+	println("starting to seal deal sector", "sector", sid, "trigger", "user")
 	log.Infow("starting to seal deal sector", "sector", sid, "trigger", "user")
 	return m.sectors.Send(uint64(sid), SectorStartPacking{})
 }

node/impl/storminer.go

@@ -410,6 +410,10 @@ func (sm *StorageMinerAPI) SectorMatchPendingPiecesToOpenSectors(ctx context.Con
 	return sm.Miner.SectorMatchPendingPiecesToOpenSectors(ctx)
 }
 
+func (sm *StorageMinerAPI) SectorTryCreateNewSector(ctx context.Context) (abi.SectorNumber, error) {
+	return sm.Miner.SectorTryCreateNewSector(ctx)
+}
+
 func (sm *StorageMinerAPI) ComputeWindowPoSt(ctx context.Context, dlIdx uint64, tsk types.TipSetKey) ([]lminer.SubmitWindowedPoStParams, error) {
 	var ts *types.TipSet
 	var err error

storage/miner_sealing.go

@@ -75,6 +75,10 @@ func (m *Miner) SectorMatchPendingPiecesToOpenSectors(ctx context.Context) error
 	return m.sealing.MatchPendingPiecesToOpenSectors(ctx)
 }
 
+func (m *Miner) SectorTryCreateNewSector(ctx context.Context) (abi.SectorNumber, error) {
+	return m.sealing.SectorTryCreateNewSector(ctx)
+}
+
 func (m *Miner) MarkForUpgrade(ctx context.Context, id abi.SectorNumber, snap bool) error {
 	if snap {
 		return m.sealing.MarkForSnapUpgrade(ctx, id)