certusone
/
wormhole-explorer
mirror of https://github.com/certusone/wormhole-explorer.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Minor fixes and change rate limit (#699) 

Co-authored-by: walker-16 <agpazos85@gmail.com>
This commit is contained in:
ftocal 2023-09-21 17:20:50 -03:00 committed by GitHub
parent 3209658b1e
commit f000470e5e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
contract-watcher/config/testnet.go
View File

@ -313,7 +313,7 @@ var ARBITRUM_TESTNET = WatcherBlockchainAddresses{
}
var OPTIMISM_TESTNET = WatcherBlockchainAddresses{
ChainID: vaa.ChainIDArbitrum,
ChainID: vaa.ChainIDOptimism,
Name: "optimism_goerli",
SizeBlocks: 100,
WaitSeconds: 10,

24
contract-watcher/watcher/solana_watcher.go
View File

@ -53,8 +53,8 @@ const (
postVAATypeIndex = 0x2
)
const maxRetries = 5
const retryDelay = 10 * time.Second
const maxRetries = 3
const retryDelay = 5 * time.Second
type SolanaWatcher struct {
client *solana.SolanaSDK
@ -197,7 +197,7 @@ func (w *SolanaWatcher) processBlock(ctx context.Context, fromBlock uint64, toBl
result, err := w.client.GetBlock(ctx, block)
if err != nil {
if err == solana.ErrSlotSkipped {
logger.Info("slot was skipped")
logger.Debug("slot was skipped")
return nil
}
return fmt.Errorf("cannot get block. %w", err)
@ -210,15 +210,6 @@ func (w *SolanaWatcher) processBlock(ctx context.Context, fromBlock uint64, toBl
w.processTransaction(ctx, &txRpc, block, txNum, result.BlockTime)
}
// update the last block number processed in the database.
if updateWatcherBlock {
watcherBlock := storage.WatcherBlock{
ID: w.blockchain,
BlockNumber: int64(block),
UpdatedAt: time.Now(),
}
return w.repository.UpdateWatcherBlock(ctx, w.chainID, watcherBlock)
}
return nil
},
retry.Attempts(maxRetries),
@ -230,6 +221,15 @@ func (w *SolanaWatcher) processBlock(ctx context.Context, fromBlock uint64, toBl
if err != nil {
logger.Error("processing block", zap.Error(err))
}
// update the last block number processed in the database.
if updateWatcherBlock {
watcherBlock := storage.WatcherBlock{
ID: w.blockchain,
BlockNumber: int64(block),
UpdatedAt: time.Now(),
}
w.repository.UpdateWatcherBlock(ctx, w.chainID, watcherBlock)
}
}
}

4
deploy/contract-watcher/env/production-mainnet.env vendored
View File

@ -10,7 +10,7 @@ RESOURCES_REQUESTS_CPU=250m
P2P_NETWORK=mainnet
PPROF_ENABLED=false
ANKR_URL=
ANKR_REQUESTS_PER_SECOND=1000
ANKR_REQUESTS_PER_SECOND=200
APTOS_URL=
APTOS_REQUESTS_PER_SECOND=20
ARBITRUM_URL=
@ -32,7 +32,7 @@ OPTIMISM_REQUESTS_PER_SECOND=3
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=20
SOLANA_REQUESTS_PER_SECOND=1000
TERRA_URL=
TERRA_REQUESTS_PER_SECOND=10
ALERT_ENABLED=true

12
deploy/contract-watcher/env/production-testnet.env vendored
View File

@ -12,13 +12,13 @@ PPROF_ENABLED=false
ANKR_URL=
ANKR_REQUESTS_PER_SECOND=10
APTOS_URL=
APTOS_REQUESTS_PER_SECOND=1
APTOS_REQUESTS_PER_SECOND=5
ARBITRUM_URL=
ARBITRUM_REQUESTS_PER_SECOND=1
ARBITRUM_REQUESTS_PER_SECOND=3
AVALANCHE_URL=
AVALANCHE_REQUESTS_PER_SECOND=5
BASE_URL=
BASE_REQUESTS_PER_SECOND=1
BASE_REQUESTS_PER_SECOND=3
CELO_URL=
CELO_REQUESTS_PER_SECOND=20
ETHEREUM_URL=
@ -26,13 +26,13 @@ ETHEREUM_REQUESTS_PER_SECOND=2
MOONBEAM_URL=
MOONBEAM_REQUESTS_PER_SECOND=2
OASIS_URL=
OASIS_REQUESTS_PER_SECOND=1
OASIS_REQUESTS_PER_SECOND=3
OPTIMISM_URL=
OPTIMISM_REQUESTS_PER_SECOND=1
OPTIMISM_REQUESTS_PER_SECOND=3
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=2
SOLANA_REQUESTS_PER_SECOND=5
TERRA_URL=
TERRA_REQUESTS_PER_SECOND=5
ALERT_ENABLED=false

2
deploy/contract-watcher/env/staging-mainnet.env vendored
View File

@ -32,7 +32,7 @@ OPTIMISM_REQUESTS_PER_SECOND=3
POLYGON_URL=
POLYGON_REQUESTS_PER_SECOND=3
SOLANA_URL=
SOLANA_REQUESTS_PER_SECOND=20
SOLANA_REQUESTS_PER_SECOND=500
TERRA_URL=
TERRA_REQUESTS_PER_SECOND=10
ALERT_ENABLED=false