From 7c7bb94864b9c6adacd71d49315736bc4e82ea01 Mon Sep 17 00:00:00 2001
From: josh <josh@elixxir.io>
Date: Thu, 21 Apr 2022 13:02:31 -0700
Subject: [PATCH] Add String method to processors
---
single/listener.go | 7 +++++++
single/requestPartProcessor.go | 6 ++++++
single/responseProcessor.go | 7 +++++++
ud/utils_test.go | 4 ++++
4 files changed, 24 insertions(+)
diff --git a/single/listener.go b/single/listener.go
index 3f3efbf75..0ee3165a0 100644
--- a/single/listener.go
+++ b/single/listener.go
@@ -13,6 +13,8 @@ import (
"gitlab.com/xx_network/primitives/id"
)
+const listenerProcessorName = "listenerProcessorName"
+
type Receiver interface {
Callback(*Request, receptionID.EphemeralIdentity, []rounds.Round)
}
@@ -145,6 +147,11 @@ func (l *listener) Process(ecrMsg format.Message,
}
}
+func (l *listener) String() string {
+ return listenerProcessorName
+
+}
+
func (l *listener) Stop() {
svc := cmixMsg.Service{
Identifier: l.myId[:],
diff --git a/single/requestPartProcessor.go b/single/requestPartProcessor.go
index bf473d948..b6564d1e8 100644
--- a/single/requestPartProcessor.go
+++ b/single/requestPartProcessor.go
@@ -16,6 +16,8 @@ import (
"gitlab.com/xx_network/primitives/id"
)
+const requestPartProcessorName = "requestPartProcessor"
+
// requestPartProcessor handles the decryption and collation of request parts.
type requestPartProcessor struct {
myId *id.ID
@@ -56,3 +58,7 @@ func (rpp *requestPartProcessor) Process(msg format.Message,
rpp.cb(payload, rpp.roundIDs.getList())
}
}
+
+func (rpp *requestPartProcessor) String() string {
+ return requestPartProcessorName
+}
diff --git a/single/responseProcessor.go b/single/responseProcessor.go
index 0339427dd..5f1e89163 100644
--- a/single/responseProcessor.go
+++ b/single/responseProcessor.go
@@ -9,6 +9,8 @@ import (
"gitlab.com/elixxir/primitives/format"
)
+const responseProcessorName = "responseProcessorName"
+
type callbackWrapper func(payload []byte,
receptionID receptionID.EphemeralIdentity, rounds []rounds.Round, err error)
@@ -58,3 +60,8 @@ func (rsp *responseProcessor) Process(ecrMsg format.Message,
rsp.callback(payload, receptionID, rsp.roundIDs.getList(), nil)
}
}
+
+func (rsp *responseProcessor) String() string {
+ return responseProcessorName
+
+}
diff --git a/ud/utils_test.go b/ud/utils_test.go
index 0cfc90dd0..675acc924 100644
--- a/ud/utils_test.go
+++ b/ud/utils_test.go
@@ -313,6 +313,10 @@ func (tnm *testNetworkManager) Process(ecrMsg format.Message,
}
+func (tnm *testNetworkManager) String() string {
+ return "mockPRocessor"
+}
+
func (tnm *testNetworkManager) DeleteService(clientID *id.ID, toDelete message.Service, processor message.Processor) {
return
}
--
GitLab