diff options
Diffstat (limited to 'src/cmd/peer_mockup/main.go')
-rw-r--r-- | src/cmd/peer_mockup/main.go | 68 |
1 files changed, 0 insertions, 68 deletions
diff --git a/src/cmd/peer_mockup/main.go b/src/cmd/peer_mockup/main.go deleted file mode 100644 index 59bc002..0000000 --- a/src/cmd/peer_mockup/main.go +++ /dev/null | |||
@@ -1,68 +0,0 @@ | |||
1 | package main | ||
2 | |||
3 | import ( | ||
4 | "encoding/hex" | ||
5 | "flag" | ||
6 | "fmt" | ||
7 | |||
8 | "github.com/bfix/gospel/logger" | ||
9 | "gnunet/core" | ||
10 | "gnunet/transport" | ||
11 | ) | ||
12 | |||
13 | var ( | ||
14 | p *core.Peer // local peer (with private key) | ||
15 | t *core.Peer // remote peer | ||
16 | ) | ||
17 | |||
18 | func main() { | ||
19 | // handle command line arguments | ||
20 | var ( | ||
21 | asServer bool | ||
22 | err error | ||
23 | ch transport.Channel | ||
24 | ) | ||
25 | flag.BoolVar(&asServer, "s", false, "accept incoming connections") | ||
26 | flag.Parse() | ||
27 | |||
28 | // setup peer instances from static data | ||
29 | if err = setupPeers(false); err != nil { | ||
30 | fmt.Println(err.Error()) | ||
31 | return | ||
32 | } | ||
33 | |||
34 | fmt.Println("======================================================================") | ||
35 | fmt.Println("GNUnet peer mock-up (EXPERIMENTAL) (c) 2018,2019 by Bernd Fix, >Y<") | ||
36 | fmt.Printf(" Identity '%s'\n", p.GetIDString()) | ||
37 | fmt.Printf(" [%s]\n", hex.EncodeToString(p.GetID())) | ||
38 | fmt.Println("======================================================================") | ||
39 | |||
40 | if asServer { | ||
41 | // run as server | ||
42 | fmt.Println("Waiting for connections...") | ||
43 | hdlr := make(chan transport.Channel) | ||
44 | go func() { | ||
45 | for { | ||
46 | select { | ||
47 | case ch = <-hdlr: | ||
48 | mc := transport.NewMsgChannel(ch) | ||
49 | if err = process(mc, t, p); err != nil { | ||
50 | logger.Println(logger.ERROR, err.Error()) | ||
51 | } | ||
52 | } | ||
53 | } | ||
54 | }() | ||
55 | _, err = transport.NewChannelServer("tcp+0.0.0.0:2086", hdlr) | ||
56 | } else { | ||
57 | // connect to peer | ||
58 | fmt.Println("Connecting to target peer") | ||
59 | if ch, err = transport.NewChannel("tcp+172.17.0.5:2086"); err != nil { | ||
60 | logger.Println(logger.ERROR, err.Error()) | ||
61 | } | ||
62 | mc := transport.NewMsgChannel(ch) | ||
63 | err = process(mc, p, t) | ||
64 | } | ||
65 | if err != nil { | ||
66 | fmt.Println(err) | ||
67 | } | ||
68 | } | ||