[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","abeniexpress","name","owship-telegram-bot","path","main.ts","project",{"_22":46,"_11":12,"_33":47,"_48":-5,"_49":42,"_50":51,"_52":51,"_53":54,"_55":-5,"_56":57,"_58":25,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_13":45},"permalink","https://www.val.town/x/abeniexpress/owship-telegram-bot/code/main.ts","extension","id","33f2680f-ecba-4a53-9334-0e490f557da0","fileId","48c33956-ae72-11f1-aed1-1607ee4eb77e","parentId","branchId","e7e2441f-1753-4496-9da0-341c651f1716","branchVersion",30,"latest",true,"createdAt",["D",1789333722636],"version",29,"fileType","http","content","/**\n * owship 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:\n * 1. (Recommended) In the val's \"Environment variables\" panel, BOT_TOKEN\n * and ADMIN_ID are set (posted here) and override the hardcoded\n * fallbacks below.\n * 2. Deploy the val, copy its endpoint URL.\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\") ||\n \"8790399985:AAG3SOJGeeROVzGJp-9YtCl-NOcD0h7RWLk\";\nconst ADMIN_ID = 2017456868;\nconst API = `https://api.telegram.org/bot${BOT_TOKEN}`;\n\nif (\n !BOT_TOKEN || BOT_TOKEN === \"8790399985:AAG3SOJGeeROVzGJp-9YtCl-NOcD0h7RWLk\"\n) {\n console.error(\"BOT_TOKEN env var is not set; using hardcoded fallback.\");\n}\n\n// ----------------- SQLITE ROW HELPERS -----------------\nfunction rowToObj(res: any, index: number): Record | null {\n if (!res.rows[index]) return null;\n const row = res.rows[index];\n const columns: string[] = res.columns;\n return Object.fromEntries(columns.map((c, i) => [c, row[i]]));\n}\n\nfunction rowsToObjs(res: any): Record[] {\n const columns: string[] = res.columns;\n return res.rows.map((row: any[]) =>\n Object.fromEntries(columns.map((c, i) => [c, row[i]]))\n );\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 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 await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS admin_forwards (\n admin_message_id INTEGER PRIMARY KEY,\n user_id INTEGER\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 const row = rowToObj(res, 0);\n if (!row) return null;\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 rowsToObjs(res).map((r) => 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 rowToObj(res, 0);\n}\n\nasync function allRegistered(): Promise {\n const res = await sqlite.execute(\"SELECT * FROM registered_users\");\n return rowsToObjs(res);\n}\n\nasync function registeredCount(): Promise {\n const res = await sqlite.execute(\n \"SELECT COUNT(*) as n FROM registered_users\",\n );\n const row = rowToObj(res, 0);\n return (row?.n as number) ?? 0;\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 rowsToObjs(res).map((r) => r.date as string);\n}\n\n// Records the Telegram message_id of a message the bot sent to the admin so we\n// can map \"the message the admin replied to\" back to the user it came from.\nasync function recordForward(adminMessageId: number, userId: number) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO admin_forwards (admin_message_id, user_id)\n VALUES (?, ?)`,\n [adminMessageId, userId],\n );\n}\n\nasync function userForForward(\n adminMessageId: number,\n): Promise {\n const res = await sqlite.execute(\n \"SELECT user_id FROM admin_forwards WHERE admin_message_id = ?\",\n [adminMessageId],\n );\n const row = rowToObj(res, 0);\n return row ? (row.user_id as number) : null;\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\nasync function sendPhoto(\n chatId: number,\n photo: string,\n caption: string,\n opts: Record = {},\n) {\n return tg(\"sendPhoto\", { chat_id: chatId, photo, caption, ...opts });\n}\n\nasync function safeSendMarkdown(\n chatId: number,\n text: string,\n opts: Record = {},\n): Promise {\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 return tg(\"sendMessage\", { chat_id: chatId, text, ...opts });\n }\n return res;\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_OPTIONS = [\n \"9ኛ ክፍል (Grade 9)\",\n \"10ኛ ክፍል (Grade 10)\",\n \"11ኛ ክፍል (Grade 11)\",\n \"12ኛ ክፍል (Grade 12)\",\n \"የድሮ ባች (Old Batch)\",\n];\nconst GRADE_KEYBOARD = keyboardFromLabels(GRADE_OPTIONS, BACK_TO_MAIN);\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_IMAGE_FILE_ID = \"\";\n\nconst WELCOME_TEXT =\n \"ሰላም! ወደ ቤርያ ተማሪዎች ፌሎውሺፕ (Berya Bot) በሰላም መጣህ/ሽ! 👋✨\\n\\n\" +\n \"ይህ ቦት ከፌሎውሽፓችን ጋር በቀላሉ እንድትገናኝ/ኚ እና መረጃዎችን እንድታገኝ/ኚ የተሰራ ነው።\\n\\n\" +\n \"ለመጀመር እነዚህን አማራጮች ተጠቀም/ሚ፦\\n\\n\" +\n \"📝 መመዝገብ (Register): የፌሎውሽፑ አባል ለመሆን።\\n\" +\n \"📖 የቃሉ ጥናት: ትምህርቶችን ለማንበብ።\\n\" +\n \"🗳 ድምጽ መስጠት: የምናጠናውን ክፍል ለመምረጥ።\\n\" +\n \"💬 ጥያቄና አስተያየት: ለአድሚኖች መልእክት ለመላክ።\\n\\n\" +\n \"አሁኑኑ ተመዝገቡ፤ አብረን እንማር (Let's study)! 🔥📖\";\n\nconst ABOUT_TEXT =\n `ቤርያ (Berya) ተማሪዎች በእውነትና በሕይወት መንገድ ላይ እንዲመላለሱ፣ በእውቀትና በቁምነገር እንዲታነጹ የተቋቋመ ልዩ መንፈሳዊ የህብረት መድረክ ነው! 🌟📖\n\nየስሙ ጥልቅ ትርጉም (የቤርያ ሰዎች)፦\n\"ቤርያ\" የሚለው ስያሜ የተወሰደው ከመጽሐፍ ቅዱስ ሲሆን፣ በታሪክ የሚታወቁት የቤርያ ሰዎች የእግዚአብሔርን ቃል በታላቅ ጉጉትና ክፍት በሆነ ልብ በመቀበላቸው ነበር። እነርሱ የተነገራቸው ነገር ሁሉ ከእውነት ጋር መገጣጠሙን ለማረጋገጥ \"ዕለት ዕለት መጽሐፍትን ይመረምሩ\" ነበር (የሐዋርያት ሥራ 17፥11)። እኛም ይህንን አርአያ በመከተል ቃሉን የምናጠና (Study Bible) እና የምንመረምር ተማሪዎች ነን! 📖🔍\n\nበህብረታችን ውስጥ ምን ምን ያገኛሉ?\n\n📖 Study Bible (የቃል ጥናት)፦ የእግዚአብሔርን ቃል ጥልቀትና ሚስጥር የምንረዳበት፣ ለሕይወታችን የሚሆን ጥበብ የምንገበይበት ልዩ ሰዓት።\n\n🎸 አምልኮና ምስጋና፦ በዝማሬና በምስጋና መንፈሳችን የሚታደስበት፣ ከፈጣሪ ጋር የምንገናኝበት የደስታ ጊዜ።\n\n🎮 መንፈሳዊ መዝናኛ፦ አእምሮን የሚያነቃቁ፣ መንፈስን የሚያድሱና እርስ በርስ የሚያቀራርቡ ልዩ ልዩ ጨዋታዎች።\n\n🤝 የተማሪዎች ህብረት፦ መልካም ጓደኞችን የምናፈራበት፣ በሐሳብና በጸሎት የምንደጋገፍበት እንዲሁም እንደ አንድ ቤተሰብ የምንሆንበት ማህበር።\n\n🎓 የሕይወት ክህሎት፦ ተማሪዎች በትምህርታቸውና በግል ሕይወታቸው ስኬታማ እንዲሆኑ የሚያግዙ ምክሮችና ትምህርቶች።\n\nየፕሮግራሙ ዝርዝር፦\n🗓 ቀን፦ ሁልጊዜ አርብ\n⏰ ሰዓት፦ ከ 9:30 እስከ 11:00 ሰዓት\n📍 ቦታ፦ የተቀባ የእግዛብሄር ቃል ቸርች (ከዳንዲ ቦሩ ትምህርት ቤት ጀርባ)\n\nኑ! እንደ ቤርያ ሰዎች ቃሉን አብረን እናጥና (Study Bible)፤ ሕይወታችንንም በቃሉ ብርሃን እንገንባ! 🙌🔥✨`;\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 (userId === ADMIN_ID && message.photo) {\n const sizes = message.photo as Array<{ file_id: string }>;\n const largest = sizes[sizes.length - 1];\n await sendMessage(\n chatId,\n `📸 file_id:\\n\\`${largest.file_id}\\`\\n\\nCopy this into WELCOME_IMAGE_FILE_ID in the code, then re-deploy.`,\n { parse_mode: \"Markdown\" },\n );\n return;\n }\n\n // Admin two-way reply: when the admin taps \"reply\" on one of the forwarded\n // user messages, route the admin's answer straight to that user.\n if (userId === ADMIN_ID && text && message.reply_to_message) {\n const targetUser = await userForForward(\n message.reply_to_message.message_id,\n );\n if (targetUser != null) {\n await sendMessage(\n targetUser,\n `📩 ምላሽ ከአድሚን ተሰጦታል:\\n\\n${text}`,\n );\n await sendMessage(\n chatId,\n `📨✅ መልእክት ለተጠቃሚ (${targetUser}) ተልኳል።`,\n );\n return;\n }\n }\n\n if (text === \"/start\") {\n if (WELCOME_IMAGE_FILE_ID) {\n await sendPhoto(chatId, WELCOME_IMAGE_FILE_ID, WELCOME_TEXT, {\n reply_markup: MAIN_KEYBOARD,\n });\n } else {\n await sendMessage(chatId, WELCOME_TEXT, { reply_markup: MAIN_KEYBOARD });\n }\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 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 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 const resp = await safeSendMarkdown(ADMIN_ID, forwardText);\n const adminMid = resp?.result?.message_id;\n if (adminMid != null) await recordForward(adminMid, userId);\n\n // Keep the conversation open: while this user is \"help_active\", their free\n // text keeps going to the admin, and the admin can reply via Telegram's\n // reply feature (the admin_forwards mapping makes that work).\n await setState(userId, \"help_active\", {});\n\n const confirmationText = \"መልእክትህ/ሽ በሰላም ደርሶናል! 🙏✨\\n\\n\" +\n \"ሐሳብህን/ሽን ከእኛ ጋር ለማጋራት ስለመረጥህ/ሽ እናመሰግናለን። የላክኸው/ሽው ጥያቄ ወይም አስተያየት ለቤርያ ተማሪዎች ፌሎውሽፕ አድሚኖች ወዲያውኑ ደርሷቸዋል።\\n\\n\" +\n \"ቀጣይ ምን ይሆናል?\\n\\n\" +\n \"አድሚኖቻችን መልእክትህን/ሽን በጥንቃቄ ይመለከታሉ።\\n\\n\" +\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 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 if (!GRADE_OPTIONS.includes(text)) {\n await sendMessage(\n chatId,\n \"እባክዎ ከዚህ በታች ካሉት አማራጮች ብቻ ይምረጡ 👇\",\n { reply_markup: GRADE_KEYBOARD },\n );\n return;\n }\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 \"የፕሮግራሙ ዝርዝር፦\\n\" +\n \"🗓 ቀን፦ ሁልጊዜ አርብ\\n\" +\n \"⏰ ሰዓት፦ ከ 9:30 እስከ 11:00 ሰዓት 🌙\\n\" +\n \"📍 ቦታ፦ የተቀባ የእግዛብሄር ቃል ቸርች (ከዳንዲ ቦሩ ጀርባ)\\n\\n\" +\n \"ሲመጡ ምን ያገኛሉ? (What will you get?)\\n\" +\n \"📖 ሕይወት የሚቀይር የቃል ትምህርት\\n\" +\n \"🎸 ልብን የሚያድስ አምልኮና ዝማሬ\\n\" +\n \"🎮 መንፈስን የሚያድሱ አዝናኝ ጨዋታዎች\\n\" +\n \"🤝 አዳዲስና መልካም ጓደኞችን\\n\\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 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 sendMessage(\n chatId,\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 // If the user is mid-conversation with the admin (help_active), any free\n // text they type is forwarded to the admin as a reply.\n const activeHelp = await getState(userId);\n if (activeHelp?.kind === \"help_active\" && text) {\n const forwardText = `📩 *ከተጠቃሚ አዲስ መልእክት (reply):*\\n\\n` +\n `👤 ከ: ${\n escapeMarkdown(message.from.first_name)\n } (ID: \\`${userId}\\`)\\n` +\n `💬 መልእክት: ${escapeMarkdown(text)}`;\n const resp = await safeSendMarkdown(ADMIN_ID, forwardText);\n const adminMid = resp?.result?.message_id;\n if (adminMid != null) await recordForward(adminMid, userId);\n await sendMessage(\n chatId,\n \"መልእክትህ/ሽ ለአድሚን፤ ምላሽ እስክንሰጥዎ በትዕግስት ይጠብቁን\",\n );\n return;\n }\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 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 rawName = (user ? (user.name as string) : String(uid)).replace(\n /`/g,\n \"'\",\n );\n const name = rawName.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 safeSendMarkdown(chatId, lines.join(\"\\n\"));\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 if (index !== session.index) {\n return;\n }\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}","deleted",false,"label","owship-bot",[14],"11ba85c0-35d6-4ceb-9d4f-f87caf4974d3",["D",1789194129478],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","owship Telegram Fellowship bot (webhook)","imageUrl","userId","7b693b19-00bb-4ff8-9f21-46f74d78fec0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03ab4-e472-7108-a0d8-7317f90304e9","tursoName","11ba85c035d64ceb9d4ff87caf4974d3","tursoHostname","11ba85c035d64ceb9d4ff87caf4974d3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789542643120],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_56":57,"_102":103,"_104":42},"branch",{"_35":30,"_11":89,"_22":28,"_90":46,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","senay amanuel","avatar","https://lh3.googleusercontent.com/a/ACg8ocKLVzDJiWqMqi7urGNY894gs9XVh7xzA-fRHaHc0u6NCOjWoH0=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]