From 92c4360a3feb9752fcbabd0950e11488a082c5fa Mon Sep 17 00:00:00 2001
From: capossele <angelocapossele@gmail.com>
Date: Thu, 2 Apr 2020 19:39:46 +0100
Subject: [PATCH] :sparkles: enables drng dispatcher
---
go.mod | 1 +
pluginmgr/core/plugins.go | 2 ++
plugins/drng/plugin.go | 11 ++++++++++-
3 files changed, 13 insertions(+), 1 deletion(-)
diff --git a/go.mod b/go.mod
index 5c9e5984..1b60712a 100644
--- a/go.mod
+++ b/go.mod
@@ -7,6 +7,7 @@ require (
github.com/dgraph-io/badger/v2 v2.0.2
github.com/dgrijalva/jwt-go v3.2.0+incompatible
github.com/drand/drand v0.5.4
+ github.com/gobuffalo/logger v1.0.1
github.com/gobuffalo/packr/v2 v2.7.1
github.com/golang/protobuf v1.3.4
github.com/googollee/go-engine.io v1.4.3-0.20190924125625-798118fc0dd2
diff --git a/pluginmgr/core/plugins.go b/pluginmgr/core/plugins.go
index a210f3d1..cb4692f7 100644
--- a/pluginmgr/core/plugins.go
+++ b/pluginmgr/core/plugins.go
@@ -6,6 +6,7 @@ import (
"github.com/iotaledger/goshimmer/plugins/cli"
"github.com/iotaledger/goshimmer/plugins/config"
"github.com/iotaledger/goshimmer/plugins/database"
+ "github.com/iotaledger/goshimmer/plugins/drng"
"github.com/iotaledger/goshimmer/plugins/gossip"
"github.com/iotaledger/goshimmer/plugins/gracefulshutdown"
"github.com/iotaledger/goshimmer/plugins/logger"
@@ -28,4 +29,5 @@ var PLUGINS = node.Plugins(
gossip.PLUGIN,
gracefulshutdown.PLUGIN,
metrics.PLUGIN,
+ drng.PLUGIN,
)
diff --git a/plugins/drng/plugin.go b/plugins/drng/plugin.go
index 3b55c645..7f009d48 100644
--- a/plugins/drng/plugin.go
+++ b/plugins/drng/plugin.go
@@ -7,6 +7,7 @@ import (
"github.com/iotaledger/goshimmer/packages/binary/messagelayer/tangle"
"github.com/iotaledger/goshimmer/plugins/messagelayer"
"github.com/iotaledger/hive.go/events"
+ "github.com/iotaledger/hive.go/logger"
"github.com/iotaledger/hive.go/marshalutil"
"github.com/iotaledger/hive.go/node"
)
@@ -15,9 +16,13 @@ const name = "DRNG" // name of the plugin
var PLUGIN = node.NewPlugin(name, node.Enabled, configure, run)
-var Instance *drng.Instance
+var (
+ Instance *drng.Instance
+ log *logger.Logger
+)
func configure(*node.Plugin) {
+ log = logger.NewLogger(name)
Instance = drng.New()
configureEvents()
}
@@ -33,11 +38,15 @@ func configureEvents() {
parsedPayload, err := payload.Parse(marshalUtil)
if err != nil {
//TODO: handle error
+ log.Info(err)
return
}
if err := Instance.Dispatch(msg.IssuerPublicKey(), msg.IssuingTime(), parsedPayload); err != nil {
//TODO: handle error
+ log.Info(err)
+ return
}
+ log.Info(Instance.State.Randomness())
})
}))
--
GitLab