Archived
1
0

add http proxy support to feeds

This commit is contained in:
Jeff Becker 2017-12-29 10:24:03 -05:00
parent 9e644eb004
commit 29ab733808
No known key found for this signature in database
GPG Key ID: F357B3B42F6F9B05

View File

@ -4,6 +4,7 @@
package srnd package srnd
import ( import (
"bufio"
"crypto/tls" "crypto/tls"
"errors" "errors"
"fmt" "fmt"
@ -286,6 +287,36 @@ func (self *NNTPDaemon) dialOut(proxy_type, proxy_addr, remote_addr string) (con
err = errors.New("failed to connect via proxy") err = errors.New("failed to connect via proxy")
return return
} }
} else if proxy_type == "http" {
log.Println("dial out via http proxy", proxy_addr)
conn, err = net.Dial("tcp", proxy_addr)
if err == nil {
var ok bool
_, err = fmt.Fprintf(conn, "CONNECT %s HTTP/1.1\r\n\r\n", remote_addr)
if err == nil {
r := bufio.NewReader(conn)
var line, firstline string
firstline, err = r.ReadString(10)
if strings.HasPrefix(firstline, "HTTP/1.1 200") {
ok = true
log.Println("http proxy connect accepted")
}
for err == nil {
line, err = r.ReadString(10)
if line == "\r" || line == "" {
break
}
}
if ok {
log.Println("http proxy connect okay")
} else {
err = errors.New("proxy request rejected: " + strings.Trim(firstline, "\r"))
log.Println(err)
conn.Close()
conn = nil
}
}
}
} else { } else {
err = errors.New("invalid proxy type: " + proxy_type) err = errors.New("invalid proxy type: " + proxy_type)
} }