- Add more documetation

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

1 files changed, 7 insertions, 2 deletions

diff --git a/plugins/websockets/executor/executor.go b/plugins/websockets/executor/executor.go
index 9ef5e40a..048a41ed 100644
--- a/plugins/websockets/executor/executor.go
+++ b/plugins/websockets/executor/executor.go
@@ -3,6 +3,7 @@ package executor
 import (
 	"github.com/fasthttp/websocket"
 	json "github.com/json-iterator/go"
+	"github.com/spiral/errors"
 	"github.com/spiral/roadrunner/v2/pkg/pubsub"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 	"github.com/spiral/roadrunner/v2/plugins/websockets/commands"
@@ -22,6 +23,8 @@ type Executor struct {
 
 	// associated connection ID
 	connID string
+
+	// map with the pubsub drivers
 	pubsub map[string]pubsub.PubSub
 }
 
@@ -37,14 +40,16 @@ func NewExecutor(conn *connection.Connection, log logger.Logger, bst *storage.St
 }
 
 func (e *Executor) StartCommandLoop() error {
+	const op = errors.Op("executor_command_loop")
 	for {
 		mt, data, err := e.conn.Read()
 		if err != nil {
 			if mt == -1 {
-				return err
+				e.log.Error("socket was closed", "error", err, "message type", mt)
+				return nil
 			}
 
-			return err
+			return errors.E(op, err)
 		}
 
 		msg := &pubsub.Msg{}