[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":25,"_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",5,"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","40c8f232-ae67-11f1-a9a5-1607ee4eb77e","name","fileType","script","content","/**\n * Berya Students Fellowship Telegram Bot — Val Town HTTP val\n *\n * Architecture note: Val Town runs each HTTP request in a fresh, stateless\n * invocation — there is no long-lived process like Python's infinity_polling().\n * Telegram is configured to POST each update straight to this val's URL\n * (a \"webhook\"), and every piece of state — registered users, attendance,\n * and even *mid-conversation* state like \"this user is on step 2 of\n * registration\" — is stored in SQLite, because nothing survives in memory\n * between one request and the next.\n *\n * SETUP (do this after pasting this code into a new Val Town HTTP val):\n * 1. In the val's \"Environment variables\" panel, add:\n * BOT_TOKEN = your Telegram bot token\n * ADMIN_ID = your numeric Telegram user id (e.g. 157828443)\n * 2. Deploy the val, copy its URL (looks like\n * https://yourname--xxxxx.web.val.run)\n * 3. Register the webhook by visiting this URL once in your browser\n * (replace TOKEN and VAL_URL):\n * https://api.telegram.org/botTOKEN/setWebhook?url=VAL_URL\n * You only need to do this once — Telegram remembers it.\n * 4. Message your bot on Telegram. It should respond.\n */\n\nimport sqlite from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BOT_TOKEN = \"8790399985:AAGPRuVkjl0BvoLZw9TifXtEKhxz-TgCi10\";\nconst ADMIN_ID = 157828443;\nconst API = `https://api.telegram.org/bot${BOT_TOKEN}`;\n\nif (!BOT_TOKEN) {\n console.error(\"BOT_TOKEN environment variable is not set on this val.\");\n}\n\n// ----------------- DB SETUP -----------------\nasync function ensureTables() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS interacted_users (\n user_id INTEGER PRIMARY KEY\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS registered_users (\n user_id INTEGER PRIMARY KEY,\n name TEXT,\n phone TEXT,\n school TEXT,\n grade TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS attendance (\n date TEXT,\n user_id INTEGER,\n status TEXT,\n PRIMARY KEY (date, user_id)\n )\n `);\n // Transient conversation state per user (registration step, help mode,\n // admin broadcast wait, admin attendance session). Replaces the\n // in-memory dicts from the Python version.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS conversation_state (\n user_id INTEGER PRIMARY KEY,\n kind TEXT,\n payload TEXT\n )\n `);\n}\nawait ensureTables();\n\n// ----------------- STATE HELPERS -----------------\nasync function getState(\n userId: number,\n): Promise<{ kind: string; payload: any } | null> {\n const res = await sqlite.execute(\n \"SELECT kind, payload FROM conversation_state WHERE user_id = ?\",\n [userId],\n );\n if (res.rows.length === 0) return null;\n const row = res.rows[0] as any;\n return {\n kind: row.kind as string,\n payload: JSON.parse(row.payload as string),\n };\n}\n\nasync function setState(userId: number, kind: string, payload: any) {\n await sqlite.execute(\n `INSERT INTO conversation_state (user_id, kind, payload) VALUES (?, ?, ?)\n ON CONFLICT(user_id) DO UPDATE SET kind = excluded.kind, payload = excluded.payload`,\n [userId, kind, JSON.stringify(payload)],\n );\n}\n\nasync function clearState(userId: number) {\n await sqlite.execute(\"DELETE FROM conversation_state WHERE user_id = ?\", [\n userId,\n ]);\n}\n\n// ----------------- DATA HELPERS -----------------\nasync function addInteracted(userId: number) {\n await sqlite.execute(\n \"INSERT OR IGNORE INTO interacted_users (user_id) VALUES (?)\",\n [userId],\n );\n}\n\nasync function allInteracted(): Promise {\n const res = await sqlite.execute(\"SELECT user_id FROM interacted_users\");\n return res.rows.map((r: any) => r.user_id as number);\n}\n\nasync function registerUser(\n userId: number,\n name: string,\n phone: string,\n school: string,\n grade: string,\n) {\n await sqlite.execute(\n `INSERT INTO registered_users (user_id, name, phone, school, grade)\n VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(user_id) DO UPDATE SET\n name = excluded.name, phone = excluded.phone,\n school = excluded.school, grade = excluded.grade`,\n [userId, name, phone, school, grade],\n );\n}\n\nasync function getUser(userId: number) {\n const res = await sqlite.execute(\n \"SELECT * FROM registered_users WHERE user_id = ?\",\n [userId],\n );\n return res.rows.length ? (res.rows[0] as any) : null;\n}\n\nasync function allRegistered(): Promise {\n const res = await sqlite.execute(\"SELECT * FROM registered_users\");\n return res.rows as any[];\n}\n\nasync function registeredCount(): Promise {\n const res = await sqlite.execute(\n \"SELECT COUNT(*) as n FROM registered_users\",\n );\n return (res.rows[0] as any).n as number;\n}\n\nasync function setAttendance(date: string, userId: number, status: string) {\n await sqlite.execute(\n `INSERT INTO attendance (date, user_id, status) VALUES (?, ?, ?)\n ON CONFLICT(date, user_id) DO UPDATE SET status = excluded.status`,\n [date, userId, status],\n );\n}\n\nasync function userAttendanceDates(userId: number): Promise {\n const res = await sqlite.execute(\n \"SELECT date FROM attendance WHERE user_id = ? AND status = 'Present' ORDER BY date\",\n [userId],\n );\n return res.rows.map((r: any) => r.date as string);\n}\n\n// ----------------- TELEGRAM API HELPERS -----------------\nasync function tg(method: string, body: Record) {\n const res = await fetch(`${API}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n if (!res.ok) {\n const errText = await res.text();\n console.error(`Telegram API error on ${method}:`, errText);\n }\n return res.json().catch(() => null);\n}\n\nasync function sendMessage(\n chatId: number,\n text: string,\n opts: Record = {},\n) {\n return tg(\"sendMessage\", { chat_id: chatId, text, ...opts });\n}\n\n/** Sends with Markdown, and retries as plain text if Telegram rejects the\n * entities (e.g. user-supplied text containing _ * ` [ ). Mirrors the\n * escape+fallback approach from the Python version. */\nasync function safeSendMarkdown(\n chatId: number,\n text: string,\n opts: Record = {},\n) {\n const res = await tg(\"sendMessage\", {\n chat_id: chatId,\n text,\n parse_mode: \"Markdown\",\n ...opts,\n });\n if (res && res.ok === false) {\n await tg(\"sendMessage\", { chat_id: chatId, text, ...opts });\n }\n}\n\nfunction escapeMarkdown(text: string | null | undefined): string {\n if (text == null) return \"\";\n return String(text).replace(/([_*`\\[])/g, \"\\\\$1\");\n}\n\nasync function answerCallbackQuery(\n id: string,\n text?: string,\n showAlert = false,\n) {\n return tg(\"answerCallbackQuery\", {\n callback_query_id: id,\n ...(text ? { text, show_alert: showAlert } : {}),\n });\n}\n\nasync function deleteMessage(chatId: number, messageId: number) {\n try {\n await tg(\"deleteMessage\", { chat_id: chatId, message_id: messageId });\n } catch {\n // best-effort, ignore failures\n }\n}\n\n// ----------------- KEYBOARDS -----------------\nconst MAIN_MENU_LABELS = [\n \"መሪ ይምረጡ 👤 ✨ »\",\n \"📖 የምንመረምረውን ክፍል ይምረጡ Choose Verse\",\n \"ጥያቄና አስተያየት 💬 Help\",\n \"ተመዝገብ/ቢ 📝 Register Now\",\n \"ℹ️ ስለ ቤርያ ተማሪዎች ፌሎውሺፕ (About Us)\",\n \"ቦታውን ለማግኘት 📍 Location\",\n \"👤 የእኔ ፕሮፋይል (My Profile)\",\n \"📋 የእኔ መገኘት (My Attendance)\",\n];\n\nfunction chunk(arr: T[], size: number): T[][] {\n const out: T[][] = [];\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\n return out;\n}\n\nfunction keyboardFromLabels(labels: string[], backLabel?: string) {\n const rows = chunk(\n labels.map((l) => ({ text: l })),\n 2,\n );\n if (backLabel) rows.push([{ text: backLabel }]);\n return { keyboard: rows, resize_keyboard: true };\n}\n\nconst MAIN_KEYBOARD = keyboardFromLabels(MAIN_MENU_LABELS);\nconst BACK_TO_MAIN = \"🔙 ዋና ገጽ (Main Menu)\";\nconst BACK_ONLY_KEYBOARD = {\n keyboard: [[{ text: BACK_TO_MAIN }]],\n resize_keyboard: true,\n};\n\nconst GRADE_KEYBOARD = keyboardFromLabels(\n [\n \"9ኛ ክፍል (Grade 9)\",\n \"10ኛ ክፍል (Grade 10)\",\n \"11ኛ ክፍል (Grade 11)\",\n \"12ኛ ክፍል (Grade 12)\",\n ],\n BACK_TO_MAIN,\n);\n\nconst TESTAMENT_KEYBOARD = keyboardFromLabels(\n [\"📜 ብሉይ ኪዳን (Old Testament)\", \"📖 አዲስ ኪዳን (New Testament)\"],\n BACK_TO_MAIN,\n);\n\nconst BACK_TO_TESTAMENT = \"🔙 ወደ ኪዳናት ምርጫ (Back)\";\n\nconst OLD_TESTAMENT_BOOKS = [\n \"📘 ኦሪት ዘፍጥረት\",\n \"📘 ኦሪት ዘጸአት\",\n \"📘 ኦሪት ዘሌዋውያን\",\n \"📘 ኦሪት ዘኍልቍ\",\n \"📘 ኦሪት ዘዳግም\",\n \"📗 ኢያሱ ወልደ ነዌ\",\n \"📗 መጽሐፈ መሳፍንት\",\n \"📗 መጽሐፈ ሩት\",\n \"📗 1 ሳሙኤል\",\n \"📗 2 ሳሙኤል\",\n \"📗 1 ንጉሥ\",\n \"📗 2 ንጉሥ\",\n \"📗 1 ዜና መዋዕል\",\n \"📗 2 ዜና መዋዕል\",\n \"📗 መጽሐፈ ኤዝራ\",\n \"📗 መጽሐፈ ነህምያ\",\n \"📗 መጽሐፈ አስቴር\",\n \"📙 መጽሐፈ ኢዮብ\",\n \"📙 መዝሙረ ዳዊት\",\n \"📙 መጽሐፈ ምሳሌ\",\n \"📙 መክብብ\",\n \"📙 መኃልየ መኃልይ ዘሰሎሞን\",\n \"📕 ትንቢተ ኢሳይያስ\",\n \"📕 ትንቢተ ኤርምያስ\",\n \"📕 ሰቆቃወ ኤርምያስ\",\n \"📕 ትንቢተ ሕዝቅኤል\",\n \"📕 ትንቢተ ዳንኤል\",\n \"📕 ትንቢተ ሆሴዕ\",\n \"📕 ትንቢተ ኢዩኤል\",\n \"📕 ትንቢተ አሞጽ\",\n \"📕 ትንቢተ አብድዩ\",\n \"📕 ትንቢተ ዮናስ\",\n \"📕 ትንቢተ ሚክያስ\",\n \"📕 ትንቢተ ናሆም\",\n \"📕 ትንቢተ ዕንባቆም\",\n \"📕 ትንቢተ ሶፎንያስ\",\n \"📕 ትንቢተ ሐጌ\",\n \"📕 ትንቢተ ዘካርያስ\",\n \"📕 ትንቢተ ሚልኪያስ\",\n];\n\nconst NEW_TESTAMENT_BOOKS = [\n \"📖 የማቴዎስ ወንጌል\",\n \"📖 የማርቆስ ወንጌል\",\n \"📖 የሉቃስ ወንጌል\",\n \"📖 የዮሐንስ ወንጌል\",\n \"📜 የሐዋርያት ሥራ\",\n \"✉️ ወደ ሮሜ ሰዎች\",\n \"✉️ 1 ቆሮንቶስ\",\n \"✉️ 2 ቆሮንቶስ\",\n \"✉️ ወደ ገላትያ ሰዎች\",\n \"✉️ ወደ ኤፌሶን ሰዎች\",\n \"✉️ ወደ ፊልጵስዩስ ሰዎች\",\n \"✉️ ወደ ቆላስይስ ሰዎች\",\n \"✉️ 1 ተሰሎንቄ\",\n \"✉️ 2 ተሰሎንቄ\",\n \"✉️ 1 ጢሞቴዎስ\",\n \"✉️ 2 ጢሞቴዎስ\",\n \"✉️ ወደ ቲቶ\",\n \"✉️ ወደ ፊልሞና\",\n \"✉️ ወደ ዕብራውያን\",\n \"✉️ የያዕቆብ መልእክት\",\n \"✉️ 1 ጴጥሮስ\",\n \"✉️ 2 ጴጥሮስ\",\n \"✉️ 1 ዮሐንስ\",\n \"✉️ 2 ዮሐንስ\",\n \"✉️ 3 ዮሐንስ\",\n \"✉️ የዩዳ መልእክት\",\n \"📖 የዮሐንስ ራእይ\",\n];\n\nconst BOOK_BUTTON_TEXTS = new Set([\n ...OLD_TESTAMENT_BOOKS,\n ...NEW_TESTAMENT_BOOKS,\n]);\n\nconst OLD_TESTAMENT_KEYBOARD = keyboardFromLabels(\n OLD_TESTAMENT_BOOKS,\n BACK_TO_TESTAMENT,\n);\nconst NEW_TESTAMENT_KEYBOARD = keyboardFromLabels(\n NEW_TESTAMENT_BOOKS,\n BACK_TO_TESTAMENT,\n);\n\nfunction adminPanelKeyboard() {\n return {\n inline_keyboard: [\n [{ text: \"📢 Broadcast Message\", callback_data: \"admin_broadcast\" }],\n [{ text: \"📊 User Stats\", callback_data: \"admin_stats\" }],\n [{\n text: \"📋 Start Attendance Table Session\",\n callback_data: \"admin_start_attendance\",\n }],\n ],\n };\n}\n\nfunction attendanceInlineKeyboard(index: number) {\n return {\n inline_keyboard: [\n [\n { text: \"✅ Present\", callback_data: `att_mark_Present_${index}` },\n { text: \"❌ Absent\", callback_data: `att_mark_Absent_${index}` },\n ],\n ],\n };\n}\n\n// ----------------- TEXT CONSTANTS -----------------\nconst WELCOME_TEXT =\n \"ሰላም! ወደ ቤርያ ተማሪዎች ፌሎውሺፕ (Berya Bot) በሰላም መጣህ/ሽ! 👋✨\\n\\n\" +\n \"ይህ ቦት ከፌሎውሽፓችን ጋር በቀላሉ እንድትገናኝ/ኚ እና መረጃዎችን እንድታገኝ/ኚ የተሰራ ነው።\\n\\n\" +\n \"ለመጀመር እነዚህን አማራጮች ተጠቀም/ሚ፦\";\n\nconst ABOUT_TEXT =\n \"ቤርያ (Berya) ተማሪዎች በእውነትና በሕይወት መንገድ ላይ እንዲመላለሱ የተቋቋመ ልዩ መንፈሳዊ የህብረት መድረክ ነው! 🌟📖\";\n\nconst LOCATION_TEXT = \"📍 አድራሻ፦ የተቀባ የእግዚአብሔር ቃል ቸርች\\n\" +\n \"https://maps.app.goo.gl/1kzzWwx7NevsGCkz7\";\n\n// ----------------- MESSAGE HANDLING -----------------\nasync function handleMessage(message: any) {\n const userId = message.from.id as number;\n const chatId = message.chat.id as number;\n const text = (message.text ?? \"\") as string;\n\n await addInteracted(userId);\n\n if (text === \"/start\") {\n await sendMessage(chatId, WELCOME_TEXT, { reply_markup: MAIN_KEYBOARD });\n return;\n }\n\n if (text === BACK_TO_MAIN) {\n await clearState(userId);\n await sendMessage(chatId, \"ወደ ዋናው ገጽ ተመልሰዋል 👇\", {\n reply_markup: MAIN_KEYBOARD,\n });\n return;\n }\n\n const state = await getState(userId);\n\n // ---- Admin broadcast capture ----\n if (userId === ADMIN_ID && state?.kind === \"admin_broadcast_waiting\") {\n await clearState(userId);\n const recipients = await allInteracted();\n let sent = 0;\n let failed = 0;\n for (const uid of recipients) {\n const res = await tg(\"sendMessage\", { chat_id: uid, text });\n if (res && res.ok === false) failed++;\n else sent++;\n }\n await sendMessage(\n chatId,\n `📢 Broadcast complete. Sent: ${sent}, Failed: ${failed}, Total recipients: ${recipients.length}`,\n );\n return;\n }\n\n // ---- Help/feedback capture ----\n if (state?.kind === \"help_waiting\") {\n await clearState(userId);\n const forwardText = `📩 *አዲስ ጥያቄ ወይም አስተያየት ደርሷል!*\\n\\n` +\n `👤 ከ: ${escapeMarkdown(message.from.first_name)} (ID: \\`${userId}\\`)\\n` +\n `💬 መልእክት: ${escapeMarkdown(text)}`;\n await safeSendMarkdown(ADMIN_ID, forwardText);\n\n const confirmationText = \"መልእክትህ/ሽ በሰላም ደርሷል! 🙏✨\\n\\n\" +\n \"ሃሳብህን/ሽ ከእኛ ጋር ለማጋራት ስለመረጥክ/ሽ እናመሰግናለን። የላከው/ሽው ጥያቄ ወይም አስተያየት ለፌሎ ተማሪዎች ፌሎውሺፕ አደራጆች ወዲያውኑ ደርሷል።\\n\\n\" +\n \"ቀጣይ ምን ይሆናል?\\n\" +\n \"አደራጆቻችን መልእክትህን/ሽ በጥንቃቄ ይመለከታሉ:: ጥያቄ ካለህ/ሽ በዚህ በኩል በቅርብ ጊዜ ምላሽ እንሰጣለን/ለን::\\n\" +\n \"በጌታ ፍቅር እንወድሃለን/ሽ! 💖😊\";\n await sendMessage(chatId, confirmationText, {\n reply_markup: MAIN_KEYBOARD,\n });\n return;\n }\n\n // ---- Registration flow ----\n if (state?.kind === \"registration\") {\n const data = state.payload as {\n step: number;\n name?: string;\n phone?: string;\n school?: string;\n };\n\n if (data.step === 1) {\n data.name = text;\n data.step = 2;\n await setState(userId, \"registration\", data);\n await sendMessage(\n chatId,\n \"በጣም ደስ ይላል! ⭐ በመቀጠል ደግሞ የምንገኝበትን/ችሁትን ትክክለኛ ስልክ ቁጥርህን/ሽ እዚህ አግኝ/ሉ:: 📱 📞\",\n { reply_markup: BACK_ONLY_KEYBOARD },\n );\n return;\n } else if (data.step === 2) {\n data.phone = text;\n data.step = 3;\n await setState(userId, \"registration\", data);\n await sendMessage(\n chatId,\n \"ሳባ! 💪 በመቀጠል የምትማርበትን/ችሁትን የትምህርት ቤት ስም ንገርን/ንገሪን:: 🏫 🎓\",\n { reply_markup: BACK_ONLY_KEYBOARD },\n );\n return;\n } else if (data.step === 3) {\n data.school = text;\n data.step = 4;\n await setState(userId, \"registration\", data);\n await sendMessage(\n chatId,\n \"እባክዎ ከዚህ በታች ካሉት አማራጮች የክፍል ደረጃዎን (Grade) ይምረጡ፦ 📚\",\n { reply_markup: GRADE_KEYBOARD },\n );\n return;\n } else if (data.step === 4) {\n const grade = text;\n await registerUser(userId, data.name!, data.phone!, data.school!, grade);\n await clearState(userId);\n\n const successMsg = \"✅ ምዝገባህ/ሽ በተሳካ ሁኔታ ተጠናቅቋል! 🙌✨\\n\" +\n \"የቤርያ ተማሪዎች ፌሎውሽፕ ቤተሰብ አካል በመሆንህ/ሽ በጣም ደስ ብሎናል!\\n\\n\" +\n \"🗓 ቀን፦ ሁልጊዜ አርብ | ⏰ ሰዓት፦ ከ 9:30 እስከ 11:00 ሰዓት 🌙\\n\" +\n \"📍 ቦታ፦ የተቀባ የእግዛብሄር ቃል ቸርች (ከዳንዲ ቦሩ ጀርባ)\";\n await sendMessage(chatId, successMsg, { reply_markup: MAIN_KEYBOARD });\n\n const adminNotify = `📝 *አዲስ የተመዘገበ ተማሪ!*\\n👤 ስም: ${\n escapeMarkdown(\n data.name,\n )\n }\\n🆔 ID: \\`${userId}\\``;\n await safeSendMarkdown(ADMIN_ID, adminNotify);\n return;\n }\n }\n\n // ---- Menu routing ----\n if (text.includes(\"መሪ ይምረጡ\")) {\n await sendMessage(chatId, \"የዚህ ዓመት መሪ ምርጫ በቅርብ ይጀምራል! 👑\", {\n reply_markup: BACK_ONLY_KEYBOARD,\n });\n } else if (\n text.includes(\"የምንመረምረውን ክፍል ይምረጡ\") || text.includes(\"Choose Verse\")\n ) {\n await sendMessage(chatId, \"📖 እባክዎ ከዚህ በታች ካሉት የኪዳን ዓይነቶች አንዱን ይምረጡ፦\", {\n reply_markup: TESTAMENT_KEYBOARD,\n });\n } else if (text === \"📜 ብሉይ ኪዳን (Old Testament)\") {\n await sendMessage(chatId, \"📜 የብሉይ ኪዳን መጻሕፍት ዝርዝር፦\", {\n reply_markup: OLD_TESTAMENT_KEYBOARD,\n });\n } else if (text === \"📖 አዲስ ኪዳን (New Testament)\") {\n await sendMessage(chatId, \"📖 የአዲስ ኪዳን መጻሕፍት ዝርዝር፦\", {\n reply_markup: NEW_TESTAMENT_KEYBOARD,\n });\n } else if (text === BACK_TO_TESTAMENT) {\n await sendMessage(chatId, \"📖 እባክዎ ከዚህ በታች ካሉት የኪዳን ዓይነቶች አንዱን ይምረጡ፦\", {\n reply_markup: TESTAMENT_KEYBOARD,\n });\n } else if (BOOK_BUTTON_TEXTS.has(text)) {\n await safeSendMarkdown(\n chatId,\n `መረጡት መጽሐፍ: *${\n escapeMarkdown(text)\n }*\\n\\nየዚህን መጽሐፍ ክፍሎች ወይም ጥቅሶች በቅርቡ እናጭራለን።`,\n { reply_markup: BACK_ONLY_KEYBOARD },\n );\n } else if (text.includes(\"ጥያቄና አስተያየት\") || text.includes(\"Help\")) {\n await setState(userId, \"help_waiting\", {});\n await sendMessage(chatId, \"ሰላም! ሃሳብዎን ወይም ጥያቄዎን በዝርዝር ከታች ይጻፉ! 😊\", {\n reply_markup: BACK_ONLY_KEYBOARD,\n });\n } else if (text.includes(\"ተመዝገብ/ቢ\") || text.includes(\"Register Now\")) {\n await setState(userId, \"registration\", { step: 1 });\n await sendMessage(chatId, \"እባክዎ ሙሉ ስምዎን እዚህ ይጻፉ። ✨ ✍️\", {\n reply_markup: BACK_ONLY_KEYBOARD,\n });\n } else if (text.includes(\"የእኔ ፕሮፋይል\") || text.includes(\"My Profile\")) {\n const profile = await getUser(userId);\n if (profile) {\n const profileText = \"👤 *የእርስዎ ፕሮፋይል መረጃ (Your Profile)*:\\n\\n\" +\n `📌 ሙሉ ስም: ${escapeMarkdown(profile.name)}\\n` +\n `📞 ስልክ ቁጥር: ${escapeMarkdown(profile.phone)}\\n` +\n `🏫 ትምህርት ቤት: ${escapeMarkdown(profile.school)}\\n` +\n `📚 የክፍል ደረጃ: ${escapeMarkdown(profile.grade)}\\n`;\n await safeSendMarkdown(chatId, profileText, {\n reply_markup: MAIN_KEYBOARD,\n });\n } else {\n await sendMessage(\n chatId,\n \"እስካሁን አልተመዘገቡም! እባክዎ በመጀመሪያ 'ተመዝገብ/ቢ' የሚለውን ይጫኑ። 📝\",\n {\n reply_markup: MAIN_KEYBOARD,\n },\n );\n }\n } else if (text.includes(\"የእኔ መገኘት\") || text.includes(\"My Attendance\")) {\n const dates = await userAttendanceDates(userId);\n if (dates.length) {\n const datesStr = dates.map((d) => `• 📅 ${d}`).join(\"\\n\");\n await sendMessage(\n chatId,\n `📋 *የእርስዎ የመገኘት ታሪክ*:\\n\\nበጠቅላላ የተገኙባቸው ቀናት (${dates.length}):\\n${datesStr}`,\n { parse_mode: \"Markdown\", reply_markup: MAIN_KEYBOARD },\n );\n } else {\n await sendMessage(chatId, \"📋 እስካሁን የተመዘገበ የመገኘት ታሪክ የለዎትም።\", {\n reply_markup: MAIN_KEYBOARD,\n });\n }\n } else if (text.includes(\"ስለ ቤርያ\") || text.includes(\"About Us\")) {\n await sendMessage(chatId, ABOUT_TEXT, { reply_markup: MAIN_KEYBOARD });\n } else if (text.includes(\"ቦታውን ለማግኘት\") || text.includes(\"Location\")) {\n await sendMessage(chatId, LOCATION_TEXT, {\n reply_markup: MAIN_KEYBOARD,\n disable_web_page_preview: true,\n });\n } else if (text === \"/admin\" && userId === ADMIN_ID) {\n await sendMessage(\n chatId,\n \"🛠 *Admin Panel*\\nWelcome back, Admin. Choose an action:\",\n {\n parse_mode: \"Markdown\",\n reply_markup: adminPanelKeyboard(),\n },\n );\n } else {\n await sendMessage(chatId, \"እባክዎ ከታች ያሉትን አማራጮች ይጠቀሙ 👇\", {\n reply_markup: MAIN_KEYBOARD,\n });\n }\n}\n\n// ----------------- ATTENDANCE SESSION FLOW -----------------\ntype AttendanceSession = {\n date: string;\n userIds: number[];\n index: number;\n attendance: Record;\n};\n\nasync function sendAttendanceRow(chatId: number, adminId: number) {\n const state = await getState(adminId);\n if (!state || state.kind !== \"attendance_session\") return;\n const session = state.payload as AttendanceSession;\n\n if (session.index >= session.userIds.length) {\n // Finished — persist attendance and show summary\n const lines: string[] = [\n `📋 *Attendance Summary Table for ${session.date}*:\\n`,\n ];\n lines.push(\"```\");\n lines.push(\n `${\"No\".padEnd(3)} | ${\"Student Name\".padEnd(18)} | ${\n \"Status\".padEnd(7)\n }`,\n );\n lines.push(\"-\".repeat(34));\n\n let idx = 1;\n for (const uid of session.userIds) {\n const status = session.attendance[uid] ?? \"Absent\";\n await setAttendance(session.date, uid, status);\n const user = await getUser(uid);\n const name = (user ? (user.name as string) : String(uid)).slice(0, 16);\n lines.push(\n `${String(idx).padEnd(3)} | ${name.padEnd(18)} | ${status.padEnd(7)}`,\n );\n idx++;\n }\n lines.push(\"```\");\n await sendMessage(chatId, lines.join(\"\\n\"), { parse_mode: \"Markdown\" });\n await clearState(adminId);\n return;\n }\n\n const currentUid = session.userIds[session.index];\n const user = await getUser(currentUid);\n const text = `📋 *Taking Attendance (Table Mode)*\\n` +\n `📅 Date: ${session.date}\\n` +\n `👤 Student ${session.index + 1} of ${session.userIds.length}\\n\\n` +\n `📌 *Name*: ${escapeMarkdown(user.name)}\\n` +\n `🏫 *School*: ${escapeMarkdown(user.school)}\\n` +\n `📚 *Grade*: ${escapeMarkdown(user.grade)}\\n\\n` +\n `Choose status for this student:`;\n await safeSendMarkdown(chatId, text, {\n reply_markup: attendanceInlineKeyboard(session.index),\n });\n}\n\n// ----------------- CALLBACK QUERY HANDLING -----------------\nasync function handleCallbackQuery(callback: any) {\n const userId = callback.from.id as number;\n const chatId = callback.message.chat.id as number;\n const data = callback.data as string;\n\n if (userId !== ADMIN_ID) {\n await answerCallbackQuery(callback.id, \"Unauthorized!\", true);\n return;\n }\n\n if (data === \"admin_stats\") {\n await answerCallbackQuery(callback.id);\n const registered = await registeredCount();\n const interacted = (await allInteracted()).length;\n await sendMessage(\n chatId,\n `📊 Total registered users: ${registered}\\n📊 Total interacted users: ${interacted}`,\n );\n return;\n }\n\n if (data === \"admin_broadcast\") {\n await answerCallbackQuery(callback.id);\n await setState(userId, \"admin_broadcast_waiting\", {});\n await sendMessage(\n chatId,\n \"📢 Send the message you want to broadcast to all members.\",\n );\n return;\n }\n\n if (data === \"admin_start_attendance\") {\n await answerCallbackQuery(callback.id);\n const registered = await allRegistered();\n if (!registered.length) {\n await sendMessage(\n chatId,\n \"⚠️ No registered users found to take attendance.\",\n );\n return;\n }\n const todayStr = new Date().toISOString().slice(0, 10);\n const session: AttendanceSession = {\n date: todayStr,\n userIds: registered.map((u) => u.user_id as number),\n index: 0,\n attendance: {},\n };\n await setState(userId, \"attendance_session\", session);\n await sendMessage(\n chatId,\n `🚀 Starting interactive attendance session for *${todayStr}* across ${session.userIds.length} registered students.`,\n { parse_mode: \"Markdown\" },\n );\n await sendAttendanceRow(chatId, userId);\n return;\n }\n\n if (data.startsWith(\"att_mark_\")) {\n await answerCallbackQuery(callback.id);\n const parts = data.split(\"_\");\n const status = parts[2];\n const index = Number(parts[3]);\n\n const state = await getState(userId);\n if (!state || state.kind !== \"attendance_session\") {\n await sendMessage(chatId, \"Session expired or reset.\");\n return;\n }\n const session = state.payload as AttendanceSession;\n const currentUid = session.userIds[index];\n session.attendance[currentUid] = status;\n session.index = index + 1;\n await setState(userId, \"attendance_session\", session);\n\n await deleteMessage(chatId, callback.message.message_id);\n await sendAttendanceRow(chatId, userId);\n return;\n }\n}\n\n// ----------------- HTTP HANDLER (Val Town entrypoint) -----------------\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"Berya Bot webhook endpoint is running.\", {\n status: 200,\n });\n }\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n let update: any;\n try {\n update = await req.json();\n } catch {\n return new Response(\"Bad Request\", { status: 400 });\n }\n\n try {\n if (update.message) {\n await handleMessage(update.message);\n } else if (update.callback_query) {\n await handleCallbackQuery(update.callback_query);\n }\n } catch (err) {\n console.error(\"Error handling update:\", err);\n }\n\n return new Response(\"OK\", { status: 200 });\n}","/**\n * Berya Students Fellowship Telegram Bot — Val Town HTTP val\n *\n * Architecture note: Val Town runs each HTTP request in a fresh, stateless\n * invocation — there is no long-lived process like Python's infinity_polling().\n * Telegram is configured to POST each update straight to this val's URL\n * (a \"webhook\"), and every piece of state — registered users, attendance,\n * and even *mid-conversation* state like \"this user is on step 2 of\n * registration\" — is stored in SQLite, because nothing survives in memory\n * between one request and the next.\n *\n * SETUP (do this after pasting this code into a new Val Town HTTP val):\n * 1. In the val's \"Environment variables\" panel, add:\n * BOT_TOKEN = your Telegram bot token\n * ADMIN_ID = your numeric Telegram user id (e.g. 157828443)\n * 2. Deploy the val, copy its URL (looks like\n * https://yourname--xxxxx.web.val.run)\n * 3. Register the webhook by visiting this URL once in your browser\n * (replace TOKEN and VAL_URL):\n * https://api.telegram.org/botTOKEN/setWebhook?url=VAL_URL\n * You only need to do this once — Telegram remembers it.\n * 4. Message your bot on Telegram. It should respond.\n */\n\nimport sqlite from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BOT_TOKEN = Deno.env.get(\"BOT_TOKEN\");\nconst ADMIN_ID = Number(Deno.env.get(\"ADMIN_ID\"));\nconst API = `https://api.telegram.org/bot${BOT_TOKEN}`;\n\nif (!BOT_TOKEN) {\n console.error(\"BOT_TOKEN environment variable is not set on this val.\");\n}\n\n// ----------------- DB SETUP -----------------\nasync function ensureTables() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS interacted_users (\n user_id INTEGER PRIMARY KEY\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS registered_users (\n user_id INTEGER PRIMARY KEY,\n name TEXT,\n phone TEXT,\n school TEXT,\n grade TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS attendance (\n date TEXT,\n user_id INTEGER,\n status TEXT,\n PRIMARY KEY (date, user_id)\n )\n `);\n // Transient conversation state per user (registration step, help mode,\n // admin broadcast wait, admin attendance session). Replaces the\n // in-memory dicts from the Python version.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS conversation_state (\n user_id INTEGER PRIMARY KEY,\n kind TEXT,\n payload TEXT\n )\n `);\n}\nawait ensureTables();\n\n// ----------------- STATE HELPERS -----------------\nasync function getState(\n userId: number,\n): Promise<{ kind: string; payload: any } | null> {\n const res = await sqlite.execute(\n \"SELECT kind, payload FROM conversation_state WHERE user_id = ?\",\n [userId],\n );\n if (res.rows.length === 0) return null;\n const row = res.rows[0] as any;\n return {\n kind: row.kind as string,\n payload: JSON.parse(row.payload as string),\n };\n}\n\nasync function setState(userId: number, kind: string, payload: any) {\n await sqlite.execute(\n `INSERT INTO conversation_state (user_id, kind, payload) VALUES (?, ?, ?)\n ON CONFLICT(user_id) DO UPDATE SET kind = excluded.kind, payload = excluded.payload`,\n [userId, kind, JSON.stringify(payload)],\n );\n}\n\nasync function clearState(userId: number) {\n await sqlite.execute(\"DELETE FROM conversation_state WHERE user_id = ?\", [\n userId,\n ]);\n}\n\n// ----------------- DATA HELPERS -----------------\nasync function addInteracted(userId: number) {\n await sqlite.execute(\n \"INSERT OR IGNORE INTO interacted_users (user_id) VALUES (?)\",\n [userId],\n );\n}\n\nasync function allInteracted(): Promise {\n const res = await sqlite.execute(\"SELECT user_id FROM interacted_users\");\n return res.rows.map((r: any) => r.user_id as number);\n}\n\nasync function registerUser(\n userId: number,\n name: string,\n phone: string,\n school: string,\n grade: string,\n) {\n await sqlite.execute(\n `INSERT INTO registered_users (user_id, name, phone, school, grade)\n VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(user_id) DO UPDATE SET\n name = excluded.name, phone = excluded.phone,\n school = excluded.school, grade = excluded.grade`,\n [userId, name, phone, school, grade],\n );\n}\n\nasync function getUser(userId: number) {\n const res = await sqlite.execute(\n \"SELECT * FROM registered_users WHERE user_id = ?\",\n [userId],\n );\n return res.rows.length ? (res.rows[0] as any) : null;\n}\n\nasync function allRegistered(): Promise {\n const res = await sqlite.execute(\"SELECT * FROM registered_users\");\n return res.rows as any[];\n}\n\nasync function registeredCount(): Promise {\n const res = await sqlite.execute(\n \"SELECT COUNT(*) as n FROM registered_users\",\n );\n return (res.rows[0] as any).n as number;\n}\n\nasync function setAttendance(date: string, userId: number, status: string) {\n await sqlite.execute(\n `INSERT INTO attendance (date, user_id, status) VALUES (?, ?, ?)\n ON CONFLICT(date, user_id) DO UPDATE SET status = excluded.status`,\n [date, userId, status],\n );\n}\n\nasync function userAttendanceDates(userId: number): Promise {\n const res = await sqlite.execute(\n \"SELECT date FROM attendance WHERE user_id = ? AND status = 'Present' ORDER BY date\",\n [userId],\n );\n return res.rows.map((r: any) => r.date as string);\n}\n\n// ----------------- TELEGRAM API HELPERS -----------------\nasync function tg(method: string, body: Record) {\n const res = await fetch(`${API}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n if (!res.ok) {\n const errText = await res.text();\n console.error(`Telegram API error on ${method}:`, errText);\n }\n return res.json().catch(() => null);\n}\n\nasync function sendMessage(\n chatId: number,\n text: string,\n opts: Record = {},\n) {\n return tg(\"sendMessage\", { chat_id: chatId, text, ...opts });\n}\n\n/** Sends with Markdown, and retries as plain text if Telegram rejects the\n * entities (e.g. user-supplied text containing _ * ` [ ). Mirrors the\n * escape+fallback approach from the Python version. */\nasync function safeSendMarkdown(\n chatId: number,\n text: string,\n opts: Record = {},\n) {\n const res = await tg(\"sendMessage\", {\n chat_id: chatId,\n text,\n parse_mode: \"Markdown\",\n ...opts,\n });\n if (res && res.ok === false) {\n await tg(\"sendMessage\", { chat_id: chatId, text, ...opts });\n }\n}\n\nfunction escapeMarkdown(text: string | null | undefined): string {\n if (text == null) return \"\";\n return String(text).replace(/([_*`\\[])/g, \"\\\\$1\");\n}\n\nasync function answerCallbackQuery(\n id: string,\n text?: string,\n showAlert = false,\n) {\n return tg(\"answerCallbackQuery\", {\n callback_query_id: id,\n ...(text ? { text, show_alert: showAlert } : {}),\n });\n}\n\nasync function deleteMessage(chatId: number, messageId: number) {\n try {\n await tg(\"deleteMessage\", { chat_id: chatId, message_id: messageId });\n } catch {\n // best-effort, ignore failures\n }\n}\n\n// ----------------- KEYBOARDS -----------------\nconst MAIN_MENU_LABELS = [\n \"መሪ ይምረጡ 👤 ✨ »\",\n \"📖 የምንመረምረውን ክፍል ይምረጡ Choose Verse\",\n \"ጥያቄና አስተያየት 💬 Help\",\n \"ተመዝገብ/ቢ 📝 Register Now\",\n \"ℹ️ ስለ ቤርያ ተማሪዎች ፌሎውሺፕ (About Us)\",\n \"ቦታውን ለማግኘት 📍 Location\",\n \"👤 የእኔ ፕሮፋይል (My Profile)\",\n \"📋 የእኔ መገኘት (My Attendance)\",\n];\n\nfunction chunk(arr: T[], size: number): T[][] {\n const out: T[][] = [];\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\n return out;\n}\n\nfunction keyboardFromLabels(labels: string[], backLabel?: string) {\n const rows = chunk(\n labels.map((l) => ({ text: l })),\n 2,\n );\n if (backLabel) rows.push([{ text: backLabel }]);\n return { keyboard: rows, resize_keyboard: true };\n}\n\nconst MAIN_KEYBOARD = keyboardFromLabels(MAIN_MENU_LABELS);\nconst BACK_TO_MAIN = \"🔙 ዋና ገጽ (Main Menu)\";\nconst BACK_ONLY_KEYBOARD = {\n keyboard: [[{ text: BACK_TO_MAIN }]],\n resize_keyboard: true,\n};\n\nconst GRADE_KEYBOARD = keyboardFromLabels(\n [\n \"9ኛ ክፍል (Grade 9)\",\n \"10ኛ ክፍል (Grade 10)\",\n \"11ኛ ክፍል (Grade 11)\",\n \"12ኛ ክፍል (Grade 12)\",\n ],\n BACK_TO_MAIN,\n);\n\nconst TESTAMENT_KEYBOARD = keyboardFromLabels(\n [\"📜 ብሉይ ኪዳን (Old Testament)\", \"📖 አዲስ ኪዳን (New Testament)\"],\n BACK_TO_MAIN,\n);\n\nconst BACK_TO_TESTAMENT = \"🔙 ወደ ኪዳናት ምርጫ (Back)\";\n\nconst OLD_TESTAMENT_BOOKS = [\n \"📘 ኦሪት ዘፍጥረት\",\n \"📘 ኦሪት ዘጸአት\",\n \"📘 ኦሪት ዘሌዋውያን\",\n \"📘 ኦሪት ዘኍልቍ\",\n \"📘 ኦሪት ዘዳግም\",\n \"📗 ኢያሱ ወልደ ነዌ\",\n \"📗 መጽሐፈ መሳፍንት\",\n \"📗 መጽሐፈ ሩት\",\n \"📗 1 ሳሙኤል\",\n \"📗 2 ሳሙኤል\",\n \"📗 1 ንጉሥ\",\n \"📗 2 ንጉሥ\",\n \"📗 1 ዜና መዋዕል\",\n \"📗 2 ዜና መዋዕል\",\n \"📗 መጽሐፈ ኤዝራ\",\n \"📗 መጽሐፈ ነህምያ\",\n \"📗 መጽሐፈ አስቴር\",\n \"📙 መጽሐፈ ኢዮብ\",\n \"📙 መዝሙረ ዳዊት\",\n \"📙 መጽሐፈ ምሳሌ\",\n \"📙 መክብብ\",\n \"📙 መኃልየ መኃልይ ዘሰሎሞን\",\n \"📕 ትንቢተ ኢሳይያስ\",\n \"📕 ትንቢተ ኤርምያስ\",\n \"📕 ሰቆቃወ ኤርምያስ\",\n \"📕 ትንቢተ ሕዝቅኤል\",\n \"📕 ትንቢተ ዳንኤል\",\n \"📕 ትንቢተ ሆሴዕ\",\n \"📕 ትንቢተ ኢዩኤል\",\n \"📕 ትንቢተ አሞጽ\",\n \"📕 ትንቢተ አብድዩ\",\n \"📕 ትንቢተ ዮናስ\",\n \"📕 ትንቢተ ሚክያስ\",\n \"📕 ትንቢተ ናሆም\",\n \"📕 ትንቢተ ዕንባቆም\",\n \"📕 ትንቢተ ሶፎንያስ\",\n \"📕 ትንቢተ ሐጌ\",\n \"📕 ትንቢተ ዘካርያስ\",\n \"📕 ትንቢተ ሚልኪያስ\",\n];\n\nconst NEW_TESTAMENT_BOOKS = [\n \"📖 የማቴዎስ ወንጌል\",\n \"📖 የማርቆስ ወንጌል\",\n \"📖 የሉቃስ ወንጌል\",\n \"📖 የዮሐንስ ወንጌል\",\n \"📜 የሐዋርያት ሥራ\",\n \"✉️ ወደ ሮሜ ሰዎች\",\n \"✉️ 1 ቆሮንቶስ\",\n \"✉️ 2 ቆሮንቶስ\",\n \"✉️ ወደ ገላትያ ሰዎች\",\n \"✉️ ወደ ኤፌሶን ሰዎች\",\n \"✉️ ወደ ፊልጵስዩስ ሰዎች\",\n \"✉️ ወደ ቆላስይስ ሰዎች\",\n \"✉️ 1 ተሰሎንቄ\",\n \"✉️ 2 ተሰሎንቄ\",\n \"✉️ 1 ጢሞቴዎስ\",\n \"✉️ 2 ጢሞቴዎስ\",\n \"✉️ ወደ ቲቶ\",\n \"✉️ ወደ ፊልሞና\",\n \"✉️ ወደ ዕብራውያን\",\n \"✉️ የያዕቆብ መልእክት\",\n \"✉️ 1 ጴጥሮስ\",\n \"✉️ 2 ጴጥሮስ\",\n \"✉️ 1 ዮሐንስ\",\n \"✉️ 2 ዮሐንስ\",\n \"✉️ 3 ዮሐንስ\",\n \"✉️ የዩዳ መልእክት\",\n \"📖 የዮሐንስ ራእይ\",\n];\n\nconst BOOK_BUTTON_TEXTS = new Set([\n ...OLD_TESTAMENT_BOOKS,\n ...NEW_TESTAMENT_BOOKS,\n]);\n\nconst OLD_TESTAMENT_KEYBOARD = keyboardFromLabels(\n OLD_TESTAMENT_BOOKS,\n BACK_TO_TESTAMENT,\n);\nconst NEW_TESTAMENT_KEYBOARD = keyboardFromLabels(\n NEW_TESTAMENT_BOOKS,\n BACK_TO_TESTAMENT,\n);\n\nfunction adminPanelKeyboard() {\n return {\n inline_keyboard: [\n [{ text: \"📢 Broadcast Message\", callback_data: \"admin_broadcast\" }],\n [{ text: \"📊 User Stats\", callback_data: \"admin_stats\" }],\n [{\n text: \"📋 Start Attendance Table Session\",\n callback_data: \"admin_start_attendance\",\n }],\n ],\n };\n}\n\nfunction attendanceInlineKeyboard(index: number) {\n return {\n inline_keyboard: [\n [\n { text: \"✅ Present\", callback_data: `att_mark_Present_${index}` },\n { text: \"❌ Absent\", callback_data: `att_mark_Absent_${index}` },\n ],\n ],\n };\n}\n\n// ----------------- TEXT CONSTANTS -----------------\nconst WELCOME_TEXT =\n \"ሰላም! ወደ ቤርያ ተማሪዎች ፌሎውሺፕ (Berya Bot) በሰላም መጣህ/ሽ! 👋✨\\n\\n\" +\n \"ይህ ቦት ከፌሎውሽፓችን ጋር በቀላሉ እንድትገናኝ/ኚ እና መረጃዎችን እንድታገኝ/ኚ የተሰራ ነው።\\n\\n\" +\n \"ለመጀመር እነዚህን አማራጮች ተጠቀም/ሚ፦\";\n\nconst ABOUT_TEXT =\n \"ቤርያ (Berya) ተማሪዎች በእውነትና በሕይወት መንገድ ላይ እንዲመላለሱ የተቋቋመ ልዩ መንፈሳዊ የህብረት መድረክ ነው! 🌟📖\";\n\nconst LOCATION_TEXT = \"📍 አድራሻ፦ የተቀባ የእግዚአብሔር ቃል ቸርች\\n\" +\n \"https://maps.app.goo.gl/1kzzWwx7NevsGCkz7\";\n\n// ----------------- MESSAGE HANDLING -----------------\nasync function handleMessage(message: any) {\n const userId = message.from.id as number;\n const chatId = message.chat.id as number;\n const text = (message.text ?? \"\") as string;\n\n await addInteracted(userId);\n\n if (text === \"/start\") {\n await sendMessage(chatId, WELCOME_TEXT, { reply_markup: MAIN_KEYBOARD });\n return;\n }\n\n if (text === BACK_TO_MAIN) {\n await clearState(userId);\n await sendMessage(chatId, \"ወደ ዋናው ገጽ ተመልሰዋል 👇\", {\n reply_markup: MAIN_KEYBOARD,\n });\n return;\n }\n\n const state = await getState(userId);\n\n // ---- Admin broadcast capture ----\n if (userId === ADMIN_ID && state?.kind === \"admin_broadcast_waiting\") {\n await clearState(userId);\n const recipients = await allInteracted();\n let sent = 0;\n let failed = 0;\n for (const uid of recipients) {\n const res = await tg(\"sendMessage\", { chat_id: uid, text });\n if (res && res.ok === false) failed++;\n else sent++;\n }\n await sendMessage(\n chatId,\n `📢 Broadcast complete. Sent: ${sent}, Failed: ${failed}, Total recipients: ${recipients.length}`,\n );\n return;\n }\n\n // ---- Help/feedback capture ----\n if (state?.kind === \"help_waiting\") {\n await clearState(userId);\n const forwardText = `📩 *አዲስ ጥያቄ ወይም አስተያየት ደርሷል!*\\n\\n` +\n `👤 ከ: ${escapeMarkdown(message.from.first_name)} (ID: \\`${userId}\\`)\\n` +\n `💬 መልእክት: ${escapeMarkdown(text)}`;\n await safeSendMarkdown(ADMIN_ID, forwardText);\n\n const confirmationText = \"መልእክትህ/ሽ በሰላም ደርሷል! 🙏✨\\n\\n\" +\n \"ሃሳብህን/ሽ ከእኛ ጋር ለማጋራት ስለመረጥክ/ሽ እናመሰግናለን። የላከው/ሽው ጥያቄ ወይም አስተያየት ለፌሎ ተማሪዎች ፌሎውሺፕ አደራጆች ወዲያውኑ ደርሷል።\\n\\n\" +\n \"ቀጣይ ምን ይሆናል?\\n\" +\n \"አደራጆቻችን መልእክትህን/ሽ በጥንቃቄ ይመለከታሉ:: ጥያቄ ካለህ/ሽ በዚህ በኩል በቅርብ ጊዜ ምላሽ እንሰጣለን/ለን::\\n\" +\n \"በጌታ ፍቅር እንወድሃለን/ሽ! 💖😊\";\n await sendMessage(chatId, confirmationText, {\n reply_markup: MAIN_KEYBOARD,\n });\n return;\n }\n\n // ---- Registration flow ----\n if (state?.kind === \"registration\") {\n const data = state.payload as {\n step: number;\n name?: string;\n phone?: string;\n school?: string;\n };\n\n if (data.step === 1) {\n data.name = text;\n data.step = 2;\n await setState(userId, \"registration\", data);\n await sendMessage(\n chatId,\n \"በጣም ደስ ይላል! ⭐ በመቀጠል ደግሞ የምንገኝበትን/ችሁትን ትክክለኛ ስልክ ቁጥርህን/ሽ እዚህ አግኝ/ሉ:: 📱 📞\",\n { reply_markup: BACK_ONLY_KEYBOARD },\n );\n return;\n } else if (data.step === 2) {\n data.phone = text;\n data.step = 3;\n await setState(userId, \"registration\", data);\n await sendMessage(\n chatId,\n \"ሳባ! 💪 በመቀጠል የምትማርበትን/ችሁትን የትምህርት ቤት ስም ንገርን/ንገሪን:: 🏫 🎓\",\n { reply_markup: BACK_ONLY_KEYBOARD },\n );\n return;\n } else if (data.step === 3) {\n data.school = text;\n data.step = 4;\n await setState(userId, \"registration\", data);\n await sendMessage(\n chatId,\n \"እባክዎ ከዚህ በታች ካሉት አማራጮች የክፍል ደረጃዎን (Grade) ይምረጡ፦ 📚\",\n { reply_markup: GRADE_KEYBOARD },\n );\n return;\n } else if (data.step === 4) {\n const grade = text;\n await registerUser(userId, data.name!, data.phone!, data.school!, grade);\n await clearState(userId);\n\n const successMsg = \"✅ ምዝገባህ/ሽ በተሳካ ሁኔታ ተጠናቅቋል! 🙌✨\\n\" +\n \"የቤርያ ተማሪዎች ፌሎውሽፕ ቤተሰብ አካል በመሆንህ/ሽ በጣም ደስ ብሎናል!\\n\\n\" +\n \"🗓 ቀን፦ ሁልጊዜ አርብ | ⏰ ሰዓት፦ ከ 9:30 እስከ 11:00 ሰዓት 🌙\\n\" +\n \"📍 ቦታ፦ የተቀባ የእግዛብሄር ቃል ቸርች (ከዳንዲ ቦሩ ጀርባ)\";\n await sendMessage(chatId, successMsg, { reply_markup: MAIN_KEYBOARD });\n\n const adminNotify = `📝 *አዲስ የተመዘገበ ተማሪ!*\\n👤 ስም: ${\n escapeMarkdown(\n data.name,\n )\n }\\n🆔 ID: \\`${userId}\\``;\n await safeSendMarkdown(ADMIN_ID, adminNotify);\n return;\n }\n }\n\n // ---- Menu routing ----\n if (text.includes(\"መሪ ይምረጡ\")) {\n await sendMessage(chatId, \"የዚህ ዓመት መሪ ምርጫ በቅርብ ይጀምራል! 👑\", {\n reply_markup: BACK_ONLY_KEYBOARD,\n });\n } else if (\n text.includes(\"የምንመረምረውን ክፍል ይምረጡ\") || text.includes(\"Choose Verse\")\n ) {\n await sendMessage(chatId, \"📖 እባክዎ ከዚህ በታች ካሉት የኪዳን ዓይነቶች አንዱን ይምረጡ፦\", {\n reply_markup: TESTAMENT_KEYBOARD,\n });\n } else if (text === \"📜 ብሉይ ኪዳን (Old Testament)\") {\n await sendMessage(chatId, \"📜 የብሉይ ኪዳን መጻሕፍት ዝርዝር፦\", {\n reply_markup: OLD_TESTAMENT_KEYBOARD,\n });\n } else if (text === \"📖 አዲስ ኪዳን (New Testament)\") {\n await sendMessage(chatId, \"📖 የአዲስ ኪዳን መጻሕፍት ዝርዝር፦\", {\n reply_markup: NEW_TESTAMENT_KEYBOARD,\n });\n } else if (text === BACK_TO_TESTAMENT) {\n await sendMessage(chatId, \"📖 እባክዎ ከዚህ በታች ካሉት የኪዳን ዓይነቶች አንዱን ይምረጡ፦\", {\n reply_markup: TESTAMENT_KEYBOARD,\n });\n } else if (BOOK_BUTTON_TEXTS.has(text)) {\n await safeSendMarkdown(\n chatId,\n `መረጡት መጽሐፍ: *${\n escapeMarkdown(text)\n }*\\n\\nየዚህን መጽሐፍ ክፍሎች ወይም ጥቅሶች በቅርቡ እናጭራለን።`,\n { reply_markup: BACK_ONLY_KEYBOARD },\n );\n } else if (text.includes(\"ጥያቄና አስተያየት\") || text.includes(\"Help\")) {\n await setState(userId, \"help_waiting\", {});\n await sendMessage(chatId, \"ሰላም! ሃሳብዎን ወይም ጥያቄዎን በዝርዝር ከታች ይጻፉ! 😊\", {\n reply_markup: BACK_ONLY_KEYBOARD,\n });\n } else if (text.includes(\"ተመዝገብ/ቢ\") || text.includes(\"Register Now\")) {\n await setState(userId, \"registration\", { step: 1 });\n await sendMessage(chatId, \"እባክዎ ሙሉ ስምዎን እዚህ ይጻፉ። ✨ ✍️\", {\n reply_markup: BACK_ONLY_KEYBOARD,\n });\n } else if (text.includes(\"የእኔ ፕሮፋይል\") || text.includes(\"My Profile\")) {\n const profile = await getUser(userId);\n if (profile) {\n const profileText = \"👤 *የእርስዎ ፕሮፋይል መረጃ (Your Profile)*:\\n\\n\" +\n `📌 ሙሉ ስም: ${escapeMarkdown(profile.name)}\\n` +\n `📞 ስልክ ቁጥር: ${escapeMarkdown(profile.phone)}\\n` +\n `🏫 ትምህርት ቤት: ${escapeMarkdown(profile.school)}\\n` +\n `📚 የክፍል ደረጃ: ${escapeMarkdown(profile.grade)}\\n`;\n await safeSendMarkdown(chatId, profileText, {\n reply_markup: MAIN_KEYBOARD,\n });\n } else {\n await sendMessage(\n chatId,\n \"እስካሁን አልተመዘገቡም! እባክዎ በመጀመሪያ 'ተመዝገብ/ቢ' የሚለውን ይጫኑ። 📝\",\n {\n reply_markup: MAIN_KEYBOARD,\n },\n );\n }\n } else if (text.includes(\"የእኔ መገኘት\") || text.includes(\"My Attendance\")) {\n const dates = await userAttendanceDates(userId);\n if (dates.length) {\n const datesStr = dates.map((d) => `• 📅 ${d}`).join(\"\\n\");\n await sendMessage(\n chatId,\n `📋 *የእርስዎ የመገኘት ታሪክ*:\\n\\nበጠቅላላ የተገኙባቸው ቀናት (${dates.length}):\\n${datesStr}`,\n { parse_mode: \"Markdown\", reply_markup: MAIN_KEYBOARD },\n );\n } else {\n await sendMessage(chatId, \"📋 እስካሁን የተመዘገበ የመገኘት ታሪክ የለዎትም።\", {\n reply_markup: MAIN_KEYBOARD,\n });\n }\n } else if (text.includes(\"ስለ ቤርያ\") || text.includes(\"About Us\")) {\n await sendMessage(chatId, ABOUT_TEXT, { reply_markup: MAIN_KEYBOARD });\n } else if (text.includes(\"ቦታውን ለማግኘት\") || text.includes(\"Location\")) {\n await sendMessage(chatId, LOCATION_TEXT, {\n reply_markup: MAIN_KEYBOARD,\n disable_web_page_preview: true,\n });\n } else if (text === \"/admin\" && userId === ADMIN_ID) {\n await sendMessage(\n chatId,\n \"🛠 *Admin Panel*\\nWelcome back, Admin. Choose an action:\",\n {\n parse_mode: \"Markdown\",\n reply_markup: adminPanelKeyboard(),\n },\n );\n } else {\n await sendMessage(chatId, \"እባክዎ ከታች ያሉትን አማራጮች ይጠቀሙ 👇\", {\n reply_markup: MAIN_KEYBOARD,\n });\n }\n}\n\n// ----------------- ATTENDANCE SESSION FLOW -----------------\ntype AttendanceSession = {\n date: string;\n userIds: number[];\n index: number;\n attendance: Record;\n};\n\nasync function sendAttendanceRow(chatId: number, adminId: number) {\n const state = await getState(adminId);\n if (!state || state.kind !== \"attendance_session\") return;\n const session = state.payload as AttendanceSession;\n\n if (session.index >= session.userIds.length) {\n // Finished — persist attendance and show summary\n const lines: string[] = [\n `📋 *Attendance Summary Table for ${session.date}*:\\n`,\n ];\n lines.push(\"```\");\n lines.push(\n `${\"No\".padEnd(3)} | ${\"Student Name\".padEnd(18)} | ${\n \"Status\".padEnd(7)\n }`,\n );\n lines.push(\"-\".repeat(34));\n\n let idx = 1;\n for (const uid of session.userIds) {\n const status = session.attendance[uid] ?? \"Absent\";\n await setAttendance(session.date, uid, status);\n const user = await getUser(uid);\n const name = (user ? (user.name as string) : String(uid)).slice(0, 16);\n lines.push(\n `${String(idx).padEnd(3)} | ${name.padEnd(18)} | ${status.padEnd(7)}`,\n );\n idx++;\n }\n lines.push(\"```\");\n await sendMessage(chatId, lines.join(\"\\n\"), { parse_mode: \"Markdown\" });\n await clearState(adminId);\n return;\n }\n\n const currentUid = session.userIds[session.index];\n const user = await getUser(currentUid);\n const text = `📋 *Taking Attendance (Table Mode)*\\n` +\n `📅 Date: ${session.date}\\n` +\n `👤 Student ${session.index + 1} of ${session.userIds.length}\\n\\n` +\n `📌 *Name*: ${escapeMarkdown(user.name)}\\n` +\n `🏫 *School*: ${escapeMarkdown(user.school)}\\n` +\n `📚 *Grade*: ${escapeMarkdown(user.grade)}\\n\\n` +\n `Choose status for this student:`;\n await safeSendMarkdown(chatId, text, {\n reply_markup: attendanceInlineKeyboard(session.index),\n });\n}\n\n// ----------------- CALLBACK QUERY HANDLING -----------------\nasync function handleCallbackQuery(callback: any) {\n const userId = callback.from.id as number;\n const chatId = callback.message.chat.id as number;\n const data = callback.data as string;\n\n if (userId !== ADMIN_ID) {\n await answerCallbackQuery(callback.id, \"Unauthorized!\", true);\n return;\n }\n\n if (data === \"admin_stats\") {\n await answerCallbackQuery(callback.id);\n const registered = await registeredCount();\n const interacted = (await allInteracted()).length;\n await sendMessage(\n chatId,\n `📊 Total registered users: ${registered}\\n📊 Total interacted users: ${interacted}`,\n );\n return;\n }\n\n if (data === \"admin_broadcast\") {\n await answerCallbackQuery(callback.id);\n await setState(userId, \"admin_broadcast_waiting\", {});\n await sendMessage(\n chatId,\n \"📢 Send the message you want to broadcast to all members.\",\n );\n return;\n }\n\n if (data === \"admin_start_attendance\") {\n await answerCallbackQuery(callback.id);\n const registered = await allRegistered();\n if (!registered.length) {\n await sendMessage(\n chatId,\n \"⚠️ No registered users found to take attendance.\",\n );\n return;\n }\n const todayStr = new Date().toISOString().slice(0, 10);\n const session: AttendanceSession = {\n date: todayStr,\n userIds: registered.map((u) => u.user_id as number),\n index: 0,\n attendance: {},\n };\n await setState(userId, \"attendance_session\", session);\n await sendMessage(\n chatId,\n `🚀 Starting interactive attendance session for *${todayStr}* across ${session.userIds.length} registered students.`,\n { parse_mode: \"Markdown\" },\n );\n await sendAttendanceRow(chatId, userId);\n return;\n }\n\n if (data.startsWith(\"att_mark_\")) {\n await answerCallbackQuery(callback.id);\n const parts = data.split(\"_\");\n const status = parts[2];\n const index = Number(parts[3]);\n\n const state = await getState(userId);\n if (!state || state.kind !== \"attendance_session\") {\n await sendMessage(chatId, \"Session expired or reset.\");\n return;\n }\n const session = state.payload as AttendanceSession;\n const currentUid = session.userIds[index];\n session.attendance[currentUid] = status;\n session.index = index + 1;\n await setState(userId, \"attendance_session\", session);\n\n await deleteMessage(chatId, callback.message.message_id);\n await sendAttendanceRow(chatId, userId);\n return;\n }\n}\n\n// ----------------- HTTP HANDLER (Val Town entrypoint) -----------------\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"Berya Bot webhook endpoint is running.\", {\n status: 200,\n });\n }\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n let update: any;\n try {\n update = await req.json();\n } catch {\n return new Response(\"Bad Request\", { status: 400 });\n }\n\n try {\n if (update.message) {\n await handleMessage(update.message);\n } else if (update.callback_query) {\n await handleCallbackQuery(update.callback_query);\n }\n } catch (err) {\n console.error(\"Error handling update:\", err);\n }\n\n return new Response(\"OK\", { status: 200 });\n}","createdAt",["D",1789190137486],"branchVersion","branchId","1fb84b51-d029-4add-91a2-51f440ffba62","id","7ffc3e70-5e6c-40d4-9e31-9bc600523674","berya-bot",["D",1789189085059],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Berya Students Fellowship Telegram bot","imageUrl","108830de-1854-4c2d-b380-041269774dde","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f089e-c076-75dd-98bd-b5c12306103f","tursoName","7ffc3e705e6c40d49e319bc600523674","tursoHostname","7ffc3e705e6c40d49e319bc600523674-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789536664699],"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",7,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","abenzeramanuel","handle","displayName","abenzer amanuel","avatar","https://lh3.googleusercontent.com/a/ACg8ocK94Zj-WbUHHDr7tRtpMkHnHYGTj82tpree-qGok3z1FcZiGA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":153,"_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":154,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":155,"_82":156,"_84":157,"_86":25},"tree",[148],"files",[148],"counts",{"_137":61,"_138":139,"_140":61,"_141":142,"_143":144},"contents",[129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","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},"77b74816-b7b4-4886-8710-896d3b7205fb","parentId","latest",["D",1789190137486],4,"label",[28],"pulls","branches",1,"forks","envVars",{"_145":61,"_147":61},"connections",{"_145":61,"_146":61},"count","unfilledCount","emptyCount",{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":149,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_150":151,"_27":152},["D",1789190137486],"children",[],[28],["D",1789189085059],["D",1789536664699],{"_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":191,"_192":193,"_194":195,"_196":25,"_197":25,"_198":25,"_199":200,"_201":-5,"_202":-7,"_203":-7,"_204":61,"_205":25,"_206":25,"_207":-5,"_208":25,"_209":25,"_210":25,"_211":-5},"ENV",{"_162":163,"_164":165,"_166":88,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v5