forked from eoscanada/eos-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.go
52 lines (40 loc) · 1.14 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package main
import (
"encoding/hex"
"flag"
"fmt"
"log"
"github.com/eoscanada/eos-go/p2p"
)
var peer1 = flag.String("peer1", "localhost:9876", "peer 1")
var peer2 = flag.String("peer2", "localhost:2222", "peer 2")
var chainID = flag.String("chain-id", "308cae83a690640be3726a725dde1fa72a845e28cfc63f28c3fa0a6ccdb6faf0", "peer 1")
var showLog = flag.Bool("v", false, "show detail log")
func main() {
flag.Parse()
fmt.Println("P2P Proxy")
if *showLog {
p2p.EnableP2PLogging()
}
defer p2p.SyncLogger()
cID, err := hex.DecodeString(*chainID)
if err != nil {
log.Fatal(err)
}
proxy := p2p.NewProxy(
p2p.NewOutgoingPeer(*peer1, "eos-proxy", nil),
p2p.NewOutgoingPeer(*peer2, "eos-proxy", &p2p.HandshakeInfo{
ChainID: cID,
}),
)
//proxy := p2p.NewProxy(
// p2p.NewOutgoingPeer("localhost:9876", chainID, "eos-proxy", false),
// p2p.NewIncommingPeer("localhost:1111", chainID, "eos-proxy"),
//)
//proxy := p2p.NewProxy(
// p2p.NewIncommingPeer("localhost:2222", "eos-proxy"),
// p2p.NewIncommingPeer("localhost:1111", "eos-proxy"),
//)
proxy.RegisterHandler(p2p.StringLoggerHandler)
fmt.Println(proxy.ConnectAndStart())
}