dex: implement bad peer detect and disconnect mechanism (#360)

1 files changed, 6 insertions, 1 deletions

diff --git a/dex/network.go b/dex/network.go
index 0e2d338c1..ab676a349 100644
--- a/dex/network.go
+++ b/dex/network.go
@@ -84,6 +84,11 @@ func (n *DexconNetwork) BroadcastAgreementResult(result *types.AgreementResult)
 }
 
 // ReceiveChan returns a channel to receive messages from DEXON network.
-func (n *DexconNetwork) ReceiveChan() <-chan interface{} {
+func (n *DexconNetwork) ReceiveChan() <-chan types.Msg {
 	return n.pm.ReceiveChan()
 }
+
+// ReportBadPeerChan returns a channel to receive messages from DEXON network.
+func (n *DexconNetwork) ReportBadPeerChan() chan<- interface{} {
+	return n.pm.ReportBadPeerChan()
+}