Update app.py

app.py

@@ -501,6 +501,11 @@ HTML_TEMPLATE = """
         .sec-pill { padding: 2px 5px; font-size: 10px; cursor: pointer; border-radius: 2px; color: #666; font-family:'JetBrains Mono'; }
         .sec-pill:hover { background: #ddd; color: #000; }
         .sec-pill.active { background: var(--accent); color: white; font-weight: bold; }
+        
+        /* CORRUPTED DATA INDICATOR */
+        .sec-pill.bad { background: #ff5252; color: white; opacity: 0.9; }
+        .sec-pill.bad:hover { background: #d50000; }
+        .sec-pill.bad.active { background: #b71c1c; border: 1px solid #fff; }
 
         .grid-layout { display: flex; height: calc(100vh - 60px); }
         
@@ -932,15 +937,93 @@ HTML_TEMPLATE = """
         document.getElementById('loader').style.display = 'none';
     }
 
+    // --- VALIDATION LOGIC FOR HISTORICAL DATA ---
+    function validateSnapshot(data) {
+        // 1. Identify Reference Price (Spot or Future)
+        let refPrice = 0;
+        let hasOptions = false;
+        
+        // Loop to find Reference and check if data exists
+        for(let sym in data) {
+            // Check for Spot or Index (Priority)
+            if(sym.includes('INDEX') || sym.endsWith('-EQ') || sym.startsWith('BSE:SENSEX')) {
+                if(data[sym].ltp > 0) refPrice = data[sym].ltp;
+            }
+            // Fallback to Future if Spot not found or is 0
+            else if(sym.endsWith('FUT') && refPrice === 0) {
+                if(data[sym].ltp > 0) refPrice = data[sym].ltp;
+            }
+            // Check if options exist in this packet
+            if(sym.endsWith('CE') || sym.endsWith('PE')) hasOptions = true;
+        }
+
+        // CRITERIA 1: Missing Reference Price (Corrupted)
+        if(refPrice === 0) return false;
+
+        // CRITERIA 2: Validate ATM ± Range Data (Zero Qty Check)
+        if(hasOptions) {
+            // Extract valid strikes from symbol keys
+            let strikes = [];
+            for(let sym in data) {
+                // Regex matches Fyers symbols ending in Number+CE/PE (e.g., ...22100CE)
+                let match = sym.match(/(\d+)(CE|PE)$/); 
+                if(match && match[1]) {
+                    strikes.push({
+                        k: parseFloat(match[1]),
+                        d: data[sym]
+                    });
+                }
+            }
+
+            if(strikes.length > 0) {
+                // Find ATM Strike based on Ref Price
+                strikes.sort((a,b) => a.k - b.k);
+                let closest = strikes.reduce((prev, curr) => 
+                    Math.abs(curr.k - refPrice) < Math.abs(prev.k - refPrice) ? curr : prev
+                );
+                
+                // Get unique strikes to determine index range
+                let uniqKs = [...new Set(strikes.map(i => i.k))].sort((a,b)=>a-b);
+                let atmIndex = uniqKs.indexOf(closest.k);
+                
+                // Define Range: ATM ± 5 strikes
+                let start = Math.max(0, atmIndex - 5);
+                let end = Math.min(uniqKs.length - 1, atmIndex + 5);
+                let targetKs = uniqKs.slice(start, end + 1);
+
+                // Check specific options in this range
+                for(let item of strikes) {
+                    if(targetKs.includes(item.k)) {
+                        let qB = item.d.totalbuyqty;
+                        let qS = item.d.totalsellqty;
+                        
+                        // THE CHECK: If both Buy AND Sell Qty are 0 or undefined -> Data is inefficient
+                        if((!qB && !qS) || (qB === 0 && qS === 0)) {
+                            return false; // Mark as Bad
+                        }
+                    }
+                }
+            }
+        }
+        
+        return true; // Data passed checks
+    }
+
     function renderSecondBar() {
         const bar = document.getElementById('secBar');
-        bar.innerHTML = CACHED_TIMELINE.map((item, idx) => `
-            <div class="sec-pill ${idx===0?'active':''}" 
+        bar.innerHTML = CACHED_TIMELINE.map((item, idx) => {
+            // Run validation on the data packet ('d')
+            const isValid = validateSnapshot(item.d);
+            const statusClass = isValid ? '' : 'bad';
+            
+            return `
+            <div class="sec-pill ${idx===0?'active':''} ${statusClass}" 
                  onclick="selectSnapshot(${idx})" 
-                 id="pill-${idx}">
+                 id="pill-${idx}"
+                 title="${isValid ? 'Data OK' : 'Data Inefficient (Zero Qty or Missing Ref)'}">
                  :${item.s}
             </div>
-        `).join('');
+        `}).join('');
     }
 
     function selectSnapshot(idx) {