in main.go [66:86]
func (h *httpStream) run() {
buf := bufio.NewReader(&h.r)
for {
req, err := http.ReadRequest(buf)
if err == io.EOF {
// We must read until we see an EOF... very important!
return
} else if err != nil {
log.Println("Error reading stream", h.net, h.transport, ":", err)
} else {
reqSourceIP := h.net.Src().String()
reqDestionationPort := h.transport.Dst().String()
body, bErr := ioutil.ReadAll(req.Body)
if bErr != nil {
return
}
req.Body.Close()
go forwardRequest(req, reqSourceIP, reqDestionationPort, body)
}
}
}