mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-27 23:26:44 +00:00
c2ca66adad
* fix: resolve conflict * chg: use bor url for import * Fix regressions from merge Co-authored-by: Jaynti Kanani <jdkanani@gmail.com>
38 lines
973 B
Go
38 lines
973 B
Go
package node
|
|
|
|
import (
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"testing"
|
|
|
|
"github.com/maticnetwork/bor/rpc"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestNewWebsocketUpgradeHandler_websocket(t *testing.T) {
|
|
srv := rpc.NewServer()
|
|
|
|
handler := NewWebsocketUpgradeHandler(nil, srv.WebsocketHandler([]string{}))
|
|
ts := httptest.NewServer(handler)
|
|
defer ts.Close()
|
|
|
|
responses := make(chan *http.Response)
|
|
go func(responses chan *http.Response) {
|
|
client := &http.Client{}
|
|
|
|
req, _ := http.NewRequest(http.MethodGet, ts.URL, nil)
|
|
req.Header.Set("Connection", "upgrade")
|
|
req.Header.Set("Upgrade", "websocket")
|
|
req.Header.Set("Sec-WebSocket-Version", "13")
|
|
req.Header.Set("Sec-Websocket-Key", "SGVsbG8sIHdvcmxkIQ==")
|
|
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
t.Error("could not issue a GET request to the test http server", err)
|
|
}
|
|
responses <- resp
|
|
}(responses)
|
|
|
|
response := <-responses
|
|
assert.Equal(t, "websocket", response.Header.Get("Upgrade"))
|
|
}
|