[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":53,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",12,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","10e67432-a82b-11f1-8916-1607ee4eb77e","name","fileType","interval","content","// ============================================================================\n// HİSSE ÖNERİLER - GÜNLÜK OTOMATİK GÜNCELLEME + PUSH BİLDİRİM (CRON VAL) — v3\n// ============================================================================\n// v2'den farkı: \"AL\" listesi ve VİOP \"Volatilitesi Yüksek/Düşük\" listeleri artık\n// günlük rotasyonla DEĞİL, price_history tablosundaki GERÇEK fiyat verisinden\n// hesaplanan bir teknik skorla belirleniyor:\n// - AL listesi: son ~14 günlük penceredeki fiyat değişim yüzdesi (momentum)\n// en yüksek 5 hisse.\n// - VİOP Volatilitesi Yüksek: aynı pencerede günlük ortalama mutlak %\n// değişimi (volatilite) en yüksek 5 hisse.\n// - VİOP Volatilitesi Düşük: aynı hesap, volatilitesi en düşük 5 hisse.\n// SAT/Azalt listesi DEĞİŞMEDİ — o zaten gerçek aracı kurum tavsiyelerinden\n// elle derleniyordu, olduğu gibi kalıyor.\n//\n// ÖNEMLİ SINIRLAMA: price_history tablosu yakın zamanda dolmaya başladı, bu\n// yüzden ilk haftalarda bazı hisselerin yeterli geçmişi olmayabilir. Böyle\n// durumlarda o hisse teknik sıralamaya girmiyor, eksik kalan slotlar eski\n// rotasyon yöntemiyle dolduruluyor (kod içinde açıkça loglanıyor). Veri\n// biriktikçe (birkaç hafta içinde) tüm slotlar otomatik olarak gerçek veriye\n// dayanır hale gelecek, ekstra bir işlem yapmana gerek yok.\n//\n// KURULUM:\n// 1. Mevcut \"hisse-oneriler-cron-v2\" val'ının Code sekmesindeki içeriği bu\n// dosyanın TAMAMIYLA değiştir, kaydet. (Aynı val, sadece kod güncelleniyor.)\n// 2. Yeni bir ortam değişkeni EKLEMENE GEREK YOK — SUPABASE_SERVICE_ROLE_KEY\n// zaten \"hisse-fiyat-alarm-cron\" val'ı için hesap ayarlarına eklenmişti,\n// val.town'da ortam değişkenleri hesap genelinde paylaşılır, bu val da\n// otomatik olarak erişebilir.\n// 3. Zamanlama aynı kalabilir: 0 4 * * * (07:00 TR).\n// ============================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst STORAGE_KEY = \"hisse-oneriler-data\";\nconst SUPABASE_URL = \"https://uqkwmrwzcslessuopcrv.supabase.co\";\nconst TEKNIK_PENCERE_GUN = 14; // geriye dönük kaç takvim günü verisine bakılacak\n\nconst NAME_MAP: Record = {\n GARAN: \"Garanti BBVA\",\n AKBNK: \"Akbank\",\n ISCTR: \"Türkiye İş Bankası\",\n YKBNK: \"Yapı Kredi\",\n VAKBN: \"VakıfBank\",\n HALKB: \"Halkbank\",\n TCELL: \"Turkcell\",\n TTKOM: \"Türk Telekom\",\n SAHOL: \"Sabancı Holding\",\n KCHOL: \"Koç Holding\",\n TUPRS: \"Tüpraş\",\n THYAO: \"Türk Hava Yolları\",\n TOASO: \"Tofaş\",\n ASELS: \"Aselsan\",\n BIMAS: \"BİM\",\n SISE: \"Şişecam\",\n MGROS: \"Migros\",\n ULKER: \"Ülker\",\n EREGL: \"Ereğli Demir Çelik\",\n PETKM: \"Petkim\",\n FROTO: \"Ford Otosan\",\n ARCLK: \"Arçelik\",\n PGSUS: \"Pegasus\",\n KOZAL: \"Koza Altın\",\n SASA: \"Sasa Polyester\",\n KRDMD: \"Kardemir\",\n ENJSA: \"Enerjisa\",\n TAVHL: \"TAV Havalimanları\",\n OYAKC: \"Oyak Çimento\",\n ALARK: \"Alarko Holding\",\n KONTR: \"Kontrol Enerji\",\n MOGAN: \"Mogan Enerji\",\n};\nfunction nameOf(code: string) {\n return NAME_MAP[code] || code;\n}\n\nfunction todayTR(): string {\n const ay = [\n \"Ocak\",\n \"Şubat\",\n \"Mart\",\n \"Nisan\",\n \"Mayıs\",\n \"Haziran\",\n \"Temmuz\",\n \"Ağustos\",\n \"Eylül\",\n \"Ekim\",\n \"Kasım\",\n \"Aralık\",\n ];\n const parts = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/Istanbul\",\n year: \"numeric\",\n month: \"numeric\",\n day: \"numeric\",\n }).formatToParts(new Date());\n const d = parts.find((p) => p.type === \"day\")!.value;\n const m = parseInt(parts.find((p) => p.type === \"month\")!.value, 10);\n const y = parts.find((p) => p.type === \"year\")!.value;\n return `${d} ${ay[m - 1]} ${y}`;\n}\n\nfunction dayOfYearTR(): number {\n const parts = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/Istanbul\",\n year: \"numeric\",\n month: \"numeric\",\n day: \"numeric\",\n }).formatToParts(new Date());\n const d = parseInt(parts.find((p) => p.type === \"day\")!.value, 10);\n const m = parseInt(parts.find((p) => p.type === \"month\")!.value, 10);\n const y = parseInt(parts.find((p) => p.type === \"year\")!.value, 10);\n const start = Date.UTC(y, 0, 0);\n const cur = Date.UTC(y, m - 1, d);\n return Math.floor((cur - start) / 86400000);\n}\n\nfunction isoDaysAgoTR(daysAgo: number): string {\n const now = new Date(Date.now() - daysAgo * 86400000);\n const parts = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Europe/Istanbul\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).formatToParts(now);\n const y = parts.find((p) => p.type === \"year\")!.value;\n const m = parts.find((p) => p.type === \"month\")!.value;\n const d = parts.find((p) => p.type === \"day\")!.value;\n return `${y}-${m}-${d}`;\n}\n\n// Havuzlar (likit, BIST30/BIST100 içinde, VİOP'ta işlem gören şirketler).\nconst AL_HAVUZU = [\n \"GARAN\",\n \"AKBNK\",\n \"ISCTR\",\n \"YKBNK\",\n \"VAKBN\",\n \"THYAO\",\n \"TUPRS\",\n \"TOASO\",\n \"ASELS\",\n \"BIMAS\",\n \"SISE\",\n \"TCELL\",\n \"TTKOM\",\n \"KCHOL\",\n \"SAHOL\",\n \"EREGL\",\n \"PETKM\",\n \"FROTO\",\n \"PGSUS\",\n \"SASA\",\n \"MGROS\",\n \"ULKER\",\n \"TAVHL\",\n \"ENJSA\",\n];\nconst VIOP_AGRESIF_HAVUZU = [\n \"GARAN\",\n \"AKBNK\",\n \"ISCTR\",\n \"YKBNK\",\n \"VAKBN\",\n \"THYAO\",\n \"SASA\",\n \"EREGL\",\n \"PGSUS\",\n \"ASELS\",\n];\nconst VIOP_MUHAFAZAKAR_HAVUZU = [\n \"TCELL\",\n \"SAHOL\",\n \"KCHOL\",\n \"TUPRS\",\n \"TTKOM\",\n \"SISE\",\n \"BIMAS\",\n \"MGROS\",\n \"ULKER\",\n \"TAVHL\",\n];\n\n// SAT/Azalt tavsiyeli hisseler — DEĞİŞMEDİ, bu liste zaten gerçek aracı kurum\n// kaynaklarına dayanıyor (bkz. v2'deki açıklama). Periyodik olarak elle\n// güncellenmesi gerekir.\nconst SAT_LISTESI: { code: string; sourceCount: number }[] = [\n { code: \"PETKM\", sourceCount: 2 },\n { code: \"HALKB\", sourceCount: 2 },\n { code: \"MOGAN\", sourceCount: 1 },\n];\n\n// Bir hisse aynı anda hem AL hem SAT listesinde görünüp kullanıcıyı\n// şaşırtmasın diye, SAT listesindeki kodları AL havuzundan çıkarıyoruz —\n// SAT listesi gerçek/doğrulanmış analist görüşüne dayandığı için önceliklidir.\nconst SAT_KODLARI = new Set(SAT_LISTESI.map((s) => s.code));\nconst AL_HAVUZU_UYGUN = AL_HAVUZU.filter((c) => !SAT_KODLARI.has(c));\n\nfunction pickRotating(pool: T[], start: number, count: number): T[] {\n const n = pool.length;\n const out: T[] = [];\n for (let i = 0; i < count; i++) {\n out.push(pool[(start + i) % n]);\n }\n return out;\n}\n\n// ---------------------------------------------------------------------------\n// Supabase — price_history okuma (service_role ile, RLS'i bypass eder)\n// ---------------------------------------------------------------------------\n\ntype PriceRow = { trade_date: string; stock_code: string; close_price: number };\n\nasync function fetchPriceHistory(\n serviceRoleKey: string,\n codes: string[],\n sinceISO: string,\n): Promise> {\n const codesParam = codes.join(\",\");\n const url =\n `${SUPABASE_URL}/rest/v1/price_history?stock_code=in.(${codesParam})&trade_date=gte.${sinceISO}&select=trade_date,stock_code,close_price&order=trade_date.asc`;\n const resp = await fetch(url, {\n headers: {\n apikey: serviceRoleKey,\n authorization: `Bearer ${serviceRoleKey}`,\n },\n });\n if (!resp.ok) {\n const text = await resp.text().catch(() => \"\");\n throw new Error(\n `price_history okuma hatası (${resp.status}): ${text.slice(0, 300)}`,\n );\n }\n const rows = (await resp.json()) as PriceRow[];\n const map = new Map();\n for (const row of rows) {\n if (!map.has(row.stock_code)) map.set(row.stock_code, []);\n map.get(row.stock_code)!.push(row);\n }\n return map;\n}\n\n// Momentum: pencere içindeki İLK ve SON fiyat arasındaki % değişim.\n// En az 2 farklı günün verisi yoksa null döner (henüz yeterli veri yok).\nfunction momentumScore(rows: PriceRow[] | undefined): number | null {\n if (!rows || rows.length < 2) return null;\n const first = rows[0].close_price;\n const last = rows[rows.length - 1].close_price;\n if (!first) return null;\n return ((last - first) / first) * 100;\n}\n\n// Volatilite: ardışık günler arası % değişimlerin ortalama MUTLAK değeri.\nfunction volatilityScore(rows: PriceRow[] | undefined): number | null {\n if (!rows || rows.length < 2) return null;\n const changes: number[] = [];\n for (let i = 1; i < rows.length; i++) {\n const prev = rows[i - 1].close_price;\n const cur = rows[i].close_price;\n if (prev) changes.push(Math.abs((cur - prev) / prev) * 100);\n }\n if (!changes.length) return null;\n return changes.reduce((a, b) => a + b, 0) / changes.length;\n}\n\n// AL listesi: momentumu en yüksek `count` hisse. Yeterli veri yoksa, kalan\n// slotları eski rotasyon yöntemiyle (günün seed'i) doldurur.\nfunction rankByMomentum(\n pool: string[],\n histMap: Map,\n count: number,\n): { picked: string[]; fallbackUsed: number } {\n const scored = pool\n .map((code) => ({ code, score: momentumScore(histMap.get(code)) }))\n .filter((x): x is { code: string; score: number } => x.score !== null);\n scored.sort((a, b) => b.score - a.score);\n const picked = scored.slice(0, count).map((x) => x.code);\n const fallbackUsed = Math.max(0, count - picked.length);\n if (fallbackUsed > 0) {\n const seed = dayOfYearTR();\n const start = (seed * 7) % pool.length;\n const rotated = pickRotating(pool, start, pool.length);\n for (const code of rotated) {\n if (picked.length >= count) break;\n if (!picked.includes(code)) picked.push(code);\n }\n }\n return { picked, fallbackUsed };\n}\n\n// VİOP listeleri: volatilitesi en yüksek/düşük `count` hisse, 1-99 arası bir\n// gösterim puanına (\"puan X/100\") çevrilmiş halde. Yeterli veri yoksa kalan\n// slotlar rotasyonla ve orta seviye bir puanla doldurulur.\nfunction rankByVolatility(\n pool: string[],\n histMap: Map,\n count: number,\n direction: \"high\" | \"low\",\n): { picked: { code: string; scoreDisplay: number }[]; fallbackUsed: number } {\n const scored = pool\n .map((code) => ({ code, vol: volatilityScore(histMap.get(code)) }))\n .filter((x): x is { code: string; vol: number } => x.vol !== null);\n scored.sort((a, b) => (direction === \"high\" ? b.vol - a.vol : a.vol - b.vol));\n const picked = scored.slice(0, count);\n const fallbackUsed = Math.max(0, count - picked.length);\n if (fallbackUsed > 0) {\n const seed = dayOfYearTR();\n const start = (seed * (direction === \"high\" ? 3 : 9)) % pool.length;\n const rotated = pickRotating(pool, start, pool.length);\n const already = new Set(picked.map((p) => p.code));\n for (const code of rotated) {\n if (picked.length >= count) break;\n if (!already.has(code)) {\n picked.push({ code, vol: direction === \"high\" ? 3 : 1 });\n already.add(code);\n }\n }\n }\n return {\n picked: picked.map(({ code, vol }) => ({\n code,\n scoreDisplay: direction === \"high\"\n ? Math.max(1, Math.min(99, Math.round(vol * 10)))\n : Math.max(1, Math.min(99, Math.round(100 - vol * 10))),\n })),\n fallbackUsed,\n };\n}\n\n// ---------------------------------------------------------------------------\n// FCM (Firebase Cloud Messaging) — konuya (topic) bildirim gönderme\n// (v2 ile birebir aynı, değişmedi)\n// ---------------------------------------------------------------------------\n\nfunction pemToBinary(pem: string): ArrayBuffer {\n const b64 = pem\n .replace(/-----BEGIN PRIVATE KEY-----/, \"\")\n .replace(/-----END PRIVATE KEY-----/, \"\")\n .replace(/\\s+/g, \"\");\n const binary = atob(b64);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) bytes[i] = binary.charCodeAt(i);\n return bytes.buffer;\n}\n\nfunction base64url(input: string | ArrayBuffer): string {\n let bytes: Uint8Array;\n if (typeof input === \"string\") {\n bytes = new TextEncoder().encode(input);\n } else {\n bytes = new Uint8Array(input);\n }\n let str = \"\";\n for (let i = 0; i < bytes.length; i++) str += String.fromCharCode(bytes[i]);\n return btoa(str).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n}\n\ntype ServiceAccount = {\n client_email: string;\n private_key: string;\n token_uri: string;\n project_id: string;\n};\n\nasync function getAccessToken(sa: ServiceAccount): Promise {\n const header = { alg: \"RS256\", typ: \"JWT\" };\n const now = Math.floor(Date.now() / 1000);\n const claims = {\n iss: sa.client_email,\n scope: \"https://www.googleapis.com/auth/firebase.messaging\",\n aud: sa.token_uri,\n iat: now,\n exp: now + 3600,\n };\n const signingInput = `${base64url(JSON.stringify(header))}.${\n base64url(JSON.stringify(claims))\n }`;\n\n const cryptoKey = await crypto.subtle.importKey(\n \"pkcs8\",\n pemToBinary(sa.private_key),\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const signature = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n cryptoKey,\n new TextEncoder().encode(signingInput),\n );\n const jwt = `${signingInput}.${base64url(signature)}`;\n\n const resp = await fetch(sa.token_uri, {\n method: \"POST\",\n headers: { \"content-type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n const json = await resp.json();\n if (!resp.ok || !json.access_token) {\n throw new Error(\"OAuth token alınamadı: \" + JSON.stringify(json));\n }\n return json.access_token as string;\n}\n\nasync function sendTopicPush(\n accessToken: string,\n projectId: string,\n topic: string,\n title: string,\n body: string,\n data: Record,\n) {\n const resp = await fetch(\n `https://fcm.googleapis.com/v1/projects/${projectId}/messages:send`,\n {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"authorization\": `Bearer ${accessToken}`,\n },\n body: JSON.stringify({\n message: { topic, notification: { title, body }, data },\n }),\n },\n );\n const json = await resp.json().catch(() => ({}));\n if (!resp.ok) {\n console.log(`FCM gönderim hatası (${topic}):`, JSON.stringify(json));\n } else {\n console.log(`FCM gönderildi: ${topic} — ${body}`);\n }\n}\n\nfunction diffCodes(\n oldList: { code: string }[] | undefined | null,\n newList: { code: string }[],\n): { entries: string[]; exits: string[] } {\n const oldCodes = new Set((oldList || []).map((x) => x.code));\n const newCodes = new Set(newList.map((x) => x.code));\n return {\n entries: [...newCodes].filter((c) => !oldCodes.has(c)),\n exits: [...oldCodes].filter((c) => !newCodes.has(c)),\n };\n}\n\n// ---------------------------------------------------------------------------\n\nexport default async function () {\n const seed = dayOfYearTR();\n const today = todayTR();\n const serviceRoleKey = Deno.env.get(\"SUPABASE_SERVICE_ROLE_KEY\");\n\n let alSecili: string[];\n let aggFinal: { code: string; scoreDisplay: number }[];\n let conFinal: { code: string; scoreDisplay: number }[];\n\n function eskiRotasyonaDon() {\n const alStart = (seed * 7) % AL_HAVUZU_UYGUN.length;\n alSecili = pickRotating(AL_HAVUZU_UYGUN, alStart, 5);\n const aggStart = (seed * 3) % VIOP_AGRESIF_HAVUZU.length;\n const aggPuanlar = [97, 93, 88, 84, 80];\n aggFinal = pickRotating(VIOP_AGRESIF_HAVUZU, aggStart, 5).map((\n code,\n i,\n ) => ({ code, scoreDisplay: aggPuanlar[i] }));\n const conStart = (seed * 9) % VIOP_MUHAFAZAKAR_HAVUZU.length;\n const conPuanlar = [90, 86, 82, 78, 74];\n conFinal = pickRotating(VIOP_MUHAFAZAKAR_HAVUZU, conStart, 5).map((\n code,\n i,\n ) => ({ code, scoreDisplay: conPuanlar[i] }));\n }\n\n if (!serviceRoleKey) {\n console.log(\n \"SUPABASE_SERVICE_ROLE_KEY eksik — teknik sinyal hesaplanamadı, eski rotasyon yöntemine dönülüyor.\",\n );\n eskiRotasyonaDon();\n } else {\n try {\n const allCodes = Array.from(\n new Set([\n ...AL_HAVUZU,\n ...VIOP_AGRESIF_HAVUZU,\n ...VIOP_MUHAFAZAKAR_HAVUZU,\n ]),\n );\n const sinceISO = isoDaysAgoTR(TEKNIK_PENCERE_GUN);\n const histMap = await fetchPriceHistory(\n serviceRoleKey,\n allCodes,\n sinceISO,\n );\n\n const alSonuc = rankByMomentum(AL_HAVUZU_UYGUN, histMap, 5);\n alSecili = alSonuc.picked;\n const aggSonuc = rankByVolatility(\n VIOP_AGRESIF_HAVUZU,\n histMap,\n 5,\n \"high\",\n );\n aggFinal = aggSonuc.picked;\n const conSonuc = rankByVolatility(\n VIOP_MUHAFAZAKAR_HAVUZU,\n histMap,\n 5,\n \"low\",\n );\n conFinal = conSonuc.picked;\n\n console.log(\n `Teknik sinyal hesaplandı (pencere: son ${TEKNIK_PENCERE_GUN} gün). ` +\n `AL: ${alSonuc.fallbackUsed} slot rotasyonla dolduruldu (veri yetersiz). ` +\n `VİOP-Yüksek: ${aggSonuc.fallbackUsed} slot rotasyonla. VİOP-Düşük: ${conSonuc.fallbackUsed} slot rotasyonla.`,\n );\n } catch (e) {\n console.log(\n \"Teknik sinyal hesaplama hatası, eski rotasyon yöntemine dönülüyor:\",\n String(e),\n );\n eskiRotasyonaDon();\n }\n }\n\n const final = {\n updatedAt: today,\n items: alSecili!.map((code) => ({ code, name: nameOf(code), tag: \"AL\" })),\n satItems: SAT_LISTESI.map(({ code, sourceCount }) => ({\n code,\n name: nameOf(code),\n tag: \"SAT\",\n sourceCount,\n })),\n viop: {\n updatedAt: today,\n aggressive: aggFinal!.map(({ code, scoreDisplay }) => ({\n code,\n name: nameOf(code),\n score: scoreDisplay,\n })),\n conservative: conFinal!.map(({ code, scoreDisplay }) => ({\n code,\n name: nameOf(code),\n score: scoreDisplay,\n })),\n },\n };\n\n // Bildirimler için, ÜZERİNE YAZMADAN ÖNCE dünkü veriyi oku.\n let previous: typeof final | null = null;\n try {\n previous = (await blob.getJSON(STORAGE_KEY)) as typeof final | null;\n } catch (_e) {}\n\n await blob.setJSON(STORAGE_KEY, final);\n\n // ---- Push bildirimleri: liste giriş/çıkışlarını bul ve gönder ----\n try {\n const projectId = Deno.env.get(\"FCM_PROJECT_ID\");\n const clientEmail = Deno.env.get(\"FCM_CLIENT_EMAIL\");\n const privateKey = Deno.env.get(\"FCM_PRIVATE_KEY\");\n if (!projectId || !clientEmail || !privateKey) {\n console.log(\n \"FCM_PROJECT_ID / FCM_CLIENT_EMAIL / FCM_PRIVATE_KEY eksik — push bildirimleri atlandı.\",\n );\n } else {\n const sa: ServiceAccount = {\n project_id: projectId,\n client_email: clientEmail,\n private_key: privateKey,\n token_uri: \"https://oauth2.googleapis.com/token\",\n };\n const accessToken = await getAccessToken(sa);\n\n const alDiff = diffCodes(previous?.items, final.items);\n const satDiff = diffCodes(previous?.satItems, final.satItems);\n const aggDiff = diffCodes(\n previous?.viop?.aggressive,\n final.viop.aggressive,\n );\n const conDiff = diffCodes(\n previous?.viop?.conservative,\n final.viop.conservative,\n );\n\n const jobs: Array<() => Promise> = [];\n for (const code of alDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} bugünkü AL listesine girdi`,\n { code, type: \"al_entry\" },\n )\n );\n }\n for (const code of alDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} AL listesinden çıktı`,\n { code, type: \"al_exit\" },\n )\n );\n }\n for (const code of satDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} bugünkü SAT/Azalt listesine girdi`,\n { code, type: \"sat_entry\" },\n )\n );\n }\n for (const code of satDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} SAT/Azalt listesinden çıktı`,\n { code, type: \"sat_exit\" },\n )\n );\n }\n for (const code of aggDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Yüksek listesine girdi`,\n { code, type: \"viop_agg_entry\" },\n )\n );\n }\n for (const code of aggDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Yüksek listesinden çıktı`,\n { code, type: \"viop_agg_exit\" },\n )\n );\n }\n for (const code of conDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Düşük listesine girdi`,\n { code, type: \"viop_con_entry\" },\n )\n );\n }\n for (const code of conDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Düşük listesinden çıktı`,\n { code, type: \"viop_con_exit\" },\n )\n );\n }\n\n console.log(`Push: ${jobs.length} bildirim gönderilecek.`);\n for (const job of jobs) {\n try {\n await job();\n } catch (e) {\n console.log(\"Tekil push hatası:\", String(e));\n }\n }\n }\n } catch (e) {\n console.log(\"Push bildirim bloğu genel hata:\", String(e));\n }\n\n console.log(\n `Hisse öneriler güncellendi: ${today} — ${final.items.length} AL, ${final.satItems.length} SAT, ${final.viop.aggressive.length} agresif VİOP, ${final.viop.conservative.length} muhafazakâr VİOP.`,\n );\n return final;\n}","// ============================================================================\n// HİSSE ÖNERİLER - GÜNLÜK OTOMATİK GÜNCELLEME + PUSH BİLDİRİM (CRON VAL) — v3\n// ============================================================================\n// v2'den farkı: \"AL\" listesi ve VİOP \"Volatilitesi Yüksek/Düşük\" listeleri artık\n// günlük rotasyonla DEĞİL, price_history tablosundaki GERÇEK fiyat verisinden\n// hesaplanan bir teknik skorla belirleniyor:\n// - AL listesi: son ~14 günlük penceredeki fiyat değişim yüzdesi (momentum)\n// en yüksek 5 hisse.\n// - VİOP Volatilitesi Yüksek: aynı pencerede günlük ortalama mutlak %\n// değişimi (volatilite) en yüksek 5 hisse.\n// - VİOP Volatilitesi Düşük: aynı hesap, volatilitesi en düşük 5 hisse.\n// SAT/Azalt listesi DEĞİŞMEDİ — o zaten gerçek aracı kurum tavsiyelerinden\n// elle derleniyordu, olduğu gibi kalıyor.\n//\n// ÖNEMLİ SINIRLAMA: price_history tablosu yakın zamanda dolmaya başladı, bu\n// yüzden ilk haftalarda bazı hisselerin yeterli geçmişi olmayabilir. Böyle\n// durumlarda o hisse teknik sıralamaya girmiyor, eksik kalan slotlar eski\n// rotasyon yöntemiyle dolduruluyor (kod içinde açıkça loglanıyor). Veri\n// biriktikçe (birkaç hafta içinde) tüm slotlar otomatik olarak gerçek veriye\n// dayanır hale gelecek, ekstra bir işlem yapmana gerek yok.\n//\n// KURULUM:\n// 1. Mevcut \"hisse-oneriler-cron-v2\" val'ının Code sekmesindeki içeriği bu\n// dosyanın TAMAMIYLA değiştir, kaydet. (Aynı val, sadece kod güncelleniyor.)\n// 2. Yeni bir ortam değişkeni EKLEMENE GEREK YOK — SUPABASE_SERVICE_ROLE_KEY\n// zaten \"hisse-fiyat-alarm-cron\" val'ı için hesap ayarlarına eklenmişti,\n// val.town'da ortam değişkenleri hesap genelinde paylaşılır, bu val da\n// otomatik olarak erişebilir.\n// 3. Zamanlama aynı kalabilir: 0 4 * * * (07:00 TR).\n// ============================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst STORAGE_KEY = \"hisse-oneriler-data\";\nconst SUPABASE_URL = \"https://uqkwmrwzcslessuopcrv.supabase.co\";\nconst TEKNIK_PENCERE_GUN = 14; // geriye dönük kaç takvim günü verisine bakılacak\n\nconst NAME_MAP: Record = {\n GARAN: \"Garanti BBVA\",\n AKBNK: \"Akbank\",\n ISCTR: \"Türkiye İş Bankası\",\n YKBNK: \"Yapı Kredi\",\n VAKBN: \"VakıfBank\",\n HALKB: \"Halkbank\",\n TCELL: \"Turkcell\",\n TTKOM: \"Türk Telekom\",\n SAHOL: \"Sabancı Holding\",\n KCHOL: \"Koç Holding\",\n TUPRS: \"Tüpraş\",\n THYAO: \"Türk Hava Yolları\",\n TOASO: \"Tofaş\",\n ASELS: \"Aselsan\",\n BIMAS: \"BİM\",\n SISE: \"Şişecam\",\n MGROS: \"Migros\",\n ULKER: \"Ülker\",\n EREGL: \"Ereğli Demir Çelik\",\n PETKM: \"Petkim\",\n FROTO: \"Ford Otosan\",\n ARCLK: \"Arçelik\",\n PGSUS: \"Pegasus\",\n KOZAL: \"Koza Altın\",\n SASA: \"Sasa Polyester\",\n KRDMD: \"Kardemir\",\n ENJSA: \"Enerjisa\",\n TAVHL: \"TAV Havalimanları\",\n OYAKC: \"Oyak Çimento\",\n ALARK: \"Alarko Holding\",\n KONTR: \"Kontrol Enerji\",\n MOGAN: \"Mogan Enerji\",\n};\nfunction nameOf(code: string) {\n return NAME_MAP[code] || code;\n}\n\nfunction todayTR(): string {\n const ay = [\n \"Ocak\",\n \"Şubat\",\n \"Mart\",\n \"Nisan\",\n \"Mayıs\",\n \"Haziran\",\n \"Temmuz\",\n \"Ağustos\",\n \"Eylül\",\n \"Ekim\",\n \"Kasım\",\n \"Aralık\",\n ];\n const parts = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/Istanbul\",\n year: \"numeric\",\n month: \"numeric\",\n day: \"numeric\",\n }).formatToParts(new Date());\n const d = parts.find((p) => p.type === \"day\")!.value;\n const m = parseInt(parts.find((p) => p.type === \"month\")!.value, 10);\n const y = parts.find((p) => p.type === \"year\")!.value;\n return `${d} ${ay[m - 1]} ${y}`;\n}\n\nfunction dayOfYearTR(): number {\n const parts = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/Istanbul\",\n year: \"numeric\",\n month: \"numeric\",\n day: \"numeric\",\n }).formatToParts(new Date());\n const d = parseInt(parts.find((p) => p.type === \"day\")!.value, 10);\n const m = parseInt(parts.find((p) => p.type === \"month\")!.value, 10);\n const y = parseInt(parts.find((p) => p.type === \"year\")!.value, 10);\n const start = Date.UTC(y, 0, 0);\n const cur = Date.UTC(y, m - 1, d);\n return Math.floor((cur - start) / 86400000);\n}\n\nfunction isoDaysAgoTR(daysAgo: number): string {\n const now = new Date(Date.now() - daysAgo * 86400000);\n const parts = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Europe/Istanbul\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).formatToParts(now);\n const y = parts.find((p) => p.type === \"year\")!.value;\n const m = parts.find((p) => p.type === \"month\")!.value;\n const d = parts.find((p) => p.type === \"day\")!.value;\n return `${y}-${m}-${d}`;\n}\n\n// Havuzlar (likit, BIST30/BIST100 içinde, VİOP'ta işlem gören şirketler).\nconst AL_HAVUZU = [\n \"GARAN\",\n \"AKBNK\",\n \"ISCTR\",\n \"YKBNK\",\n \"VAKBN\",\n \"THYAO\",\n \"TUPRS\",\n \"TOASO\",\n \"ASELS\",\n \"BIMAS\",\n \"SISE\",\n \"TCELL\",\n \"TTKOM\",\n \"KCHOL\",\n \"SAHOL\",\n \"EREGL\",\n \"PETKM\",\n \"FROTO\",\n \"PGSUS\",\n \"SASA\",\n \"MGROS\",\n \"ULKER\",\n \"TAVHL\",\n \"ENJSA\",\n];\nconst VIOP_AGRESIF_HAVUZU = [\n \"GARAN\",\n \"AKBNK\",\n \"ISCTR\",\n \"YKBNK\",\n \"VAKBN\",\n \"THYAO\",\n \"SASA\",\n \"EREGL\",\n \"PGSUS\",\n \"ASELS\",\n];\nconst VIOP_MUHAFAZAKAR_HAVUZU = [\n \"TCELL\",\n \"SAHOL\",\n \"KCHOL\",\n \"TUPRS\",\n \"TTKOM\",\n \"SISE\",\n \"BIMAS\",\n \"MGROS\",\n \"ULKER\",\n \"TAVHL\",\n];\n\n// SAT/Azalt tavsiyeli hisseler — bu liste gerçek aracı kurum kaynaklarına\n// dayanıyor ve OTOMATİK GÜNCELLENMİYOR, elle bakım gerektiriyor. 6 Eylül 2026'da\n// yapılan bir doğrulama turunda PETKM ve HALKB'nin artık SAT değil TUT/AL'a\n// yükseltildiği ortaya çıktı (aracı kurumlar zamanla görüş değiştiriyor) —\n// listeden çıkarıldılar. MOGAN, İş Yatırım'ın 10 Ağustos 2026 tarihli TUT→SAT\n// düşürmesiyle hâlâ güncel ve doğrulanmış durumda.\n// ÖNEMLİ: Bu liste zamanla yine bayatlayabilir (aracı kurum görüşleri\n// değişiyor) — birkaç ayda bir aynı doğrulamayı tekrarlamak gerekiyor,\n// yoksa artık geçerli olmayan bir SAT tavsiyesi kullanıcıya gösterilmeye\n// devam eder. Şu an tek doğrulanmış isim kaldığı için liste kısa — bu,\n// eksik değil, Türk aracı kurumlarının zaten nadiren açık SAT yayınlamasından\n// kaynaklanıyor; uydurma/doğrulanmamış bir isim eklemek yerine kısa\n// bırakmak tercih edildi.\nconst SAT_LISTESI: { code: string; sourceCount: number }[] = [\n { code: \"MOGAN\", sourceCount: 1 },\n];\n\n// Bir hisse aynı anda hem AL hem SAT listesinde görünüp kullanıcıyı\n// şaşırtmasın diye, SAT listesindeki kodları AL havuzundan çıkarıyoruz —\n// SAT listesi gerçek/doğrulanmış analist görüşüne dayandığı için önceliklidir.\nconst SAT_KODLARI = new Set(SAT_LISTESI.map((s) => s.code));\nconst AL_HAVUZU_UYGUN = AL_HAVUZU.filter((c) => !SAT_KODLARI.has(c));\n\nfunction pickRotating(pool: T[], start: number, count: number): T[] {\n const n = pool.length;\n const out: T[] = [];\n for (let i = 0; i < count; i++) {\n out.push(pool[(start + i) % n]);\n }\n return out;\n}\n\n// ---------------------------------------------------------------------------\n// Supabase — price_history okuma (service_role ile, RLS'i bypass eder)\n// ---------------------------------------------------------------------------\n\ntype PriceRow = { trade_date: string; stock_code: string; close_price: number };\n\nasync function fetchPriceHistory(\n serviceRoleKey: string,\n codes: string[],\n sinceISO: string,\n): Promise> {\n const codesParam = codes.join(\",\");\n const url =\n `${SUPABASE_URL}/rest/v1/price_history?stock_code=in.(${codesParam})&trade_date=gte.${sinceISO}&select=trade_date,stock_code,close_price&order=trade_date.asc`;\n const resp = await fetch(url, {\n headers: {\n apikey: serviceRoleKey,\n authorization: `Bearer ${serviceRoleKey}`,\n },\n });\n if (!resp.ok) {\n const text = await resp.text().catch(() => \"\");\n throw new Error(\n `price_history okuma hatası (${resp.status}): ${text.slice(0, 300)}`,\n );\n }\n const rows = (await resp.json()) as PriceRow[];\n const map = new Map();\n for (const row of rows) {\n if (!map.has(row.stock_code)) map.set(row.stock_code, []);\n map.get(row.stock_code)!.push(row);\n }\n return map;\n}\n\n// Momentum: pencere içindeki İLK ve SON fiyat arasındaki % değişim.\n// En az 2 farklı günün verisi yoksa null döner (henüz yeterli veri yok).\nfunction momentumScore(rows: PriceRow[] | undefined): number | null {\n if (!rows || rows.length < 2) return null;\n const first = rows[0].close_price;\n const last = rows[rows.length - 1].close_price;\n if (!first) return null;\n return ((last - first) / first) * 100;\n}\n\n// Volatilite: ardışık günler arası % değişimlerin ortalama MUTLAK değeri.\nfunction volatilityScore(rows: PriceRow[] | undefined): number | null {\n if (!rows || rows.length < 2) return null;\n const changes: number[] = [];\n for (let i = 1; i < rows.length; i++) {\n const prev = rows[i - 1].close_price;\n const cur = rows[i].close_price;\n if (prev) changes.push(Math.abs((cur - prev) / prev) * 100);\n }\n if (!changes.length) return null;\n return changes.reduce((a, b) => a + b, 0) / changes.length;\n}\n\n// AL listesi: momentumu en yüksek `count` hisse. Yeterli veri yoksa, kalan\n// slotları eski rotasyon yöntemiyle (günün seed'i) doldurur.\nfunction rankByMomentum(\n pool: string[],\n histMap: Map,\n count: number,\n): { picked: string[]; fallbackUsed: number } {\n const scored = pool\n .map((code) => ({ code, score: momentumScore(histMap.get(code)) }))\n .filter((x): x is { code: string; score: number } => x.score !== null);\n scored.sort((a, b) => b.score - a.score);\n const picked = scored.slice(0, count).map((x) => x.code);\n const fallbackUsed = Math.max(0, count - picked.length);\n if (fallbackUsed > 0) {\n const seed = dayOfYearTR();\n const start = (seed * 7) % pool.length;\n const rotated = pickRotating(pool, start, pool.length);\n for (const code of rotated) {\n if (picked.length >= count) break;\n if (!picked.includes(code)) picked.push(code);\n }\n }\n return { picked, fallbackUsed };\n}\n\n// VİOP listeleri: volatilitesi en yüksek/düşük `count` hisse, 1-99 arası bir\n// gösterim puanına (\"puan X/100\") çevrilmiş halde. Yeterli veri yoksa kalan\n// slotlar rotasyonla ve orta seviye bir puanla doldurulur.\nfunction rankByVolatility(\n pool: string[],\n histMap: Map,\n count: number,\n direction: \"high\" | \"low\",\n): { picked: { code: string; scoreDisplay: number }[]; fallbackUsed: number } {\n const scored = pool\n .map((code) => ({ code, vol: volatilityScore(histMap.get(code)) }))\n .filter((x): x is { code: string; vol: number } => x.vol !== null);\n scored.sort((a, b) => (direction === \"high\" ? b.vol - a.vol : a.vol - b.vol));\n const picked = scored.slice(0, count);\n const fallbackUsed = Math.max(0, count - picked.length);\n if (fallbackUsed > 0) {\n const seed = dayOfYearTR();\n const start = (seed * (direction === \"high\" ? 3 : 9)) % pool.length;\n const rotated = pickRotating(pool, start, pool.length);\n const already = new Set(picked.map((p) => p.code));\n for (const code of rotated) {\n if (picked.length >= count) break;\n if (!already.has(code)) {\n picked.push({ code, vol: direction === \"high\" ? 3 : 1 });\n already.add(code);\n }\n }\n }\n return {\n picked: picked.map(({ code, vol }) => ({\n code,\n scoreDisplay: direction === \"high\"\n ? Math.max(1, Math.min(99, Math.round(vol * 10)))\n : Math.max(1, Math.min(99, Math.round(100 - vol * 10))),\n })),\n fallbackUsed,\n };\n}\n\n// ---------------------------------------------------------------------------\n// FCM (Firebase Cloud Messaging) — konuya (topic) bildirim gönderme\n// (v2 ile birebir aynı, değişmedi)\n// ---------------------------------------------------------------------------\n\nfunction pemToBinary(pem: string): ArrayBuffer {\n const b64 = pem\n .replace(/-----BEGIN PRIVATE KEY-----/, \"\")\n .replace(/-----END PRIVATE KEY-----/, \"\")\n .replace(/\\s+/g, \"\");\n const binary = atob(b64);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) bytes[i] = binary.charCodeAt(i);\n return bytes.buffer;\n}\n\nfunction base64url(input: string | ArrayBuffer): string {\n let bytes: Uint8Array;\n if (typeof input === \"string\") {\n bytes = new TextEncoder().encode(input);\n } else {\n bytes = new Uint8Array(input);\n }\n let str = \"\";\n for (let i = 0; i < bytes.length; i++) str += String.fromCharCode(bytes[i]);\n return btoa(str).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n}\n\ntype ServiceAccount = {\n client_email: string;\n private_key: string;\n token_uri: string;\n project_id: string;\n};\n\nasync function getAccessToken(sa: ServiceAccount): Promise {\n const header = { alg: \"RS256\", typ: \"JWT\" };\n const now = Math.floor(Date.now() / 1000);\n const claims = {\n iss: sa.client_email,\n scope: \"https://www.googleapis.com/auth/firebase.messaging\",\n aud: sa.token_uri,\n iat: now,\n exp: now + 3600,\n };\n const signingInput = `${base64url(JSON.stringify(header))}.${\n base64url(JSON.stringify(claims))\n }`;\n\n const cryptoKey = await crypto.subtle.importKey(\n \"pkcs8\",\n pemToBinary(sa.private_key),\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const signature = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n cryptoKey,\n new TextEncoder().encode(signingInput),\n );\n const jwt = `${signingInput}.${base64url(signature)}`;\n\n const resp = await fetch(sa.token_uri, {\n method: \"POST\",\n headers: { \"content-type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n const json = await resp.json();\n if (!resp.ok || !json.access_token) {\n throw new Error(\"OAuth token alınamadı: \" + JSON.stringify(json));\n }\n return json.access_token as string;\n}\n\nasync function sendTopicPush(\n accessToken: string,\n projectId: string,\n topic: string,\n title: string,\n body: string,\n data: Record,\n) {\n const resp = await fetch(\n `https://fcm.googleapis.com/v1/projects/${projectId}/messages:send`,\n {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"authorization\": `Bearer ${accessToken}`,\n },\n body: JSON.stringify({\n message: { topic, notification: { title, body }, data },\n }),\n },\n );\n const json = await resp.json().catch(() => ({}));\n if (!resp.ok) {\n console.log(`FCM gönderim hatası (${topic}):`, JSON.stringify(json));\n } else {\n console.log(`FCM gönderildi: ${topic} — ${body}`);\n }\n}\n\nfunction diffCodes(\n oldList: { code: string }[] | undefined | null,\n newList: { code: string }[],\n): { entries: string[]; exits: string[] } {\n const oldCodes = new Set((oldList || []).map((x) => x.code));\n const newCodes = new Set(newList.map((x) => x.code));\n return {\n entries: [...newCodes].filter((c) => !oldCodes.has(c)),\n exits: [...oldCodes].filter((c) => !newCodes.has(c)),\n };\n}\n\n// ---------------------------------------------------------------------------\n\nexport default async function () {\n const seed = dayOfYearTR();\n const today = todayTR();\n const serviceRoleKey = Deno.env.get(\"SUPABASE_SERVICE_ROLE_KEY\");\n\n let alSecili: string[];\n let aggFinal: { code: string; scoreDisplay: number }[];\n let conFinal: { code: string; scoreDisplay: number }[];\n\n function eskiRotasyonaDon() {\n const alStart = (seed * 7) % AL_HAVUZU_UYGUN.length;\n alSecili = pickRotating(AL_HAVUZU_UYGUN, alStart, 5);\n const aggStart = (seed * 3) % VIOP_AGRESIF_HAVUZU.length;\n const aggPuanlar = [97, 93, 88, 84, 80];\n aggFinal = pickRotating(VIOP_AGRESIF_HAVUZU, aggStart, 5).map((\n code,\n i,\n ) => ({ code, scoreDisplay: aggPuanlar[i] }));\n const conStart = (seed * 9) % VIOP_MUHAFAZAKAR_HAVUZU.length;\n const conPuanlar = [90, 86, 82, 78, 74];\n conFinal = pickRotating(VIOP_MUHAFAZAKAR_HAVUZU, conStart, 5).map((\n code,\n i,\n ) => ({ code, scoreDisplay: conPuanlar[i] }));\n }\n\n if (!serviceRoleKey) {\n console.log(\n \"SUPABASE_SERVICE_ROLE_KEY eksik — teknik sinyal hesaplanamadı, eski rotasyon yöntemine dönülüyor.\",\n );\n eskiRotasyonaDon();\n } else {\n try {\n const allCodes = Array.from(\n new Set([\n ...AL_HAVUZU,\n ...VIOP_AGRESIF_HAVUZU,\n ...VIOP_MUHAFAZAKAR_HAVUZU,\n ]),\n );\n const sinceISO = isoDaysAgoTR(TEKNIK_PENCERE_GUN);\n const histMap = await fetchPriceHistory(\n serviceRoleKey,\n allCodes,\n sinceISO,\n );\n\n const alSonuc = rankByMomentum(AL_HAVUZU_UYGUN, histMap, 5);\n alSecili = alSonuc.picked;\n const aggSonuc = rankByVolatility(\n VIOP_AGRESIF_HAVUZU,\n histMap,\n 5,\n \"high\",\n );\n aggFinal = aggSonuc.picked;\n const conSonuc = rankByVolatility(\n VIOP_MUHAFAZAKAR_HAVUZU,\n histMap,\n 5,\n \"low\",\n );\n conFinal = conSonuc.picked;\n\n console.log(\n `Teknik sinyal hesaplandı (pencere: son ${TEKNIK_PENCERE_GUN} gün). ` +\n `AL: ${alSonuc.fallbackUsed} slot rotasyonla dolduruldu (veri yetersiz). ` +\n `VİOP-Yüksek: ${aggSonuc.fallbackUsed} slot rotasyonla. VİOP-Düşük: ${conSonuc.fallbackUsed} slot rotasyonla.`,\n );\n } catch (e) {\n console.log(\n \"Teknik sinyal hesaplama hatası, eski rotasyon yöntemine dönülüyor:\",\n String(e),\n );\n eskiRotasyonaDon();\n }\n }\n\n const final = {\n updatedAt: today,\n items: alSecili!.map((code) => ({ code, name: nameOf(code), tag: \"AL\" })),\n satItems: SAT_LISTESI.map(({ code, sourceCount }) => ({\n code,\n name: nameOf(code),\n tag: \"SAT\",\n sourceCount,\n })),\n viop: {\n updatedAt: today,\n aggressive: aggFinal!.map(({ code, scoreDisplay }) => ({\n code,\n name: nameOf(code),\n score: scoreDisplay,\n })),\n conservative: conFinal!.map(({ code, scoreDisplay }) => ({\n code,\n name: nameOf(code),\n score: scoreDisplay,\n })),\n },\n };\n\n // Bildirimler için, ÜZERİNE YAZMADAN ÖNCE dünkü veriyi oku.\n let previous: typeof final | null = null;\n try {\n previous = (await blob.getJSON(STORAGE_KEY)) as typeof final | null;\n } catch (_e) {}\n\n await blob.setJSON(STORAGE_KEY, final);\n\n // ---- Push bildirimleri: liste giriş/çıkışlarını bul ve gönder ----\n try {\n const projectId = Deno.env.get(\"FCM_PROJECT_ID\");\n const clientEmail = Deno.env.get(\"FCM_CLIENT_EMAIL\");\n const privateKey = Deno.env.get(\"FCM_PRIVATE_KEY\");\n if (!projectId || !clientEmail || !privateKey) {\n console.log(\n \"FCM_PROJECT_ID / FCM_CLIENT_EMAIL / FCM_PRIVATE_KEY eksik — push bildirimleri atlandı.\",\n );\n } else {\n const sa: ServiceAccount = {\n project_id: projectId,\n client_email: clientEmail,\n private_key: privateKey,\n token_uri: \"https://oauth2.googleapis.com/token\",\n };\n const accessToken = await getAccessToken(sa);\n\n const alDiff = diffCodes(previous?.items, final.items);\n const satDiff = diffCodes(previous?.satItems, final.satItems);\n const aggDiff = diffCodes(\n previous?.viop?.aggressive,\n final.viop.aggressive,\n );\n const conDiff = diffCodes(\n previous?.viop?.conservative,\n final.viop.conservative,\n );\n\n const jobs: Array<() => Promise> = [];\n for (const code of alDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} bugünkü AL listesine girdi`,\n { code, type: \"al_entry\" },\n )\n );\n }\n for (const code of alDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} AL listesinden çıktı`,\n { code, type: \"al_exit\" },\n )\n );\n }\n for (const code of satDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} bugünkü SAT/Azalt listesine girdi`,\n { code, type: \"sat_entry\" },\n )\n );\n }\n for (const code of satDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} SAT/Azalt listesinden çıktı`,\n { code, type: \"sat_exit\" },\n )\n );\n }\n for (const code of aggDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Yüksek listesine girdi`,\n { code, type: \"viop_agg_entry\" },\n )\n );\n }\n for (const code of aggDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Yüksek listesinden çıktı`,\n { code, type: \"viop_agg_exit\" },\n )\n );\n }\n for (const code of conDiff.entries) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Düşük listesine girdi`,\n { code, type: \"viop_con_entry\" },\n )\n );\n }\n for (const code of conDiff.exits) {\n jobs.push(() =>\n sendTopicPush(\n accessToken,\n projectId,\n \"hisse_\" + code,\n \"Hisse Takip\",\n `${code} VİOP Volatilitesi Düşük listesinden çıktı`,\n { code, type: \"viop_con_exit\" },\n )\n );\n }\n\n console.log(`Push: ${jobs.length} bildirim gönderilecek.`);\n for (const job of jobs) {\n try {\n await job();\n } catch (e) {\n console.log(\"Tekil push hatası:\", String(e));\n }\n }\n }\n } catch (e) {\n console.log(\"Push bildirim bloğu genel hata:\", String(e));\n }\n\n console.log(\n `Hisse öneriler güncellendi: ${today} — ${final.items.length} AL, ${final.satItems.length} SAT, ${final.viop.aggressive.length} agresif VİOP, ${final.viop.conservative.length} muhafazakâr VİOP.`,\n );\n return final;\n}","createdAt",["D",1788729550319],"branchVersion","branchId","0b4a4214-5135-442d-8ed6-3a45ef3c2f3a","id","6fcae7ea-aa84-432b-9789-ab317d84e01f","HISSE-GUNCEL",["D",1788503834494],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","9369fb07-940d-43a1-9c9b-bcb3073cb82b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a054b3-b67d-7156-85d3-7dd40b0cfe04","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",13,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","erkancavdaroglu","handle","displayName","Erkan Çavdaroğlu","avatar","https://lh3.googleusercontent.com/a/ACg8ocKWeW9Gqj4zojrCQIad1hYkesysiVRx4L2RaDdHPq79p-XPY7BJ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":151,"_79":152,"_81":153,"_83":25},"tree",[145],"files",[145],"counts",{"_133":61,"_134":135,"_136":61,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"245a7444-e54d-4984-b9f9-a43f8a0344cb","parentId","latest",["D",1788729550319],11,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":61},"connections",{"_141":61,"_142":61},"count","unfilledCount",5,"emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1788729550319],"children",[],[28],["D",1788503834494],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":196,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_158":159,"_160":161,"_162":85,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v12