From 79ab30782c7bcaff999e72c44e8931a6420c1ae0 Mon Sep 17 00:00:00 2001
From: mindesbunister <github_service@egonetix.de>
Date: Tue, 2 Dec 2025 12:43:35 +0100
Subject: [PATCH] fix: MarketData storage now working in execute endpoint

- Added debug logging to trace execution
- Confirmed 1-minute signals being stored continuously
- Database accumulating rows every 1-3 minutes
- All indicators (ATR, ADX, RSI, volume, price position) storing correctly
- 1-year retention active (365 days)
- Foundation ready for 8-hour blocked signal tracking
---
 app/api/trading/execute/route.ts |  32 +++++++++++++++++++++++++++++++
 cluster/exploration.db           | Bin 204800 -> 204800 bytes
 2 files changed, 32 insertions(+)

diff --git a/app/api/trading/execute/route.ts b/app/api/trading/execute/route.ts
index 7cf1cd0..e219513 100644
--- a/app/api/trading/execute/route.ts
+++ b/app/api/trading/execute/route.ts
@@ -32,6 +32,7 @@ export interface ExecuteTradeRequest {
   volumeRatio?: number
   pricePosition?: number
   maGap?: number // V9: MA gap convergence metric
+  volume?: number // Raw volume value for time-series tracking
   indicatorVersion?: string // Pine Script version (v5, v6, etc.)
 }
 
@@ -176,6 +177,37 @@ export async function POST(request: NextRequest): Promise<NextResponse<ExecuteTr
         console.error(`❌ Failed to save ${timeframe}min signal:`, dbError)
       }
       
+      // CRITICAL (Dec 2, 2025): For 1-minute signals, ALSO store in MarketData table
+      // This enables historical time-series analysis with full indicator data
+      console.log(`🔍 DEBUG: timeframe value = "${timeframe}", type = ${typeof timeframe}, checking if === '1'`)
+      if (timeframe === '1') {
+        console.log(`✅ Conditional matched! Storing to MarketData...`)
+        try {
+          const { getPrismaClient } = await import('@/lib/database/trades')
+          const prisma = getPrismaClient()
+          
+          await prisma.marketData.create({
+            data: {
+              symbol: driftSymbol,
+              timeframe: '1',
+              price: currentPrice,
+              atr: Number(body.atr) || 0,
+              adx: Number(body.adx) || 0,
+              rsi: Number(body.rsi) || 50,
+              volumeRatio: Number(body.volumeRatio) || 1.0,
+              pricePosition: Number(body.pricePosition) || 50,
+              maGap: Number(body.maGap) || undefined,
+              volume: Number(body.volume) || undefined,
+              timestamp: new Date()
+            }
+          })
+          
+          console.log(`💾 Stored 1-minute data in database for ${driftSymbol} (from execute endpoint)`)
+        } catch (marketDataError) {
+          console.error('❌ Failed to store 1-minute market data:', marketDataError)
+        }
+      }
+      
       return NextResponse.json({
         success: false,
         error: 'Data collection only',
diff --git a/cluster/exploration.db b/cluster/exploration.db
index 40ce9941ffb3f3fd3aa92e423830a7278f0c4a31..6dcf0a59f2ea32bc0514455a9f8136e1763bf250 100644
GIT binary patch
delta 215
zcmZoTz|(MmXM!~2nTayajAu3`EZQ$6#^A;{gNZ4ENsNCVe+|DC-yX&pd{vCM_-rN{
zJn-I}e!!5C$$@?Hf%Ec{<<GNDesW%j=fJN_y>mvHx(~isaZWlfFKfa4g84;JX<lAt
zUV3?cQFdyPQKsJ6uOI~uOdy?`%@5t@X5stCpf+)$5|b4dP!pr&WQFr0To7Xz7#ui2
y>KM%@-#aJ9bI=^Foega9-E)d83=9l56DL|QIk19+nxoIRN1tch9(|r^X#fEDs#Vkg

delta 226
zcmZoTz|(MmXM!~2iHS1Kj3+iGEZQ$t!QjRu#=sQ8B*wpwzlPt6Zx7!;zJ|#<5BxW$
zA24K`xWI{tZ{?)(){IP(51g0ZY<}oIH<Lcs<cWvngbgg2UogKYNX<*h%uCPIeegw}
z6C^HeV1Xviz`(!(#0*v(lkLvQ%bJ6vi%RqIfZEFQi?UOTj575OnuAPmU<27Q`R+MI
kCM$NZVlxcIhM9T?et{LUf)qDLpKp&o&$vDMJk!zu049o9NdN!<