[{"_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-bildirim","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-bildirim/code/main.ts","extension","id","426f7f1c-af4c-45ef-9815-f7a8cb55f39d","fileId","cc0395d0-a658-11f1-bed9-1607ee4eb77e","parentId","branchId","a1306370-a402-41b6-b8e5-921b7ac16e08","branchVersion",5,"latest",true,"createdAt",["D",1788304891985],"version",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",[14],"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",{"_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"]