tasks

type ChainAPI interface {
	ChainHead(context.Context) (*chaintypes.TipSet, error)
	StateGetRandomnessDigestFromBeacon(ctx context.Context, randEpoch abi.ChainEpoch, tsk chaintypes.TipSetKey) (abi.Randomness, error) //perm:read
}

type InitProvingPeriodTask struct {
	// contains filtered or unexported fields
}

type MessageWatcherEth struct {
	// contains filtered or unexported fields
}

type MessageWatcherEthClient interface {
	TransactionByHash(ctx context.Context, hash common.Hash) (tx *types.Transaction, isPending bool, err error)
	TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
}

type NextProvingPeriodTask struct {
	// contains filtered or unexported fields
}

type ProofSetCreate struct {
	CreateMessageHash string `db:"create_message_hash"`
	Service           string `db:"service"`
}

type ProofSetRootAdd struct {
	ProofSet       uint64 `db:"proofset"`
	AddMessageHash string `db:"add_message_hash"`
}

type ProveTask struct {
	// contains filtered or unexported fields
}

type RootAddEntry struct {
	ProofSet        uint64 `db:"proofset"`
	Root            string `db:"root"`
	AddMessageHash  string `db:"add_message_hash"`
	AddMessageIndex uint64 `db:"add_message_index"`
	Subroot         string `db:"subroot"`
	SubrootOffset   int64  `db:"subroot_offset"`
	SubrootSize     int64  `db:"subroot_size"`
	PDPPieceRefID   int64  `db:"pdp_pieceref"`
	AddMessageOK    *bool  `db:"add_message_ok"`
	PDPProofSetID   uint64 `db:"proofset"`
}

type SendTaskETH struct {
	// contains filtered or unexported fields
}

type SenderETH struct {
	// contains filtered or unexported fields
}

type SenderETHClient interface {
	NetworkID(ctx context.Context) (*big.Int, error)
	HeaderByNumber(ctx context.Context, number *big.Int) (*ethtypes.Header, error)
	PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
	EstimateGas(ctx context.Context, msg ethereum.CallMsg) (uint64, error)
	SendTransaction(ctx context.Context, transaction *ethtypes.Transaction) error
	SuggestGasTipCap(ctx context.Context) (*big.Int, error)
}

type TransactionResult struct {
	TxHash               string
	Receipt              *types.Receipt
	Transaction          *types.Transaction
	ConfirmedBlockNumber int64
	TxDataJSON           []byte
	ReceiptJSON          []byte
	TxSuccess            bool
}

type WatcherOption func(*MessageWatcherEth)