- Add new internal plugin - channel. Which used to deliver messages from

  the ws plugin to the http directly

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

1 files changed, 22 insertions, 0 deletions

diff --git a/tests/plugins/http/http_plugin_test.go b/tests/plugins/http/http_plugin_test.go
index 128eec26..aa57077d 100644
--- a/tests/plugins/http/http_plugin_test.go
+++ b/tests/plugins/http/http_plugin_test.go
@@ -24,6 +24,7 @@ import (
 	goridgeRpc "github.com/spiral/goridge/v3/pkg/rpc"
 	"github.com/spiral/roadrunner/v2/pkg/events"
 	"github.com/spiral/roadrunner/v2/pkg/process"
+	"github.com/spiral/roadrunner/v2/plugins/channel"
 	"github.com/spiral/roadrunner/v2/plugins/config"
 	"github.com/spiral/roadrunner/v2/plugins/gzip"
 	"github.com/spiral/roadrunner/v2/plugins/informer"
@@ -62,6 +63,7 @@ func TestHTTPInit(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -126,6 +128,7 @@ func TestHTTPNoConfigSection(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -193,6 +196,7 @@ func TestHTTPInformerReset(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&informer.Plugin{},
 		&resetter.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -315,6 +319,7 @@ func TestSSL(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -451,6 +456,7 @@ func TestSSLRedirect(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -540,6 +546,7 @@ func TestSSLPushPipes(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -630,6 +637,7 @@ func TestFastCGI_RequestUri(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -724,6 +732,7 @@ func TestH2CUpgrade(t *testing.T) {
 		mockLogger,
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -815,6 +824,7 @@ func TestH2C(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -907,6 +917,7 @@ func TestHttpMiddleware(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&PluginMiddleware{},
 		&PluginMiddleware2{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1053,6 +1064,7 @@ logs:
 		&httpPlugin.Plugin{},
 		&PluginMiddleware{},
 		&PluginMiddleware2{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1138,6 +1150,7 @@ func TestHttpEnvVariables(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&PluginMiddleware{},
 		&PluginMiddleware2{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1225,6 +1238,7 @@ func TestHttpBrokenPipes(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&PluginMiddleware{},
 		&PluginMiddleware2{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1286,6 +1300,7 @@ func TestHTTPSupervisedPool(t *testing.T) {
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
 		&informer.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1488,6 +1503,7 @@ func TestHTTPBigRequestSize(t *testing.T) {
 		&logger.ZapLogger{},
 		&server.Plugin{},
 		&httpPlugin.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1580,6 +1596,7 @@ func TestStaticEtagPlugin(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&gzip.Plugin{},
 		&static.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1678,6 +1695,7 @@ func TestStaticPluginSecurity(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&gzip.Plugin{},
 		&static.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1827,6 +1845,7 @@ func TestStaticPlugin(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&gzip.Plugin{},
 		&static.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -1941,6 +1960,7 @@ func TestStaticDisabled_Error(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&gzip.Plugin{},
 		&static.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 	assert.Error(t, cont.Init())
@@ -1962,6 +1982,7 @@ func TestStaticFilesDisabled(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&gzip.Plugin{},
 		&static.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)
 
@@ -2054,6 +2075,7 @@ func TestStaticFilesForbid(t *testing.T) {
 		&httpPlugin.Plugin{},
 		&gzip.Plugin{},
 		&static.Plugin{},
+		&channel.Plugin{},
 	)
 	assert.NoError(t, err)