mihomo/constant/adapters.go

146 lines
2.7 KiB
Go
Raw Normal View History

2018-06-10 22:50:03 +08:00
package constant
import (
2019-07-02 19:18:03 +08:00
"context"
"fmt"
2018-06-14 01:00:58 +08:00
"net"
"time"
2018-06-10 22:50:03 +08:00
)
// Adapter Type
const (
Direct AdapterType = iota
Reject
2020-03-19 20:26:53 +08:00
Shadowsocks
2019-10-09 18:46:23 +08:00
Snell
2018-08-12 13:50:54 +08:00
Socks5
Http
2018-09-06 10:53:29 +08:00
Vmess
2020-03-19 20:26:53 +08:00
Trojan
Relay
2020-03-19 20:26:53 +08:00
Selector
Fallback
URLTest
2019-02-15 14:25:20 +08:00
LoadBalance
)
2018-06-10 22:50:03 +08:00
type ServerAdapter interface {
2019-04-23 23:29:36 +08:00
net.Conn
2018-09-30 12:25:52 +08:00
Metadata() *Metadata
2018-06-10 22:50:03 +08:00
}
type Connection interface {
Chains() Chain
AppendToChains(adapter ProxyAdapter)
}
type Chain []string
func (c Chain) String() string {
switch len(c) {
case 0:
return ""
case 1:
return c[0]
default:
return fmt.Sprintf("%s[%s]", c[len(c)-1], c[0])
}
}
type Conn interface {
net.Conn
Connection
}
type PacketConn interface {
net.PacketConn
Connection
2020-02-17 17:34:19 +08:00
WriteWithMetadata(p []byte, metadata *Metadata) (n int, err error)
}
type ProxyAdapter interface {
2018-06-16 21:34:13 +08:00
Name() string
Type() AdapterType
StreamConn(c net.Conn, metadata *Metadata) (net.Conn, error)
DialContext(ctx context.Context, metadata *Metadata) (Conn, error)
2020-01-31 14:43:54 +08:00
DialUDP(metadata *Metadata) (PacketConn, error)
2019-04-23 23:29:36 +08:00
SupportUDP() bool
2018-11-21 13:47:46 +08:00
MarshalJSON() ([]byte, error)
Addr() string
// Unwrap extracts the proxy from a proxy-group. It returns nil when nothing to extract.
Unwrap(metadata *Metadata) Proxy
2018-06-10 22:50:03 +08:00
}
type DelayHistory struct {
Time time.Time `json:"time"`
Delay uint16 `json:"delay"`
}
type Proxy interface {
ProxyAdapter
Alive() bool
DelayHistory() []DelayHistory
Dial(metadata *Metadata) (Conn, error)
LastDelay() uint16
2019-07-02 19:18:03 +08:00
URLTest(ctx context.Context, url string) (uint16, error)
}
// AdapterType is enum of adapter type
type AdapterType int
func (at AdapterType) String() string {
switch at {
case Direct:
return "Direct"
case Reject:
return "Reject"
2020-03-19 20:26:53 +08:00
case Shadowsocks:
return "Shadowsocks"
2019-10-09 18:46:23 +08:00
case Snell:
return "Snell"
2018-08-12 13:50:54 +08:00
case Socks5:
return "Socks5"
case Http:
return "Http"
2018-09-06 10:53:29 +08:00
case Vmess:
return "Vmess"
2020-03-19 20:26:53 +08:00
case Trojan:
return "Trojan"
case Relay:
return "Relay"
2020-03-19 20:26:53 +08:00
case Selector:
return "Selector"
case Fallback:
return "Fallback"
case URLTest:
return "URLTest"
2019-02-15 14:25:20 +08:00
case LoadBalance:
return "LoadBalance"
2020-03-19 20:26:53 +08:00
default:
2019-08-26 12:26:14 +08:00
return "Unknown"
}
}
// UDPPacket contains the data of UDP packet, and offers control/info of UDP packet's source
type UDPPacket interface {
// Data get the payload of UDP Packet
Data() []byte
// WriteBack writes the payload with source IP/Port equals addr
// - variable source IP/Port is important to STUN
// - if addr is not provided, WriteBack will wirte out UDP packet with SourceIP/Prot equals to origional Target,
// this is important when using Fake-IP.
WriteBack(b []byte, addr net.Addr) (n int, err error)
// Drop call after packet is used, could recycle buffer in this function.
Drop()
// LocalAddr returns the source IP/Port of packet
LocalAddr() net.Addr
}