mirrors/SpoofDPI
1
0
Fork 0
mirror of https://github.com/xvzc/SpoofDPI.git synced 2024-12-22 14:26:31 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: rename HttpPacket to HttpRequest

Browse Source
This commit is contained in:
xvzc 2024-08-22 13:05:19 +09:00
parent d97d4e483c
commit 9beb9f8390
4 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
packet/http.go
View File

@ -44,7 +44,7 @@ var validMethod = map[string]struct{}{
"UNLINK": {}, "UNLINK": {},
} }
type HttpPacket struct { type HttpRequest struct {
raw []byte raw []byte
method string method string
domain string domain string
@ -53,7 +53,7 @@ type HttpPacket struct {
version string version string
} }
func ReadHttpPacket(rdr io.Reader) (*HttpPacket, error) { func ReadHttpRequest(rdr io.Reader) (*HttpRequest, error) {
p, err := parse(rdr) p, err := parse(rdr)
if err != nil { if err != nil {
return nil, err return nil, err
@ -62,26 +62,26 @@ func ReadHttpPacket(rdr io.Reader) (*HttpPacket, error) {
return p, nil return p, nil
} }
func (p *HttpPacket) Raw() []byte { func (p *HttpRequest) Raw() []byte {
return p.raw return p.raw
} }
func (p *HttpPacket) Method() string { func (p *HttpRequest) Method() string {
return p.method return p.method
} }
func (p *HttpPacket) Domain() string { func (p *HttpRequest) Domain() string {
return p.domain return p.domain
} }
func (p *HttpPacket) Port() string { func (p *HttpRequest) Port() string {
return p.port return p.port
} }
func (p *HttpPacket) Version() string { func (p *HttpRequest) Version() string {
return p.version return p.version
} }
func (p *HttpPacket) IsValidMethod() bool { func (p *HttpRequest) IsValidMethod() bool {
if _, exists := validMethod[p.Method()]; exists { if _, exists := validMethod[p.Method()]; exists {
return true return true
} }
@ -89,11 +89,11 @@ func (p *HttpPacket) IsValidMethod() bool {
return false return false
} }
func (p *HttpPacket) IsConnectMethod() bool { func (p *HttpRequest) IsConnectMethod() bool {
return p.Method() == "CONNECT" return p.Method() == "CONNECT"
} }
func (p *HttpPacket) Tidy() { func (p *HttpRequest) Tidy() {
s := string(p.raw) s := string(p.raw)
lines := strings.Split(s, "\r\n") lines := strings.Split(s, "\r\n")
@ -121,7 +121,7 @@ func (p *HttpPacket) Tidy() {
p.raw = []byte(result) p.raw = []byte(result)
} }
func parse(rdr io.Reader) (*HttpPacket, error) { func parse(rdr io.Reader) (*HttpRequest, error) {
sb := strings.Builder{} sb := strings.Builder{}
tee := io.TeeReader(rdr, &sb) tee := io.TeeReader(rdr, &sb)
request, err := http.ReadRequest(bufio.NewReader(tee)) request, err := http.ReadRequest(bufio.NewReader(tee))
@ -129,7 +129,7 @@ func parse(rdr io.Reader) (*HttpPacket, error) {
return nil, err return nil, err
} }
p := &HttpPacket{} p := &HttpRequest{}
p.raw = []byte(sb.String()) p.raw = []byte(sb.String())
p.domain, p.port, err = net.SplitHostPort(request.Host) p.domain, p.port, err = net.SplitHostPort(request.Host)

2
proxy/http.go
View File

@ -9,7 +9,7 @@ import (
"github.com/xvzc/SpoofDPI/packet" "github.com/xvzc/SpoofDPI/packet"
) )
func (pxy *Proxy) handleHttp(lConn *net.TCPConn, pkt *packet.HttpPacket, ip string) { func (pxy *Proxy) handleHttp(lConn *net.TCPConn, pkt *packet.HttpRequest, ip string) {
pkt.Tidy() pkt.Tidy()
// Create a connection to the requested server // Create a connection to the requested server

2
proxy/https.go
View File

@ -8,7 +8,7 @@ import (
"github.com/xvzc/SpoofDPI/packet" "github.com/xvzc/SpoofDPI/packet"
) )
func (pxy *Proxy) handleHttps(lConn *net.TCPConn, exploit bool, initPkt *packet.HttpPacket, ip string) { func (pxy *Proxy) handleHttps(lConn *net.TCPConn, exploit bool, initPkt *packet.HttpRequest, ip string) {
// Create a connection to the requested server // Create a connection to the requested server
var port int = 443 var port int = 443
var err error var err error

2
proxy/proxy.go
View File

@ -59,7 +59,7 @@ func (pxy *Proxy) Start() {
} }
go func() { go func() {
pkt, err := packet.ReadHttpPacket(conn) pkt, err := packet.ReadHttpRequest(conn)
if err != nil { if err != nil {
log.Debug("[PROXY] error while parsing request: ", err) log.Debug("[PROXY] error while parsing request: ", err)
conn.Close() conn.Close()