95 lines
1.8 KiB
Go
95 lines
1.8 KiB
Go
package proxy
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"github.com/Dreamacro/clash/config"
|
|
C "github.com/Dreamacro/clash/constant"
|
|
"github.com/Dreamacro/clash/proxy/http"
|
|
"github.com/Dreamacro/clash/proxy/socks"
|
|
)
|
|
|
|
var (
|
|
listener *Listener
|
|
once sync.Once
|
|
)
|
|
|
|
type Listener struct {
|
|
// signal for update
|
|
httpSignal *C.ProxySignal
|
|
socksSignal *C.ProxySignal
|
|
}
|
|
|
|
func (l *Listener) updateHTTP(addr string) error {
|
|
if l.httpSignal != nil {
|
|
signal := l.httpSignal
|
|
signal.Done <- struct{}{}
|
|
<-signal.Closed
|
|
l.httpSignal = nil
|
|
}
|
|
|
|
signal, err := http.NewHttpProxy(addr)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
l.httpSignal = signal
|
|
return nil
|
|
}
|
|
|
|
func (l *Listener) updateSocks(addr string) error {
|
|
if l.socksSignal != nil {
|
|
signal := l.socksSignal
|
|
signal.Done <- struct{}{}
|
|
<-signal.Closed
|
|
l.socksSignal = nil
|
|
}
|
|
|
|
signal, err := socks.NewSocksProxy(addr)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
l.socksSignal = signal
|
|
return nil
|
|
}
|
|
|
|
func (l *Listener) process(signal chan<- struct{}) {
|
|
sub := config.Instance().Subscribe()
|
|
signal <- struct{}{}
|
|
reportCH := config.Instance().Report()
|
|
for elm := range sub {
|
|
event := elm.(*config.Event)
|
|
switch event.Type {
|
|
case "http-addr":
|
|
addr := event.Payload.(string)
|
|
err := l.updateHTTP(addr)
|
|
reportCH <- &config.Event{Type: "http-addr", Payload: err == nil}
|
|
break
|
|
case "socks-addr":
|
|
addr := event.Payload.(string)
|
|
err := l.updateSocks(addr)
|
|
reportCH <- &config.Event{Type: "socks-addr", Payload: err == nil}
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
// Run ensure config monitoring
|
|
func (l *Listener) Run() {
|
|
signal := make(chan struct{})
|
|
go l.process(signal)
|
|
<-signal
|
|
}
|
|
|
|
func newListener() *Listener {
|
|
return &Listener{}
|
|
}
|
|
|
|
// Instance return singleton instance of Listener
|
|
func Instance() *Listener {
|
|
once.Do(func() {
|
|
listener = newListener()
|
|
})
|
|
return listener
|
|
}
|