aggregator

type Aggregator interface {
	// CollectResponseSignature is a method that collects the response signature from the operator
	CollectResponseSignature(response *ResponseWithSignature, result chan<- ValidatedResponse) error
}

type AggregatorConfig struct {
	AggregatorRPCServer     string `json:"aggregator_rpc_server"`
	OperatorResponseTimeout string `json:"operator_response_timeout"`
}

type ChainConfig struct {
	ChainID                     ChainID        `json:"-"`
	RPCURL                      string         `json:"rpc_url"`
	OperatorInfoProviderAddress common.Address `json:"operator_info_provider_address"`
	OperatorKeyManagerAddress   common.Address `json:"operator_key_manager_address"`
	CentralSchedulerAddress     common.Address `json:"central_scheduler_address"`
}

type ChainID = int64

type ResponseWithSignature struct {
	Data        []byte
	Digest      [32]byte
	Signature   *bls.Signature
	OperatorID  [32]byte
	RequestData avsitypes.DVSRequest
}

type ValidatedResponse struct {
	Data                        []byte
	Err                         error
	Hash                        []byte
	NonSignersPubkeysG1         []*bls.G1Point
	GroupApksG1                 []*bls.G1Point
	SignersApkG2                *bls.G2Point
	SignersAggSigG1             *bls.Signature
	NonSignerGroupBitmapIndices []uint32
	GroupApkIndices             []uint32
	TotalStakeIndices           []uint32
	NonSignerStakeIndices       [][]uint32
}