pss/outbox: Removed SetForwardFunction

Author: aperonam

pss/outbox/outbox.go

@@ -85,9 +85,6 @@ func (o *Outbox) processOutbox() {
 		}(slot)
 	}
 }
-func (o *Outbox) SetForwardFunction(forwardFunc forwardFunction) {
-	o.forwardFunc = forwardFunc
-}
 
 func (o *Outbox) msg(slot int) *outboxMsg {
 	return o.queue[slot]

pss/pss_test.go

@@ -262,13 +262,8 @@ func TestAddressMatchProx(t *testing.T) {
 	if err != nil {
 		t.Fatal(err.Error())
 	}
-	// enqueue method now is blocking, so we need always somebody processing the outbox
-	mockForwardFunc :=
-		func(msg *message.Message) error {
-			return nil
-		}
 
-	ps.outbox.SetForwardFunction(mockForwardFunc)
+	//Forwarding will fail. Since in this test we are not relying on forwarding, but just handling, the test is valid
 	ps.outbox.Start()
 
 	// create kademlia peers, so we have peers both inside and outside minproxlimit
@@ -374,6 +369,7 @@ func TestAddressMatchProx(t *testing.T) {
 
 		log.Trace("withprox addrs", "local", localAddr, "remote", remoteAddr)
 		ps.handle(context.TODO(), pssMsg)
+
 		if (!expects[i] && prevReceive != receives) || (expects[i] && prevReceive == receives) {
 			t.Fatalf("expected distance %d recipient %v when prox is set for handler", distance, expects[i])
 		}