Resolve consensus message sub error (#137)

diff --git a/event/event.go b/event/event.go
index 8b08ee5..de421fe 100644 (file)
--- a/event/event.go
+++ b/event/event.go
@@ -33,9 +33,6 @@ type BlockSignatureEvent struct {
        XPub      [64]byte
 }
 
-//NewBlockProposeEvent block propose event which needs to broadcast.
-type NewBlockProposeEvent struct{ Block types.Block }
-
 // TypeMuxEvent is a time-tagged notification pushed to subscribers.
 type TypeMuxEvent struct {
        Time time.Time

diff --git a/netsync/consensusmgr/handle.go b/netsync/consensusmgr/handle.go
index 67fec0c..668a2f7 100644 (file)
--- a/netsync/consensusmgr/handle.go
+++ b/netsync/consensusmgr/handle.go
@@ -102,7 +102,7 @@ func (m *Manager) handleBlockSignatureMsg(peerID string, msg *BlockSignatureMsg)
 }
 
 func (m *Manager) blockProposeMsgBroadcastLoop() {
-       blockProposeMsgSub, err := m.eventDispatcher.Subscribe(event.NewBlockProposeEvent{})
+       blockProposeMsgSub, err := m.eventDispatcher.Subscribe(event.NewProposedBlockEvent{})
        if err != nil {
                logrus.WithFields(logrus.Fields{"module": logModule, "err": err}).Error("failed on subscribe NewBlockProposeEvent")
                return
@@ -117,7 +117,7 @@ func (m *Manager) blockProposeMsgBroadcastLoop() {
                                return
                        }
 
-                       ev, ok := obj.Data.(event.NewBlockProposeEvent)
+                       ev, ok := obj.Data.(event.NewProposedBlockEvent)
                        if !ok {
                                logrus.WithFields(logrus.Fields{"module": logModule}).Error("event type error")
                                continue