dsesed

Author: theshadow76

pocketoptionapi/__pycache__/stable_api.cpython-310.pyc

@@ -17,6 +17,7 @@
 # from pocketoptionapi.expiration import get_expiration_time, get_remaning_time
 import pandas as pd
 from pocketoptionapi.ws.chanels.get_balances import *
+from pocketoptionapi.ws.client import WebsocketClient
 
 # Obtener la zona horaria local del sistema como una cadena en el formato IANA
 local_zone_name = get_localzone()
@@ -103,6 +104,8 @@ def connect(self):
             return False
         return True
 
+    async def reconect(self):
+        await WebsocketClient(self).reconnect()
     @staticmethod
     def check_connect():
         # True/False

pocketoptionapi/stable_api.py

@@ -6,7 +6,7 @@
 import json
 import logging
 import ssl
-
+import time
 # Suponiendo la existencia de estos módulos basados en tu código original
 import pocketoptionapi.constants as OP_code
 import pocketoptionapi.global_value as global_value
@@ -63,8 +63,7 @@ async def reconnect(self):
         regs = self.region.get_regions()
         for i in regs:
             print(f"Reconnecting to {i}...")
-            async with websockets.connect(i, extra_headers={"Origin": "https://m.pocketoption.com"}) as ws:
-
+            async with websockets.connect(i, extra_headers={"Origin": "https://m.pocketoption.com "}) as ws:
                 print("Conectado a: ", i)
                 self.websocket = ws
                 self.url = i
@@ -140,6 +139,7 @@ async def on_message(self, message):  # pylint: disable=unused-argument
         # global_value.ssl_Mutual_exclusion = True
         logger = logging.getLogger(__name__)
         logger.debug(message)
+        print(message)
 
         # message = json.loads(str(message))
 
@@ -203,7 +203,8 @@ async def on_message(self, message):  # pylint: disable=unused-argument
             await self.websocket.send("3")
 
         elif message.startswith('40{"sid":"'):
-            # print(f"{self.url.split('/')[2]} got 40 sid send session")
+            print(f"{self.url.split('/')[2]} got 40 sid send session")
+            print(f"send: {self.ssid}")
             await self.websocket.send(self.ssid)
 
         elif message.startswith('451-['):
@@ -245,7 +246,7 @@ async def on_error(self, error):  # pylint: disable=unused-argument
         logger = logging.getLogger(__name__)
         logger.error(error)
         try:
-            self.reconnect()
+            await self.reconnect()
         except:
             global_value.websocket_error_reason = str(error)
             global_value.check_websocket_if_error = True
@@ -255,6 +256,6 @@ async def on_close(self, error):  # pylint: disable=unused-argument
         logger = logging.getLogger(__name__)
         logger.debug("Websocket connection closed.")
         try:
-            self.reconnect()
+            await self.reconnect()
         except:
             global_value.websocket_is_connected = False

pocketoptionapi/ws/__pycache__/client.cpython-310.pyc

@@ -1,17 +1,32 @@
 import random
 import time
 import dotenv
+import asyncio
 from pocketoptionapi.stable_api import PocketOption
 import os
 dotenv.load_dotenv()
-ssid = os.getenv("SSID")
-api = PocketOption(ssid)
-print(ssid)
+SSID=(r'42["auth",{"session":"a:4:{s:10:"session_id";s:32:"a1dc009a7f1f0c8267d940d0a036156f";s:10:"ip_address";s:12:"190.162.4.33";s:10:"user_agent";s:120:"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36 OP";s:13:"last_activity";i:1709914958;}793884e7bccc89ec798c06ef1279fcf2","isDemo":1,"uid":27658142,"platform":1}]')
+api = PocketOption(SSID)
+print(SSID)
 
 def direction():
     # Selecciona aleatoriamente entre 'call' y 'put'
     return random.choice(['call', 'put'])
 
-if __name__ == "__main__":
+def main():
     api.connect()
-    time.sleep(2)
+
+    max_retries = 5
+    for _ in range(max_retries):
+        time.sleep(5)
+        try:
+            asyncio.run(api.reconect())
+        except:
+            pass
+        if api.check_connect(): 
+           break  # Exit loop if connected
+    else:
+        print("Failed to connect after max retries")
+
+if __name__ == '__main__':
+    main()