aligned_layer/core/config/aggregator.go at 6d64a1688ca0c73dc1e510f41f1076ef01bde893 · yetanotherco/aligned_layer · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
package config

import (
	"errors"
	"log"
	"os"
	"time"

	"github.com/ethereum/go-ethereum/common"
	"github.com/yetanotherco/aligned_layer/core/utils"
)

type AggregatorConfig struct {
	BaseConfig  *BaseConfig
	EcdsaConfig *EcdsaConfig
	BlsConfig   *BlsConfig
	Aggregator  struct {
		ServerIpPortAddress           string
		BlsPublicKeyCompendiumAddress common.Address
		AvsServiceManagerAddress      common.Address
		EnableMetrics                 bool
		MetricsIpPortAddress          string
		TelemetryIpPortAddress        string
		GarbageCollectorPeriod        time.Duration
		GarbageCollectorTasksAge      uint64
		GarbageCollectorTasksInterval uint64
		BlsServiceTaskTimeout         time.Duration
		GasBaseBumpPercentage         uint
		GasBumpIncrementalPercentage  uint
		GasBumpPercentageLimit        uint
		TimeToWaitBeforeBump          time.Duration
		PollLatestBatchInterval       time.Duration
	}
}

type AggregatorConfigFromYaml struct {
	Aggregator struct {
		ServerIpPortAddress           string         `yaml:"server_ip_port_address"`
		BlsPublicKeyCompendiumAddress common.Address `yaml:"bls_public_key_compendium_address"`
		AvsServiceManagerAddress      common.Address `yaml:"avs_service_manager_address"`
		EnableMetrics                 bool           `yaml:"enable_metrics"`
		MetricsIpPortAddress          string         `yaml:"metrics_ip_port_address"`
		TelemetryIpPortAddress        string         `yaml:"telemetry_ip_port_address"`
		GarbageCollectorPeriod        time.Duration  `yaml:"garbage_collector_period"`
		GarbageCollectorTasksAge      uint64         `yaml:"garbage_collector_tasks_age"`
		GarbageCollectorTasksInterval uint64         `yaml:"garbage_collector_tasks_interval"`
		BlsServiceTaskTimeout         time.Duration  `yaml:"bls_service_task_timeout"`
		GasBaseBumpPercentage         uint           `yaml:"gas_base_bump_percentage"`
		GasBumpIncrementalPercentage  uint           `yaml:"gas_bump_incremental_percentage"`
		GasBumpPercentageLimit        uint           `yaml:"gas_bump_percentage_limit"`
		TimeToWaitBeforeBump          time.Duration  `yaml:"time_to_wait_before_bump"`
		PollLatestBatchInterval       time.Duration  `yaml:"poll_latest_batch_interval"`
	} `yaml:"aggregator"`
}

func NewAggregatorConfig(configFilePath string) *AggregatorConfig {

	if _, err := os.Stat(configFilePath); errors.Is(err, os.ErrNotExist) {
		log.Fatal("Setup config file does not exist")
	}

	baseConfig := NewBaseConfig(configFilePath)
	if baseConfig == nil {
		log.Fatal("Error reading base config: ")
	}

	ecdsaConfig := NewEcdsaConfig(configFilePath, baseConfig.ChainId)
	if ecdsaConfig == nil {
		log.Fatal("Error reading ecdsa config: ")
	}

	blsConfig := NewBlsConfig(configFilePath)
	if blsConfig == nil {
		log.Fatal("Error reading bls config: ")
	}

	var aggregatorConfigFromYaml AggregatorConfigFromYaml
	err := utils.ReadYamlConfig(configFilePath, &aggregatorConfigFromYaml)
	if err != nil {
		log.Fatal("Error reading aggregator config: ", err)
	}

	return &AggregatorConfig{
		BaseConfig:  baseConfig,
		EcdsaConfig: ecdsaConfig,
		BlsConfig:   blsConfig,
		Aggregator: struct {
			ServerIpPortAddress           string
			BlsPublicKeyCompendiumAddress common.Address
			AvsServiceManagerAddress      common.Address
			EnableMetrics                 bool
			MetricsIpPortAddress          string
			TelemetryIpPortAddress        string
			GarbageCollectorPeriod        time.Duration
			GarbageCollectorTasksAge      uint64
			GarbageCollectorTasksInterval uint64
			BlsServiceTaskTimeout         time.Duration
			GasBaseBumpPercentage         uint
			GasBumpIncrementalPercentage  uint
			GasBumpPercentageLimit        uint
			TimeToWaitBeforeBump          time.Duration
			PollLatestBatchInterval       time.Duration
		}(aggregatorConfigFromYaml.Aggregator),
	}
}