mirror of
https://github.com/filecoin-project/lotus.git
synced 2025-08-25 02:02:01 +08:00
79206a00eb
Upgrade to go-f3 `v0.8.3` Upgrade to the latest go-f3, to bubble up: * various bug fixes * extended manifest parameters for better control in passive testing Note that the return type from F3GetProgress API has changed to now include the input chain to an instance. Update CLI templates to print the additional fields.
101 lines
2.8 KiB
Go
101 lines
2.8 KiB
Go
package full
|
|
|
|
import (
|
|
"context"
|
|
|
|
"go.uber.org/fx"
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/go-address"
|
|
"github.com/filecoin-project/go-f3/certs"
|
|
"github.com/filecoin-project/go-f3/gpbft"
|
|
"github.com/filecoin-project/go-f3/manifest"
|
|
|
|
"github.com/filecoin-project/lotus/api"
|
|
"github.com/filecoin-project/lotus/chain/lf3"
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
)
|
|
|
|
type F3API struct {
|
|
fx.In
|
|
|
|
F3 *lf3.F3 `optional:"true"`
|
|
}
|
|
|
|
func (f3api *F3API) F3GetOrRenewParticipationTicket(ctx context.Context, miner address.Address, previous api.F3ParticipationTicket, instances uint64) (api.F3ParticipationTicket, error) {
|
|
if f3api.F3 == nil {
|
|
log.Infof("F3GetParticipationTicket called for %v, F3 is disabled", miner)
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
minerID, err := address.IDFromAddress(miner)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("miner address is not of ID type: %v: %w", miner, err)
|
|
}
|
|
return f3api.F3.GetOrRenewParticipationTicket(ctx, minerID, previous, instances)
|
|
}
|
|
|
|
func (f3api *F3API) F3Participate(ctx context.Context, ticket api.F3ParticipationTicket) (api.F3ParticipationLease, error) {
|
|
|
|
if f3api.F3 == nil {
|
|
log.Infof("F3Participate called, F3 is disabled")
|
|
return api.F3ParticipationLease{}, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.Participate(ctx, ticket)
|
|
}
|
|
|
|
func (f3api *F3API) F3GetCertificate(ctx context.Context, instance uint64) (*certs.FinalityCertificate, error) {
|
|
if f3api.F3 == nil {
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.GetCert(ctx, instance)
|
|
}
|
|
|
|
func (f3api *F3API) F3GetLatestCertificate(ctx context.Context) (*certs.FinalityCertificate, error) {
|
|
if f3api.F3 == nil {
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.GetLatestCert(ctx)
|
|
}
|
|
|
|
func (f3api *F3API) F3GetManifest(ctx context.Context) (*manifest.Manifest, error) {
|
|
if f3api.F3 == nil {
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.GetManifest(ctx)
|
|
}
|
|
|
|
func (f3api *F3API) F3IsRunning(context.Context) (bool, error) {
|
|
if f3api.F3 == nil {
|
|
return false, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.IsRunning(), nil
|
|
}
|
|
|
|
func (f3api *F3API) F3GetECPowerTable(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) {
|
|
if f3api.F3 == nil {
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.GetPowerTable(ctx, tsk)
|
|
}
|
|
|
|
func (f3api *F3API) F3GetF3PowerTable(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) {
|
|
if f3api.F3 == nil {
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.GetF3PowerTable(ctx, tsk)
|
|
}
|
|
|
|
func (f3api *F3API) F3GetProgress(context.Context) (gpbft.InstanceProgress, error) {
|
|
if f3api.F3 == nil {
|
|
return gpbft.InstanceProgress{}, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.Progress(), nil
|
|
}
|
|
|
|
func (f3api *F3API) F3ListParticipants(context.Context) ([]api.F3Participant, error) {
|
|
if f3api.F3 == nil {
|
|
return nil, api.ErrF3Disabled
|
|
}
|
|
return f3api.F3.ListParticipants(), nil
|
|
}
|