mirror of
https://github.com/bettercap/bettercap
synced 2025-07-16 10:03:39 -07:00
misc: replaced glide with go dep
This commit is contained in:
evilsocket
parent
a2e90769fe
commit
6b6078d30d
533 changed files with 298 additions and 128052 deletions
45
vendor/github.com/inconshreveable/go-vhost/http_test.go
generated
vendored
45
vendor/github.com/inconshreveable/go-vhost/http_test.go
generated
vendored
|
|
@ -1,45 +0,0 @@
|
|||
package vhost
|
||||
|
||||
import (
|
||||
"net"
|
||||
"net/http"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestHTTPHost(t *testing.T) {
|
||||
var testHostname string = "foo.example.com"
|
||||
|
||||
l, err := net.Listen("tcp", "127.0.0.1:12345")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
defer l.Close()
|
||||
|
||||
go func() {
|
||||
conn, err := net.Dial("tcp", "127.0.0.1:12345")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
defer conn.Close()
|
||||
req, err := http.NewRequest("GET", "http://"+testHostname+"/bar", nil)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
if err = req.Write(conn); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
}()
|
||||
|
||||
conn, err := l.Accept()
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
c, err := HTTP(conn)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
if c.Host() != testHostname {
|
||||
t.Errorf("Connection Host() is %s, expected %s", c.Host(), testHostname)
|
||||
}
|
||||
}
|
||||
195
vendor/github.com/inconshreveable/go-vhost/mux_test.go
generated
vendored
195
vendor/github.com/inconshreveable/go-vhost/mux_test.go
generated
vendored
|
|
@ -1,195 +0,0 @@
|
|||
package vhost
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"io"
|
||||
"io/ioutil"
|
||||
"net"
|
||||
"net/http"
|
||||
"strconv"
|
||||
"strings"
|
||||
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
|
||||
// TestErrors ensures that error types for this package are implemented properly
|
||||
func TestErrors(t *testing.T) {
|
||||
// test case for https://github.com/inconshreveable/go-vhost/pull/2
|
||||
// create local err vars of error interface type
|
||||
var notFoundErr error
|
||||
var badRequestErr error
|
||||
var closedErr error
|
||||
|
||||
// stuff local error types in to interface values
|
||||
notFoundErr = NotFound{fmt.Errorf("test NotFound")}
|
||||
badRequestErr = BadRequest{fmt.Errorf("test BadRequest")}
|
||||
closedErr = Closed{fmt.Errorf("test Closed")}
|
||||
|
||||
// assert the types
|
||||
switch errType := notFoundErr.(type) {
|
||||
case NotFound:
|
||||
default:
|
||||
t.Fatalf("expected NotFound, got: %s", errType)
|
||||
}
|
||||
switch errType := badRequestErr.(type) {
|
||||
case BadRequest:
|
||||
default:
|
||||
t.Fatalf("expected BadRequest, got: %s", errType)
|
||||
}
|
||||
switch errType := closedErr.(type) {
|
||||
case Closed:
|
||||
default:
|
||||
t.Fatalf("expected Closed, got: %s", errType)
|
||||
}
|
||||
}
|
||||
|
||||
func localListener(t *testing.T) (net.Listener, string) {
|
||||
l, err := net.Listen("tcp", "localhost:0")
|
||||
if err != nil {
|
||||
t.Fatalf("failed to listen: %v", err)
|
||||
}
|
||||
return l, strconv.Itoa(l.Addr().(*net.TCPAddr).Port)
|
||||
}
|
||||
|
||||
func TestHTTPMux(t *testing.T) {
|
||||
l, port := localListener(t)
|
||||
mux, err := NewHTTPMuxer(l, time.Second)
|
||||
if err != nil {
|
||||
t.Fatalf("failed to start muxer: %v", err)
|
||||
}
|
||||
go mux.HandleErrors()
|
||||
|
||||
muxed, err := mux.Listen("example.com")
|
||||
if err != nil {
|
||||
t.Fatalf("failed to listen on muxer: %v", muxed)
|
||||
}
|
||||
|
||||
go http.Serve(muxed, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||
io.Copy(w, r.Body)
|
||||
}))
|
||||
|
||||
msg := "test"
|
||||
url := "http://localhost:" + port
|
||||
resp, err := http.Post(url, "text/plain", strings.NewReader(msg))
|
||||
if err != nil {
|
||||
t.Fatalf("failed to post: %v", err)
|
||||
}
|
||||
|
||||
if resp.StatusCode != 404 {
|
||||
t.Fatalf("sent incorrect host header, expected 404 but got %d", resp.StatusCode)
|
||||
}
|
||||
|
||||
req, err := http.NewRequest("POST", url, strings.NewReader(msg))
|
||||
if err != nil {
|
||||
t.Fatalf("failed to construct HTTP request: %v", err)
|
||||
}
|
||||
req.Host = "example.com"
|
||||
req.Header.Set("Content-Type", "text/plain")
|
||||
|
||||
resp, err = new(http.Client).Do(req)
|
||||
if err != nil {
|
||||
t.Fatalf("failed to make HTTP request", err)
|
||||
}
|
||||
|
||||
body, err := ioutil.ReadAll(resp.Body)
|
||||
if err != nil {
|
||||
t.Fatalf("failed to read: %v", err)
|
||||
}
|
||||
|
||||
got := string(body)
|
||||
if got != msg {
|
||||
t.Fatalf("unexpected resposne. got: %v, expected: %v", got, msg)
|
||||
}
|
||||
}
|
||||
|
||||
func testMux(t *testing.T, listen, dial string) {
|
||||
muxFn := func(c net.Conn) (Conn, error) {
|
||||
return fakeConn{c, dial}, nil
|
||||
}
|
||||
|
||||
fakel := make(fakeListener, 1)
|
||||
mux, err := NewVhostMuxer(fakel, muxFn, time.Second)
|
||||
if err != nil {
|
||||
t.Fatalf("failed to start vhost muxer: %v", err)
|
||||
}
|
||||
|
||||
l, err := mux.Listen(listen)
|
||||
if err != nil {
|
||||
t.Fatalf("failed to listen for %s", err)
|
||||
}
|
||||
|
||||
done := make(chan struct{})
|
||||
go func() {
|
||||
conn, err := l.Accept()
|
||||
if err != nil {
|
||||
t.Fatalf("failed to accept connection: %v", err)
|
||||
return
|
||||
}
|
||||
|
||||
got := conn.(Conn).Host()
|
||||
expected := dial
|
||||
if got != expected {
|
||||
t.Fatalf("got connection with unexpected host. got: %s, expected: %s", got, expected)
|
||||
return
|
||||
}
|
||||
|
||||
close(done)
|
||||
}()
|
||||
|
||||
go func() {
|
||||
_, err := mux.NextError()
|
||||
if err != nil {
|
||||
t.Fatalf("muxing error: %v", err)
|
||||
}
|
||||
}()
|
||||
|
||||
fakel <- struct{}{}
|
||||
select {
|
||||
case <-done:
|
||||
case <-time.After(time.Second):
|
||||
t.Fatalf("test timed out: dial: %s listen: %s", dial, listen)
|
||||
}
|
||||
}
|
||||
|
||||
func TestMuxingPatterns(t *testing.T) {
|
||||
var tests = []struct {
|
||||
listen string
|
||||
dial string
|
||||
}{
|
||||
{"example.com", "example.com"},
|
||||
{"sub.example.com", "sub.example.com"},
|
||||
{"*.example.com", "sub.example.com"},
|
||||
{"*.example.com", "nested.sub.example.com"},
|
||||
}
|
||||
|
||||
for _, test := range tests {
|
||||
testMux(t, test.listen, test.dial)
|
||||
}
|
||||
}
|
||||
|
||||
type fakeConn struct {
|
||||
net.Conn
|
||||
host string
|
||||
}
|
||||
|
||||
func (c fakeConn) SetDeadline(d time.Time) error { return nil }
|
||||
func (c fakeConn) Host() string { return c.host }
|
||||
func (c fakeConn) Free() {}
|
||||
|
||||
type fakeNetConn struct {
|
||||
net.Conn
|
||||
}
|
||||
|
||||
func (fakeNetConn) SetDeadline(time.Time) error { return nil }
|
||||
|
||||
type fakeListener chan struct{}
|
||||
|
||||
func (l fakeListener) Accept() (net.Conn, error) {
|
||||
for _ = range l {
|
||||
return fakeNetConn{nil}, nil
|
||||
}
|
||||
select {}
|
||||
}
|
||||
func (fakeListener) Addr() net.Addr { return nil }
|
||||
func (fakeListener) Close() error { return nil }
|
||||
64
vendor/github.com/inconshreveable/go-vhost/shared_test.go
generated
vendored
64
vendor/github.com/inconshreveable/go-vhost/shared_test.go
generated
vendored
|
|
@ -1,64 +0,0 @@
|
|||
package vhost
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"io"
|
||||
"net"
|
||||
"reflect"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestHeaderPreserved(t *testing.T) {
|
||||
var msg string = "TestHeaderPreserved message! Hello world!"
|
||||
var headerLen int = 15
|
||||
|
||||
l, err := net.Listen("tcp", "127.0.0.1:12345")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
defer l.Close()
|
||||
|
||||
go func() {
|
||||
conn, err := net.Dial("tcp", "127.0.0.1:12345")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
if _, err := conn.Write([]byte(msg)); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
if err = conn.Close(); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
}()
|
||||
|
||||
conn, err := l.Accept()
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
// create a shared connection object
|
||||
c, rd := newShared(conn)
|
||||
|
||||
// read out a "header"
|
||||
p := make([]byte, headerLen)
|
||||
_, err = io.ReadFull(rd, p)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
// make sure we got the header
|
||||
expectedHeader := []byte(msg[:headerLen])
|
||||
if !reflect.DeepEqual(p, expectedHeader) {
|
||||
t.Errorf("Read header bytes %s, expected %s", p, expectedHeader)
|
||||
return
|
||||
}
|
||||
|
||||
// read out the entire connection. make sure it includes the header
|
||||
buf := bytes.NewBuffer([]byte{})
|
||||
io.Copy(buf, c)
|
||||
|
||||
expected := []byte(msg)
|
||||
if !reflect.DeepEqual(buf.Bytes(), expected) {
|
||||
t.Errorf("Read full connection bytes %s, expected %s", buf.Bytes(), expected)
|
||||
}
|
||||
}
|
||||
39
vendor/github.com/inconshreveable/go-vhost/tls_test.go
generated
vendored
39
vendor/github.com/inconshreveable/go-vhost/tls_test.go
generated
vendored
|
|
@ -1,39 +0,0 @@
|
|||
package vhost
|
||||
|
||||
import (
|
||||
"crypto/tls"
|
||||
"net"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestSNI(t *testing.T) {
|
||||
var testHostname string = "foo.example.com"
|
||||
|
||||
l, err := net.Listen("tcp", "127.0.0.1:12345")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
defer l.Close()
|
||||
|
||||
go func() {
|
||||
conf := &tls.Config{ServerName: testHostname}
|
||||
conn, err := tls.Dial("tcp", "127.0.0.1:12345", conf)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
conn.Close()
|
||||
}()
|
||||
|
||||
conn, err := l.Accept()
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
c, err := TLS(conn)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
if c.Host() != testHostname {
|
||||
t.Errorf("Connection Host() is %s, expected %s", c.Host(), testHostname)
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue