fix(market): use MK20 DDO duration for deal schedule (#1345)

* market: preserve MK20 DDO duration with allocations

* market: fix MK20 DDO duration sanity check

Author: hyunmoon

market/mk20/mk20.go

@@ -478,14 +478,14 @@ func (m *MK20) sanitizeDDODeal(ctx context.Context, deal *Deal) (*ProviderDealRe
 		if alloc.TermMin > deal.Products.DDOV1.Duration {
 			return &ProviderDealRejectionInfo{
 				HTTPCode: ErrBadProposal,
-				Reason:   "Allocation term min is less than deal duration",
+				Reason:   "Allocation term min is greater than deal duration",
 			}, nil
 		}
 
-		if alloc.TermMax > deal.Products.DDOV1.Duration {
+		if alloc.TermMax < deal.Products.DDOV1.Duration {
 			return &ProviderDealRejectionInfo{
 				HTTPCode: ErrBadProposal,
-				Reason:   "Allocation term max is greater than deal duration",
+				Reason:   "Allocation term max is less than deal duration",
 			}, nil
 		}
 

tasks/storage-market/mk20.go

@@ -1070,7 +1070,14 @@ func (d *CurioStorageDealMarket) processMK20DealIngestion(ctx context.Context) {
 				log.Errorw("allocation expired", "deal", deal.ID, "error", err)
 				continue
 			}
-			end = start + alloc.TermMin
+			if abi.ChainEpoch(deal.Duration) < alloc.TermMin || abi.ChainEpoch(deal.Duration) > alloc.TermMax {
+				log.Errorw("deal duration outside allocation bounds",
+					"deal", deal.ID,
+					"duration", deal.Duration,
+					"term_min", alloc.TermMin,
+					"term_max", alloc.TermMax)
+				continue
+			}
 			vak = &miner.VerifiedAllocationKey{
 				Client: abi.ActorID(allocClientID),
 				ID:     verifreg13.AllocationId(*mk20Deal.Products.DDOV1.AllocationId),