97 lines
2.9 KiB
Go
97 lines
2.9 KiB
Go
package sealing
|
|
|
|
import (
|
|
"context"
|
|
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/go-address"
|
|
|
|
"github.com/filecoin-project/lotus/build"
|
|
"github.com/filecoin-project/lotus/chain/actors"
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
)
|
|
|
|
type ErrApi error
|
|
|
|
type ErrInvalidDeals error
|
|
type ErrExpiredDeals error
|
|
|
|
type ErrBadCommD error
|
|
type ErrExpiredTicket error
|
|
|
|
func checkPieces(ctx context.Context, si SectorInfo, api sealingApi) error {
|
|
head, err := api.ChainHead(ctx)
|
|
if err != nil {
|
|
return ErrApi(xerrors.Errorf("getting chain head: %w", err))
|
|
}
|
|
|
|
for i, piece := range si.Pieces {
|
|
deal, err := api.StateMarketStorageDeal(ctx, piece.DealID, nil)
|
|
if err != nil {
|
|
return ErrApi(xerrors.Errorf("getting deal %d for piece %d: %w", piece.DealID, i, err))
|
|
}
|
|
|
|
if string(deal.PieceRef) != string(piece.CommP) {
|
|
return ErrInvalidDeals(xerrors.Errorf("piece %d of sector %d refers deal %d with wrong CommP: %x != %x", i, si.SectorID, piece.DealID, piece.CommP, deal.PieceRef))
|
|
}
|
|
|
|
if piece.Size != deal.PieceSize {
|
|
return ErrInvalidDeals(xerrors.Errorf("piece %d of sector %d refers deal %d with different size: %d != %d", i, si.SectorID, piece.DealID, piece.Size, deal.PieceSize))
|
|
}
|
|
|
|
if head.Height() >= deal.ProposalExpiration {
|
|
return ErrExpiredDeals(xerrors.Errorf("piece %d of sector %d refers expired deal %d - expires %d, head %d", i, si.SectorID, piece.DealID, deal.ProposalExpiration, head.Height()))
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func checkSeal(ctx context.Context, maddr address.Address, si SectorInfo, api sealingApi) (err error) {
|
|
head, err := api.ChainHead(ctx)
|
|
if err != nil {
|
|
return ErrApi(xerrors.Errorf("getting chain head: %w", err))
|
|
}
|
|
|
|
ssize, err := api.StateMinerSectorSize(ctx, maddr, head)
|
|
if err != nil {
|
|
return ErrApi(err)
|
|
}
|
|
|
|
ccparams, err := actors.SerializeParams(&actors.ComputeDataCommitmentParams{
|
|
DealIDs: si.deals(),
|
|
SectorSize: ssize,
|
|
})
|
|
if err != nil {
|
|
return xerrors.Errorf("computing params for ComputeDataCommitment: %w", err)
|
|
}
|
|
|
|
ccmt := &types.Message{
|
|
To: actors.StorageMarketAddress,
|
|
From: maddr,
|
|
Value: types.NewInt(0),
|
|
GasPrice: types.NewInt(0),
|
|
GasLimit: types.NewInt(9999999999),
|
|
Method: actors.SMAMethods.ComputeDataCommitment,
|
|
Params: ccparams,
|
|
}
|
|
r, err := api.StateCall(ctx, ccmt, nil)
|
|
if err != nil {
|
|
return xerrors.Errorf("calling ComputeDataCommitment: %w", err)
|
|
}
|
|
if r.ExitCode != 0 {
|
|
return ErrBadCommD(xerrors.Errorf("receipt for ComputeDataCommitment had exit code %d", r.ExitCode))
|
|
}
|
|
if string(r.Return) != string(si.CommD) {
|
|
return ErrBadCommD(xerrors.Errorf("on chain CommD differs from sector: %x != %x", r.Return, si.CommD))
|
|
}
|
|
|
|
if int64(head.Height())-int64(si.Ticket.BlockHeight+build.SealRandomnessLookback) > build.SealRandomnessLookbackLimit {
|
|
return ErrExpiredTicket(xerrors.Errorf("ticket expired: seal height: %d, head: %d", si.Ticket.BlockHeight+build.SealRandomnessLookback, head.Height()))
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|