mirror of
https://github.com/e1732a364fed/v2ray_simple.git
synced 2025-12-24 13:27:56 +08:00
100 lines
2.3 KiB
Go
100 lines
2.3 KiB
Go
package httpLayer
|
||
|
||
import (
|
||
"bytes"
|
||
"errors"
|
||
"net"
|
||
"net/http"
|
||
|
||
"github.com/e1732a364fed/v2ray_simple/netLayer"
|
||
)
|
||
|
||
const (
|
||
Fallback_none = 0
|
||
)
|
||
const (
|
||
FallBack_default byte = 1 << iota //default 其实也是path，只不过path是通配符。
|
||
|
||
//这里剩余fallback按该固定顺序排列. 这是为了方便代码的书写(alpn和sni都是tls的)
|
||
|
||
// 虽然alpn和sni都是tls的，但是回落本身是专门用于http的，所以还是放在httpLayer包中
|
||
|
||
Fallback_path
|
||
Fallback_alpn
|
||
Fallback_sni
|
||
|
||
fallback_end
|
||
|
||
all_non_default_fallbacktype_count = iota - 2
|
||
|
||
//alpn_unspecified = 0
|
||
)
|
||
|
||
const (
|
||
alpn_http11 = 1 << iota
|
||
alpn_http20
|
||
)
|
||
|
||
var ErrShouldFallback = errors.New("will fallback")
|
||
|
||
// http level fallback metadata
|
||
type FallbackMeta struct {
|
||
net.Conn
|
||
H1RequestBuf *bytes.Buffer
|
||
Path string
|
||
Method string
|
||
IsH2 bool
|
||
Reason string
|
||
|
||
H2Request *http.Request
|
||
H2RW http.ResponseWriter
|
||
XFF net.Addr
|
||
}
|
||
|
||
func getfallbacktype_byindex(i int) byte {
|
||
return 1 << (i + 1)
|
||
}
|
||
|
||
// 判断 Fallback.SupportType 返回的 数值 是否具有特定的Fallback类型
|
||
func HasFallbackType(ftype, b byte) bool {
|
||
return ftype&b > 0
|
||
}
|
||
|
||
// 实现 Fallback. 这里的fallback只与http协议有关，所以只能按path,alpn 和 sni 进行分类
|
||
type Fallback interface {
|
||
GetFallback(ftype byte, params ...string) *FallbackResult
|
||
SupportType() byte //参考Fallback_开头的常量。如果支持多个，则返回它们 按位与 的结果
|
||
}
|
||
|
||
type FallbackResult struct {
|
||
Addr netLayer.Addr
|
||
Xver int
|
||
}
|
||
|
||
func (r *FallbackResult) GetFallback(ftype byte, _ ...string) *FallbackResult {
|
||
return r
|
||
}
|
||
|
||
func (FallbackResult) SupportType() byte {
|
||
return FallBack_default
|
||
}
|
||
|
||
type FallbackConf struct {
|
||
//可选
|
||
FromTag []string `toml:"from" json:"from"` //which inServer triggered this fallback
|
||
|
||
Xver int `toml:"xver" json:"xver"` //use PROXY protocol or not, and which version
|
||
|
||
//必填。
|
||
//see netLayer.NewAddrFromAny for details about "any" addr.
|
||
//
|
||
// 约定，如果该项是字符串 且 开头为@，则我们认为它给出的是 tag 名称，要将其替换为 实际 该tag的 listen 的地址。
|
||
Dest any `toml:"dest" json:"dest"`
|
||
|
||
//几种匹配方式，可选
|
||
|
||
Path string `toml:"path" json:"path"`
|
||
Sni string `toml:"sni" json:"sni"`
|
||
Alpn []string `toml:"alpn" json:"alpn"`
|
||
}
|