security

type AggregatorReactor ¶ added in v0.3.1

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

AggregatorReactor handles the collection and aggregation of response signatures from operators, interfacing between the DVS system and the aggregator service

func CreateAggregatorReactor(
	aggClient aggtypes.Aggregator,
	dvsRequestIndexer requestindex.DvsRequestIndexer,
	privValidator types.PrivValidator,
	dvsState *DVSState,
	logger log.Logger,
	eventManager *EventManager,
) *AggregatorReactor

func (ar *AggregatorReactor) HandleSignatureCollectionRequest(requestHash avsitypes.DVSRequestHash) error

type AggregatorResponse ¶ added in v0.3.1

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

AggregatorResponse encapsulates the result of an aggregation operation, containing both the original request hash and the validated response

type DVSReactor ¶

type DVSReactor struct {
	ProxyApp proxy.AppConns
	// contains filtered or unexported fields
}

func CreateDVSReactor(
	config config.PellConfig,
	proxyApp proxy.AppConns,
	dvsRequestIndexer requestindex.DvsRequestIndexer,
	dvsReader reader.DVSReader,
	dvsState *DVSState,
	logger log.Logger,
	eventManager *EventManager,
) (DVSReactor, error)

func (dvs *DVSReactor) HandleDVSRequest(request avsitypes.DVSRequest) error

func (dvs *DVSReactor) OnRequestAfterAggregated(requestHash avsitypes.DVSRequestHash,
	validatedResponse aggtypes.ValidatedResponse) error

func (dvs *DVSReactor) SaveDVSRequestResult(res *avsitypes.DVSRequestResult, first bool) error

type DVSReqResponse ¶

type DVSReqResponse struct {
	Request  avsitypes.DVSRequest
	Response *types.ValidatedResponse
	Receipt  *ResponsePostRequest
}

DVSReqResponse represents the complete lifecycle of a DVS request, including the original request, its validated response, and confirmation receipt

type DVSState ¶

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

DVSState maintains the current state of a DVS node, including operator identity and request storage

func NewDVSState(cfg *config.PellConfig, requestStore RequestStore, storeDir string) (*DVSState, error)

func (dvsState *DVSState) StoreRequest(req *DVSReqResponse) error

type EventManager ¶ added in v0.3.1

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

EventManager coordinates communication between different components of the system by managing event subscriptions and routing events to appropriate handlers

func NewEventManager(logger log.Logger) *EventManager

func (em *EventManager) SetAggregatorReactor(aggregatorReactor *AggregatorReactor)

func (em *EventManager) SetDVSReactor(dvsReactor *DVSReactor)

func (em *EventManager) StartListening()

type PersistentStore ¶ added in v0.3.1

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

PersistentStore implements RequestStore using a persistent database backend for reliable storage of DVS requests and responses

func NewPersistentStore(dir string) (*PersistentStore, error)

func (s *PersistentStore) FetchRequest(id string) (*RequestProcessRequest, error)

func (s *PersistentStore) StoreRequest(req *DVSReqResponse) error

type RequestPostRequest ¶

type RequestPostRequest struct {
	Response types.ValidatedResponse
}

RequestPostRequest contains the validated aggregated response to be posted back to the requestor

type RequestProcessRequest ¶

type RequestProcessRequest struct {
	Request avsitypes.DVSRequest
}

RequestProcessRequest encapsulates a DVS request that needs to be processed by the validation system

type RequestStore ¶ added in v0.3.1

type RequestStore interface {
	StoreRequest(req *DVSReqResponse) error
	FetchRequest(id string) (*RequestProcessRequest, error)
}

RequestStore defines the interface for storing and retrieving DVS requests providing persistence capabilities for the validation system

type ResponsePostRequest ¶

type ResponsePostRequest struct{}

ResponsePostRequest represents a confirmation request after a response has been successfully posted to the network

type ResponseProcessRequest ¶

type ResponseProcessRequest struct {
	Response       []byte
	ResponseDigest []byte
}

ResponseProcessRequest contains the processed response data and its digest following validation of a DVS request