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
}
|