dhwahdwa

Author: theshadow76

client_test.py

@@ -14,8 +14,8 @@ async def websocket_client(url, pro):
             async with websockets.connect(
                 url,
                 extra_headers={
-                    "Origin": "https://pocket-link19.co",
-                    # "Origin": "https://po.trade/"
+                    #"Origin": "https://pocket-link19.co",
+                    "Origin": "https://po.trade/"
                 },
             ) as websocket:
                 async for message in websocket:

pocketoptionapi/__pycache__/__init__.cpython-310.pyc

@@ -0,0 +1,62 @@
+import websockets
+import anyio
+from rich.pretty import pprint as print
+import json
+
+SESSION = 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}]'
+
+
+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)