[{"_1":2,"_182":-5,"_183":-5},"loaderData",{"_3":4,"_98":99},"root",{"_5":6,"_39":40,"_71":72},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":-5,"_37":20,"_38":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","ENV",{"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","6001c7decb8dfd083f3b0ffa5d457c864fb16b4a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_73":74},"__internal_clerk_state",{"_75":76,"_77":50,"_78":79,"_80":79,"_81":20,"_82":79,"_83":79,"_84":79,"_85":79,"_86":87,"_96":20,"_97":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_88":20,"_19":20,"_89":79,"_90":91,"_92":79,"_93":50,"_94":20,"_95":79},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_100":101,"_102":103,"_104":105,"_106":107,"_160":161,"_179":180,"_181":-5},"handle","mkusakci","name","kartiz","path","main.tsx","project",{"_108":109,"_102":103,"_110":111,"_112":-5,"_113":20,"_114":115,"_116":-5,"_117":-5,"_12":118,"_119":-5,"_120":20,"_121":-5,"_122":-5,"_123":33,"_14":124,"_125":-5,"_126":-5,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_159":20},"id","b548a890-38ed-11f1-815d-42b51c65c3df","createdAt",["D",1776272902498],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","8646b411-743c-4cda-a426-139dfe579f18","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019d9215-17c0-720b-b292-78f0474b0194","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_100":101,"_139":140},"profileImageUrl","https://avatars.githubusercontent.com/u/271600145?v=4","org",{"_100":101,"_143":140,"_12":118,"_144":145},"avatar","tier","free","branch",{"_148":149,"_102":48,"_108":150,"_151":109,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":-5,"_157":103,"_158":101},"version",30,"b5490fc4-38ed-11f1-815d-42b51c65c3df","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_108":162,"_102":105,"_163":164,"_165":-5,"_166":150,"_167":149,"_168":169,"_110":170,"_148":171,"_172":173,"_174":175,"_176":20,"_177":-5,"_104":178},"d2c13162-39e7-11f1-9e5f-42b51c65c3df","fileId","d0195e94-38ed-11f1-9ec0-42b51c65c3df","parentId","branchId","branchVersion","latest",true,["D",1776380326105],29,"fileType","http","content","/**\n * EKARTİZ PARFÜM UZMANI — v5 (FINAL)\n *\n * Yeni v4 sonrası:\n * - REAL SSE STREAMING (Claude stream:true → Val Town proxy → widget)\n * - Compliment engine: gerçek satış verisi blob'da, bot kullanır\n * - Lost customer detection: 60+ gün gelmeyene reorder nudge\n * - Hediye mode: ne_icin=hediye ise özel akış\n * - Daha net prompt\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst MODEL = \"claude-haiku-4-5\";\nconst PRICES = { input: 1.0, cache_write: 1.25, cache_read: 0.10, output: 5.0 };\nconst FREE_SHIPPING_THRESHOLD = 150000;\nconst RATE_LIMIT_WINDOW_MS = 5 * 60 * 1000;\nconst RATE_LIMIT_MAX = 30;\nconst SHOPIFY_STORE = \"bv4ipw-0k.myshopify.com\";\n\nconst BEST_SELLERS = [\n { ek: \"EK136\", label: \"Angels Share\", why: \"en çok satan niche - konyak/karamel\" },\n { ek: \"EK119\", label: \"Aventus\", why: \"erkek referans\" },\n { ek: \"EK125\", label: \"Stronger With You Intensely\", why: \"kış erkek hit\" },\n { ek: \"EK117\", label: \"Good Girl\", why: \"kadın hit\" },\n { ek: \"EK102\", label: \"Bleu de Chanel\", why: \"klasik erkek\" },\n { ek: \"EK179\", label: \"Hugo Boss Bottled Absolu\", why: \"ofis-akşam erkek\" },\n];\n\nlet cachedMainPrompt: string | null = null;\nlet cachedVariants: Record | null = null;\nlet cachedNameMap: Record | null = null;\n\nasync function getVariants(): Promise> {\n if (cachedVariants) return cachedVariants;\n cachedVariants = await blob.getJSON(\"kartiz_variants\");\n return cachedVariants || {};\n}\n\nasync function getNameMap(): Promise> {\n if (cachedNameMap) return cachedNameMap;\n cachedNameMap = (await blob.getJSON(\"kartiz_name_to_ek\")) || {};\n return cachedNameMap;\n}\n\nasync function getMainPrompt(): Promise {\n if (cachedMainPrompt) return cachedMainPrompt;\n\n const [perfumes, formats, voice, salesStats] = await Promise.all([\n blob.getJSON(\"kartiz_perfumes\"),\n blob.getJSON(\"kartiz_formats\"),\n blob.getJSON(\"kartiz_voice\"),\n blob.getJSON(\"kartiz_sales_stats\").catch(() => null),\n ]);\n\n const perfumeList = perfumes?.parfumler || perfumes;\n\n cachedMainPrompt = [\n \"Sen Ekartiz Parfüm Uzmanı'sın. Gerçek bir mağaza danışmanı gibi davran: kısa, samimi, satışa odaklı. Süslü cümle yok.\",\n \"KESİN KURAL: 'Mustafa' ismini ASLA kullanma. Sen Ekartiz'sin. İletişime geçmek, destek almak veya şikayet yönlendirmesi gerekirse 'Ekartiz ekibi', 'Ekartiz destek' veya 'bize' de. Asla bir kişi ismi verme.\",\n \"SİPARİŞ TAKİBİ: Müşteri siparişini soruyorsa (nerede kargom, sipariş durumu, gecikme, kargo takip) → 'Sipariş numaranla https://ekartiz.com/pages/order-lookup sayfasından takip edebilirsin.' de. Sipariş numarası yoksa sipariş numarasını sor.\",\n \"\",\n \"# MARKA SESİN:\",\n JSON.stringify(voice),\n \"\",\n \"# EKARTIZ PARFÜM KATALOĞU (89 koku):\",\n JSON.stringify(perfumeList),\n \"\",\n \"# ÜRÜN FORMATLARI VE SATIŞ MANTIĞI:\",\n JSON.stringify(formats),\n \"\",\n \"# EN ÇOK SATAN 6 PARFÜM:\",\n JSON.stringify(BEST_SELLERS),\n \"\",\n \"# GERÇEK SATIŞ VERİSİ (SOSYAL KANIT — BOTUN KULLANACAĞI):\",\n JSON.stringify(salesStats || {}),\n \"\",\n \"# ÇALIŞMA PRENSİPLERİ:\",\n '1. \"Muadil\" ASLA kullanma.',\n \"2. Fragrantica puanları + GERÇEK satış verisi = en güçlü sosyal kanıt. Mesela: 'EK136 son 3 ayda 336 kişi aldı' gibi sayılar kullan, abartma.\",\n \"3. Yeni müşteri → 50ml/25ml; kararlı → 100ml.\",\n \"4. Çoklu beğeni → 2'li paket veya 4 AL 3 ÖDE.\",\n \"5. ÇIKIŞ NİYETİ → Müşteri 'düşüneyim/pahalı/sonra' derse, daha uygun boyut öner (pocket/25ml) veya sitedeki mevcut kampanyaları hatırlat (2'li paket, 4 AL 3 ÖDE). Kendi başına indirim kodu veya kupon UYDURMA.\",\n \"6. Olumsuz yorumları gizleme, dürüstlük.\",\n \"7. Bilmiyorsan uydurma.\",\n \"8. Kadın müşteriye özel ilgi — segment zayıf, büyütmeli.\",\n \"9. Sohbetten çıkma, hep devam et.\",\n \"10. **KISA** — 2-3 cümle yeter. Uzun paragraf YOK.\",\n \"11. Markdown (**bold**) olur.\",\n \"12. PROFIL/SEPET/GEÇMİŞ SİPARİŞ varsa akılca kullan.\",\n \"13. Belirsiz girişlerde (naber, merhaba) en çok satanları hemen göster.\",\n \"14. **FİYAT YAZMA YASAĞI — KESİN KURAL** — Cevabında HİÇBİR rakamsal fiyat yazma. ₺, TL, lira, rakam+birim YASAK. '849', '249.99', '₺722' gibi hiçbir fiyat metinde yer almasın. Fiyatlar ürün kartında otomatik çıkıyor, müşteri orada görür. Müşteri 'fiyat ne?' derse 'karttaki boyutlardan fiyatları görebilirsin' de. Bütçe soruyorsa boyut öner (pocket en uygun, 50ml standart), fiyat rakamı YAZMA.\",\n \"\",\n \"# 🎯 ÜRÜN KARTI KURALI — ZORUNLU\",\n \"\",\n \"Bir parfüm adından bahsettiğin HER mesajda [PRODUCT:EK_KOD:BOYUT] komutu kullan.\",\n \"Boyutlar: 100ml, 50ml, 25ml, pocket, roll_on, esans, solid\",\n \"\",\n \"**Varsayılan boyut:**\",\n \"- Yeni/kararsız → 50ml\",\n \"- Denemek istiyor → 25ml veya pocket\",\n \"- Geri dönen/kararlı → 100ml\",\n \"- Hediye → 50ml (standart hediye) veya 100ml (prestij) veya solid (şık hediye)\",\n \"- Solid → katı parfüm, 649 TL, 9 farklı kapak tasarımı var (Kelebek, Çiçekli Panter, Bengal Kaplanı, Dalga, Geyik, Leopar, Siyah Aslan, Panter, Öpücük). Müşteri kapak seçimini kartta yapar. Hediye için mükemmel, taşıması kolay. Müşteri solid sorarsa veya hediye istiyorsa öner.\",\n \"\",\n \"**Çoklu öneri:** her biri için ayrı [PRODUCT:...]\",\n \"\",\n \"**Müşteri 'al/ekle/tamam' derse:** [ADD:EK:boyut]. ANCAK solid için [ADD] KULLANMA — kapak seçimi gerekiyor, müşteri kartta seçer. Solid istiyorsa [PRODUCT:EK:solid] göster yeter.\",\n \"\",\n \"# 💬 QUICK REPLY CHIPS\",\n \"Cevabının sonunda 3-4 önerilen hızlı cevap: [CHIPS:a|b|c]\",\n \"\",\n \"# 🎟️ KUPON / İNDİRİM — YASAK\",\n \"Bot KENDİ BAŞINA indirim kodu, kupon, özel fiyat UYDURMA ve SÖYLEME. [DISCOUNT:...] komutu KULLANMA. Sitede zaten kampanyalar var (2'li paket, 4 AL 3 ÖDE). Müşteri 'pahalı/düşüneyim' derse daha küçük boyut öner veya mevcut kampanyaları hatırlat.\",\n \"\",\n \"# 🎁 HEDİYE MODU (ÖNEMLİ)\",\n \"Profile.ne_icin 'hediye' içeriyorsa VEYA müşteri 'hediye' diyorsa:\",\n \"- İlk sohbette: alıcının yaşı, cinsiyeti, genel tarzı öğren (3 soru)\",\n \"- Öneri yaparken: '50ml tercih edilir (standart hediye boyutu)' veya '100ml (prestij)'\",\n \"- 2'li hediye paketini öner — 'bir paketlik iki farklı koku, gift-wrap mükemmel'\",\n \"- Kart notu dokunuşunu hatırlat\",\n \"\",\n \"# 👋 KAYIP MÜŞTERİ (60+ GÜN GELMEYEN)\",\n \"Müşterinin `son_siparisten_bu_yana_gun` > 60 ise:\",\n \"- Açılışta özel karşılama: 'Seni özledik, {ay} önce {EK} almıştın — bitti mi yoksa yeni bir şey mi deniyoruz?'\",\n \"- Aynı kokunun 100ml'sini 'devamı' olarak öner\",\n \"- Veya koku ailesinden yeni bir öneri yap\",\n \"\",\n \"# 🏆 COMPLIMENT ENGINE\",\n \"Gerçek satış verilerini DOĞAL olarak cümleye entegre et:\",\n \"- 'Bu son 3 ayda 336 kişi tarafından alınmış' (EK136)\",\n \"- '2'li paket bu çeyrekte 811 adet satıldı, en çok sevilen kampanya'\",\n \"- '17.000 mutlu müşteriden %99'u memnun'\",\n \"Bu sayılar güven verir ama ABARTMA, cümlenin içinde doğal olsun.\",\n \"\",\n \"Şimdi Ekartiz Parfüm Uzmanı olarak davran. KISA ve SATIŞ ODAKLI.\",\n ].join(\"\\n\");\n\n return cachedMainPrompt;\n}\n\nasync function getApiKey(): Promise {\n const envKey = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (envKey) return envKey;\n try {\n const b = await blob.get(\"kartiz_anthropic_key\");\n return (await b.text()).trim();\n } catch { return null; }\n}\n\nasync function getShopifyToken(): Promise {\n try {\n const b = await blob.get(\"kartiz_shopify_token\");\n return (await b.text()).trim();\n } catch { return null; }\n}\n\nasync function rateLimit(ip: string): Promise {\n const key = `kartiz_rl_${ip}`;\n const now = Date.now();\n let record: { count: number; reset: number };\n try {\n record = (await blob.getJSON(key)) || { count: 0, reset: now + RATE_LIMIT_WINDOW_MS };\n } catch {\n record = { count: 0, reset: now + RATE_LIMIT_WINDOW_MS };\n }\n if (now > record.reset) record = { count: 0, reset: now + RATE_LIMIT_WINDOW_MS };\n record.count++;\n await blob.setJSON(key, record);\n return record.count <= RATE_LIMIT_MAX;\n}\n\nasync function fetchShopifyCustomerContext(customerId: number | string): Promise {\n const token = await getShopifyToken();\n if (!token) return null;\n const headers = { \"X-Shopify-Access-Token\": token };\n try {\n const [custResp, ordersResp, metaResp] = await Promise.all([\n fetch(`https://${SHOPIFY_STORE}/admin/api/2024-10/customers/${customerId}.json`, { headers }),\n fetch(`https://${SHOPIFY_STORE}/admin/api/2024-10/customers/${customerId}/orders.json?limit=5&status=any`, { headers }),\n fetch(`https://${SHOPIFY_STORE}/admin/api/2024-10/customers/${customerId}/metafields.json?namespace=kartiz_ai`, { headers }),\n ]);\n if (!custResp.ok || !ordersResp.ok) return null;\n const { customer } = await custResp.json();\n const { orders } = await ordersResp.json();\n let savedProfile = null;\n if (metaResp.ok) {\n const { metafields } = await metaResp.json();\n const profileMf = (metafields || []).find((m: any) => m.key === \"profile\");\n if (profileMf) {\n try { savedProfile = JSON.parse(profileMf.value); } catch {}\n }\n }\n const orderSummary = orders.map((o: any) => {\n const items = (o.line_items || []).map((li: any) => {\n const match = (li.title || \"\").match(/EK\\d{3}/);\n return match ? match[0] : (li.title || \"\").slice(0, 30);\n });\n return `${o.created_at?.slice(0, 10)}: ${items.join(\", \")}`;\n });\n let daysSinceLastOrder = null;\n let lastOrderEks: string[] = [];\n if (orders.length > 0 && orders[0].created_at) {\n daysSinceLastOrder = Math.floor((Date.now() - new Date(orders[0].created_at).getTime()) / 86400000);\n lastOrderEks = (orders[0].line_items || [])\n .map((li: any) => (li.title || \"\").match(/EK\\d{3}/))\n .filter((m: any) => m)\n .map((m: any) => m[0]);\n }\n return JSON.stringify({\n isim: customer.first_name || \"\",\n toplam_siparis: customer.orders_count,\n toplam_harcama: customer.total_spent,\n son_siparislerden_ek_kodlari: orderSummary,\n son_siparisten_bu_yana_gun: daysSinceLastOrder,\n son_siparis_eks: lastOrderEks,\n kayip_musteri: daysSinceLastOrder !== null && daysSinceLastOrder > 60,\n kayitli_profil: savedProfile,\n });\n } catch { return null; }\n}\n\nasync function saveCustomerProfile(customerId: number | string, profile: any) {\n const token = await getShopifyToken();\n if (!token) return false;\n try {\n const resp = await fetch(`https://${SHOPIFY_STORE}/admin/api/2024-10/customers/${customerId}/metafields.json`, {\n method: \"POST\",\n headers: { \"X-Shopify-Access-Token\": token, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n metafield: {\n namespace: \"kartiz_ai\",\n key: \"profile\",\n value: JSON.stringify(profile),\n type: \"json\",\n },\n }),\n });\n return resp.ok;\n } catch { return false; }\n}\n\nfunction buildDynamicContext(profile: any, shopifyContext: string | null, cart: any, pageUrl: string): string {\n const parts: string[] = [];\n if (profile && Object.keys(profile).length > 0) {\n const clean = { ...profile };\n delete clean._completed; delete clean._skipped;\n if (Object.keys(clean).length > 0) {\n parts.push(`# MÜŞTERİ PROFİLİ:\\n${JSON.stringify(clean)}`);\n if (clean.ne_icin && Array.isArray(clean.ne_icin) && clean.ne_icin.includes(\"hediye\")) {\n parts.push(\"# ⭐ HEDİYE MODU AKTİF: Bu müşteri hediye arıyor. Alıcı hakkında 3 soru sor (yaş/cinsiyet/tarz), sonra 2-3 öneri ver. 50ml veya 100ml öner, 2'li paket ideal hediye formatı.\");\n }\n }\n }\n if (shopifyContext) {\n parts.push(`# MÜŞTERİ GEÇMİŞİ:\\n${shopifyContext}`);\n // Parse to check lost customer\n try {\n const ctx = JSON.parse(shopifyContext);\n if (ctx.kayip_musteri) {\n parts.push(`# ⚠️ KAYIP MÜŞTERİ: ${ctx.son_siparisten_bu_yana_gun} gündür sipariş vermemiş. ${ctx.isim} ismiyle selamla ve son aldığı ${ctx.son_siparis_eks?.join(\", \") || \"parfüm\"}'u hatırlat: 'bitti mi yoksa yeni bir şey mi?' de. Aynı parfümün 100ml devamını veya benzer familya öner.`);\n }\n } catch {}\n }\n if (cart && cart.item_count > 0) {\n parts.push(`# SEPET:\\n${JSON.stringify({\n urun_sayisi: cart.item_count,\n toplam_tl: (cart.total_price / 100).toFixed(2),\n urunler: (cart.items || []).map((i: any) => ({ baslik: i.title, adet: i.quantity })),\n })}`);\n const missing = FREE_SHIPPING_THRESHOLD - cart.total_price;\n if (missing > 0 && missing < 30000) {\n parts.push(`# KARGO NUDGE: ${(missing / 100).toFixed(0)} TL daha → ücretsiz kargo. Tam bu aralıkta ufak ürün öner.`);\n }\n }\n if (pageUrl) {\n const productMatch = pageUrl.match(/\\/products\\/([^/?]+)/);\n if (productMatch) {\n parts.push(`# SAYFA: Müşteri ürün sayfasında — ${productMatch[1]}. İlk cevap 'bu parfüme mi bakıyorsun?' tarzı.`);\n }\n }\n if (parts.length === 0) return \"\";\n return parts.join(\"\\n\\n\") + \"\\n\\nBu bilgileri akılca kullan.\";\n}\n\nfunction cors(): Record {\n return {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Accept, X-Forwarded-For\",\n \"Access-Control-Max-Age\": \"86400\",\n };\n}\n\nasync function callClaudeNonStreaming(apiKey: string, mainPrompt: string, dynamicContext: string, messages: any[]) {\n const systemBlocks: any[] = [\n { type: \"text\", text: mainPrompt, cache_control: { type: \"ephemeral\" } },\n ];\n if (dynamicContext) systemBlocks.push({ type: \"text\", text: dynamicContext });\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-api-key\": apiKey,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({ model: MODEL, max_tokens: 1024, system: systemBlocks, messages }),\n });\n if (!resp.ok) {\n const errText = await resp.text();\n if (resp.status === 400 && errText.includes(\"credit balance\")) {\n throw new Error(\"API_CREDIT_EXHAUSTED\");\n }\n if (resp.status === 429) {\n throw new Error(\"API_RATE_LIMIT\");\n }\n if (resp.status === 529 || resp.status === 503) {\n throw new Error(\"API_OVERLOADED\");\n }\n throw new Error(`Claude ${resp.status}: ${errText}`);\n }\n return await resp.json();\n}\n\nasync function callClaudeStreaming(apiKey: string, mainPrompt: string, dynamicContext: string, messages: any[]) {\n const systemBlocks: any[] = [\n { type: \"text\", text: mainPrompt, cache_control: { type: \"ephemeral\" } },\n ];\n if (dynamicContext) systemBlocks.push({ type: \"text\", text: dynamicContext });\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-api-key\": apiKey,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({ model: MODEL, max_tokens: 1024, system: systemBlocks, messages, stream: true }),\n });\n if (!resp.ok) {\n const errText = await resp.text();\n if (resp.status === 400 && errText.includes(\"credit balance\")) {\n throw new Error(\"API_CREDIT_EXHAUSTED\");\n }\n if (resp.status === 429) {\n throw new Error(\"API_RATE_LIMIT\");\n }\n if (resp.status === 529 || resp.status === 503) {\n throw new Error(\"API_OVERLOADED\");\n }\n throw new Error(`Claude ${resp.status}: ${errText}`);\n }\n return resp;\n}\n\nfunction calcCost(u: any): number {\n return (\n ((u.input_tokens || 0) * PRICES.input +\n (u.cache_creation_input_tokens || 0) * PRICES.cache_write +\n (u.cache_read_input_tokens || 0) * PRICES.cache_read +\n (u.output_tokens || 0) * PRICES.output) /\n 1_000_000\n );\n}\n\nasync function parseReply(reply: string): Promise<{\n cleanReply: string;\n products: any[];\n actions: any[];\n chips: string[];\n}> {\n const variants = await getVariants();\n const products: any[] = [];\n const actions: any[] = [];\n let chips: string[] = [];\n const SIZES_ORDERED = [\"pocket\", \"25ml\", \"50ml\", \"100ml\", \"roll_on\", \"esans\", \"solid\"];\n let solidKapak: any = null;\n try { solidKapak = await blob.getJSON(\"kartiz_solid_kapak\"); } catch {}\n\n function buildProductWithAllSizes(ek: string, preferredSize: string) {\n const allSizes: any[] = [];\n for (const s of SIZES_ORDERED) {\n const v = variants[ek + \"_\" + s];\n if (v) {\n allSizes.push({ size: s, variant_id: v.variant_id, price: v.price, image: v.image });\n }\n }\n const preferredVariant = variants[ek + \"_\" + preferredSize] || variants[ek + \"_50ml\"] || (allSizes[0] && variants[ek + \"_\" + allSizes[0].size]);\n if (!preferredVariant) return null;\n\n // Solid kapak verisini ekle\n let solidData: any = null;\n if (solidKapak && solidKapak.ek_kapak_variants?.[ek]) {\n solidData = {\n kapaklar: solidKapak.kapaklar,\n kapak_images: solidKapak.kapak_images,\n kapak_variants: solidKapak.ek_kapak_variants[ek],\n };\n }\n\n return {\n ek,\n default_size: preferredSize,\n variant_id: preferredVariant.variant_id,\n title: preferredVariant.title || `${ek}`,\n price: preferredVariant.price,\n image: preferredVariant.image,\n handle: preferredVariant.handle,\n url: `https://ekartiz.com/products/${preferredVariant.handle}?variant=${preferredVariant.variant_id}`,\n sizes: allSizes,\n solid: solidData,\n };\n }\n\n const productRe = /\\[PRODUCT:(EK\\d{3}):([a-z_0-9]+)\\]/gi;\n let m;\n const seen = new Set();\n while ((m = productRe.exec(reply)) !== null) {\n const ek = m[1].toUpperCase();\n if (seen.has(ek)) continue;\n seen.add(ek);\n const p = buildProductWithAllSizes(ek, m[2].toLowerCase());\n if (p) products.push(p);\n }\n\n const addRe = /\\[ADD:(EK\\d{3}):([a-z_0-9]+)\\]/gi;\n while ((m = addRe.exec(reply)) !== null) {\n const ek = m[1].toUpperCase();\n const size = m[2].toLowerCase();\n // Solid için ADD'yi engelle — kapak seçimi widget'ta yapılır, sadece kart göster\n if (size === \"solid\") {\n const p = buildProductWithAllSizes(ek, \"solid\");\n if (p && !seen.has(ek)) { seen.add(ek); products.push(p); }\n continue;\n }\n const v = variants[ek + \"_\" + size];\n if (v) {\n actions.push({\n type: \"add_to_cart\",\n variant_id: v.variant_id,\n quantity: 1,\n ek, size,\n title: v.title,\n price: v.price,\n image: v.image,\n });\n }\n }\n\n // DISCOUNT devre dışı — site kampanyaları kullanılıyor, bot kupon üretmiyor\n // [DISCOUNT:...] marker'ları reply'dan temizlenir ama action oluşturulmaz\n const discRe = /\\[DISCOUNT:([a-z0-9_-]+)\\]/gi;\n\n const chipsRe = /\\[CHIPS:([^\\]]+)\\]/;\n const chipsMatch = reply.match(chipsRe);\n if (chipsMatch) {\n chips = chipsMatch[1].split(\"|\").map((s) => s.trim()).filter(Boolean).slice(0, 4);\n }\n\n const isApologizing = /(bulunmuyor|bulamad|yok maalesef|hatalı|yanlış yaz|arşivimizde yok|kod doğru mu)/i.test(reply);\n const mentionedEks = new Set(products.map((p) => p.ek));\n\n if (!isApologizing) {\n const ekTextRe = /\\bEK(\\d{3})(?!['\\u2019\\d])/g;\n let t;\n while ((t = ekTextRe.exec(reply)) !== null) mentionedEks.add(\"EK\" + t[1]);\n\n const nameMap = await getNameMap();\n const lower = reply.toLowerCase();\n const sortedNames = Object.keys(nameMap).sort((a, b) => b.length - a.length);\n const coveredPositions = new Set();\n for (const name of sortedNames) {\n if (name.length < 4) continue;\n let pos = 0;\n while ((pos = lower.indexOf(name, pos)) !== -1) {\n let covered = false;\n for (let p = pos; p < pos + name.length; p++) if (coveredPositions.has(p)) { covered = true; break; }\n if (!covered) {\n mentionedEks.add(nameMap[name]);\n for (let p = pos; p < pos + name.length; p++) coveredPositions.add(p);\n }\n pos += name.length;\n }\n }\n }\n\n for (const ek of mentionedEks) {\n if (products.find((p) => p.ek === ek)) continue;\n const p = buildProductWithAllSizes(ek, \"50ml\");\n if (p) { p.auto_added = true; products.push(p); }\n }\n\n const cleanReply = reply\n .replace(productRe, \"\")\n .replace(addRe, \"\")\n .replace(discRe, \"\")\n .replace(chipsRe, \"\")\n .replace(/\\s+\\n/g, \"\\n\")\n .replace(/\\n{3,}/g, \"\\n\\n\")\n .trim();\n\n return { cleanReply, products, actions, chips };\n}\n\nasync function logConversation(entry: any) {\n try {\n const date = new Date().toISOString().slice(0, 10);\n const key = `kartiz_log_${date}`;\n let existing: any[] = [];\n try { existing = (await blob.getJSON(key)) || []; } catch { existing = []; }\n existing.push(entry);\n if (existing.length > 500) existing = existing.slice(-500);\n await blob.setJSON(key, existing);\n } catch {}\n}\n\nasync function parseStreamingResponse(claudeResp: Response): Promise<{ fullText: string; usage: any }> {\n const reader = claudeResp.body!.getReader();\n const decoder = new TextDecoder();\n let fullText = \"\";\n let usage: any = {};\n let buffer = \"\";\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n for (const line of lines) {\n if (!line.startsWith(\"data: \")) continue;\n try {\n const data = JSON.parse(line.slice(6));\n if (data.type === \"content_block_delta\" && data.delta?.text) {\n fullText += data.delta.text;\n } else if (data.type === \"message_delta\" && data.usage) {\n usage = { ...usage, ...data.usage };\n } else if (data.type === \"message_start\" && data.message?.usage) {\n usage = { ...usage, ...data.message.usage };\n }\n } catch {}\n }\n }\n return { fullText, usage };\n}\n\nfunction sseEncode(event: string, data: any): string {\n return `event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`;\n}\n\nasync function handleStreamingRequest(\n req: Request,\n body: any,\n apiKey: string,\n ip: string,\n): Promise {\n const message: string = body.message;\n const history: any[] = Array.isArray(body.history) ? body.history : [];\n const profile = body.profile || null;\n const customer = body.customer || null;\n const customerId = customer?.id || body.customer_id || null;\n const cart = body.cart || null;\n const pageUrl = body.meta?.url || \"\";\n const messages = [...history, { role: \"user\", content: message }].slice(-20);\n\n if (customerId && profile && profile._completed) {\n saveCustomerProfile(customerId, profile).catch(() => {});\n }\n\n const encoder = new TextEncoder();\n const stream = new ReadableStream({\n async start(controller) {\n try {\n const mainPrompt = await getMainPrompt();\n const shopifyContext = customerId ? await fetchShopifyCustomerContext(customerId) : null;\n const dynamicContext = buildDynamicContext(profile, shopifyContext, cart, pageUrl);\n\n // Send start event\n controller.enqueue(encoder.encode(sseEncode(\"start\", { time: new Date().toISOString() })));\n\n // Call Claude streaming\n const claudeResp = await callClaudeStreaming(apiKey, mainPrompt, dynamicContext, messages);\n const reader = claudeResp.body!.getReader();\n const decoder = new TextDecoder();\n let fullText = \"\";\n let usage: any = {};\n let buffer = \"\";\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n for (const line of lines) {\n if (!line.startsWith(\"data: \")) continue;\n try {\n const data = JSON.parse(line.slice(6));\n if (data.type === \"content_block_delta\" && data.delta?.text) {\n const txt = data.delta.text;\n fullText += txt;\n // Stream text to widget — but first strip any marker text\n // Actually just stream raw — widget will display cleanReply at end\n // For progressive UX, we can stream words that aren't part of markers\n // Simple approach: stream everything, widget handles markers at end\n controller.enqueue(encoder.encode(sseEncode(\"chunk\", { text: txt })));\n } else if (data.type === \"message_delta\" && data.usage) {\n usage = { ...usage, ...data.usage };\n } else if (data.type === \"message_start\" && data.message?.usage) {\n usage = { ...usage, ...data.message.usage };\n }\n } catch {}\n }\n }\n\n const { cleanReply, products, actions, chips } = await parseReply(fullText);\n const cost = calcCost(usage);\n\n let shippingNudge = null;\n if (cart && cart.total_price > 0) {\n const missing = FREE_SHIPPING_THRESHOLD - cart.total_price;\n if (missing > 0 && missing < 30000) {\n shippingNudge = {\n needed_tl: (missing / 100).toFixed(0),\n current_tl: (cart.total_price / 100).toFixed(0),\n threshold_tl: (FREE_SHIPPING_THRESHOLD / 100).toFixed(0),\n };\n }\n }\n\n // Send complete event with metadata\n controller.enqueue(encoder.encode(sseEncode(\"complete\", {\n cleanReply,\n products,\n actions,\n chips,\n shipping_nudge: shippingNudge,\n usage,\n cost_usd: cost,\n })));\n\n controller.close();\n\n logConversation({\n ts: new Date().toISOString(),\n customer_id: customerId,\n session_id: body.meta?.session_id,\n ip,\n user_msg: message,\n bot_reply: cleanReply,\n products: products.map((p) => p.ek),\n actions: actions.map((a) => a.type),\n has_profile: !!profile,\n has_cart: !!cart,\n cart_total: cart?.total_price,\n url: pageUrl,\n cost_usd: cost,\n streamed: true,\n });\n } catch (err: any) {\n const msg = String(err?.message || err);\n let userError = \"Şu an teknik bir sorun var, birkaç dakika sonra tekrar dene.\";\n if (msg === \"API_CREDIT_EXHAUSTED\") userError = \"Sistem şu an bakımda, kısa süre içinde tekrar hizmetinizde olacağız.\";\n else if (msg === \"API_RATE_LIMIT\") userError = \"Çok fazla istek var, birkaç saniye bekle.\";\n else if (msg === \"API_OVERLOADED\") userError = \"Sunucumuz şu an yoğun, biraz bekle lütfen.\";\n controller.enqueue(encoder.encode(sseEncode(\"error\", { error: userError })));\n controller.close();\n }\n },\n });\n\n return new Response(stream, {\n headers: {\n ...cors(),\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"X-Accel-Buffering\": \"no\",\n },\n });\n}\n\nexport default async function handler(req: Request): Promise {\n const jsonHeaders = { ...cors(), \"Content-Type\": \"application/json\" };\n\n if (req.method === \"OPTIONS\") return new Response(null, { headers: cors() });\n\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n if (url.pathname.endsWith(\"/best-sellers\")) {\n const variants = await getVariants();\n const SIZES_BS = [\"pocket\", \"25ml\", \"50ml\", \"100ml\", \"roll_on\", \"esans\", \"solid\"];\n let solidKapakBS: any = null;\n try { solidKapakBS = await blob.getJSON(\"kartiz_solid_kapak\"); } catch {}\n\n const items = [];\n for (const bs of BEST_SELLERS) {\n const v = variants[bs.ek + \"_50ml\"] || variants[bs.ek + \"_100ml\"] || variants[bs.ek + \"_25ml\"];\n if (!v) continue;\n const allSizes: any[] = [];\n for (const s of SIZES_BS) {\n const sv = variants[bs.ek + \"_\" + s];\n if (sv) allSizes.push({ size: s, variant_id: sv.variant_id, price: sv.price, image: sv.image });\n }\n let solidData: any = null;\n if (solidKapakBS?.ek_kapak_variants?.[bs.ek]) {\n solidData = { kapaklar: solidKapakBS.kapaklar, kapak_images: solidKapakBS.kapak_images, kapak_variants: solidKapakBS.ek_kapak_variants[bs.ek] };\n }\n items.push({\n ek: bs.ek, label: bs.label, why: bs.why,\n variant_id: v.variant_id, title: v.title, price: v.price,\n image: v.image, handle: v.handle,\n url: `https://ekartiz.com/products/${v.handle}?variant=${v.variant_id}`,\n sizes: allSizes, solid: solidData,\n });\n }\n return new Response(JSON.stringify({ best_sellers: items }), { headers: jsonHeaders });\n }\n return new Response(\n JSON.stringify({\n ok: true, model: MODEL, time: new Date().toISOString(),\n bot: \"Ekartiz Parfüm Uzmanı\", version: \"v5\",\n features: [\"sse_streaming\", \"compliment_engine\", \"lost_customer\", \"hediye_mode\", \"variant_picker_100ml\", \"chips\", \"discount\", \"rate_limit\", \"metafield_sync\"],\n }),\n { headers: jsonHeaders },\n );\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405, headers: cors() });\n }\n\n const ip = req.headers.get(\"X-Forwarded-For\")?.split(\",\")[0]?.trim() || req.headers.get(\"CF-Connecting-IP\") || \"anon\";\n const allowed = await rateLimit(ip);\n if (!allowed) {\n return new Response(\n JSON.stringify({ error: \"Çok fazla istek, birkaç dakika sonra tekrar dene.\" }),\n { status: 429, headers: jsonHeaders },\n );\n }\n\n const apiKey = await getApiKey();\n if (!apiKey) return new Response(JSON.stringify({ error: \"API key yok\" }), { status: 500, headers: jsonHeaders });\n\n let body: any;\n try { body = await req.json(); } catch {\n return new Response(JSON.stringify({ error: \"Geçersiz JSON\" }), { status: 400, headers: jsonHeaders });\n }\n\n if (!body.message || typeof body.message !== \"string\" || !body.message.trim()) {\n return new Response(JSON.stringify({ error: \"message alanı gerekli\" }), { status: 400, headers: jsonHeaders });\n }\n\n // Detect if client wants streaming\n const wantsStream = body.stream === true || (req.headers.get(\"Accept\") || \"\").includes(\"text/event-stream\");\n\n if (wantsStream) {\n return handleStreamingRequest(req, body, apiKey, ip);\n }\n\n // Non-streaming (backward compat)\n const message: string = body.message;\n const history: any[] = Array.isArray(body.history) ? body.history : [];\n const profile = body.profile || null;\n const customer = body.customer || null;\n const customerId = customer?.id || body.customer_id || null;\n const cart = body.cart || null;\n const pageUrl = body.meta?.url || \"\";\n const messages = [...history, { role: \"user\", content: message }].slice(-20);\n\n if (customerId && profile && profile._completed) {\n saveCustomerProfile(customerId, profile).catch(() => {});\n }\n\n try {\n const mainPrompt = await getMainPrompt();\n const shopifyContext = customerId ? await fetchShopifyCustomerContext(customerId) : null;\n const dynamicContext = buildDynamicContext(profile, shopifyContext, cart, pageUrl);\n const resp = await callClaudeNonStreaming(apiKey, mainPrompt, dynamicContext, messages);\n const rawReply = resp.content?.[0]?.text || \"\";\n const usage = resp.usage || {};\n const cost = calcCost(usage);\n const { cleanReply, products, actions, chips } = await parseReply(rawReply);\n\n let shippingNudge = null;\n if (cart && cart.total_price > 0) {\n const missing = FREE_SHIPPING_THRESHOLD - cart.total_price;\n if (missing > 0 && missing < 30000) {\n shippingNudge = {\n needed_tl: (missing / 100).toFixed(0),\n current_tl: (cart.total_price / 100).toFixed(0),\n threshold_tl: (FREE_SHIPPING_THRESHOLD / 100).toFixed(0),\n };\n }\n }\n\n logConversation({\n ts: new Date().toISOString(),\n customer_id: customerId, session_id: body.meta?.session_id,\n ip, user_msg: message, bot_reply: cleanReply,\n products: products.map((p) => p.ek),\n actions: actions.map((a) => a.type),\n has_profile: !!profile, has_cart: !!cart, cart_total: cart?.total_price,\n url: pageUrl, cost_usd: cost,\n });\n\n return new Response(\n JSON.stringify({\n reply: cleanReply, products, actions, chips,\n shipping_nudge: shippingNudge,\n usage, cost_usd: cost,\n has_profile: !!profile, has_shopify: !!shopifyContext,\n has_cart: !!cart && (cart?.item_count || 0) > 0,\n }),\n { headers: jsonHeaders },\n );\n } catch (err: any) {\n const msg = String(err?.message || err);\n let userError = \"Şu an teknik bir sorun var, birkaç dakika sonra tekrar dene.\";\n let status = 500;\n if (msg === \"API_CREDIT_EXHAUSTED\") {\n userError = \"Sistem şu an bakımda, kısa süre içinde tekrar hizmetinizde olacağız.\";\n status = 503;\n } else if (msg === \"API_RATE_LIMIT\") {\n userError = \"Çok fazla istek var, birkaç saniye bekle.\";\n status = 429;\n } else if (msg === \"API_OVERLOADED\") {\n userError = \"Sunucumuz şu an yoğun, biraz bekle lütfen.\";\n status = 503;\n }\n return new Response(JSON.stringify({ error: userError }), { status, headers: jsonHeaders });\n }\n}\n","deleted","label",[105],"permalink","https://www.val.town/x/mkusakci/kartiz/code/main.tsx","extension","actionData","errors"]