From e2f3f69e2bd8522f1083c7a78b29cd8d88027348 Mon Sep 17 00:00:00 2001 From: tbjump <103955289+tbjump@users.noreply.github.com> Date: Mon, 28 Nov 2022 10:58:26 -0600 Subject: [PATCH] node/p2p: separate governor config and status message prefix (#1956) Co-authored-by: tbjump --- node/pkg/governor/governor_monitoring.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/node/pkg/governor/governor_monitoring.go b/node/pkg/governor/governor_monitoring.go index 00bfeb692..acf774abb 100644 --- a/node/pkg/governor/governor_monitoring.go +++ b/node/pkg/governor/governor_monitoring.go @@ -461,7 +461,8 @@ func (gov *ChainGovernor) CollectMetrics(hb *gossipv1.Heartbeat, sendC chan []by } } -var governorMessagePrefix = []byte("governor|") +var governorMessagePrefixConfig = []byte("governor_config_000000000000000000|") +var governorMessagePrefixStatus = []byte("governor_status_000000000000000000|") func (gov *ChainGovernor) publishConfig(hb *gossipv1.Heartbeat, sendC chan []byte, gk *ecdsa.PrivateKey, ourAddr ethCommon.Address) { chains := make([]*gossipv1.ChainGovernorConfig_Chain, 0) @@ -498,7 +499,7 @@ func (gov *ChainGovernor) publishConfig(hb *gossipv1.Heartbeat, sendC chan []byt return } - digest := ethCrypto.Keccak256Hash(append(governorMessagePrefix, b...)) + digest := ethCrypto.Keccak256Hash(append(governorMessagePrefixConfig, b...)) sig, err := ethCrypto.Sign(digest.Bytes(), gk) if err != nil { @@ -577,7 +578,7 @@ func (gov *ChainGovernor) publishStatus(hb *gossipv1.Heartbeat, sendC chan []byt return } - digest := ethCrypto.Keccak256Hash(append(governorMessagePrefix, b...)) + digest := ethCrypto.Keccak256Hash(append(governorMessagePrefixStatus, b...)) sig, err := ethCrypto.Sign(digest.Bytes(), gk) if err != nil {