(feat) create candles downloader page

pages/6_🗂_Candles_Downloader.py

@@ -0,0 +1,75 @@
+import time
+from subprocess import CalledProcessError
+
+import streamlit as st
+
+import constants
+from utils import os_utils
+from utils.docker_manager import DockerManager
+
+st.set_page_config(
+    page_title="Candles Downloader",
+    page_icon=":bar_chart:",
+    layout="wide",
+)
+docker_manager = DockerManager()
+st.write(f"# 🗂️ Candles Downloader")
+st.write("---")
+
+c1, c2, c3 = st.columns([2, 2, 0.5])
+with c1:
+    exchange = st.selectbox("Exchange", ["binance_perpetual", "binance"], index=0)
+    # TODO: Add more trading pairs querying the exchange API
+    trading_pairs = st.text_input("Trading Pairs (separated with commas)", value="BTC-USDT,ETH-USDT")
+with c2:
+    intervals = st.multiselect("Intervals", options=["1m", "3m", "5m", "15m", "1h", "4h", "1d"], default=["1m", "3m", "1h"])
+    days_to_download = st.number_input("Days to Download", value=30, min_value=1, max_value=365, step=1)
+with c3:
+    get_data_button = st.button("Download Candles!")
+    clean_container_folder_button = st.button("Clean Candles Folder")
+
+
+if clean_container_folder_button:
+    st.warning("Cleaning Candles Data folder...", icon="⚠️")
+    st.write("---")
+    os_utils.remove_files_from_directory(constants.CANDLES_DATA_PATH)
+    st.write("### Container folder cleaned.")
+    st.write("---")
+
+if get_data_button:
+    candles_container_config = {
+        "EXCHANGE": exchange,
+        "TRADING_PAIRS": trading_pairs,
+        "INTERVALS": ",".join(intervals),
+        "DAYS_TO_DOWNLOAD": days_to_download,
+    }
+    time.sleep(0.5)
+    docker_manager.create_download_candles_container(candles_container_config)
+    st.write("---")
+
+st.write("---")
+st.write("## ⚙️Containers Management")
+try:
+
+    c1, c2 = st.columns([0.85, 0.15])
+    with c1:
+        st.write("Active Containers:")
+        st.info(docker_manager.get_active_containers())
+
+        st.write("Exited Containers:")
+        st.warning(docker_manager.get_exited_containers())
+    with c2:
+        stop_containers_button = st.button("Stop Containers")
+        if stop_containers_button:
+            docker_manager.stop_active_containers()
+
+        clean_exited_containers_button = st.button("Clean Containers")
+        if clean_exited_containers_button:
+            docker_manager.clean_exited_containers()
+
+        refresh_button = st.button("Refresh")
+        if refresh_button:
+            pass
+except CalledProcessError as error:
+    st.write("### Docker is not running. Please start docker in your machine.")
+