[SocketIOUser] - I have provided the code to turn off the SSL certification but still, I'm getting an SSL certification error

[balaji2711]

Hi All,

I have provided the code to turn off the SSL certification but still, I'm getting an SSL certification error. Please find the below code -

class TestLocust(SocketIOUser):

@task
def my_task(self):
    self.connect("wss://javascript.info/article/websocket/demo/hello", header=["XMLDecode", {"cert_req": ssl.CERT_NONE}])
    self.send('hello["subscribe",{"url":"/article/websocket/demo/hello","sendInitialUpdate": true, "message":"helloworld"}]')     

def on_message(self, message):
    self.my_value = message

Error Message:
ssl.SSLCertVerificationError: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: certificate has expired (_ssl.c:997)

Any help or suggestion would be appreciated. Thanks in advance.

[balaji2711]

I'm using the below version, - locust 2.10.1

[cyberw]

open() is pretty much just a wrapper around websocket.create_connection(), so maybe check its documentation?

[balaji2711]

Hi @cyberw,

I don't see open() in a WebSocket class. And I don't see it's documented anywhere.
Please find the below create_connection() from WebSocket class.

WebSocket.create_connection() is accepting the sslopt parameters (Refer the highlighted lines below) but SocketIOUser.connect() is not accepting the sslopt. Getting the below error message when I pass the sslopt parameters

TypeError: SocketIOUser.connect() got an unexpected keyword argument 'sslopt'

def create_connection(url, timeout=None, class_=WebSocket, **options):
"""
Parameters
----------
class_: class
class to instantiate when creating the connection. It has to implement
settimeout and connect. It's init should be compatible with
WebSocket.init, i.e. accept all of it's kwargs.
header: list or dict
custom http header list or dict.
cookie: str
Cookie value.
origin: str
custom origin url.
suppress_origin: bool
suppress outputting origin header.
host: str
custom host header string.
timeout: int or float
socket timeout time. This value could be either float/integer.
If set to None, it uses the default_timeout value.
http_proxy_host: str
HTTP proxy host name.
http_proxy_port: str or int
HTTP proxy port. If not set, set to 80.
http_no_proxy: list
Whitelisted host names that don't use the proxy.
http_proxy_auth: tuple
HTTP proxy auth information. tuple of username and password. Default is None.
enable_multithread: bool
Enable lock for multithread.
redirect_limit: int
Number of redirects to follow.
sockopt: tuple
Values for socket.setsockopt.
sockopt must be a tuple and each element is an argument of sock.setsockopt.
sslopt: dict
Optional dict object for ssl socket options. See FAQ for details.
subprotocols: list
List of available subprotocols. Default is None.
skip_utf8_validation: bool
Skip utf8 validation.
socket: socket
Pre-initialized stream socket.
"""
sockopt = options.pop("sockopt", [])
sslopt = options.pop("sslopt", {})
fire_cont_frame = options.pop("fire_cont_frame", False)
enable_multithread = options.pop("enable_multithread", True)
skip_utf8_validation = options.pop("skip_utf8_validation", False)
websock = class_(sockopt=sockopt, sslopt=sslopt,
fire_cont_frame=fire_cont_frame,
enable_multithread=enable_multithread,
skip_utf8_validation=skip_utf8_validation, **options)
websock.settimeout(timeout if timeout is not None else getdefaulttimeout())
websock.connect(url, **options)
return websock

Please note: I'm able to run my code with websocket.create_connection() not with SocketIOUser.connect()

Kindly change the code to accept sslopt and subprotocols as well.

[cyberw]

Sorry, I meant connect, not open.

https://github.com/SvenskaSpel/locust-plugins/blob/bf4097eb3a04580de886b5b138151a6b0d21660e/locust_plugins/users/socketio.py#L24

[cyberw]

If you want to change it to also forward other arguments, please make a PR.

[balaji2711]

Hi @cyberw,

I have raised the PR. Please review and merge the code.

[cyberw]

Fixed in locust-plugins 2.6.9