fix(strategy): corrections schema DB, pool import, route signal dans gateway

diff --git a/Wallette/gateway/gateway.js b/Wallette/gateway/gateway.js
index 9cfa0a80f7466007396cd620921561ec60e52a42..3e3abd709f7bcc38a6668d9690c2575cb55f1e05 100644 (file)
--- a/Wallette/gateway/gateway.js
+++ b/Wallette/gateway/gateway.js
@@ -55,6 +55,7 @@ const ROUTES = [
   { prefix: '/api/price',    upstream: SERVICE_BASE_URLS.price,    name: 'price-service'    },
   { prefix: '/api/pairs',    upstream: SERVICE_BASE_URLS.price,    name: 'price-service'    },
   { prefix: '/api/strategy', upstream: SERVICE_BASE_URLS.strategy, name: 'strategy-service' },
+  { prefix: '/api/signal',   upstream: SERVICE_BASE_URLS.strategy, name: 'strategy-service' },
 ].sort((a, b) => b.prefix.length - a.prefix.length);
 
 const PROXY_TIMEOUT_MS = 5000;

diff --git a/Wallette/git b/Wallette/git
new file mode 100644 (file)
index 0000000..e69de29

diff --git a/Wallette/server/modules/strategy/repositories/MarketDataRepo.js b/Wallette/server/modules/strategy/repositories/MarketDataRepo.js
index 1012ec850317542eecab4d47efc9d5de55e8ba36..c88750881bc80920c03d24909af3a0d38d8e78a1 100644 (file)
--- a/Wallette/server/modules/strategy/repositories/MarketDataRepo.js
+++ b/Wallette/server/modules/strategy/repositories/MarketDataRepo.js
@@ -11,7 +11,7 @@ class MarketDataRepo {
      */
     async getLastCandles(pairId, limit = 100) {
         const sql = `
-            SELECT 
+           SELECT
                 timestamp_ms,
                 open_price,
                 high_price,
@@ -39,4 +39,4 @@ class MarketDataRepo {
 }
 
 const marketDataRepo = new MarketDataRepo();
-export default marketDataRepo;
\ No newline at end of file
+export default marketDataRepo;

diff --git a/Wallette/server/modules/strategy/repositories/StrategyRepo.js b/Wallette/server/modules/strategy/repositories/StrategyRepo.js
index 3432d54036dafc74fac21f854c6b4e3b7fed164f..1e87aad529ec451910143937b644c1c89d7f868f 100644 (file)
--- a/Wallette/server/modules/strategy/repositories/StrategyRepo.js
+++ b/Wallette/server/modules/strategy/repositories/StrategyRepo.js
@@ -41,7 +41,7 @@ class StrategyRepo {
 
         // On vérifie si l'utilisateur a déjà une configuration pour cette paire
         const checkSql = `SELECT user_strategy_id FROM user_strategies WHERE user_id = ? AND pair_id = ?`;
-        const [rows] = await db.query(checkSql, [userId, pairId]); // ⚠️ Remplace 'db' par le nom de ta variable de connexion (souvent 'pool' ou 'db')
+        const [rows] = await pool.query(checkSql, [userId, pairId]); // ⚠️ Remplace 'db' par le nom de ta variable de connexion (souvent 'pool' ou 'db')
 
         if (rows.length > 0) {
             // MISE À JOUR : La stratégie existe, on l'écrase avec le nouveau mode
@@ -50,7 +50,7 @@ class StrategyRepo {
                 SET mode = ?, params = ?, strategy_key = ?, is_active = 1, updated_at_ms = ?
                 WHERE user_id = ? AND pair_id = ?
             `;
-            await db.query(updateSql, [mode, params, strategyKey, now, userId, pairId]);
+            await pool.query(updateSql, [mode, params, strategyKey, now, userId, pairId]);
             return { action: 'updated', user_id: userId, pair_id: pairId, mode };
         } else {
             // CRÉATION : C'est la première fois qu'il configure cette paire
@@ -59,7 +59,7 @@ class StrategyRepo {
                 (user_strategy_id, user_id, pair_id, strategy_key, mode, params, is_active, created_at_ms, updated_at_ms)
                 VALUES (UUID(), ?, ?, ?, ?, ?, 1, ?, ?)
             `;
-            await db.query(insertSql, [userId, pairId, strategyKey, mode, params, now, now]);
+            await pool.query(insertSql, [userId, pairId, strategyKey, mode, params, now, now]);
             return { action: 'created', user_id: userId, pair_id: pairId, mode };
         }
     }