mirror of
https://github.com/MetaCubeX/mihomo.git
synced 2024-11-16 11:42:43 +08:00
322 lines
7.5 KiB
Go
322 lines
7.5 KiB
Go
package adapter
|
|
|
|
import (
|
|
"context"
|
|
"crypto/tls"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net"
|
|
"net/http"
|
|
"net/netip"
|
|
"net/url"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/metacubex/mihomo/common/atomic"
|
|
"github.com/metacubex/mihomo/common/queue"
|
|
"github.com/metacubex/mihomo/common/utils"
|
|
"github.com/metacubex/mihomo/component/ca"
|
|
"github.com/metacubex/mihomo/component/dialer"
|
|
C "github.com/metacubex/mihomo/constant"
|
|
"github.com/metacubex/mihomo/log"
|
|
"github.com/puzpuzpuz/xsync/v3"
|
|
)
|
|
|
|
var UnifiedDelay = atomic.NewBool(false)
|
|
|
|
const (
|
|
defaultHistoriesNum = 10
|
|
)
|
|
|
|
type internalProxyState struct {
|
|
alive atomic.Bool
|
|
history *queue.Queue[C.DelayHistory]
|
|
}
|
|
|
|
type Proxy struct {
|
|
C.ProxyAdapter
|
|
alive atomic.Bool
|
|
history *queue.Queue[C.DelayHistory]
|
|
extra *xsync.MapOf[string, *internalProxyState]
|
|
}
|
|
|
|
// Adapter implements C.Proxy
|
|
func (p *Proxy) Adapter() C.ProxyAdapter {
|
|
return p.ProxyAdapter
|
|
}
|
|
|
|
// AliveForTestUrl implements C.Proxy
|
|
func (p *Proxy) AliveForTestUrl(url string) bool {
|
|
if state, ok := p.extra.Load(url); ok {
|
|
return state.alive.Load()
|
|
}
|
|
|
|
return p.alive.Load()
|
|
}
|
|
|
|
// Dial implements C.Proxy
|
|
func (p *Proxy) Dial(metadata *C.Metadata) (C.Conn, error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), C.DefaultTCPTimeout)
|
|
defer cancel()
|
|
return p.DialContext(ctx, metadata)
|
|
}
|
|
|
|
// DialContext implements C.ProxyAdapter
|
|
func (p *Proxy) DialContext(ctx context.Context, metadata *C.Metadata, opts ...dialer.Option) (C.Conn, error) {
|
|
conn, err := p.ProxyAdapter.DialContext(ctx, metadata, opts...)
|
|
return conn, err
|
|
}
|
|
|
|
// DialUDP implements C.ProxyAdapter
|
|
func (p *Proxy) DialUDP(metadata *C.Metadata) (C.PacketConn, error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), C.DefaultUDPTimeout)
|
|
defer cancel()
|
|
return p.ListenPacketContext(ctx, metadata)
|
|
}
|
|
|
|
// ListenPacketContext implements C.ProxyAdapter
|
|
func (p *Proxy) ListenPacketContext(ctx context.Context, metadata *C.Metadata, opts ...dialer.Option) (C.PacketConn, error) {
|
|
pc, err := p.ProxyAdapter.ListenPacketContext(ctx, metadata, opts...)
|
|
return pc, err
|
|
}
|
|
|
|
// DelayHistory implements C.Proxy
|
|
func (p *Proxy) DelayHistory() []C.DelayHistory {
|
|
queueM := p.history.Copy()
|
|
histories := []C.DelayHistory{}
|
|
for _, item := range queueM {
|
|
histories = append(histories, item)
|
|
}
|
|
return histories
|
|
}
|
|
|
|
// DelayHistoryForTestUrl implements C.Proxy
|
|
func (p *Proxy) DelayHistoryForTestUrl(url string) []C.DelayHistory {
|
|
var queueM []C.DelayHistory
|
|
|
|
if state, ok := p.extra.Load(url); ok {
|
|
queueM = state.history.Copy()
|
|
}
|
|
histories := []C.DelayHistory{}
|
|
for _, item := range queueM {
|
|
histories = append(histories, item)
|
|
}
|
|
return histories
|
|
}
|
|
|
|
// ExtraDelayHistories return all delay histories for each test URL
|
|
// implements C.Proxy
|
|
func (p *Proxy) ExtraDelayHistories() map[string]C.ProxyState {
|
|
histories := map[string]C.ProxyState{}
|
|
|
|
p.extra.Range(func(k string, v *internalProxyState) bool {
|
|
testUrl := k
|
|
state := v
|
|
|
|
queueM := state.history.Copy()
|
|
var history []C.DelayHistory
|
|
|
|
for _, item := range queueM {
|
|
history = append(history, item)
|
|
}
|
|
|
|
histories[testUrl] = C.ProxyState{
|
|
Alive: state.alive.Load(),
|
|
History: history,
|
|
}
|
|
return true
|
|
})
|
|
return histories
|
|
}
|
|
|
|
// LastDelayForTestUrl return last history record of the specified URL. if proxy is not alive, return the max value of uint16.
|
|
// implements C.Proxy
|
|
func (p *Proxy) LastDelayForTestUrl(url string) (delay uint16) {
|
|
var maxDelay uint16 = 0xffff
|
|
|
|
alive := false
|
|
var history C.DelayHistory
|
|
|
|
if state, ok := p.extra.Load(url); ok {
|
|
alive = state.alive.Load()
|
|
history = state.history.Last()
|
|
}
|
|
|
|
if !alive || history.Delay == 0 {
|
|
return maxDelay
|
|
}
|
|
return history.Delay
|
|
}
|
|
|
|
// MarshalJSON implements C.ProxyAdapter
|
|
func (p *Proxy) MarshalJSON() ([]byte, error) {
|
|
inner, err := p.ProxyAdapter.MarshalJSON()
|
|
if err != nil {
|
|
return inner, err
|
|
}
|
|
|
|
mapping := map[string]any{}
|
|
_ = json.Unmarshal(inner, &mapping)
|
|
mapping["history"] = p.DelayHistory()
|
|
mapping["extra"] = p.ExtraDelayHistories()
|
|
mapping["alive"] = p.alive.Load()
|
|
mapping["name"] = p.Name()
|
|
mapping["udp"] = p.SupportUDP()
|
|
mapping["xudp"] = p.SupportXUDP()
|
|
mapping["tfo"] = p.SupportTFO()
|
|
return json.Marshal(mapping)
|
|
}
|
|
|
|
// URLTest get the delay for the specified URL
|
|
// implements C.Proxy
|
|
func (p *Proxy) URLTest(ctx context.Context, url string, expectedStatus utils.IntRanges[uint16]) (t uint16, err error) {
|
|
var satisfied bool
|
|
|
|
defer func() {
|
|
alive := err == nil
|
|
record := C.DelayHistory{Time: time.Now()}
|
|
if alive {
|
|
record.Delay = t
|
|
}
|
|
|
|
p.alive.Store(alive)
|
|
p.history.Put(record)
|
|
if p.history.Len() > defaultHistoriesNum {
|
|
p.history.Pop()
|
|
}
|
|
|
|
state, ok := p.extra.Load(url)
|
|
if !ok {
|
|
state = &internalProxyState{
|
|
history: queue.New[C.DelayHistory](defaultHistoriesNum),
|
|
alive: atomic.NewBool(true),
|
|
}
|
|
p.extra.Store(url, state)
|
|
}
|
|
|
|
if !satisfied {
|
|
record.Delay = 0
|
|
alive = false
|
|
}
|
|
|
|
state.alive.Store(alive)
|
|
state.history.Put(record)
|
|
if state.history.Len() > defaultHistoriesNum {
|
|
state.history.Pop()
|
|
}
|
|
|
|
}()
|
|
|
|
unifiedDelay := UnifiedDelay.Load()
|
|
|
|
addr, err := urlToMetadata(url)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
start := time.Now()
|
|
instance, err := p.DialContext(ctx, &addr)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer func() {
|
|
_ = instance.Close()
|
|
}()
|
|
|
|
req, err := http.NewRequest(http.MethodHead, url, nil)
|
|
if err != nil {
|
|
return
|
|
}
|
|
req = req.WithContext(ctx)
|
|
|
|
transport := &http.Transport{
|
|
DialContext: func(context.Context, string, string) (net.Conn, error) {
|
|
return instance, nil
|
|
},
|
|
// from http.DefaultTransport
|
|
MaxIdleConns: 100,
|
|
IdleConnTimeout: 90 * time.Second,
|
|
TLSHandshakeTimeout: 10 * time.Second,
|
|
ExpectContinueTimeout: 1 * time.Second,
|
|
TLSClientConfig: ca.GetGlobalTLSConfig(&tls.Config{}),
|
|
}
|
|
|
|
client := http.Client{
|
|
Timeout: 30 * time.Second,
|
|
Transport: transport,
|
|
CheckRedirect: func(req *http.Request, via []*http.Request) error {
|
|
return http.ErrUseLastResponse
|
|
},
|
|
}
|
|
|
|
defer client.CloseIdleConnections()
|
|
|
|
resp, err := client.Do(req)
|
|
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
_ = resp.Body.Close()
|
|
|
|
if unifiedDelay {
|
|
second := time.Now()
|
|
var ignoredErr error
|
|
var secondResp *http.Response
|
|
secondResp, ignoredErr = client.Do(req)
|
|
if ignoredErr == nil {
|
|
resp = secondResp
|
|
_ = resp.Body.Close()
|
|
start = second
|
|
} else {
|
|
if strings.HasPrefix(url, "http://") {
|
|
log.Errorln("%s failed to get the second response from %s: %v", p.Name(), url, ignoredErr)
|
|
log.Warnln("It is recommended to use HTTPS for provider.health-check.url and group.url to ensure better reliability. Due to some proxy providers hijacking test addresses and not being compatible with repeated HEAD requests, using HTTP may result in failed tests.")
|
|
}
|
|
}
|
|
}
|
|
|
|
satisfied = resp != nil && (expectedStatus == nil || expectedStatus.Check(uint16(resp.StatusCode)))
|
|
t = uint16(time.Since(start) / time.Millisecond)
|
|
return
|
|
}
|
|
func NewProxy(adapter C.ProxyAdapter) *Proxy {
|
|
return &Proxy{
|
|
ProxyAdapter: adapter,
|
|
history: queue.New[C.DelayHistory](defaultHistoriesNum),
|
|
alive: atomic.NewBool(true),
|
|
extra: xsync.NewMapOf[string, *internalProxyState]()}
|
|
}
|
|
|
|
func urlToMetadata(rawURL string) (addr C.Metadata, err error) {
|
|
u, err := url.Parse(rawURL)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
port := u.Port()
|
|
if port == "" {
|
|
switch u.Scheme {
|
|
case "https":
|
|
port = "443"
|
|
case "http":
|
|
port = "80"
|
|
default:
|
|
err = fmt.Errorf("%s scheme not Support", rawURL)
|
|
return
|
|
}
|
|
}
|
|
uintPort, err := strconv.ParseUint(port, 10, 16)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
addr = C.Metadata{
|
|
Host: u.Hostname(),
|
|
DstIP: netip.Addr{},
|
|
DstPort: uint16(uintPort),
|
|
}
|
|
return
|
|
}
|