Add Logger package.

src/inter/common.go

@@ -6,6 +6,7 @@ import (
 	"strings"
 
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 )
 
 // ParseEvents parses events from ASCII-scheme for test purpose.
@@ -47,7 +48,7 @@ func ParseEvents(asciiScheme string) (
 				break
 			default: // it is a event name
 				if _, ok := names[symbol]; ok {
-					panic(fmt.Errorf("event '%s' already exists", symbol))
+					logger.Log.Fatalf("event '%s' already exists", symbol)
 				}
 				nCreators = append(nCreators, current-1)
 				nNames = append(nNames, symbol)

src/inter/event.go

@@ -9,6 +9,7 @@ import (
 	"github.com/Fantom-foundation/go-lachesis/src/crypto"
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
 	"github.com/Fantom-foundation/go-lachesis/src/inter/wire"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 )
 
 /*
@@ -44,7 +45,7 @@ func (e *Event) SignBy(priv *common.PrivateKey) error {
 // Verify sign event by public key.
 func (e *Event) Verify(pubKey *common.PublicKey) bool {
 	if pubKey == nil {
-		panic("can't verify")
+		logger.Log.Fatal("can't verify")
 	}
 
 	if e.Sign == "" {
@@ -54,7 +55,7 @@ func (e *Event) Verify(pubKey *common.PublicKey) bool {
 	hash := e.Hash()
 	r, s, err := crypto.DecodeSignature(string(e.Sign))
 	if err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 
 	return pubKey.Verify(hash.Bytes(), r, s)
@@ -112,7 +113,7 @@ func EventHashOf(e *Event) hash.Event {
 	w.Sign = ""
 	buf, err := proto.Marshal(w)
 	if err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 	return hash.Event(hash.Of(buf))
 }

src/logger/logger.go

@@ -0,0 +1,49 @@
+package logger
+
+import (
+	"github.com/sirupsen/logrus"
+)
+
+/*
+ * global vars:
+ */
+
+var (
+	// Log - global logger
+	Log *logrus.Logger
+)
+
+func init() {
+	defaults := logrus.StandardLogger()
+	defaults.SetLevel(logrus.DebugLevel)
+	SetLogger(defaults)
+}
+
+// SetLogger sets logger for whole package.
+func SetLogger(custom *logrus.Logger) {
+	if custom == nil {
+		panic("Nil-logger set")
+	}
+	Log = custom
+}
+
+// GetLevel return logrus.Level by string.
+// Example: "debug" -> logrus.DebugLevel and etc.
+func GetLevel(l string) logrus.Level {
+	switch l {
+	case "debug":
+		return logrus.DebugLevel
+	case "info":
+		return logrus.InfoLevel
+	case "warn":
+		return logrus.WarnLevel
+	case "error":
+		return logrus.ErrorLevel
+	case "fatal":
+		return logrus.FatalLevel
+	case "panic":
+		return logrus.PanicLevel
+	default:
+		return logrus.DebugLevel
+	}
+}

src/network/network.go

@@ -3,6 +3,8 @@ package network
 import (
 	"context"
 	"net"
+
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 )
 
 // ListenFunc returns addr listener.
@@ -13,7 +15,7 @@ type ListenFunc func(addr string) net.Listener
 func TCPListener(addr string) net.Listener {
 	res, err := net.Listen("tcp", addr)
 	if err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 	return res
 }
@@ -23,7 +25,7 @@ func TCPListener(addr string) net.Listener {
 func FakeListener(addr string) net.Listener {
 	res, err := listenFreeAddr(Addr(addr))
 	if err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 
 	return res

src/poslachesis/cli/command/transfer.go

@@ -4,6 +4,7 @@ import (
 	"github.com/spf13/cobra"
 
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 )
 
 // Transfer makes a transaction for stake transfer.
@@ -44,9 +45,9 @@ func init() {
 	Transfer.Flags().Uint64("amount", 0, "transaction amount (required)")
 
 	if err := Transfer.MarkFlagRequired("receiver"); err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 	if err := Transfer.MarkFlagRequired("amount"); err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 }

src/poslachesis/config.go

@@ -12,6 +12,7 @@ type Config struct {
 	AppPort  int
 	CtrlPort int
 	Node     posnode.Config
+	LogLevel string
 }
 
 // DefaultConfig returns lachesis default config.
@@ -20,6 +21,7 @@ func DefaultConfig() *Config {
 		AppPort:  55556,
 		CtrlPort: 55557,
 		Node:     *posnode.DefaultConfig(),
+		LogLevel: "debug",
 	}
 }
 

src/poslachesis/lachesis.go

@@ -2,11 +2,13 @@ package lachesis
 
 import (
 	"github.com/dgraph-io/badger"
+	"github.com/sirupsen/logrus"
 	"google.golang.org/grpc"
 
 	"github.com/Fantom-foundation/go-lachesis/src/common"
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
 	"github.com/Fantom-foundation/go-lachesis/src/kvdb"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 	"github.com/Fantom-foundation/go-lachesis/src/network"
 	"github.com/Fantom-foundation/go-lachesis/src/posnode"
 	"github.com/Fantom-foundation/go-lachesis/src/posposet"
@@ -37,6 +39,10 @@ func makeLachesis(db *badger.DB, host string, key *common.PrivateKey, conf *Conf
 		conf = DefaultConfig()
 	}
 
+	l := logrus.StandardLogger()
+	l.SetLevel(logger.GetLevel(conf.LogLevel))
+	logger.SetLogger(l)
+
 	c := posposet.New(cdb, ndb)
 	n := posnode.New(host, key, ndb, c, &conf.Node, listen, opts...)
 
@@ -75,7 +81,7 @@ func (l *Lachesis) AddPeers(hosts ...string) {
 
 func (l *Lachesis) init(genesis map[hash.Peer]uint64) {
 	if err := l.consensusStore.ApplyGenesis(genesis); err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 }
 

src/poslachesis/service.go

@@ -1,6 +1,7 @@
 package lachesis
 
 import (
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 	"github.com/Fantom-foundation/go-lachesis/src/network"
 	"github.com/Fantom-foundation/go-lachesis/src/poset"
 	"github.com/Fantom-foundation/go-lachesis/src/posposet"
@@ -27,7 +28,7 @@ func (l *Lachesis) serviceStart() {
 			l.service.listen,
 		)
 		if err != nil {
-			panic(err)
+			logger.Log.Fatal(err)
 		}
 		defer ctrl.Close()
 
@@ -42,7 +43,7 @@ func (l *Lachesis) serviceStart() {
 			l.service.listen,
 		)
 		if err != nil {
-			panic(err)
+			logger.Log.Fatal(err)
 		}
 		defer app.Close()
 

src/posnode/api/security.go

@@ -15,6 +15,7 @@ import (
 	"github.com/Fantom-foundation/go-lachesis/src/common"
 	"github.com/Fantom-foundation/go-lachesis/src/crypto"
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 )
 
 // peerID is a internal key for context.Value().
@@ -86,7 +87,7 @@ func ServerAuth(key *common.PrivateKey) grpc.UnaryServerInterceptor {
 		sign := signData(resp, key)
 		md := metadata.Pairs("sign", sign, "pub", pub)
 		if e := grpc.SetTrailer(ctx, md); e != nil {
-			panic(err)
+			logger.Log.Fatal(err)
 		}
 
 		return resp, err
@@ -154,7 +155,7 @@ func verifyData(data interface{}, sign string, pub *common.PublicKey) error {
 func hashOfData(data interface{}) hash.Hash {
 	d, ok := data.(proto.Message)
 	if !ok {
-		panic("data is not proto.Message")
+		logger.Log.Fatal("data is not proto.Message")
 	}
 
 	if IsProtoEmpty(&d) {
@@ -164,7 +165,7 @@ func hashOfData(data interface{}) hash.Hash {
 	var pbf proto.Buffer
 	pbf.SetDeterministic(true)
 	if err := pbf.Marshal(d); err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 
 	return hash.Of(pbf.Bytes())

src/posnode/api/wire.go

@@ -20,6 +20,7 @@ import (
 
 	"github.com/Fantom-foundation/go-lachesis/src/common"
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 	"github.com/Fantom-foundation/go-lachesis/src/network"
 )
 
@@ -48,13 +49,13 @@ func StartService(bind string, key *common.PrivateKey, svc NodeServer, log func(
 func GrpcPeerHost(ctx context.Context) string {
 	p, ok := peer.FromContext(ctx)
 	if !ok {
-		panic("GrpcPeerHost should be called from gRPC handler only")
+		logger.Log.Fatal("GrpcPeerHost should be called from gRPC handler only")
 	}
 
 	addr := p.Addr.String()
 	host, _, err := net.SplitHostPort(addr)
 	if err != nil {
-		panic(err)
+		logger.Log.Fatal(err)
 	}
 	return host
 }
@@ -63,7 +64,7 @@ func GrpcPeerHost(ctx context.Context) string {
 func GrpcPeerID(ctx context.Context) hash.Peer {
 	id, ok := ctx.Value(peerID{}).(hash.Peer)
 	if !ok {
-		panic("GrpcPeerID should be called from gRPC handler only")
+		logger.Log.Fatal("GrpcPeerID should be called from gRPC handler only")
 	}
 
 	return id

src/posnode/builtin.go

@@ -2,6 +2,8 @@ package posnode
 
 import (
 	"sync"
+
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 )
 
 // builtin is a set of some built in data.
@@ -19,7 +21,7 @@ func (n *Node) AddBuiltInPeers(hosts ...string) {
 
 	n.builtin.hosts = append(n.builtin.hosts, hosts...)
 
-	n.log.Debugf("built in peer hosts: %v", n.builtin.hosts)
+	logger.Log.Debugf("built in peer hosts: %v", n.builtin.hosts)
 }
 
 // NextBuiltInPeer returns next peer host or empty string.

src/posnode/client.go

@@ -10,6 +10,7 @@ import (
 	"github.com/pkg/errors"
 	"google.golang.org/grpc"
 
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 	"github.com/Fantom-foundation/go-lachesis/src/posnode/api"
 )
 
@@ -50,12 +51,12 @@ func (n *Node) initClient() {
 // ConnectTo connects to other node service.
 func (n *Node) ConnectTo(peer *Peer) (client api.NodeClient, free func(), fail func(error), err error) {
 	addr := n.NetAddrOf(peer.Host)
-	n.log.Debugf("connect to %s", addr)
+	logger.Log.Debugf("connect to %s", addr)
 
 	c, err := n.connPool.Get(addr)
 	if err != nil {
 		err = errors.Wrapf(err, "connect to: %s", addr)
-		n.log.Warn(err)
+		logger.Log.Warn(err)
 		return
 	}
 

src/posnode/discovery.go

@@ -9,6 +9,7 @@ import (
 	"google.golang.org/grpc/status"
 
 	"github.com/Fantom-foundation/go-lachesis/src/hash"
+	"github.com/Fantom-foundation/go-lachesis/src/logger"
 	"github.com/Fantom-foundation/go-lachesis/src/posnode/api"
 )
 
@@ -58,7 +59,7 @@ func (n *Node) StartDiscovery() {
 		}
 	}()
 
-	n.log.Info("discovery started")
+	logger.Log.Info("discovery started")
 }
 
 // StopDiscovery stops network discovery.
@@ -70,7 +71,7 @@ func (n *Node) StopDiscovery() {
 	close(n.discovery.done)
 	n.discovery.done = nil
 
-	n.log.Info("discovery stopped")
+	logger.Log.Info("discovery stopped")
 }
 
 // CheckPeerIsKnown queues peer checking for a late.
@@ -81,7 +82,7 @@ func (n *Node) CheckPeerIsKnown(host string, id *hash.Peer) {
 		unknown: id,
 	}:
 	default:
-		n.log.Warn("discovery.tasks queue is full, so skipped")
+		logger.Log.Warn("discovery.tasks queue is full, so skipped")
 	}
 }
 
@@ -94,7 +95,7 @@ func (n *Node) AskPeerInfo(host string, id *hash.Peer) {
 		return
 	}
 
-	n.log.Debugf("ask %s about peer %s", host, id)
+	logger.Log.Debugf("ask %s about peer %s", host, id)
 
 	peer := &Peer{Host: host}
 
@@ -116,7 +117,7 @@ func (n *Node) AskPeerInfo(host string, id *hash.Peer) {
 		if id == nil {
 			n.ConnectFail(peer, fmt.Errorf("host %s knows nothing about self", host))
 		} else {
-			n.log.Warnf("peer %s (%s) knows nothing about %s", source.String(), host, id.String())
+			logger.Log.Warnf("peer %s (%s) knows nothing about %s", source.String(), host, id.String())
 			n.ConnectOK(peer)
 		}
 		return
@@ -136,7 +137,7 @@ func (n *Node) AskPeerInfo(host string, id *hash.Peer) {
 	info.Host = host
 	peer = WireToPeer(info)
 	n.store.SetWirePeer(peer.ID, info)
-	n.log.Debugf("discovered new peer %s with host %s", info.ID, info.Host)
+	logger.Log.Debugf("discovered new peer %s with host %s", info.ID, info.Host)
 	n.ConnectOK(peer)
 }