[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_150":151,"_152":153},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_88":-7,"_89":43,"_29":-7,"_90":-5,"_15":91,"_92":93,"_94":95,"_96":97,"_98":99,"_100":-5,"_101":-5,"_102":-5,"_103":38,"_104":105,"_106":38,"_107":-5,"_108":-5,"_109":110},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","erkancavdaroglu","name","hisse-alarm","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60,"_61":60,"_62":63,"_64":63,"_65":63,"_66":60,"_67":60,"_68":69,"_70":71,"_72":73,"_74":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","e86f4f7c-7415-472a-8a61-43ee48122ef7","createdAt",["D",1788608552271],"updatedAt",["D",1788626650376],"main","projectId","07512d90-35a4-4ca0-9975-bee0f65b27dd","version",9,"forkedBranchId","forkedBranchVersion","lockfileKey","1788626650514-esm.town_v_erkancavdaroglu_hisse-alarm@9-main","deletedAt",["D",1788608552271],"legacyEnvVars",false,"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",{"_11":12,"_87":83},"org",{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Erkan Çavdaroğlu","avatar","https://lh3.googleusercontent.com/a/ACg8ocKWeW9Gqj4zojrCQIad1hYkesysiVRx4L2RaDdHPq79p-XPY7BJ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_20":28,"_13":14,"_22":146,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60,"_61":60,"_62":63,"_64":63,"_65":63,"_66":60,"_67":60,"_68":147,"_70":148,"_72":149,"_74":38},"tree",[141],"files",[141],"counts",{"_130":52,"_17":131,"_132":52,"_133":134,"_135":136},"contents",[111],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_20":112,"_13":113,"_114":115,"_116":-5,"_117":21,"_118":30,"_119":120,"_22":121,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_89":129},"ced91713-9d91-48b7-85b8-2258bb9b42e3","main.ts","fileId","e1878754-a91e-11f1-8de0-1607ee4eb77e","parentId","branchId","branchVersion","latest",true,["D",1788626650376],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","label",[113],"pulls",1,"forks","envVars",{"_137":139,"_140":52},"connections",{"_137":52,"_138":52},"count","unfilledCount",7,"emptyCount",{"_20":112,"_13":113,"_114":115,"_116":-5,"_117":21,"_118":30,"_119":120,"_22":142,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_143":144,"_89":145},["D",1788626650376],"children",[],[113],["D",1788608552271],{"_11":12,"_87":83},{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"ctx",{"_68":-5,"_108":183,"_184":185,"_186":187,"_188":38,"_189":38,"_190":38,"_191":120,"_192":-5,"_193":-7,"_194":-7,"_195":52,"_196":38,"_197":38,"_198":-5,"_199":38,"_200":38,"_201":38,"_202":-5},"ENV",{"_154":155,"_156":157,"_158":26,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182},"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","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1