We are back

[theshadow76]

Hello! We are back!
We will start again developing this API!

[theshadow76]

Check this link
To learn more about the implementation.

[VampyreBatz]

is this able to get the realtime otc data? thats all i need right now. if i can get that i will be smooth for awhile

[vladdd183]

try it

import anyio
import websockets
import asyncio
import random
import time
from asyncio import Queue
import json
import os
from rich.pretty import pprint as print


async def main():
    cl = Client(r'42["auth",{"token":"TyMaALqKLC","balance":50000}]')
    cl.start()
    await anyio.sleep(4)
    # uncomment it to get stream
    #await cl.ws.send('42["changeSymbol",{"asset":"YERUSD_otc","period":1000}]')

   # uncomment it to get data in current time
   #await cl.ws.send(
        '42["loadHistoryPeriod",{"asset":"EURJPY","index":123,"time":1712170375,"offset":100,"period":0}]'
    )
    try:
        while True:
            await anyio.sleep(2)
    except:
        exit()


class Client:
    def __init__(self, session_string):
        self.ws = None
        self.queue = Queue()
        self.session = session_string
        self.running = False
        self.tasks = []
        self.retries = 0

    async def stop(self, reason):
        print("stopped")
        self.running = False
        for task in self.tasks:
            task.cancel()
        await asyncio.gather(*self.tasks, return_exceptions=True)
        self.tasks.clear()
        await self.ws.close()

    def start(self):
        self.running = True
        # Нужно для работе в фоне. Так же нужно сделать метод остановки бота
        self.tasks.extend(
            [
                asyncio.create_task(self.messages_to_queue()),
                asyncio.create_task(self.handle_session()),
            ]
        )

    async def messages_to_queue(self):
        while self.running and self.retries < 5:
            self.retries += 1
            self.ws = await websockets.connect(
                "wss://try-demo-eu.po.market/socket.io/?EIO=4&transport=websocket",
                # os.environ["WS"],
                extra_headers={
                    "Origin": "https://pocket-link27.co",
                },
            )
            try:
                async for message in self.ws:
                    if type(message) != type(b""):
                        print(str(message))
                    await self.queue.put(message)
            except Exception as e:
                print(e)
        asyncio.create_task(self.stop("Невозможно подключиться к серверу"))

    async def handle_session(self):
        next_stream = False
        history = False
        while self.running and (self.retries < 5):
            try:
                message = await self.queue.get()
                if next_stream or history:
                    print(json.loads(message.decode()))
                    next_stream = False
                    history = False
                    continue
                if '451-["loadHistoryPerio' in str(message):
                    history = True
                    continue

                if '451-["updateStream' in str(message):
                    next_stream = True
                    continue

                if "error" in str(message):
                    print(str(message))
                    continue
                message = str(message)
                if "successauth" in message:
                    self.retries = 0
                if "NotAuthorized" in message:
                    self.retries += 1
                    continue
                if message.startswith('0{"sid":"'):
                    print("send 40")
                    await self.ws.send("40")
                elif message == "2":
                    print("send 3")
                    await self.ws.send("3")
                if message.startswith('40{"sid":"'):
                    print("send session")
                    await self.ws.send(self.session)
            except Exception as e:
                print("error handle")
                print(e)
                self.retries += 1
        asyncio.create_task(self.stop("Не верная строка авторизации"))


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