diff --git a/cmd/node/appchain.go b/cmd/node/appchain.go index 87ef01a..b864f84 100644 --- a/cmd/node/appchain.go +++ b/cmd/node/appchain.go @@ -533,7 +533,6 @@ func (ap *AppChain) SendReputerModeData(ctx context.Context, topicId uint64, res var reputerAddrs []*string var reputerAddrSet = make(map[string]bool) // Prevents duplicate reputer addresses from being counted in vote tally var nonceCurrent *emissionstypes.Nonce - var nonceEval *emissionstypes.Nonce var blockCurrentToReputer = make(map[int64][]string) // map blockHeight to addresses of reputers who sent data for current block height var blockEvalToReputer = make(map[int64][]string) // map blockHeight to addresses of reputers who sent data for eval block height @@ -596,37 +595,31 @@ func (ap *AppChain) SendReputerModeData(ctx context.Context, topicId uint64, res } blockCurrentHeight, blockEvalHeight, err := ap.getStakeWeightedBlockHeights(ctx, topicId, &blockCurrentToReputer, &blockEvalToReputer, reputerAddrs) + ap.Logger.Info().Err(err).Int64("Current", blockCurrentHeight).Int64("Eval", blockEvalHeight).Msg("Weighted Block heights") if err != nil { ap.Logger.Error().Err(err).Msg("could not get stake-weighted block heights, not sending data to the chain") return } - if blockCurrentHeight == -1 || blockEvalHeight == -1 { + if blockCurrentHeight == -1 { ap.Logger.Error().Msg("could not get stake-weighted block heights, not sending data to the chain") return } - if blockCurrentHeight < blockEvalHeight { - ap.Logger.Error().Int64("blockCurrentHeight", blockCurrentHeight).Int64("blockEvalHeight", blockEvalHeight).Msg("blockCurrentHeight < blockEvalHeight, not sending data to the chain") - return - } nonceCurrent = &emissionstypes.Nonce{BlockHeight: blockCurrentHeight} - nonceEval = &emissionstypes.Nonce{BlockHeight: blockEvalHeight} // Remove those bundles that do not come from the current block height var valueBundlesFiltered []*emissionstypes.ReputerValueBundle for _, valueBundle := range valueBundles { - if valueBundle.ValueBundle.ReputerRequestNonce.ReputerNonce.BlockHeight == blockCurrentHeight && valueBundle.ValueBundle.ReputerRequestNonce.WorkerNonce.BlockHeight == blockEvalHeight { + if valueBundle.ValueBundle.ReputerRequestNonce.ReputerNonce.BlockHeight == blockCurrentHeight { ap.Logger.Debug(). Str("reputer", valueBundle.ValueBundle.Reputer). Str("nonce reputer", strconv.FormatInt(valueBundle.ValueBundle.ReputerRequestNonce.ReputerNonce.BlockHeight, 10)). - Str("nonce worker", strconv.FormatInt(valueBundle.ValueBundle.ReputerRequestNonce.WorkerNonce.BlockHeight, 10)). Msg("Valid nonce, adding to valueBundlesFiltered") valueBundlesFiltered = append(valueBundlesFiltered, valueBundle) } else { ap.Logger.Warn(). Str("reputer", valueBundle.ValueBundle.Reputer). Str("nonce reputer", strconv.FormatInt(valueBundle.ValueBundle.ReputerRequestNonce.ReputerNonce.BlockHeight, 10)). - Str("nonce worker", strconv.FormatInt(valueBundle.ValueBundle.ReputerRequestNonce.WorkerNonce.BlockHeight, 10)). Msg("Rejected Bundle, non-matching nonces.") } } @@ -636,7 +629,6 @@ func (ap *AppChain) SendReputerModeData(ctx context.Context, topicId uint64, res Sender: ap.Address, ReputerRequestNonce: &emissionstypes.ReputerRequestNonce{ ReputerNonce: nonceCurrent, - WorkerNonce: nonceEval, }, TopicId: topicId, ReputerValueBundles: valueBundles, diff --git a/cmd/node/main.go b/cmd/node/main.go index 700ee4f..f46ccbe 100644 --- a/cmd/node/main.go +++ b/cmd/node/main.go @@ -33,8 +33,8 @@ import ( "github.com/allora-network/b7s/node" "github.com/allora-network/b7s/peerstore" "github.com/allora-network/b7s/store" - "github.com/prometheus/client_golang/prometheus" - "github.com/prometheus/client_golang/prometheus/promhttp" + "github.com/prometheus/client_golang/prometheus" + "github.com/prometheus/client_golang/prometheus/promhttp" ) const ( @@ -44,44 +44,44 @@ const ( ) var ( - opsProcessed = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "allora_node_total_operations", - Help: "The total number of processed operations", - }) + opsProcessed = prometheus.NewCounter(prometheus.CounterOpts{ + Name: "allora_node_total_operations", + Help: "The total number of processed operations", + }) headRequests = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "allora_head_node_total_requests", - Help: "The total number of request made by head node", - }) + Name: "allora_head_node_total_requests", + Help: "The total number of request made by head node", + }) workerResponse = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "allora_worker_node_total_response", - Help: "The total number of responds from worker node", - }) + Name: "allora_worker_node_total_response", + Help: "The total number of responds from worker node", + }) reputerResponse = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "allora_reputer_node_total_response", - Help: "The total number of responds from reputer node", - }) + Name: "allora_reputer_node_total_response", + Help: "The total number of responds from reputer node", + }) workerChainCommit = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "allora_worker_node_chain_commit", - Help: "The total number of worker commits to the chain", - }) + Name: "allora_worker_node_chain_commit", + Help: "The total number of worker commits to the chain", + }) reputerChainCommit = prometheus.NewCounter(prometheus.CounterOpts{ - Name: "allora_reputer_node_chain_commit", - Help: "The total number of reputer commits to the chain", - }) + Name: "allora_reputer_node_chain_commit", + Help: "The total number of reputer commits to the chain", + }) ) func init() { - prometheus.MustRegister(opsProcessed) - prometheus.MustRegister(headRequests) - prometheus.MustRegister(workerResponse) - prometheus.MustRegister(reputerResponse) - prometheus.MustRegister(workerChainCommit) - prometheus.MustRegister(reputerChainCommit) + prometheus.MustRegister(opsProcessed) + prometheus.MustRegister(headRequests) + prometheus.MustRegister(workerResponse) + prometheus.MustRegister(reputerResponse) + prometheus.MustRegister(workerChainCommit) + prometheus.MustRegister(reputerChainCommit) } func main() { @@ -292,9 +292,6 @@ func (e *AlloraExecutor) ExecuteFunction(requestID string, req execute.Request) ReputerNonce: &types.Nonce{ BlockHeight: alloraBlockHeightCurrent, }, - WorkerNonce: &types.Nonce{ - BlockHeight: alloraBlockHeightEval, - }, } // Now get the string of the value, unescape it and unmarshall into ValueBundle @@ -484,7 +481,7 @@ func (e *AlloraExecutor) ExecuteFunction(requestID string, req execute.Request) } // increament the number of operations processed by worker or reputer - opsProcessed.Inc() + opsProcessed.Inc() return result, err } diff --git a/go.mod b/go.mod index f44360d..ce5edd6 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,7 @@ go 1.22.2 require ( cosmossdk.io/math v1.3.0 - github.com/allora-network/allora-chain v0.2.11 + github.com/allora-network/allora-chain v0.2.13-0.20240712153715-51a1470939ab github.com/allora-network/b7s v0.0.2-0.20240626021501-5a913378a8d8 github.com/cockroachdb/pebble v1.1.0 github.com/cosmos/cosmos-sdk v0.50.5 diff --git a/go.sum b/go.sum index f5e3994..ca36eaa 100644 --- a/go.sum +++ b/go.sum @@ -57,8 +57,10 @@ github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751/go.mod h1:LOuy github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0= github.com/alecthomas/units v0.0.0-20190717042225-c3de453c63f4/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0= github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d/go.mod h1:rBZYJk541a8SKzHPHnH3zbiI+7dagKZ0cgpgrD7Fyho= -github.com/allora-network/allora-chain v0.2.11 h1:dNKYc9tZA1GwEcLii8U+bmUX/crVxuB2pSq0UQEn07w= -github.com/allora-network/allora-chain v0.2.11/go.mod h1:nYJd641Y0iieiL+t+P5VOWnYdiAq2kiazdbL1Bi4jrw= +github.com/allora-network/allora-chain v0.2.13-0.20240711095825-787633192f37 h1:dc7/UcloiDQGJp2hmfeED1GvFZmXJGTNQNylDhHn+Ok= +github.com/allora-network/allora-chain v0.2.13-0.20240711095825-787633192f37/go.mod h1:nYJd641Y0iieiL+t+P5VOWnYdiAq2kiazdbL1Bi4jrw= +github.com/allora-network/allora-chain v0.2.13-0.20240712153715-51a1470939ab h1:IFVoMze1vnSQ84mFP8Nw14PYWfGq6dGFFV38xb/J2wY= +github.com/allora-network/allora-chain v0.2.13-0.20240712153715-51a1470939ab/go.mod h1:nYJd641Y0iieiL+t+P5VOWnYdiAq2kiazdbL1Bi4jrw= github.com/allora-network/b7s v0.0.2-0.20240626021501-5a913378a8d8 h1:w0MOdikeH7bmSoqJCgc9j9bRp7+sIRK7Rvf0P00S12g= github.com/allora-network/b7s v0.0.2-0.20240626021501-5a913378a8d8/go.mod h1:rJJrdC5Y83LEDFxo/iJp3JJpi8I6TJncOTigMWk8ieE= github.com/anmitsu/go-shlex v0.0.0-20161002113705-648efa622239/go.mod h1:2FmKhYUyUczH0OGQWaF5ceTx0UBShxjsH6f8oGKYe2c=