provide deal scheduling info to FSM so that it can set pre-commit expiry

node/impl/storminer.go

@@ -75,10 +75,10 @@ func (sm *StorageMinerAPI) SectorsStatus(ctx context.Context, sid abi.SectorNumb
 
 	deals := make([]abi.DealID, len(info.Pieces))
 	for i, piece := range info.Pieces {
-		if piece.DealID == nil {
+		if piece.DealInfo == nil {
 			continue
 		}
-		deals[i] = *piece.DealID
+		deals[i] = piece.DealInfo.DealID
 	}
 
 	log := make([]api.SectorLog, len(info.Log))

node/modules/storageminer.go

@@ -282,10 +282,15 @@ func SetupBlockProducer(lc fx.Lifecycle, ds dtypes.MetadataDS, api lapi.FullNode
 }
 
 func SealTicketGen(fapi lapi.FullNode) sealing.TicketFn {
-	return func(ctx context.Context) (abi.SealRandomness, abi.ChainEpoch, error) {
-		ts, err := fapi.ChainHead(ctx)
+	return func(ctx context.Context, tok sealing.TipSetToken) (abi.SealRandomness, abi.ChainEpoch, error) {
+		tsk, err := types.TipSetKeyFromBytes(tok)
 		if err != nil {
-			return nil, 0, xerrors.Errorf("getting head ts for SealTicket failed: %w", err)
+			return nil, 0, xerrors.Errorf("could not unmarshal TipSetToken to TipSetKey: %w", err)
+		}
+
+		ts, err := fapi.ChainGetTipSet(ctx, tsk)
+		if err != nil {
+			return nil, 0, xerrors.Errorf("getting TipSet for key failed: %w", err)
 		}
 
 		r, err := fapi.ChainGetRandomness(ctx, ts.Key(), crypto.DomainSeparationTag_SealRandomness, ts.Height()-build.SealRandomnessLookback, nil)