response 41 after sending 42 auth session

[vladdd183]

Hello! I'm doing web socket reverse engineering too, ran into a problem, I'm doing the same as you:

1. I connect to the web socket
2. I get "0 sid..."
3. Send "40" in response
4. Receive message "40 sid..."
5. I reply with "42 auth session"
6. I get "41" in reply

async def process_message(message, websocket):
    print(message)
    if message.startswith('0{"sid":"'):
        message = message.lstrip("0")
        data = json.loads(message)
        print("got 0 sid send 40 ")
        await websocket.send("40")
    elif message == "2":
        print("got 2 send 3")
        await websocket.send("3")
    elif message.startswith('40{"sid":"'):
        print("got 40 sid send session")
        data = r"""42["auth",{"session":"a:4:{s:10:"session_id";s:32:"c53eec05c6f8a8be2d134d4fd55266f8";s:10:"ip_address";s:14:"46.138.176.190";s:10:"user_agent";s:101:"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36";s:13:"last_activity";i:1707850603;}9f383935faff5a86bc1658bbde8c61e7","isDemo":1,"uid":72038016,"platform":3}]"""
        await websocket.send(data)

I don't understand what this is about, could you please advise me?

[theshadow76]

Yes, same here, I am getting the error of 41, I am going to try using webdriver, probably it's beeing blocked, so I will try that, but I am not giving up on this api that for sure :)

[theshadow76]

I'll tell you what happened, and if I recomend it.

[vladdd183]

Okay, thank you very much. I'll keep trying and I'll tell you too if I find a solution :)

[vladdd183]

@theshadow76
I've made progress.
It was the backslashes before the inverted commas.
Now we're getting binary data
However, after the first data is received, the disconnect occurs.

data = r'42["auth",{"session":"a:4:{s:10:\"session_id\";s:32:\"c53eec05c6f8a8be2d134d4fd55266f8\";s:10:\"ip_address\";s:14:\"46.138.176.190\";s:10:\"user_agent\";s:101:\"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\";s:13:\"last_activity\";i:1707850603;}9f383935faff5a86bc1658bbde8c61e7","isDemo":1,"uid":72038016,"platform":3}]'

This is what the data should look like

Also you need "origin" header with website url, in my case: https://pocket-link19.co

            async with websockets.connect(
                "wss://api-eu.po.market/socket.io/?EIO=4&transport=websocket",
                extra_headers={
                    "Origin": "https://pocket-link19.co",
                },
            ) as websocket:

i am using "websockets" python library

so, to all you need:

1. Backslashes
2. Origin header

[vladdd183]

i made a little mistake with reconnection, now it works good.
Also you need only Backslashes and Origin Header

[theshadow76]

Thank you very much!

[theshadow76]

I'll adjust the code

[theshadow76]

@vladdd183
Hello!
Sorry to bother you again, but here:

import urllib
import websocket
from pocketoptionapi.constants import REGION
import threading
import logging
import ssl

class WebSocketClient:
    def __init__(self, url, pocket_api_instance=None):
        self.url = url
        self.pocket_api_instance = pocket_api_instance
        self.logger = logging.getLogger(__name__)
        self.logger.setLevel(logging.INFO)
        formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s')

        # Create file handler and add it to the logger
        file_handler = logging.FileHandler('pocket.log')
        file_handler.setFormatter(formatter)
        self.logger.addHandler(file_handler)
        self.header = "Origin: https://google.com"
        self.ws = websocket.WebSocketApp(self.url,
                                         on_open=self.on_open,
                                         on_message=self.on_message,
                                         on_error=self.on_error,
                                         on_close=self.on_close,
                                         header=[self.header])
        self.logger.info("Starting websocket client...")

    def on_message(self, ws, message):
        print(f"Message: {message}")
        self.logger.info(f"Recieved a message!: {message}")

        if str(message).startswith('0{"sid":'):
            ws.send("40")
        if str(message).startswith('40{"sid"'):
            data = r'42["auth",{"session":"a:4:{s:10:\"session_id\";s:32:\"da7a5a82c8f6c35a87b2ee31d4f5b3b4\";s:10:\"ip_address\";s:10:\"90.36.9.15\";s:10:\"user_agent\";s:120:\"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36 OP\";s:13:\"last_activity\";i:1707667599;}3a0058a58a6df5e7b49f652f8e4f8249","isDemo":0,"uid":27658142,"platform":1}]'
            print(f"Sent the auth messaage!: {data}")
            ws.send(data)
        

    def on_error(self, ws, error):
        print(error)
        self.logger.error(f"Got a error: {error}")

    def on_close(self, ws, close_status_code, close_msg):
        print("### closed ###")
        self.logger.warning(f"Connection closed, conections status_code: {close_status_code} and the message is: {close_msg}")

    def on_open(self, ws):
        print("Opened connection")
        self.logger.info("Opened!")

    def run(self):
        self.ws.run_forever()  # Use dispatcher for automatic reconnection

