| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140 | package httpimport (	"context"	"io"	"net/http"	"strings"	"v2ray.com/core/common"	"v2ray.com/core/common/net"	"v2ray.com/core/common/serial"	"v2ray.com/core/common/session"	"v2ray.com/core/common/signal/done"	"v2ray.com/core/transport/internet"	"v2ray.com/core/transport/internet/tls")type Listener struct {	server  *http.Server	handler internet.ConnHandler	local   net.Addr	config  Config}func (l *Listener) Addr() net.Addr {	return l.local}func (l *Listener) Close() error {	return l.server.Close()}type flushWriter struct {	w io.Writer	d *done.Instance}func (fw flushWriter) Write(p []byte) (n int, err error) {	if fw.d.Done() {		return 0, io.ErrClosedPipe	}	n, err = fw.w.Write(p)	if f, ok := fw.w.(http.Flusher); ok {		f.Flush()	}	return}func (l *Listener) ServeHTTP(writer http.ResponseWriter, request *http.Request) {	host := request.Host	if !l.config.isValidHost(host) {		writer.WriteHeader(404)		return	}	path := l.config.getNormalizedPath()	if !strings.HasPrefix(request.URL.Path, path) {		writer.WriteHeader(404)		return	}	writer.Header().Set("Cache-Control", "no-store")	writer.WriteHeader(200)	if f, ok := writer.(http.Flusher); ok {		f.Flush()	}	remoteAddr := l.Addr()	dest, err := net.ParseDestination(request.RemoteAddr)	if err != nil {		newError("failed to parse request remote addr: ", request.RemoteAddr).Base(err).WriteToLog()	} else {		remoteAddr = &net.TCPAddr{			IP:   dest.Address.IP(),			Port: int(dest.Port),		}	}	done := done.New()	conn := net.NewConnection(		net.ConnectionOutput(request.Body),		net.ConnectionInput(flushWriter{w: writer, d: done}),		net.ConnectionOnClose(common.NewChainedClosable(done, request.Body)),		net.ConnectionLocalAddr(l.Addr()),		net.ConnectionRemoteAddr(remoteAddr),	)	l.handler(conn)	<-done.Wait()}func Listen(ctx context.Context, address net.Address, port net.Port, handler internet.ConnHandler) (internet.Listener, error) {	rawSettings := internet.StreamSettingsFromContext(ctx)	httpSettings, ok := rawSettings.ProtocolSettings.(*Config)	if !ok {		return nil, newError("HTTP config is not set.").AtError()	}	listener := &Listener{		handler: handler,		local: &net.TCPAddr{			IP:   address.IP(),			Port: int(port),		},		config: *httpSettings,	}	config := tls.ConfigFromContext(ctx)	if config == nil {		return nil, newError("TLS must be enabled for http transport.").AtWarning()	}	server := &http.Server{		Addr:      serial.Concat(address, ":", port),		TLSConfig: config.GetTLSConfig(tls.WithNextProto("h2")),		Handler:   listener,	}	listener.server = server	go func() {		tcpListener, err := internet.ListenSystemTCP(ctx, &net.TCPAddr{			IP:   address.IP(),			Port: int(port),		})		if err != nil {			newError("failed to listen on", address, ":", port).Base(err).WriteToLog(session.ExportIDToError(ctx))			return		}		err = server.ServeTLS(tcpListener, "", "")		if err != nil {			newError("stoping serving TLS").Base(err).WriteToLog(session.ExportIDToError(ctx))		}	}()	return listener, nil}func init() {	common.Must(internet.RegisterTransportListener(protocolName, Listen))}
 |