Fix byte sizes

Author: nhooyr

.github/workflows/ci.yml

@@ -4,23 +4,23 @@ on: [push]
 jobs:
   fmt:
     runs-on: ubuntu-latest
-    container: docker://nhooyr/websocket-ci@sha256:97aa0fddfcf1ba7d90a21b1e7978884b7f4c1ca9668d2ed1891ff61f778aeaf0
+    container: docker://nhooyr/websocket-ci@sha256:9f69035d64afdb2062a631d35748d46f440ecf2a1985845fc99b8c97ab14ca58
     steps:
       - uses: actions/checkout@v1
         with:
           fetch-depth: 1
       - run: ./ci/fmt.sh
   lint:
     runs-on: ubuntu-latest
-    container: docker://nhooyr/websocket-ci@sha256:97aa0fddfcf1ba7d90a21b1e7978884b7f4c1ca9668d2ed1891ff61f778aeaf0
+    container: docker://nhooyr/websocket-ci@sha256:9f69035d64afdb2062a631d35748d46f440ecf2a1985845fc99b8c97ab14ca58
     steps:
       - uses: actions/checkout@v1
         with:
           fetch-depth: 1
       - run: ./ci/lint.sh
   test:
     runs-on: ubuntu-latest
-    container: docker://nhooyr/websocket-ci@sha256:97aa0fddfcf1ba7d90a21b1e7978884b7f4c1ca9668d2ed1891ff61f778aeaf0
+    container: docker://nhooyr/websocket-ci@sha256:9f69035d64afdb2062a631d35748d46f440ecf2a1985845fc99b8c97ab14ca58
     steps:
       - uses: actions/checkout@v1
         with:
@@ -30,7 +30,7 @@ jobs:
           CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
   wasm:
     runs-on: ubuntu-latest
-    container: docker://nhooyr/websocket-ci@sha256:97aa0fddfcf1ba7d90a21b1e7978884b7f4c1ca9668d2ed1891ff61f778aeaf0
+    container: docker://nhooyr/websocket-ci@sha256:9f69035d64afdb2062a631d35748d46f440ecf2a1985845fc99b8c97ab14ca58
     steps:
       - uses: actions/checkout@v1
         with:

ci/fmt.sh

@@ -18,7 +18,7 @@ fmt() {
   go run go.coder.com/go-tools/cmd/goimports -w "-local=$(go list -m)" .
   go run mvdan.cc/sh/cmd/shfmt -i 2 -w -s -sr .
   # shellcheck disable=SC2046
-  npx prettier \
+  npx -q prettier \
     --write \
     --print-width 120 \
     --no-semi \

ci/wasm.sh

@@ -4,22 +4,29 @@ set -euo pipefail
 cd "$(dirname "${0}")"
 cd "$(git rev-parse --show-toplevel)"
 
-stdout="$(mktemp -d)/stdout"
-mkfifo "$stdout"
-go run ./internal/wsecho/cmd > "$stdout" &
+wsEchoOut="$(mktemp)"
+go run ./internal/wsecho/cmd >> "$wsEchoOut" &
 
-WS_ECHO_SERVER_URL="$(head -n 1 "$stdout")"
+# Give it max 30 seconds.
+for _ in {1..30}; do
+  WS_ECHO_SERVER_URL="$(cat "$wsEchoOut")"
+  if [[ -n $WS_ECHO_SERVER_URL ]]; then
+    break
+  fi
+  sleep 1
+done
+
+if [[ -z $WS_ECHO_SERVER_URL ]]; then
+  echo "wsecho/cmd did not start in time"
+  exit 1
+fi
 
 GOOS=js GOARCH=wasm go vet ./...
 go install golang.org/x/lint/golint
 GOOS=js GOARCH=wasm golint -set_exit_status ./...
 go install github.com/agnivade/wasmbrowsertest
-GOOS=js GOARCH=wasm go test -exec="wasmbrowsertest" ./... -args "$WS_ECHO_SERVER_URL"
+GOOS=js GOARCH=wasm go test -exec=wasmbrowsertest ./... -args "$WS_ECHO_SERVER_URL"
 
-echo kill
-jobs
 kill %1
-echo wait
 wait -n || true
-jobs
-echo over
+rm "$wsEchoOut"

internal/wsecho/wsecho.go

@@ -30,16 +30,16 @@ func Serve(w http.ResponseWriter, r *http.Request) {
 
 // Loop echos every msg received from c until an error
 // occurs or the context expires.
-// The read limit is set to 1 << 40.
+// The read limit is set to 1 << 30.
 func Loop(ctx context.Context, c *websocket.Conn) {
 	defer c.Close(websocket.StatusInternalError, "")
 
-	c.SetReadLimit(1 << 40)
+	c.SetReadLimit(1 << 30)
 
 	ctx, cancel := context.WithTimeout(ctx, time.Minute)
 	defer cancel()
 
-	b := make([]byte, 32768)
+	b := make([]byte, 32<<10)
 	echo := func() error {
 		typ, r, err := c.Reader(ctx)
 		if err != nil {

websocket_js_test.go

@@ -2,20 +2,18 @@ package websocket_test
 
 import (
 	"context"
+	"flag"
 	"net/http"
-	"os"
 	"testing"
 	"time"
 
 	"nhooyr.io/websocket"
 )
 
-var wsEchoServerURL = os.Args[1]
-
 func TestWebSocket(t *testing.T) {
 	t.Parallel()
 
-	t.Skip("???")
+	wsEchoServerURL := flag.Arg(0)
 
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
 	defer cancel()

websocket_test.go

@@ -963,7 +963,7 @@ func TestAutobahn(t *testing.T) {
 					return err
 				}
 				defer c.Close(websocket.StatusInternalError, "")
-				c.SetReadLimit(1 << 40)
+				c.SetReadLimit(1 << 30)
 
 				ctx := r.Context()
 				if testingClient {
@@ -997,7 +997,7 @@ func TestAutobahn(t *testing.T) {
 				t.Fatal(err)
 			}
 			defer c.Close(websocket.StatusInternalError, "")
-			c.SetReadLimit(1 << 40)
+			c.SetReadLimit(1 << 30)
 
 			if testingClient {
 				err = fn(ctx, c)