[{"_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",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":53,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","erkancavdaroglu","name","hisse-bildirim","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","426f7f1c-af4c-45ef-9815-f7a8cb55f39d","main.ts","fileId","cc0395d0-a658-11f1-bed9-1607ee4eb77e","parentId","branchId","a1306370-a402-41b6-b8e5-921b7ac16e08","branchVersion",5,"latest",true,"createdAt",["D",1788304891985],4,"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 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}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1788304891985],"children",[],[35],"774b37b4-75b9-47d7-90ef-a9dfb1ce5a72",["D",1788303573503],"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",{"_11":12,"_115":111},"org",{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},"branch",{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","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","adoptOrgId",{"_33":61,"_13":14,"_45":150,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":19,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":151,"_95":152,"_97":153,"_99":53},[147],"files",[147],"counts",{"_136":77,"_137":138,"_139":77,"_31":140,"_141":142},[134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":135},[35],"pulls","branches",1,"forks",{"_143":145,"_146":77},"connections",{"_143":77,"_144":77},"count","unfilledCount",2,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":148,"_18":149},[],[35],["D",1788303573503],{"_11":12,"_115":111},{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_131":187,"_188":189,"_190":191,"_192":53,"_193":53,"_194":53,"_195":44,"_196":-5,"_197":-7,"_198":-7,"_199":77,"_200":53,"_201":53,"_202":-5,"_203":53,"_204":53,"_205":53,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":16,"_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"]

Code