[{"_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",{"_94":93,"_32":45,"_103":84,"_27":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":25,"_120":-5,"_121":-5,"_122":123},"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",5,"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","cc0395d0-a658-11f1-bed9-1607ee4eb77e","name","fileType","interval","content","// Hisse Takip — KAP/haber bildirim görevi\n// val.town'da \"Cron\" tetikleyicili bir val olarak çalışır.\n// Gerekli ortam değişkenleri (val.town'da tanımlanmalı): SUPABASE_SECRET_KEY, RESEND_API_KEY\n\nexport default async function (interval) {\n const SUPABASE_URL = \"https://uqkwmrwzcslessuopcrv.supabase.co\";\n const SUPABASE_SECRET_KEY = Deno.env.get(\"SUPABASE_SECRET_KEY\");\n const RESEND_API_KEY = Deno.env.get(\"RESEND_API_KEY\");\n const KAP_PROXY_URL = \"https://kap-proxy.val.run\";\n const FROM_EMAIL = \"Hisse Takip \";\n\n const sbHeaders = {\n apikey: SUPABASE_SECRET_KEY,\n Authorization: `Bearer ${SUPABASE_SECRET_KEY}`,\n \"Content-Type\": \"application/json\",\n };\n\n // 1) Tüm kullanıcıların takip listesini çek (secret key ile, RLS atlanır)\n const wlRes = await fetch(\n `${SUPABASE_URL}/rest/v1/watchlist?select=user_id,user_email,stock_code,stock_name`,\n { headers: sbHeaders },\n );\n if (!wlRes.ok) throw new Error(\"watchlist çekilemedi: \" + wlRes.status);\n const watchlist = await wlRes.json();\n if (!Array.isArray(watchlist) || watchlist.length === 0) {\n return { stocksChecked: 0, emailsSent: 0, note: \"takip listesi boş\" };\n }\n\n // Hisse kodu -> { name, users: [{id, email}] }\n const byStock = new Map();\n for (const row of watchlist) {\n if (!byStock.has(row.stock_code)) {\n byStock.set(row.stock_code, { name: row.stock_name, users: [] });\n }\n byStock.get(row.stock_code).users.push({\n id: row.user_id,\n email: row.user_email,\n });\n }\n\n // 2) Daha önce hangi öğeler için bildirim gönderildiğini çek (tekrar göndermemek için)\n const logRes = await fetch(\n `${SUPABASE_URL}/rest/v1/notified_log?select=user_id,stock_code,item_key`,\n { headers: sbHeaders },\n );\n const notifiedRows = logRes.ok ? await logRes.json() : [];\n const notifiedSet = new Set(\n notifiedRows.map((r) => `${r.user_id}|${r.stock_code}|${r.item_key}`),\n );\n\n // Kullanıcı bazlı toplama: her kullanıcıya TEK e-posta (birden çok hisse için tek seferde)\n const perUser = new Map(); // user_id -> { email, items: [] }\n const newLogRows = [];\n\n for (const [code, info] of byStock) {\n // --- KAP bildirimleri ---\n let kapItems = [];\n try {\n const r = await fetch(\n `${KAP_PROXY_URL}?code=${encodeURIComponent(code)}`,\n );\n if (r.ok) {\n const d = await r.json();\n if (Array.isArray(d.items)) kapItems = d.items;\n }\n } catch (_e) {\n // KAP alınamadıysa bu turu atla, bir sonraki çalıştırmada tekrar denenir\n }\n\n // --- Haberler (Google Haberler RSS — sunucu tarafında CORS sorunu yok, doğrudan çekiliyor) ---\n let newsItems = [];\n try {\n const q = encodeURIComponent(\n `\"${info.name}\" (hisse OR BIST OR borsa OR şirket OR hedef fiyat)`,\n );\n const rssUrl =\n `https://news.google.com/rss/search?q=${q}&hl=tr-TR&gl=TR&ceid=TR:tr`;\n const r = await fetch(rssUrl);\n if (r.ok) {\n const xml = await r.text();\n newsItems = parseRssItems(xml).slice(0, 5);\n }\n } catch (_e) {\n // haber alınamadıysa devam et\n }\n\n const candidates = [\n ...kapItems\n .filter((it) => it.link)\n .map((it) => ({\n code,\n name: info.name,\n type: \"KAP\",\n title: it.subject || it.title || \"KAP Bildirimi\",\n link: it.link,\n date: it.date || \"\",\n })),\n ...newsItems\n .filter((it) => it.link)\n .map((it) => ({\n code,\n name: info.name,\n type: \"Haber\",\n title: it.title,\n link: it.link,\n date: it.pubDate || \"\",\n })),\n ];\n if (!candidates.length) continue;\n\n for (const user of info.users) {\n const newOnes = candidates.filter((it) =>\n !notifiedSet.has(`${user.id}|${code}|${it.link}`)\n );\n if (!newOnes.length) continue;\n if (!perUser.has(user.id)) {\n perUser.set(user.id, { email: user.email, items: [] });\n }\n perUser.get(user.id).items.push(...newOnes);\n for (const it of newOnes) {\n newLogRows.push({\n user_id: user.id,\n stock_code: code,\n item_key: it.link,\n });\n }\n }\n }\n\n // 3) Her kullanıcıya toplu bir e-posta gönder\n let emailsSent = 0;\n for (const [, data] of perUser) {\n const html = buildEmailHtml(data.items);\n const res = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${RESEND_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: FROM_EMAIL,\n to: data.email,\n subject: `Hisse Takip: ${data.items.length} yeni bildirim`,\n html,\n }),\n });\n if (res.ok) emailsSent++;\n }\n\n // 4) Gönderilenleri işaretle (bir sonraki çalıştırmada tekrar gönderilmesin diye)\n if (newLogRows.length) {\n await fetch(`${SUPABASE_URL}/rest/v1/notified_log`, {\n method: \"POST\",\n headers: { ...sbHeaders, Prefer: \"resolution=ignore-duplicates\" },\n body: JSON.stringify(newLogRows),\n });\n }\n\n return {\n stocksChecked: byStock.size,\n usersNotified: perUser.size,\n emailsSent,\n };\n}\n\nfunction buildEmailHtml(items) {\n const rows = items\n .map(\n (it) => `\n \n \n

${it.type} · ${it.code}

\n ${\n escapeHtml(it.title)\n }\n

${\n escapeHtml(it.date)\n }

\n \n `,\n )\n .join(\"\");\n return `\n

📈 Hisse Takip — Yeni Gelişmeler

Takip ettiğin hisselerle ilgili yeni KAP bildirimi/haber var:

\n ${rows}

Bu e-posta AI destekli bir bilgilendirme aracıdır, kesinlikle yatırım tavsiyesi değildir.

`;\n}\n\nfunction escapeHtml(s) {\n return (s || \"\").replace(/&/g, \"&\").replace(//g,\n \">\",\n );\n}\n\nfunction parseRssItems(xml) {\n const items = [];\n const itemRegex = /([\\s\\S]*?)<\\/item>/g;\n let m;\n while ((m = itemRegex.exec(xml))) {\n const block = m[1];\n const rawTitle = extractTag(block, \"title\");\n const link = extractTag(block, \"link\");\n const pubDate = extractTag(block, \"pubDate\");\n items.push({ title: cleanTitle(decodeEntities(rawTitle)), link, pubDate });\n }\n return items;\n}\nfunction extractTag(block, tag) {\n const m = new RegExp(`<${tag}>([\\\\s\\\\S]*?)<\\\\/${tag}>`).exec(block);\n if (!m) return \"\";\n return m[1].replace(/^$/, \"\").trim();\n}\nfunction decodeEntities(s) {\n return s.replace(/&/g, \"&\").replace(/</g, \"<\").replace(/>/g, \">\")\n .replace(/"/g, '\"').replace(/'/g, \"'\");\n}\nfunction cleanTitle(title) {\n const idx = title.lastIndexOf(\" - \");\n return idx > 0 ? title.slice(0, idx) : title;\n}","// Hisse Takip — KAP/haber bildirim görevi\n// val.town'da \"Cron\" tetikleyicili bir val olarak çalışır.\n// Gerekli ortam değişkenleri (val.town'da tanımlanmalı): SUPABASE_SECRET_KEY, RESEND_API_KEY\n\nexport default async function (interval) {\n const SUPABASE_URL = \"https://uqkwmrwzcslessuopcrv.supabase.co\";\n const SUPABASE_SECRET_KEY = Deno.env.get(\"SUPABASE_SECRET_KEY\");\n const RESEND_API_KEY = Deno.env.get(\"RESEND_API_KEY\");\n const KAP_PROXY_URL = \"https://kap-proxy.val.run\";\n const FROM_EMAIL = \"Hisse Takip \";\n\n const sbHeaders = {\n apikey: SUPABASE_SECRET_KEY,\n Authorization: `Bearer ${SUPABASE_SECRET_KEY}`,\n \"Content-Type\": \"application/json\",\n };\n\n // 1) Tüm kullanıcıların takip listesini çek (secret key ile, RLS atlanır)\n const wlRes = await fetch(\n `${SUPABASE_URL}/rest/v1/watchlist?select=user_id,user_email,stock_code,stock_name`,\n { headers: sbHeaders },\n );\n if (!wlRes.ok) throw new Error(\"watchlist çekilemedi: \" + wlRes.status);\n const watchlist = await wlRes.json();\n if (!Array.isArray(watchlist) || watchlist.length === 0) {\n return { stocksChecked: 0, emailsSent: 0, note: \"takip listesi boş\" };\n }\n\n // Hisse kodu -> { name, users: [{id, email}] }\n const byStock = new Map();\n for (const row of watchlist) {\n if (!byStock.has(row.stock_code)) {\n byStock.set(row.stock_code, { name: row.stock_name, users: [] });\n }\n byStock.get(row.stock_code).users.push({\n id: row.user_id,\n email: row.user_email,\n });\n }\n\n // 2) Daha önce hangi öğeler için bildirim gönderildiğini çek (tekrar göndermemek için)\n const logRes = await fetch(\n `${SUPABASE_URL}/rest/v1/notified_log?select=user_id,stock_code,item_key`,\n { headers: sbHeaders },\n );\n const notifiedRows = logRes.ok ? await logRes.json() : [];\n const notifiedSet = new Set(\n notifiedRows.map((r) => `${r.user_id}|${r.stock_code}|${r.item_key}`),\n );\n\n // Kullanıcı bazlı toplama: her kullanıcıya TEK e-posta (birden çok hisse için tek seferde)\n const perUser = new Map(); // user_id -> { email, items: [] }\n const newLogRows = [];\n\n for (const [code, info] of byStock) {\n // --- KAP bildirimleri ---\n let kapItems = [];\n try {\n const r = await fetch(\n `${KAP_PROXY_URL}?code=${encodeURIComponent(code)}`,\n );\n if (r.ok) {\n const d = await r.json();\n if (Array.isArray(d.items)) kapItems = d.items;\n }\n } catch (_e) {\n // KAP alınamadıysa bu turu atla, bir sonraki çalıştırmada tekrar denenir\n }\n\n // --- Haberler (Google Haberler RSS — sunucu tarafında CORS sorunu yok, doğrudan çekiliyor) ---\n let newsItems = [];\n try {\n const q = encodeURIComponent(\n `\"${info.name}\" (hisse OR BIST OR borsa OR şirket OR hedef fiyat)`,\n );\n const rssUrl =\n `https://news.google.com/rss/search?q=${q}&hl=tr-TR&gl=TR&ceid=TR:tr`;\n const r = await fetch(rssUrl);\n if (r.ok) {\n const xml = await r.text();\n newsItems = parseRssItems(xml).slice(0, 5);\n }\n } catch (_e) {\n // haber alınamadıysa devam et\n }\n\n const candidates = [\n ...kapItems\n .filter((it) => it.link)\n .map((it) => ({\n code,\n name: info.name,\n type: \"KAP\",\n title: it.subject || it.title || \"KAP Bildirimi\",\n link: it.link,\n date: it.date || \"\",\n })),\n ...newsItems\n .filter((it) => it.link)\n .map((it) => ({\n code,\n name: info.name,\n type: \"Haber\",\n title: it.title,\n link: it.link,\n date: it.pubDate || \"\",\n })),\n ];\n if (!candidates.length) continue;\n\n for (const user of info.users) {\n const newOnes = candidates.filter((it) =>\n !notifiedSet.has(`${user.id}|${code}|${it.link}`)\n );\n if (!newOnes.length) continue;\n if (!perUser.has(user.id)) {\n perUser.set(user.id, { email: user.email, items: [] });\n }\n perUser.get(user.id).items.push(...newOnes);\n for (const it of newOnes) {\n newLogRows.push({\n user_id: user.id,\n stock_code: code,\n item_key: it.link,\n });\n }\n }\n }\n\n // 3) Her kullanıcıya toplu bir e-posta gönder\n let emailsSent = 0;\n for (const [, data] of perUser) {\n const html = buildEmailHtml(data.items);\n const res = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${RESEND_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: FROM_EMAIL,\n to: data.email,\n subject: `Hisse Takip: ${data.items.length} yeni bildirim`,\n html,\n }),\n });\n if (res.ok) emailsSent++;\n }\n\n // 4) Gönderilenleri işaretle (bir sonraki çalıştırmada tekrar gönderilmesin diye)\n if (newLogRows.length) {\n await fetch(`${SUPABASE_URL}/rest/v1/notified_log`, {\n method: \"POST\",\n headers: { ...sbHeaders, Prefer: \"resolution=ignore-duplicates\" },\n body: JSON.stringify(newLogRows),\n });\n }\n\n const result = {\n stocksChecked: byStock.size,\n usersNotified: perUser.size,\n emailsSent,\n };\n console.log(\"Hisse Takip bildirim görevi sonucu:\", JSON.stringify(result));\n return result;\n}\n\nfunction buildEmailHtml(items) {\n const rows = items\n .map(\n (it) => `\n \n \n

${it.type} · ${it.code}

\n ${\n escapeHtml(it.title)\n }\n

${\n escapeHtml(it.date)\n }

\n \n `,\n )\n .join(\"\");\n return `\n

📈 Hisse Takip — Yeni Gelişmeler

Takip ettiğin hisselerle ilgili yeni KAP bildirimi/haber var:

\n ${rows}

Bu e-posta AI destekli bir bilgilendirme aracıdır, kesinlikle yatırım tavsiyesi değildir.

`;\n}\n\nfunction escapeHtml(s) {\n return (s || \"\").replace(/&/g, \"&\").replace(//g,\n \">\",\n );\n}\n\nfunction parseRssItems(xml) {\n const items = [];\n const itemRegex = /([\\s\\S]*?)<\\/item>/g;\n let m;\n while ((m = itemRegex.exec(xml))) {\n const block = m[1];\n const rawTitle = extractTag(block, \"title\");\n const link = extractTag(block, \"link\");\n const pubDate = extractTag(block, \"pubDate\");\n items.push({ title: cleanTitle(decodeEntities(rawTitle)), link, pubDate });\n }\n return items;\n}\nfunction extractTag(block, tag) {\n const m = new RegExp(`<${tag}>([\\\\s\\\\S]*?)<\\\\/${tag}>`).exec(block);\n if (!m) return \"\";\n return m[1].replace(/^$/, \"\").trim();\n}\nfunction decodeEntities(s) {\n return s.replace(/&/g, \"&\").replace(/</g, \"<\").replace(/>/g, \">\")\n .replace(/"/g, '\"').replace(/'/g, \"'\");\n}\nfunction cleanTitle(title) {\n const idx = title.lastIndexOf(\" - \");\n return idx > 0 ? title.slice(0, idx) : title;\n}","createdAt",["D",1788304891985],"branchVersion","branchId","a1306370-a402-41b6-b8e5-921b7ac16e08","id","774b37b4-75b9-47d7-90ef-a9dfb1ce5a72","hisse-bildirim",["D",1788303573503],"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",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned","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",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":128,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"426f7f1c-af4c-45ef-9815-f7a8cb55f39d","parentId","latest",true,["D",1788304891985],4,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":61},"connections",{"_141":61,"_142":61},"count","unfilledCount",2,"emptyCount",{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":128,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1788304891985],"children",[],[28],["D",1788303573503],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_77":-5,"_121":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":128,"_196":-5,"_197":-7,"_198":-7,"_199":61,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":84,"_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","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v5