forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

beacon/light: lower case error messages

Browse source
This commit is contained in:
Zsolt Felfoldi 2024-01-21 03:51:03 +01:00 committed by Felix Lange
parent 9f371776cd
commit 2ea0421599
2 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
beacon/light/api/light_api.go
View file

@ -141,7 +141,7 @@ func (api *BeaconLightApi) httpGet(path string) ([]byte, error) {
case 500: case 500:
return nil, ErrInternal return nil, ErrInternal
default: default:
return nil, fmt.Errorf("Unexpected error from API endpoint \"%s\": status code %d", path, resp.StatusCode) return nil, fmt.Errorf("unexpected error from API endpoint \"%s\": status code %d", path, resp.StatusCode)
} }
} }
@ -412,7 +412,7 @@ func (api *BeaconLightApi) StartHeadListener(headFn func(slot uint64, blockRoot
req, err := http.NewRequest("GET", api.url+ req, err := http.NewRequest("GET", api.url+
"/eth/v1/events?topics=head&topics=light_client_optimistic_update&topics=light_client_finality_update", nil) "/eth/v1/events?topics=head&topics=light_client_optimistic_update&topics=light_client_finality_update", nil)
if err != nil { if err != nil {
errFn(fmt.Errorf("Error creating event subscription request: %v", err)) errFn(fmt.Errorf("error creating event subscription request: %v", err))
return return
} }
for k, v := range api.customHeaders { for k, v := range api.customHeaders {
@ -420,7 +420,7 @@ func (api *BeaconLightApi) StartHeadListener(headFn func(slot uint64, blockRoot
} }
stream, err := eventsource.SubscribeWithRequest("", req) stream, err := eventsource.SubscribeWithRequest("", req)
if err != nil { if err != nil {
errFn(fmt.Errorf("Error creating event subscription: %v", err)) errFn(fmt.Errorf("error creating event subscription: %v", err))
close(streamCh) close(streamCh)
return return
} }
@ -455,22 +455,22 @@ func (api *BeaconLightApi) StartHeadListener(headFn func(slot uint64, blockRoot
if slot, blockRoot, err := decodeHeadEvent([]byte(event.Data())); err == nil { if slot, blockRoot, err := decodeHeadEvent([]byte(event.Data())); err == nil {
headFn(slot, blockRoot) headFn(slot, blockRoot)
} else { } else {
errFn(fmt.Errorf("Error decoding head event: %v", err)) errFn(fmt.Errorf("error decoding head event: %v", err))
} }
case "light_client_optimistic_update": case "light_client_optimistic_update":
if signedHead, err := decodeOptimisticHeadUpdate([]byte(event.Data())); err == nil { if signedHead, err := decodeOptimisticHeadUpdate([]byte(event.Data())); err == nil {
signedFn(signedHead) signedFn(signedHead)
} else { } else {
errFn(fmt.Errorf("Error decoding optimistic update event: %v", err)) errFn(fmt.Errorf("error decoding optimistic update event: %v", err))
} }
case "light_client_finality_update": case "light_client_finality_update":
if finalityUpdate, err := decodeFinalityUpdate([]byte(event.Data())); err == nil { if finalityUpdate, err := decodeFinalityUpdate([]byte(event.Data())); err == nil {
finalityFn(finalityUpdate) finalityFn(finalityUpdate)
} else { } else {
errFn(fmt.Errorf("Error decoding finality update event: %v", err)) errFn(fmt.Errorf("error decoding finality update event: %v", err))
} }
default: default:
errFn(fmt.Errorf("Unexpected event: %s", event.Event())) errFn(fmt.Errorf("unexpected event: %s", event.Event()))
} }
case err, ok := <-stream.Errors: case err, ok := <-stream.Errors:
if !ok { if !ok {

4
beacon/light/committee_chain.go
View file

@ -467,12 +467,12 @@ func (s *CommitteeChain) getSyncCommittee(period uint64) (syncCommittee, error)
if sc, ok := s.committees.get(s.db, period); ok { if sc, ok := s.committees.get(s.db, period); ok {
c, err := s.sigVerifier.deserializeSyncCommittee(sc) c, err := s.sigVerifier.deserializeSyncCommittee(sc)
if err != nil { if err != nil {
return nil, fmt.Errorf("Sync committee #%d deserialization error: %v", period, err) return nil, fmt.Errorf("sync committee #%d deserialization error: %v", period, err)
} }
s.committeeCache.Add(period, c) s.committeeCache.Add(period, c)
return c, nil return c, nil
} }
return nil, fmt.Errorf("Missing serialized sync committee #%d", period) return nil, fmt.Errorf("missing serialized sync committee #%d", period)
} }
// VerifySignedHeader returns true if the given signed header has a valid signature // VerifySignedHeader returns true if the given signed header has a valid signature