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

add method validation

Browse Source
This commit is contained in:
xvzc 2022-01-07 23:04:09 +09:00
parent 2fd2503dd5
commit 72d5770d18
3 changed files with 81 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
proxy/https.go
View File

@ -8,42 +8,42 @@ import (
)
func HandleHttps(clientConn net.Conn, ip string) {
// Create a connection to the requested server
remoteConn, err := net.Dial("tcp", ip+":443")
if err != nil {
util.Debug(err)
return
}
defer remoteConn.Close()
// Create a connection to the requested server
remoteConn, err := net.Dial("tcp", ip+":443")
if err != nil {
util.Debug(err)
return
}
defer remoteConn.Close()
util.Debug("[HTTPS] Connected to the server.")
util.Debug("[HTTPS] Connected to the server.")
// Send self generated response for connect request
fmt.Fprintf(clientConn, "HTTP/1.1 200 Connection Established\r\n\r\n")
util.Debug("[HTTPS] Sent 200 Connection Estabalished")
// Send self generated response for connect request
fmt.Fprintf(clientConn, "HTTP/1.1 200 Connection Established\r\n\r\n")
util.Debug("[HTTPS] Sent 200 Connection Estabalished")
// Read client hello
clientHello, err := ReadBytes(clientConn)
if err != nil {
util.Debug("[HTTPS] Error reading client hello: ", err)
util.Debug("Closing connection ", clientConn.RemoteAddr())
}
// Read client hello
clientHello, err := ReadBytes(clientConn)
if err != nil {
util.Debug("[HTTPS] Error reading client hello: ", err)
util.Debug("Closing connection ", clientConn.RemoteAddr())
}
util.Debug(clientConn.RemoteAddr(), "[HTTPS] Client sent hello", len(clientHello))
util.Debug(clientConn.RemoteAddr(), "[HTTPS] Client sent hello", len(clientHello))
// Generate a go routine that reads from the server
go Serve(remoteConn, clientConn, "HTTPS")
// Generate a go routine that reads from the server
go Serve(remoteConn, clientConn, "HTTPS")
// Send chunked request
chunks := util.BytesToChunks(clientHello)
for i := 0; i < len(chunks); i++ {
_, write_err := remoteConn.Write(chunks[i])
if write_err != nil {
util.Debug("[HTTPS] Error writing to the client:", write_err)
break
}
}
// Send chunked request
chunks := util.BytesToChunks(clientHello)
for i := 0; i < len(chunks); i++ {
_, write_err := remoteConn.Write(chunks[i])
if write_err != nil {
util.Debug("[HTTPS] Error writing to the client:", write_err)
break
}
}
// Read from the client
Serve(clientConn, remoteConn, "HTTPS")
// Read from the client
Serve(clientConn, remoteConn, "HTTPS")
}

5
proxy/proxy.go
View File

@ -37,6 +37,11 @@ func Start() {
util.Debug("Client sent data: ", len(message))
method := util.ExtractMethod(&message)
if !util.IsValidMethod(method) {
return
}
domain := util.ExtractDomain(&message)
ip, err := util.DnsLookupOverHttps(config.GetConfig().DNS, domain) // Dns lookup over https

46
util/util.go
View File

@ -7,6 +7,50 @@ import (
"github.com/xvzc/SpoofDPI/config"
)
var validMethod = map[string]struct{}{
"DELETE": {},
"GET": {},
"HEAD": {},
"POST": {},
"PUT": {},
"CONNECT": {},
"OPTIONS": {},
"TRACE": {},
"COPY": {},
"LOCK": {},
"MKCOL": {},
"MOVE": {},
"PROPFIND": {},
"PROPPATCH": {},
"SEARCH": {},
"UNLOCK": {},
"BIND": {},
"REBIND": {},
"UNBIND": {},
"ACL": {},
"REPORT": {},
"MKACTIVITY": {},
"CHECKOUT": {},
"MERGE": {},
"M-SEARCH": {},
"NOTIFY": {},
"SUBSCRIBE": {},
"UNSUBSCRIBE": {},
"PATCH": {},
"PURGE": {},
"MKCALENDAR": {},
"LINK": {},
"UNLINK": {},
}
func IsValidMethod(name string) bool {
if _, exists := validMethod[name]; exists {
return true
}
return false
}
func ExtractDomain(message *[]byte) string {
i := 0
for ; i < len(*message); i++ {
@ -32,7 +76,7 @@ func ExtractDomain(message *[]byte) string {
domain := strings.Split(string((*message)[i:j]), ":")[0]
return strings.TrimSpace(domain)
return strings.ToUpper(strings.TrimSpace(domain))
}
func ExtractMethod(message *[]byte) string {