update

pkg/anonymity/anonymity.go

@@ -109,7 +109,7 @@ func (p *sNode) runProducer(pCtx context.Context) error {
 				continue
 			}
 			// internal logger
-			_, _ = p.storeHashWithProduce(pCtx, netMsg)
+			_, _ = p.produceMessage(pCtx, netMsg)
 		}
 	}
 }
@@ -126,7 +126,7 @@ func (p *sNode) runConsumer(pCtx context.Context) error {
 				continue
 			}
 			// internal logger
-			_ = p.messageHandler(pCtx, netMsg)
+			_ = p.consumeMessage(pCtx, netMsg)
 		}
 	}
 }
@@ -225,7 +225,7 @@ func (p *sNode) recvResponse(pCtx context.Context, pActionKey string) ([]byte, e
 	}
 }
 
-func (p *sNode) messageHandler(pCtx context.Context, pNetMsg net_message.IMessage) error {
+func (p *sNode) consumeMessage(pCtx context.Context, pNetMsg net_message.IMessage) error {
 	logBuilder := anon_logger.NewLogBuilder(p.fSettings.GetServiceName())
 
 	// update logger state
@@ -389,7 +389,7 @@ func (p *sNode) enrichLogger(pLogBuilder anon_logger.ILogBuilder, pNetMsg net_me
 		WithSize(size)
 }
 
-func (p *sNode) storeHashWithProduce(
+func (p *sNode) produceMessage(
 	pCtx context.Context,
 	pNetMsg net_message.IMessage,
 ) (bool, error) {

pkg/anonymity/anonymity_test.go

@@ -338,7 +338,7 @@ func TestHandleWrapper(t *testing.T) {
 	defer testFreeNodes([]INode{_node}, 7)
 
 	node := _node.(*sNode)
-	handler := node.messageHandler
+	handler := node.consumeMessage
 	client := node.fQBProcessor.GetClient()
 
 	privKey := client.GetPrivKey()
@@ -488,11 +488,11 @@ func TestStoreHashWithBroadcastMessage(t *testing.T) {
 	})
 
 	netMsg := node.testNewNetworkMessage(sett, msg)
-	if ok, err := node.storeHashWithProduce(ctx, netMsg); !ok || err != nil {
+	if ok, err := node.produceMessage(ctx, netMsg); !ok || err != nil {
 		t.Error(err)
 		return
 	}
-	if ok, err := node.storeHashWithProduce(ctx, netMsg); ok || err != nil {
+	if ok, err := node.produceMessage(ctx, netMsg); ok || err != nil {
 		switch {
 		case ok:
 			t.Error("success store one message again")