@@ -32,7 +32,11 @@ type httpclient interface {
32
32
Do (* http.Request ) (* http.Response , error )
33
33
}
34
34
35
- var errCannotReadFromWebsocket = errors .New ("cannot read message from websocket" )
35
+ var (
36
+ errCannotReadFromWebsocket = errors .New ("cannot read message from websocket" )
37
+ errEmptyMethod = errors .New ("empty method" )
38
+ )
39
+
36
40
var logger = log .NewFromGlobal (log .AddContext ("pkg" , "rpc/subscription" ))
37
41
38
42
// WSConn struct to hold WebSocket Connection references
@@ -63,6 +67,10 @@ func (c *WSConn) readWebsocketMessage() (rawBytes []byte, wsMessage *websocketMe
63
67
return nil , nil , err
64
68
}
65
69
70
+ if wsMessage .Method == "" {
71
+ return nil , nil , errEmptyMethod
72
+ }
73
+
66
74
return rawBytes , wsMessage , nil
67
75
}
68
76
@@ -81,12 +89,6 @@ func (c *WSConn) HandleConn() {
81
89
}
82
90
83
91
logger .Tracef ("websocket message received: %s" , string (rawBytes ))
84
-
85
- if wsMessage .Method == "" {
86
- c .safeSendError (0 , big .NewInt (InvalidRequestCode ), InvalidRequestMessage )
87
- continue
88
- }
89
-
90
92
logger .Debugf ("ws method %s called with params %v" , wsMessage .Method , wsMessage .Params )
91
93
92
94
if ! strings .Contains (wsMessage .Method , "_unsubscribe" ) && ! strings .Contains (wsMessage .Method , "_unwatch" ) {
0 commit comments