forked from coyim/coyim
/
tor.go
114 lines (92 loc) · 2.14 KB
/
tor.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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package net
import (
"encoding/json"
"io/ioutil"
"log"
"net"
"net/http"
"time"
"golang.org/x/net/proxy"
)
var (
defaultTorHost = "127.0.0.1"
defaultTorPorts = []string{"9050", "9150"}
timeout = 30 * time.Second
)
//TorState informs the state of Tor
type TorState interface {
Detect() bool
Address() string
IsConnectionOverTor(proxy.Dialer) bool
}
// Tor is the default state manager for Tor
var Tor TorState = &defaultTorManager{}
type defaultTorManager struct {
addr string
detected bool
torHost string
torPorts []string
}
func (m *defaultTorManager) Detect() bool {
torHost := m.torHost
if len(torHost) == 0 {
torHost = defaultTorHost
}
torPorts := m.torPorts
if len(m.torPorts) == 0 {
torPorts = defaultTorPorts
}
var found bool
m.addr, found = detectTor(torHost, torPorts)
m.detected = found
return found
}
func (m *defaultTorManager) Address() string {
if !m.detected {
m.Detect()
}
return m.addr
}
func detectTor(host string, ports []string) (string, bool) {
for _, port := range ports {
addr := net.JoinHostPort(host, port)
conn, err := net.DialTimeout("tcp", addr, timeout)
if err != nil {
continue
}
defer conn.Close()
return addr, true
}
return "", false
}
// CheckTorResult represents the JSON result from a check tor request
type CheckTorResult struct {
IsTor bool
IP string
}
// IsConnectionOverTor will make a connection to the check.torproject page to see if we're using Tor or not
func (*defaultTorManager) IsConnectionOverTor(d proxy.Dialer) bool {
if d == nil {
d = proxy.Direct
}
c := &http.Client{Transport: &http.Transport{Dial: func(network, addr string) (net.Conn, error) {
return d.Dial(network, addr)
}}}
resp, err := c.Get("https://check.torproject.org/api/ip")
if err != nil {
log.Printf("Got error when trying to check tor: %v", err)
return false
}
content, err := ioutil.ReadAll(resp.Body)
if err != nil {
log.Printf("Got error when trying to check tor: %v", err)
return false
}
v := CheckTorResult{}
err = json.Unmarshal(content, &v)
if err != nil {
log.Printf("Got error when trying to check tor: %v", err)
return false
}
return v.IsTor
}