2017-07-13 21:55:41 +08:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"log"
|
|
|
|
"os"
|
|
|
|
"os/signal"
|
|
|
|
"strings"
|
|
|
|
"syscall"
|
|
|
|
)
|
|
|
|
|
2017-07-18 19:25:54 +08:00
|
|
|
// VERSION .
|
2017-08-20 21:44:18 +08:00
|
|
|
const VERSION = "0.4.0"
|
2017-07-13 21:55:41 +08:00
|
|
|
|
2017-08-23 16:35:39 +08:00
|
|
|
func dialerFromConf() Dialer {
|
2017-07-30 01:54:19 +08:00
|
|
|
// global forwarders in xx.conf
|
2017-08-23 16:35:39 +08:00
|
|
|
var forwarders []Dialer
|
2017-07-18 19:25:54 +08:00
|
|
|
for _, chain := range conf.Forward {
|
2017-08-23 16:35:39 +08:00
|
|
|
var forward Dialer
|
2017-07-13 21:55:41 +08:00
|
|
|
var err error
|
2017-07-14 20:52:49 +08:00
|
|
|
for _, url := range strings.Split(chain, ",") {
|
2017-08-23 16:35:39 +08:00
|
|
|
forward, err = DialerFromURL(url, forward)
|
2017-07-13 21:55:41 +08:00
|
|
|
if err != nil {
|
|
|
|
log.Fatal(err)
|
|
|
|
}
|
2017-07-14 20:52:49 +08:00
|
|
|
}
|
|
|
|
forwarders = append(forwarders, forward)
|
|
|
|
}
|
2017-07-13 21:55:41 +08:00
|
|
|
|
2017-08-23 18:58:24 +08:00
|
|
|
return NewStrategyDialer(conf.Strategy, forwarders, conf.CheckWebSite, conf.CheckDuration)
|
2017-08-23 16:35:39 +08:00
|
|
|
}
|
2017-07-30 01:54:19 +08:00
|
|
|
|
2017-08-23 16:35:39 +08:00
|
|
|
func main() {
|
2017-07-30 01:54:19 +08:00
|
|
|
|
2017-08-23 16:35:39 +08:00
|
|
|
confInit()
|
2017-08-23 18:58:24 +08:00
|
|
|
sDialer := NewRuleDialer(conf.rules, dialerFromConf())
|
2017-07-30 01:54:19 +08:00
|
|
|
|
2017-07-18 19:25:54 +08:00
|
|
|
for _, listen := range conf.Listen {
|
2017-08-23 16:35:39 +08:00
|
|
|
local, err := ServerFromURL(listen, sDialer)
|
2017-07-14 20:52:49 +08:00
|
|
|
if err != nil {
|
|
|
|
log.Fatal(err)
|
2017-07-13 21:55:41 +08:00
|
|
|
}
|
2017-07-14 20:52:49 +08:00
|
|
|
|
|
|
|
go local.ListenAndServe()
|
2017-07-13 21:55:41 +08:00
|
|
|
}
|
|
|
|
|
2017-08-16 13:20:12 +08:00
|
|
|
if conf.DNS != "" {
|
2017-08-23 16:35:39 +08:00
|
|
|
dns, err := NewDNS(conf.DNS, conf.DNSServer[0], sDialer)
|
2017-08-16 13:20:12 +08:00
|
|
|
if err != nil {
|
|
|
|
log.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
// rule
|
2017-08-23 16:35:39 +08:00
|
|
|
for _, frwder := range conf.rules {
|
2017-08-16 13:20:12 +08:00
|
|
|
for _, domain := range frwder.Domain {
|
|
|
|
if len(frwder.DNSServer) > 0 {
|
|
|
|
dns.SetServer(domain, frwder.DNSServer[0])
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-08-23 18:58:24 +08:00
|
|
|
// add a handler to update proxy rules when a domain resolved
|
|
|
|
dns.AddAnswerHandler(sDialer.AddDomainIP)
|
2017-08-23 16:35:39 +08:00
|
|
|
|
2017-08-16 13:20:12 +08:00
|
|
|
go dns.ListenAndServe()
|
|
|
|
}
|
|
|
|
|
2017-07-13 21:55:41 +08:00
|
|
|
sigCh := make(chan os.Signal, 1)
|
|
|
|
signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)
|
|
|
|
<-sigCh
|
|
|
|
}
|