137 lines
3.3 KiB
Go
137 lines
3.3 KiB
Go
package http
|
|
|
|
import (
|
|
"fmt"
|
|
"net"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/Dreamacro/clash/adapter/inbound"
|
|
"github.com/Dreamacro/clash/common/cache"
|
|
N "github.com/Dreamacro/clash/common/net"
|
|
C "github.com/Dreamacro/clash/constant"
|
|
authStore "github.com/Dreamacro/clash/listener/auth"
|
|
"github.com/Dreamacro/clash/log"
|
|
)
|
|
|
|
func HandleConn(c net.Conn, in chan<- C.ConnContext, cache *cache.Cache) {
|
|
client := newClient(c.RemoteAddr(), in)
|
|
defer client.CloseIdleConnections()
|
|
|
|
conn := N.NewBufferedConn(c)
|
|
|
|
keepAlive := true
|
|
trusted := cache == nil // disable authenticate if cache is nil
|
|
|
|
for keepAlive {
|
|
request, err := ReadRequest(conn.Reader())
|
|
if err != nil {
|
|
break
|
|
}
|
|
|
|
request.RemoteAddr = conn.RemoteAddr().String()
|
|
|
|
keepAlive = strings.TrimSpace(strings.ToLower(request.Header.Get("Proxy-Connection"))) == "keep-alive"
|
|
|
|
var resp *http.Response
|
|
|
|
if !trusted {
|
|
resp = authenticate(request, cache)
|
|
|
|
trusted = resp == nil
|
|
}
|
|
|
|
if trusted {
|
|
if request.Method == http.MethodConnect {
|
|
// Manual writing to support CONNECT for http 1.0 (workaround for uplay client)
|
|
if _, err = fmt.Fprintf(conn, "HTTP/%d.%d %03d %s\r\n\r\n", request.ProtoMajor, request.ProtoMinor, http.StatusOK, "Connection established"); err != nil {
|
|
break // close connection
|
|
}
|
|
|
|
in <- inbound.NewHTTPS(request, conn)
|
|
|
|
return // hijack connection
|
|
}
|
|
|
|
host := request.Header.Get("Host")
|
|
if host != "" {
|
|
request.Host = host
|
|
}
|
|
|
|
request.RequestURI = ""
|
|
|
|
if isUpgradeRequest(request) {
|
|
handleUpgrade(conn, request, in)
|
|
|
|
return // hijack connection
|
|
}
|
|
|
|
removeHopByHopHeaders(request.Header)
|
|
removeExtraHTTPHostPort(request)
|
|
|
|
if request.URL.Scheme == "" || request.URL.Host == "" {
|
|
resp = responseWith(request, http.StatusBadRequest)
|
|
} else {
|
|
resp, err = client.Do(request)
|
|
if err != nil {
|
|
resp = responseWith(request, http.StatusBadGateway)
|
|
}
|
|
}
|
|
|
|
removeHopByHopHeaders(resp.Header)
|
|
}
|
|
|
|
if keepAlive {
|
|
resp.Header.Set("Proxy-Connection", "keep-alive")
|
|
resp.Header.Set("Connection", "keep-alive")
|
|
resp.Header.Set("Keep-Alive", "timeout=4")
|
|
}
|
|
|
|
resp.Close = !keepAlive
|
|
|
|
err = resp.Write(conn)
|
|
if err != nil {
|
|
break // close connection
|
|
}
|
|
}
|
|
|
|
conn.Close()
|
|
}
|
|
|
|
func authenticate(request *http.Request, cache *cache.Cache) *http.Response {
|
|
authenticator := authStore.Authenticator()
|
|
if authenticator != nil {
|
|
credential := parseBasicProxyAuthorization(request)
|
|
if credential == "" {
|
|
resp := responseWith(request, http.StatusProxyAuthRequired)
|
|
resp.Header.Set("Proxy-Authenticate", "Basic")
|
|
return resp
|
|
}
|
|
|
|
var authed any
|
|
if authed = cache.Get(credential); authed == nil {
|
|
user, pass, err := decodeBasicProxyAuthorization(credential)
|
|
authed = err == nil && authenticator.Verify(user, pass)
|
|
cache.Put(credential, authed, time.Minute)
|
|
}
|
|
if !authed.(bool) {
|
|
log.Infoln("Auth failed from %s", request.RemoteAddr)
|
|
|
|
return responseWith(request, http.StatusForbidden)
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func responseWith(request *http.Request, statusCode int) *http.Response {
|
|
return &http.Response{
|
|
StatusCode: statusCode,
|
|
Status: http.StatusText(statusCode),
|
|
Proto: request.Proto,
|
|
ProtoMajor: request.ProtoMajor,
|
|
ProtoMinor: request.ProtoMinor,
|
|
Header: http.Header{},
|
|
}
|
|
}
|