Update app.py

app.py

@@ -9,15 +9,15 @@ from quotexpy.utils.candles_period import CandlesPeriod
 from quotexpy.utils.account_type import AccountType
 
 state = []
-
-# Initialize once, so you can see connection errors immediately
+# Fill in your demo (or real) credentials here; without these you’ll often get no data.
 client = Quotex(email="", password="", headless=True)
 
 def background_worker(pair: str, timeframe: str):
     try:
-        client.connect()
-        client.change_account(AccountType.PRACTICE)
-        print(f"[Worker] Connected to QUOTEX as PRACTICE user")
+        ok = client.connect()
+        print(f"[Debug] connect() returned: {ok}", flush=True)
+        ok = client.change_account(AccountType.PRACTICE)
+        print(f"[Debug] change_account() returned: {ok}", flush=True)
 
         period_map = {
             "5s":  CandlesPeriod.SEC_5,
@@ -26,42 +26,45 @@ def background_worker(pair: str, timeframe: str):
             "5m":  CandlesPeriod.FIVE_MINUTES,
         }
         period = period_map.get(timeframe)
-        if period is None:
-            raise ValueError(f"Unsupported timeframe: {timeframe}")
+        print(f"[Debug] using period enum: {period}", flush=True)
+
+        # Ask for 10 candles in the buffer
+        list_size = 10
+        client.start_candles_stream(pair, list_size, period)
+        print(f"[Debug] started stream: pair={pair}, size={list_size}", flush=True)
 
-        print(f"[Worker] Subscribing to {pair} @ {timeframe}")
-        client.start_candles_stream(pair, 1, period)
+        # give it a moment to fill up
+        time.sleep(2)
 
         while True:
             candles = client.get_realtime_candles(pair)
-            # DEBUG: print the raw payload
-            print(f"[Worker] raw candles payload: {candles!r}")
+            print(f"[Debug] raw candles payload: {candles}", flush=True)
 
             if candles:
-                # Assuming candles is a dict of timestamp→data
-                # Take the latest candle
+                # pick the newest timestamp key
                 latest_ts = max(candles.keys())
                 c = candles[latest_ts]
                 symbol = "↑" if c["close"] > c["open"] else "↓"
-                ts = datetime.utcfromtimestamp(latest_ts/1000)\
-                     .replace(tzinfo=pytz.UTC)\
-                     .astimezone(pytz.timezone("Asia/Karachi"))\
-                     .strftime("%H:%M:%S")
+                ts = (
+                    datetime.utcfromtimestamp(latest_ts / 1000)
+                    .replace(tzinfo=pytz.UTC)
+                    .astimezone(pytz.timezone("Asia/Karachi"))
+                    .strftime("%H:%M:%S")
+                )
                 entry = f"{ts} {symbol}"
                 state.append(entry)
                 if len(state) > 100:
                     state.pop(0)
-                print(f"[Worker] appended: {entry}")
+                print(f"[Debug] appended: {entry}", flush=True)
             else:
-                print("[Worker] no candles received yet")
+                print("[Debug] no candles received yet", flush=True)
+
+            time.sleep(1)
 
-            time.sleep(1)  # throttle loop to 1 s
     except Exception as e:
-        # Any exception will show up in your Space logs
-        print(f"[Worker] ERROR: {e}", flush=True)
+        print(f"[Error] {e}", flush=True)
 
 def start(pair, timeframe):
-    # clear previous state so you know fresh data is coming
     state.clear()
     threading.Thread(
         target=background_worker,