-
Notifications
You must be signed in to change notification settings - Fork 95
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'stage' into alan/fork-cleanup
# Conflicts: # network/topics/pubsub.go # operator/validator/controller.go
- Loading branch information
Showing
36 changed files
with
663 additions
and
208 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| package handlers | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "net/http" | ||
|
|
||
| "github.com/attestantio/go-eth2-client/spec/phase0" | ||
| spectypes "github.com/ssvlabs/ssv-spec/types" | ||
|
|
||
| "github.com/ssvlabs/ssv/api" | ||
| exporterapi "github.com/ssvlabs/ssv/exporter/api" | ||
| "github.com/ssvlabs/ssv/exporter/convert" | ||
| ibftstorage "github.com/ssvlabs/ssv/ibft/storage" | ||
| qbftstorage "github.com/ssvlabs/ssv/protocol/v2/qbft/storage" | ||
| "github.com/ssvlabs/ssv/utils/casts" | ||
| ) | ||
|
|
||
| type Exporter struct { | ||
| DomainType spectypes.DomainType | ||
| QBFTStores *ibftstorage.QBFTStores | ||
| } | ||
|
|
||
| type ParticipantResponse struct { | ||
| Role string `json:"role"` | ||
| Slot uint64 `json:"slot"` | ||
| PublicKey string `json:"public_key"` | ||
| Message struct { | ||
| // We're keeping "Signers" capitalized to avoid breaking existing clients that rely on the current structure | ||
| Signers []uint64 `json:"Signers"` | ||
| } `json:"message"` | ||
| } | ||
|
|
||
| func (e *Exporter) Decideds(w http.ResponseWriter, r *http.Request) error { | ||
| var request struct { | ||
| From uint64 `json:"from"` | ||
| To uint64 `json:"to"` | ||
| Roles api.RoleSlice `json:"roles"` | ||
| PubKeys api.HexSlice `json:"pubkeys"` | ||
| } | ||
| var response struct { | ||
| Data []*ParticipantResponse `json:"data"` | ||
| } | ||
|
|
||
| if err := api.Bind(r, &request); err != nil { | ||
| return api.BadRequestError(err) | ||
| } | ||
|
|
||
| if request.From > request.To { | ||
| return api.BadRequestError(fmt.Errorf("'from' must be less than or equal to 'to'")) | ||
| } | ||
|
|
||
| if len(request.PubKeys) == 0 { | ||
| return api.BadRequestError(fmt.Errorf("at least one public key is required")) | ||
| } | ||
|
|
||
| if len(request.Roles) == 0 { | ||
| return api.BadRequestError(fmt.Errorf("at least one role is required")) | ||
| } | ||
|
|
||
| response.Data = []*ParticipantResponse{} | ||
|
|
||
| qbftStores := make(map[convert.RunnerRole]qbftstorage.QBFTStore, len(request.Roles)) | ||
| for _, role := range request.Roles { | ||
| runnerRole := casts.BeaconRoleToConvertRole(spectypes.BeaconRole(role)) | ||
| storage := e.QBFTStores.Get(runnerRole) | ||
| if storage == nil { | ||
| return api.Error(fmt.Errorf("role storage doesn't exist: %v", role)) | ||
| } | ||
|
|
||
| qbftStores[runnerRole] = storage | ||
| } | ||
|
|
||
| for _, role := range request.Roles { | ||
| runnerRole := casts.BeaconRoleToConvertRole(spectypes.BeaconRole(role)) | ||
| qbftStore := qbftStores[runnerRole] | ||
|
|
||
| for _, pubKey := range request.PubKeys { | ||
| msgID := convert.NewMsgID(e.DomainType, pubKey, runnerRole) | ||
| from := phase0.Slot(request.From) | ||
| to := phase0.Slot(request.To) | ||
|
|
||
| participantsList, err := qbftStore.GetParticipantsInRange(msgID, from, to) | ||
| if err != nil { | ||
| return api.Error(fmt.Errorf("error getting participants: %w", err)) | ||
| } | ||
|
|
||
| if len(participantsList) == 0 { | ||
| continue | ||
| } | ||
|
|
||
| data, err := exporterapi.ParticipantsAPIData(participantsList...) | ||
| if err != nil { | ||
| return api.Error(fmt.Errorf("error getting participants API data: %w", err)) | ||
| } | ||
|
|
||
| apiData, ok := data.([]*exporterapi.ParticipantsAPI) | ||
| if !ok { | ||
| return api.Error(fmt.Errorf("invalid type for participants API data")) | ||
| } | ||
|
|
||
| for _, apiMsg := range apiData { | ||
| response.Data = append(response.Data, transformToParticipantResponse(apiMsg)) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| return api.Render(w, r, response) | ||
| } | ||
|
|
||
| func transformToParticipantResponse(apiMsg *exporterapi.ParticipantsAPI) *ParticipantResponse { | ||
| response := &ParticipantResponse{ | ||
| Role: apiMsg.Role, | ||
| Slot: uint64(apiMsg.Slot), | ||
| PublicKey: apiMsg.ValidatorPK, | ||
| } | ||
| response.Message.Signers = apiMsg.Signers | ||
|
|
||
| return response | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.