Skip to content

Commit a1f00bf

Browse files
committed
fly/bootstrap_monitor: use network consts
1 parent 594ecfd commit a1f00bf

File tree

1 file changed

+10
-16
lines changed

1 file changed

+10
-16
lines changed

fly/cmd/bootstrap_monitor/main.go

+10-16
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import (
66
"log"
77
"os"
88
"strconv"
9+
"strings"
910
"time"
1011

1112
"github.com/certusone/wormhole/node/pkg/common"
@@ -27,13 +28,11 @@ var (
2728
rootCtxCancel context.CancelFunc
2829
hbReceived bool
2930
// The following are from the .env file:
30-
p2pNetworkID string
31-
p2pPort uint
32-
nodeKeyPath string
33-
ethRpcUrl string
34-
coreBridgeAddr string
35-
logLevel string
36-
promRemoteURL string
31+
p2pNetworkID string
32+
p2pPort uint
33+
nodeKeyPath string
34+
logLevel string
35+
promRemoteURL string
3736
)
3837

3938
var (
@@ -49,16 +48,13 @@ func loadEnvVars() {
4948
if err != nil {
5049
log.Fatal("Error loading .env file")
5150
}
52-
p2pNetworkID = verifyEnvVar("P2P_NETWORK_ID")
5351
port, err := strconv.ParseUint(verifyEnvVar("P2P_PORT"), 10, 32)
5452
if err != nil {
5553
log.Fatal("Error parsing P2P_PORT")
5654
}
5755
p2pPort = uint(port)
5856
nodeKeyPath = verifyEnvVar("NODE_KEY_PATH")
5957
logLevel = verifyEnvVar("LOG_LEVEL")
60-
ethRpcUrl = verifyEnvVar("ETH_RPC_URL")
61-
coreBridgeAddr = verifyEnvVar("CORE_BRIDGE_ADDR")
6258
promRemoteURL = verifyEnvVar("PROM_REMOTE_URL")
6359
}
6460

@@ -95,11 +91,9 @@ func RunPrometheusScraper(ctx context.Context, logger *zap.Logger, info promremo
9591

9692
func main() {
9793
loadEnvVars()
98-
p2pBootstraps := []string{"/dns4/wormhole-v2-mainnet-bootstrap.xlabs.xyz/udp/8999/quic/p2p/12D3KooWNQ9tVrcb64tw6bNs2CaNrUGPM7yRrKvBBheQ5yCyPHKC",
99-
"/dns4/wormhole.mcf.rocks/udp/8999/quic/p2p/12D3KooWDZVv7BhZ8yFLkarNdaSWaB43D6UbQwExJ8nnGAEmfHcU",
100-
"/dns4/wormhole-v2-mainnet-bootstrap.staking.fund/udp/8999/quic/p2p/12D3KooWG8obDX9DNi1KUwZNu9xkGwfKqTp2GFwuuHpWZ3nQruS1"}
101-
102-
level, err := ipfslog.LevelFromString("info")
94+
p2pNetworkID = p2p.MainnetNetworkId
95+
p2pBootstraps := strings.Split(p2p.MainnetBootstrapPeers, `,`)
96+
level, err := ipfslog.LevelFromString(logLevel)
10397
if err != nil {
10498
fmt.Println("Invalid log level")
10599
os.Exit(1)
@@ -221,7 +215,7 @@ func main() {
221215
}
222216

223217
if hbReceived {
224-
logger.Info("Heartbeat received for", zap.String("bootstrap peer", bootstrapPeer))
218+
logger.Info("***** Heartbeat received ***** for", zap.String("bootstrap peer", bootstrapPeer))
225219
bootstrapPeerStatus.WithLabelValues(bootstrapPeer).Set(1)
226220
} else {
227221
logger.Warn("******** ALERT ********** No heartbeat received for", zap.String("bootstrap peer", bootstrapPeer))

0 commit comments

Comments
 (0)