Skip to content

Commit

Permalink
Use rpc standard for polygon (#630)
Browse files Browse the repository at this point in the history
  • Loading branch information
ftocal committed Aug 11, 2023
1 parent 4c037b8 commit 74c6f51
Show file tree
Hide file tree
Showing 9 changed files with 36 additions and 8 deletions.
14 changes: 12 additions & 2 deletions contract-watcher/cmd/service/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@ type watchersConfig struct {
moonbeam *config.WatcherBlockchainAddresses
oasis *config.WatcherBlockchainAddresses
optimism *config.WatcherBlockchainAddresses
polygon *config.WatcherBlockchainAddresses
solana *config.WatcherBlockchain
terra *config.WatcherBlockchain
rateLimit rateLimitConfig
Expand All @@ -65,6 +66,7 @@ type rateLimitConfig struct {
moonbeam int
oasis int
optimism int
polygon int
solana int
terra int
}
Expand Down Expand Up @@ -234,13 +236,18 @@ func newWatchers(config *config.ServiceConfiguration, repo *storage.Repository,
result = append(result, baseWatcher)
}

// add polygon watcher
if watchers.polygon != nil {
polygonWatcher := builder.CreateEvmWatcher(watchers.rateLimit.polygon, config.PolygonUrl, *watchers.polygon, logger, repo, metrics)
result = append(result, polygonWatcher)
}

return result
}

func newWatchersForMainnet(cfg *config.ServiceConfiguration) *watchersConfig {
return &watchersConfig{
ankr: []config.WatcherBlockchainAddresses{
config.POLYGON_MAINNET,
config.BSC_MAINNET,
config.FANTOM_MAINNET,
},
Expand All @@ -253,6 +260,7 @@ func newWatchersForMainnet(cfg *config.ServiceConfiguration) *watchersConfig {
moonbeam: &config.MOONBEAM_MAINNET,
oasis: &config.OASIS_MAINNET,
optimism: &config.OPTIMISM_MAINNET,
polygon: &config.POLYGON_MAINNET,
solana: &config.SOLANA_MAINNET,
terra: &config.TERRA_MAINNET,

Expand All @@ -267,6 +275,7 @@ func newWatchersForMainnet(cfg *config.ServiceConfiguration) *watchersConfig {
moonbeam: cfg.MoonbeamRequestsPerSecond,
oasis: cfg.OasisRequestsPerSecond,
optimism: cfg.OptimismRequestsPerSecond,
polygon: cfg.PolygonRequestsPerSecond,
solana: cfg.SolanaRequestsPerSecond,
terra: cfg.TerraRequestsPerSecond,
},
Expand All @@ -276,7 +285,6 @@ func newWatchersForMainnet(cfg *config.ServiceConfiguration) *watchersConfig {
func newWatchersForTestnet(cfg *config.ServiceConfiguration) *watchersConfig {
return &watchersConfig{
ankr: []config.WatcherBlockchainAddresses{
config.POLYGON_TESTNET,
config.BSC_TESTNET,
config.FANTOM_TESTNET,
},
Expand All @@ -289,6 +297,7 @@ func newWatchersForTestnet(cfg *config.ServiceConfiguration) *watchersConfig {
moonbeam: &config.MOONBEAM_TESTNET,
oasis: &config.OASIS_TESTNET,
optimism: &config.OPTIMISM_TESTNET,
polygon: &config.POLYGON_TESTNET,
solana: &config.SOLANA_TESTNET,
rateLimit: rateLimitConfig{
ankr: cfg.AnkrRequestsPerSecond,
Expand All @@ -301,6 +310,7 @@ func newWatchersForTestnet(cfg *config.ServiceConfiguration) *watchersConfig {
moonbeam: cfg.MoonbeamRequestsPerSecond,
oasis: cfg.OasisRequestsPerSecond,
optimism: cfg.OptimismRequestsPerSecond,
polygon: cfg.PolygonRequestsPerSecond,
solana: cfg.SolanaRequestsPerSecond,
terra: cfg.TerraRequestsPerSecond,
},
Expand Down
2 changes: 2 additions & 0 deletions contract-watcher/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,8 @@ type ServiceConfiguration struct {
OptimismRequestsPerSecond int `env:"OPTIMISM_REQUESTS_PER_SECOND,required"`
OasisUrl string `env:"OASIS_URL,required"`
OasisRequestsPerSecond int `env:"OASIS_REQUESTS_PER_SECOND,required"`
PolygonUrl string `env:"POLYGON_URL,required"`
PolygonRequestsPerSecond int `env:"POLYGON_REQUESTS_PER_SECOND,required"`
SolanaUrl string `env:"SOLANA_URL,required"`
SolanaRequestsPerSecond int `env:"SOLANA_REQUESTS_PER_SECOND,required"`
TerraUrl string `env:"TERRA_URL,required"`
Expand Down
2 changes: 1 addition & 1 deletion contract-watcher/watcher/terra_watcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ func (w *TerraWatcher) Start(ctx context.Context) error {
w.repository.UpdateWatcherBlock(ctx, w.chainID, watcherBlock)
}
} else {
w.logger.Info("waiting for new terra blocks")
w.logger.Debug("waiting for new terra blocks")
select {
case <-ctx.Done():
w.wg.Done()
Expand Down
7 changes: 7 additions & 0 deletions deploy/contract-watcher/contract-watcher-service.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -144,6 +144,13 @@ spec:
key: avalanche-url
- name: AVALANCHE_REQUESTS_PER_SECOND
value: "{{ .AVALANCHE_REQUESTS_PER_SECOND }}"
- name: POLYGON_URL
valueFrom:
secretKeyRef:
name: blockchain
key: polygon-url
- name: POLYGON_REQUESTS_PER_SECOND
value: "{{ .POLYGON_REQUESTS_PER_SECOND }}"
- name: ALERT_API_KEY
valueFrom:
secretKeyRef:
Expand Down
2 changes: 2 additions & 0 deletions deploy/contract-watcher/env/production-mainnet.env
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,8 @@ OASIS_URL=
OASIS_REQUESTS_PER_SECOND=3
OPTIMISM_URL=
OPTIMISM_REQUESTS_PER_SECOND=3
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=20
TERRA_URL=
Expand Down
6 changes: 4 additions & 2 deletions deploy/contract-watcher/env/production-testnet.env
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,14 @@ CELO_URL=
CELO_REQUESTS_PER_SECOND=20
ETHEREUM_URL=
ETHEREUM_REQUESTS_PER_SECOND=2
MOONBEAM_URL=
MOONBEAM_REQUESTS_PER_SECOND=2
OASIS_URL=
OASIS_REQUESTS_PER_SECOND=1
OPTIMISM_URL=
OPTIMISM_REQUESTS_PER_SECOND=1
MOONBEAM_URL=
MOONBEAM_REQUESTS_PER_SECOND=2
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=2
TERRA_URL=
Expand Down
4 changes: 3 additions & 1 deletion deploy/contract-watcher/env/staging-mainnet.env
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ ANKR_REQUESTS_PER_SECOND=1000
APTOS_URL=
APTOS_REQUESTS_PER_SECOND=20
ARBITRUM_URL=
ARBITRUM_REQUESTS_PER_SECOND=3
ARBITRUM_REQUESTS_PER_SECOND=5
AVALANCHE_URL=
AVALANCHE_REQUESTS_PER_SECOND=5
BASE_URL=
Expand All @@ -29,6 +29,8 @@ OASIS_URL=
OASIS_REQUESTS_PER_SECOND=3
OPTIMISM_URL=
OPTIMISM_REQUESTS_PER_SECOND=3
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=20
TERRA_URL=
Expand Down
6 changes: 4 additions & 2 deletions deploy/contract-watcher/env/staging-testnet.env
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,14 @@ CELO_URL=
CELO_REQUESTS_PER_SECOND=20
ETHEREUM_URL=
ETHEREUM_REQUESTS_PER_SECOND=2
MOONBEAM_URL=
MOONBEAM_REQUESTS_PER_SECOND=2
OASIS_URL=
OASIS_REQUESTS_PER_SECOND=1
OPTIMISM_URL=
OPTIMISM_REQUESTS_PER_SECOND=1
MOONBEAM_URL=
MOONBEAM_REQUESTS_PER_SECOND=2
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=2
TERRA_URL=
Expand Down
1 change: 1 addition & 0 deletions deploy/contract-watcher/secrets.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,4 +17,5 @@ data:
ethereum-url: {{ .ETHEREUM_URL | b64enc }}
avalanche-url: {{ .AVALANCHE_URL | b64enc }}
base-url: {{ .BASE_URL | b64enc }}
polygon-url: {{ .POLYGON_URL | b64enc }}
type: Opaque

0 comments on commit 74c6f51

Please sign in to comment.