Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Make functions exportable #49

Merged
merged 7 commits into from
Sep 21, 2024
Merged

Make functions exportable #49

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
6dfab93
Make Consensus_core.go functions exportable
VeerChaurasia Sep 20, 2024
403016f
Made all structs exportable
VeerChaurasia Sep 20, 2024
43cf071
Resolved StaticCheck Linter error
VeerChaurasia Sep 20, 2024
9d72f4a
Resolved the exportable field error
VeerChaurasia Sep 20, 2024
118827c
Made the func BaseConfig and ChainID exportable
VeerChaurasia Sep 20, 2024
ba36eef
Resolved all Exportable issues in Config module
VeerChaurasia Sep 20, 2024
5e2be51
Resolved database error
VeerChaurasia Sep 21, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
36 changes: 18 additions & 18 deletions config/checkpoints/checkpoints.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ type Slot struct {
// @param url: string - url to fetch
// @return *http.Response, error
// Fetches the response from the given url
func get(url string) (*http.Response, error) {
func Get(url string) (*http.Response, error) {
var resp *http.Response

// Retry with default settings
Expand Down Expand Up @@ -107,7 +107,7 @@ func get(url string) (*http.Response, error) {
// @param data: []byte - data to deserialize
// @return *uint64, error
// Deserializes the given data to uint64
func deserialize_slot(data []byte) (*uint64, error) {
func DeserializeSlot(data []byte) (*uint64, error) {
var s string
if err := json.Unmarshal(data, &s); err != nil {
return nil, err
Expand All @@ -128,7 +128,7 @@ func deserialize_slot(data []byte) (*uint64, error) {

// create a new CheckpointFallback object
// @return CheckpointFallback
func (ch CheckpointFallback) new() CheckpointFallback {
func (ch CheckpointFallback) New() CheckpointFallback {
return CheckpointFallback{
Services: make(map[config.Network][]CheckpointFallbackService),
Networks: []config.Network{
Expand All @@ -145,7 +145,7 @@ func (ch CheckpointFallback) new() CheckpointFallback {
// / Build the checkpoint fallback service from the community-maintained list by [ethPandaOps](https://github.com/ethpandaops).
// /
// / The list is defined in [ethPandaOps/checkpoint-fallback-service](https://github.com/ethpandaops/checkpoint-sync-health-checks/blob/master/_data/endpoints.yaml).
func (ch CheckpointFallback) build() (CheckpointFallback, error) {
func (ch CheckpointFallback) Build() (CheckpointFallback, error) {
resp, err := http.Get(CHECKPOINT_SYNC_SERVICES_LIST)
if err != nil {
return ch, fmt.Errorf("failed to fetch services list: %w", err)
Expand Down Expand Up @@ -202,9 +202,9 @@ func (ch CheckpointFallback) build() (CheckpointFallback, error) {
}

// fetch the latest checkpoint from the given network
func (ch CheckpointFallback) fetch_latest_checkpoint(network config.Network) byte256 {
services := ch.get_healthy_fallback_services(network)
checkpoint, error := ch.fetch_latest_checkpoint_from_services(services)
func (ch CheckpointFallback) FetchLatestCheckpoint(network config.Network) byte256 {
services := ch.GetHealthyFallbackServices(network)
checkpoint, error := ch.FetchLatestCheckpointFromServices(services)
if error != nil {
return byte256{}
}
Expand All @@ -213,8 +213,8 @@ func (ch CheckpointFallback) fetch_latest_checkpoint(network config.Network) byt
}

// fetch the latest checkpoint from the given endpoint
func (ch CheckpointFallback) query_service(endpoint string) (*RawSlotResponse, error) {
constructed_url := ch.construct_url(endpoint)
func (ch CheckpointFallback) QueryService(endpoint string) (*RawSlotResponse, error) {
constructed_url := ch.ConstructUrl(endpoint)
resp, err := http.Get(constructed_url)
if err != nil {
return nil, err
Expand All @@ -230,7 +230,7 @@ func (ch CheckpointFallback) query_service(endpoint string) (*RawSlotResponse, e
}

// fetch the latest checkpoint from the given services
func (ch CheckpointFallback) fetch_latest_checkpoint_from_services(services []CheckpointFallbackService) (byte256, error) {
func (ch CheckpointFallback) FetchLatestCheckpointFromServices(services []CheckpointFallbackService) (byte256, error) {
var (
slots []Slot
wg sync.WaitGroup
Expand All @@ -242,7 +242,7 @@ func (ch CheckpointFallback) fetch_latest_checkpoint_from_services(services []Ch
wg.Add(1)
go func(service CheckpointFallbackService) {
defer wg.Done()
raw, err := ch.query_service(service.Endpoint)
raw, err := ch.QueryService(service.Endpoint)
if err != nil {
errorsChan <- fmt.Errorf("failed to fetch checkpoint from service %s: %w", service.Endpoint, err)
return
Expand Down Expand Up @@ -322,8 +322,8 @@ func (ch CheckpointFallback) fetch_latest_checkpoint_from_services(services []Ch
return mostCommon, nil
}

func (ch CheckpointFallback) fetch_latest_checkpoint_from_api(url string) (byte256, error) {
constructed_url := ch.construct_url(url)
func (ch CheckpointFallback) FetchLatestCheckpointFromApi(url string) (byte256, error) {
constructed_url := ch.ConstructUrl(url)
resp, err := http.Get(constructed_url)

if err != nil {
Expand All @@ -349,11 +349,11 @@ func (ch CheckpointFallback) fetch_latest_checkpoint_from_api(url string) (byte2

}

func (ch CheckpointFallback) construct_url(endpoint string) string {
func (ch CheckpointFallback) ConstructUrl(endpoint string) string {
return fmt.Sprintf("%s/checkpointz/v1/beacon/slots", endpoint)
}

func (ch CheckpointFallback) get_all_fallback_endpoints(network config.Network) []string {
func (ch CheckpointFallback) GetAllFallbackEndpoints(network config.Network) []string {
var endpoints []string
for _, service := range ch.Services[network] {
endpoints = append(endpoints, service.Endpoint)
Expand All @@ -363,7 +363,7 @@ func (ch CheckpointFallback) get_all_fallback_endpoints(network config.Network)

}

func (ch CheckpointFallback) get_healthy_fallback_endpoints(network config.Network) []string {
func (ch CheckpointFallback) GetHealthyFallbackEndpoints(network config.Network) []string {
var healthyEndpoints []string
for _, service := range ch.Services[network] {
if service.Health_from_fallback.Result {
Expand All @@ -373,7 +373,7 @@ func (ch CheckpointFallback) get_healthy_fallback_endpoints(network config.Netwo
return healthyEndpoints

}
func (ch CheckpointFallback) get_healthy_fallback_services(network config.Network) []CheckpointFallbackService {
func (ch CheckpointFallback) GetHealthyFallbackServices(network config.Network) []CheckpointFallbackService {
var healthyServices []CheckpointFallbackService
for _, service := range ch.Services[network] {
if service.Health_from_fallback.Result {
Expand All @@ -383,6 +383,6 @@ func (ch CheckpointFallback) get_healthy_fallback_services(network config.Networ
return healthyServices

}
func (ch CheckpointFallback) get_fallback_services(network config.Network) []CheckpointFallbackService {
func (ch CheckpointFallback) GetFallbackServices(network config.Network) []CheckpointFallbackService {
return ch.Services[network]
}
2 changes: 1 addition & 1 deletion config/config.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ type Config struct {
// only if we are using CLI
func (c Config) from_file(configPath *string, network *string, cliConfig *CliConfig) Config {
n := Network(*network)
baseConfig, err := n.baseConfig(*network)
baseConfig, err := n.BaseConfig(*network)
if err != nil {
baseConfig = BaseConfig{}.Default()
}
Expand Down
4 changes: 2 additions & 2 deletions config/networks.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ const (
GOERLI Network = "GOERLI"
SEPOLIA Network = "SEPOLIA"
)
func (n Network) baseConfig(s string) (BaseConfig, error) {
func (n Network) BaseConfig(s string) (BaseConfig, error) {
switch strings.ToUpper(s) {
case "MAINNET":
config, err := Mainnet()
Expand All @@ -37,7 +37,7 @@ func (n Network) baseConfig(s string) (BaseConfig, error) {
return BaseConfig{}, errors.New("network not recognized")
}
}
func (n Network) chainID (id uint64) (BaseConfig, error) {
func (n Network) ChainID(id uint64) (BaseConfig, error) {
switch id {
case 1:
config, err := Mainnet()
Expand Down
4 changes: 2 additions & 2 deletions config/utils.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import (
"github.com/BlocSoc-iitr/selene/common"
)

func bytes_serialise(bytes []byte) ([]byte, error) {
func BytesSerialise(bytes []byte) ([]byte, error) {

if bytes == nil {
return json.Marshal(nil)
Expand All @@ -21,7 +21,7 @@ func bytes_serialise(bytes []byte) ([]byte, error) {

}

func bytes_deserialise(data []byte) ([]byte, error) {
func BytesDeserialise(data []byte) ([]byte, error) {
var bytesOpt *string
if err := json.Unmarshal(data, &bytesOpt); err != nil {
return nil, err
Expand Down
Loading
Loading