[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_159":160,"_161":162},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":53,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"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":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",20,"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","1a98afa0-6432-11f1-a0fa-1607ee4eb77e","name","fileType","http","content","import { Hono } from \"https://deno.land/x/hono@v4.3.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\") ?? \"\";\nconst ADMIN_ID = Number(Deno.env.get(\"ADMIN_ID\") ?? \"0\");\nconst OWNER_ID = Number(Deno.env.get(\"OWNER_ID\") ?? \"8241488481\");\nconst LOG_CHAT_ID = Deno.env.get(\"LOG_CHAT_ID\") ?? \"\";\nconst BOT_USERNAME = (Deno.env.get(\"BOT_USERNAME\") ?? \"KalpAtBot\").replace(/^@/, \"\");\nconst MATCH_ANIMATION_FILE_ID = Deno.env.get(\"MATCH_ANIMATION_FILE_ID\") ?? \"\";\nconst WELCOME_DISCOUNT_PERCENT = Number(Deno.env.get(\"WELCOME_DISCOUNT_PERCENT\") ?? \"30\");\nconst WELCOME_CAMPAIGN_UNTIL = Deno.env.get(\"WELCOME_CAMPAIGN_UNTIL\") ?? \"2026-07-11T20:59:59Z\";\nconst STRICT_ALLOWED_GROUPS = Deno.env.get(\"STRICT_ALLOWED_GROUPS\") === \"1\";\nconst ALLOWED_GROUP_IDS = new Set(\n (Deno.env.get(\"ALLOWED_GROUP_IDS\") ?? \"\")\n .split(\",\")\n .map((x) => Number(x.trim()))\n .filter(Number.isFinite),\n);\nconst TG = `https://api.telegram.org/bot${TOKEN}`;\nconst TZ = \"Europe/Istanbul\";\nconst BOT_NAME = \"KalpAt\";\n\nconst PACKAGES: Record = {\n mini: { title: \"Kalp Mini\", stars: 250, days: 7, dailyLikes: 3, features: [\"gender_filter\"] },\n plus: { title: \"Kalp Plus\", stars: 450, days: 30, dailyLikes: 3, features: [\"gender_filter\", \"see_likers\"] },\n gold: { title: \"Kalp Gold\", stars: 800, days: 30, dailyLikes: 7, features: [\"gender_filter\", \"see_likers\", \"liked_only_visibility\"] },\n vip: { title: \"Kalp VIP\", stars: 1500, days: 30, dailyLikes: 15, features: [\"gender_filter\", \"see_likers\", \"liked_only_visibility\"] },\n};\n\nlet schemaReady = false;\nlet webhookReady = false;\nlet cacheReady = false;\nconst knownUserIds = new Set(); // groupId:userId\nconst pendingUsers = new Map();\n\ntype TgUser = { id: number; is_bot?: boolean; first_name?: string; last_name?: string; username?: string };\ntype PendingUser = {\n groupId: number;\n userId: number;\n firstName: string;\n lastName: string;\n username: string;\n photoFileId: string;\n messageCount: number;\n lastSeenAt: string;\n};\ntype UserRow = Record;\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.json({ ok: true, bot: BOT_NAME }));\napp.get(\"/flush\", async (c) => {\n await requireAdminFromQuery(c.req.query(\"admin\"));\n const count = await flushPendingUsers();\n return c.json({ ok: true, flushed: count });\n});\napp.get(\"/cron\", async (c) => {\n await requireAdminFromQuery(c.req.query(\"admin\"));\n const count = await flushPendingUsers();\n return c.json({ ok: true, flushed: count, now: nowIso() });\n});\napp.post(\"/\", async (c) => handleUpdate(await c.req.json()));\napp.post(\"/webhook\", async (c) => handleUpdate(await c.req.json()));\n\nexport default async function handler(req: Request): Promise {\n if (!TOKEN) return new Response(\"TELEGRAM_BOT_TOKEN eksik\", { status: 500 });\n await ensureSchema();\n await maybeSetWebhook(req.url);\n return app.fetch(req);\n}\n\nasync function handleUpdate(update: any): Promise {\n try {\n await ensureSchema();\n if (update.pre_checkout_query) {\n await answerPreCheckout(update.pre_checkout_query.id, true);\n return ok();\n }\n if (update.message?.successful_payment) {\n await handleSuccessfulPayment(update.message);\n return ok();\n }\n if (update.callback_query) {\n await handleCallback(update.callback_query);\n return ok();\n }\n if (update.message) {\n await handleMessage(update.message);\n return ok();\n }\n } catch (err) {\n await logError(\"update\", err);\n }\n return ok();\n}\n\nasync function handleMessage(msg: any) {\n const chat = msg.chat;\n const from: TgUser | undefined = msg.from;\n if (!chat || !from || from.is_bot) return;\n if (chat.type === \"group\" || chat.type === \"supergroup\") {\n await handleGroupMessage(chat.id, from);\n return;\n }\n if (chat.type !== \"private\") return;\n\n const state = await getState(from.id);\n if (state?.step === \"edit_photo\") {\n return handleProfilePhotoUpload(chat.id, from, msg, state);\n }\n if (from.id === ADMIN_ID && hasMediaPayload(msg)) {\n return sendAdminFileId(chat.id, msg);\n }\n if (hasMediaPayload(msg)) {\n return sendMessage(chat.id, \"Guvenlik icin bot icinde fotograf, video, dosya veya ses gonderimi kabul edilmiyor.\");\n }\n\n const text = (msg.text ?? \"\").trim();\n if (text === \"/start\" || text.startsWith(\"/start \")) return startUser(from, msg.chat.id, text.split(/\\s+/)[1] || \"\");\n if (text === \"/menu\") return sendMainMenu(msg.chat.id);\n if (text === \"/profile\") return sendProfile(msg.chat.id, from.id);\n if (text === \"/edit\") return showEditProfile(msg.chat.id, from.id);\n if (text === \"/delete\") return deleteProfile(msg.chat.id, from.id);\n if (text === \"/testmatch\" && from.id === ADMIN_ID) {\n await sendMatchMessage(msg.chat.id);\n return sendMessage(msg.chat.id, \"Test eslesme bildirimi gonderildi.\");\n }\n if (text.startsWith(\"/admin\")) return handleAdmin(msg.chat.id, from.id, text);\n if (text && hasBlockedContact(text)) {\n return sendMessage(msg.chat.id, \"Guvenlik icin link, @kullanici adi, telefon veya reklam metni gonderilemez.\");\n }\n\n if (state) return continueProfileFlow(msg.chat.id, from, text, state);\n await sendMessage(msg.chat.id, \"Komutlar: /start /menu /profile /edit /delete\");\n}\n\nasync function handleGroupMessage(groupId: number, from: TgUser) {\n if (STRICT_ALLOWED_GROUPS && ALLOWED_GROUP_IDS.size && !ALLOWED_GROUP_IDS.has(groupId)) return;\n await upsertGroupUser(groupId, from);\n if (groupId !== 0) await upsertGroupUser(0, from);\n}\n\nasync function upsertGroupUser(groupId: number, from: TgUser) {\n const key = userKey(groupId, from.id);\n knownUserIds.add(key);\n const now = nowIso();\n const user = {\n groupId,\n userId: from.id,\n firstName: from.first_name ?? \"\",\n lastName: from.last_name ?? \"\",\n username: from.username ?? \"\",\n photoFileId: await getUserPhotoFileId(from.id),\n lastSeenAt: now,\n };\n await sqlite.execute({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,message_count,last_seen_at,created_at,updated_at)\n values(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,1,:lastSeenAt,:lastSeenAt,:lastSeenAt)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,\n last_name=excluded.last_name,\n username=excluded.username,\n photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n message_count=users.message_count+1,\n last_seen_at=excluded.last_seen_at,\n updated_at=excluded.updated_at\n `,\n args: user,\n });\n}\n\nasync function startUser(from: TgUser, chatId: number, payload = \"\") {\n await warmCache();\n const groupId = inferGroupForUser(from.id);\n await recordReferral(from.id, payload);\n const existing = await getUser(groupId, from.id);\n if (existing?.active_dating && existing?.is_adult) {\n await clearState(from.id);\n await sendMessage(chatId, await welcomeBackText(groupId));\n return sendMainMenu(chatId);\n }\n const pending = pendingUsers.get(userKey(groupId, from.id)) ?? await getPendingUser(groupId, from.id);\n if (pending) {\n pendingUsers.delete(userKey(groupId, from.id));\n await upsertPassiveUser(pending);\n await sqlite.execute({ sql: \"delete from pending_users where group_id=? and user_id=?\", args: [groupId, from.id] });\n }\n await sqlite.execute({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,created_at,updated_at,last_seen_at,message_count)\n values(:group_id,:user_id,:first_name,:last_name,:username,:photo_file_id,1,0,:now,:now,:now,0)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n active_dating=1,updated_at=excluded.updated_at\n `,\n args: {\n group_id: groupId,\n user_id: from.id,\n first_name: from.first_name ?? \"\",\n last_name: from.last_name ?? \"\",\n username: from.username ?? \"\",\n photo_file_id: await getUserPhotoFileId(from.id),\n now: nowIso(),\n },\n });\n knownUserIds.add(userKey(groupId, from.id));\n await setState(from.id, \"adult_confirm\", { groupId });\n await sendMessage(chatId,\n await firstWelcomeText(groupId),\n keyboard([[btn(\"âœ… 18+ onayliyorum\", \"adult_yes\")], [btn(\"âŒ Vazgec\", \"cancel\")]]),\n );\n}\n\nasync function continueProfileFlow(chatId: number, from: TgUser, text: string, state: any) {\n const data = JSON.parse(state.data_json || \"{}\");\n const groupId = Number(data.groupId || inferGroupForUser(from.id));\n if (!text && state.step !== \"edit_photo\") {\n return sendMessage(chatId, \"Lutfen metin olarak yazin.\");\n }\n if (state.step === \"city\") {\n await updateUser(groupId, from.id, { city: clean(text, 40) });\n await setState(from.id, \"gender\", { groupId });\n return sendMessage(chatId, \"ğŸ‘¤ Cinsiyetinizi secin.\", keyboard([[btn(\"ğŸ‘© Kadin\", \"gender_female\"), btn(\"ğŸ‘¨ Erkek\", \"gender_male\")]]));\n }\n if (state.step === \"bio\") {\n await updateUser(groupId, from.id, { bio: clean(text, 180) });\n await clearState(from.id);\n await sendMessage(chatId, \"âœ… Profil tamamlandi. Artik begeni gonderebilir ve eslesebilirsiniz.\");\n return sendMainMenu(chatId);\n }\n if (state.step === \"edit_city\") {\n await updateUser(groupId, from.id, { city: clean(text, 40) });\n await clearState(from.id);\n await sendMessage(chatId, \"Sehir guncellendi.\");\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"edit_bio\") {\n await updateUser(groupId, from.id, { bio: clean(text, 180) });\n await clearState(from.id);\n await sendMessage(chatId, \"Bio guncellendi.\");\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"compose_message\") {\n const toId = Number(data.toId);\n if (!toId) {\n await clearState(from.id);\n return sendMessage(chatId, \"Mesaj gonderilecek eslesme bulunamadi.\");\n }\n if (!(await areMatched(groupId, from.id, toId))) {\n await clearState(from.id);\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n const body = clean(text, 500);\n await sqlite.execute({\n sql: \"insert into match_messages(group_id,from_user_id,to_user_id,text,created_at) values(?,?,?,?,?)\",\n args: [groupId, from.id, toId, body, nowIso()],\n });\n await clearState(from.id);\n await sendMessage(toId, `Mesaj var:\\n\\n${body}`, keyboard([\n [btn(\"Cevap yaz\", `msg:${from.id}`)],\n [btn(\"Menu\", \"menu\")],\n ])).catch(() => {});\n return sendMessage(chatId, \"Mesajin iletildi.\", keyboard([\n [btn(\"Yeni mesaj yaz\", `msg:${toId}`)],\n [btn(\"Menu\", \"menu\")],\n ]));\n }\n}\n\nasync function handleCallback(q: any) {\n const data = q.data ?? \"\";\n const from: TgUser = q.from;\n const chatId = q.message?.chat?.id ?? from.id;\n await answerCallback(q.id);\n if (data === \"cancel\") {\n await clearState(from.id);\n return sendMessage(chatId, \"Islem iptal edildi.\");\n }\n if (data === \"adult_yes\") {\n const state = await getState(from.id);\n const groupId = JSON.parse(state?.data_json || \"{}\").groupId || inferGroupForUser(from.id);\n await updateUser(groupId, from.id, { is_adult: 1 });\n await setState(from.id, \"city\", { groupId });\n return sendMessage(chatId, \"ğŸ“ Sehir yazin. Ornek: Istanbul\");\n }\n if (data.startsWith(\"gender_\")) {\n const state = await getState(from.id);\n const groupId = JSON.parse(state?.data_json || \"{}\").groupId || inferGroupForUser(from.id);\n await updateUser(groupId, from.id, { gender: data.replace(\"gender_\", \"\") });\n await setState(from.id, \"bio\", { groupId });\n return sendMessage(chatId, \"âœ¨ Standart uyelikte iki cinsiyetten profiller de gorunur.\\nğŸ” Kadin/Erkek filtresi tum ucretli paketlerde acilir.\\n\\nğŸ“ Kisa bir bio yazin. En fazla 180 karakter.\");\n }\n if (data.startsWith(\"seek_\")) {\n const state = await getState(from.id);\n const groupId = JSON.parse(state?.data_json || \"{}\").groupId || inferGroupForUser(from.id);\n await updateUser(groupId, from.id, { seek_gender: data.replace(\"seek_\", \"\") });\n await clearState(from.id);\n return sendMessage(chatId, \"âœ… Cinsiyet filtresi guncellendi.\");\n }\n if (data === \"edit_profile\") return showEditProfile(chatId, from.id);\n if (data === \"edit_city\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_city\", { groupId: user.group_id });\n return sendMessage(chatId, \"Yeni sehrini yaz.\");\n }\n if (data === \"edit_bio\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_bio\", { groupId: user.group_id });\n return sendMessage(chatId, \"Yeni bio yaz. En fazla 180 karakter.\");\n }\n if (data === \"edit_photo\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_photo\", { groupId: user.group_id });\n return sendMessage(chatId, \"Profil fotografi olarak kullanmak istedigin fotografi gonder.\");\n }\n if (data === \"refresh_photo\") return refreshProfilePhoto(chatId, from.id);\n if (data.startsWith(\"edit_gender_\")) {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await updateUser(user.group_id, from.id, { gender: data.replace(\"edit_gender_\", \"\") });\n await sendMessage(chatId, \"Cinsiyet guncellendi.\");\n return showEditProfile(chatId, from.id);\n }\n if (data.startsWith(\"msg:\")) return beginMatchedMessage(chatId, from.id, Number(data.split(\":\")[1]));\n if (data === \"browse\") return showNextProfile(chatId, from.id);\n if (data.startsWith(\"like:\")) return likeProfile(chatId, from.id, Number(data.split(\":\")[1]));\n if (data === \"skip\") return showNextProfile(chatId, from.id);\n if (data.startsWith(\"skip:\")) return snoozeProfile(chatId, from.id, Number(data.split(\":\")[1]), 3);\n if (data.startsWith(\"hide:\")) return hideProfile(chatId, from.id, Number(data.split(\":\")[1]));\n if (data === \"buy\") return showShop(chatId, from.id);\n if (data === \"features\") return showFeatures(chatId);\n if (data === \"invite\") return showInvite(chatId, from.id);\n if (data === \"matches\") return showMatches(chatId, from.id);\n if (data === \"filter\") return showGenderFilter(chatId, from.id);\n if (data.startsWith(\"buy:\")) return sendInvoice(chatId, from.id, data.slice(4));\n if (data === \"likers\") return showLikers(chatId, from.id);\n if (data === \"menu\") return sendMainMenu(chatId);\n}\n\nasync function sendMainMenu(chatId: number) {\n const active = await getActiveUser(Number(chatId));\n const groupId = active?.group_id ?? inferGroupForUser(Number(chatId));\n await sendMessage(chatId, await menuText(groupId), keyboard([\n [btn(\"Profilimi duzenle\", \"edit_profile\")],\n [btn(\"ğŸ’ Profil gez\", \"browse\")],\n [btn(\"Eslesmelerim\", \"matches\")],\n [btn(\"ğŸ‘€ Beni begenenler\", \"likers\"), btn(\"ğŸ” Cinsiyet filtresi\", \"filter\")],\n [btn(\"âœ¨ Ozellikler\", \"features\"), btn(\"â Paketler\", \"buy\")],\n [btn(\"ğŸ Davet et\", \"invite\")],\n ]));\n}\n\nasync function showNextProfile(chatId: number, viewerId: number) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n if (!viewer.is_adult) return sendMessage(chatId, \"Devam etmek icin /start ile 18+ onayi verin.\");\n const row = await sqlite.execute({\n sql: `\n select u.* from users u\n left join likes l on l.group_id=u.group_id and l.from_user_id=:viewer and l.to_user_id=u.user_id\n where u.group_id=:group_id and u.user_id<>:viewer and u.deleted_at is null and u.banned=0\n and l.id is null\n and not exists(select 1 from profile_snoozes s where s.group_id=u.group_id and s.viewer_user_id=:viewer and s.snoozed_user_id=u.user_id and s.expires_at>:now)\n and not exists(select 1 from hidden_profiles h where h.group_id=u.group_id and h.viewer_user_id=:viewer and h.hidden_user_id=u.user_id and h.expires_at>:now)\n and (\n not exists(select 1 from premium p where p.group_id=u.group_id and p.user_id=u.user_id and p.feature='liked_only_visibility' and p.expires_at>:now)\n or exists(select 1 from likes lx where lx.group_id=u.group_id and lx.from_user_id=u.user_id and lx.to_user_id=:viewer)\n )\n and (:can_filter=0 or :seek='any' or u.gender is null or u.gender='' or u.gender=:seek)\n order by u.active_dating desc, u.last_seen_at desc\n limit 1\n `,\n args: {\n viewer: viewerId,\n group_id: viewer.group_id,\n seek: viewer.seek_gender || \"any\",\n can_filter: await hasPremium(viewer.group_id, viewerId, \"gender_filter\") ? 1 : 0,\n now: nowIso(),\n },\n });\n const target = row.rows[0] as UserRow | undefined;\n if (!target) return sendMessage(chatId, \"Su an gosterecek profil kalmadi.\");\n await sendProfileCard(chatId, target, keyboard([\n [btn(\"â¤ï¸ Kalp At\", `like:${target.user_id}`), btn(\"â¡ï¸ Gec\", `skip:${target.user_id}`), btn(\"âŒ Olmaz\", `hide:${target.user_id}`)],\n [btn(\"ğŸ Menu\", \"menu\")],\n ]));\n}\n\nasync function hideProfile(chatId: number, viewerId: number, hiddenUserId: number) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sqlite.execute({\n sql: `\n insert into hidden_profiles(group_id,viewer_user_id,hidden_user_id,created_at,expires_at)\n values(?,?,?,?,?)\n on conflict(group_id,viewer_user_id,hidden_user_id) do update set\n created_at=excluded.created_at,\n expires_at=excluded.expires_at\n `,\n args: [viewer.group_id, viewerId, hiddenUserId, nowIso(), addHoursIso(36)],\n });\n return showNextProfile(chatId, viewerId);\n}\n\nasync function snoozeProfile(chatId: number, viewerId: number, snoozedUserId: number, hours: number) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sqlite.execute({\n sql: `\n insert into profile_snoozes(group_id,viewer_user_id,snoozed_user_id,created_at,expires_at)\n values(?,?,?,?,?)\n on conflict(group_id,viewer_user_id,snoozed_user_id) do update set\n created_at=excluded.created_at,\n expires_at=excluded.expires_at\n `,\n args: [viewer.group_id, viewerId, snoozedUserId, nowIso(), addHoursIso(hours)],\n });\n return showNextProfile(chatId, viewerId);\n}\n\nasync function likeProfile(chatId: number, fromId: number, toId: number) {\n const from = await getActiveUser(fromId);\n if (!from || !from.active_dating || !from.is_adult) return sendMessage(chatId, \"Once /start ile aktif profil olusturun.\");\n const target = await getUser(from.group_id, toId);\n if (!target) return sendMessage(chatId, \"Profil bulunamadi.\");\n const canLike = await consumeLikeRight(from.group_id, fromId);\n if (!canLike) return showShop(chatId, fromId, \"Bugunku ucretsiz begeni hakkiniz bitti.\");\n await sqlite.execute({\n sql: \"insert or ignore into likes(group_id,from_user_id,to_user_id,created_at) values(?,?,?,?)\",\n args: [from.group_id, fromId, toId, nowIso()],\n });\n const reciprocal = await sqlite.execute({\n sql: \"select id from likes where group_id=? and from_user_id=? and to_user_id=? limit 1\",\n args: [from.group_id, toId, fromId],\n });\n if (reciprocal.rows[0] && target.active_dating) {\n await sqlite.execute({\n sql: \"insert or ignore into matches(group_id,user1_id,user2_id,created_at) values(?,?,?,?)\",\n args: [from.group_id, Math.min(fromId, toId), Math.max(fromId, toId), nowIso()],\n });\n await sendMatchMessage(chatId, toId);\n await sendMatchMessage(toId, fromId);\n } else {\n await sendMessage(chatId, target.active_dating ? \"â¤ï¸ Kalp atildi.\" : \"â¤ï¸ Kalbin kaydedildi. Karsi taraf KalpAt'a katildiginda akisa dahil olur.\");\n }\n return showNextProfile(chatId, fromId);\n}\n\nasync function sendMatchMessage(chatId: number, otherUserId?: number) {\n const displayText = \"Karsilikli Kalp!\\n\\nBirbirinize kalp attiniz.\\nArtik eslestiniz.\\n\\nBot icinden guvenli sekilde mesajlasabilirsiniz.\";\n const extra = otherUserId ? keyboard([\n [btn(\"Mesaj gonder\", `msg:${otherUserId}`)],\n [btn(\"Menu\", \"menu\")],\n ]) : {};\n if (MATCH_ANIMATION_FILE_ID) {\n const sentAnimation = await tg(\"sendAnimation\", {\n chat_id: chatId,\n animation: MATCH_ANIMATION_FILE_ID,\n caption: displayText,\n ...extra,\n }).then(() => true).catch(() => false);\n if (sentAnimation) return;\n if (!sentAnimation) {\n const sentVideo = await tg(\"sendVideo\", {\n chat_id: chatId,\n video: MATCH_ANIMATION_FILE_ID,\n caption: displayText,\n supports_streaming: true,\n ...extra,\n }).then(() => true).catch(() => false);\n if (sentVideo) return;\n }\n }\n await sendMessage(chatId, displayText, extra);\n}\n\nasync function consumeLikeRight(groupId: number, userId: number) {\n if (isPrivilegedUser(userId)) return true;\n const today = dayKey();\n const credit = await sqlite.execute({ sql: \"select * from credits where group_id=? and user_id=?\", args: [groupId, userId] });\n const row = credit.rows[0] as UserRow | undefined;\n if (!row) {\n await sqlite.execute({ sql: \"insert into credits(group_id,user_id,paid_likes,free_like_day,free_like_used) values(?,?,?,?,1)\", args: [groupId, userId, 0, today] });\n return true;\n }\n if (row.free_like_day !== today) {\n await sqlite.execute({ sql: \"update credits set free_like_day=?,free_like_used=1 where group_id=? and user_id=?\", args: [today, groupId, userId] });\n return true;\n }\n if (!row.free_like_used) {\n await sqlite.execute({ sql: \"update credits set free_like_used=1 where group_id=? and user_id=?\", args: [groupId, userId] });\n return true;\n }\n if (row.plan_expires_at && row.plan_expires_at > nowIso()) {\n const usedToday = row.plan_used_day === today ? Number(row.plan_used_today || 0) : 0;\n const dailyLimit = Number(row.plan_daily_likes || 0);\n if (dailyLimit > usedToday) {\n await sqlite.execute({\n sql: \"update credits set plan_used_day=?,plan_used_today=? where group_id=? and user_id=?\",\n args: [today, usedToday + 1, groupId, userId],\n });\n return true;\n }\n }\n if (Number(row.paid_likes) > 0) {\n await sqlite.execute({ sql: \"update credits set paid_likes=paid_likes-1 where group_id=? and user_id=?\", args: [groupId, userId] });\n return true;\n }\n return false;\n}\n\nasync function showShop(chatId: number, userId?: number, prefix = \"â Paket secin.\") {\n const discountInfo = userId ? await getBestDiscountInfo(userId) : { percent: 0, label: \"\" };\n const discount = discountInfo.percent;\n const price = (key: string) => discountedStars(PACKAGES[key].stars, discount);\n const priceLabel = (key: string) => discount ? `${PACKAGES[key].stars} -> ${price(key)} Stars` : `${PACKAGES[key].stars} Stars`;\n const discountText = discount ? `\\n${discountInfo.label}: %${discount} indirim aktif` : \"\";\n const rows = [\n [btn(`Mini 7 gun - ${priceLabel(\"mini\")}`, \"buy:mini\")],\n [btn(`Plus 30 gun - ${priceLabel(\"plus\")}`, \"buy:plus\")],\n [btn(`Gold 30 gun - ${priceLabel(\"gold\")}`, \"buy:gold\")],\n [btn(`VIP 30 gun - ${priceLabel(\"vip\")}`, \"buy:vip\")],\n [btn(\"âœ¨ Ozellikler\", \"features\"), btn(\"ğŸ Ana menu\", \"menu\")],\n ];\n await sendMessage(chatId, `${prefix}${discountText}\n\nğŸ’— Mini: 7 gun, gunde 3 begeni, cinsiyet filtresi\nğŸ’– Plus: 30 gun, gunde 3 begeni, filtre, beni begenenler\nğŸ’› Gold: 30 gun, gunde 7 begeni, filtre, beni begenenler, gizli gorunurluk\nğŸ‘‘ VIP: 30 gun, gunde 15 begeni, filtre, beni begenenler, gizli gorunurluk`, keyboard(rows));\n}\n\nasync function showFeatures(chatId: number) {\n await sendMessage(chatId, `âœ¨ KalpAt Ozellikleri\n\nğŸ” Cinsiyet filtresi\nSadece kadin, sadece erkek veya farketmez secimi yaparsin. Tum ucretli paketlerde acilir.\n\nğŸ‘€ Beni begenenleri gor\nSeni kimlerin begendigini listelersin. Plus, Gold ve VIP paketlerinde acilir.\n\nğŸ«¥ Gizli gorunurluk\nSadece senin begendigin kisiler profilini gorebilir. Gold ve VIP paketlerinde acilir.\n\nğŸ Davet indirimi\n10 kisi davet et, davet ettiklerinden 1 kisi paket alirsa %10 indirim kazan.`, keyboard([\n [btn(\"â Paketler\", \"buy\"), btn(\"ğŸ Davet et\", \"invite\")],\n [btn(\"ğŸ Ana menu\", \"menu\")],\n ]));\n}\n\nasync function showInvite(chatId: number, userId: number) {\n const link = `https://t.me/${BOT_USERNAME}?start=ref_${userId}`;\n const shareText = `KalpAt'a katil, profilleri kesfet â¤ï¸\\n\\nBenim davet linkim:`;\n const shareUrl = `https://t.me/share/url?url=${encodeURIComponent(link)}&text=${encodeURIComponent(shareText)}`;\n const stats = await getReferralStats(userId);\n await sendMessage(chatId, `ğŸ Davet Kazanci\n\nDavet linkin:\n${link}\n\nDurum:\nğŸ‘¥ Davet edilen: ${stats.total}/10\nâ Alis yapan davetli: ${stats.buyers}/1\nğŸŸ Indirim: ${stats.discount ? \"%10 aktif\" : \"henuz aktif degil\"}\n\n10 kisi davet et ve davet ettiklerinden en az 1 kisi paket alsin; sonraki paketlerinde %10 indirim kullan.\n\nğŸ“© Kullaniciya oner butonuna basinca Telegram kisi secme ekrani acilir. Sectigin kisiye referans linkin mesaj olarak gider.`, keyboard([\n [urlBtn(\"ğŸ“© Kullaniciya oner\", shareUrl)],\n [btn(\"â Paketler\", \"buy\")],\n [btn(\"ğŸ Ana menu\", \"menu\")],\n ]));\n}\n\nasync function showGenderFilter(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n const premium = await hasPremium(user.group_id, userId, \"gender_filter\");\n if (!premium) {\n return showShop(chatId, userId, \"ğŸ” Standart uyelikte iki cinsiyetten profiller gorunur. Cinsiyet filtresi tum ucretli paketlerde acilir.\");\n }\n await sendMessage(chatId, \"ğŸ” Kimi gormek istersiniz?\", keyboard([\n [btn(\"ğŸ‘© Kadin\", \"seek_female\"), btn(\"ğŸ‘¨ Erkek\", \"seek_male\"), btn(\"âœ¨ Farketmez\", \"seek_any\")],\n [btn(\"ğŸ Ana menu\", \"menu\")],\n ]));\n}\n\nasync function sendInvoice(chatId: number, userId: number, productId: string) {\n const item = PACKAGES[productId];\n if (!item) return sendMessage(chatId, \"Paket bulunamadi.\");\n const discountInfo = await getBestDiscountInfo(userId);\n const discount = discountInfo.percent;\n const amount = discountedStars(item.stars, discount);\n const payload = JSON.stringify({ productId, userId, discount, discountLabel: discountInfo.label, amount, t: Date.now() });\n await tg(\"sendInvoice\", {\n chat_id: chatId,\n title: discount ? `${item.title} (%${discount} indirim)` : item.title,\n description: `${BOT_NAME} dijital paket`,\n payload,\n provider_token: \"\",\n currency: \"XTR\",\n prices: [{ label: item.title, amount }],\n });\n}\n\nasync function handleSuccessfulPayment(msg: any) {\n const payment = msg.successful_payment;\n const payload = JSON.parse(payment.invoice_payload || \"{}\");\n const productId = payload.productId;\n const buyerId = msg.from.id;\n const groupId = inferGroupForUser(buyerId);\n await sqlite.execute({\n sql: \"insert into purchases(group_id,user_id,product_id,stars,charge_id,payload,created_at) values(?,?,?,?,?,?,?)\",\n args: [groupId, buyerId, productId, payment.total_amount, payment.telegram_payment_charge_id, payment.invoice_payload, nowIso()],\n });\n await markReferralPurchase(buyerId);\n const pack = PACKAGES[productId];\n if (pack) {\n await sqlite.execute({\n sql: `\n insert into credits(group_id,user_id,paid_likes,free_like_day,free_like_used,plan_daily_likes,plan_used_day,plan_used_today,plan_expires_at)\n values(?,?,0,'',0,?,'',0,?)\n on conflict(group_id,user_id) do update set\n plan_daily_likes=excluded.plan_daily_likes,\n plan_used_day='',\n plan_used_today=0,\n plan_expires_at=excluded.plan_expires_at\n `,\n args: [groupId, buyerId, pack.dailyLikes, addDaysIso(pack.days)],\n });\n for (const feature of pack.features) {\n await sqlite.execute({\n sql: `\n insert into premium(group_id,user_id,feature,expires_at,created_at) values(?,?,?,?,?)\n on conflict(group_id,user_id,feature) do update set expires_at=excluded.expires_at\n `,\n args: [groupId, buyerId, feature, addDaysIso(pack.days), nowIso()],\n });\n }\n await sendMessage(buyerId, `âœ… ${pack.title} aktif edildi.\\n${pack.days} gun boyunca gunde ${pack.dailyLikes} begeni hakkiniz var.`);\n }\n}\n\nasync function showLikers(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start kullanin.\");\n const premium = await hasPremium(user.group_id, userId, \"see_likers\");\n if (!premium) return showShop(chatId, userId, \"ğŸ‘€ Beni begenenleri gormek Plus, Gold ve VIP paketlerinde acilir.\");\n const res = await sqlite.execute({\n sql: \"select u.* from likes l join users u on u.group_id=l.group_id and u.user_id=l.from_user_id where l.group_id=? and l.to_user_id=? order by l.created_at desc limit 10\",\n args: [user.group_id, userId],\n });\n if (!res.rows.length) return sendMessage(chatId, \"Henuz begeni yok.\");\n await sendMessage(chatId, res.rows.map((r: any) => profileText(r)).join(\"\\n\\n---\\n\\n\"));\n}\n\nasync function showMatches(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start kullanin.\");\n const res = await sqlite.execute({\n sql: `\n select u.* from matches m\n join users u on u.group_id=m.group_id\n and u.user_id=case when m.user1_id=:user then m.user2_id else m.user1_id end\n where m.group_id=:group_id and (m.user1_id=:user or m.user2_id=:user)\n and u.deleted_at is null and u.banned=0\n order by m.created_at desc\n limit 10\n `,\n args: { group_id: user.group_id, user: userId },\n });\n if (!res.rows.length) return sendMessage(chatId, \"Henuz eslesme yok.\", keyboard([[btn(\"Profil gez\", \"browse\")], [btn(\"Menu\", \"menu\")]]));\n const rows = (res.rows as any[]).map((r) => {\n const name = clean(`${r.first_name || \"\"} ${r.last_name || \"\"}` || \"Eslesme\", 24);\n return [btn(`Mesaj: ${name || \"Eslesme\"}`, `msg:${r.user_id}`)];\n });\n rows.push([btn(\"Profil gez\", \"browse\"), btn(\"Menu\", \"menu\")]);\n return sendMessage(chatId, \"Eslesmelerin:\", keyboard(rows));\n}\n\nasync function firstWelcomeText(groupId: number) {\n const stats = await getPublicStats(groupId);\n return `â¤ï¸ KalpAt'a hos geldin\n\nğŸ‘¤ ${stats.total} profil seni bekliyor\nğŸ”¥ ${stats.recent} kisi yakin zamanda aktifti\nğŸ’˜ ${stats.active} profil eslesmeye acik\n\n/start ile eslesme sistemine katildiniz.\nDevam etmek icin 18+ oldugunuzu onaylayin.`;\n}\n\nasync function welcomeBackText(groupId: number) {\n const stats = await getPublicStats(groupId);\n return `â¤ï¸ KalpAt'a tekrar hos geldin\n\nğŸ‘¤ ${stats.total} profil\nğŸ”¥ ${stats.recent} yakin zamanda aktif\nğŸ’˜ ${stats.active} eslesmeye acik\n\nProfilin aktif. Buradan profil gezebilir, begenilerini gorebilir, paketleri inceleyebilir veya arkadaslarini davet edebilirsin.`;\n}\n\nasync function menuText(groupId: number) {\n const stats = await getPublicStats(groupId);\n return `â¤ï¸ KalpAt\n\nğŸ‘¤ ${stats.total} profil\nğŸ”¥ ${stats.recent} yakin zamanda aktif\nğŸ’˜ ${stats.active} eslesmeye acik\n\nNe yapmak istersin?`;\n}\n\nasync function getPublicStats(groupId: number) {\n const since = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000).toISOString();\n const res = await sqlite.execute({\n sql: `\n select\n count(*) total,\n sum(case when active_dating=1 then 1 else 0 end) active,\n sum(case when last_seen_at>=? then 1 else 0 end) recent\n from users\n where group_id=? and deleted_at is null and banned=0\n `,\n args: [since, groupId],\n });\n const row = (res.rows[0] || {}) as UserRow;\n return {\n total: Number(row.total || 0),\n active: Number(row.active || 0),\n recent: Number(row.recent || 0),\n };\n}\n\nasync function showEditProfile(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sendMessage(chatId, `Profil duzenle\\n\\n${profileText(user)}`, keyboard([\n [btn(\"Sehir\", \"edit_city\"), btn(\"Bio\", \"edit_bio\")],\n [btn(\"Kadin\", \"edit_gender_female\"), btn(\"Erkek\", \"edit_gender_male\")],\n [btn(\"Fotograf ekle/degistir\", \"edit_photo\")],\n [btn(\"Telegram fotografimi yenile\", \"refresh_photo\")],\n [btn(\"Profilimi goster\", \"menu\")],\n ]));\n}\n\nasync function handleProfilePhotoUpload(chatId: number, from: TgUser, msg: any, state: any) {\n const text = (msg.text ?? \"\").trim();\n if (text === \"/menu\" || text === \"/cancel\") {\n await clearState(from.id);\n return sendMainMenu(chatId);\n }\n if (!msg.photo?.length) {\n return sendMessage(chatId, \"Bu adimda sadece fotograf kabul edilir. Iptal etmek icin /menu yazabilirsiniz.\");\n }\n const data = JSON.parse(state.data_json || \"{}\");\n const groupId = Number(data.groupId || inferGroupForUser(from.id));\n const photo = msg.photo[msg.photo.length - 1];\n await updateUser(groupId, from.id, { photo_file_id: photo.file_id });\n await clearState(from.id);\n await sendMessage(chatId, \"Profil fotografi guncellendi.\");\n return sendProfile(chatId, from.id);\n}\n\nasync function refreshProfilePhoto(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n const fileId = await getUserPhotoFileId(userId);\n if (!fileId) return sendMessage(chatId, \"Telegram profil fotografi okunamadi. Profil duzenle > Fotograf ekle/degistir ile fotograf yukleyebilirsin.\");\n await updateUser(user.group_id, userId, { photo_file_id: fileId });\n await sendMessage(chatId, \"Telegram profil fotografi yenilendi.\");\n return sendProfile(chatId, userId);\n}\n\nasync function beginMatchedMessage(chatId: number, fromId: number, toId: number) {\n const user = await getActiveUser(fromId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n if (!(await areMatched(user.group_id, fromId, toId))) return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n await setState(fromId, \"compose_message\", { groupId: user.group_id, toId });\n return sendMessage(chatId, \"Mesajini yaz. Link, @kullanici adi, telefon, fotograf ve video gonderilemez.\");\n}\n\nasync function areMatched(groupId: number, a: number, b: number) {\n const res = await sqlite.execute({\n sql: \"select 1 from matches where group_id=? and user1_id=? and user2_id=? limit 1\",\n args: [groupId, Math.min(a, b), Math.max(a, b)],\n });\n return Boolean(res.rows[0]);\n}\n\nasync function handleAdmin(chatId: number, fromId: number, text: string) {\n if (fromId !== ADMIN_ID) return sendMessage(chatId, \"Yetki yok.\");\n const parts = text.split(/\\s+/);\n if (parts[1] === \"stats\") {\n const groups = await sqlite.execute({ sql: \"select group_id,count(*) total,sum(active_dating) active,sum(case when active_dating=0 then 1 else 0 end) passive from users where deleted_at is null group by group_id\" });\n const likes = await sqlite.execute({ sql: \"select count(*) likes from likes\" });\n const matches = await sqlite.execute({ sql: \"select count(*) matches from matches\" });\n const purchases = await sqlite.execute({ sql: \"select count(*) purchases from purchases\" });\n return sendMessage(chatId, \"Stats:\\n\" + JSON.stringify({\n groups: groups.rows,\n likes: likes.rows[0],\n matches: matches.rows[0],\n purchases: purchases.rows[0],\n pending: pendingUsers.size,\n }, null, 2));\n }\n if (parts[1] === \"ban\" && parts[2]) {\n await sqlite.execute({ sql: \"update users set banned=1 where user_id=?\", args: [Number(parts[2])] });\n return sendMessage(chatId, \"Banlandi.\");\n }\n if (parts[1] === \"unban\" && parts[2]) {\n await sqlite.execute({ sql: \"update users set banned=0 where user_id=?\", args: [Number(parts[2])] });\n return sendMessage(chatId, \"Ban kaldirildi.\");\n }\n if (parts[1] === \"delete\" && parts[2]) {\n await sqlite.execute({ sql: \"update users set deleted_at=? where user_id=?\", args: [nowIso(), Number(parts[2])] });\n return sendMessage(chatId, \"Silindi.\");\n }\n if (parts[1] === \"flush\") {\n const count = await flushPendingUsers();\n return sendMessage(chatId, `${count} pending kullanici yazildi.`);\n }\n if (parts[1] === \"syncglobal\") {\n const count = await syncGlobalPool();\n return sendMessage(chatId, `${count} profil ana havuza kopyalandi.`);\n }\n if (parts[1] === \"testmatch\") {\n const targetChatId = Number(parts[2] || chatId);\n await sendMatchMessage(targetChatId);\n return sendMessage(chatId, \"Test eslesme bildirimi gonderildi.\");\n }\n return sendMessage(chatId, \"/admin stats | ban ID | unban ID | delete ID | flush | syncglobal | testmatch [CHAT_ID]\");\n}\n\nasync function deleteProfile(chatId: number, userId: number) {\n await sqlite.execute({ sql: \"update users set deleted_at=?,active_dating=0 where user_id=?\", args: [nowIso(), userId] });\n await sendMessage(chatId, \"Profiliniz silindi. Botu tekrar kullanmak icin /start yazabilirsiniz.\");\n}\n\nasync function syncGlobalPool() {\n const res = await sqlite.execute({ sql: \"select * from users where group_id<>0 and deleted_at is null and banned=0\" });\n const rows = res.rows as any[];\n if (!rows.length) return 0;\n await sqlite.batch(rows.map((u) => ({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,city,gender,seek_gender,bio,message_count,last_seen_at,created_at,updated_at)\n values(0,:user_id,:first_name,:last_name,:username,:photo_file_id,:active_dating,:is_adult,:city,:gender,:seek_gender,:bio,:message_count,:last_seen_at,:created_at,:updated_at)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,\n last_name=excluded.last_name,\n username=excluded.username,\n photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n message_count=max(users.message_count,excluded.message_count),\n last_seen_at=excluded.last_seen_at,\n updated_at=excluded.updated_at\n `,\n args: u,\n })));\n return rows.length;\n}\n\nasync function sendProfile(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Profil bulunamadi. /start yazin.\");\n await sendProfileCard(chatId, user);\n}\n\nasync function sendAdminFileId(chatId: number, msg: any) {\n const animationId = msg.animation?.file_id;\n const videoId = msg.video?.file_id;\n const videoNoteId = msg.video_note?.file_id;\n const documentId = msg.document?.file_id;\n const fileId = animationId || videoId || videoNoteId || documentId;\n const kind = animationId ? \"animation\" : videoId ? \"video\" : videoNoteId ? \"video_note\" : \"document\";\n if (!fileId) return;\n await sendMessage(chatId, `Dosya tipi: ${kind}\\n\\nVal Town env'e sunu ekle:\\n\\nMATCH_ANIMATION_FILE_ID=${fileId}`);\n}\n\nasync function sendProfileCard(chatId: number, user: UserRow, extra: any = {}) {\n if (user.photo_file_id) {\n await tg(\"sendPhoto\", {\n chat_id: chatId,\n photo: user.photo_file_id,\n caption: profileText(user),\n ...extra,\n });\n return;\n }\n await sendMessage(chatId, profileText(user), extra);\n}\n\nfunction profileText(u: UserRow) {\n const name = `${u.first_name || \"\"} ${u.last_name || \"\"}`.trim() || \"Isimsiz\";\n const active = u.active_dating ? \"Aktif\" : \"Pasif\";\n return [\n `${name}`,\n `Durum: ${active}`,\n `Sehir: ${u.city || \"eklenmedi\"}`,\n `Cinsiyet: ${labelGender(u.gender)}`,\n `Bio: ${u.bio || \"eklenmedi\"}`,\n `Son aktif: ${formatLastSeen(u.last_seen_at)}`,\n ].join(\"\\n\");\n}\n\nasync function flushPendingUsers() {\n await ensureSchema();\n const fromDb = await sqlite.execute({ sql: \"select * from pending_users order by created_at asc limit 1000\" });\n const items = [\n ...fromDb.rows.map((r: any) => ({\n groupId: Number(r.group_id),\n userId: Number(r.user_id),\n firstName: r.first_name ?? \"\",\n lastName: r.last_name ?? \"\",\n username: r.username ?? \"\",\n photoFileId: r.photo_file_id ?? \"\",\n messageCount: Number(r.message_count ?? 1),\n lastSeenAt: r.last_seen_at ?? nowIso(),\n })),\n ...[...pendingUsers.values()].filter((p) => !fromDb.rows.some((r: any) => Number(r.group_id) === p.groupId && Number(r.user_id) === p.userId)),\n ];\n if (!items.length) return 0;\n const queries = items.map((p) => ({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,message_count,last_seen_at,created_at,updated_at)\n values(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,:messageCount,:lastSeenAt,:now,:now)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n message_count=users.message_count+excluded.message_count,last_seen_at=excluded.last_seen_at,updated_at=excluded.updated_at\n `,\n args: { ...p, now: nowIso() },\n }));\n await sqlite.batch(queries);\n await sqlite.batch(items.map((p) => ({\n sql: \"delete from pending_users where group_id=? and user_id=?\",\n args: [p.groupId, p.userId],\n })));\n pendingUsers.clear();\n return items.length;\n}\n\nasync function upsertPassiveUser(p: PendingUser) {\n await sqlite.execute({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,message_count,last_seen_at,created_at,updated_at)\n values(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,:messageCount,:lastSeenAt,:now,:now)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,\n photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n updated_at=excluded.updated_at\n `,\n args: { ...p, now: nowIso() },\n });\n}\n\nasync function warmCache() {\n if (cacheReady) return;\n await ensureSchema();\n const res = await sqlite.execute({ sql: \"select group_id,user_id from users where deleted_at is null\" });\n for (const row of res.rows as any[]) knownUserIds.add(userKey(Number(row.group_id), Number(row.user_id)));\n const pending = await sqlite.execute({ sql: \"select group_id,user_id from pending_users\" });\n for (const row of pending.rows as any[]) knownUserIds.add(userKey(Number(row.group_id), Number(row.user_id)));\n cacheReady = true;\n}\n\nasync function ensureSchema() {\n if (schemaReady) return;\n await sqlite.batch([\n `create table if not exists users(\n id integer primary key autoincrement,\n group_id integer not null,\n user_id integer not null,\n first_name text default '',\n last_name text default '',\n username text default '',\n photo_file_id text default '',\n active_dating integer default 0,\n is_adult integer default 0,\n city text default '',\n gender text default '',\n seek_gender text default 'any',\n bio text default '',\n message_count integer default 0,\n last_seen_at text,\n banned integer default 0,\n deleted_at text,\n created_at text,\n updated_at text,\n unique(group_id,user_id)\n )`,\n `create table if not exists states(user_id integer primary key,step text,data_json text,updated_at text)`,\n `create table if not exists pending_users(group_id integer,user_id integer,first_name text default '',last_name text default '',username text default '',photo_file_id text default '',message_count integer default 1,last_seen_at text,created_at text,primary key(group_id,user_id))`,\n `create table if not exists likes(id integer primary key autoincrement,group_id integer,from_user_id integer,to_user_id integer,created_at text,unique(group_id,from_user_id,to_user_id))`,\n `create table if not exists hidden_profiles(id integer primary key autoincrement,group_id integer,viewer_user_id integer,hidden_user_id integer,created_at text,expires_at text default '',unique(group_id,viewer_user_id,hidden_user_id))`,\n `create table if not exists profile_snoozes(id integer primary key autoincrement,group_id integer,viewer_user_id integer,snoozed_user_id integer,created_at text,expires_at text,unique(group_id,viewer_user_id,snoozed_user_id))`,\n `create table if not exists matches(id integer primary key autoincrement,group_id integer,user1_id integer,user2_id integer,created_at text,unique(group_id,user1_id,user2_id))`,\n `create table if not exists match_messages(id integer primary key autoincrement,group_id integer,from_user_id integer,to_user_id integer,text text,created_at text)`,\n `create table if not exists credits(\n group_id integer,\n user_id integer,\n paid_likes integer default 0,\n free_like_day text default '',\n free_like_used integer default 0,\n plan_daily_likes integer default 0,\n plan_used_day text default '',\n plan_used_today integer default 0,\n plan_expires_at text default '',\n primary key(group_id,user_id)\n )`,\n `create table if not exists purchases(id integer primary key autoincrement,group_id integer,user_id integer,product_id text,stars integer,charge_id text,payload text,created_at text)`,\n `create table if not exists premium(group_id integer,user_id integer,feature text,expires_at text,created_at text,primary key(group_id,user_id,feature))`,\n `create table if not exists referrals(referrer_id integer,referred_id integer,created_at text,purchased integer default 0,purchased_at text,primary key(referrer_id,referred_id))`,\n ]);\n await migrateCredits();\n await migrateProfilePhotos();\n await migrateVisibilityTables();\n schemaReady = true;\n}\n\nasync function migrateCredits() {\n const columns = [\n [\"plan_daily_likes\", \"integer default 0\"],\n [\"plan_used_day\", \"text default ''\"],\n [\"plan_used_today\", \"integer default 0\"],\n [\"plan_expires_at\", \"text default ''\"],\n ];\n for (const [name, type] of columns) {\n await sqlite.execute({ sql: `alter table credits add column ${name} ${type}` }).catch(() => {});\n }\n}\n\nasync function migrateProfilePhotos() {\n await sqlite.execute({ sql: \"alter table users add column photo_file_id text default ''\" }).catch(() => {});\n await sqlite.execute({ sql: \"alter table pending_users add column photo_file_id text default ''\" }).catch(() => {});\n}\n\nasync function migrateVisibilityTables() {\n await sqlite.execute({ sql: \"alter table hidden_profiles add column expires_at text default ''\" }).catch(() => {});\n}\n\nasync function getUser(groupId: number, userId: number) {\n const res = await sqlite.execute({ sql: \"select * from users where group_id=? and user_id=? and deleted_at is null and banned=0\", args: [groupId, userId] });\n return res.rows[0] as UserRow | undefined;\n}\n\nasync function getActiveUser(userId: number) {\n const res = await sqlite.execute({\n sql: \"select * from users where user_id=? and active_dating=1 and deleted_at is null and banned=0 order by updated_at desc limit 1\",\n args: [userId],\n });\n return res.rows[0] as UserRow | undefined;\n}\n\nasync function getPendingUser(groupId: number, userId: number): Promise {\n const res = await sqlite.execute({ sql: \"select * from pending_users where group_id=? and user_id=? limit 1\", args: [groupId, userId] });\n const row = res.rows[0] as UserRow | undefined;\n if (!row) return undefined;\n return {\n groupId: Number(row.group_id),\n userId: Number(row.user_id),\n firstName: row.first_name ?? \"\",\n lastName: row.last_name ?? \"\",\n username: row.username ?? \"\",\n photoFileId: row.photo_file_id ?? \"\",\n messageCount: Number(row.message_count ?? 1),\n lastSeenAt: row.last_seen_at ?? nowIso(),\n };\n}\n\nasync function updateUser(groupId: number, userId: number, fields: Record) {\n const allowed = [\"city\", \"gender\", \"seek_gender\", \"bio\", \"is_adult\", \"photo_file_id\"];\n const keys = Object.keys(fields).filter((k) => allowed.includes(k));\n if (!keys.length) return;\n await sqlite.execute({\n sql: `update users set ${keys.map((k) => `${k}=?`).join(\",\")},updated_at=? where group_id=? and user_id=?`,\n args: [...keys.map((k) => fields[k]), nowIso(), groupId, userId],\n });\n}\n\nasync function setState(userId: number, step: string, data: any) {\n await sqlite.execute({\n sql: \"insert into states(user_id,step,data_json,updated_at) values(?,?,?,?) on conflict(user_id) do update set step=excluded.step,data_json=excluded.data_json,updated_at=excluded.updated_at\",\n args: [userId, step, JSON.stringify(data), nowIso()],\n });\n}\nasync function getState(userId: number) {\n const res = await sqlite.execute({ sql: \"select * from states where user_id=?\", args: [userId] });\n return res.rows[0] as UserRow | undefined;\n}\nasync function clearState(userId: number) {\n await sqlite.execute({ sql: \"delete from states where user_id=?\", args: [userId] });\n}\n\nasync function hasPremium(groupId: number, userId: number, feature: string) {\n if (isPrivilegedUser(userId)) return true;\n const res = await sqlite.execute({\n sql: \"select 1 from premium where group_id=? and user_id=? and feature=? and expires_at>? limit 1\",\n args: [groupId, userId, feature, nowIso()],\n });\n return Boolean(res.rows[0]);\n}\n\nasync function recordReferral(userId: number, payload: string) {\n const match = /^ref_(\\d+)$/.exec(payload || \"\");\n if (!match) return;\n const referrerId = Number(match[1]);\n if (!referrerId || referrerId === userId) return;\n await sqlite.execute({\n sql: \"insert or ignore into referrals(referrer_id,referred_id,created_at,purchased) values(?,?,?,0)\",\n args: [referrerId, userId, nowIso()],\n });\n}\n\nasync function markReferralPurchase(userId: number) {\n await sqlite.execute({\n sql: \"update referrals set purchased=1,purchased_at=? where referred_id=?\",\n args: [nowIso(), userId],\n });\n}\n\nasync function getReferralStats(userId: number) {\n const total = await sqlite.execute({ sql: \"select count(*) total from referrals where referrer_id=?\", args: [userId] });\n const buyers = await sqlite.execute({ sql: \"select count(*) buyers from referrals where referrer_id=? and purchased=1\", args: [userId] });\n const totalCount = Number((total.rows[0] as any)?.total || 0);\n const buyerCount = Number((buyers.rows[0] as any)?.buyers || 0);\n return { total: totalCount, buyers: buyerCount, discount: totalCount >= 10 && buyerCount >= 1 };\n}\n\nasync function getReferralDiscount(userId: number) {\n const stats = await getReferralStats(userId);\n return stats.discount ? 10 : 0;\n}\n\nasync function getBestDiscountInfo(userId: number) {\n const welcomeActive = WELCOME_DISCOUNT_PERCENT > 0 && new Date(WELCOME_CAMPAIGN_UNTIL).getTime() > Date.now();\n const welcome = welcomeActive ? WELCOME_DISCOUNT_PERCENT : 0;\n const referral = await getReferralDiscount(userId);\n if (welcome >= referral && welcome > 0) return { percent: welcome, label: \"Hos Geldin Kampanyasi\" };\n if (referral > 0) return { percent: referral, label: \"Davet indirimi\" };\n return { percent: 0, label: \"\" };\n}\n\nfunction discountedStars(stars: number, discount: number) {\n if (!discount) return stars;\n return Math.max(1, Math.round(stars * (100 - discount) / 100));\n}\n\nfunction inferGroupForUser(userId: number) {\n if (!STRICT_ALLOWED_GROUPS) return 0;\n for (const key of knownUserIds) {\n const [g, u] = key.split(\":\").map(Number);\n if (u === userId) return g;\n }\n const first = [...ALLOWED_GROUP_IDS][0];\n return first || 0;\n}\n\nasync function maybeSetWebhook(url: string) {\n if (webhookReady) return;\n const webhookUrl = new URL(url);\n webhookUrl.pathname = \"/webhook\";\n webhookUrl.search = \"\";\n await tg(\"setWebhook\", { url: webhookUrl.toString() });\n webhookReady = true;\n}\n\nasync function tg(method: string, body: any) {\n const res = await fetch(`${TG}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const data = await res.json().catch(() => ({}));\n if (!res.ok || data.ok === false) throw new Error(`${method}: ${JSON.stringify(data)}`);\n return data;\n}\nasync function sendMessage(chatId: number | string, text: string, extra: any = {}) {\n return tg(\"sendMessage\", { chat_id: chatId, text, ...extra });\n}\nasync function answerCallback(id: string) {\n return tg(\"answerCallbackQuery\", { callback_query_id: id });\n}\nasync function answerPreCheckout(id: string, ok: boolean) {\n return tg(\"answerPreCheckoutQuery\", { pre_checkout_query_id: id, ok });\n}\nasync function getUserPhotoFileId(userId: number) {\n try {\n const data = await tg(\"getUserProfilePhotos\", { user_id: userId, limit: 1 });\n const photos = data.result?.photos;\n const first = Array.isArray(photos) ? photos[0] : undefined;\n if (!Array.isArray(first) || !first.length) return \"\";\n return first[first.length - 1]?.file_id ?? \"\";\n } catch {\n return \"\";\n }\n}\nasync function logError(scope: string, err: unknown) {\n console.error(scope, err);\n if (LOG_CHAT_ID) {\n await sendMessage(LOG_CHAT_ID, `Hata: ${scope}\\n${String((err as Error)?.message ?? err).slice(0, 1000)}`).catch(() => {});\n }\n}\n\nfunction keyboard(inline_keyboard: any[][]) {\n return { reply_markup: { inline_keyboard } };\n}\nfunction btn(text: string, callback_data: string) {\n return { text, callback_data };\n}\nfunction urlBtn(text: string, url: string) {\n return { text, url };\n}\nfunction hasMediaPayload(msg: any) {\n return Boolean(\n msg.photo ||\n msg.video ||\n msg.animation ||\n msg.document ||\n msg.audio ||\n msg.voice ||\n msg.video_note ||\n msg.sticker,\n );\n}\nfunction hasBlockedContact(text: string) {\n return /(https?:\\/\\/|www\\.|t\\.me\\/|telegram\\.me\\/|@\\w{3,}|(?:\\+?\\d[\\d\\s().-]{7,}\\d))/i.test(text);\n}\nfunction ok() {\n return new Response(\"ok\", { status: 200 });\n}\nfunction userKey(groupId: number, userId: number) {\n return `${groupId}:${userId}`;\n}\nfunction nowIso() {\n return new Date().toISOString();\n}\nfunction dayKey() {\n return new Intl.DateTimeFormat(\"en-CA\", { timeZone: TZ, year: \"numeric\", month: \"2-digit\", day: \"2-digit\" }).format(new Date());\n}\nfunction addDaysIso(days: number) {\n const d = new Date();\n d.setUTCDate(d.getUTCDate() + days);\n return d.toISOString();\n}\nfunction addHoursIso(hours: number) {\n const d = new Date();\n d.setUTCHours(d.getUTCHours() + hours);\n return d.toISOString();\n}\nfunction formatLastSeen(value: string) {\n if (!value) return \"bilinmiyor\";\n const date = new Date(value);\n if (Number.isNaN(date.getTime())) return \"yakinda\";\n const diffMs = Date.now() - date.getTime();\n const dayMs = 24 * 60 * 60 * 1000;\n if (diffMs < dayMs) return \"bugun\";\n if (diffMs < 2 * dayMs) return \"dun\";\n if (diffMs < 7 * dayMs) return \"son 7 gun icinde\";\n return new Intl.DateTimeFormat(\"tr-TR\", { timeZone: TZ, day: \"numeric\", month: \"long\" }).format(date);\n}\nfunction clean(text: string, max: number) {\n return text.trim().replace(/\\s+/g, \" \").slice(0, max);\n}\nfunction labelGender(g: string) {\n if (g === \"female\") return \"Kadin\";\n if (g === \"male\") return \"Erkek\";\n if (g === \"any\") return \"Farketmez\";\n return \"eklenmedi\";\n}\nfunction isPrivilegedUser(userId: number) {\n return Boolean(userId && (userId === OWNER_ID || userId === ADMIN_ID));\n}\nasync function requireAdminFromQuery(admin: string | undefined) {\n if (!ADMIN_ID || Number(admin) !== ADMIN_ID) throw new Error(\"Yetki yok\");\n}","import { Hono } from \"https://deno.land/x/hono@v4.3.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\") ?? \"\";\nconst ADMIN_ID = Number(Deno.env.get(\"ADMIN_ID\") ?? \"0\");\nconst OWNER_ID = Number(Deno.env.get(\"OWNER_ID\") ?? \"8241488481\");\nconst LOG_CHAT_ID = Deno.env.get(\"LOG_CHAT_ID\") ?? \"\";\nconst BOT_USERNAME = (Deno.env.get(\"BOT_USERNAME\") ?? \"KalpAtBot\").replace(\n /^@/,\n \"\",\n);\nconst MATCH_ANIMATION_FILE_ID = Deno.env.get(\"MATCH_ANIMATION_FILE_ID\") ?? \"\";\nconst WELCOME_DISCOUNT_PERCENT = Number(\n Deno.env.get(\"WELCOME_DISCOUNT_PERCENT\") ?? \"30\",\n);\nconst WELCOME_CAMPAIGN_UNTIL = Deno.env.get(\"WELCOME_CAMPAIGN_UNTIL\") ??\n \"2026-07-11T20:59:59Z\";\nconst STRICT_ALLOWED_GROUPS = Deno.env.get(\"STRICT_ALLOWED_GROUPS\") === \"1\";\nconst ALLOWED_GROUP_IDS = new Set(\n (Deno.env.get(\"ALLOWED_GROUP_IDS\") ?? \"\")\n .split(\",\")\n .map((x) => Number(x.trim()))\n .filter(Number.isFinite),\n);\nconst TG = `https://api.telegram.org/bot${TOKEN}`;\nconst TZ = \"Europe/Istanbul\";\nconst BOT_NAME = \"KalpAt\";\nconst EM = {\n heart: \"\\u{2764}\\u{FE0F}\",\n twoHearts: \"\\u{1F495}\",\n sparklingHeart: \"\\u{1F496}\",\n party: \"\\u{1F389}\",\n user: \"\\u{1F464}\",\n fire: \"\\u{1F525}\",\n eye: \"\\u{1F440}\",\n search: \"\\u{1F50E}\",\n sparkles: \"\\u{2728}\",\n star: \"\\u{2B50}\",\n gift: \"\\u{1F381}\",\n home: \"\\u{1F3E0}\",\n check: \"\\u{2705}\",\n cross: \"\\u{274C}\",\n next: \"\\u{27A1}\\u{FE0F}\",\n chat: \"\\u{1F4AC}\",\n camera: \"\\u{1F4F7}\",\n pin: \"\\u{1F4CD}\",\n note: \"\\u{1F4DD}\",\n woman: \"\\u{1F469}\",\n man: \"\\u{1F468}\",\n ticket: \"\\u{1F3AB}\",\n};\n\nconst PACKAGES: Record = {\n mini: {\n title: \"Kalp Mini\",\n stars: 250,\n days: 7,\n dailyLikes: 3,\n features: [\"gender_filter\"],\n },\n plus: {\n title: \"Kalp Plus\",\n stars: 450,\n days: 30,\n dailyLikes: 3,\n features: [\"gender_filter\", \"see_likers\"],\n },\n gold: {\n title: \"Kalp Gold\",\n stars: 800,\n days: 30,\n dailyLikes: 7,\n features: [\"gender_filter\", \"see_likers\", \"liked_only_visibility\"],\n },\n vip: {\n title: \"Kalp VIP\",\n stars: 1500,\n days: 30,\n dailyLikes: 15,\n features: [\"gender_filter\", \"see_likers\", \"liked_only_visibility\"],\n },\n};\n\nlet schemaReady = false;\nlet webhookReady = false;\nlet cacheReady = false;\nconst knownUserIds = new Set(); // groupId:userId\nconst pendingUsers = new Map();\n\ntype TgUser = {\n id: number;\n is_bot?: boolean;\n first_name?: string;\n last_name?: string;\n username?: string;\n};\ntype PendingUser = {\n groupId: number;\n userId: number;\n firstName: string;\n lastName: string;\n username: string;\n photoFileId: string;\n messageCount: number;\n lastSeenAt: string;\n};\ntype UserRow = Record;\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.json({ ok: true, bot: BOT_NAME }));\napp.get(\"/flush\", async (c) => {\n await requireAdminFromQuery(c.req.query(\"admin\"));\n const count = await flushPendingUsers();\n return c.json({ ok: true, flushed: count });\n});\napp.get(\"/cron\", async (c) => {\n await requireAdminFromQuery(c.req.query(\"admin\"));\n const count = await flushPendingUsers();\n return c.json({ ok: true, flushed: count, now: nowIso() });\n});\napp.post(\"/\", async (c) => handleUpdate(await c.req.json()));\napp.post(\"/webhook\", async (c) => handleUpdate(await c.req.json()));\n\nexport default async function handler(req: Request): Promise {\n if (!TOKEN) return new Response(\"TELEGRAM_BOT_TOKEN eksik\", { status: 500 });\n await ensureSchema();\n await maybeSetWebhook(req.url);\n return app.fetch(req);\n}\n\nasync function handleUpdate(update: any): Promise {\n try {\n await ensureSchema();\n if (update.pre_checkout_query) {\n await answerPreCheckout(update.pre_checkout_query.id, true);\n return ok();\n }\n if (update.message?.successful_payment) {\n await handleSuccessfulPayment(update.message);\n return ok();\n }\n if (update.callback_query) {\n await handleCallback(update.callback_query);\n return ok();\n }\n if (update.message) {\n await handleMessage(update.message);\n return ok();\n }\n } catch (err) {\n await logError(\"update\", err);\n }\n return ok();\n}\n\nasync function handleMessage(msg: any) {\n const chat = msg.chat;\n const from: TgUser | undefined = msg.from;\n if (!chat || !from || from.is_bot) return;\n if (chat.type === \"group\" || chat.type === \"supergroup\") {\n await handleGroupMessage(chat.id, from);\n return;\n }\n if (chat.type !== \"private\") return;\n\n const state = await getState(from.id);\n if (state?.step === \"edit_photo\") {\n return handleProfilePhotoUpload(chat.id, from, msg, state);\n }\n if (from.id === ADMIN_ID && hasMediaPayload(msg)) {\n return sendAdminFileId(chat.id, msg);\n }\n if (hasMediaPayload(msg)) {\n return sendMessage(\n chat.id,\n \"Guvenlik icin bot icinde fotograf, video, dosya veya ses gonderimi kabul edilmiyor.\",\n );\n }\n\n const text = (msg.text ?? \"\").trim();\n if (text === \"/start\" || text.startsWith(\"/start \")) {\n return startUser(from, msg.chat.id, text.split(/\\s+/)[1] || \"\");\n }\n if (text === \"/menu\") return sendMainMenu(msg.chat.id);\n if (text === \"/profile\") return sendProfile(msg.chat.id, from.id);\n if (text === \"/edit\") return showEditProfile(msg.chat.id, from.id);\n if (text === \"/delete\") return deleteProfile(msg.chat.id, from.id);\n if (text === \"/testmatch\" && from.id === ADMIN_ID) {\n await sendMatchMessage(msg.chat.id);\n return sendMessage(msg.chat.id, \"Test eslesme bildirimi gonderildi.\");\n }\n if (text.startsWith(\"/admin\")) return handleAdmin(msg.chat.id, from.id, text);\n if (text && hasBlockedContact(text)) {\n return sendMessage(\n msg.chat.id,\n \"Guvenlik icin link, @kullanici adi, telefon veya reklam metni gonderilemez.\",\n );\n }\n\n if (state) return continueProfileFlow(msg.chat.id, from, text, state);\n await sendMessage(\n msg.chat.id,\n \"Komutlar: /start /menu /profile /edit /delete\",\n );\n}\n\nasync function handleGroupMessage(groupId: number, from: TgUser) {\n if (\n STRICT_ALLOWED_GROUPS && ALLOWED_GROUP_IDS.size &&\n !ALLOWED_GROUP_IDS.has(groupId)\n ) return;\n await upsertGroupUser(groupId, from);\n if (groupId !== 0) await upsertGroupUser(0, from);\n}\n\nasync function upsertGroupUser(groupId: number, from: TgUser) {\n const key = userKey(groupId, from.id);\n knownUserIds.add(key);\n const now = nowIso();\n const user = {\n groupId,\n userId: from.id,\n firstName: from.first_name ?? \"\",\n lastName: from.last_name ?? \"\",\n username: from.username ?? \"\",\n photoFileId: await getUserPhotoFileId(from.id),\n lastSeenAt: now,\n };\n await sqlite.execute({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,message_count,last_seen_at,created_at,updated_at)\n values(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,1,:lastSeenAt,:lastSeenAt,:lastSeenAt)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,\n last_name=excluded.last_name,\n username=excluded.username,\n photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n message_count=users.message_count+1,\n last_seen_at=excluded.last_seen_at,\n updated_at=excluded.updated_at\n `,\n args: user,\n });\n}\n\nasync function startUser(from: TgUser, chatId: number, payload = \"\") {\n await warmCache();\n const groupId = inferGroupForUser(from.id);\n await recordReferral(from.id, payload);\n const existing = await getUser(groupId, from.id);\n if (existing?.active_dating && existing?.is_adult) {\n await clearState(from.id);\n await sendMessage(chatId, await welcomeBackText(groupId));\n return sendMainMenu(chatId);\n }\n const pending = pendingUsers.get(userKey(groupId, from.id)) ??\n await getPendingUser(groupId, from.id);\n if (pending) {\n pendingUsers.delete(userKey(groupId, from.id));\n await upsertPassiveUser(pending);\n await sqlite.execute({\n sql: \"delete from pending_users where group_id=? and user_id=?\",\n args: [groupId, from.id],\n });\n }\n await sqlite.execute({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,created_at,updated_at,last_seen_at,message_count)\n values(:group_id,:user_id,:first_name,:last_name,:username,:photo_file_id,1,0,:now,:now,:now,0)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n active_dating=1,updated_at=excluded.updated_at\n `,\n args: {\n group_id: groupId,\n user_id: from.id,\n first_name: from.first_name ?? \"\",\n last_name: from.last_name ?? \"\",\n username: from.username ?? \"\",\n photo_file_id: await getUserPhotoFileId(from.id),\n now: nowIso(),\n },\n });\n knownUserIds.add(userKey(groupId, from.id));\n await setState(from.id, \"adult_confirm\", { groupId });\n await sendMessage(\n chatId,\n await firstWelcomeText(groupId),\n keyboard([[btn(`${EM.check} 18+ onayliyorum`, \"adult_yes\")], [\n btn(`${EM.cross} Vazgec`, \"cancel\"),\n ]]),\n );\n}\n\nasync function continueProfileFlow(\n chatId: number,\n from: TgUser,\n text: string,\n state: any,\n) {\n const data = JSON.parse(state.data_json || \"{}\");\n const groupId = Number(data.groupId || inferGroupForUser(from.id));\n if (!text && state.step !== \"edit_photo\") {\n return sendMessage(chatId, \"Lutfen metin olarak yazin.\");\n }\n if (state.step === \"city\") {\n await updateUser(groupId, from.id, { city: clean(text, 40) });\n await setState(from.id, \"gender\", { groupId });\n return sendMessage(\n chatId,\n `${EM.user} Cinsiyetinizi secin.`,\n keyboard([[\n btn(`${EM.woman} Kadin`, \"gender_female\"),\n btn(`${EM.man} Erkek`, \"gender_male\"),\n ]]),\n );\n }\n if (state.step === \"bio\") {\n await updateUser(groupId, from.id, { bio: clean(text, 180) });\n await clearState(from.id);\n await sendMessage(\n chatId,\n `${EM.check} Profil tamamlandi. Artik begeni gonderebilir ve eslesebilirsiniz.`,\n );\n return sendMainMenu(chatId);\n }\n if (state.step === \"edit_city\") {\n await updateUser(groupId, from.id, { city: clean(text, 40) });\n await clearState(from.id);\n await sendMessage(chatId, \"Sehir guncellendi.\");\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"edit_bio\") {\n await updateUser(groupId, from.id, { bio: clean(text, 180) });\n await clearState(from.id);\n await sendMessage(chatId, \"Bio guncellendi.\");\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"compose_message\") {\n const toId = Number(data.toId);\n if (!toId) {\n await clearState(from.id);\n return sendMessage(chatId, \"Mesaj gonderilecek eslesme bulunamadi.\");\n }\n if (!(await areMatched(groupId, from.id, toId))) {\n await clearState(from.id);\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n const body = clean(text, 500);\n await sqlite.execute({\n sql:\n \"insert into match_messages(group_id,from_user_id,to_user_id,text,created_at) values(?,?,?,?,?)\",\n args: [groupId, from.id, toId, body, nowIso()],\n });\n await clearState(from.id);\n await sendMessage(\n toId,\n `Mesaj var:\\n\\n${body}`,\n keyboard([\n [btn(\"Cevap yaz\", `msg:${from.id}`)],\n [btn(\"Menu\", \"menu\")],\n ]),\n ).catch(() => {});\n return sendMessage(\n chatId,\n \"Mesajin iletildi.\",\n keyboard([\n [btn(\"Yeni mesaj yaz\", `msg:${toId}`)],\n [btn(\"Menu\", \"menu\")],\n ]),\n );\n }\n}\n\nasync function handleCallback(q: any) {\n const data = q.data ?? \"\";\n const from: TgUser = q.from;\n const chatId = q.message?.chat?.id ?? from.id;\n await answerCallback(q.id);\n if (data === \"noop\") return;\n if (data === \"cancel\") {\n await clearState(from.id);\n return sendMessage(chatId, \"Islem iptal edildi.\");\n }\n if (data === \"adult_yes\") {\n const state = await getState(from.id);\n const groupId = JSON.parse(state?.data_json || \"{}\").groupId ||\n inferGroupForUser(from.id);\n await updateUser(groupId, from.id, { is_adult: 1 });\n await setState(from.id, \"city\", { groupId });\n return sendMessage(chatId, `${EM.pin} Sehir yazin. Ornek: Istanbul`);\n }\n if (data.startsWith(\"gender_\")) {\n const state = await getState(from.id);\n const groupId = JSON.parse(state?.data_json || \"{}\").groupId ||\n inferGroupForUser(from.id);\n await updateUser(groupId, from.id, { gender: data.replace(\"gender_\", \"\") });\n await setState(from.id, \"bio\", { groupId });\n return sendMessage(\n chatId,\n `${EM.sparkles} Standart uyelikte iki cinsiyetten profiller de gorunur.\\n${EM.search} Kadin/Erkek filtresi tum ucretli paketlerde acilir.\\n\\n${EM.note} Kisa bir bio yazin. En fazla 180 karakter.`,\n );\n }\n if (data.startsWith(\"seek_\")) {\n const state = await getState(from.id);\n const groupId = JSON.parse(state?.data_json || \"{}\").groupId ||\n inferGroupForUser(from.id);\n await updateUser(groupId, from.id, {\n seek_gender: data.replace(\"seek_\", \"\"),\n });\n await clearState(from.id);\n return sendMessage(chatId, `${EM.check} Cinsiyet filtresi guncellendi.`);\n }\n if (data === \"edit_profile\") return showEditProfile(chatId, from.id);\n if (data === \"edit_city\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_city\", { groupId: user.group_id });\n return sendMessage(chatId, \"Yeni sehrini yaz.\");\n }\n if (data === \"edit_bio\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_bio\", { groupId: user.group_id });\n return sendMessage(chatId, \"Yeni bio yaz. En fazla 180 karakter.\");\n }\n if (data === \"edit_photo\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_photo\", { groupId: user.group_id });\n return sendMessage(\n chatId,\n \"Profil fotografi olarak kullanmak istedigin fotografi gonder.\",\n );\n }\n if (data === \"refresh_photo\") return refreshProfilePhoto(chatId, from.id);\n if (data.startsWith(\"edit_gender_\")) {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await updateUser(user.group_id, from.id, {\n gender: data.replace(\"edit_gender_\", \"\"),\n });\n await sendMessage(chatId, \"Cinsiyet guncellendi.\");\n return showEditProfile(chatId, from.id);\n }\n if (data.startsWith(\"msg:\")) {\n return beginMatchedMessage(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data === \"browse\") return showNextProfile(chatId, from.id);\n if (data.startsWith(\"like:\")) {\n await clearInlineKeyboard(q);\n return likeProfile(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data === \"skip\") return showNextProfile(chatId, from.id);\n if (data.startsWith(\"skip:\")) {\n await clearInlineKeyboard(q);\n return snoozeProfile(chatId, from.id, Number(data.split(\":\")[1]), 3);\n }\n if (data.startsWith(\"hide:\")) {\n await clearInlineKeyboard(q);\n return hideProfile(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data.startsWith(\"dismiss_liker:\")) {\n await clearInlineKeyboard(q);\n return dismissLiker(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data === \"buy\") return showShop(chatId, from.id);\n if (data === \"features\") return showFeatures(chatId);\n if (data === \"invite\") return showInvite(chatId, from.id);\n if (data === \"matches\") return showMatches(chatId, from.id);\n if (data === \"filter\") return showGenderFilter(chatId, from.id);\n if (data.startsWith(\"buy:\")) {\n return sendInvoice(chatId, from.id, data.slice(4));\n }\n if (data === \"likers\") return showLikers(chatId, from.id);\n if (data === \"menu\") return sendMainMenu(chatId);\n}\n\nasync function sendMainMenu(chatId: number) {\n const active = await getActiveUser(Number(chatId));\n const groupId = active?.group_id ?? inferGroupForUser(Number(chatId));\n await sendMessage(\n chatId,\n await menuText(groupId),\n keyboard([\n [btn(`${EM.note} Profilimi duzenle`, \"edit_profile\")],\n [btn(`${EM.twoHearts} Profil gez`, \"browse\")],\n [btn(`${EM.chat} Eslesmelerim`, \"matches\")],\n [\n btn(`${EM.eye} Beni begenenler`, \"likers\"),\n btn(`${EM.search} Cinsiyet filtresi`, \"filter\"),\n ],\n [\n btn(`${EM.sparkles} Ozellikler`, \"features\"),\n btn(`${EM.star} Paketler`, \"buy\"),\n ],\n [btn(`${EM.gift} Davet et`, \"invite\")],\n ]),\n );\n}\n\nasync function showNextProfile(chatId: number, viewerId: number) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n if (!viewer.is_adult) {\n return sendMessage(chatId, \"Devam etmek icin /start ile 18+ onayi verin.\");\n }\n const row = await sqlite.execute({\n sql: `\n select u.* from users u\n left join likes l on l.group_id=u.group_id and l.from_user_id=:viewer and l.to_user_id=u.user_id\n where u.group_id=:group_id and u.user_id<>:viewer and u.deleted_at is null and u.banned=0\n and l.id is null\n and not exists(select 1 from profile_snoozes s where s.group_id=u.group_id and s.viewer_user_id=:viewer and s.snoozed_user_id=u.user_id and s.expires_at>:now)\n and not exists(select 1 from hidden_profiles h where h.group_id=u.group_id and h.viewer_user_id=:viewer and h.hidden_user_id=u.user_id and h.expires_at>:now)\n and (\n not exists(select 1 from premium p where p.group_id=u.group_id and p.user_id=u.user_id and p.feature='liked_only_visibility' and p.expires_at>:now)\n or exists(select 1 from likes lx where lx.group_id=u.group_id and lx.from_user_id=u.user_id and lx.to_user_id=:viewer)\n )\n and (:can_filter=0 or :seek='any' or u.gender is null or u.gender='' or u.gender=:seek)\n order by u.active_dating desc, u.last_seen_at desc\n limit 1\n `,\n args: {\n viewer: viewerId,\n group_id: viewer.group_id,\n seek: viewer.seek_gender || \"any\",\n can_filter: await hasPremium(viewer.group_id, viewerId, \"gender_filter\")\n ? 1\n : 0,\n now: nowIso(),\n },\n });\n const target = row.rows[0] as UserRow | undefined;\n if (!target) return sendMessage(chatId, \"Su an gosterecek profil kalmadi.\");\n await sendProfileCard(\n chatId,\n target,\n keyboard([\n [\n btn(`${EM.heart} Kalp At`, `like:${target.user_id}`),\n btn(`${EM.next} Gec`, `skip:${target.user_id}`),\n btn(`${EM.cross} Olmaz`, `hide:${target.user_id}`),\n ],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n}\n\nasync function hideProfile(\n chatId: number,\n viewerId: number,\n hiddenUserId: number,\n) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sqlite.execute({\n sql: `\n insert into hidden_profiles(group_id,viewer_user_id,hidden_user_id,created_at,expires_at)\n values(?,?,?,?,?)\n on conflict(group_id,viewer_user_id,hidden_user_id) do update set\n created_at=excluded.created_at,\n expires_at=excluded.expires_at\n `,\n args: [viewer.group_id, viewerId, hiddenUserId, nowIso(), addHoursIso(36)],\n });\n return showNextProfile(chatId, viewerId);\n}\n\nasync function snoozeProfile(\n chatId: number,\n viewerId: number,\n snoozedUserId: number,\n hours: number,\n) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sqlite.execute({\n sql: `\n insert into profile_snoozes(group_id,viewer_user_id,snoozed_user_id,created_at,expires_at)\n values(?,?,?,?,?)\n on conflict(group_id,viewer_user_id,snoozed_user_id) do update set\n created_at=excluded.created_at,\n expires_at=excluded.expires_at\n `,\n args: [\n viewer.group_id,\n viewerId,\n snoozedUserId,\n nowIso(),\n addHoursIso(hours),\n ],\n });\n return showNextProfile(chatId, viewerId);\n}\n\nasync function likeProfile(chatId: number, fromId: number, toId: number) {\n const from = await getActiveUser(fromId);\n if (!from || !from.active_dating || !from.is_adult) {\n return sendMessage(chatId, \"Once /start ile aktif profil olusturun.\");\n }\n const target = await getUser(from.group_id, toId);\n if (!target) return sendMessage(chatId, \"Profil bulunamadi.\");\n const alreadyLiked = await sqlite.execute({\n sql:\n \"select 1 from likes where group_id=? and from_user_id=? and to_user_id=? limit 1\",\n args: [from.group_id, fromId, toId],\n });\n if (alreadyLiked.rows[0]) {\n return sendMessage(\n chatId,\n `${EM.heart} Bu profile zaten kalp attin.`,\n keyboard([[\n btn(`${EM.twoHearts} Profil gez`, \"browse\"),\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\n );\n }\n const canLike = await consumeLikeRight(from.group_id, fromId);\n if (!canLike) {\n return showShop(chatId, fromId, \"Bugunku ucretsiz begeni hakkiniz bitti.\");\n }\n await sqlite.execute({\n sql:\n \"insert or ignore into likes(group_id,from_user_id,to_user_id,created_at) values(?,?,?,?)\",\n args: [from.group_id, fromId, toId, nowIso()],\n });\n const reciprocal = await sqlite.execute({\n sql:\n \"select id from likes where group_id=? and from_user_id=? and to_user_id=? limit 1\",\n args: [from.group_id, toId, fromId],\n });\n if (reciprocal.rows[0] && target.active_dating) {\n await sqlite.execute({\n sql:\n \"insert or ignore into matches(group_id,user1_id,user2_id,created_at) values(?,?,?,?)\",\n args: [\n from.group_id,\n Math.min(fromId, toId),\n Math.max(fromId, toId),\n nowIso(),\n ],\n });\n await sendMatchMessage(chatId, toId);\n await sendMatchMessage(toId, fromId);\n } else {\n await sendMessage(\n chatId,\n target.active_dating\n ? `${EM.heart} Kalp atildi.`\n : `${EM.heart} Kalbin kaydedildi. Karsi taraf KalpAt'a katildiginda akisa dahil olur.`,\n );\n }\n return showNextProfile(chatId, fromId);\n}\n\nasync function sendMatchMessage(chatId: number, otherUserId?: number) {\n const displayText =\n \"Karsilikli Kalp!\\n\\nBirbirinize kalp attiniz.\\nArtik eslestiniz.\\n\\nBot icinden guvenli sekilde mesajlasabilirsiniz.\";\n const extra = otherUserId\n ? keyboard([\n [btn(\"Mesaj gonder\", `msg:${otherUserId}`)],\n [btn(\"Menu\", \"menu\")],\n ])\n : {};\n if (MATCH_ANIMATION_FILE_ID) {\n const sentAnimation = await tg(\"sendAnimation\", {\n chat_id: chatId,\n animation: MATCH_ANIMATION_FILE_ID,\n caption: displayText,\n ...extra,\n }).then(() => true).catch(() => false);\n if (sentAnimation) return;\n if (!sentAnimation) {\n const sentVideo = await tg(\"sendVideo\", {\n chat_id: chatId,\n video: MATCH_ANIMATION_FILE_ID,\n caption: displayText,\n supports_streaming: true,\n ...extra,\n }).then(() => true).catch(() => false);\n if (sentVideo) return;\n }\n }\n await sendMessage(chatId, displayText, extra);\n}\n\nasync function consumeLikeRight(groupId: number, userId: number) {\n if (isPrivilegedUser(userId)) return true;\n const today = dayKey();\n const credit = await sqlite.execute({\n sql: \"select * from credits where group_id=? and user_id=?\",\n args: [groupId, userId],\n });\n const row = credit.rows[0] as UserRow | undefined;\n if (!row) {\n await sqlite.execute({\n sql:\n \"insert into credits(group_id,user_id,paid_likes,free_like_day,free_like_used) values(?,?,?,?,1)\",\n args: [groupId, userId, 0, today],\n });\n return true;\n }\n if (row.free_like_day !== today) {\n await sqlite.execute({\n sql:\n \"update credits set free_like_day=?,free_like_used=1 where group_id=? and user_id=?\",\n args: [today, groupId, userId],\n });\n return true;\n }\n if (!row.free_like_used) {\n await sqlite.execute({\n sql: \"update credits set free_like_used=1 where group_id=? and user_id=?\",\n args: [groupId, userId],\n });\n return true;\n }\n if (row.plan_expires_at && row.plan_expires_at > nowIso()) {\n const usedToday = row.plan_used_day === today\n ? Number(row.plan_used_today || 0)\n : 0;\n const dailyLimit = Number(row.plan_daily_likes || 0);\n if (dailyLimit > usedToday) {\n await sqlite.execute({\n sql:\n \"update credits set plan_used_day=?,plan_used_today=? where group_id=? and user_id=?\",\n args: [today, usedToday + 1, groupId, userId],\n });\n return true;\n }\n }\n if (Number(row.paid_likes) > 0) {\n await sqlite.execute({\n sql:\n \"update credits set paid_likes=paid_likes-1 where group_id=? and user_id=?\",\n args: [groupId, userId],\n });\n return true;\n }\n return false;\n}\n\nasync function showShop(\n chatId: number,\n userId?: number,\n prefix = `${EM.star} Paket secin.`,\n) {\n const discountInfo = userId\n ? await getBestDiscountInfo(userId)\n : { percent: 0, label: \"\" };\n const discount = discountInfo.percent;\n const price = (key: string) => discountedStars(PACKAGES[key].stars, discount);\n const priceLabel = (key: string) =>\n discount\n ? `${PACKAGES[key].stars} -> ${price(key)} Stars`\n : `${PACKAGES[key].stars} Stars`;\n const discountText = discount\n ? `\\n${discountInfo.label}: %${discount} indirim aktif`\n : \"\";\n const rows = [\n [btn(`Mini 7 gun - ${priceLabel(\"mini\")}`, \"buy:mini\")],\n [btn(`Plus 30 gun - ${priceLabel(\"plus\")}`, \"buy:plus\")],\n [btn(`Gold 30 gun - ${priceLabel(\"gold\")}`, \"buy:gold\")],\n [btn(`VIP 30 gun - ${priceLabel(\"vip\")}`, \"buy:vip\")],\n [\n btn(`${EM.sparkles} Ozellikler`, \"features\"),\n btn(`${EM.home} Ana menu`, \"menu\"),\n ],\n ];\n await sendMessage(\n chatId,\n `${prefix}${discountText}\n\n${EM.twoHearts} Mini: 7 gun, gunde 3 begeni, cinsiyet filtresi\n${EM.sparklingHeart} Plus: 30 gun, gunde 3 begeni, filtre, beni begenenler\n${EM.star} Gold: 30 gun, gunde 7 begeni, filtre, beni begenenler, gizli gorunurluk\n${EM.fire} VIP: 30 gun, gunde 15 begeni, filtre, beni begenenler, gizli gorunurluk`,\n keyboard(rows),\n );\n}\n\nasync function showFeatures(chatId: number) {\n await sendMessage(\n chatId,\n `${EM.sparkles} KalpAt Ozellikleri\n\n${EM.search} Cinsiyet filtresi\nSadece kadin, sadece erkek veya farketmez secimi yaparsin. Tum ucretli paketlerde acilir.\n\n${EM.eye} Beni begenenleri gor\nSeni kimlerin begendigini listelersin. Plus, Gold ve VIP paketlerinde acilir.\n\n${EM.sparkles} Gizli gorunurluk\nSadece senin begendigin kisiler profilini gorebilir. Gold ve VIP paketlerinde acilir.\n\n${EM.gift} Davet indirimi\n10 kisi davet et, davet ettiklerinden 1 kisi paket alirsa %10 indirim kazan.`,\n keyboard([\n [btn(`${EM.star} Paketler`, \"buy\"), btn(`${EM.gift} Davet et`, \"invite\")],\n [btn(`${EM.home} Ana menu`, \"menu\")],\n ]),\n );\n}\n\nasync function showInvite(chatId: number, userId: number) {\n const link = `https://t.me/${BOT_USERNAME}?start=ref_${userId}`;\n const shareText =\n `KalpAt'a katil, profilleri kesfet ${EM.heart}\\n\\nBenim davet linkim:`;\n const shareUrl = `https://t.me/share/url?url=${\n encodeURIComponent(link)\n }&text=${encodeURIComponent(shareText)}`;\n const stats = await getReferralStats(userId);\n await sendMessage(\n chatId,\n `${EM.gift} Davet Kazanci\n\nDavet linkin:\n${link}\n\nDurum:\n${EM.user} Davet edilen: ${stats.total}/10\n${EM.star} Alis yapan davetli: ${stats.buyers}/1\n${EM.ticket} Indirim: ${stats.discount ? \"%10 aktif\" : \"henuz aktif degil\"}\n\n10 kisi davet et ve davet ettiklerinden en az 1 kisi paket alsin; sonraki paketlerinde %10 indirim kullan.\n\n${EM.chat} Kullaniciya oner butonuna basinca Telegram kisi secme ekrani acilir. Sectigin kisiye referans linkin mesaj olarak gider.`,\n keyboard([\n [urlBtn(`${EM.chat} Kullaniciya oner`, shareUrl)],\n [btn(`${EM.star} Paketler`, \"buy\")],\n [btn(`${EM.home} Ana menu`, \"menu\")],\n ]),\n );\n}\n\nasync function showGenderFilter(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n const premium = await hasPremium(user.group_id, userId, \"gender_filter\");\n if (!premium) {\n return showShop(\n chatId,\n userId,\n `${EM.search} Standart uyelikte iki cinsiyetten profiller gorunur. Cinsiyet filtresi tum ucretli paketlerde acilir.`,\n );\n }\n await sendMessage(\n chatId,\n `${EM.search} Kimi gormek istersiniz?`,\n keyboard([\n [\n btn(`${EM.woman} Kadin`, \"seek_female\"),\n btn(`${EM.man} Erkek`, \"seek_male\"),\n btn(`${EM.sparkles} Farketmez`, \"seek_any\"),\n ],\n [btn(`${EM.home} Ana menu`, \"menu\")],\n ]),\n );\n}\n\nasync function sendInvoice(chatId: number, userId: number, productId: string) {\n const item = PACKAGES[productId];\n if (!item) return sendMessage(chatId, \"Paket bulunamadi.\");\n const discountInfo = await getBestDiscountInfo(userId);\n const discount = discountInfo.percent;\n const amount = discountedStars(item.stars, discount);\n const payload = JSON.stringify({\n productId,\n userId,\n discount,\n discountLabel: discountInfo.label,\n amount,\n t: Date.now(),\n });\n await tg(\"sendInvoice\", {\n chat_id: chatId,\n title: discount ? `${item.title} (%${discount} indirim)` : item.title,\n description: `${BOT_NAME} dijital paket`,\n payload,\n provider_token: \"\",\n currency: \"XTR\",\n prices: [{ label: item.title, amount }],\n });\n}\n\nasync function handleSuccessfulPayment(msg: any) {\n const payment = msg.successful_payment;\n const payload = JSON.parse(payment.invoice_payload || \"{}\");\n const productId = payload.productId;\n const buyerId = msg.from.id;\n const groupId = inferGroupForUser(buyerId);\n await sqlite.execute({\n sql:\n \"insert into purchases(group_id,user_id,product_id,stars,charge_id,payload,created_at) values(?,?,?,?,?,?,?)\",\n args: [\n groupId,\n buyerId,\n productId,\n payment.total_amount,\n payment.telegram_payment_charge_id,\n payment.invoice_payload,\n nowIso(),\n ],\n });\n await markReferralPurchase(buyerId);\n const pack = PACKAGES[productId];\n if (pack) {\n await sqlite.execute({\n sql: `\n insert into credits(group_id,user_id,paid_likes,free_like_day,free_like_used,plan_daily_likes,plan_used_day,plan_used_today,plan_expires_at)\n values(?,?,0,'',0,?,'',0,?)\n on conflict(group_id,user_id) do update set\n plan_daily_likes=excluded.plan_daily_likes,\n plan_used_day='',\n plan_used_today=0,\n plan_expires_at=excluded.plan_expires_at\n `,\n args: [groupId, buyerId, pack.dailyLikes, addDaysIso(pack.days)],\n });\n for (const feature of pack.features) {\n await sqlite.execute({\n sql: `\n insert into premium(group_id,user_id,feature,expires_at,created_at) values(?,?,?,?,?)\n on conflict(group_id,user_id,feature) do update set expires_at=excluded.expires_at\n `,\n args: [groupId, buyerId, feature, addDaysIso(pack.days), nowIso()],\n });\n }\n await sendMessage(\n buyerId,\n `${EM.check} ${pack.title} aktif edildi.\\n${pack.days} gun boyunca gunde ${pack.dailyLikes} begeni hakkiniz var.`,\n );\n }\n}\n\nasync function showLikers(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start kullanin.\");\n const premium = await hasPremium(user.group_id, userId, \"see_likers\");\n if (!premium) {\n return showShop(\n chatId,\n userId,\n `${EM.eye} Beni begenenleri gormek Plus, Gold ve VIP paketlerinde acilir.`,\n );\n }\n const res = await sqlite.execute({\n sql: `\n select u.* from likes l\n join users u on u.group_id=l.group_id and u.user_id=l.from_user_id\n left join likes mine on mine.group_id=l.group_id and mine.from_user_id=:me and mine.to_user_id=l.from_user_id\n where l.group_id=:group_id and l.to_user_id=:me and mine.id is null\n order by l.created_at desc\n limit 10\n `,\n args: { group_id: user.group_id, me: userId },\n });\n if (!res.rows.length) {\n return sendMessage(\n chatId,\n \"Henuz yeni begeni yok.\",\n keyboard([[btn(`${EM.twoHearts} Profil gez`, \"browse\")], [\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\n );\n }\n await sendMessage(chatId, `${EM.eye} Seni begenenler:`);\n for (const liker of res.rows as any[]) {\n await sendProfileCard(\n chatId,\n liker,\n keyboard([\n [\n btn(`${EM.sparklingHeart} Esles`, `like:${liker.user_id}`),\n btn(`${EM.cross} Kaldir`, `dismiss_liker:${liker.user_id}`),\n ],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n }\n}\n\nasync function dismissLiker(chatId: number, userId: number, likerId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start kullanin.\");\n await sqlite.execute({\n sql:\n \"delete from likes where group_id=? and from_user_id=? and to_user_id=?\",\n args: [user.group_id, likerId, userId],\n });\n return sendMessage(\n chatId,\n \"Begeni kaldirildi.\",\n keyboard([[btn(`${EM.eye} Beni begenenler`, \"likers\")], [\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\n );\n}\n\nasync function showMatches(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start kullanin.\");\n const res = await sqlite.execute({\n sql: `\n select u.* from matches m\n join users u on u.group_id=m.group_id\n and u.user_id=case when m.user1_id=:user then m.user2_id else m.user1_id end\n where m.group_id=:group_id and (m.user1_id=:user or m.user2_id=:user)\n and u.deleted_at is null and u.banned=0\n order by m.created_at desc\n limit 10\n `,\n args: { group_id: user.group_id, user: userId },\n });\n if (!res.rows.length) {\n return sendMessage(\n chatId,\n \"Henuz eslesme yok.\",\n keyboard([[btn(\"Profil gez\", \"browse\")], [btn(\"Menu\", \"menu\")]]),\n );\n }\n const rows = (res.rows as any[]).map((r) => {\n const name = clean(\n `${r.first_name || \"\"} ${r.last_name || \"\"}` || \"Eslesme\",\n 24,\n );\n return [btn(`Mesaj: ${name || \"Eslesme\"}`, `msg:${r.user_id}`)];\n });\n rows.push([btn(\"Profil gez\", \"browse\"), btn(\"Menu\", \"menu\")]);\n return sendMessage(chatId, \"Eslesmelerin:\", keyboard(rows));\n}\n\nasync function firstWelcomeText(groupId: number) {\n const stats = await getPublicStats(groupId);\n return `${EM.heart} KalpAt'a hos geldin\n\n${EM.user} ${stats.total} profil seni bekliyor\n${EM.fire} ${stats.recent} kisi yakin zamanda aktifti\n${EM.sparklingHeart} ${stats.active} profil eslesmeye acik\n\n/start ile eslesme sistemine katildiniz.\nDevam etmek icin 18+ oldugunuzu onaylayin.`;\n}\n\nasync function welcomeBackText(groupId: number) {\n const stats = await getPublicStats(groupId);\n return `${EM.heart} KalpAt'a tekrar hos geldin\n\n${EM.user} ${stats.total} profil\n${EM.fire} ${stats.recent} yakin zamanda aktif\n${EM.sparklingHeart} ${stats.active} eslesmeye acik\n\nProfilin aktif. Buradan profil gezebilir, begenilerini gorebilir, paketleri inceleyebilir veya arkadaslarini davet edebilirsin.`;\n}\n\nasync function menuText(groupId: number) {\n const stats = await getPublicStats(groupId);\n return `${EM.heart} KalpAt\n\n${EM.user} ${stats.total} profil\n${EM.fire} ${stats.recent} yakin zamanda aktif\n${EM.sparklingHeart} ${stats.active} eslesmeye acik\n\nNe yapmak istersin?`;\n}\n\nasync function getPublicStats(groupId: number) {\n const since = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000).toISOString();\n const res = await sqlite.execute({\n sql: `\n select\n count(*) total,\n sum(case when active_dating=1 then 1 else 0 end) active,\n sum(case when last_seen_at>=? then 1 else 0 end) recent\n from users\n where group_id=? and deleted_at is null and banned=0\n `,\n args: [since, groupId],\n });\n const row = (res.rows[0] || {}) as UserRow;\n return {\n total: Number(row.total || 0),\n active: Number(row.active || 0),\n recent: Number(row.recent || 0),\n };\n}\n\nasync function showEditProfile(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sendMessage(\n chatId,\n `Profil duzenle\\n\\n${profileText(user)}`,\n keyboard([\n [btn(\"Sehir\", \"edit_city\"), btn(\"Bio\", \"edit_bio\")],\n [btn(\"Kadin\", \"edit_gender_female\"), btn(\"Erkek\", \"edit_gender_male\")],\n [btn(\"Fotograf ekle/degistir\", \"edit_photo\")],\n [btn(\"Telegram fotografimi yenile\", \"refresh_photo\")],\n [btn(\"Profilimi goster\", \"menu\")],\n ]),\n );\n}\n\nasync function handleProfilePhotoUpload(\n chatId: number,\n from: TgUser,\n msg: any,\n state: any,\n) {\n const text = (msg.text ?? \"\").trim();\n if (text === \"/menu\" || text === \"/cancel\") {\n await clearState(from.id);\n return sendMainMenu(chatId);\n }\n if (!msg.photo?.length) {\n return sendMessage(\n chatId,\n \"Bu adimda sadece fotograf kabul edilir. Iptal etmek icin /menu yazabilirsiniz.\",\n );\n }\n const data = JSON.parse(state.data_json || \"{}\");\n const groupId = Number(data.groupId || inferGroupForUser(from.id));\n const photo = msg.photo[msg.photo.length - 1];\n await updateUser(groupId, from.id, { photo_file_id: photo.file_id });\n await clearState(from.id);\n await sendMessage(chatId, \"Profil fotografi guncellendi.\");\n return sendProfile(chatId, from.id);\n}\n\nasync function refreshProfilePhoto(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n const fileId = await getUserPhotoFileId(userId);\n if (!fileId) {\n return sendMessage(\n chatId,\n \"Telegram profil fotografi okunamadi. Profil duzenle > Fotograf ekle/degistir ile fotograf yukleyebilirsin.\",\n );\n }\n await updateUser(user.group_id, userId, { photo_file_id: fileId });\n await sendMessage(chatId, \"Telegram profil fotografi yenilendi.\");\n return sendProfile(chatId, userId);\n}\n\nasync function beginMatchedMessage(\n chatId: number,\n fromId: number,\n toId: number,\n) {\n const user = await getActiveUser(fromId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n if (!(await areMatched(user.group_id, fromId, toId))) {\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n await setState(fromId, \"compose_message\", { groupId: user.group_id, toId });\n return sendMessage(\n chatId,\n \"Mesajini yaz. Link, @kullanici adi, telefon, fotograf ve video gonderilemez.\",\n );\n}\n\nasync function areMatched(groupId: number, a: number, b: number) {\n const res = await sqlite.execute({\n sql:\n \"select 1 from matches where group_id=? and user1_id=? and user2_id=? limit 1\",\n args: [groupId, Math.min(a, b), Math.max(a, b)],\n });\n return Boolean(res.rows[0]);\n}\n\nasync function handleAdmin(chatId: number, fromId: number, text: string) {\n if (fromId !== ADMIN_ID) return sendMessage(chatId, \"Yetki yok.\");\n const parts = text.split(/\\s+/);\n if (parts[1] === \"stats\") {\n const groups = await sqlite.execute({\n sql:\n \"select group_id,count(*) total,sum(active_dating) active,sum(case when active_dating=0 then 1 else 0 end) passive from users where deleted_at is null group by group_id\",\n });\n const likes = await sqlite.execute({\n sql: \"select count(*) likes from likes\",\n });\n const matches = await sqlite.execute({\n sql: \"select count(*) matches from matches\",\n });\n const purchases = await sqlite.execute({\n sql: \"select count(*) purchases from purchases\",\n });\n return sendMessage(\n chatId,\n \"Stats:\\n\" + JSON.stringify(\n {\n groups: groups.rows,\n likes: likes.rows[0],\n matches: matches.rows[0],\n purchases: purchases.rows[0],\n pending: pendingUsers.size,\n },\n null,\n 2,\n ),\n );\n }\n if (parts[1] === \"ban\" && parts[2]) {\n await sqlite.execute({\n sql: \"update users set banned=1 where user_id=?\",\n args: [Number(parts[2])],\n });\n return sendMessage(chatId, \"Banlandi.\");\n }\n if (parts[1] === \"unban\" && parts[2]) {\n await sqlite.execute({\n sql: \"update users set banned=0 where user_id=?\",\n args: [Number(parts[2])],\n });\n return sendMessage(chatId, \"Ban kaldirildi.\");\n }\n if (parts[1] === \"delete\" && parts[2]) {\n await sqlite.execute({\n sql: \"update users set deleted_at=? where user_id=?\",\n args: [nowIso(), Number(parts[2])],\n });\n return sendMessage(chatId, \"Silindi.\");\n }\n if (parts[1] === \"flush\") {\n const count = await flushPendingUsers();\n return sendMessage(chatId, `${count} pending kullanici yazildi.`);\n }\n if (parts[1] === \"syncglobal\") {\n const count = await syncGlobalPool();\n return sendMessage(chatId, `${count} profil ana havuza kopyalandi.`);\n }\n if (parts[1] === \"testmatch\") {\n const targetChatId = Number(parts[2] || chatId);\n await sendMatchMessage(targetChatId);\n return sendMessage(chatId, \"Test eslesme bildirimi gonderildi.\");\n }\n return sendMessage(\n chatId,\n \"/admin stats | ban ID | unban ID | delete ID | flush | syncglobal | testmatch [CHAT_ID]\",\n );\n}\n\nasync function deleteProfile(chatId: number, userId: number) {\n await sqlite.execute({\n sql: \"update users set deleted_at=?,active_dating=0 where user_id=?\",\n args: [nowIso(), userId],\n });\n await sendMessage(\n chatId,\n \"Profiliniz silindi. Botu tekrar kullanmak icin /start yazabilirsiniz.\",\n );\n}\n\nasync function syncGlobalPool() {\n const res = await sqlite.execute({\n sql:\n \"select * from users where group_id<>0 and deleted_at is null and banned=0\",\n });\n const rows = res.rows as any[];\n if (!rows.length) return 0;\n await sqlite.batch(rows.map((u) => ({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,city,gender,seek_gender,bio,message_count,last_seen_at,created_at,updated_at)\n values(0,:user_id,:first_name,:last_name,:username,:photo_file_id,:active_dating,:is_adult,:city,:gender,:seek_gender,:bio,:message_count,:last_seen_at,:created_at,:updated_at)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,\n last_name=excluded.last_name,\n username=excluded.username,\n photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n message_count=max(users.message_count,excluded.message_count),\n last_seen_at=excluded.last_seen_at,\n updated_at=excluded.updated_at\n `,\n args: u,\n })));\n return rows.length;\n}\n\nasync function sendProfile(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Profil bulunamadi. /start yazin.\");\n await sendProfileCard(chatId, user);\n}\n\nasync function sendAdminFileId(chatId: number, msg: any) {\n const animationId = msg.animation?.file_id;\n const videoId = msg.video?.file_id;\n const videoNoteId = msg.video_note?.file_id;\n const documentId = msg.document?.file_id;\n const fileId = animationId || videoId || videoNoteId || documentId;\n const kind = animationId\n ? \"animation\"\n : videoId\n ? \"video\"\n : videoNoteId\n ? \"video_note\"\n : \"document\";\n if (!fileId) return;\n await sendMessage(\n chatId,\n `Dosya tipi: ${kind}\\n\\nVal Town env'e sunu ekle:\\n\\nMATCH_ANIMATION_FILE_ID=${fileId}`,\n );\n}\n\nasync function sendProfileCard(chatId: number, user: UserRow, extra: any = {}) {\n if (user.photo_file_id) {\n await tg(\"sendPhoto\", {\n chat_id: chatId,\n photo: user.photo_file_id,\n caption: profileText(user),\n ...extra,\n });\n return;\n }\n await sendMessage(chatId, profileText(user), extra);\n}\n\nfunction profileText(u: UserRow) {\n const name = `${u.first_name || \"\"} ${u.last_name || \"\"}`.trim() || \"Isimsiz\";\n const active = u.active_dating ? \"Aktif\" : \"Pasif\";\n return [\n `${name}`,\n `Durum: ${active}`,\n `Sehir: ${u.city || \"eklenmedi\"}`,\n `Cinsiyet: ${labelGender(u.gender)}`,\n `Bio: ${u.bio || \"eklenmedi\"}`,\n `Son aktif: ${formatLastSeen(u.last_seen_at)}`,\n ].join(\"\\n\");\n}\n\nasync function flushPendingUsers() {\n await ensureSchema();\n const fromDb = await sqlite.execute({\n sql: \"select * from pending_users order by created_at asc limit 1000\",\n });\n const items = [\n ...fromDb.rows.map((r: any) => ({\n groupId: Number(r.group_id),\n userId: Number(r.user_id),\n firstName: r.first_name ?? \"\",\n lastName: r.last_name ?? \"\",\n username: r.username ?? \"\",\n photoFileId: r.photo_file_id ?? \"\",\n messageCount: Number(r.message_count ?? 1),\n lastSeenAt: r.last_seen_at ?? nowIso(),\n })),\n ...[...pendingUsers.values()].filter((p) =>\n !fromDb.rows.some((r: any) =>\n Number(r.group_id) === p.groupId && Number(r.user_id) === p.userId\n )\n ),\n ];\n if (!items.length) return 0;\n const queries = items.map((p) => ({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,message_count,last_seen_at,created_at,updated_at)\n values(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,:messageCount,:lastSeenAt,:now,:now)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n message_count=users.message_count+excluded.message_count,last_seen_at=excluded.last_seen_at,updated_at=excluded.updated_at\n `,\n args: { ...p, now: nowIso() },\n }));\n await sqlite.batch(queries);\n await sqlite.batch(items.map((p) => ({\n sql: \"delete from pending_users where group_id=? and user_id=?\",\n args: [p.groupId, p.userId],\n })));\n pendingUsers.clear();\n return items.length;\n}\n\nasync function upsertPassiveUser(p: PendingUser) {\n await sqlite.execute({\n sql: `\n insert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,message_count,last_seen_at,created_at,updated_at)\n values(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,:messageCount,:lastSeenAt,:now,:now)\n on conflict(group_id,user_id) do update set\n first_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,\n photo_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\n updated_at=excluded.updated_at\n `,\n args: { ...p, now: nowIso() },\n });\n}\n\nasync function warmCache() {\n if (cacheReady) return;\n await ensureSchema();\n const res = await sqlite.execute({\n sql: \"select group_id,user_id from users where deleted_at is null\",\n });\n for (const row of res.rows as any[]) {\n knownUserIds.add(userKey(Number(row.group_id), Number(row.user_id)));\n }\n const pending = await sqlite.execute({\n sql: \"select group_id,user_id from pending_users\",\n });\n for (const row of pending.rows as any[]) {\n knownUserIds.add(userKey(Number(row.group_id), Number(row.user_id)));\n }\n cacheReady = true;\n}\n\nasync function ensureSchema() {\n if (schemaReady) return;\n await sqlite.batch([\n `create table if not exists users(\n id integer primary key autoincrement,\n group_id integer not null,\n user_id integer not null,\n first_name text default '',\n last_name text default '',\n username text default '',\n photo_file_id text default '',\n active_dating integer default 0,\n is_adult integer default 0,\n city text default '',\n gender text default '',\n seek_gender text default 'any',\n bio text default '',\n message_count integer default 0,\n last_seen_at text,\n banned integer default 0,\n deleted_at text,\n created_at text,\n updated_at text,\n unique(group_id,user_id)\n )`,\n `create table if not exists states(user_id integer primary key,step text,data_json text,updated_at text)`,\n `create table if not exists pending_users(group_id integer,user_id integer,first_name text default '',last_name text default '',username text default '',photo_file_id text default '',message_count integer default 1,last_seen_at text,created_at text,primary key(group_id,user_id))`,\n `create table if not exists likes(id integer primary key autoincrement,group_id integer,from_user_id integer,to_user_id integer,created_at text,unique(group_id,from_user_id,to_user_id))`,\n `create table if not exists hidden_profiles(id integer primary key autoincrement,group_id integer,viewer_user_id integer,hidden_user_id integer,created_at text,expires_at text default '',unique(group_id,viewer_user_id,hidden_user_id))`,\n `create table if not exists profile_snoozes(id integer primary key autoincrement,group_id integer,viewer_user_id integer,snoozed_user_id integer,created_at text,expires_at text,unique(group_id,viewer_user_id,snoozed_user_id))`,\n `create table if not exists matches(id integer primary key autoincrement,group_id integer,user1_id integer,user2_id integer,created_at text,unique(group_id,user1_id,user2_id))`,\n `create table if not exists match_messages(id integer primary key autoincrement,group_id integer,from_user_id integer,to_user_id integer,text text,created_at text)`,\n `create table if not exists credits(\n group_id integer,\n user_id integer,\n paid_likes integer default 0,\n free_like_day text default '',\n free_like_used integer default 0,\n plan_daily_likes integer default 0,\n plan_used_day text default '',\n plan_used_today integer default 0,\n plan_expires_at text default '',\n primary key(group_id,user_id)\n )`,\n `create table if not exists purchases(id integer primary key autoincrement,group_id integer,user_id integer,product_id text,stars integer,charge_id text,payload text,created_at text)`,\n `create table if not exists premium(group_id integer,user_id integer,feature text,expires_at text,created_at text,primary key(group_id,user_id,feature))`,\n `create table if not exists referrals(referrer_id integer,referred_id integer,created_at text,purchased integer default 0,purchased_at text,primary key(referrer_id,referred_id))`,\n ]);\n await migrateCredits();\n await migrateProfilePhotos();\n await migrateVisibilityTables();\n schemaReady = true;\n}\n\nasync function migrateCredits() {\n const columns = [\n [\"plan_daily_likes\", \"integer default 0\"],\n [\"plan_used_day\", \"text default ''\"],\n [\"plan_used_today\", \"integer default 0\"],\n [\"plan_expires_at\", \"text default ''\"],\n ];\n for (const [name, type] of columns) {\n await sqlite.execute({\n sql: `alter table credits add column ${name} ${type}`,\n }).catch(() => {});\n }\n}\n\nasync function migrateProfilePhotos() {\n await sqlite.execute({\n sql: \"alter table users add column photo_file_id text default ''\",\n }).catch(() => {});\n await sqlite.execute({\n sql: \"alter table pending_users add column photo_file_id text default ''\",\n }).catch(() => {});\n}\n\nasync function migrateVisibilityTables() {\n await sqlite.execute({\n sql: \"alter table hidden_profiles add column expires_at text default ''\",\n }).catch(() => {});\n}\n\nasync function getUser(groupId: number, userId: number) {\n const res = await sqlite.execute({\n sql:\n \"select * from users where group_id=? and user_id=? and deleted_at is null and banned=0\",\n args: [groupId, userId],\n });\n return res.rows[0] as UserRow | undefined;\n}\n\nasync function getActiveUser(userId: number) {\n const res = await sqlite.execute({\n sql:\n \"select * from users where user_id=? and active_dating=1 and deleted_at is null and banned=0 order by updated_at desc limit 1\",\n args: [userId],\n });\n return res.rows[0] as UserRow | undefined;\n}\n\nasync function getPendingUser(\n groupId: number,\n userId: number,\n): Promise {\n const res = await sqlite.execute({\n sql: \"select * from pending_users where group_id=? and user_id=? limit 1\",\n args: [groupId, userId],\n });\n const row = res.rows[0] as UserRow | undefined;\n if (!row) return undefined;\n return {\n groupId: Number(row.group_id),\n userId: Number(row.user_id),\n firstName: row.first_name ?? \"\",\n lastName: row.last_name ?? \"\",\n username: row.username ?? \"\",\n photoFileId: row.photo_file_id ?? \"\",\n messageCount: Number(row.message_count ?? 1),\n lastSeenAt: row.last_seen_at ?? nowIso(),\n };\n}\n\nasync function updateUser(\n groupId: number,\n userId: number,\n fields: Record,\n) {\n const allowed = [\n \"city\",\n \"gender\",\n \"seek_gender\",\n \"bio\",\n \"is_adult\",\n \"photo_file_id\",\n ];\n const keys = Object.keys(fields).filter((k) => allowed.includes(k));\n if (!keys.length) return;\n await sqlite.execute({\n sql: `update users set ${\n keys.map((k) => `${k}=?`).join(\",\")\n },updated_at=? where group_id=? and user_id=?`,\n args: [...keys.map((k) => fields[k]), nowIso(), groupId, userId],\n });\n}\n\nasync function setState(userId: number, step: string, data: any) {\n await sqlite.execute({\n sql:\n \"insert into states(user_id,step,data_json,updated_at) values(?,?,?,?) on conflict(user_id) do update set step=excluded.step,data_json=excluded.data_json,updated_at=excluded.updated_at\",\n args: [userId, step, JSON.stringify(data), nowIso()],\n });\n}\nasync function getState(userId: number) {\n const res = await sqlite.execute({\n sql: \"select * from states where user_id=?\",\n args: [userId],\n });\n return res.rows[0] as UserRow | undefined;\n}\nasync function clearState(userId: number) {\n await sqlite.execute({\n sql: \"delete from states where user_id=?\",\n args: [userId],\n });\n}\n\nasync function hasPremium(groupId: number, userId: number, feature: string) {\n if (isPrivilegedUser(userId)) return true;\n const res = await sqlite.execute({\n sql:\n \"select 1 from premium where group_id=? and user_id=? and feature=? and expires_at>? limit 1\",\n args: [groupId, userId, feature, nowIso()],\n });\n return Boolean(res.rows[0]);\n}\n\nasync function recordReferral(userId: number, payload: string) {\n const match = /^ref_(\\d+)$/.exec(payload || \"\");\n if (!match) return;\n const referrerId = Number(match[1]);\n if (!referrerId || referrerId === userId) return;\n await sqlite.execute({\n sql:\n \"insert or ignore into referrals(referrer_id,referred_id,created_at,purchased) values(?,?,?,0)\",\n args: [referrerId, userId, nowIso()],\n });\n}\n\nasync function markReferralPurchase(userId: number) {\n await sqlite.execute({\n sql: \"update referrals set purchased=1,purchased_at=? where referred_id=?\",\n args: [nowIso(), userId],\n });\n}\n\nasync function getReferralStats(userId: number) {\n const total = await sqlite.execute({\n sql: \"select count(*) total from referrals where referrer_id=?\",\n args: [userId],\n });\n const buyers = await sqlite.execute({\n sql:\n \"select count(*) buyers from referrals where referrer_id=? and purchased=1\",\n args: [userId],\n });\n const totalCount = Number((total.rows[0] as any)?.total || 0);\n const buyerCount = Number((buyers.rows[0] as any)?.buyers || 0);\n return {\n total: totalCount,\n buyers: buyerCount,\n discount: totalCount >= 10 && buyerCount >= 1,\n };\n}\n\nasync function getReferralDiscount(userId: number) {\n const stats = await getReferralStats(userId);\n return stats.discount ? 10 : 0;\n}\n\nasync function getBestDiscountInfo(userId: number) {\n const welcomeActive = WELCOME_DISCOUNT_PERCENT > 0 &&\n new Date(WELCOME_CAMPAIGN_UNTIL).getTime() > Date.now();\n const welcome = welcomeActive ? WELCOME_DISCOUNT_PERCENT : 0;\n const referral = await getReferralDiscount(userId);\n if (welcome >= referral && welcome > 0) {\n return { percent: welcome, label: \"Hos Geldin Kampanyasi\" };\n }\n if (referral > 0) return { percent: referral, label: \"Davet indirimi\" };\n return { percent: 0, label: \"\" };\n}\n\nfunction discountedStars(stars: number, discount: number) {\n if (!discount) return stars;\n return Math.max(1, Math.round(stars * (100 - discount) / 100));\n}\n\nfunction inferGroupForUser(userId: number) {\n if (!STRICT_ALLOWED_GROUPS) return 0;\n for (const key of knownUserIds) {\n const [g, u] = key.split(\":\").map(Number);\n if (u === userId) return g;\n }\n const first = [...ALLOWED_GROUP_IDS][0];\n return first || 0;\n}\n\nasync function maybeSetWebhook(url: string) {\n if (webhookReady) return;\n const webhookUrl = new URL(url);\n webhookUrl.pathname = \"/webhook\";\n webhookUrl.search = \"\";\n await tg(\"setWebhook\", { url: webhookUrl.toString() });\n webhookReady = true;\n}\n\nasync function tg(method: string, body: any) {\n const res = await fetch(`${TG}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const data = await res.json().catch(() => ({}));\n if (!res.ok || data.ok === false) {\n throw new Error(`${method}: ${JSON.stringify(data)}`);\n }\n return data;\n}\nasync function sendMessage(\n chatId: number | string,\n text: string,\n extra: any = {},\n) {\n return tg(\"sendMessage\", { chat_id: chatId, text, ...extra });\n}\nasync function answerCallback(id: string) {\n return tg(\"answerCallbackQuery\", { callback_query_id: id });\n}\nasync function clearInlineKeyboard(q: any) {\n const chatId = q.message?.chat?.id;\n const messageId = q.message?.message_id;\n if (!chatId || !messageId) return;\n await tg(\"editMessageReplyMarkup\", {\n chat_id: chatId,\n message_id: messageId,\n reply_markup: { inline_keyboard: [] },\n }).catch(() => {});\n}\nasync function answerPreCheckout(id: string, ok: boolean) {\n return tg(\"answerPreCheckoutQuery\", { pre_checkout_query_id: id, ok });\n}\nasync function getUserPhotoFileId(userId: number) {\n try {\n const data = await tg(\"getUserProfilePhotos\", {\n user_id: userId,\n limit: 1,\n });\n const photos = data.result?.photos;\n const first = Array.isArray(photos) ? photos[0] : undefined;\n if (!Array.isArray(first) || !first.length) return \"\";\n return first[first.length - 1]?.file_id ?? \"\";\n } catch {\n return \"\";\n }\n}\nasync function logError(scope: string, err: unknown) {\n console.error(scope, err);\n if (LOG_CHAT_ID) {\n await sendMessage(\n LOG_CHAT_ID,\n `Hata: ${scope}\\n${\n String((err as Error)?.message ?? err).slice(0, 1000)\n }`,\n ).catch(() => {});\n }\n}\n\nfunction keyboard(inline_keyboard: any[][]) {\n return { reply_markup: { inline_keyboard } };\n}\nfunction btn(text: string, callback_data: string) {\n return { text, callback_data };\n}\nfunction urlBtn(text: string, url: string) {\n return { text, url };\n}\nfunction hasMediaPayload(msg: any) {\n return Boolean(\n msg.photo ||\n msg.video ||\n msg.animation ||\n msg.document ||\n msg.audio ||\n msg.voice ||\n msg.video_note ||\n msg.sticker,\n );\n}\nfunction hasBlockedContact(text: string) {\n return /(https?:\\/\\/|www\\.|t\\.me\\/|telegram\\.me\\/|@\\w{3,}|(?:\\+?\\d[\\d\\s().-]{7,}\\d))/i\n .test(text);\n}\nfunction ok() {\n return new Response(\"ok\", { status: 200 });\n}\nfunction userKey(groupId: number, userId: number) {\n return `${groupId}:${userId}`;\n}\nfunction nowIso() {\n return new Date().toISOString();\n}\nfunction dayKey() {\n return new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: TZ,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).format(new Date());\n}\nfunction addDaysIso(days: number) {\n const d = new Date();\n d.setUTCDate(d.getUTCDate() + days);\n return d.toISOString();\n}\nfunction addHoursIso(hours: number) {\n const d = new Date();\n d.setUTCHours(d.getUTCHours() + hours);\n return d.toISOString();\n}\nfunction formatLastSeen(value: string) {\n if (!value) return \"bilinmiyor\";\n const date = new Date(value);\n if (Number.isNaN(date.getTime())) return \"yakinda\";\n const diffMs = Date.now() - date.getTime();\n const dayMs = 24 * 60 * 60 * 1000;\n if (diffMs < dayMs) return \"bugun\";\n if (diffMs < 2 * dayMs) return \"dun\";\n if (diffMs < 7 * dayMs) return \"son 7 gun icinde\";\n return new Intl.DateTimeFormat(\"tr-TR\", {\n timeZone: TZ,\n day: \"numeric\",\n month: \"long\",\n }).format(date);\n}\nfunction clean(text: string, max: number) {\n return text.trim().replace(/\\s+/g, \" \").slice(0, max);\n}\nfunction labelGender(g: string) {\n if (g === \"female\") return \"Kadin\";\n if (g === \"male\") return \"Erkek\";\n if (g === \"any\") return \"Farketmez\";\n return \"eklenmedi\";\n}\nfunction isPrivilegedUser(userId: number) {\n return Boolean(userId && (userId === OWNER_ID || userId === ADMIN_ID));\n}\nasync function requireAdminFromQuery(admin: string | undefined) {\n if (!ADMIN_ID || Number(admin) !== ADMIN_ID) throw new Error(\"Yetki yok\");\n}","createdAt",["D",1781375184361],"branchVersion","branchId","9429160c-fff2-4500-aa0d-83d75a528ab6","id","4555dd65-e469-4b4f-889c-e9fb2ee47dc6","KalpAt",["D",1781030178231],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","e7c5fd3e-8357-4e93-8118-a1197754c77f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019eadaa-f059-75cb-806f-3a87e9afe6f1","tursoName","4555dd65e4694b4f889ce9fb2ee47dc6","tursoHostname","4555dd65e4694b4f889ce9fb2ee47dc6-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789500689328],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",38,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","kalpat","handle","displayName","AHMET Y","avatar","https://lh3.googleusercontent.com/a/ACg8ocLPnvPNlOjcS-kABwYX-UdqBT1tn9vPbtz-SjvEiZpQ2yDL6A=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":154,"_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":65,"_66":67,"_68":155,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":156,"_82":157,"_84":158,"_86":25},"tree",[149],"files",[149],"counts",{"_137":61,"_138":139,"_140":61,"_141":142,"_143":144},"contents",[129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"66228705-1914-4bea-8453-2040c1ed4b38","parentId","latest",["D",1781375184361],19,"label",[28],"pulls","branches",1,"forks","envVars",{"_145":147,"_148":61},"connections",{"_145":61,"_146":61},"count","unfilledCount",8,"emptyCount",{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":150,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_151":152,"_27":153},["D",1781375184361],"children",[],[28],["D",1781030178231],["D",1789500689328],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":192,"_193":194,"_195":196,"_197":25,"_198":25,"_199":25,"_200":124,"_201":-5,"_202":-7,"_203":-7,"_204":61,"_205":25,"_206":25,"_207":-5,"_208":25,"_209":25,"_210":25,"_211":-5},"ENV",{"_163":164,"_165":166,"_167":88,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191},"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 · v20