diff options
| author | Valery Piashchynski <[email protected]> | 2021-06-16 15:53:40 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-06-16 15:53:40 +0300 |
| commit | 25e0841c6aa5e2686da5b9f74e3d77d3814ff592 (patch) | |
| tree | 5b7c5259375d53b0685bf838555118d5ad93f149 /plugins/websockets/executor | |
| parent | 9dc98d43b0c0de3e1e1bd8fdc97c122c7c7c594f (diff) | |
| parent | b1aa5d0ea3617710aec6476bdae956e16b946281 (diff) | |
#730 bug(websockets): not properly checked request originv2.3.1-beta.3
#730 bug(websockets): not properly checked request origin
Diffstat (limited to 'plugins/websockets/executor')
| -rw-r--r-- | plugins/websockets/executor/executor.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/plugins/websockets/executor/executor.go b/plugins/websockets/executor/executor.go index e3d47166..5f904d26 100644 --- a/plugins/websockets/executor/executor.go +++ b/plugins/websockets/executor/executor.go @@ -5,7 +5,6 @@ import ( "net/http" "sync" - "github.com/fasthttp/websocket" json "github.com/json-iterator/go" "github.com/spiral/errors" websocketsv1 "github.com/spiral/roadrunner/v2/pkg/proto/websockets/v1beta" @@ -100,7 +99,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit return errors.E(op, fmt.Errorf("%v,%v", err, errJ)) } - errW := e.conn.Write(websocket.BinaryMessage, packet) + errW := e.conn.Write(packet) if errW != nil { e.log.Error("error writing payload to the connection", "payload", packet, "error", errW) return errors.E(op, fmt.Errorf("%v,%v", err, errW)) @@ -120,7 +119,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit return errors.E(op, err) } - err = e.conn.Write(websocket.BinaryMessage, packet) + err = e.conn.Write(packet) if err != nil { e.log.Error("error writing payload to the connection", "payload", packet, "error", err) return errors.E(op, err) @@ -150,7 +149,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit return errors.E(op, err) } - err = e.conn.Write(websocket.BinaryMessage, packet) + err = e.conn.Write(packet) if err != nil { e.log.Error("error writing payload to the connection", "payload", packet, "error", err) return errors.E(op, err) |