fraud

Documentation

Index

• func ConstructModule(tp node.Type) fx.Option
• func Unmarshaler() fraud.ProofUnmarshaler[*header.ExtendedHeader]
• type API
  • func (api *API) Get(ctx context.Context, proofType fraud.ProofType) ([]Proof, error)
  • func (api *API) Subscribe(ctx context.Context, proofType fraud.ProofType) (<-chan *Proof, error)
• type Module
• type Proof
  • func (f *Proof) MarshalJSON() ([]byte, error)
  • func (f *Proof) UnmarshalJSON(data []byte) error
• type ServiceBreaker
  • func (breaker *ServiceBreaker[S, H]) Start(ctx context.Context) error
  • func (breaker *ServiceBreaker[S, H]) Stop(ctx context.Context) error

Functions

func ConstructModule

func ConstructModule(tp node.Type) fx.Option

func Unmarshaler

func Unmarshaler() fraud.ProofUnmarshaler[*header.ExtendedHeader]

Types

type API

type API struct {
	Internal struct {
		Subscribe func(context.Context, fraud.ProofType) (<-chan *Proof, error) `perm:"read"`
		Get       func(context.Context, fraud.ProofType) ([]Proof, error)       `perm:"read"`
	}
}

API is a wrapper around Module for the RPC. TODO(@distractedm1nd): These structs need to be autogenerated.

func (*API) Get

func (api *API) Get(ctx context.Context, proofType fraud.ProofType) ([]Proof, error)

func (*API) Subscribe

func (api *API) Subscribe(ctx context.Context, proofType fraud.ProofType) (<-chan *Proof, error)

type Module

type Module interface {
	// Subscribe allows to subscribe on a Proof pub sub topic by its type.
	Subscribe(context.Context, fraud.ProofType) (<-chan *Proof, error)
	// Get fetches fraud proofs from the disk by its type.
	Get(context.Context, fraud.ProofType) ([]Proof, error)
}

Module encompasses the behavior necessary to subscribe and broadcast fraud proofs within the network. Any method signature changed here needs to also be changed in the API struct.

type Proof

type Proof struct {
	fraud.Proof[*header.ExtendedHeader]
}

Proof embeds the fraud.Proof interface type to provide a concrete type for JSON serialization.

func (*Proof) MarshalJSON

func (f *Proof) MarshalJSON() ([]byte, error)

func (*Proof) UnmarshalJSON

func (f *Proof) UnmarshalJSON(data []byte) error

type ServiceBreaker

type ServiceBreaker[S service, H libhead.Header[H]] struct {
	Service   S
	FraudType fraud.ProofType
	FraudServ fraud.Service[H]
	// contains filtered or unexported fields
}

ServiceBreaker wraps any service with fraud proof subscription of a specific type. If proof happens the service is Stopped automatically. TODO(@Wondertan): Support multiple fraud types.

func (*ServiceBreaker[S, H]) Start

func (breaker *ServiceBreaker[S, H]) Start(ctx context.Context) error

Start starts the inner service if there are no fraud proofs stored. Subscribes for fraud and stops the service whenever necessary.

func (*ServiceBreaker[S, H]) Stop

func (breaker *ServiceBreaker[S, H]) Stop(ctx context.Context) error

Stop stops the service and cancels subscription.