123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475 |
- // Copyright 2018 The go-ethereum Authors
- // This file is part of the go-ethereum library.
- //
- // The go-ethereum library is free software: you can redistribute it and/or modify
- // it under the terms of the GNU Lesser General Public License as published by
- // the Free Software Foundation, either version 3 of the License, or
- // (at your option) any later version.
- //
- // The go-ethereum library is distributed in the hope that it will be useful,
- // but WITHOUT ANY WARRANTY; without even the implied warranty of
- // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- // GNU Lesser General Public License for more details.
- //
- // You should have received a copy of the GNU Lesser General Public License
- // along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
- package enode
- import (
- "bytes"
- "fmt"
- "io/ioutil"
- "net"
- "os"
- "path/filepath"
- "reflect"
- "testing"
- "time"
- )
- var keytestID = HexID("51232b8d7821617d2b29b54b81cdefb9b3e9c37d7fd5f63270bcc9e1a6f6a439")
- func TestDBNodeKey(t *testing.T) {
- enc := nodeKey(keytestID)
- want := []byte{
- 'n', ':',
- 0x51, 0x23, 0x2b, 0x8d, 0x78, 0x21, 0x61, 0x7d, // node id
- 0x2b, 0x29, 0xb5, 0x4b, 0x81, 0xcd, 0xef, 0xb9, //
- 0xb3, 0xe9, 0xc3, 0x7d, 0x7f, 0xd5, 0xf6, 0x32, //
- 0x70, 0xbc, 0xc9, 0xe1, 0xa6, 0xf6, 0xa4, 0x39, //
- ':', 'v', '4',
- }
- if !bytes.Equal(enc, want) {
- t.Errorf("wrong encoded key:\ngot %q\nwant %q", enc, want)
- }
- id, _ := splitNodeKey(enc)
- if id != keytestID {
- t.Errorf("wrong ID from splitNodeKey")
- }
- }
- func TestDBNodeItemKey(t *testing.T) {
- wantIP := net.IP{127, 0, 0, 3}
- wantField := "foobar"
- enc := nodeItemKey(keytestID, wantIP, wantField)
- want := []byte{
- 'n', ':',
- 0x51, 0x23, 0x2b, 0x8d, 0x78, 0x21, 0x61, 0x7d, // node id
- 0x2b, 0x29, 0xb5, 0x4b, 0x81, 0xcd, 0xef, 0xb9, //
- 0xb3, 0xe9, 0xc3, 0x7d, 0x7f, 0xd5, 0xf6, 0x32, //
- 0x70, 0xbc, 0xc9, 0xe1, 0xa6, 0xf6, 0xa4, 0x39, //
- ':', 'v', '4', ':',
- 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, // IP
- 0x00, 0x00, 0xff, 0xff, 0x7f, 0x00, 0x00, 0x03, //
- ':', 'f', 'o', 'o', 'b', 'a', 'r',
- }
- if !bytes.Equal(enc, want) {
- t.Errorf("wrong encoded key:\ngot %q\nwant %q", enc, want)
- }
- id, ip, field := splitNodeItemKey(enc)
- if id != keytestID {
- t.Errorf("splitNodeItemKey returned wrong ID: %v", id)
- }
- if !ip.Equal(wantIP) {
- t.Errorf("splitNodeItemKey returned wrong IP: %v", ip)
- }
- if field != wantField {
- t.Errorf("splitNodeItemKey returned wrong field: %q", field)
- }
- }
- var nodeDBInt64Tests = []struct {
- key []byte
- value int64
- }{
- {key: []byte{0x01}, value: 1},
- {key: []byte{0x02}, value: 2},
- {key: []byte{0x03}, value: 3},
- }
- func TestDBInt64(t *testing.T) {
- db, _ := OpenDB("")
- defer db.Close()
- tests := nodeDBInt64Tests
- for i := 0; i < len(tests); i++ {
- // Insert the next value
- if err := db.storeInt64(tests[i].key, tests[i].value); err != nil {
- t.Errorf("test %d: failed to store value: %v", i, err)
- }
- // Check all existing and non existing values
- for j := 0; j < len(tests); j++ {
- num := db.fetchInt64(tests[j].key)
- switch {
- case j <= i && num != tests[j].value:
- t.Errorf("test %d, item %d: value mismatch: have %v, want %v", i, j, num, tests[j].value)
- case j > i && num != 0:
- t.Errorf("test %d, item %d: value mismatch: have %v, want %v", i, j, num, 0)
- }
- }
- }
- }
- func TestDBFetchStore(t *testing.T) {
- node := NewV4(
- hexPubkey("1dd9d65c4552b5eb43d5ad55a2ee3f56c6cbc1c64a5c8d659f51fcd51bace24351232b8d7821617d2b29b54b81cdefb9b3e9c37d7fd5f63270bcc9e1a6f6a439"),
- net.IP{192, 168, 0, 1},
- 30303,
- 30303,
- )
- inst := time.Now()
- num := 314
- db, _ := OpenDB("")
- defer db.Close()
- // Check fetch/store operations on a node ping object
- if stored := db.LastPingReceived(node.ID(), node.IP()); stored.Unix() != 0 {
- t.Errorf("ping: non-existing object: %v", stored)
- }
- if err := db.UpdateLastPingReceived(node.ID(), node.IP(), inst); err != nil {
- t.Errorf("ping: failed to update: %v", err)
- }
- if stored := db.LastPingReceived(node.ID(), node.IP()); stored.Unix() != inst.Unix() {
- t.Errorf("ping: value mismatch: have %v, want %v", stored, inst)
- }
- // Check fetch/store operations on a node pong object
- if stored := db.LastPongReceived(node.ID(), node.IP()); stored.Unix() != 0 {
- t.Errorf("pong: non-existing object: %v", stored)
- }
- if err := db.UpdateLastPongReceived(node.ID(), node.IP(), inst); err != nil {
- t.Errorf("pong: failed to update: %v", err)
- }
- if stored := db.LastPongReceived(node.ID(), node.IP()); stored.Unix() != inst.Unix() {
- t.Errorf("pong: value mismatch: have %v, want %v", stored, inst)
- }
- // Check fetch/store operations on a node findnode-failure object
- if stored := db.FindFails(node.ID(), node.IP()); stored != 0 {
- t.Errorf("find-node fails: non-existing object: %v", stored)
- }
- if err := db.UpdateFindFails(node.ID(), node.IP(), num); err != nil {
- t.Errorf("find-node fails: failed to update: %v", err)
- }
- if stored := db.FindFails(node.ID(), node.IP()); stored != num {
- t.Errorf("find-node fails: value mismatch: have %v, want %v", stored, num)
- }
- // Check fetch/store operations on an actual node object
- if stored := db.Node(node.ID()); stored != nil {
- t.Errorf("node: non-existing object: %v", stored)
- }
- if err := db.UpdateNode(node); err != nil {
- t.Errorf("node: failed to update: %v", err)
- }
- if stored := db.Node(node.ID()); stored == nil {
- t.Errorf("node: not found")
- } else if !reflect.DeepEqual(stored, node) {
- t.Errorf("node: data mismatch: have %v, want %v", stored, node)
- }
- }
- var nodeDBSeedQueryNodes = []struct {
- node *Node
- pong time.Time
- }{
- // This one should not be in the result set because its last
- // pong time is too far in the past.
- {
- node: NewV4(
- hexPubkey("1dd9d65c4552b5eb43d5ad55a2ee3f56c6cbc1c64a5c8d659f51fcd51bace24351232b8d7821617d2b29b54b81cdefb9b3e9c37d7fd5f63270bcc9e1a6f6a439"),
- net.IP{127, 0, 0, 3},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-3 * time.Hour),
- },
- // This one shouldn't be in the result set because its
- // nodeID is the local node's ID.
- {
- node: NewV4(
- hexPubkey("ff93ff820abacd4351b0f14e47b324bc82ff014c226f3f66a53535734a3c150e7e38ca03ef0964ba55acddc768f5e99cd59dea95ddd4defbab1339c92fa319b2"),
- net.IP{127, 0, 0, 3},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-4 * time.Second),
- },
- // These should be in the result set.
- {
- node: NewV4(
- hexPubkey("c2b5eb3f5dde05f815b63777809ee3e7e0cbb20035a6b00ce327191e6eaa8f26a8d461c9112b7ab94698e7361fa19fd647e603e73239002946d76085b6f928d6"),
- net.IP{127, 0, 0, 1},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-2 * time.Second),
- },
- {
- node: NewV4(
- hexPubkey("6ca1d400c8ddf8acc94bcb0dd254911ad71a57bed5e0ae5aa205beed59b28c2339908e97990c493499613cff8ecf6c3dc7112a8ead220cdcd00d8847ca3db755"),
- net.IP{127, 0, 0, 2},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-3 * time.Second),
- },
- {
- node: NewV4(
- hexPubkey("234dc63fe4d131212b38236c4c3411288d7bec61cbf7b120ff12c43dc60c96182882f4291d209db66f8a38e986c9c010ff59231a67f9515c7d1668b86b221a47"),
- net.IP{127, 0, 0, 3},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-1 * time.Second),
- },
- {
- node: NewV4(
- hexPubkey("c013a50b4d1ebce5c377d8af8cb7114fd933ffc9627f96ad56d90fef5b7253ec736fd07ef9a81dc2955a997e54b7bf50afd0aa9f110595e2bec5bb7ce1657004"),
- net.IP{127, 0, 0, 3},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-2 * time.Second),
- },
- {
- node: NewV4(
- hexPubkey("f141087e3e08af1aeec261ff75f48b5b1637f594ea9ad670e50051646b0416daa3b134c28788cbe98af26992a47652889cd8577ccc108ac02c6a664db2dc1283"),
- net.IP{127, 0, 0, 3},
- 30303,
- 30303,
- ),
- pong: time.Now().Add(-2 * time.Second),
- },
- }
- func TestDBSeedQuery(t *testing.T) {
- // Querying seeds uses seeks an might not find all nodes
- // every time when the database is small. Run the test multiple
- // times to avoid flakes.
- const attempts = 15
- var err error
- for i := 0; i < attempts; i++ {
- if err = testSeedQuery(); err == nil {
- return
- }
- }
- if err != nil {
- t.Errorf("no successful run in %d attempts: %v", attempts, err)
- }
- }
- func testSeedQuery() error {
- db, _ := OpenDB("")
- defer db.Close()
- // Insert a batch of nodes for querying
- for i, seed := range nodeDBSeedQueryNodes {
- if err := db.UpdateNode(seed.node); err != nil {
- return fmt.Errorf("node %d: failed to insert: %v", i, err)
- }
- if err := db.UpdateLastPongReceived(seed.node.ID(), seed.node.IP(), seed.pong); err != nil {
- return fmt.Errorf("node %d: failed to insert bondTime: %v", i, err)
- }
- }
- // Retrieve the entire batch and check for duplicates
- seeds := db.QuerySeeds(len(nodeDBSeedQueryNodes)*2, time.Hour)
- have := make(map[ID]struct{})
- for _, seed := range seeds {
- have[seed.ID()] = struct{}{}
- }
- want := make(map[ID]struct{})
- for _, seed := range nodeDBSeedQueryNodes[1:] {
- want[seed.node.ID()] = struct{}{}
- }
- if len(seeds) != len(want) {
- return fmt.Errorf("seed count mismatch: have %v, want %v", len(seeds), len(want))
- }
- for id := range have {
- if _, ok := want[id]; !ok {
- return fmt.Errorf("extra seed: %v", id)
- }
- }
- for id := range want {
- if _, ok := have[id]; !ok {
- return fmt.Errorf("missing seed: %v", id)
- }
- }
- return nil
- }
- func TestDBPersistency(t *testing.T) {
- root, err := ioutil.TempDir("", "nodedb-")
- if err != nil {
- t.Fatalf("failed to create temporary data folder: %v", err)
- }
- defer os.RemoveAll(root)
- var (
- testKey = []byte("somekey")
- testInt = int64(314)
- )
- // Create a persistent database and store some values
- db, err := OpenDB(filepath.Join(root, "database"))
- if err != nil {
- t.Fatalf("failed to create persistent database: %v", err)
- }
- if err := db.storeInt64(testKey, testInt); err != nil {
- t.Fatalf("failed to store value: %v.", err)
- }
- db.Close()
- // Reopen the database and check the value
- db, err = OpenDB(filepath.Join(root, "database"))
- if err != nil {
- t.Fatalf("failed to open persistent database: %v", err)
- }
- if val := db.fetchInt64(testKey); val != testInt {
- t.Fatalf("value mismatch: have %v, want %v", val, testInt)
- }
- db.Close()
- }
- var nodeDBExpirationNodes = []struct {
- node *Node
- pong time.Time
- storeNode bool
- exp bool
- }{
- // Node has new enough pong time and isn't expired:
- {
- node: NewV4(
- hexPubkey("8d110e2ed4b446d9b5fb50f117e5f37fb7597af455e1dab0e6f045a6eeaa786a6781141659020d38bdc5e698ed3d4d2bafa8b5061810dfa63e8ac038db2e9b67"),
- net.IP{127, 0, 0, 1},
- 30303,
- 30303,
- ),
- storeNode: true,
- pong: time.Now().Add(-dbNodeExpiration + time.Minute),
- exp: false,
- },
- // Node with pong time before expiration is removed:
- {
- node: NewV4(
- hexPubkey("913a205579c32425b220dfba999d215066e5bdbf900226b11da1907eae5e93eb40616d47412cf819664e9eacbdfcca6b0c6e07e09847a38472d4be46ab0c3672"),
- net.IP{127, 0, 0, 2},
- 30303,
- 30303,
- ),
- storeNode: true,
- pong: time.Now().Add(-dbNodeExpiration - time.Minute),
- exp: true,
- },
- // Just pong time, no node stored:
- {
- node: NewV4(
- hexPubkey("b56670e0b6bad2c5dab9f9fe6f061a16cf78d68b6ae2cfda3144262d08d97ce5f46fd8799b6d1f709b1abe718f2863e224488bd7518e5e3b43809ac9bd1138ca"),
- net.IP{127, 0, 0, 3},
- 30303,
- 30303,
- ),
- storeNode: false,
- pong: time.Now().Add(-dbNodeExpiration - time.Minute),
- exp: true,
- },
- // Node with multiple pong times, all older than expiration.
- {
- node: NewV4(
- hexPubkey("29f619cebfd32c9eab34aec797ed5e3fe15b9b45be95b4df3f5fe6a9ae892f433eb08d7698b2ef3621568b0fb70d57b515ab30d4e72583b798298e0f0a66b9d1"),
- net.IP{127, 0, 0, 4},
- 30303,
- 30303,
- ),
- storeNode: true,
- pong: time.Now().Add(-dbNodeExpiration - time.Minute),
- exp: true,
- },
- {
- node: NewV4(
- hexPubkey("29f619cebfd32c9eab34aec797ed5e3fe15b9b45be95b4df3f5fe6a9ae892f433eb08d7698b2ef3621568b0fb70d57b515ab30d4e72583b798298e0f0a66b9d1"),
- net.IP{127, 0, 0, 5},
- 30303,
- 30303,
- ),
- storeNode: false,
- pong: time.Now().Add(-dbNodeExpiration - 2*time.Minute),
- exp: true,
- },
- // Node with multiple pong times, one newer, one older than expiration.
- {
- node: NewV4(
- hexPubkey("3b73a9e5f4af6c4701c57c73cc8cfa0f4802840b24c11eba92aac3aef65644a3728b4b2aec8199f6d72bd66be2c65861c773129039bd47daa091ca90a6d4c857"),
- net.IP{127, 0, 0, 6},
- 30303,
- 30303,
- ),
- storeNode: true,
- pong: time.Now().Add(-dbNodeExpiration + time.Minute),
- exp: false,
- },
- {
- node: NewV4(
- hexPubkey("3b73a9e5f4af6c4701c57c73cc8cfa0f4802840b24c11eba92aac3aef65644a3728b4b2aec8199f6d72bd66be2c65861c773129039bd47daa091ca90a6d4c857"),
- net.IP{127, 0, 0, 7},
- 30303,
- 30303,
- ),
- storeNode: false,
- pong: time.Now().Add(-dbNodeExpiration - time.Minute),
- exp: true,
- },
- }
- func TestDBExpiration(t *testing.T) {
- db, _ := OpenDB("")
- defer db.Close()
- // Add all the test nodes and set their last pong time.
- for i, seed := range nodeDBExpirationNodes {
- if seed.storeNode {
- if err := db.UpdateNode(seed.node); err != nil {
- t.Fatalf("node %d: failed to insert: %v", i, err)
- }
- }
- if err := db.UpdateLastPongReceived(seed.node.ID(), seed.node.IP(), seed.pong); err != nil {
- t.Fatalf("node %d: failed to update bondTime: %v", i, err)
- }
- }
- db.expireNodes()
- // Check that expired entries have been removed.
- unixZeroTime := time.Unix(0, 0)
- for i, seed := range nodeDBExpirationNodes {
- node := db.Node(seed.node.ID())
- pong := db.LastPongReceived(seed.node.ID(), seed.node.IP())
- if seed.exp {
- if seed.storeNode && node != nil {
- t.Errorf("node %d (%s) shouldn't be present after expiration", i, seed.node.ID().TerminalString())
- }
- if !pong.Equal(unixZeroTime) {
- t.Errorf("pong time %d (%s %v) shouldn't be present after expiration", i, seed.node.ID().TerminalString(), seed.node.IP())
- }
- } else {
- if seed.storeNode && node == nil {
- t.Errorf("node %d (%s) should be present after expiration", i, seed.node.ID().TerminalString())
- }
- if !pong.Equal(seed.pong.Truncate(1 * time.Second)) {
- t.Errorf("pong time %d (%s) should be %v after expiration, but is %v", i, seed.node.ID().TerminalString(), seed.pong, pong)
- }
- }
- }
- }
- // This test checks that expiration works when discovery v5 data is present
- // in the database.
- func TestDBExpireV5(t *testing.T) {
- db, _ := OpenDB("")
- defer db.Close()
- ip := net.IP{127, 0, 0, 1}
- db.UpdateFindFailsV5(ID{}, ip, 4)
- db.expireNodes()
- }
|