[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_102":103,"_104":105},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","erkancavdaroglu","name","hisse-alarm","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":-5,"_58":42,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/erkancavdaroglu/hisse-alarm/code/main.ts","extension","id","ced91713-9d91-48b7-85b8-2258bb9b42e3","fileId","e1878754-a91e-11f1-8de0-1607ee4eb77e","parentId","branchId","e86f4f7c-7415-472a-8a61-43ee48122ef7","branchVersion",9,"latest",true,"createdAt",["D",1788626650376],"version",8,"fileType","interval","content","// ============================================================================\n// HİSSE TAKİP — FİYAT DEĞİŞİM BİLDİRİMİ (SAATLİK CRON VAL)\n// ============================================================================\n// Bu, MEVCUT \"hisse-oneriler-cron-v2.ts\" val'ının YERİNE geçmiyor — o val\n// günde 1 kez (07:00 TR) çalışıp AL/SAT/VİOP listelerini güncelliyor ve\n// listeye giriş/çıkışlarda bildirim gönderiyor. BU dosya ise val.town'da\n// AYRI, YENİ bir Cron val olarak kurulacak ve BIST işlem saatlerinde saatte\n// bir çalışıp kullanıcıların favori hisselerinde girdikleri %artış/%azalış\n// eşiğini kontrol edip aşıldığında bildirim gönderecek.\n//\n// KURULUM:\n// 1. val.town'da YENİ bir Cron val oluştur (mevcut \"hisse-oneriler-cron-v2\"\n// val'ına dokunma, o ayrı ve olduğu gibi kalmalı).\n// 2. Bu dosyanın tamamını o yeni val'ın Code sekmesine yapıştır.\n// 3. Zamanlama: 0 7-15 * * 1-5 (BIST işlem saatleri 10:00-18:00 TR =\n// 07:00-15:00 UTC, hafta içi, saat başı — Türkiye artık DST kullanmıyor,\n// yıl boyu UTC+3 sabit).\n// 4. Aşağıdaki YENİ ortam değişkenlerini val.town hesap ayarlarında\n// (Settings > Environment Variables) ekle:\n// COLLECTAPI_KEY — CollectAPI \"Altın, Döviz ve Borsa API\"\n// anahtarın (Basic/9$ plana geçtiğinde de\n// aynı anahtar geçerli olacak, değişmez).\n// SUPABASE_SERVICE_ROLE_KEY — Supabase projendeki (Project Settings >\n// API > \"service_role\" secret) anahtar.\n// BU ÇOK HASSAS bir anahtardır — tüm\n// veritabanına RLS'i atlayarak erişim\n// verir. SADECE buraya (val.town env var)\n// yapıştır, asla uygulama koduna (client)\n// veya başka bir yere KOYMA.\n// Mevcut FCM_PROJECT_ID / FCM_CLIENT_EMAIL / FCM_PRIVATE_KEY zaten\n// hesabında kayıtlı olduğu için tekrar eklemene gerek yok, bu val onları\n// aynı şekilde okuyacak.\n// 5. Supabase SQL Editor'da bir kere şunu çalıştırıp \"price_alerts\"\n// tablosunu oluştur (henüz yoksa):\n//\n// create table if not exists public.price_alerts (\n// user_id uuid not null references auth.users(id) on delete cascade,\n// stock_code text not null,\n// stock_name text not null,\n// threshold_up numeric,\n// threshold_down numeric,\n// last_alert_date date,\n// updated_at timestamptz not null default now(),\n// primary key (user_id, stock_code)\n// );\n// alter table public.price_alerts enable row level security;\n// create policy \"Users can manage their own price alerts\"\n// on public.price_alerts for all\n// using (auth.uid() = user_id)\n// with check (auth.uid() = user_id);\n//\n// ÖNEMLİ VARSAYIM (ilk test çalıştırmasında MUTLAKA doğrula):\n// CollectAPI'nin /economy/liveBorsa endpoint'i her hisse için bir \"rate\"\n// alanı döndürüyor (\"Anlık olarak borsada tüm endekslerdeki değerlerin\n// DEĞİŞİMLERİNİ gösteren servis\" açıklamasına göre). Bunun GÜNLÜK YÜZDE\n// DEĞİŞİM olduğunu ve düşüşlerde NEGATİF değer döndüğünü varsayıyoruz\n// (ör. -3.2 = %3.2 düşüş). Bu doğrulanmadı — ilk çalıştırmada aşağıdaki\n// console.log çıktısında o an düşüşte olan bilinen bir hisseye (ör. o gün\n// kırmızıda olan bir BIST30 hissesi) bakıp \"rate\" gerçekten negatif mi\n// kontrol et. Değilse (ör. hep pozitif ve ayrı bir yön alanı gerekiyorsa)\n// haber ver, mantığı ona göre düzeltirim.\n// ============================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst SUPABASE_URL = \"https://uqkwmrwzcslessuopcrv.supabase.co\";\nconst COLLECTAPI_URL = \"https://api.collectapi.com/economy/liveBorsa\";\nconst ALERTED_TODAY_KEY = \"hisse-fiyat-alarm-son-tarih\"; // yedek/log amaçlı, asıl dedup Supabase'de\n\nfunction todayISOTR(): string {\n const parts = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Europe/Istanbul\", year: \"numeric\", month: \"2-digit\", day: \"2-digit\",\n }).formatToParts(new Date());\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// ---------------------------------------------------------------------------\n// FCM (Firebase Cloud Messaging) — hisse-oneriler-cron-v2.ts ile birebir aynı\n// yardımcı fonksiyonlar (kopyalandı, çünkü val.town val'ları birbirinin\n// kodunu import edemiyor — her val kendi içinde bağımsız).\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))}.${base64url(JSON.stringify(claims))}`;\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 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({ message: { topic, notification: { title, body }, data } }),\n },\n );\n const rawText = await resp.text().catch(() => \"\");\n if (!resp.ok) {\n console.log(`FCM gönderim hatası (${topic}) — HTTP ${resp.status}: ${rawText}`);\n return false;\n }\n console.log(`FCM gönderildi: ${topic} — ${body}`);\n return true;\n}\n\n// ---------------------------------------------------------------------------\n// CollectAPI — canlı BIST fiyat/değişim verisi\n// ---------------------------------------------------------------------------\n\ntype LiveBorsaItem = { currency: string; name: string; pricestr: string; price: number; rate: number; time: string };\n\nasync function fetchLiveBorsa(apiKey: string): Promise> {\n const resp = await fetch(COLLECTAPI_URL, {\n method: \"GET\",\n headers: {\n \"authorization\": `apikey ${apiKey}`,\n \"content-type\": \"application/json\",\n },\n });\n const json = await resp.json().catch(() => ({}));\n if (!resp.ok || !json.success || !Array.isArray(json.result)) {\n throw new Error(\"CollectAPI liveBorsa hatası: \" + JSON.stringify(json).slice(0, 500));\n }\n const map = new Map();\n for (const item of json.result as LiveBorsaItem[]) {\n map.set(item.name, item);\n }\n return map;\n}\n\n// ---------------------------------------------------------------------------\n// Supabase — price_alerts tablosunu service_role anahtarıyla oku/güncelle\n// (RLS'i bypass eder, bu yüzden anahtar ÇOK hassas)\n// ---------------------------------------------------------------------------\n\ntype PriceAlertRow = {\n user_id: string;\n stock_code: string;\n stock_name: string;\n threshold_up: number | null;\n threshold_down: number | null;\n last_alert_date: string | null;\n};\n\nasync function fetchAllPriceAlerts(serviceRoleKey: string): Promise {\n const resp = await fetch(`${SUPABASE_URL}/rest/v1/price_alerts?select=*`, {\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(`Supabase price_alerts okuma hatası (${resp.status}): ${text.slice(0, 500)}`);\n }\n return (await resp.json()) as PriceAlertRow[];\n}\n\nasync function markAlertedToday(serviceRoleKey: string, userId: string, code: string, dateISO: string) {\n const url = `${SUPABASE_URL}/rest/v1/price_alerts?user_id=eq.${encodeURIComponent(userId)}&stock_code=eq.${encodeURIComponent(code)}`;\n const resp = await fetch(url, {\n method: \"PATCH\",\n headers: {\n \"apikey\": serviceRoleKey,\n \"authorization\": `Bearer ${serviceRoleKey}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({ last_alert_date: dateISO }),\n });\n if (!resp.ok) {\n console.log(`Supabase last_alert_date güncelleme hatası (${userId}/${code}):`, await resp.text().catch(() => \"\"));\n }\n}\n\n// ---------------------------------------------------------------------------\n// \"Takip Listem\" ekranındaki 10-gün-önce / güncel fiyat karşılaştırması için\n// her çalıştırmada gördüğümüz tüm hisselerin fiyatını price_history tablosuna\n// yazıyoruz (aynı gün için üzerine yazar — günün son çalıştırması o günün\n// kapanışa en yakın fiyatı olur, çünkü zamanlama BIST kapanışına kadar sürüyor).\n// ---------------------------------------------------------------------------\n\nasync function upsertPriceHistory(serviceRoleKey: string, dateISO: string, liveData: Map) {\n const rows = Array.from(liveData.entries()).map(([code, item]) => ({\n trade_date: dateISO,\n stock_code: code,\n close_price: item.price,\n }));\n if (!rows.length) return;\n const resp = await fetch(`${SUPABASE_URL}/rest/v1/price_history?on_conflict=trade_date,stock_code`, {\n method: \"POST\",\n headers: {\n \"apikey\": serviceRoleKey,\n \"authorization\": `Bearer ${serviceRoleKey}`,\n \"content-type\": \"application/json\",\n \"prefer\": \"resolution=merge-duplicates\",\n },\n body: JSON.stringify(rows),\n });\n if (!resp.ok) {\n const text = await resp.text().catch(() => \"\");\n console.log(`price_history yazma hatası (${resp.status}): ${text.slice(0, 300)}`);\n } else {\n console.log(`price_history güncellendi: ${rows.length} hisse, tarih ${dateISO}.`);\n }\n}\n\n// ---------------------------------------------------------------------------\n\nexport default async function () {\n const collectApiKey = Deno.env.get(\"COLLECTAPI_KEY\");\n const serviceRoleKey = Deno.env.get(\"SUPABASE_SERVICE_ROLE_KEY\");\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\n if (!collectApiKey) { console.log(\"COLLECTAPI_KEY eksik — durduruldu.\"); return { ok: false }; }\n if (!serviceRoleKey) { console.log(\"SUPABASE_SERVICE_ROLE_KEY eksik — durduruldu.\"); return { ok: false }; }\n if (!projectId || !clientEmail || !privateKey) { console.log(\"FCM env var'ları eksik — durduruldu.\"); return { ok: false }; }\n\n const today = todayISOTR();\n\n const liveData = await fetchLiveBorsa(collectApiKey);\n console.log(`CollectAPI'den ${liveData.size} hisse verisi alındı.`);\n\n await upsertPriceHistory(serviceRoleKey, today, liveData);\n\n const alerts = await fetchAllPriceAlerts(serviceRoleKey);\n console.log(`Supabase'de ${alerts.length} favori/eşik kaydı bulundu.`);\n\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 let sent = 0;\n for (const row of alerts) {\n if (row.last_alert_date === today) {\n console.log(`[debug] ${row.stock_code}: bugün zaten bildirim gönderilmiş, atlanıyor.`);\n continue;\n }\n if (row.threshold_up == null && row.threshold_down == null) {\n console.log(`[debug] ${row.stock_code}: eşik girilmemiş, atlanıyor.`);\n continue;\n }\n\n const item = liveData.get(row.stock_code);\n if (!item) {\n console.log(`[debug] ${row.stock_code}: CollectAPI'nin döndürdüğü listede bulunamadı (${liveData.size} hisse arasında).`);\n continue;\n }\n const rate = item.rate;\n console.log(`[debug] ${row.stock_code}: rate=${rate}, threshold_up=${row.threshold_up}, threshold_down=${row.threshold_down}`);\n\n let direction: \"up\" | \"down\" | null = null;\n if (row.threshold_up != null && rate >= row.threshold_up) direction = \"up\";\n else if (row.threshold_down != null && rate <= -row.threshold_down) direction = \"down\";\n if (!direction) {\n console.log(`[debug] ${row.stock_code}: eşik aşılmadı, bildirim gönderilmiyor.`);\n continue;\n }\n\n const topic = \"user_\" + row.user_id;\n const body = direction === \"up\"\n ? `${row.stock_code} bugün %${rate.toFixed(2)} yükseldi (senin eşiğin: %${row.threshold_up})`\n : `${row.stock_code} bugün %${Math.abs(rate).toFixed(2)} düştü (senin eşiğin: %${row.threshold_down})`;\n\n const ok = await sendTopicPush(accessToken, projectId, topic, \"Hisse Takip — Fiyat Alarmı\", body, {\n code: row.stock_code, type: direction === \"up\" ? \"price_up\" : \"price_down\", rate: String(rate),\n });\n if (ok) {\n await markAlertedToday(serviceRoleKey, row.user_id, row.stock_code, today);\n sent++;\n }\n }\n\n console.log(`Fiyat alarmı taraması tamamlandı: ${sent} bildirim gönderildi.`);\n try { await blob.setJSON(ALERTED_TODAY_KEY, { date: today, sent }); } catch (_e) {}\n return { ok: true, checked: alerts.length, sent };\n}","deleted",false,"label",[14],"07512d90-35a4-4ca0-9975-bee0f65b27dd",["D",1788608552271],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","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",{"_9":10,"_101":97},"org",{"_9":10,"_94":95,"_96":97,"_55":56,"_98":99,"_100":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Erkan Çavdaroğlu","avatar","https://lh3.googleusercontent.com/a/ACg8ocKWeW9Gqj4zojrCQIad1hYkesysiVRx4L2RaDdHPq79p-XPY7BJ=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_135":136,"_137":138,"_139":140,"_141":42,"_142":42,"_143":42,"_144":32,"_145":-5,"_146":-7,"_147":-7,"_148":62,"_149":42,"_150":42,"_151":-5,"_152":42,"_153":42,"_154":42,"_155":-5},"ENV",{"_106":107,"_108":109,"_110":85,"_111":112,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]