From: Matt Joiner Date: Mon, 24 May 2021 07:37:04 +0000 (+1000) Subject: Expose AnacrolixDhtServerWrapper X-Git-Tag: v1.29.0~31^2~2 X-Git-Url: http://www.git.stargrave.org/?a=commitdiff_plain;h=bc186ac2114b21b2115ae5737fc4a081fbe247da;p=btrtrc.git Expose AnacrolixDhtServerWrapper --- diff --git a/client_test.go b/client_test.go index e8f652eb..84a99f46 100644 --- a/client_test.go +++ b/client_test.go @@ -322,7 +322,7 @@ func TestDhtInheritBlocklist(t *testing.T) { numServers := 0 cl.eachDhtServer(func(s DhtServer) { t.Log(s) - assert.Equal(t, ipl, s.(anacrolixDhtServerWrapper).Server.IPBlocklist()) + assert.Equal(t, ipl, s.(AnacrolixDhtServerWrapper).Server.IPBlocklist()) numServers++ }) assert.EqualValues(t, 2, numServers) diff --git a/dht.go b/dht.go index 8b0e8471..464090f9 100644 --- a/dht.go +++ b/dht.go @@ -29,11 +29,11 @@ type DhtAnnounce interface { Peers() <-chan dht.PeersValues } -type anacrolixDhtServerWrapper struct { +type AnacrolixDhtServerWrapper struct { *dht.Server } -func (me anacrolixDhtServerWrapper) Stats() interface{} { +func (me AnacrolixDhtServerWrapper) Stats() interface{} { return me.Server.Stats() } @@ -45,13 +45,13 @@ func (me anacrolixDhtAnnounceWrapper) Peers() <-chan dht.PeersValues { return me.Announce.Peers } -func (me anacrolixDhtServerWrapper) Announce(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error) { +func (me AnacrolixDhtServerWrapper) Announce(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error) { ann, err := me.Server.Announce(hash, port, impliedPort) return anacrolixDhtAnnounceWrapper{ann}, err } -func (me anacrolixDhtServerWrapper) Ping(addr *net.UDPAddr) { +func (me AnacrolixDhtServerWrapper) Ping(addr *net.UDPAddr) { me.Server.Ping(addr) } -var _ DhtServer = anacrolixDhtServerWrapper{} +var _ DhtServer = AnacrolixDhtServerWrapper{}