From 29a5df0b1ab70c9b52f25a84673d9e7eb8d0a4dd Mon Sep 17 00:00:00 2001
From: algizn97 <algiz_n@mail.ru>
Date: Tue, 26 Aug 2025 19:11:07 +0500
Subject: [PATCH] Added tasks

---
 app/tasks/tasks.py | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)
 create mode 100644 app/tasks/tasks.py

diff --git a/app/tasks/tasks.py b/app/tasks/tasks.py
new file mode 100644
index 0000000..13becce
--- /dev/null
+++ b/app/tasks/tasks.py
@@ -0,0 +1,24 @@
+import asyncio
+
+from app.services.Bybit.functions.Futures import close_trade_after_delay, trading_cycle
+
+active_start_tasks = {}
+active_close_tasks = {}
+
+def start_trading_cycle(tg_id, message):
+    task = asyncio.create_task(trading_cycle(tg_id, message))
+    active_start_tasks[tg_id] = task
+
+def stop_trading_cycle(tg_id):
+    task = active_start_tasks.pop(tg_id, None)
+    if task:
+        task.cancel()
+
+def start_close_trade_task(tg_id, message, symbol, delay_sec):
+    task = asyncio.create_task(close_trade_after_delay(tg_id, message, symbol, delay_sec))
+    active_close_tasks[tg_id] = task
+
+def stop_close_trade_task(tg_id):
+    task = active_close_tasks.pop(tg_id, None)
+    if task:
+        task.cancel()