aboutsummaryrefslogtreecommitdiff
path: root/setup/base/base_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'setup/base/base_test.go')
-rw-r--r--setup/base/base_test.go49
1 files changed, 47 insertions, 2 deletions
diff --git a/setup/base/base_test.go b/setup/base/base_test.go
index d906294c..658dc5b0 100644
--- a/setup/base/base_test.go
+++ b/setup/base/base_test.go
@@ -2,10 +2,13 @@ package base_test
import (
"bytes"
+ "context"
"embed"
"html/template"
+ "net"
"net/http"
"net/http/httptest"
+ "path"
"testing"
"time"
@@ -18,7 +21,7 @@ import (
//go:embed static/*.gotmpl
var staticContent embed.FS
-func TestLandingPage(t *testing.T) {
+func TestLandingPage_Tcp(t *testing.T) {
// generate the expected result
tmpl := template.Must(template.ParseFS(staticContent, "static/*.gotmpl"))
expectedRes := &bytes.Buffer{}
@@ -35,7 +38,9 @@ func TestLandingPage(t *testing.T) {
s.Close()
// start base with the listener and wait for it to be started
- go b.SetupAndServeHTTP(config.HTTPAddress(s.URL), nil, nil)
+ address, err := config.HTTPAddress(s.URL)
+ assert.NoError(t, err)
+ go b.SetupAndServeHTTP(address, nil, nil)
time.Sleep(time.Millisecond * 10)
// When hitting /, we should be redirected to /_matrix/static, which should contain the landing page
@@ -55,3 +60,43 @@ func TestLandingPage(t *testing.T) {
// Using .String() for user friendly output
assert.Equal(t, expectedRes.String(), buf.String(), "response mismatch")
}
+
+func TestLandingPage_UnixSocket(t *testing.T) {
+ // generate the expected result
+ tmpl := template.Must(template.ParseFS(staticContent, "static/*.gotmpl"))
+ expectedRes := &bytes.Buffer{}
+ err := tmpl.ExecuteTemplate(expectedRes, "index.gotmpl", map[string]string{
+ "Version": internal.VersionString(),
+ })
+ assert.NoError(t, err)
+
+ b, _, _ := testrig.Base(nil)
+ defer b.Close()
+
+ tempDir := t.TempDir()
+ socket := path.Join(tempDir, "socket")
+ // start base with the listener and wait for it to be started
+ address := config.UnixSocketAddress(socket, 0755)
+ assert.NoError(t, err)
+ go b.SetupAndServeHTTP(address, nil, nil)
+ time.Sleep(time.Millisecond * 100)
+
+ client := &http.Client{
+ Transport: &http.Transport{
+ DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
+ return net.Dial("unix", socket)
+ },
+ },
+ }
+ resp, err := client.Get("http://unix/")
+ assert.NoError(t, err)
+ assert.Equal(t, http.StatusOK, resp.StatusCode)
+
+ // read the response
+ buf := &bytes.Buffer{}
+ _, err = buf.ReadFrom(resp.Body)
+ assert.NoError(t, err)
+
+ // Using .String() for user friendly output
+ assert.Equal(t, expectedRes.String(), buf.String(), "response mismatch")
+}