import fs from "fs"; import zlib from "zlib";
const env=Object.fromEntries(fs.readFileSync(process.env.UW_KEY_FILE,"utf8").split("\n").filter(l=>/^[A-Z_]+=/.test(l)).map(l=>{const i=l.indexOf("=");return [l.slice(0,i),l.slice(i+1).replace(/^"|"$/g,"")]}));
const key=env.UW_API_KEY||env.UNUSUAL_WHALES_API_KEY||env.UW_TOKEN; const H={Authorization:`Bearer ${key}`,Accept:"application/json"}; const B="https://api.unusualwhales.com";
const OUT="<data-root>/fp-data/gex/history"; const files=fs.readdirSync(OUT).filter(f=>f.endsWith(".json.gz")); let n=0,i=0;
async function w(){ while(i<files.length){ const fn=files[i++]; const p=`${OUT}/${fn}`; const rec=JSON.parse(zlib.gunzipSync(fs.readFileSync(p))); if(rec.ndx_close) continue;
  const r=await fetch(B+`/api/stock/NDX/ohlc/1d?date=${rec.date}`,{headers:H}); const j=await r.json().catch(()=>({})); const od=j.data||[]; const reg=od.find(x=>x.market_time==="r")||od[od.length-1]; if(reg){rec.ndx_close=+reg.close; fs.writeFileSync(p,zlib.gzipSync(JSON.stringify(rec))); n++;} } }
await Promise.all([w(),w(),w(),w()]); console.log("ndx closes added",n,"of",files.length);