- Rework finished

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 0 insertions, 112 deletions

diff --git a/tests/plugins/broadcast/broadcast_plugin_test.go b/tests/plugins/broadcast/broadcast_plugin_test.go
index 5b195bd0..585a81a9 100644
--- a/tests/plugins/broadcast/broadcast_plugin_test.go
+++ b/tests/plugins/broadcast/broadcast_plugin_test.go
@@ -1,22 +1,13 @@
 package broadcast
 
 import (
-	"net"
-	"net/http"
-	"net/rpc"
-	"net/url"
 	"os"
 	"os/signal"
 	"sync"
 	"syscall"
 	"testing"
-	"time"
 
-	"github.com/fasthttp/websocket"
-	json "github.com/json-iterator/go"
 	endure "github.com/spiral/endure/pkg/container"
-	goridgeRpc "github.com/spiral/goridge/v3/pkg/rpc"
-	websocketsv1 "github.com/spiral/roadrunner/v2/pkg/proto/websockets/v1beta"
 	"github.com/spiral/roadrunner/v2/plugins/broadcast"
 	"github.com/spiral/roadrunner/v2/plugins/config"
 	httpPlugin "github.com/spiral/roadrunner/v2/plugins/http"
@@ -26,7 +17,6 @@ import (
 	rpcPlugin "github.com/spiral/roadrunner/v2/plugins/rpc"
 	"github.com/spiral/roadrunner/v2/plugins/server"
 	"github.com/spiral/roadrunner/v2/plugins/websockets"
-	"github.com/spiral/roadrunner/v2/utils"
 	"github.com/stretchr/testify/assert"
 )
 
@@ -98,109 +88,7 @@ func TestBroadcastInit(t *testing.T) {
 		}
 	}()
 
-	t.Run("TestWSInit", wsInit)
-
 	stopCh <- struct{}{}
 
 	wg.Wait()
 }
-
-func wsInit(t *testing.T) {
-	da := websocket.Dialer{
-		Proxy:            http.ProxyFromEnvironment,
-		HandshakeTimeout: time.Second * 20,
-	}
-
-	connURL := url.URL{Scheme: "ws", Host: "localhost:11111", Path: "/ws"}
-
-	c, resp, err := da.Dial(connURL.String(), nil)
-	assert.NoError(t, err)
-
-	defer func() {
-		_ = resp.Body.Close()
-	}()
-
-	d, err := json.Marshal(messageWS("join", "memory", []byte("hello websockets"), "foo", "foo2"))
-	if err != nil {
-		panic(err)
-	}
-
-	err = c.WriteMessage(websocket.BinaryMessage, d)
-	assert.NoError(t, err)
-
-	_, msg, err := c.ReadMessage()
-	retMsg := utils.AsString(msg)
-	assert.NoError(t, err)
-
-	// subscription done
-	assert.Equal(t, `{"topic":"@join","payload":["foo","foo2"]}`, retMsg)
-
-	err = c.WriteControl(websocket.CloseMessage, nil, time.Time{})
-	assert.NoError(t, err)
-}
-
-func publishAsync(t *testing.T, command string, broker string, topics ...string) {
-	conn, err := net.Dial("tcp", "127.0.0.1:6001")
-	if err != nil {
-		panic(err)
-	}
-
-	client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-
-	ret := &websocketsv1.Response{}
-	err = client.Call("websockets.PublishAsync", makeMessage(command, broker, []byte("hello, PHP"), topics...), ret)
-	assert.NoError(t, err)
-	assert.True(t, ret.Ok)
-}
-
-func publishAsync2(t *testing.T, command string, broker string, topics ...string) {
-	conn, err := net.Dial("tcp", "127.0.0.1:6001")
-	if err != nil {
-		panic(err)
-	}
-
-	client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-
-	ret := &websocketsv1.Response{}
-	err = client.Call("websockets.PublishAsync", makeMessage(command, broker, []byte("hello, PHP2"), topics...), ret)
-	assert.NoError(t, err)
-	assert.True(t, ret.Ok)
-}
-
-func publish2(t *testing.T, command string, broker string, topics ...string) {
-	conn, err := net.Dial("tcp", "127.0.0.1:6001")
-	if err != nil {
-		panic(err)
-	}
-
-	client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-
-	ret := &websocketsv1.Response{}
-	err = client.Call("websockets.Publish", makeMessage(command, broker, []byte("hello, PHP2"), topics...), ret)
-	assert.NoError(t, err)
-	assert.True(t, ret.Ok)
-}
-
-func messageWS(command string, broker string, payload []byte, topics ...string) *websocketsv1.Message {
-	return &websocketsv1.Message{
-		Topics:  topics,
-		Command: command,
-		//Broker:  broker,
-		Payload: payload,
-	}
-}
-
-func makeMessage(command string, broker string, payload []byte, topics ...string) *websocketsv1.Request {
-	m := &websocketsv1.Request{
-		Messages: []*websocketsv1.Message{
-			{
-				Topics:  topics,
-				Command: command,
-				//Broker:  broker,
-				Payload: payload,
-			},
-		},
-	}
-
-	return m
-}