Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
M
mybee
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
vicotor
mybee
Commits
111ca35a
Unverified
Commit
111ca35a
authored
Jul 09, 2021
by
chuwt
Committed by
GitHub
Jul 09, 2021
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
chore: fix typos (#2320)
parent
3289c621
Changes
8
Hide whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
13 additions
and
13 deletions
+13
-13
peer_test.go
pkg/debugapi/peer_test.go
+2
-2
handshake.go
pkg/p2p/libp2p/internal/handshake/handshake.go
+1
-1
handshake_test.go
pkg/p2p/libp2p/internal/handshake/handshake_test.go
+2
-2
ens_integration_test.go
pkg/resolver/client/ens/ens_integration_test.go
+1
-1
export_test.go
pkg/resolver/client/ens/export_test.go
+1
-1
swap.go
pkg/settlement/swap/mock/swap.go
+2
-2
tag.go
pkg/tags/tag.go
+1
-1
kademlia.go
pkg/topology/kademlia/kademlia.go
+3
-3
No files found.
pkg/debugapi/peer_test.go
View file @
111ca35a
...
...
@@ -104,7 +104,7 @@ func TestConnect(t *testing.T) {
func
TestDisconnect
(
t
*
testing
.
T
)
{
address
:=
swarm
.
MustParseHexAddress
(
"ca1e9f3938cc1425c6061b96ad9eb93e134dfe8734ad490164ef20af9d1cf59c"
)
unknownAdd
d
ress
:=
swarm
.
MustParseHexAddress
(
"ca1e9f3938cc1425c6061b96ad9eb93e134dfe8734ad490164ef20af9d1cf59e"
)
unknownAddress
:=
swarm
.
MustParseHexAddress
(
"ca1e9f3938cc1425c6061b96ad9eb93e134dfe8734ad490164ef20af9d1cf59e"
)
errorAddress
:=
swarm
.
MustParseHexAddress
(
"ca1e9f3938cc1425c6061b96ad9eb93e134dfe8734ad490164ef20af9d1cf59a"
)
testErr
:=
errors
.
New
(
"test error"
)
...
...
@@ -132,7 +132,7 @@ func TestDisconnect(t *testing.T) {
})
t
.
Run
(
"unknown"
,
func
(
t
*
testing
.
T
)
{
jsonhttptest
.
Request
(
t
,
testServer
.
Client
,
http
.
MethodDelete
,
"/peers/"
+
unknownAdd
d
ress
.
String
(),
http
.
StatusBadRequest
,
jsonhttptest
.
Request
(
t
,
testServer
.
Client
,
http
.
MethodDelete
,
"/peers/"
+
unknownAddress
.
String
(),
http
.
StatusBadRequest
,
jsonhttptest
.
WithExpectedJSONResponse
(
jsonhttp
.
StatusResponse
{
Code
:
http
.
StatusBadRequest
,
Message
:
"peer not found"
,
...
...
pkg/p2p/libp2p/internal/handshake/handshake.go
View file @
111ca35a
...
...
@@ -56,7 +56,7 @@ var (
// AdvertisableAddressResolver can Resolve a Multiaddress.
type
AdvertisableAddressResolver
interface
{
Resolve
(
observedAdd
d
ress
ma
.
Multiaddr
)
(
ma
.
Multiaddr
,
error
)
Resolve
(
observedAddress
ma
.
Multiaddr
)
(
ma
.
Multiaddr
,
error
)
}
type
SenderMatcher
interface
{
...
...
pkg/p2p/libp2p/internal/handshake/handshake_test.go
View file @
111ca35a
...
...
@@ -729,7 +729,7 @@ type AdvertisableAddresserMock struct {
err
error
}
func
(
a
*
AdvertisableAddresserMock
)
Resolve
(
observedAdd
d
ress
ma
.
Multiaddr
)
(
ma
.
Multiaddr
,
error
)
{
func
(
a
*
AdvertisableAddresserMock
)
Resolve
(
observedAddress
ma
.
Multiaddr
)
(
ma
.
Multiaddr
,
error
)
{
if
a
.
err
!=
nil
{
return
nil
,
a
.
err
}
...
...
@@ -738,7 +738,7 @@ func (a *AdvertisableAddresserMock) Resolve(observedAdddress ma.Multiaddr) (ma.M
return
a
.
advertisableAddress
,
nil
}
return
observedAdd
d
ress
,
nil
return
observedAddress
,
nil
}
type
MockSenderMatcher
struct
{
...
...
pkg/resolver/client/ens/ens_integration_test.go
View file @
111ca35a
...
...
@@ -14,7 +14,7 @@ import (
"github.com/ethersphere/bee/pkg/swarm"
)
func
TestENSntegration
(
t
*
testing
.
T
)
{
func
TestENS
I
ntegration
(
t
*
testing
.
T
)
{
// TODO: consider using a stable gateway instead of INFURA.
defaultEndpoint
:=
"https://goerli.infura.io/v3/59d83a5a4be74f86b9851190c802297b"
defaultAddr
:=
swarm
.
MustParseHexAddress
(
"00cb23598c2e520b6a6aae3ddc94fed4435a2909690bdd709bf9d9e7c2aadfad"
)
...
...
pkg/resolver/client/ens/export_test.go
View file @
111ca35a
...
...
@@ -14,7 +14,7 @@ const SwarmContentHashPrefix = swarmContentHashPrefix
var
ErrNotImplemented
=
errNotImplemented
// WithConnectFunc will set the Dial function implementaton.
// WithConnectFunc will set the Dial function implementat
i
on.
func
WithConnectFunc
(
fn
func
(
endpoint
string
,
contractAddr
string
)
(
*
ethclient
.
Client
,
*
goens
.
Registry
,
error
))
Option
{
return
func
(
c
*
Client
)
{
c
.
connectFn
=
fn
...
...
pkg/settlement/swap/mock/swap.go
View file @
111ca35a
...
...
@@ -42,7 +42,7 @@ type Service struct {
cashoutStatusFunc
func
(
ctx
context
.
Context
,
peer
swarm
.
Address
)
(
*
chequebook
.
CashoutStatus
,
error
)
}
// With
settlem
entFunc sets the mock settlement function
// With
SettlementS
entFunc sets the mock settlement function
func
WithSettlementSentFunc
(
f
func
(
swarm
.
Address
)
(
*
big
.
Int
,
error
))
Option
{
return
optionFunc
(
func
(
s
*
Service
)
{
s
.
settlementSentFunc
=
f
...
...
@@ -55,7 +55,7 @@ func WithSettlementRecvFunc(f func(swarm.Address) (*big.Int, error)) Option {
})
}
// With
settlements
Func sets the mock settlements function
// With
SettlementsSent
Func sets the mock settlements function
func
WithSettlementsSentFunc
(
f
func
()
(
map
[
string
]
*
big
.
Int
,
error
))
Option
{
return
optionFunc
(
func
(
s
*
Service
)
{
s
.
settlementsSentFunc
=
f
...
...
pkg/tags/tag.go
View file @
111ca35a
...
...
@@ -296,7 +296,7 @@ func encodeInt64Append(buffer *[]byte, val int64) {
}
func
decodeInt64Splice
(
buffer
*
[]
byte
)
int64
{
val
,
n
:=
binary
.
Varint
(
(
*
buffer
)
)
val
,
n
:=
binary
.
Varint
(
*
buffer
)
*
buffer
=
(
*
buffer
)[
n
:
]
return
val
}
...
...
pkg/topology/kademlia/kademlia.go
View file @
111ca35a
...
...
@@ -155,10 +155,10 @@ func New(
func
(
k
*
Kad
)
generateCommonBinPrefixes
()
{
bitCombinationsCount
:=
int
(
math
.
Pow
(
2
,
float64
(
k
.
bitSuffixLength
)))
bitSufixes
:=
make
([]
uint8
,
bitCombinationsCount
)
bitSuf
f
ixes
:=
make
([]
uint8
,
bitCombinationsCount
)
for
i
:=
0
;
i
<
bitCombinationsCount
;
i
++
{
bitSufixes
[
i
]
=
uint8
(
i
)
bitSuf
f
ixes
[
i
]
=
uint8
(
i
)
}
addr
:=
swarm
.
MustParseHexAddress
(
k
.
base
.
String
())
...
...
@@ -197,7 +197,7 @@ func (k *Kad) generateCommonBinPrefixes() {
for
l
:=
i
+
1
;
l
<
i
+
k
.
bitSuffixLength
+
1
;
l
++
{
index
,
pos
:=
l
/
8
,
l
%
8
if
hasBit
(
bitSufixes
[
j
],
uint8
(
bitSuffixPos
))
{
if
hasBit
(
bitSuf
f
ixes
[
j
],
uint8
(
bitSuffixPos
))
{
pseudoAddrBytes
[
index
]
=
bits
.
Reverse8
(
setBit
(
bits
.
Reverse8
(
pseudoAddrBytes
[
index
]),
uint8
(
pos
)))
}
else
{
pseudoAddrBytes
[
index
]
=
bits
.
Reverse8
(
clearBit
(
bits
.
Reverse8
(
pseudoAddrBytes
[
index
]),
uint8
(
pos
)))
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment