update

.depricated-readthedocs.yaml

@@ -0,0 +1,18 @@
+version: 2
+
+# List of output formats (optional)
+formats:
+  - pdf
+  - epub
+  - htmlzip
+
+# Python settings
+python:
+  version: "3.10"  # Specify Python version as a string
+  install:
+    - method: pip
+      path: .
+
+# Enable Sphinx build - test1
+sphinx:
+  configuration: docs/source/conf.py

.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,38 @@
+---
+name: Bug report
+about: Create a report to help us improve
+title: ''
+labels: ''
+assignees: ''
+
+---
+
+**Describe the bug**
+A clear and concise description of what the bug is.
+
+**To Reproduce**
+Steps to reproduce the behavior:
+1. Go to '...'
+2. Click on '....'
+3. Scroll down to '....'
+4. See error
+
+**Expected behavior**
+A clear and concise description of what you expected to happen.
+
+**Screenshots**
+If applicable, add screenshots to help explain your problem.
+
+**Desktop (please complete the following information):**
+ - OS: [e.g. iOS]
+ - Browser [e.g. chrome, safari]
+ - Version [e.g. 22]
+
+**Smartphone (please complete the following information):**
+ - Device: [e.g. iPhone6]
+ - OS: [e.g. iOS8.1]
+ - Browser [e.g. stock browser, safari]
+ - Version [e.g. 22]
+
+**Additional context**
+Add any other context about the problem here.

.github/ISSUE_TEMPLATE/feature_request.md

@@ -0,0 +1,20 @@
+---
+name: Feature request
+about: Suggest an idea for this project
+title: ''
+labels: ''
+assignees: ''
+
+---
+
+**Is your feature request related to a problem? Please describe.**
+A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]
+
+**Describe the solution you'd like**
+A clear and concise description of what you want to happen.
+
+**Describe alternatives you've considered**
+A clear and concise description of any alternative solutions or features you've considered.
+
+**Additional context**
+Add any other context or screenshots about the feature request here.

.github/worflows/workflow.yml

@@ -0,0 +1 @@
+

.gitignore

@@ -4,4 +4,8 @@ docker-compose.yml
 efs.py
 fesfs.py
 wupwup.py
-data
+data
+.venv
+C:\Users\Vigo\BinaryOptionsTools-2\BinaryOptionstools.egg-info
+dist
+BinaryOptionstools.egg-info

.gitpod.yml

@@ -0,0 +1,10 @@
+# This configuration file was automatically generated by Gitpod.
+# Please adjust to your needs (see https://www.gitpod.io/docs/introduction/learn-gitpod/gitpod-yaml)
+# and commit this file to your remote git repository to share the goodness with others.
+
+# Learn more from ready-to-use templates: https://www.gitpod.io/docs/introduction/getting-started/quickstart
+
+tasks:
+  - init: make
+
+

.readthedocs.yml

@@ -0,0 +1,13 @@
+version: "2"
+
+build:
+  os: "ubuntu-22.04"
+  tools:
+    python: "3.10"
+
+python:
+  install:
+    - requirements: docs/requirements.txt
+
+sphinx:
+  configuration: docs/source/conf.py

BinaryOptionsTools/__init__.py

@@ -1,4 +1,4 @@
-# Made by © Vigo Walker
+# Made by © Vigo Walker and © Alenxendre Portner at Chipa
 
 # Pocket Option
 from BinaryOptionsTools.platforms.pocketoption.stable_api import PocketOption
@@ -9,6 +9,8 @@ def __init__(self, ssid: str, demo: bool = True) -> None:
         self.ssid = ssid
         self.api = PocketOption(ssid, demo)
         self.api.connect()
+        print("Connecting...")
+        time.sleep(10)
     def GetBalance(self) -> int | float:
         data = self.api.get_balance()
         return data
@@ -19,27 +21,52 @@ def Reconnect(self, retries: int = 1) -> bool:
             time.sleep(5)
         if self.api.check_connect():
             return True
-        elif self.api.check_connect() == False:
+        elif self.api.check_connect() is False:
             return False
         return None
     def Call(self, amount: int = 1, active: str = "EURUSD_otc", expiration: int = 60, add_check_win: bool = False):
         if add_check_win:
-            ido = self.api.buy(amount, active, "Call", expiration)
+            ido = self.api.buy(amount, active, "call", expiration)[1]
+            print(ido)
             data = self.api.check_win(ido)
             return data
-        elif add_check_win == False:
-            ido = self.api.buy(amount, active, "Call", expiration)
+        elif add_check_win is False:
+            ido = self.api.buy(amount, active, "call", expiration)
             return ido
         return None
     def Put(self, amount: int = 1, active: str = "EURUSD_otc", expiration: int = 60, add_check_win: bool = False):
         if add_check_win:
-            ido = self.api.buy(amount, active, "Put", expiration)
+            ido = self.api.buy(amount, active, "put", expiration)
             data = self.api.check_win(ido)
             return data
-        elif add_check_win == False:
-            ido = self.api.buy(amount, active, "Put", expiration)
+        elif add_check_win is False:
+            ido = self.api.buy(amount, active, "put", expiration)
             return ido
         return None
     def GetCandles(self, active, period, start_time=None, count=6000, count_request=1):
         data = self.api.get_candles(active, period, start_time, count, count_request)
-        return data
+        return data
+
+    def GetCandlesMultipleAssets(self, assets, period=60, start_time=None, count=6000, count_request=1, max_workers=None):
+        """
+        Fetch candles for multiple assets in parallel using multiprocessing.
+
+        Args:
+            assets: List of asset symbols (e.g., ["EURUSD_otc", "GBPUSD_otc", "USDJPY_otc"])
+            period: The time interval of each candle in seconds (default: 60)
+            start_time: The end time for the last candle (default: None for current time)
+            count: Number of seconds to fetch per request (default: 6000)
+            count_request: Number of requests for historical data (default: 1)
+            max_workers: Maximum number of parallel workers (default: None)
+
+        Returns:
+            Dictionary with asset symbols as keys and their candle data as values
+        """
+        return self.api.get_candles_multiple_assets(assets, period, start_time, count, count_request, max_workers)
+
+    def CheckWin(self, id):
+        data = self.api.check_win(id)
+        return data
+
+    def GetPayout(self, pair):
+        return self.api.GetPayout(pair)

BinaryOptionsTools/bot/base.py

@@ -0,0 +1,11 @@
+import pandas as pd
+
+class BaseBot:
+    def __init__(self):
+        pass
+
+    def get_data(self, timestamp: int) -> pd.DataFrame:
+        pass
+
+    def predict_trade(self, data: pd.DataFrame) -> String:
+        pass

BinaryOptionsTools/bot/signals/__init__.py

@@ -0,0 +1,21 @@
+from BinaryOptionsTools.indicators.trend import sma
+
+class StreamSignals:
+    def __init__(self) -> None:
+        pass
+    def sma(self, period):
+        pass
+
+class signals:
+    def __init__(self) -> None:
+        pass
+    def sma_cross_over(self, api, FAST_SMA_PERIOD: int = 9, SLOW_SMA_PERIOD: int = 14, timeframe: int = 60, ticker: str = "EURUSD_otc"):
+        fast_sma = sma(api, timeframe, ticker, FAST_SMA_PERIOD)
+        slow_sma = sma(api, timeframe, ticker, SLOW_SMA_PERIOD)
+
+        if fast_sma["latest"] > slow_sma["latest"]:
+            return "Bullish"
+        elif fast_sma["latest"] < slow_sma["latest"]:
+            return "Bearish"
+        else:
+            return "No trend"

BinaryOptionsTools/indicators/momentum.py

@@ -0,0 +1,33 @@
+from ta.momentum import RSIIndicator
+import pandas as pd
+import time
+
+def _fetch_candles(api, active, period, num_candles):
+    try:
+        candles_df = api.GetCandles(active, period)
+        candles_df['volume'] = 0
+
+        if len(candles_df) > num_candles:
+            candles_df = candles_df.iloc[-num_candles:]
+
+        required_columns = ['time', 'open', 'high', 'low', 'close']
+        if not all(col in candles_df.columns for col in required_columns):
+            raise ValueError("Missing required columns in candle data.")
+
+        candles_df.ffill(inplace=True)
+        candles_df['time'] = pd.to_datetime(candles_df['time'], unit='s')
+
+        return candles_df
+
+    except Exception as e:
+        print(f"Error fetching candles: {e}")
+        time.sleep(5)
+        return pd.DataFrame()
+
+def rsi(api, timeframe: int = 60, ticker: str = "EURUSD_otc", rsi_period: int = 14):
+    close = _fetch_candles(api=api, active=ticker, period=timeframe, num_candles=420)
+    rsi_data = RSIIndicator(close=close["close"], window=rsi_period, fillna=True).rsi()
+    return {
+        "rsi_values" : rsi_data,
+        "latest" : rsi_data.iloc[-1]
+    }