[{"_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",24,"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(\n /^@/,\n \"\",\n);\nconst MATCH_ANIMATION_FILE_ID = Deno.env.get(\"MATCH_ANIMATION_FILE_ID\") ?? \"\";\nconst DEFAULT_PROFILE_PHOTO_URL = Deno.env.get(\"DEFAULT_PROFILE_PHOTO_URL\") ??\n \"https://api.dicebear.com/9.x/initials/png?seed=KalpAt\";\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 mail: \"\\u{1F48C}\",\n cake: \"\\u{1F382}\",\n hourglass: \"\\u{23F3}\",\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 (state?.step === \"compose_message\" && hasMediaPayload(msg)) {\n return continueMediaMessageFlow(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 await logUserEvent(\n \"Engellenen medya\",\n from,\n \"Medya premium eslesme mesaji disinda engellendi.\",\n );\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\") {\n await clearState(from.id);\n return sendMainMenu(msg.chat.id);\n }\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 await logUserEvent(\"Engellenen metin\", from, text);\n return sendMessage(\n msg.chat.id,\n \"Guvenlik icin link, @kullanici adi, telefon veya reklam metni gonderilemez.\",\n );\n }\n\n if (text && !text.startsWith(\"/\") && !state) {\n await logUserEvent(\"Kullanici mesaji\", from, text);\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 if (groupId === 0 && LOG_CHAT_ID) {\n await sendMessage(\n LOG_CHAT_ID,\n `${EM.check} Grup mesaji havuza yazildi\\nID: ${from.id}\\nAd: ${\n displayName(user)\n }`,\n ).catch(() => {});\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,deleted_at=null,banned=0,updated_at=excluded.updated_at,last_seen_at=excluded.last_seen_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 === \"edit_age\") {\n const age = Number(text);\n if (!Number.isInteger(age) || age < 18 || age > 99) {\n return sendMessage(chatId, \"Lutfen 18-99 arasinda bir yas yaz.\");\n }\n await updateUser(groupId, from.id, { age });\n await clearState(from.id);\n await sendMessage(chatId, `${EM.check} Yas guncellendi.`);\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"delete_reason\") {\n await createDeleteRequest(chatId, from, groupId, text);\n return;\n }\n if (state.step === \"compose_message\") {\n const toId = Number(data.toId);\n const target = await getUser(groupId, 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 logChatMessage(from, toId, body);\n await clearState(from.id);\n const fromName = displayName({\n firstName: from.first_name ?? \"\",\n lastName: from.last_name ?? \"\",\n first_name: from.first_name ?? \"\",\n last_name: from.last_name ?? \"\",\n });\n await sendMessage(\n toId,\n `${EM.chat} ${fromName} sana mesaj gonderdi:\\n\\n${body}`,\n keyboard([\n [\n btn(`${EM.chat} Cevapla`, `msg:${from.id}`),\n btn(`${EM.user} Profili gor`, `view_match:${from.id}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${from.id}`)],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n ).catch(() => {});\n return sendMessage(\n chatId,\n `${EM.check} Mesajin ${\n target ? displayName(target) : \"eslesmene\"\n } iletildi.`,\n keyboard([\n [\n btn(`${EM.chat} Yeni mesaj yaz`, `msg:${toId}`),\n btn(`${EM.user} Profili gor`, `view_match:${toId}`),\n ],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n }\n}\n\nasync function continueMediaMessageFlow(\n chatId: number,\n from: TgUser,\n msg: any,\n state: any,\n) {\n const data = JSON.parse(state.data_json || \"{}\");\n const groupId = Number(data.groupId || inferGroupForUser(from.id));\n const toId = Number(data.toId);\n if (!toId || !(await areMatched(groupId, from.id, toId))) {\n await clearState(from.id);\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n if (!(await hasAnyPremium(groupId, from.id))) {\n await logUserEvent(\"Premium olmayan medya denemesi\", from, mediaKind(msg));\n return showShop(\n chatId,\n from.id,\n `${EM.camera} Fotograf, video ve GIF mesajlari premium uyelere aciktir.`,\n );\n }\n const media = extractMedia(msg);\n if (!media) return sendMessage(chatId, \"Bu medya turu desteklenmiyor.\");\n const fromName = displayName({\n first_name: from.first_name ?? \"\",\n last_name: from.last_name ?? \"\",\n });\n const caption = `${EM.chat} ${fromName} sana ${media.label} gonderdi.`;\n await sendMedia(\n toId,\n media,\n caption,\n keyboard([\n [\n btn(`${EM.chat} Cevapla`, `msg:${from.id}`),\n btn(`${EM.user} Profili gor`, `view_match:${from.id}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${from.id}`)],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n ).catch(() => {});\n await logMediaEvent(\"Premium medya mesaji\", from, toId, media);\n await clearState(from.id);\n return sendMessage(\n chatId,\n `${EM.check} Medya mesajin iletildi.`,\n keyboard([[btn(`${EM.chat} Yeni mesaj yaz`, `msg:${toId}`)], [\n btn(`${EM.home} 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 === \"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_age\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_age\", { groupId: user.group_id });\n return sendMessage(chatId, `${EM.user} Yasini yaz. Ornek: 24`);\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 === \"toggle_badge\") return togglePremiumBadge(chatId, from.id);\n if (data.startsWith(\"msg:\")) {\n return beginMatchedMessage(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data.startsWith(\"view_match:\")) {\n return viewMatchedProfile(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data.startsWith(\"unmatch:\")) {\n await clearInlineKeyboard(q);\n return unmatchUser(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 await logAdminEvent(\n \"Kalp atildi\",\n `${displayName(from)} (${fromId}) -> ${displayName(target)} (${toId})`,\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 logAdminEvent(\n \"Eslesme olustu\",\n `${displayName(from)} (${fromId}) + ${displayName(target)} (${toId})`,\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 other = otherUserId ? await getActiveUser(otherUserId) : undefined;\n const otherName = other ? displayName(other) : \"eslesmen\";\n const displayText =\n `${EM.party} Karsilikli Kalp!\\n\\n${EM.sparklingHeart} ${otherName} ile eslestin.\\n${EM.chat} Bot icinden guvenli sekilde mesajlasabilirsiniz.`;\n const extra = otherUserId\n ? keyboard([\n [\n btn(`${EM.chat} Mesaj yaz`, `msg:${otherUserId}`),\n btn(`${EM.user} Profili gor`, `view_match:${otherUserId}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${otherUserId}`)],\n [btn(`${EM.home} 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}${EM.star} -> ${price(key)}${EM.star}`\n : `${PACKAGES[key].stars}${EM.star}`;\n const discountText = discount\n ? `\\n${discountInfo.label}: %${discount} indirim aktif`\n : \"\";\n const rows = [\n [btn(`${EM.twoHearts} Mini | 3/gun | ${priceLabel(\"mini\")}`, \"buy:mini\")],\n [btn(\n `${EM.sparklingHeart} Plus | 3/gun | ${priceLabel(\"plus\")}`,\n \"buy:plus\",\n )],\n [btn(`${EM.star} Gold | 7/gun | ${priceLabel(\"gold\")}`, \"buy:gold\")],\n [btn(`${EM.fire} VIP | 15/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\n${EM.hourglass} 7 gun\n${EM.heart} Gunde 3 kalp\n${EM.search} Cinsiyet filtresi\n\n${EM.sparklingHeart} Plus\n${EM.hourglass} 30 gun\n${EM.heart} Gunde 3 kalp\n${EM.eye} Beni begenenleri gor\n${EM.search} Cinsiyet filtresi\n\n${EM.star} Gold\n${EM.hourglass} 30 gun\n${EM.heart} Gunde 7 kalp\n${EM.eye} Beni begenenleri gor\n${EM.sparkles} Gizli gorunurluk\n${EM.search} Cinsiyet filtresi\n\n${EM.fire} VIP\n${EM.hourglass} 30 gun\n${EM.heart} Gunde 15 kalp\n${EM.eye} Beni begenenleri gor\n${EM.sparkles} Gizli gorunurluk\n${EM.search} Cinsiyet filtresi`,\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 await logAdminEvent(\n \"Satin alim\",\n `${buyerId}\\nPaket: ${pack.title}\\nTutar: ${payment.total_amount}${EM.star}`,\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(`${EM.twoHearts} Profil gez`, \"browse\")], [\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\n );\n }\n await sendMessage(chatId, `${EM.sparklingHeart} Eslesmelerin:`);\n for (const match of res.rows as any[]) {\n await sendProfileCard(\n chatId,\n match,\n keyboard([\n [\n btn(`${EM.chat} Mesaj yaz`, `msg:${match.user_id}`),\n btn(`${EM.user} Profili gor`, `view_match:${match.user_id}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${match.user_id}`)],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n }\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.mail} Yeni kalpler seni bekliyor\n\nDevam etmek icin 18+ oldugunu onayla.`;\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.mail} Yeni kalpler seni bekliyor\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 seni bekliyor\n${EM.fire} ${stats.recent} kisi yakin zamanda aktifti\n${EM.mail} Yeni kalpler seni bekliyor\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${await profileText(user)}`,\n keyboard([\n [\n btn(\"Sehir\", \"edit_city\"),\n btn(\"Yas\", \"edit_age\"),\n btn(\"Bio\", \"edit_bio\"),\n ],\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(\n user.show_premium_badge === 0\n ? `${EM.star} Rozeti goster`\n : `${EM.star} Rozeti gizle`,\n \"toggle_badge\",\n )],\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 togglePremiumBadge(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n const next = user.show_premium_badge === 0 ? 1 : 0;\n await updateUser(user.group_id, userId, { show_premium_badge: next });\n await sendMessage(\n chatId,\n next\n ? `${EM.star} Premium rozeti gosterilecek.`\n : `${EM.star} Premium rozeti gizlenecek.`,\n );\n return showEditProfile(chatId, userId);\n}\n\nasync function createDeleteRequest(\n chatId: number,\n from: TgUser,\n groupId: number,\n reason: string,\n) {\n const cleanReason = clean(reason, 500);\n if (!cleanReason || cleanReason.startsWith(\"/\")) {\n await clearState(from.id);\n return sendMainMenu(chatId);\n }\n await sqlite.execute({\n sql:\n \"insert into delete_requests(group_id,user_id,reason,status,created_at,updated_at) values(?,?,?,'pending',?,?)\",\n args: [groupId, from.id, cleanReason, nowIso(), nowIso()],\n });\n await clearState(from.id);\n await logUserEvent(\"Profil silme talebi\", from, cleanReason);\n await sendMessage(\n chatId,\n `${EM.check} Profil silme talebin alindi.\\n\\nTalebin admin tarafindan incelenecek. Uygun gorulurse 1-2 hafta icinde profilin silinebilir.`,\n );\n}\n\nasync function listDeleteRequests(chatId: number) {\n const res = await sqlite.execute({\n sql:\n \"select d.*,u.first_name,u.last_name from delete_requests d left join users u on u.group_id=d.group_id and u.user_id=d.user_id where d.status='pending' order by d.created_at asc limit 20\",\n });\n if (!res.rows.length) {\n return sendMessage(chatId, \"Bekleyen silme talebi yok.\");\n }\n const text = (res.rows as any[]).map((r) =>\n `${\n displayName(r)\n } (${r.user_id})\\nSebep: ${r.reason}\\n/admin approve_delete ${r.user_id}\\n/admin reject_delete ${r.user_id}`\n ).join(\"\\n\\n---\\n\\n\");\n return sendMessage(chatId, text);\n}\n\nasync function approveDeleteRequest(\n chatId: number,\n userId: number,\n adminId: number,\n) {\n await sqlite.execute({\n sql: \"update users set deleted_at=?,active_dating=0 where user_id=?\",\n args: [nowIso(), userId],\n });\n await sqlite.execute({\n sql:\n \"update delete_requests set status='approved',admin_id=?,updated_at=? where user_id=? and status='pending'\",\n args: [adminId, nowIso(), userId],\n });\n await sendMessage(userId, \"Profil silme talebin onaylandi. Profilin silindi.\")\n .catch(() => {});\n await logAdminEvent(\"Silme talebi onaylandi\", `user_id=${userId}`);\n return sendMessage(chatId, \"Silme talebi onaylandi.\");\n}\n\nasync function rejectDeleteRequest(\n chatId: number,\n userId: number,\n adminId: number,\n) {\n await sqlite.execute({\n sql:\n \"update delete_requests set status='rejected',admin_id=?,updated_at=? where user_id=? and status='pending'\",\n args: [adminId, nowIso(), userId],\n });\n await sendMessage(\n userId,\n \"Profil silme talebin incelendi ve reddedildi. Profilin aktif kalmaya devam ediyor.\",\n ).catch(() => {});\n await logAdminEvent(\"Silme talebi reddedildi\", `user_id=${userId}`);\n return sendMessage(chatId, \"Silme talebi reddedildi.\");\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 const target = await getUser(user.group_id, toId);\n await setState(fromId, \"compose_message\", { groupId: user.group_id, toId });\n return sendMessage(\n chatId,\n `${EM.chat} ${\n target ? displayName(target) : \"Eslesmen\"\n } icin mesajini simdi yaz.\\n\\nGuvenlik icin link, @kullanici adi, telefon, fotograf ve video gonderilemez.`,\n keyboard([\n [btn(`${EM.user} Profili gor`, `view_match:${toId}`)],\n [btn(`${EM.cross} Vazgec`, \"cancel\"), btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n}\n\nasync function viewMatchedProfile(\n chatId: number,\n viewerId: number,\n targetId: number,\n) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n if (!(await areMatched(viewer.group_id, viewerId, targetId))) {\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n const target = await getUser(viewer.group_id, targetId);\n if (!target) return sendMessage(chatId, \"Profil bulunamadi.\");\n return sendProfileCard(\n chatId,\n target,\n keyboard([\n [\n btn(`${EM.chat} Mesaj yaz`, `msg:${targetId}`),\n btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${targetId}`),\n ],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n}\n\nasync function unmatchUser(chatId: number, userId: number, otherId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sqlite.execute({\n sql: \"delete from matches where group_id=? and user1_id=? and user2_id=?\",\n args: [user.group_id, Math.min(userId, otherId), Math.max(userId, otherId)],\n });\n await sqlite.execute({\n sql:\n \"delete from likes where group_id=? and ((from_user_id=? and to_user_id=?) or (from_user_id=? and to_user_id=?))\",\n args: [user.group_id, userId, otherId, otherId, userId],\n });\n await clearState(userId);\n await sendMessage(otherId, `${EM.cross} Bir eslesme sona erdi.`).catch(\n () => {},\n );\n return sendMessage(\n chatId,\n `${EM.check} Eslesme kaldirildi.`,\n keyboard([[btn(`${EM.sparklingHeart} Eslesmelerim`, \"matches\")], [\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\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 recentUsers = await sqlite.execute({\n sql:\n \"select group_id,user_id,first_name,last_name,last_seen_at,message_count from users where deleted_at is null order by updated_at desc limit 8\",\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 recent_users: recentUsers.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] === \"delete_requests\") return listDeleteRequests(chatId);\n if (parts[1] === \"approve_delete\" && parts[2]) {\n return approveDeleteRequest(chatId, Number(parts[2]), fromId);\n }\n if (parts[1] === \"reject_delete\" && parts[2]) {\n return rejectDeleteRequest(chatId, Number(parts[2]), fromId);\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 | delete_requests | approve_delete ID | reject_delete ID | ban ID | unban ID | delete ID | flush | syncglobal | testmatch [CHAT_ID]\",\n );\n}\n\nasync function deleteProfile(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n const groupId = user?.group_id ?? inferGroupForUser(userId);\n await setState(userId, \"delete_reason\", { groupId });\n await sendMessage(\n chatId,\n `${EM.note} Profil silme talebi olusturmak icin sebebini yaz.\\n\\nTalebin admin tarafindan incelenir. Uygun gorulurse 1-2 hafta icinde profilin silinebilir.\\n\\nVazgecmek icin /menu yazabilirsin.`,\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,age,show_premium_badge,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,:age,:show_premium_badge,: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 const photo = user.photo_file_id || DEFAULT_PROFILE_PHOTO_URL;\n const text = await profileText(user);\n if (photo) {\n await tg(\"sendPhoto\", {\n chat_id: chatId,\n photo,\n caption: text,\n ...extra,\n });\n return;\n }\n await sendMessage(chatId, text, extra);\n}\n\nasync function profileText(u: UserRow) {\n const name = `${u.first_name || \"\"} ${u.last_name || \"\"}`.trim() || \"Isimsiz\";\n const badge =\n u.show_premium_badge !== 0 &&\n await hasAnyPremium(Number(u.group_id), Number(u.user_id))\n ? [`${EM.star} Premium`]\n : [];\n return [\n `${EM.heart} ${name}`,\n `${EM.pin} Sehir: ${u.city || \"eklenmedi\"}`,\n `${EM.cake} Yas: ${u.age || \"belirtilmedi\"}`,\n `${EM.user} Cinsiyet: ${labelGender(u.gender)}`,\n `${EM.note} Bio: ${u.bio || \"eklenmedi\"}`,\n `${EM.fire} Son aktif: ${formatLastSeen(u.last_seen_at)}`,\n ...badge,\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 age integer default 0,\n show_premium_badge integer default 1,\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 `create table if not exists delete_requests(id integer primary key autoincrement,group_id integer,user_id integer,reason text,status text default 'pending',admin_id integer default 0,created_at text,updated_at text)`,\n ]);\n await migrateCredits();\n await migrateProfilePhotos();\n await migrateVisibilityTables();\n await migrateProfileFields();\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 migrateProfileFields() {\n await sqlite.execute({\n sql: \"alter table users add column age integer default 0\",\n }).catch(() => {});\n await sqlite.execute({\n sql: \"alter table users add column show_premium_badge integer default 1\",\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 \"age\",\n \"show_premium_badge\",\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 hasAnyPremium(groupId: number, userId: number) {\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 expires_at>? limit 1\",\n args: [groupId, userId, 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\", {\n url: webhookUrl.toString(),\n allowed_updates: [\"message\", \"callback_query\", \"pre_checkout_query\"],\n });\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\nasync function logUserEvent(title: string, user: TgUser, content: string) {\n if (!LOG_CHAT_ID) return;\n await sendMessage(\n LOG_CHAT_ID,\n `${title}\\n\\nKullanici: ${displayName(user)} (${user.id})\\n\\n${\n content.slice(0, 1000)\n }`,\n ).catch(() => {});\n}\n\nasync function logAdminEvent(title: string, content: string) {\n if (!LOG_CHAT_ID) return;\n await sendMessage(LOG_CHAT_ID, `${title}\\n\\n${content.slice(0, 1500)}`).catch(\n () => {},\n );\n}\n\nasync function logChatMessage(from: TgUser, toId: number, text: string) {\n if (!LOG_CHAT_ID) return;\n await sendMessage(\n LOG_CHAT_ID,\n `${EM.chat} Bot ici mesaj\\n\\nKimden: ${\n displayName(from)\n } (${from.id})\\nKime: ${toId}\\n\\nMesaj:\\n${text.slice(0, 1500)}`,\n ).catch(() => {});\n}\n\nasync function logMediaEvent(\n title: string,\n from: TgUser,\n toId: number,\n media: any,\n) {\n if (!LOG_CHAT_ID) return;\n await sendMedia(\n LOG_CHAT_ID,\n media,\n `${title}\\nKimden: ${displayName(from)} (${from.id})\\nKime: ${toId}`,\n ).catch(() => {});\n}\n\nfunction extractMedia(msg: any) {\n if (msg.photo?.length) {\n return {\n method: \"sendPhoto\",\n field: \"photo\",\n fileId: msg.photo[msg.photo.length - 1].file_id,\n label: \"fotograf\",\n };\n }\n if (msg.video?.file_id) {\n return {\n method: \"sendVideo\",\n field: \"video\",\n fileId: msg.video.file_id,\n label: \"video\",\n };\n }\n if (msg.animation?.file_id) {\n return {\n method: \"sendAnimation\",\n field: \"animation\",\n fileId: msg.animation.file_id,\n label: \"GIF\",\n };\n }\n return null;\n}\n\nfunction mediaKind(msg: any) {\n return msg.photo\n ? \"fotograf\"\n : msg.video\n ? \"video\"\n : msg.animation\n ? \"GIF\"\n : \"desteklenmeyen medya\";\n}\n\nasync function sendMedia(\n chatId: number | string,\n media: any,\n caption: string,\n extra: any = {},\n) {\n return tg(media.method, {\n chat_id: chatId,\n [media.field]: media.fileId,\n caption,\n ...extra,\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 displayName(u: any) {\n return clean(\n `${u.first_name ?? u.firstName ?? \"\"} ${u.last_name ?? u.lastName ?? \"\"}`\n .trim() || \"Isimsiz\",\n 40,\n );\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 DEFAULT_PROFILE_PHOTO_URL = Deno.env.get(\"DEFAULT_PROFILE_PHOTO_URL\") ??\n \"https://api.dicebear.com/9.x/initials/png?seed=KalpAt\";\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 mail: \"\\u{1F48C}\",\n cake: \"\\u{1F382}\",\n hourglass: \"\\u{23F3}\",\n diamond: \"\\u{1F48E}\",\n target: \"\\u{1F3AF}\",\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 (state?.step === \"compose_message\" && hasMediaPayload(msg)) {\n return continueMediaMessageFlow(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 await logUserEvent(\n \"Engellenen medya\",\n from,\n \"Medya premium eslesme mesaji disinda engellendi.\",\n );\n return sendMessage(chat.id, \"Bu medya turu burada kabul edilmiyor.\");\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\") {\n await clearState(from.id);\n return sendMainMenu(msg.chat.id);\n }\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 await logUserEvent(\"Engellenen metin\", from, text);\n return sendMessage(\n msg.chat.id,\n \"Link, @kullanici adi, telefon veya reklam gonderilemez.\",\n );\n }\n\n if (text && !text.startsWith(\"/\") && !state) {\n await logUserEvent(\"Kullanici mesaji\", from, text);\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 const mode = await getCaptureMode();\n if (mode === \"batch\") {\n await queueGroupUser(groupId, from);\n if (groupId !== 0) await queueGroupUser(0, from);\n return;\n }\n await upsertGroupUser(groupId, from);\n if (groupId !== 0) await upsertGroupUser(0, from);\n}\n\nasync function queueGroupUser(groupId: number, from: TgUser) {\n const key = userKey(groupId, from.id);\n knownUserIds.add(key);\n const now = nowIso();\n await sqlite.execute({\n sql: `\ninsert into pending_users(group_id,user_id,first_name,last_name,username,photo_file_id,message_count,last_seen_at,created_at)\nvalues(?,?,?,?,?,?,1,?,?)\non conflict(group_id,user_id) do update set\nfirst_name=excluded.first_name,\nlast_name=excluded.last_name,\nusername=excluded.username,\nphoto_file_id=coalesce(nullif(excluded.photo_file_id,''),pending_users.photo_file_id),\nmessage_count=pending_users.message_count+1,\nlast_seen_at=excluded.last_seen_at\n`,\n args: [\n groupId,\n from.id,\n from.first_name ?? \"\",\n from.last_name ?? \"\",\n from.username ?? \"\",\n await getUserPhotoFileId(from.id),\n now,\n now,\n ],\n });\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: `\ninsert 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)\nvalues(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,1,:lastSeenAt,:lastSeenAt,:lastSeenAt)\non conflict(group_id,user_id) do update set\nfirst_name=excluded.first_name,\nlast_name=excluded.last_name,\nusername=excluded.username,\nphoto_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\nmessage_count=users.message_count+1,\nlast_seen_at=excluded.last_seen_at,\nupdated_at=excluded.updated_at\n`,\n args: user,\n });\n if (groupId === 0 && LOG_CHAT_ID) {\n await sendMessage(\n LOG_CHAT_ID,\n `${EM.check} Grup mesaji havuza yazildi\\nID: ${from.id}\\nAd: ${\n displayName(user)\n }`,\n ).catch(() => {});\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: `\ninsert 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)\nvalues(:group_id,:user_id,:first_name,:last_name,:username,:photo_file_id,1,0,:now,:now,:now,0)\non conflict(group_id,user_id) do update set\nfirst_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),\nactive_dating=1,deleted_at=null,banned=0,updated_at=excluded.updated_at,last_seen_at=excluded.last_seen_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 === \"edit_interests\") {\n await updateUser(groupId, from.id, { interests: clean(text, 120) });\n await clearState(from.id);\n await sendMessage(chatId, `${EM.check} Ilgi alanlari guncellendi.`);\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"edit_age\") {\n const age = Number(text);\n if (!Number.isInteger(age) || age < 18 || age > 99) {\n return sendMessage(chatId, \"Lutfen 18-99 arasinda bir yas yaz.\");\n }\n await updateUser(groupId, from.id, { age });\n await clearState(from.id);\n await sendMessage(chatId, `${EM.check} Yas guncellendi.`);\n return showEditProfile(chatId, from.id);\n }\n if (state.step === \"delete_reason\") {\n await createDeleteRequest(chatId, from, groupId, text);\n return;\n }\n if (state.step === \"compose_message\") {\n const toId = Number(data.toId);\n const target = await getUser(groupId, 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 logChatMessage(from, toId, body);\n await clearState(from.id);\n const fromName = displayName({\n firstName: from.first_name ?? \"\",\n lastName: from.last_name ?? \"\",\n first_name: from.first_name ?? \"\",\n last_name: from.last_name ?? \"\",\n });\n await sendMessage(\n toId,\n `${EM.chat} ${fromName} sana mesaj gonderdi:\\n\\n${body}`,\n keyboard([\n [\n btn(`${EM.chat} Cevapla`, `msg:${from.id}`),\n btn(`${EM.user} Profili gor`, `view_match:${from.id}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${from.id}`)],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n ).catch(() => {});\n return sendMessage(\n chatId,\n `${EM.check} Mesajin ${\n target ? displayName(target) : \"eslesmene\"\n } iletildi.`,\n keyboard([\n [\n btn(`${EM.chat} Yeni mesaj yaz`, `msg:${toId}`),\n btn(`${EM.user} Profili gor`, `view_match:${toId}`),\n ],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n }\n}\n\nasync function continueMediaMessageFlow(\n chatId: number,\n from: TgUser,\n msg: any,\n state: any,\n) {\n const data = JSON.parse(state.data_json || \"{}\");\n const groupId = Number(data.groupId || inferGroupForUser(from.id));\n const toId = Number(data.toId);\n if (!toId || !(await areMatched(groupId, from.id, toId))) {\n await clearState(from.id);\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n if (!(await hasAnyPremium(groupId, from.id))) {\n await logUserEvent(\"Premium olmayan medya denemesi\", from, mediaKind(msg));\n return showShop(\n chatId,\n from.id,\n `${EM.camera} Fotograf, video ve GIF mesajlari premium uyelere aciktir.`,\n );\n }\n const media = extractMedia(msg);\n if (!media) return sendMessage(chatId, \"Bu medya turu desteklenmiyor.\");\n const fromName = displayName({\n first_name: from.first_name ?? \"\",\n last_name: from.last_name ?? \"\",\n });\n const caption = `${EM.chat} ${fromName} sana ${media.label} gonderdi.`;\n await sendMedia(\n toId,\n media,\n caption,\n keyboard([\n [\n btn(`${EM.chat} Cevapla`, `msg:${from.id}`),\n btn(`${EM.user} Profili gor`, `view_match:${from.id}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${from.id}`)],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n ).catch(() => {});\n await logMediaEvent(\"Premium medya mesaji\", from, toId, media);\n await clearState(from.id);\n return sendMessage(\n chatId,\n `${EM.check} Medya mesajin iletildi.`,\n keyboard([[btn(`${EM.chat} Yeni mesaj yaz`, `msg:${toId}`)], [\n btn(`${EM.home} 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 === \"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} Standartta iki cinsiyet de gorunur.\\n${EM.search} Cinsiyet filtresi paketlerde acilir.\\n\\n${EM.note} Kisa bio yaz. 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_interests\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_interests\", { groupId: user.group_id });\n return sendMessage(\n chatId,\n \"Ilgi alanlarini yaz. Ornek: muzik, kahve, film, spor\",\n );\n }\n if (data === \"edit_age\") {\n const user = await getActiveUser(from.id);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await setState(from.id, \"edit_age\", { groupId: user.group_id });\n return sendMessage(chatId, `${EM.user} Yasini yaz. Ornek: 24`);\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 === \"toggle_badge\") return togglePremiumBadge(chatId, from.id);\n if (data.startsWith(\"msg:\")) {\n return beginMatchedMessage(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data.startsWith(\"view_match:\")) {\n return viewMatchedProfile(chatId, from.id, Number(data.split(\":\")[1]));\n }\n if (data.startsWith(\"unmatch:\")) {\n await clearInlineKeyboard(q);\n return unmatchUser(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: `\nselect u.* from users u\nleft join likes l on l.group_id=u.group_id and l.from_user_id=:viewer and l.to_user_id=u.user_id\nwhere u.group_id=:group_id and u.user_id<>:viewer and u.deleted_at is null and u.banned=0\nand l.id is null\nand 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)\nand 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)\nand (\nnot 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)\nor 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)\nand (:can_filter=0 or :seek='any' or u.gender is null or u.gender='' or u.gender=:seek)\norder by u.active_dating desc, u.last_seen_at desc\nlimit 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: `\ninsert into hidden_profiles(group_id,viewer_user_id,hidden_user_id,created_at,expires_at)\nvalues(?,?,?,?,?)\non conflict(group_id,viewer_user_id,hidden_user_id) do update set\ncreated_at=excluded.created_at,\nexpires_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: `\ninsert into profile_snoozes(group_id,viewer_user_id,snoozed_user_id,created_at,expires_at)\nvalues(?,?,?,?,?)\non conflict(group_id,viewer_user_id,snoozed_user_id) do update set\ncreated_at=excluded.created_at,\nexpires_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 await logAdminEvent(\n \"Kalp atildi\",\n `${displayName(from)} (${fromId}) -> ${displayName(target)} (${toId})`,\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 logAdminEvent(\n \"Eslesme olustu\",\n `${displayName(from)} (${fromId}) + ${displayName(target)} (${toId})`,\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 other = otherUserId ? await getActiveUser(otherUserId) : undefined;\n const otherName = other ? displayName(other) : \"eslesmen\";\n const displayText =\n `${EM.party} Karsilikli Kalp!\\n\\n${EM.sparklingHeart} ${otherName} ile eslestin.\\n${EM.chat} Bot icinden guvenli sekilde mesajlasabilirsiniz.`;\n const extra = otherUserId\n ? keyboard([\n [\n btn(`${EM.chat} Mesaj yaz`, `msg:${otherUserId}`),\n btn(`${EM.user} Profili gor`, `view_match:${otherUserId}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${otherUserId}`)],\n [btn(`${EM.home} 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}${EM.star} -> ${price(key)}${EM.star}`\n : `${PACKAGES[key].stars}${EM.star}`;\n const discountText = discount\n ? `\\n${discountInfo.label}: %${discount} indirim aktif`\n : \"\";\n const rows = [\n [btn(`${EM.twoHearts} Mini | 3/gun | ${priceLabel(\"mini\")}`, \"buy:mini\")],\n [btn(\n `${EM.sparklingHeart} Plus | 3/gun | ${priceLabel(\"plus\")}`,\n \"buy:plus\",\n )],\n [btn(`${EM.star} Gold | 7/gun | ${priceLabel(\"gold\")}`, \"buy:gold\")],\n [btn(`${EM.fire} VIP | 15/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\n${EM.hourglass} 7 gun\n${EM.heart} Gunde 3 kalp\n${EM.search} Cinsiyet filtresi\n\n${EM.sparklingHeart} Plus\n${EM.hourglass} 30 gun\n${EM.heart} Gunde 3 kalp\n${EM.eye} Beni begenenleri gor\n${EM.search} Cinsiyet filtresi\n\n${EM.star} Gold\n${EM.hourglass} 30 gun\n${EM.heart} Gunde 7 kalp\n${EM.eye} Beni begenenleri gor\n${EM.sparkles} Gizli gorunurluk\n${EM.search} Cinsiyet filtresi\n\n${EM.fire} VIP\n${EM.hourglass} 30 gun\n${EM.heart} Gunde 15 kalp\n${EM.eye} Beni begenenleri gor\n${EM.sparkles} Gizli gorunurluk\n${EM.search} Cinsiyet filtresi`,\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\nKadin/erkek/farketmez secimi. Tum paketlerde acilir.\n\n${EM.eye} Beni begenenleri gor\nSeni begenenleri listelersin. Plus ve ustu.\n\n${EM.sparkles} Gizli gorunurluk\nSadece begendiklerin seni gorur. Gold ve VIP.\n\n${EM.gift} Davet indirimi\n10 davet + 1 satis = %10 indirim.`,\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 ile referans linkini gonderebilirsin.`,\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} Cinsiyet filtresi tum 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: `\ninsert 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)\nvalues(?,?,0,'',0,?,'',0,?)\non conflict(group_id,user_id) do update set\nplan_daily_likes=excluded.plan_daily_likes,\nplan_used_day='',\nplan_used_today=0,\nplan_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: `\ninsert into premium(group_id,user_id,feature,expires_at,created_at) values(?,?,?,?,?)\non 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 await logAdminEvent(\n \"Satin alim\",\n `${buyerId}\\nPaket: ${pack.title}\\nTutar: ${payment.total_amount}${EM.star}`,\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: `\nselect u.* from likes l\njoin users u on u.group_id=l.group_id and u.user_id=l.from_user_id\nleft 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\nwhere l.group_id=:group_id and l.to_user_id=:me and mine.id is null\norder by l.created_at desc\nlimit 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: `\nselect u.* from matches m\njoin users u on u.group_id=m.group_id\nand u.user_id=case when m.user1_id=:user then m.user2_id else m.user1_id end\nwhere m.group_id=:group_id and (m.user1_id=:user or m.user2_id=:user)\nand u.deleted_at is null and u.banned=0\norder by m.created_at desc\nlimit 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(`${EM.twoHearts} Profil gez`, \"browse\")], [\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\n );\n }\n await sendMessage(chatId, `${EM.sparklingHeart} Eslesmelerin:`);\n for (const match of res.rows as any[]) {\n await sendProfileCard(\n chatId,\n match,\n keyboard([\n [\n btn(`${EM.chat} Mesaj yaz`, `msg:${match.user_id}`),\n btn(`${EM.user} Profili gor`, `view_match:${match.user_id}`),\n ],\n [btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${match.user_id}`)],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n }\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.mail} Yeni kalpler seni bekliyor\n\nDevam etmek icin 18+ oldugunu onayla.`;\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.mail} Yeni kalpler seni bekliyor\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 seni bekliyor\n${EM.fire} ${stats.recent} kisi yakin zamanda aktifti\n${EM.mail} Yeni kalpler seni bekliyor\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: `\nselect\ncount(*) total,\nsum(case when active_dating=1 then 1 else 0 end) active,\nsum(case when last_seen_at>=? then 1 else 0 end) recent\nfrom users\nwhere 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${await profileText(user)}`,\n keyboard([\n [\n btn(\"Sehir\", \"edit_city\"),\n btn(\"Yas\", \"edit_age\"),\n btn(\"Bio\", \"edit_bio\"),\n ],\n [btn(\"Ilgi alanlari\", \"edit_interests\")],\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(\n user.show_premium_badge === 0\n ? `${EM.star} Rozeti goster`\n : `${EM.star} Rozeti gizle`,\n \"toggle_badge\",\n )],\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 togglePremiumBadge(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n const next = user.show_premium_badge === 0 ? 1 : 0;\n await updateUser(user.group_id, userId, { show_premium_badge: next });\n await sendMessage(\n chatId,\n next\n ? `${EM.star} Premium rozeti gosterilecek.`\n : `${EM.star} Premium rozeti gizlenecek.`,\n );\n return showEditProfile(chatId, userId);\n}\n\nasync function createDeleteRequest(\n chatId: number,\n from: TgUser,\n groupId: number,\n reason: string,\n) {\n const cleanReason = clean(reason, 500);\n if (!cleanReason || cleanReason.startsWith(\"/\")) {\n await clearState(from.id);\n return sendMainMenu(chatId);\n }\n await sqlite.execute({\n sql:\n \"insert into delete_requests(group_id,user_id,reason,status,created_at,updated_at) values(?,?,?,'pending',?,?)\",\n args: [groupId, from.id, cleanReason, nowIso(), nowIso()],\n });\n await clearState(from.id);\n await logUserEvent(\"Profil silme talebi\", from, cleanReason);\n await sendMessage(\n chatId,\n `${EM.check} Profil silme talebin alindi.\\n\\nTalebin admin tarafindan incelenecek. Uygun gorulurse 1-2 hafta icinde profilin silinebilir.`,\n );\n}\n\nasync function listDeleteRequests(chatId: number) {\n const res = await sqlite.execute({\n sql:\n \"select d.*,u.first_name,u.last_name from delete_requests d left join users u on u.group_id=d.group_id and u.user_id=d.user_id where d.status='pending' order by d.created_at asc limit 20\",\n });\n if (!res.rows.length) {\n return sendMessage(chatId, \"Bekleyen silme talebi yok.\");\n }\n const text = (res.rows as any[]).map((r) =>\n `${\n displayName(r)\n } (${r.user_id})\\nSebep: ${r.reason}\\n/admin approve_delete ${r.user_id}\\n/admin reject_delete ${r.user_id}`\n ).join(\"\\n\\n---\\n\\n\");\n return sendMessage(chatId, text);\n}\n\nasync function approveDeleteRequest(\n chatId: number,\n userId: number,\n adminId: number,\n) {\n await sqlite.execute({\n sql: \"update users set deleted_at=?,active_dating=0 where user_id=?\",\n args: [nowIso(), userId],\n });\n await sqlite.execute({\n sql:\n \"update delete_requests set status='approved',admin_id=?,updated_at=? where user_id=? and status='pending'\",\n args: [adminId, nowIso(), userId],\n });\n await sendMessage(userId, \"Profil silme talebin onaylandi. Profilin silindi.\")\n .catch(() => {});\n await logAdminEvent(\"Silme talebi onaylandi\", `user_id=${userId}`);\n return sendMessage(chatId, \"Silme talebi onaylandi.\");\n}\n\nasync function rejectDeleteRequest(\n chatId: number,\n userId: number,\n adminId: number,\n) {\n await sqlite.execute({\n sql:\n \"update delete_requests set status='rejected',admin_id=?,updated_at=? where user_id=? and status='pending'\",\n args: [adminId, nowIso(), userId],\n });\n await sendMessage(\n userId,\n \"Profil silme talebin incelendi ve reddedildi. Profilin aktif kalmaya devam ediyor.\",\n ).catch(() => {});\n await logAdminEvent(\"Silme talebi reddedildi\", `user_id=${userId}`);\n return sendMessage(chatId, \"Silme talebi reddedildi.\");\n}\n\nasync function handleCaptureAdmin(chatId: number, mode?: string) {\n if (!mode) {\n const current = await getCaptureMode();\n return sendMessage(\n chatId,\n `Profil toplama modu: ${\n current === \"instant\" ? \"Aninda\" : \"Toplu\"\n }\\n\\n/admin capture instant\\n/admin capture batch`,\n );\n }\n if (![\"instant\", \"batch\"].includes(mode)) {\n return sendMessage(\n chatId,\n \"Kullanim: /admin capture instant veya /admin capture batch\",\n );\n }\n await setSetting(\"capture_mode\", mode);\n await logAdminEvent(\"Profil toplama modu degisti\", mode);\n return sendMessage(\n chatId,\n mode === \"instant\"\n ? \"Profil toplama modu: Aninda. Grupta mesaj atan kullanici hemen havuza yazilir.\"\n : \"Profil toplama modu: Toplu. Grupta mesaj atan kullanici bekleme listesine alinir; /cron veya /admin flush ile toplu yazilir.\",\n );\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 const target = await getUser(user.group_id, toId);\n await setState(fromId, \"compose_message\", { groupId: user.group_id, toId });\n return sendMessage(\n chatId,\n `${EM.chat} ${\n target ? displayName(target) : \"Eslesmen\"\n } icin mesajini yaz.\\n\\nLink, @kullanici adi, telefon ve medya gonderilemez.`,\n keyboard([\n [btn(`${EM.user} Profili gor`, `view_match:${toId}`)],\n [btn(`${EM.cross} Vazgec`, \"cancel\"), btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n}\n\nasync function viewMatchedProfile(\n chatId: number,\n viewerId: number,\n targetId: number,\n) {\n const viewer = await getActiveUser(viewerId);\n if (!viewer) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n if (!(await areMatched(viewer.group_id, viewerId, targetId))) {\n return sendMessage(chatId, \"Bu kisiyle aktif eslesme bulunamadi.\");\n }\n const target = await getUser(viewer.group_id, targetId);\n if (!target) return sendMessage(chatId, \"Profil bulunamadi.\");\n return sendProfileCard(\n chatId,\n target,\n keyboard([\n [\n btn(`${EM.chat} Mesaj yaz`, `msg:${targetId}`),\n btn(`${EM.cross} Eslesmeyi kaldir`, `unmatch:${targetId}`),\n ],\n [btn(`${EM.home} Menu`, \"menu\")],\n ]),\n );\n}\n\nasync function unmatchUser(chatId: number, userId: number, otherId: number) {\n const user = await getActiveUser(userId);\n if (!user) return sendMessage(chatId, \"Once /start ile profil olusturun.\");\n await sqlite.execute({\n sql: \"delete from matches where group_id=? and user1_id=? and user2_id=?\",\n args: [user.group_id, Math.min(userId, otherId), Math.max(userId, otherId)],\n });\n await sqlite.execute({\n sql:\n \"delete from likes where group_id=? and ((from_user_id=? and to_user_id=?) or (from_user_id=? and to_user_id=?))\",\n args: [user.group_id, userId, otherId, otherId, userId],\n });\n await clearState(userId);\n await sendMessage(otherId, `${EM.cross} Bir eslesme sona erdi.`).catch(\n () => {},\n );\n return sendMessage(\n chatId,\n `${EM.check} Eslesme kaldirildi.`,\n keyboard([[btn(`${EM.sparklingHeart} Eslesmelerim`, \"matches\")], [\n btn(`${EM.home} Menu`, \"menu\"),\n ]]),\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 recentUsers = await sqlite.execute({\n sql:\n \"select group_id,user_id,first_name,last_name,last_seen_at,message_count from users where deleted_at is null order by updated_at desc limit 8\",\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 const captureMode = await getCaptureMode();\n return sendMessage(\n chatId,\n \"Stats:\\n\" + JSON.stringify(\n {\n capture_mode: captureMode,\n groups: groups.rows,\n recent_users: recentUsers.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] === \"delete_requests\") return listDeleteRequests(chatId);\n if (parts[1] === \"approve_delete\" && parts[2]) {\n return approveDeleteRequest(chatId, Number(parts[2]), fromId);\n }\n if (parts[1] === \"reject_delete\" && parts[2]) {\n return rejectDeleteRequest(chatId, Number(parts[2]), fromId);\n }\n if (parts[1] === \"capture\") return handleCaptureAdmin(chatId, parts[2]);\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|capture instant/batch|delete_requests|approve_delete ID|reject_delete ID|ban ID|unban ID|delete ID|flush|syncglobal|testmatch\",\n );\n}\n\nasync function deleteProfile(chatId: number, userId: number) {\n const user = await getActiveUser(userId);\n const groupId = user?.group_id ?? inferGroupForUser(userId);\n await setState(userId, \"delete_reason\", { groupId });\n await sendMessage(\n chatId,\n `${EM.note} Profil silme talebi icin sebebini yaz.\\n\\nAdmin inceler; uygun gorulurse 1-2 hafta icinde silinebilir.\\n\\nVazgecmek icin /menu.`,\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: `\ninsert into users(group_id,user_id,first_name,last_name,username,photo_file_id,active_dating,is_adult,city,gender,seek_gender,bio,interests,age,show_premium_badge,message_count,last_seen_at,created_at,updated_at)\nvalues(0,:user_id,:first_name,:last_name,:username,:photo_file_id,:active_dating,:is_adult,:city,:gender,:seek_gender,:bio,:interests,:age,:show_premium_badge,:message_count,:last_seen_at,:created_at,:updated_at)\non conflict(group_id,user_id) do update set\nfirst_name=excluded.first_name,\nlast_name=excluded.last_name,\nusername=excluded.username,\nphoto_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\nmessage_count=max(users.message_count,excluded.message_count),\nlast_seen_at=excluded.last_seen_at,\nupdated_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 const photo = user.photo_file_id || DEFAULT_PROFILE_PHOTO_URL;\n const text = await profileText(user);\n if (photo) {\n await tg(\"sendPhoto\", {\n chat_id: chatId,\n photo,\n caption: text,\n ...extra,\n });\n return;\n }\n await sendMessage(chatId, text, extra);\n}\n\nasync function profileText(u: UserRow) {\n const name = `${u.first_name || \"\"} ${u.last_name || \"\"}`.trim() || \"Isimsiz\";\n const premium = u.show_premium_badge !== 0 &&\n await hasAnyPremium(Number(u.group_id), Number(u.user_id));\n const badge = premium\n ? [`${EM.star} Premium Profil`, `${EM.diamond} One cikan uye`]\n : [];\n const bio = u.bio || defaultBioForUser(Number(u.user_id));\n const interests = u.interests\n ? [`${EM.target} Ilgi alanlari: ${u.interests}`]\n : [];\n return [\n ...badge,\n `${EM.heart} ${name}`,\n `${EM.pin} Sehir: ${u.city || \"gizli\"}`,\n `${EM.cake} Yas: ${u.age || \"belirtilmedi\"}`,\n `${EM.user} Cinsiyet: ${u.gender ? labelGender(u.gender) : \"gizli\"}`,\n `${EM.note} Bio: ${bio}`,\n ...interests,\n `${EM.fire} 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: `\ninsert 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)\nvalues(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,:messageCount,:lastSeenAt,:now,:now)\non conflict(group_id,user_id) do update set\nfirst_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),\nmessage_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: `\ninsert 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)\nvalues(:groupId,:userId,:firstName,:lastName,:username,:photoFileId,0,0,:messageCount,:lastSeenAt,:now,:now)\non conflict(group_id,user_id) do update set\nfirst_name=excluded.first_name,last_name=excluded.last_name,username=excluded.username,\nphoto_file_id=coalesce(nullif(excluded.photo_file_id,''),users.photo_file_id),\nupdated_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(\nid integer primary key autoincrement,\ngroup_id integer not null,\nuser_id integer not null,\nfirst_name text default '',\nlast_name text default '',\nusername text default '',\nphoto_file_id text default '',\nactive_dating integer default 0,\nis_adult integer default 0,\ncity text default '',\ngender text default '',\nseek_gender text default 'any',\nbio text default '',\ninterests text default '',\nage integer default 0,\nshow_premium_badge integer default 1,\nmessage_count integer default 0,\nlast_seen_at text,\nbanned integer default 0,\ndeleted_at text,\ncreated_at text,\nupdated_at text,\nunique(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(\ngroup_id integer,\nuser_id integer,\npaid_likes integer default 0,\nfree_like_day text default '',\nfree_like_used integer default 0,\nplan_daily_likes integer default 0,\nplan_used_day text default '',\nplan_used_today integer default 0,\nplan_expires_at text default '',\nprimary 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 `create table if not exists delete_requests(id integer primary key autoincrement,group_id integer,user_id integer,reason text,status text default 'pending',admin_id integer default 0,created_at text,updated_at text)`,\n `create table if not exists settings(key text primary key,value text,updated_at text)`,\n ]);\n await migrateCredits();\n await migrateProfilePhotos();\n await migrateVisibilityTables();\n await migrateProfileFields();\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 migrateProfileFields() {\n await sqlite.execute({\n sql: \"alter table users add column age integer default 0\",\n }).catch(() => {});\n await sqlite.execute({\n sql: \"alter table users add column show_premium_badge integer default 1\",\n }).catch(() => {});\n await sqlite.execute({\n sql: \"alter table users add column interests 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 \"interests\",\n \"is_adult\",\n \"photo_file_id\",\n \"age\",\n \"show_premium_badge\",\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 hasAnyPremium(groupId: number, userId: number) {\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 expires_at>? limit 1\",\n args: [groupId, userId, nowIso()],\n });\n return Boolean(res.rows[0]);\n}\n\nasync function getSetting(key: string, fallback = \"\") {\n const res = await sqlite.execute({\n sql: \"select value from settings where key=? limit 1\",\n args: [key],\n });\n return String((res.rows[0] as any)?.value ?? fallback);\n}\n\nasync function setSetting(key: string, value: string) {\n await sqlite.execute({\n sql:\n \"insert into settings(key,value,updated_at) values(?,?,?) on conflict(key) do update set value=excluded.value,updated_at=excluded.updated_at\",\n args: [key, value, nowIso()],\n });\n}\n\nasync function getCaptureMode() {\n const mode = await getSetting(\"capture_mode\", \"instant\");\n return mode === \"batch\" ? \"batch\" : \"instant\";\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\", {\n url: webhookUrl.toString(),\n allowed_updates: [\"message\", \"callback_query\", \"pre_checkout_query\"],\n });\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\nasync function logUserEvent(title: string, user: TgUser, content: string) {\n if (!LOG_CHAT_ID) return;\n await sendMessage(\n LOG_CHAT_ID,\n `${title}\\n\\nKullanici: ${displayName(user)} (${user.id})\\n\\n${\n content.slice(0, 1000)\n }`,\n ).catch(() => {});\n}\n\nasync function logAdminEvent(title: string, content: string) {\n if (!LOG_CHAT_ID) return;\n await sendMessage(LOG_CHAT_ID, `${title}\\n\\n${content.slice(0, 1500)}`).catch(\n () => {},\n );\n}\n\nasync function logChatMessage(from: TgUser, toId: number, text: string) {\n if (!LOG_CHAT_ID) return;\n await sendMessage(\n LOG_CHAT_ID,\n `${EM.chat} Bot ici mesaj\\n\\nKimden: ${\n displayName(from)\n } (${from.id})\\nKime: ${toId}\\n\\nMesaj:\\n${text.slice(0, 1500)}`,\n ).catch(() => {});\n}\n\nasync function logMediaEvent(\n title: string,\n from: TgUser,\n toId: number,\n media: any,\n) {\n if (!LOG_CHAT_ID) return;\n await sendMedia(\n LOG_CHAT_ID,\n media,\n `${title}\\nKimden: ${displayName(from)} (${from.id})\\nKime: ${toId}`,\n ).catch(() => {});\n}\n\nfunction extractMedia(msg: any) {\n if (msg.photo?.length) {\n return {\n method: \"sendPhoto\",\n field: \"photo\",\n fileId: msg.photo[msg.photo.length - 1].file_id,\n label: \"fotograf\",\n };\n }\n if (msg.video?.file_id) {\n return {\n method: \"sendVideo\",\n field: \"video\",\n fileId: msg.video.file_id,\n label: \"video\",\n };\n }\n if (msg.animation?.file_id) {\n return {\n method: \"sendAnimation\",\n field: \"animation\",\n fileId: msg.animation.file_id,\n label: \"GIF\",\n };\n }\n return null;\n}\n\nfunction mediaKind(msg: any) {\n return msg.photo\n ? \"fotograf\"\n : msg.video\n ? \"video\"\n : msg.animation\n ? \"GIF\"\n : \"desteklenmeyen medya\";\n}\n\nasync function sendMedia(\n chatId: number | string,\n media: any,\n caption: string,\n extra: any = {},\n) {\n return tg(media.method, {\n chat_id: chatId,\n [media.field]: media.fileId,\n caption,\n ...extra,\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 displayName(u: any) {\n return clean(\n `${u.first_name ?? u.firstName ?? \"\"} ${u.last_name ?? u.lastName ?? \"\"}`\n .trim() || \"Isimsiz\",\n 40,\n );\n}\nfunction defaultBioForUser(userId: number) {\n const bios = [\n \"Telegram'da sohbet etmeyi severim.\",\n \"Yeni insanlarla tanismayi severim.\",\n \"Guzel sohbet her zaman iyidir.\",\n \"Muzik, kahve ve samimi muhabbet.\",\n \"Burada yeni insanlari kesfetmek icin varim.\",\n \"Iyi enerji ve keyifli sohbet ariyorum.\",\n \"Kisa bir selam bazen guzel seyler baslatir.\",\n \"Sohbeti guzel insanlari severim.\",\n \"Yeni arkadasliklar ve guzel muhabbetler.\",\n \"Bazen en guzel tanismalar tesadufen olur.\",\n ];\n return bios[Math.abs(Number(userId || 0)) % bios.length];\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",1781451345217],"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},"c241f6b2-8ec8-4da7-a70e-124866a0709f","parentId","latest",["D",1781451345217],23,"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",1781451345217],"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 · v24