ws = WebSocketClient(url="wss://api-l.po.market/socket.io/?EIO=4&transport=websocket")
ws.run()

I am getting this output:

Opened connection
Message: 0{"sid":"s-DtcnSjnIgXZFuoNKB7","upgrades":[],"pingInterval":25000,"pingTimeout":20000,"maxPayload":1000000}
Message: 40{"sid":"aSAnWTMPfgSv-DKNNKCG"}
Sent the auth messaage!: 42["auth",{"session":"a:4:{s:10:\"session_id\";s:32:\"da7a5a82c8f6c35a87b2ee31d4f5b3b4\";s:10:\"ip_address\";s:10:\"90.36.9.15\";s:10:\"user_agent\";s:120:\"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36 OP\";s:13:\"last_activity\";i:1707667599;}3a0058a58a6df5e7b49f652f8e4f8249","isDemo":0,"uid":27658142,"platform":1}]
Message: 41
### closed ###

looks like I am still getting that issue even tho I've added the hedears, but can you check if the data variable is the way it should be?
Maybe it had to be formated in a diferent way.

Let me know what you think!

[theshadow76]

or if you would like to share your code, that would help alot to.
thx

[vladdd183]

self.header = "Origin: https://google.com"

you shoud to set origin with site you using, not google
try:
https://po.trade/ (official link) or https://pocket-link19.co (mirror link)
official is prefered, use mirror only if official link banned in your country

[theshadow76]

Okey, let me check and I'll let you know

[vladdd183]

I use "websockets" library and "anyio" for async, also "rich" for better print formating
pip3 install websockets anyio rich

this is the code (try to use second origin, that commented):

import websockets
import anyio
from rich.pretty import pprint as print
import json

SESSION = r'session_string'


async def websocket_client(url, pro):
    while True:
        try:
            async with websockets.connect(
                url,
                extra_headers={
                    "Origin": "https://pocket-link19.co",
                    # "Origin": "https://po.trade/"
                },
            ) as websocket:
                async for message in websocket:
                    await pro(message, websocket, url)
        except KeyboardInterrupt:
            exit()
        except Exception as e:
            print(e)
            print("Connection lost... reconnecting")
            await anyio.sleep(5)
    return True


async def pro(message, websocket, url):
    # if byte data
    if type(message) == type(b""):
        # cut 100 first symbols of byte date to prevent spam
        print(str(message)[:100])
        return
    else:
        print(message)

    # Code to make order
    # data = r'42["openOrder",{"asset":"#AXP_otc","amount":1,"action":"call","isDemo":1,"requestId":14680035,"optionType":100,"time":20}]'
    # await websocket.send(data)

    if message.startswith('0{"sid":"'):
        print(f"{url.split('/')[2]} got 0 sid send 40 ")
        await websocket.send("40")
    elif message == "2":
        # ping-pong thing
        print(f"{url.split('/')[2]} got 2 send 3")
        await websocket.send("3")

    if message.startswith('40{"sid":"'):
        print(f"{url.split('/')[2]} got 40 sid send session")
        await websocket.send(SESSION)


async def main():
    url = "wss://api-l.po.market/socket.io/?EIO=4&transport=websocket"
    await websocket_client(url, pro)


if __name__ == "__main__":
    anyio.run(main)

[theshadow76]

Thank you alot, I'll finish implementing it soon!
Thanks for your help!!!