From 732038ac28a1f293609cc24c62550f4fb6d3d42c Mon Sep 17 00:00:00 2001
From: Leonard Lyubich <leonard@nspcc.ru>
Date: Wed, 24 Mar 2021 12:57:50 +0300
Subject: [PATCH] [#444] cmd/node: Serve ReputationService on the node

Register reputation service server that:
  * verifies signatures of the requests and signs the responses;
  * attaches response meta header to the responses;
  * logs body structures of the requests (only as initial implementation, in
    future it will be replaces with local trust storage).

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
---
 cmd/neofs-node/reputation.go | 41 ++++++++++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)

diff --git a/cmd/neofs-node/reputation.go b/cmd/neofs-node/reputation.go
index fa463ca7..a65aacd3 100644
--- a/cmd/neofs-node/reputation.go
+++ b/cmd/neofs-node/reputation.go
@@ -2,15 +2,20 @@ package main
 
 import (
 	"bytes"
+	"context"
 	"encoding/hex"
 
+	v2reputation "github.com/nspcc-dev/neofs-api-go/v2/reputation"
+	v2reputationgrpc "github.com/nspcc-dev/neofs-api-go/v2/reputation/grpc"
 	crypto "github.com/nspcc-dev/neofs-crypto"
 	netmapcore "github.com/nspcc-dev/neofs-node/pkg/core/netmap"
 	"github.com/nspcc-dev/neofs-node/pkg/morph/event"
 	"github.com/nspcc-dev/neofs-node/pkg/morph/event/netmap"
+	grpcreputation "github.com/nspcc-dev/neofs-node/pkg/network/transport/reputation/grpc"
 	"github.com/nspcc-dev/neofs-node/pkg/services/reputation"
 	trustcontroller "github.com/nspcc-dev/neofs-node/pkg/services/reputation/local/controller"
 	truststorage "github.com/nspcc-dev/neofs-node/pkg/services/reputation/local/storage"
+	reputationrpc "github.com/nspcc-dev/neofs-node/pkg/services/reputation/rpc"
 	"github.com/nspcc-dev/neofs-node/pkg/util/logger"
 	"github.com/pkg/errors"
 	"go.uber.org/zap"
@@ -148,4 +153,40 @@ func initReputationService(c *cfg) {
 		// TODO: implement and use worker pool [neofs-node#440]
 		go c.cfgReputation.localTrustCtrl.Report(reportPrm)
 	})
+
+	v2reputationgrpc.RegisterReputationServiceServer(c.cfgGRPC.server,
+		grpcreputation.New(
+			reputationrpc.NewSignService(
+				c.key,
+				reputationrpc.NewResponseService(
+					&loggingReputationServer{
+						log: c.log,
+					},
+					c.respSvc,
+				),
+			),
+		),
+	)
+}
+
+type loggingReputationServer struct {
+	log *logger.Logger
+}
+
+func (s *loggingReputationServer) SendLocalTrust(_ context.Context, req *v2reputation.SendLocalTrustRequest) (*v2reputation.SendLocalTrustResponse, error) {
+	body := req.GetBody()
+
+	log := s.log.With(zap.Uint64("epoch", body.GetEpoch()))
+
+	for _, t := range body.GetTrusts() {
+		log.Info("local trust received",
+			zap.String("peer", hex.EncodeToString(t.GetPeer())),
+			zap.Float64("value", t.GetValue()),
+		)
+	}
+
+	resp := new(v2reputation.SendLocalTrustResponse)
+	resp.SetBody(new(v2reputation.SendLocalTrustResponseBody))
+
+	return resp, nil
 }