mirror of
https://github.com/MetaCubeX/mihomo.git
synced 2025-12-20 00:50:06 +08:00
9e57b298bf
Some checks failed
Test / test (1.20, ubuntu-latest) (push) Failing after 1s
Test / test (1.21, ubuntu-latest) (push) Failing after 1s
Test / test (1.22, ubuntu-latest) (push) Failing after 1s
Test / test (1.23, ubuntu-latest) (push) Failing after 1s
Test / test (1.24, ubuntu-latest) (push) Failing after 1s
Trigger CMFA Update / trigger-CMFA-update (push) Failing after 1s
Test / test (1.20, macos-13) (push) Has been cancelled
Test / test (1.20, macos-latest) (push) Has been cancelled
Test / test (1.20, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.20, windows-latest) (push) Has been cancelled
Test / test (1.21, macos-13) (push) Has been cancelled
Test / test (1.21, macos-latest) (push) Has been cancelled
Test / test (1.21, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.21, windows-latest) (push) Has been cancelled
Test / test (1.22, macos-13) (push) Has been cancelled
Test / test (1.22, macos-latest) (push) Has been cancelled
Test / test (1.22, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.22, windows-latest) (push) Has been cancelled
Test / test (1.23, macos-13) (push) Has been cancelled
Test / test (1.23, macos-latest) (push) Has been cancelled
Test / test (1.23, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.23, windows-latest) (push) Has been cancelled
Test / test (1.24, macos-13) (push) Has been cancelled
Test / test (1.24, macos-latest) (push) Has been cancelled
Test / test (1.24, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.24, windows-latest) (push) Has been cancelled
83 lines
2.0 KiB
Go
83 lines
2.0 KiB
Go
package proxydialer
|
|
|
|
import (
|
|
"context"
|
|
"net"
|
|
|
|
C "github.com/metacubex/mihomo/constant"
|
|
|
|
M "github.com/metacubex/sing/common/metadata"
|
|
N "github.com/metacubex/sing/common/network"
|
|
)
|
|
|
|
type SingDialer interface {
|
|
N.Dialer
|
|
SetDialer(dialer C.Dialer)
|
|
}
|
|
|
|
type singDialer proxyDialer
|
|
|
|
var _ N.Dialer = (*singDialer)(nil)
|
|
|
|
func (d *singDialer) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error) {
|
|
return (*proxyDialer)(d).DialContext(ctx, network, destination.String())
|
|
}
|
|
|
|
func (d *singDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error) {
|
|
return (*proxyDialer)(d).ListenPacket(ctx, "udp", "", destination.AddrPort())
|
|
}
|
|
|
|
func (d *singDialer) SetDialer(dialer C.Dialer) {
|
|
(*proxyDialer)(d).dialer = dialer
|
|
}
|
|
|
|
func NewSingDialer(proxy C.ProxyAdapter, dialer C.Dialer, statistic bool) SingDialer {
|
|
return (*singDialer)(&proxyDialer{
|
|
proxy: proxy,
|
|
dialer: dialer,
|
|
statistic: statistic,
|
|
})
|
|
}
|
|
|
|
type byNameSingDialer struct {
|
|
dialer C.Dialer
|
|
proxyName string
|
|
}
|
|
|
|
var _ N.Dialer = (*byNameSingDialer)(nil)
|
|
|
|
func (d *byNameSingDialer) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error) {
|
|
var cDialer C.Dialer = d.dialer
|
|
if len(d.proxyName) > 0 {
|
|
pd, err := NewByName(d.proxyName, d.dialer)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
cDialer = pd
|
|
}
|
|
return cDialer.DialContext(ctx, network, destination.String())
|
|
}
|
|
|
|
func (d *byNameSingDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error) {
|
|
var cDialer C.Dialer = d.dialer
|
|
if len(d.proxyName) > 0 {
|
|
pd, err := NewByName(d.proxyName, d.dialer)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
cDialer = pd
|
|
}
|
|
return cDialer.ListenPacket(ctx, "udp", "", destination.AddrPort())
|
|
}
|
|
|
|
func (d *byNameSingDialer) SetDialer(dialer C.Dialer) {
|
|
d.dialer = dialer
|
|
}
|
|
|
|
func NewByNameSingDialer(proxyName string, dialer C.Dialer) SingDialer {
|
|
return &byNameSingDialer{
|
|
dialer: dialer,
|
|
proxyName: proxyName,
|
|
}
|
|
}
|