[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","9fcdc8cf1ed941fa992d1f543c70306729136e51","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_150":151,"_170":171,"_172":-5},"handle","wahobd","name","newval","path","backend/index.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":116,"_118":-5,"_119":32,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_149":20},"id","a4f3d524-4f54-11f0-a138-f69ea79377d9","createdAt",["D",1750588541174],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","8e0cb670-0173-11f0-8fc2-29ca0ea0c0ed","pinnedFileId","ffa51716-5324-11f0-88af-f69ea79377d9","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","cf832929-9b29-451f-a2c4-eccee50aba5c","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_131":132},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ1TFF3NjBXTTBuSThiWUhvMGJibVVxZmNSMCJ9","org",{"_94":95,"_135":132,"_12":112},"avatar","branch",{"_138":139,"_96":44,"_102":140,"_141":103,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":97,"_148":95},"version",33,"a4f43014-4f54-11f0-a138-f69ea79377d9","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":152,"_96":153,"_154":114,"_155":156,"_157":140,"_158":139,"_159":116,"_104":160,"_138":161,"_162":163,"_164":165,"_166":20,"_167":-5,"_98":168},"dbaa75ce-533b-11f0-bdf0-f69ea79377d9","index.ts","fileId","parentId","41c03f6e-354f-4a0c-a454-7fe363b188e8","branchId","branchVersion","latest",["D",1751017700192],16,"fileType","http","content","import { Bot, InlineKeyboard, session } from \"https://deno.land/x/grammy@v1.21.1/mod.ts\";\nimport {\n type Conversation,\n type ConversationFlavor,\n conversations,\n createConversation,\n} from \"https://deno.land/x/grammy_conversations@v1.2.0/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// --- Configuration ---\nconst BOT_TOKEN = Deno.env.get(\"BOT_TOKEN\")!;\nconst ADMIN_ID = parseInt(Deno.env.get(\"OWNER_ID\")!);\nconst MANDATORY_CHANNEL_ID = Deno.env.get(\"CHANNEL_ID\")!;\n\n// Database table names\nconst TABLES = {\n users: \"users_v1\",\n referrals: \"referrals_v1\",\n referral_times: \"referral_times_v1\",\n completed_tasks: \"completed_tasks_v1\",\n user_vip_tasks_completed: \"user_vip_tasks_completed_v1\",\n user_general_tasks_completed: \"user_general_tasks_completed_v1\",\n withdraw_requests: \"withdraw_requests_v1\",\n pending_deposits: \"pending_deposits_v1\",\n user_deposit_state: \"user_deposit_state_v1\",\n user_current_task: \"user_current_task_v1\",\n user_task_start_time: \"user_task_start_time_v1\",\n live_chat_states: \"live_chat_states_v1\",\n admin_states: \"admin_states_v1\",\n global_settings: \"global_settings_v1\",\n tasks: \"tasks_v1\",\n vip_packages: \"vip_packages_v1\",\n user_daily_deposit_count: \"user_daily_deposit_count_v1\",\n user_referral_temp: \"user_referral_temp_v1\",\n};\n\nlet NAGAD_DEPOSIT_NUMBER = \"9856000700461433\";\n\n// Initialize database\nasync function initializeDatabase() {\n try {\n // Create all tables\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.users} (\n id INTEGER PRIMARY KEY,\n username TEXT,\n first_name TEXT,\n balance REAL DEFAULT 0,\n task_balance REAL DEFAULT 0,\n deposit_balance REAL DEFAULT 0,\n withdraw_number TEXT,\n withdraw_method TEXT,\n is_vip INTEGER DEFAULT 0,\n vip_expiry INTEGER DEFAULT 0,\n free_task_start_date INTEGER DEFAULT 0,\n is_banned INTEGER DEFAULT 0\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.referrals} (\n referred_id INTEGER PRIMARY KEY,\n referrer_id INTEGER,\n reward REAL DEFAULT 0,\n count INTEGER DEFAULT 0,\n blocked_until INTEGER DEFAULT 0\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.completed_tasks} (\n user_id INTEGER,\n task_id INTEGER,\n PRIMARY KEY (user_id, task_id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.tasks} (\n id INTEGER PRIMARY KEY,\n name TEXT,\n reward REAL,\n description TEXT,\n link TEXT,\n min_time INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.vip_packages} (\n id INTEGER PRIMARY KEY,\n name TEXT,\n price REAL,\n tasks INTEGER,\n duration_days INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.withdraw_requests} (\n user_id INTEGER PRIMARY KEY,\n amount REAL,\n method TEXT,\n number TEXT,\n username TEXT,\n first_name TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.pending_deposits} (\n user_id INTEGER PRIMARY KEY,\n amount REAL,\n txid TEXT,\n time INTEGER,\n username TEXT,\n first_name TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_deposit_state} (\n user_id INTEGER PRIMARY KEY,\n step TEXT,\n amount REAL,\n txid TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.admin_states} (\n admin_id INTEGER PRIMARY KEY,\n state TEXT,\n target_user_id INTEGER,\n action TEXT,\n task_data TEXT,\n vip_data TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.live_chat_states} (\n user_id INTEGER PRIMARY KEY,\n state TEXT,\n target_user_id INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_current_task} (\n user_id INTEGER PRIMARY KEY,\n task_id INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_task_start_time} (\n user_id INTEGER PRIMARY KEY,\n task_id INTEGER,\n timestamp INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_vip_tasks_completed} (\n user_id INTEGER PRIMARY KEY,\n package_id INTEGER,\n count INTEGER DEFAULT 0,\n last_completion_time INTEGER DEFAULT 0\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_general_tasks_completed} (\n user_id INTEGER PRIMARY KEY,\n date TEXT,\n count INTEGER DEFAULT 0\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_daily_deposit_count} (\n user_id INTEGER PRIMARY KEY,\n date TEXT,\n count INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.user_referral_temp} (\n user_id INTEGER PRIMARY KEY,\n referrer_id INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLES.global_settings} (\n key TEXT PRIMARY KEY,\n value TEXT\n )\n `);\n\n // Initialize default data\n const taskCountResult = await sqlite.execute(`SELECT COUNT(*) as count FROM ${TABLES.tasks}`);\n const taskCount = taskCountResult[0]?.count || 0; // Corrected line\n if (taskCount === 0) {\n const defaultTasks = [\n {\n id: 1,\n name: \"ওয়েবসাইট ভিজিট\",\n reward: 5,\n description: \"আমাদের ওয়েবসাইট ভিজিট করুন এবং অন্তত ১০ সেকেন্ড অপেক্ষা করুন।\",\n link: \"https://www.google.com\",\n min_time: 10,\n },\n {\n id: 2,\n name: \"টেলিগ্রাম গ্রুপে জয়েন\",\n reward: 3,\n description: \"আমাদের অফিসিয়াল টেলিগ্রাম গ্রুপে জয়েন করুন।\",\n link: \"https://t.me/your_telegram_group\",\n min_time: 0,\n },\n ];\n for (const task of defaultTasks) {\n await sqlite.execute(\n `INSERT INTO ${TABLES.tasks} (id, name, reward, description, link, min_time) VALUES (?, ?, ?, ?, ?, ?)`,\n [task.id, task.name, task.reward, task.description, task.link, task.min_time],\n );\n }\n }\n\n const vipPackageCountResult = await sqlite.execute(`SELECT COUNT(*) as count FROM ${TABLES.vip_packages}`);\n const vipPackageCount = vipPackageCountResult[0]?.count || 0; // Corrected line\n if (vipPackageCount === 0) {\n const defaultVipPackages = [\n { id: 1, name: \"Bronze VIP\", price: 150, tasks: 5, duration_days: 10 },\n { id: 2, name: \"Silver VIP\", price: 300, tasks: 10, duration_days: 10 },\n { id: 3, name: \"Gold VIP\", price: 500, tasks: 16, duration_days: 10 },\n { id: 4, name: \"Platinum VIP\", price: 700, tasks: 21, duration_days: 10 },\n ];\n for (const pkg of defaultVipPackages) {\n await sqlite.execute(\n `INSERT INTO ${TABLES.vip_packages} (id, name, price, tasks, duration_days) VALUES (?, ?, ?, ?, ?)`,\n [pkg.id, pkg.name, pkg.price, pkg.tasks, pkg.duration_days],\n );\n }\n }\n\n // Load NAGAD_DEPOSIT_NUMBER from global settings if available\n const nagadNumberSetting = await sqlite.execute(`SELECT value FROM ${TABLES.global_settings} WHERE key = ?`, [\n \"NAGAD_DEPOSIT_NUMBER\",\n ]);\n if (nagadNumberSetting.length > 0) {\n NAGAD_DEPOSIT_NUMBER = nagadNumberSetting[0].value;\n }\n\n console.log(\"Database initialized successfully\");\n } catch (e) {\n console.error(\"Failed to initialize database:\", e);\n throw e;\n }\n}\n\n// Database helper functions\nconst getUser = async (userId: number) => {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.users} WHERE id = ?`, [userId]);\n if (result.length > 0) {\n const row = result[0];\n return {\n id: row.id,\n username: row.username,\n first_name: row.first_name,\n balance: row.balance,\n task_balance: row.task_balance,\n deposit_balance: row.deposit_balance,\n withdraw_number: row.withdraw_number,\n withdraw_method: row.withdraw_method,\n is_vip: row.is_vip === 1,\n vip_expiry: row.vip_expiry,\n free_task_start_date: row.free_task_start_date,\n is_banned: row.is_banned === 1,\n };\n }\n return null;\n};\n\nconst ensureUserExists = async (userId: number, username: string, firstName: string) => {\n const user = await getUser(userId);\n if (!user) {\n await sqlite.execute(`INSERT INTO ${TABLES.users} (id, username, first_name) VALUES (?, ?, ?)`, [\n userId,\n username,\n firstName,\n ]);\n } else {\n await sqlite.execute(`UPDATE ${TABLES.users} SET username = ?, first_name = ? WHERE id = ?`, [\n username,\n firstName,\n userId,\n ]);\n }\n};\n\nconst updateUserBalance = async (userId: number, amount: number) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET balance = balance + ? WHERE id = ?`, [amount, userId]);\n};\n\nconst getUserBalance = async (userId: number) => {\n const result = await sqlite.execute(`SELECT balance FROM ${TABLES.users} WHERE id = ?`, [userId]);\n return result.length > 0 ? result[0].balance : 0;\n};\n\nconst updateUserDepositBalance = async (userId: number, amount: number) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET deposit_balance = deposit_balance + ? WHERE id = ?`, [\n amount,\n userId,\n ]);\n};\n\nconst getUserDepositBalance = async (userId: number) => {\n const result = await sqlite.execute(`SELECT deposit_balance FROM ${TABLES.users} WHERE id = ?`, [userId]);\n return result.length > 0 ? result[0].deposit_balance : 0;\n};\n\nconst isUserBanned = async (userId: number) => {\n const result = await sqlite.execute(`SELECT is_banned FROM ${TABLES.users} WHERE id = ?`, [userId]);\n return result.length > 0 && result[0].is_banned === 1;\n};\n\nconst isUserReferred = async (userId: number) => {\n const result = await sqlite.execute(`SELECT referred_id FROM ${TABLES.referrals} WHERE referred_id = ?`, [userId]);\n return result.length > 0;\n};\n\nconst addReferral = async (referredId: number, referrerId: number) => {\n await sqlite.execute(`INSERT INTO ${TABLES.referrals} (referred_id, referrer_id) VALUES (?, ?)`, [\n referredId,\n referrerId,\n ]);\n await sqlite.execute(\n `INSERT OR IGNORE INTO ${TABLES.referrals} (referred_id, referrer_id, reward, count) VALUES (?, ?, 0, 0)`,\n [referrerId, 0],\n );\n await sqlite.execute(`UPDATE ${TABLES.referrals} SET reward = reward + 12, count = count + 1 WHERE referred_id = ?`, [\n referrerId,\n ]);\n};\n\nconst getReferralInfo = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT reward, count, blocked_until FROM ${TABLES.referrals} WHERE referred_id = ?`,\n [userId],\n );\n return result.length > 0\n ? { reward: result[0].reward, count: result[0].count, blocked_until: result[0].blocked_until }\n : { reward: 0, count: 0, blocked_until: 0 };\n};\n\nconst getUserReferralTemp = async (userId: number) => {\n const result = await sqlite.execute(`SELECT referrer_id FROM ${TABLES.user_referral_temp} WHERE user_id = ?`, [\n userId,\n ]);\n return result.length > 0 ? result[0].referrer_id : null;\n};\n\nconst setUserReferralTemp = async (userId: number, referrerId: number) => {\n await sqlite.execute(`INSERT OR REPLACE INTO ${TABLES.user_referral_temp} (user_id, referrer_id) VALUES (?, ?)`, [\n userId,\n referrerId,\n ]);\n};\n\nconst deleteUserReferralTemp = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.user_referral_temp} WHERE user_id = ?`, [userId]);\n};\n\nconst getUserFreeTaskStartDate = async (userId: number) => {\n const result = await sqlite.execute(`SELECT free_task_start_date FROM ${TABLES.users} WHERE id = ?`, [userId]);\n return result.length > 0 ? result[0].free_task_start_date : 0;\n};\n\nconst setUserFreeTaskStartDate = async (userId: number, timestamp: number) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET free_task_start_date = ? WHERE id = ?`, [timestamp, userId]);\n};\n\nconst getTasks = async () => {\n const result = await sqlite.execute(`SELECT id, name, reward, description, link, min_time FROM ${TABLES.tasks}`);\n return result.map(row => ({\n id: row.id,\n name: row.name,\n reward: row.reward,\n description: row.description,\n link: row.link,\n minTime: row.min_time,\n }));\n};\n\nconst getVipPackages = async () => {\n const result = await sqlite.execute(`SELECT id, name, price, tasks, duration_days FROM ${TABLES.vip_packages}`);\n return result.map(row => ({\n id: row.id,\n name: row.name,\n price: row.price,\n tasks: row.tasks,\n durationDays: row.duration_days,\n }));\n};\n\nconst isUserVip = async (userId: number) => {\n const result = await sqlite.execute(`SELECT is_vip, vip_expiry FROM ${TABLES.users} WHERE id = ?`, [userId]);\n return result.length > 0 && result[0].is_vip === 1 && result[0].vip_expiry > Date.now();\n};\n\nconst setVipStatus = async (userId: number, isVip: boolean, expiry: number) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET is_vip = ?, vip_expiry = ? WHERE id = ?`, [\n isVip ? 1 : 0,\n expiry,\n userId,\n ]);\n};\n\nconst getUserVipTasksCompleted = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT package_id, count, last_completion_time FROM ${TABLES.user_vip_tasks_completed} WHERE user_id = ?`,\n [userId],\n );\n return result.length > 0\n ? { packageId: result[0].package_id, count: result[0].count, lastCompletionTime: result[0].last_completion_time }\n : { packageId: null, count: 0, lastCompletionTime: 0 };\n};\n\nconst setUserVipTasksCompleted = async (\n userId: number,\n packageId: number,\n count: number,\n lastCompletionTime: number,\n) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.user_vip_tasks_completed} (user_id, package_id, count, last_completion_time) VALUES (?, ?, ?, ?)`,\n [userId, packageId, count, lastCompletionTime],\n );\n};\n\nconst getUserGeneralTasksCompleted = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT date, count FROM ${TABLES.user_general_tasks_completed} WHERE user_id = ?`,\n [userId],\n );\n return result.length > 0 ? { date: result[0].date, count: result[0].count } : { date: null, count: 0 };\n};\n\nconst setUserGeneralTasksCompleted = async (userId: number, date: string, count: number) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.user_general_tasks_completed} (user_id, date, count) VALUES (?, ?, ?)`,\n [userId, date, count],\n );\n};\n\nconst getCompletedTasks = async (userId: number) => {\n const result = await sqlite.execute(`SELECT task_id FROM ${TABLES.completed_tasks} WHERE user_id = ?`, [userId]);\n return new Set(result.map(row => row.task_id));\n};\n\nconst addCompletedTask = async (userId: number, taskId: number) => {\n await sqlite.execute(`INSERT INTO ${TABLES.completed_tasks} (user_id, task_id) VALUES (?, ?)`, [userId, taskId]);\n};\n\nconst getUserCurrentTask = async (userId: number) => {\n const result = await sqlite.execute(`SELECT task_id FROM ${TABLES.user_current_task} WHERE user_id = ?`, [userId]);\n return result.length > 0 ? result[0].task_id : null;\n};\n\nconst setUserCurrentTask = async (userId: number, taskId: number) => {\n await sqlite.execute(`INSERT OR REPLACE INTO ${TABLES.user_current_task} (user_id, task_id) VALUES (?, ?)`, [\n userId,\n taskId,\n ]);\n};\n\nconst deleteUserCurrentTask = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.user_current_task} WHERE user_id = ?`, [userId]);\n};\n\nconst getUserTaskStartTime = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT task_id, timestamp FROM ${TABLES.user_task_start_time} WHERE user_id = ?`,\n [userId],\n );\n return result.length > 0 ? { taskId: result[0].task_id, timestamp: result[0].timestamp } : null;\n};\n\nconst setUserTaskStartTime = async (userId: number, taskId: number, timestamp: number) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.user_task_start_time} (user_id, task_id, timestamp) VALUES (?, ?, ?)`,\n [userId, taskId, timestamp],\n );\n};\n\nconst deleteUserTaskStartTime = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.user_task_start_time} WHERE user_id = ?`, [userId]);\n};\n\nconst updateUserTaskBalance = async (userId: number, amount: number) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET task_balance = task_balance + ? WHERE id = ?`, [amount, userId]);\n};\n\nconst getUserDepositState = async (userId: number) => {\n const result = await sqlite.execute(`SELECT step, amount, txid FROM ${TABLES.user_deposit_state} WHERE user_id = ?`, [\n userId,\n ]);\n return result.length > 0 ? { step: result[0].step, amount: result[0].amount, txid: result[0].txid } : null;\n};\n\nconst setUserDepositState = async (\n userId: number,\n step: string,\n amount: number | null = null,\n txid: string | null = null,\n) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.user_deposit_state} (user_id, step, amount, txid) VALUES (?, ?, ?, ?)`,\n [userId, step, amount, txid],\n );\n};\n\nconst deleteUserDepositState = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.user_deposit_state} WHERE user_id = ?`, [userId]);\n};\n\nconst getUserDailyDepositCount = async (userId: number) => {\n const result = await sqlite.execute(`SELECT date, count FROM ${TABLES.user_daily_deposit_count} WHERE user_id = ?`, [\n userId,\n ]);\n return result.length > 0 ? { date: result[0].date, count: result[0].count } : { date: null, count: 0 };\n};\n\nconst setUserDailyDepositCount = async (userId: number, date: string, count: number) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.user_daily_deposit_count} (user_id, date, count) VALUES (?, ?, ?)`,\n [userId, date, count],\n );\n};\n\nconst setPendingDeposit = async (\n userId: number,\n amount: number,\n txid: string,\n time: number,\n username: string,\n firstName: string,\n) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.pending_deposits} (user_id, amount, txid, time, username, first_name) VALUES (?, ?, ?, ?, ?, ?)`,\n [userId, amount, txid, time, username, firstName],\n );\n};\n\nconst getPendingDeposit = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT amount, txid, time, username, first_name FROM ${TABLES.pending_deposits} WHERE user_id = ?`,\n [userId],\n );\n return result.length > 0\n ? {\n amount: result[0].amount,\n txid: result[0].txid,\n time: result[0].time,\n username: result[0].username,\n first_name: result[0].first_name,\n }\n : null;\n};\n\nconst deletePendingDeposit = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.pending_deposits} WHERE user_id = ?`, [userId]);\n};\n\nconst getWithdrawMethod = async (userId: number) => {\n const result = await sqlite.execute(`SELECT withdraw_method, withdraw_number FROM ${TABLES.users} WHERE id = ?`, [\n userId,\n ]);\n return result.length > 0\n ? { method: result[0].withdraw_method, number: result[0].withdraw_number }\n : { method: null, number: null };\n};\n\nconst setWithdrawMethod = async (userId: number, method: string, number: string | null) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET withdraw_method = ?, withdraw_number = ? WHERE id = ?`, [\n method,\n number,\n userId,\n ]);\n};\n\nconst deleteWithdrawMethod = async (userId: number) => {\n await sqlite.execute(`UPDATE ${TABLES.users} SET withdraw_method = NULL, withdraw_number = NULL WHERE id = ?`, [\n userId,\n ]);\n};\n\nconst setUserWithdrawRequest = async (\n userId: number,\n amount: number,\n method: string,\n number: string,\n username: string,\n firstName: string,\n) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.withdraw_requests} (user_id, amount, method, number, username, first_name) VALUES (?, ?, ?, ?, ?, ?)`,\n [userId, amount, method, number, username, firstName],\n );\n};\n\nconst getWithdrawRequest = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT amount, method, number, username, first_name FROM ${TABLES.withdraw_requests} WHERE user_id = ?`,\n [userId],\n );\n return result.length > 0\n ? {\n amount: result[0].amount,\n method: result[0].method,\n number: result[0].number,\n username: result[0].username,\n first_name: result[0].first_name,\n }\n : null;\n};\n\nconst deleteWithdrawRequest = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.withdraw_requests} WHERE user_id = ?`, [userId]);\n};\n\nconst getAdminState = async (adminId: number) => {\n const result = await sqlite.execute(\n `SELECT state, target_user_id, action, task_data, vip_data FROM ${TABLES.admin_states} WHERE admin_id = ?`,\n [adminId],\n );\n if (result.length > 0) {\n const row = result[0];\n return {\n state: row.state,\n targetUserId: row.target_user_id,\n action: row.action,\n taskData: row.task_data ? JSON.parse(row.task_data) : null,\n vipData: row.vip_data ? JSON.parse(row.vip_data) : null,\n };\n }\n return null;\n};\n\nconst setAdminState = async (adminId: number, stateObj: any) => {\n const { state, targetUserId, action, taskData, vipData } = stateObj;\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.admin_states} \n (admin_id, state, target_user_id, action, task_data, vip_data) \n VALUES (?, ?, ?, ?, ?, ?)`,\n [\n adminId,\n state,\n targetUserId || null,\n action || null,\n taskData ? JSON.stringify(taskData) : null,\n vipData ? JSON.stringify(vipData) : null,\n ],\n );\n};\n\nconst deleteAdminState = async (adminId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.admin_states} WHERE admin_id = ?`, [adminId]);\n};\n\nconst getLiveChatState = async (userId: number) => {\n const result = await sqlite.execute(\n `SELECT state, target_user_id FROM ${TABLES.live_chat_states} WHERE user_id = ?`,\n [userId],\n );\n return result.length > 0 ? { state: result[0].state, targetUserId: result[0].target_user_id } : null;\n};\n\nconst setLiveChatState = async (userId: number, state: string, targetUserId: number | null = null) => {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.live_chat_states} (user_id, state, target_user_id) VALUES (?, ?, ?)`,\n [userId, state, targetUserId],\n );\n};\n\nconst deleteLiveChatState = async (userId: number) => {\n await sqlite.execute(`DELETE FROM ${TABLES.live_chat_states} WHERE user_id = ?`, [userId]);\n};\n\n// --- Bot Setup ---\nconst bot = new Bot(BOT_TOKEN);\n\nbot.use(session({\n initial: () => ({}),\n}));\nbot.use(conversations());\n\n// Middleware to check for banned users and channel membership\nbot.use(async (ctx, next) => {\n const userId = ctx.from?.id;\n if (!userId) return next();\n\n const chatType = ctx.chat?.type;\n\n await ensureUserExists(userId, ctx.from?.username || \"\", ctx.from?.first_name || \"ব্যবহারকারী\");\n\n if (userId === ADMIN_ID && chatType === \"private\") {\n return next();\n }\n\n if (await isUserBanned(userId)) {\n return ctx.reply(\"🚫 দুঃখিত! আপনাকে এই বট ব্যবহার থেকে নিষিদ্ধ করা হয়েছে।\");\n }\n\n try {\n const chatMember = await bot.api.getChatMember(MANDATORY_CHANNEL_ID, userId);\n const isMember = [\"member\", \"administrator\", \"creator\"].includes(chatMember.status);\n\n if (!isMember) {\n const channelLink = `https://t.me/${MANDATORY_CHANNEL_ID.replace(\"@\", \"\")}`;\n if (ctx.message && \"text\" in ctx.message && ctx.message.text?.startsWith(\"/start \")) {\n const args = ctx.message.text.split(\" \").slice(1);\n if (args.length > 0 && !isNaN(parseInt(args[0]))) {\n await setUserReferralTemp(userId, parseInt(args[0]));\n }\n }\n return ctx.reply(\n \"বট ব্যবহার করার জন্য আপনাকে প্রথমে আমাদের চ্যানেলে জয়েন করতে হবে।\",\n {\n reply_markup: {\n inline_keyboard: [\n [{ text: \"🔗 জয়েন করুন\", url: channelLink }],\n [{ text: \"✅ যাচাই করুন\", callback_data: \"check_channel_membership\" }],\n ],\n },\n },\n );\n }\n } catch (error) {\n console.error(\"Error checking channel membership:\", error);\n const channelLink = `https://t.me/${MANDATORY_CHANNEL_ID.replace(\"@\", \"\")}`;\n return ctx.reply(\n \"চ্যানেল মেম্বারশিপ যাচাই করতে সমস্যা হয়েছে। অনুগ্রহ করে নিশ্চিত করুন আপনি চ্যানেলে জয়েন করেছেন।\",\n {\n reply_markup: {\n inline_keyboard: [\n [{ text: \"🔗 জয়েন করুন\", url: channelLink }],\n [{ text: \"✅ যাচাই করুন\", callback_data: \"check_channel_membership\" }],\n ],\n },\n },\n );\n }\n\n return next();\n});\n\n// Action to recheck channel membership\nbot.callbackQuery(\"check_channel_membership\", async (ctx) => {\n await ctx.answerCallbackQuery();\n const userId = ctx.from.id;\n\n try {\n const chatMember = await ctx.api.getChatMember(MANDATORY_CHANNEL_ID, userId);\n const isMember = [\"member\", \"administrator\", \"creator\"].includes(chatMember.status);\n\n if (isMember) {\n await ctx.deleteMessage();\n await ctx.reply(\"✅ আপনি চ্যানেলে সফলভাবে জয়েন করেছেন! এখন আপনি বট ব্যবহার করতে পারবেন।\");\n\n const referId = await getUserReferralTemp(userId);\n if (referId) {\n await deleteUserReferralTemp(userId);\n\n const userUsername = ctx.from.username || \"\";\n const userName = ctx.from.first_name || \"ব্যবহারকারী\";\n const nameLink = userUsername\n ? `[${userName}](https://t.me/${userUsername})`\n : userName;\n\n if (referId !== userId && !(await isUserReferred(userId))) {\n await addReferral(userId, referId);\n await updateUserBalance(referId, 12);\n\n await bot.api.sendMessage(referId, `🎉 ${nameLink} বটে জয়েন করেছেন আপনার রেফার লিংক ব্যবহার করে।`, {\n parse_mode: \"Markdown\",\n });\n await bot.api.sendMessage(\n ADMIN_ID,\n `📢 নতুন রেফার:\\n👤 ${nameLink} (ID: ${userId})\\n🔗 রেফার করেছেন: ${referId}`,\n { parse_mode: \"Markdown\" },\n );\n\n await ctx.reply(\"✅ আপনি সফলভাবে রেফার হয়েছেন!\");\n }\n }\n\n if (!(await getUserFreeTaskStartDate(userId))) {\n await setUserFreeTaskStartDate(userId, Date.now());\n }\n\n return showMainMenu(ctx);\n } else {\n const channelLink = `https://t.me/${MANDATORY_CHANNEL_ID.replace(\"@\", \"\")}`;\n return ctx.reply(\n \"আপনি এখনো চ্যানেলে জয়েন করেননি অথবা আপনার মেম্বারশিপ যাচাই করা যায়নি।\",\n {\n reply_markup: {\n inline_keyboard: [\n [{ text: \"🔗 জয়েন করুন\", url: channelLink }],\n [{ text: \"✅ যাচাই করুন\", callback_data: \"check_channel_membership\" }],\n ],\n },\n },\n );\n }\n } catch (error) {\n console.error(\"Error rechecking channel membership:\", error);\n const channelLink = `https://t.me/${MANDATORY_CHANNEL_ID.replace(\"@\", \"\")}`;\n return ctx.reply(\n \"চ্যানেল মেম্বারশিপ যাচাই করতে সমস্যা হয়েছে। অনুগ্রহ করে নিশ্চিত করুন আপনি চ্যানেলে জয়েন করেছেন।\",\n {\n reply_markup: {\n inline_keyboard: [\n [{ text: \"🔗 জয়েন করুন\", url: channelLink }],\n [{ text: \"✅ যাচাই করুন\", callback_data: \"check_channel_membership\" }],\n ],\n },\n },\n );\n }\n});\n\n// --- Start Command ---\nbot.command(\"start\", async (ctx) => {\n const userId = ctx.from.id;\n const args = ctx.message.text.split(\" \").slice(1);\n const userUsername = ctx.from.username || \"\";\n const userName = ctx.from.first_name || \"ব্যবহারকারী\";\n const nameLink = userUsername\n ? `[${userName}](https://t.me/${userUsername})`\n : userName;\n\n await ensureUserExists(userId, userUsername, userName);\n\n const referralInfo = await getReferralInfo(userId);\n if (referralInfo.blocked_until > Date.now()) {\n return ctx.reply(\"❌ আপনার রেফার লিংক বর্তমানে নিষিদ্ধ রয়েছে। দয়া করে পরে চেষ্টা করুন।\");\n }\n\n if (args.length > 0) {\n const referId = parseInt(args[0]);\n try {\n const chatMember = await bot.api.getChatMember(MANDATORY_CHANNEL_ID, userId);\n const isMember = [\"member\", \"administrator\", \"creator\"].includes(chatMember.status);\n if (isMember) {\n if (referId === userId)\n return ctx.reply(\"❌ নিজেকে রেফার করা যাবে না!\");\n if (await isUserReferred(userId))\n return ctx.reply(\"❗ আপনি আগেই রেফার হয়েছেন।\");\n\n await addReferral(userId, referId);\n await updateUserBalance(referId, 12);\n\n await bot.api.sendMessage(referId, `🎉 ${nameLink} বটে জয়েন করেছেন আপনার রেফার লিংক ব্যবহার করে।`, {\n parse_mode: \"Markdown\",\n });\n await bot.api.sendMessage(\n ADMIN_ID,\n `📢 নতুন রেফার:\\n👤 ${nameLink} (ID: ${userId})\\n🔗 রেফার করেছেন: ${referId}`,\n { parse_mode: \"Markdown\" },\n );\n\n await ctx.reply(\"✅ আপনি সফলভাবে রেফার হয়েছেন!\");\n } else {\n await setUserReferralTemp(userId, referId);\n }\n } catch (error) {\n console.error(\"Error during start command channel membership check:\", error);\n }\n } else {\n try {\n const chatMember = await bot.api.getChatMember(MANDATORY_CHANNEL_ID, userId);\n const isMember = [\"member\", \"administrator\", \"creator\"].includes(chatMember.status);\n if (isMember) {\n await bot.api.sendMessage(ADMIN_ID, `👤 নতুন ইউজার রেফারেল ছাড়া জয়েন করেছেন:\\nনাম: ${userName} (ID: ${userId})`, {\n parse_mode: \"Markdown\",\n });\n }\n } catch (error) {\n console.error(\"Error notifying admin for non-referral join:\", error);\n }\n }\n\n if (!(await getUserFreeTaskStartDate(userId))) {\n await setUserFreeTaskStartDate(userId, Date.now());\n }\n\n return showMainMenu(ctx);\n});\n\n// --- Main Menu ---\nfunction showMainMenu(ctx: any) {\n const userId = ctx.from.id;\n const keyboard = [\n [\"💰 রেফার\", \"📥 ডিপোজিট\"],\n [\"📤 উইথড্র\", \"⭐ ভিআইপি\"],\n [\"👤 একাউন্ট\", \"📝 টাস্ক\"],\n [\"📞 সাপোর্ট\"],\n ];\n\n if (userId === ADMIN_ID) {\n keyboard.push([\"👑 Admin\"]);\n }\n\n return ctx.reply(\"🥳 মেনু থেকে একটি অপশন বেছে নিন:\", {\n reply_markup: {\n keyboard: keyboard,\n resize_keyboard: true,\n },\n });\n}\n\n// --- Handlers for Main Menu Buttons ---\nbot.hears(\"💰 রেফার\", async (ctx) => {\n const userId = ctx.from.id;\n const botUsername = ctx.me.username;\n const referLink = `https://t.me/${botUsername}?start=${userId}`;\n const referralInfo = await getReferralInfo(userId);\n const reward = referralInfo.count;\n\n if (referralInfo.blocked_until > Date.now()) {\n return ctx.reply(\"❌ আপনার রেফার লিংক বর্তমানে নিষিদ্ধ রয়েছে। দয়া করে পরে চেষ্টা করুন।\");\n }\n\n await ctx.reply(`🤝 আপনার রেফার লিঙ্ক:\\n${referLink}\\n\\n🎯 মোট রেফার: ${reward}\\n💰প্রতি সফল রেফারে ১২ টাকা`, {\n reply_markup: {\n inline_keyboard: [\n [{\n text: \"🔗 শেয়ার করুন\",\n url: `https://t.me/share/url?url=${encodeURIComponent(referLink)}&text=${\n encodeURIComponent(\"Waho Earn! প্রতিদিন ফ্রি ১০ টাকা করে পান\")\n }`,\n }],\n ],\n },\n });\n});\n\nbot.hears(\"👤 একাউন্ট\", async (ctx) => {\n const userId = ctx.from.id;\n const user = await getUser(userId);\n if (!user) {\n return ctx.reply(\"আপনার তথ্য পাওয়া যায়নি। অনুগ্রহ করে /start ব্যবহার করুন।\");\n }\n\n const userUsername = user.username || \"সেট করা হয়নি\";\n const userName = user.first_name || \"সেট করা হয়নি\";\n const referralInfo = await getReferralInfo(userId);\n const reward = referralInfo.count;\n const referBalance = referralInfo.reward;\n const balance = user.balance;\n const taskBalance = user.task_balance;\n const depositBalance = user.deposit_balance;\n const { number, method } = await getWithdrawMethod(userId);\n const isVip = user.is_vip;\n const vipExpiryDate = user.vip_expiry\n ? new Date(user.vip_expiry).toLocaleString(\"bn-BD\", { timeZone: \"Asia/Dhaka\" })\n : \"N/A\";\n\n const msg = `🧾 *আপনার একাউন্ট তথ্য*\\n\\n`\n + `👤 *নাম:* ${userName}\\n`\n + `🔗 *ইউজারনেম:* ${userUsername}\\n`\n + `🆔 *ইউজার আইডি:* \\`${userId}\\`\\n\\n`\n + `🎯 *মোট রেফার:* ${reward}\\n`\n + `💵 *রেফার ব্যালেন্স:* ${referBalance}৳\\n`\n + `💰 *মোট ব্যালেন্স:* ${balance}৳\\n`\n + `📝 *টাস্ক ব্যালেন্স:* ${taskBalance}৳\\n`\n + `📥 *ডিপোজিট ব্যালেন্স:* ${depositBalance}৳\\n\\n`\n + `🏦 *উইথড্র মেথড:* ${method || \"সেট করা হয়নি\"}\\n`\n + `📱 *উইথড্র নম্বর:* ${number || \"সেট করা হয়নি\"}\\n\\n`\n + `🌟 *ভিআইপি সদস্য:* ${isVip ? \"হ্যাঁ ✅\" : \"না ❌\"}\\n`\n + `⏳ *ভিআইপি মেয়াদ:* ${vipExpiryDate}`;\n\n ctx.reply(msg, { parse_mode: \"Markdown\" });\n});\n\n// --- Deposit Flow ---\nbot.hears(\"📥 ডিপোজিট\", async (ctx) => {\n const userId = ctx.from.id;\n const today = new Date().toISOString().slice(0, 10);\n const dailyDepositInfo = await getUserDailyDepositCount(userId);\n\n if (dailyDepositInfo.date !== today) {\n await setUserDailyDepositCount(userId, today, 0);\n dailyDepositInfo.count = 0;\n }\n\n const remainingDeposits = 3 - dailyDepositInfo.count;\n\n if (dailyDepositInfo.count >= 3) {\n return ctx.reply(\"⚠️ সতর্কবাণী: আপনি প্রতিদিন ৩ বারের বেশি ডিপোজিট করতে পারবেন না।\");\n }\n\n await setUserDepositState(ctx.from.id, \"awaiting_amount\");\n const message = `ডিপোজিট লিমিট রয়েছে: ${remainingDeposits}/3 (প্রতিদিন)\\n\\n`\n + `আপনি কত টাকা ডিপোজিট করতে চান? (শুধুমাত্র ভিআইপি কেনার জন্য এই ব্যালেন্স ব্যবহার করা যাবে)\\n`\n + `অনুগ্রহ করে টাকার পরিমাণ লিখুন:`;\n\n return ctx.reply(message, {\n parse_mode: \"Markdown\",\n reply_markup: {\n keyboard: [[\"বাতিল\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n});\n\n// --- VIP System ---\nbot.hears(\"⭐ ভিআইপি\", async (ctx) => {\n const userId = ctx.from.id;\n const isVip = await isUserVip(userId);\n const user = await getUser(userId);\n\n if (isVip) {\n const expiryDate = new Date(user!.vip_expiry).toLocaleString(\"bn-BD\", { timeZone: \"Asia/Dhaka\" });\n return ctx.reply(`আপনি ইতিমধ্যেই একজন ভিআইপি সদস্য!\\nআপনার ভিআইপি মেয়াদ শেষ হবে: ${expiryDate}`);\n }\n\n const vipPackages = await getVipPackages();\n let message = \"👑 *আমাদের ভিআইপি প্যাকেজসমূহ:*\\n\\n\";\n const keyboard = [];\n\n vipPackages.forEach(pkg => {\n message += `*${pkg.name}*\\n`;\n message += ` 💸 মূল্য: ${pkg.price}৳\\n`;\n message += ` 📝 দৈনিক টাস্ক: ${pkg.tasks}টি\\n`;\n message += ` 🗓️ মেয়াদ: ${pkg.durationDays} দিন\\n\\n`;\n keyboard.push([{ text: `কিনুন: ${pkg.name} (${pkg.price}৳)`, callback_data: `buy_vip_${pkg.id}` }]);\n });\n\n keyboard.push([{ text: \"মেইন মেনু\", callback_data: \"main_menu_from_task\" }]);\n\n await ctx.reply(message, {\n parse_mode: \"Markdown\",\n reply_markup: {\n inline_keyboard: keyboard,\n },\n });\n});\n\nbot.callbackQuery(/buy_vip_(\\d+)/, async (ctx) => {\n await ctx.answerCallbackQuery();\n const userId = ctx.from.id;\n const packageId = parseInt(ctx.match![1]);\n const vipPackages = await getVipPackages();\n const pkg = vipPackages.find(p => p.id === packageId);\n\n if (!pkg) {\n return ctx.reply(\"দুঃখিত! এই ভিআইপি প্যাকেজটি খুঁজে পাওয়া যায়নি।\");\n }\n\n const userDeposit = await getUserDepositBalance(userId);\n\n if (userDeposit < pkg.price) {\n return ctx.reply(\n `❌ আপনার পর্যাপ্ত ডিপোজিট ব্যালেন্স নেই। আপনার বর্তমান ডিপোজিট ব্যালেন্স: ${userDeposit}৳। এই প্যাকেজের জন্য ${pkg.price}৳ প্রয়োজন।`,\n );\n }\n\n await updateUserDepositBalance(userId, -pkg.price);\n\n const expiryTimestamp = Date.now() + pkg.durationDays * 24 * 60 * 60 * 1000;\n await setVipStatus(userId, true, expiryTimestamp);\n\n await setUserVipTasksCompleted(userId, pkg.id, 0, 0);\n\n await ctx.reply(\n `🎉 অভিনন্দন! আপনি সফলভাবে *${pkg.name}* প্যাকেজটি কিনেছেন!\\nআপনার ভিআইপি মেয়াদ ${pkg.durationDays} দিনের জন্য সক্রিয় হয়েছে।`,\n { parse_mode: \"Markdown\" },\n );\n await ctx.reply(`আপনার বর্তমান ডিপোজিট ব্যালেন্স: ${await getUserDepositBalance(userId)}৳`);\n\n await bot.api.sendMessage(\n ADMIN_ID,\n `👑 নতুন ভিআইপি সদস্য: ${ctx.from.first_name} (ID: ${userId}) কিনেছেন ${pkg.name} প্যাকেজ।`,\n );\n return showMainMenu(ctx);\n});\n\n// --- Task System ---\nasync function sendTaskPage(ctx: any, taskId?: number) {\n const userId = ctx.from.id;\n const userCompletedTasks = await getCompletedTasks(userId);\n const isVipUser = await isUserVip(userId);\n const today = new Date().toISOString().slice(0, 10);\n const allTasks = await getTasks();\n const vipPackages = await getVipPackages();\n\n let availableTasks = allTasks.filter(task => !userCompletedTasks.has(task.id));\n\n if (!isVipUser) {\n const freeTaskStartDate = await getUserFreeTaskStartDate(userId);\n const daysSinceStart = Math.floor((Date.now() - freeTaskStartDate) / (24 * 60 * 60 * 1000));\n\n if (daysSinceStart >= 10) {\n await deleteUserCurrentTask(userId);\n return ctx.reply(\"দুঃখিত! আপনার ফ্রি টাস্কের মেয়াদ শেষ হয়ে গেছে। ভিআইপি প্যাকেজ কিনে আরও টাস্ক সম্পন্ন করুন।\");\n }\n\n const dailyGeneralTaskInfo = await getUserGeneralTasksCompleted(userId);\n if (dailyGeneralTaskInfo.date !== today) {\n await setUserGeneralTasksCompleted(userId, today, 0);\n dailyGeneralTaskInfo.count = 0;\n }\n\n if (dailyGeneralTaskInfo.count >= 2) {\n await deleteUserCurrentTask(userId);\n return ctx.reply(\n \"দুঃখিত! আপনি আজকের জন্য আপনার সর্বোচ্চ সংখ্যক টাস্ক সম্পন্ন করেছেন (২টি)। আগামীকাল আবার চেষ্টা করুন অথবা ভিআইপি প্যাকেজ কিনুন।\",\n );\n }\n }\n\n if (isVipUser) {\n const vipInfo = await getUserVipTasksCompleted(userId);\n const currentVipPackage = vipPackages.find(p => p.id === vipInfo?.packageId);\n\n const now = Date.now();\n const startOfDay = new Date().setHours(0, 0, 0, 0);\n\n if (\n currentVipPackage && vipInfo.count < currentVipPackage.tasks\n && (!vipInfo.lastCompletionTime || vipInfo.lastCompletionTime < startOfDay)\n ) {\n const vipTaskReward = 15;\n const vipTaskId = 9999;\n const vipDailyTask = {\n id: vipTaskId,\n name: `দৈনিক ভিআইপি টাস্ক ( ${vipInfo.count + 1}/${currentVipPackage.tasks} )`,\n reward: vipTaskReward,\n description: `ভিআইপি সদস্যরা দৈনিক এই টাস্কটি সম্পন্ন করতে পারবেন। (আজকের জন্য ${\n currentVipPackage.tasks - vipInfo.count\n }টি টাস্ক বাকি)`,\n link: \"https://www.google.com\",\n minTime: 15,\n };\n availableTasks.unshift(vipDailyTask);\n }\n }\n\n if (availableTasks.length === 0) {\n await deleteUserCurrentTask(userId);\n return ctx.reply(\"দুঃখিত! বর্তমানে আপনার জন্য কোনো টাস্ক উপলব্ধ নেই।\");\n }\n\n let currentTaskIndex = -1;\n if (taskId) {\n currentTaskIndex = availableTasks.findIndex(t => t.id === taskId);\n }\n\n if (currentTaskIndex === -1 || taskId === undefined) {\n currentTaskIndex = 0;\n }\n\n const currentTask = availableTasks[currentTaskIndex];\n if (!currentTask) {\n return ctx.reply(\"টাস্ক খুঁজে পাওয়া যায়নি।\");\n }\n\n await setUserCurrentTask(userId, currentTask.id);\n\n let keyboard = [];\n if (currentTask.link) {\n keyboard.push([{ text: \"🔗 ভিজিট করুন\", callback_data: `visit_task_${currentTask.id}` }]);\n }\n keyboard.push([\n { text: \"⬅️ আগের টাস্ক\", callback_data: `prev_task_${currentTask.id}` },\n { text: \"পরের টাস্ক ➡️\", callback_data: `next_task_${currentTask.id}` },\n ]);\n keyboard.push([{ text: \"টাস্ক সম্পূর্ণ করেছি ✅\", callback_data: `complete_task_${currentTask.id}` }]);\n keyboard.push([{ text: \"মেইন মেনু\", callback_data: \"main_menu_from_task\" }]);\n\n let taskMsg = `📝 *টাস্ক: ${currentTask.name}*\\n\\n`\n + `💰 *রিওয়ার্ড:* ${currentTask.reward}৳\\n`\n + `📄 *বিবরণ:* ${currentTask.description}\\n`;\n\n if (currentTask.minTime > 0) {\n taskMsg += `⏳ *সর্বনিম্ন সময়:* ${currentTask.minTime} সেকেন্ড\\n`;\n }\n\n await ctx.reply(taskMsg, {\n parse_mode: \"Markdown\",\n reply_markup: { inline_keyboard: keyboard },\n });\n}\n\nbot.hears(\"📝 টাস্ক\", async (ctx) => {\n await sendTaskPage(ctx);\n});\n\nbot.callbackQuery(/visit_task_(\\d+)/, async (ctx) => {\n await ctx.answerCallbackQuery();\n const userId = ctx.from.id;\n const taskId = parseInt(ctx.match![1]);\n const allTasks = await getTasks();\n const vipPackages = await getVipPackages();\n\n let task = allTasks.find(t => t.id === taskId);\n\n if (taskId === 9999) {\n const isVipUser = await isUserVip(userId);\n const vipInfo = await getUserVipTasksCompleted(userId);\n const currentVipPackage = vipPackages.find(p => p.id === vipInfo?.packageId);\n const lastVipTaskCompletion = vipInfo?.lastCompletionTime;\n const now = Date.now();\n const startOfDay = new Date().setHours(0, 0, 0, 0);\n\n if (\n isVipUser && currentVipPackage && vipInfo.count < currentVipPackage.tasks\n && (!lastVipTaskCompletion || lastVipTaskCompletion < startOfDay)\n ) {\n task = {\n id: 9999,\n name: `দৈনিক ভিআইপি টাস্ক`,\n reward: 15,\n description: `ভিআইপি সদস্যরা দৈনিক এই টাস্কটি সম্পন্ন করতে পারবেন।`,\n link: \"https://www.google.com\",\n minTime: 15,\n };\n } else {\n return ctx.reply(\"এই ভিআইপি টাস্কটি এখন আপনার জন্য উপলব্ধ নয়।\");\n }\n }\n\n if (!task) {\n return ctx.reply(\"লিংক খুঁজে পাওয়া যায়নি।\");\n }\n\n await setUserTaskStartTime(userId, task.id, Date.now());\n\n await ctx.reply(\n `আপনার টাস্ক লিংকঃ ${task.link}\\nলিংকে ভিজিট করুন এবং ${task.minTime} সেকেন্ড পর বেরিয়ে আসুন। তারপর টাস্ক সম্পূর্ণ করেছি বাটনে ক্লিক করুন`,\n {\n reply_markup: {\n inline_keyboard: [\n [{ text: \"টাস্ক সম্পূর্ণ করেছি ✅\", callback_data: `complete_task_${task.id}` }],\n ],\n },\n },\n );\n});\n\nbot.callbackQuery(/complete_task_(\\d+)/, async (ctx) => {\n const userId = ctx.from.id;\n await ctx.answerCallbackQuery();\n const clickedTaskId = parseInt(ctx.match![1]);\n const currentTaskIdForUser = await getUserCurrentTask(userId);\n const today = new Date().toISOString().slice(0, 10);\n const allTasks = await getTasks();\n const vipPackages = await getVipPackages();\n\n if (currentTaskIdForUser !== clickedTaskId) {\n return ctx.reply(\"আপনি বর্তমানে এই টাস্কে নেই অথবা টাস্কটি পরিবর্তিত হয়েছে। অনুগ্রহ করে টাস্ক মেনু থেকে সঠিক টাস্ক নির্বাচন করুন।\");\n }\n\n let task = allTasks.find(t => t.id === clickedTaskId);\n const isVipUser = await isUserVip(userId);\n let isVipTask = false;\n\n if (clickedTaskId === 9999) {\n if (!isVipUser) {\n return ctx.reply(\"আপনি ভিআইপি সদস্য নন, এই টাস্কটি সম্পন্ন করতে পারবেন না।\");\n }\n const vipInfo = await getUserVipTasksCompleted(userId);\n const currentVipPackage = vipPackages.find(p => p.id === vipInfo?.packageId);\n const lastVipTaskCompletion = vipInfo?.lastCompletionTime;\n const now = Date.now();\n const startOfDay = new Date().setHours(0, 0, 0, 0);\n\n if (\n !currentVipPackage || vipInfo.count >= currentVipPackage.tasks\n || (lastVipTaskCompletion && lastVipTaskCompletion >= startOfDay)\n ) {\n return ctx.reply(\"আজকের জন্য আপনার ভিআইপি টাস্ক সম্পন্ন হয়ে গেছে অথবা আপনার প্যাকেজের টাস্ক সীমা অতিক্রম করা হয়েছে।\");\n }\n\n task = {\n id: 9999,\n name: `দৈনিক ভিআইপি টাস্ক`,\n reward: 15,\n minTime: 15,\n // Default description and link if needed, though they might not be used here\n description: `দৈনিক ভিআইপি টাস্ক`,\n link: \"https://www.google.com\",\n };\n isVipTask = true;\n } else if (!isVipUser) {\n const freeTaskStartDate = await getUserFreeTaskStartDate(userId);\n const daysSinceStart = Math.floor((Date.now() - freeTaskStartDate) / (24 * 60 * 60 * 1000));\n\n if (daysSinceStart >= 10) {\n return ctx.reply(\"আপনার ফ্রি টাস্কের মেয়াদ শেষ হয়ে গেছে। ভিআইপি প্যাকেজ কিনে আরও টাস্ক সম্পন্ন করুন।\");\n }\n\n const dailyGeneralTaskInfo = await getUserGeneralTasksCompleted(userId);\n if (dailyGeneralTaskInfo.date !== today) {\n await setUserGeneralTasksCompleted(userId, today, 0);\n dailyGeneralTaskInfo.count = 0;\n }\n if (dailyGeneralTaskInfo.count >= 2) {\n return ctx.reply(\n \"আপনি আজকের জন্য আপনার সর্বোচ্চ সংখ্যক টাস্ক সম্পন্ন করেছেন (২টি)। আগামীকাল আবার চেষ্টা করুন অথবা ভিআইপি প্যাকেজ কিনুন।\",\n );\n }\n dailyGeneralTaskInfo.count++;\n await setUserGeneralTasksCompleted(userId, dailyGeneralTaskInfo.date, dailyGeneralTaskInfo.count);\n }\n\n if (!task) {\n return ctx.reply(\"টاس্ক খুঁজে পাওয়া যায়নি।\");\n }\n\n const userTaskInfo = await getUserTaskStartTime(userId);\n if (!userTaskInfo || userTaskInfo.taskId !== clickedTaskId) {\n return ctx.reply(\"⚠️ প্রথমে \\\"🔗 ভিজিট করুন\\\" বাটনে ক্লিক করে টাস্কটি শুরু করুন।\");\n }\n\n const timeElapsed = (Date.now() - userTaskInfo.timestamp) / 1000;\n\n if (task.minTime > 0 && timeElapsed < task.minTime) {\n const remainingTime = Math.ceil(task.minTime - timeElapsed);\n return ctx.reply(`❌ আপনি টাস্ক সম্পূর্ণ করেননি। আরও ${remainingTime} সেকেন্ড অপেক্ষা করুন।`);\n }\n\n if (isVipTask) {\n const vipInfo = await getUserVipTasksCompleted(userId);\n await setUserVipTasksCompleted(userId, vipInfo.packageId!, vipInfo.count + 1, Date.now());\n await updateUserTaskBalance(userId, task.reward);\n await updateUserBalance(userId, task.reward);\n await ctx.reply(\n `🎉 অভিনন্দন! আপনি \"${task.name}\" টাস্কটি সম্পূর্ণ করেছেন এবং ${task.reward}৳ আপনার টাস্ক ব্যালেন্স ও মূল ব্যালেন্সের সাথে যোগ হয়েছে।`,\n );\n } else {\n await addCompletedTask(userId, task.id);\n await updateUserTaskBalance(userId, task.reward);\n await updateUserBalance(userId, task.reward);\n await ctx.reply(\n `🎉 অভিনন্দন! আপনি \"${task.name}\" টাস্কটি সম্পূর্ণ করেছেন এবং ${task.reward}৳ আপনার টাস্ক ব্যালেন্স ও মূল ব্যালেন্সের সাথে যোগ হয়েছে।`,\n );\n }\n\n await deleteUserCurrentTask(userId);\n await deleteUserTaskStartTime(userId);\n\n await sendTaskPage(ctx);\n});\n\nbot.callbackQuery(/prev_task_(\\\\d+)/, async (ctx) => {\n await ctx.answerCallbackQuery();\n const userId = ctx.from.id;\n const currentTaskId = parseInt(ctx.match![1]);\n const userCompletedTasks = await getCompletedTasks(userId);\n const isVipUser = await isUserVip(userId);\n const allTasks = await getTasks();\n const vipPackages = await getVipPackages();\n\n let availableTasks = allTasks.filter(task => !userCompletedTasks.has(task.id));\n\n if (isVipUser) {\n const vipInfo = await getUserVipTasksCompleted(userId);\n const currentVipPackage = vipPackages.find(p => p.id === vipInfo?.packageId);\n const now = Date.now();\n const startOfDay = new Date().setHours(0, 0, 0, 0);\n\n if (\n currentVipPackage && vipInfo.count < currentVipPackage.tasks\n && (!vipInfo.lastCompletionTime || vipInfo.lastCompletionTime < startOfDay)\n ) {\n const vipTaskReward = 15;\n const vipTaskId = 9999;\n const vipDailyTask = {\n id: vipTaskId,\n name: `দৈনিক ভিআইপি টাস্ক ( ${vipInfo.count + 1}/${currentVipPackage.tasks} )`,\n reward: vipTaskReward,\n description: `ভিআইপি সদস্যরা দৈনিক এই টাস্কটি সম্পন্ন করতে পারবেন। (আজকের জন্য ${\n currentVipPackage.tasks - vipInfo.count\n }টি টাস্ক বাকি)`,\n link: \"https://www.google.com\",\n minTime: 15,\n };\n availableTasks.unshift(vipDailyTask);\n }\n }\n\n const currentIndex = availableTasks.findIndex(t => t.id === currentTaskId);\n const prevIndex = currentIndex > 0 ? currentIndex - 1 : availableTasks.length - 1;\n const prevTask = availableTasks[prevIndex];\n\n if (prevTask) {\n await sendTaskPage(ctx, prevTask.id);\n }\n});\n\nbot.callbackQuery(/next_task_(\\\\d+)/, async (ctx) => {\n await ctx.answerCallbackQuery();\n const userId = ctx.from.id;\n const currentTaskId = parseInt(ctx.match![1]);\n const userCompletedTasks = await getCompletedTasks(userId);\n const isVipUser = await isUserVip(userId);\n const allTasks = await getTasks();\n const vipPackages = await getVipPackages();\n\n let availableTasks = allTasks.filter(task => !userCompletedTasks.has(task.id));\n\n if (isVipUser) {\n const vipInfo = await getUserVipTasksCompleted(userId);\n const currentVipPackage = vipPackages.find(p => p.id === vipInfo?.packageId);\n const now = Date.now();\n const startOfDay = new Date().setHours(0, 0, 0, 0);\n\n if (\n currentVipPackage && vipInfo.count < currentVipPackage.tasks\n && (!vipInfo.lastCompletionTime || vipInfo.lastCompletionTime < startOfDay)\n ) {\n const vipTaskReward = 15;\n const vipTaskId = 9999;\n const vipDailyTask = {\n id: vipTaskId,\n name: `দৈনিক ভিআইপি টাস্ক ( ${vipInfo.count + 1}/${currentVipPackage.tasks} )`,\n reward: vipTaskReward,\n description: `ভিআইপি সদস্যরা দৈনিক এই টাস্কটি সম্পন্ন করতে পারবেন। (আজকের জন্য ${\n currentVipPackage.tasks - vipInfo.count\n }টি টাস্ক বাকি)`,\n link: \"https://www.google.com\",\n minTime: 15,\n };\n availableTasks.unshift(vipDailyTask);\n }\n }\n\n const currentIndex = availableTasks.findIndex(t => t.id === currentTaskId);\n const nextIndex = currentIndex < availableTasks.length - 1 ? currentIndex + 1 : 0;\n const nextTask = availableTasks[nextIndex];\n\n if (nextTask) {\n await sendTaskPage(ctx, nextTask.id);\n }\n});\n\n// --- Support Button (Live Chat) ---\nbot.hears(\"📞 সাপোর্ট\", async (ctx) => {\n const userId = ctx.from.id;\n if (userId === ADMIN_ID) {\n return ctx.reply(\"আপনি নিজেই এডমিন।\");\n }\n await setLiveChatState(userId, \"chatting\");\n await ctx.reply(\"🗣️ আপনি এখন এডমিনের সাথে লাইভ চ্যাটে আছেন। আপনার প্রশ্ন বা সমস্যা লিখুন। চ্যাট শেষ করতে \\\"বাতিল\\\" টাইপ করুন।\", {\n reply_markup: {\n keyboard: [[\"বাতিল\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n await bot.api.sendMessage(ADMIN_ID, `💬 নতুন লাইভ চ্যাট শুরু হয়েছে:\\nইউজার: ${ctx.from.first_name} (ID: ${userId})`);\n});\n\n// --- Withdraw System ---\nbot.hears(\"📤 উইথড্র\", async (ctx) => {\n const userId = ctx.from.id;\n const { method } = await getWithdrawMethod(userId);\n\n if (!method) {\n await setAdminState(userId, { state: \"awaiting_method\" });\n return ctx.reply(\"📲 দয়া করে উইথড্র মেথড বাছাই করুন:\", {\n reply_markup: {\n keyboard: [[\"বিকাশ\", \"নগদ\"], [\"বাতিল\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n }\n\n const options = [[\"এডিট মেথড\", \"ডিলিট মেথড\", \"টাকা তুলুন\"]];\n\n return ctx.reply(\"📋 আপনার উইথড্র অপশন:\", {\n reply_markup: {\n keyboard: [...options, [\"মেইন মেনু\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n});\n\nbot.hears(\"বিকাশ\", async (ctx) => {\n const userId = ctx.from.id;\n const adminState = await getAdminState(userId);\n if (adminState?.state === \"awaiting_method\") {\n await setWithdrawMethod(userId, \"বিকাশ\", null);\n await setAdminState(userId, { state: \"awaiting_number\" });\n return ctx.reply(\"✅ আপনি বিকাশ সিলেক্ট করেছেন। এখন ১১ ডিজিটের নাম্বার দিন (01xxxxxxxxx):\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n }\n});\n\nbot.hears(\"নগদ\", async (ctx) => {\n const userId = ctx.from.id;\n const adminState = await getAdminState(userId);\n if (adminState?.state === \"awaiting_method\") {\n await setWithdrawMethod(userId, \"নগদ\", null);\n await setAdminState(userId, { state: \"awaiting_number\" });\n return ctx.reply(\"✅ আপনি নগদ সিলেক্ট করেছেন। এখন ১১ ডিজিটের নাম্বার দিন (01xxxxxxxxx):\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n }\n});\n\n// --- Universal Cancel Button ---\nbot.hears(\"বাতিল\", async (ctx) => {\n const userId = ctx.from.id;\n await deleteAdminState(userId);\n await deleteUserDepositState(userId);\n await deletePendingDeposit(userId);\n await deleteUserReferralTemp(userId);\n\n const liveChatInfo = await getLiveChatState(userId);\n await deleteLiveChatState(userId);\n\n const adminLiveChatInfo = await getLiveChatState(ADMIN_ID);\n if (\n userId !== ADMIN_ID && adminLiveChatInfo?.state === \"chatting_with_user\"\n && adminLiveChatInfo.targetUserId === userId\n ) {\n await deleteLiveChatState(ADMIN_ID);\n await bot.api.sendMessage(ADMIN_ID, `ইউজার ${ctx.from.first_name} (ID: ${userId}) চ্যাট শেষ করেছেন।`);\n } else if (userId === ADMIN_ID && adminLiveChatInfo?.state === \"chatting_with_user\") {\n const targetUserId = adminLiveChatInfo.targetUserId;\n await deleteLiveChatState(ADMIN_ID);\n if (targetUserId) {\n await bot.api.sendMessage(targetUserId, \"এডমিন চ্যাট শেষ করেছেন।\");\n }\n }\n\n await ctx.reply(\"❌ বাতিল করা হয়েছে।\");\n if (userId === ADMIN_ID && (await getAdminState(userId))) {\n return showAdminMenu(ctx);\n }\n return showMainMenu(ctx);\n});\n\nbot.hears(\"মেইন মেনু\", async (ctx) => {\n const userId = ctx.from.id;\n await deleteAdminState(userId);\n await deleteLiveChatState(userId);\n await deleteUserDepositState(userId);\n await deletePendingDeposit(userId);\n await deleteUserReferralTemp(userId);\n return showMainMenu(ctx);\n});\n\n// --- Admin Panel ---\nbot.hears(\"👑 Admin\", (ctx) => {\n if (ctx.from.id !== ADMIN_ID) {\n return ctx.reply(\"❌ আপনার এই কমান্ড ব্যবহারের অনুমতি নেই।\");\n }\n showAdminMenu(ctx);\n});\n\nfunction showAdminMenu(ctx: any) {\n ctx.reply(\"👑 *এডমিন প্যানেল*\", {\n parse_mode: \"Markdown\",\n reply_markup: {\n keyboard: [\n [\"➕ ব্যালেন্স যোগ\", \"➖ ব্যালেন্স বাদ\"],\n [\"➕ ডিপোজিট যোগ (ম্যানুয়াল)\", \"➖ ডিপোজিট বাদ (ম্যানুয়াল)\"],\n [\"📢 সবাইকে মেসেজ\", \"💳 ডিপোজিট নম্বর\"],\n [\"💬 লাইভ চ্যাট\", \"📊 Statistics\"],\n [\"⬅️ মেইন মেনু (এডমিন)\"],\n ],\n resize_keyboard: true,\n },\n });\n}\n\nbot.hears(\"➕ ব্যালেন্স যোগ\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n await setAdminState(ctx.from.id, { state: \"awaiting_main_balance_userid_add\" });\n ctx.reply(\"কোন ইউজারের মেইন ব্যালেন্স যোগ করতে চান? ইউজার আইডি দিন:\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n});\n\nbot.hears(\"➖ ব্যালেন্স বাদ\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n await setAdminState(ctx.from.id, { state: \"awaiting_main_balance_userid_remove\" });\n ctx.reply(\"কোন ইউজারের মেইন ব্যালেন্স থেকে বাদ দিতে চান? ইউজার আইডি দিন:\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n});\n\nbot.hears(\"➕ ডিপোজিট যোগ (ম্যানুয়াল)\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n await setAdminState(ctx.from.id, { state: \"awaiting_deposit_balance_userid_add\" });\n ctx.reply(\"কোন ইউজারের ডিপোজিট ব্যালেন্স যোগ করতে চান? ইউজার আইডি দিন:\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n});\n\nbot.hears(\"➖ ডিপোজিট বাদ (ম্যানুয়াল)\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n await setAdminState(ctx.from.id, { state: \"awaiting_deposit_balance_userid_remove\" });\n ctx.reply(\"কোন ইউজারের ডিপোজিট ব্যালেন্স থেকে বাদ দিতে চান? ইউজার আইডি দিন:\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n});\n\nbot.hears(\"💳 ডিপোজিট নম্বর\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n await setAdminState(ctx.from.id, { state: \"awaiting_new_deposit_number\" });\n ctx.reply(`বর্তমান ডিপোজিট নম্বর: \\`${NAGAD_DEPOSIT_NUMBER}\\`\\nনতুন ডিপোজিট নম্বর লিখুন:`, {\n parse_mode: \"Markdown\",\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n});\n\nbot.hears(\"📢 সবাইকে মেসেজ\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n await setAdminState(ctx.from.id, { state: \"awaiting_broadcast_message\" });\n ctx.reply(\"সব ইউজারকে যে মেসেজ পাঠাতে চান তা লিখুন:\", {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n});\n\nbot.hears(\"💬 লাইভ চ্যাট\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) return;\n\n let activeChats = \"বর্তমানে সক্রিয় চ্যাট:\\n\";\n let chatFound = false;\n const liveChatStatesRows = await sqlite.execute(`SELECT user_id, state FROM ${TABLES.live_chat_states}`);\n for (const row of liveChatStatesRows) {\n const userId = row.user_id;\n const state = row.state;\n if (state === \"chatting\" && userId !== ADMIN_ID) {\n try {\n const user = await getUser(userId);\n activeChats += `ইউজার ID: \\`${userId}\\` (${user?.first_name || \"N/A\"})\\n`;\n chatFound = true;\n } catch (error) {\n console.error(`Error fetching chat member for ID ${userId}:`, error);\n activeChats += `ইউজার ID: \\`${userId}\\` (তথ্য পাওয়া যায়নি)\\n`;\n }\n }\n }\n\n if (!chatFound) {\n activeChats = \"বর্তমানে কোনো ইউজার লাইভ চ্যাটে নেই।\";\n return ctx.reply(activeChats);\n }\n\n await setAdminState(ctx.from.id, { state: \"awaiting_chat_userid\" });\n await ctx.reply(`${activeChats}\\nকোন ইউজারের সাথে চ্যাট করতে চান? ইউজার আইডি দিন:`, {\n parse_mode: \"Markdown\",\n reply_markup: {\n keyboard: [[\"বাতিল\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n});\n\nbot.hears(\"📊 Statistics\", async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) {\n return ctx.reply(\"❌ আপনার এই কমান্ড ব্যবহারের অনুমতি নেই।\");\n }\n\n const totalUsersResult = await sqlite.execute(`SELECT COUNT(DISTINCT id) as count FROM ${TABLES.users}`);\n const totalVipMembersResult = await sqlite.execute(\n `SELECT COUNT(*) as count FROM ${TABLES.users} WHERE is_vip = 1 AND vip_expiry > ?`,\n [Date.now()],\n );\n const totalReferralsResult = await sqlite.execute(`SELECT SUM(count) as total FROM ${TABLES.referrals}`);\n const totalReferralRewardsResult = await sqlite.execute(`SELECT SUM(reward) as total FROM ${TABLES.referrals}`);\n const totalTaskRewardsResult = await sqlite.execute(`SELECT SUM(task_balance) as total FROM ${TABLES.users}`);\n const totalDepositBalanceResult = await sqlite.execute(`SELECT SUM(deposit_balance) as total FROM ${TABLES.users}`);\n const totalMainBalanceResult = await sqlite.execute(`SELECT SUM(balance) as total FROM ${TABLES.users}`);\n const totalPendingWithdrawalsResult = await sqlite.execute(\n `SELECT SUM(amount) as total FROM ${TABLES.withdraw_requests}`,\n );\n const totalPendingDepositsResult = await sqlite.execute(\n `SELECT SUM(amount) as total FROM ${TABLES.pending_deposits}`,\n );\n\n const totalUsers = totalUsersResult[0]?.count || 0;\n const totalVipMembers = totalVipMembersResult[0]?.count || 0;\n const totalReferrals = totalReferralsResult[0]?.total || 0;\n const totalReferralRewardsGiven = totalReferralRewardsResult[0]?.total || 0;\n const totalTaskRewardsGiven = totalTaskRewardsResult[0]?.total || 0;\n const totalDepositBalance = totalDepositBalanceResult[0]?.total || 0;\n const totalMainBalance = totalMainBalanceResult[0]?.total || 0;\n const totalPendingWithdrawals = totalPendingWithdrawalsResult[0]?.total || 0;\n const totalPendingDeposits = totalPendingDepositsResult[0]?.total || 0;\n\n const statsMessage = `📊 *বট পরিসংখ্যান:*\\n\\n`\n + `👥 *মোট ইউজার:* ${totalUsers}\\n`\n + `👑 *মোট ভিআইপি সদস্য:* ${totalVipMembers}\\n`\n + `🤝 *মোট রেফারেল:* ${totalReferrals} জন\\n`\n + `💵 *মোট রেফারেল রিওয়ার্ড:* ${totalReferralRewardsGiven}৳\\n`\n + `📝 *মোট টাস্ক রিওয়ার্ড:* ${totalTaskRewardsGiven}৳\\n\\n`\n + `💰 *সিস্টেমের মোট মেইন ব্যালেন্স:* ${totalMainBalance}৳\\n`\n + `📥 *সিস্টেমের মোট ডিপোজিট ব্যালেন্স:* ${totalDepositBalance}৳\\n\\n`\n + `⏳ *পেন্ডিং উইথড্রয়াল:* ${totalPendingWithdrawals}৳\\n`\n + `⏳ *পেন্ডিং ডিপোজিট:* ${totalPendingDeposits}৳`;\n\n ctx.reply(statsMessage, { parse_mode: \"Markdown\" });\n});\n\nbot.hears(\"⬅️ মেইন মেনু (এডমিন)\", async (ctx) => {\n if (ctx.from.id === ADMIN_ID) {\n await deleteAdminState(ctx.from.id);\n return showMainMenu(ctx);\n }\n});\n\n// Admin action handlers for inline buttons\nbot.callbackQuery(/withdraw_accept_(\\d+)_(\\d+)/, async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) {\n return ctx.answerCallbackQuery(\"❌ আপনার এই অ্যাকশন ব্যবহারের অনুমতি নেই।\");\n }\n await ctx.answerCallbackQuery();\n\n const [, uid, amt] = ctx.match!;\n const userId = parseInt(uid);\n const amount = parseInt(amt);\n\n const req = await getWithdrawRequest(userId);\n if (!req || req.amount !== amount) {\n return ctx.editMessageText(\"❌ এই উইথড্র রিকোয়েস্টটি পাওয়া যায়নি অথবা পরিমাণের সাথে মিলছে না।\");\n }\n\n const balance = await getUserBalance(userId);\n if (balance < amount) {\n await bot.api.sendMessage(\n userId,\n `❌ দুঃখিত! আপনার উইথড্র রিকোয়েস্ট (${amount}৳) বাতিল করা হয়েছে কারণ আপনার ব্যালেন্স পর্যাপ্ত নয়। বর্তমান ব্যালেন্স: ${balance}৳`,\n );\n return ctx.editMessageText(\"❌ ইউজারের ব্যালেন্স কম! উইথড্র বাতিল করা হলো।\");\n }\n\n await updateUserBalance(userId, -amount);\n await deleteWithdrawRequest(userId);\n\n await bot.api.sendMessage(\n userId,\n `✅ আপনার ${amount}৳ উইথড্র সফল হয়েছে! শীঘ্রই আপনার ${req.method} নম্বরে (${req.number}) টাকা পৌঁছে যাবে।`,\n );\n await ctx.editMessageText(`✅ উইথড্র সফলভাবে এপ্রুভ করা হয়েছে। ইউজার ${userId} এর ব্যালেন্স থেকে ${amount}৳ কাটা হয়েছে।`);\n});\n\nbot.callbackQuery(/withdraw_reject_(\\d+)/, async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) {\n return ctx.answerCallbackQuery(\"❌ আপনার এই অ্যাকশন ব্যবহারের অনুমতি নেই।\");\n }\n await ctx.answerCallbackQuery();\n\n const [, uid] = ctx.match!;\n const userId = parseInt(uid);\n\n if (!(await getWithdrawRequest(userId))) {\n return ctx.editMessageText(\"❌ এই উইথড্র রিকোয়েস্টটি পাওয়া যায়নি।\");\n }\n await deleteWithdrawRequest(userId);\n\n await bot.api.sendMessage(userId, \"❌ আপনার উইথড্র রিকোয়েস্ট এডমিন দ্বারা বাতিল হয়েছে।\");\n await ctx.editMessageText(\"🛑 উইথড্র রিকোয়েস্ট বাতিল করা হয়েছে। ইউজারকে জানানো হয়েছে।\");\n});\n\nbot.callbackQuery(/deposit_accept_(\\d+)_(\\d+)/, async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) {\n return ctx.answerCallbackQuery(\"❌ আপনার এই অ্যাকশন ব্যবহারের অনুমতি নেই।\");\n }\n await ctx.answerCallbackQuery();\n\n const [, uid, amt] = ctx.match!;\n const userId = parseInt(uid);\n const amount = parseInt(amt);\n\n const pendingDeposit = await getPendingDeposit(userId);\n if (!pendingDeposit || pendingDeposit.amount !== amount) {\n return ctx.editMessageText(\"❌ এই ডিপোজিট রিকোয়েস্টটি পাওয়া যায়নি অথবা পরিমাণের সাথে মিলছে না।\");\n }\n\n await deletePendingDeposit(userId);\n await updateUserDepositBalance(userId, amount);\n\n await ctx.editMessageText(\n `✅ ইউজার ${userId} এর ডিপোজিট ব্যালেন্সের সাথে ${amount}৳ যোগ করা হয়েছে। নতুন ব্যালেন্স: ${await getUserDepositBalance(\n userId,\n )}৳`,\n );\n await bot.api.sendMessage(\n userId,\n `🎉 আপনার ডিপোজিট ব্যালেন্সের সাথে ${amount}৳ যোগ করা হয়েছে! আপনার বর্তমান ডিপোজিট ব্যালেন্স: ${await getUserDepositBalance(\n userId,\n )}৳`,\n );\n});\n\nbot.callbackQuery(/deposit_reject_(\\d+)/, async (ctx) => {\n if (ctx.from.id !== ADMIN_ID) {\n return ctx.answerCallbackQuery(\"❌ আপনার এই অ্যাকশন ব্যবহারের অনুমতি নেই।\");\n }\n await ctx.answerCallbackQuery();\n\n const [, uid] = ctx.match!;\n const userId = parseInt(uid);\n\n if (!(await getPendingDeposit(userId))) {\n return ctx.editMessageText(\"❌ এই ডিপোজিট রিকোয়েস্টটি পাওয়া যায়নি।\");\n }\n await deletePendingDeposit(userId);\n\n await ctx.editMessageText(`❌ ইউজার ${userId} এর ডিপোজিট রিকোয়েস্ট বাতিল করা হয়েছে।`);\n await bot.api.sendMessage(userId, \"❌ আপনার ডিপোজিট রিকোয়েস্ট এডমিন দ্বারা বাতিল হয়েছে।\");\n});\n\n// --- Main Message Handler ---\nbot.on(\"message\", async (ctx) => {\n if (!(\"text\" in ctx.message)) return;\n\n const userId = ctx.from.id;\n const text = ctx.message.text;\n const today = new Date().toISOString().slice(0, 10);\n\n // --- Live Chat Handling ---\n const userLiveChatState = await getLiveChatState(userId);\n if (userLiveChatState?.state === \"chatting\" && userId !== ADMIN_ID) {\n await bot.api.sendMessage(ADMIN_ID, `💬 ইউজার ${ctx.from.first_name} (ID: ${userId}): ${text}`);\n await ctx.reply(\"আপনার মেসেজ এডমিনের কাছে পাঠানো হয়েছে।\");\n return;\n }\n\n const adminLiveChatState = await getLiveChatState(ADMIN_ID);\n if (userId === ADMIN_ID && adminLiveChatState?.state === \"chatting_with_user\") {\n const targetUserId = adminLiveChatState.targetUserId;\n if (targetUserId) {\n await bot.api.sendMessage(targetUserId, `💬 এডমিন: ${text}`);\n return;\n }\n }\n\n // --- Deposit Flow Logic ---\n const userDepositCurrentState = await getUserDepositState(userId);\n if (userDepositCurrentState) {\n if (userDepositCurrentState.step === \"awaiting_amount\") {\n const amount = parseInt(text);\n if (isNaN(amount) || amount <= 0) {\n return ctx.reply(\"❌ অনুগ্রহ করে সঠিক টাকার পরিমাণ লিখুন।\");\n }\n await setUserDepositState(userId, \"awaiting_txid\", amount);\n const message =\n `আপনার ${amount}৳ ডিপোজিট করার জন্য, নিচের নগদ নম্বরটিতে টাকা পাঠান (Send Money):\\n\\n\\`${NAGAD_DEPOSIT_NUMBER}\\` (কপি করুন)\\n\\nটাকা পাঠানোর পর ট্রানজেকশন আইডি (TxID) টি এখানে টাইপ করে পাঠান।`;\n return ctx.reply(message, {\n parse_mode: \"Markdown\",\n reply_markup: {\n keyboard: [[\"বাতিল\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n } else if (userDepositCurrentState.step === \"awaiting_txid\") {\n const txid = text.trim();\n if (!txid) {\n return ctx.reply(\"❌ ট্রানজেকশন আইডি দিন।\");\n }\n const amount = userDepositCurrentState.amount!;\n\n await setUserDepositState(userId, \"awaiting_deposit_confirm\", amount, txid);\n\n const confirmationMessage = `মেথড: নগদ\\n`\n + `নম্বর: \\`${NAGAD_DEPOSIT_NUMBER}\\` (কপি করুন)\\n`\n + `ট্রানজেকশন আইডি: \\`${txid}\\``;\n\n return ctx.reply(confirmationMessage, {\n parse_mode: \"Markdown\",\n reply_markup: {\n keyboard: [[\"✅ নিশ্চিত করুন\", \"বাতিল\"]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n });\n } else if (userDepositCurrentState.step === \"awaiting_deposit_confirm\" && text === \"✅ নিশ্চিত করুন\") {\n const { amount, txid } = userDepositCurrentState;\n\n const dailyDepositInfo = await getUserDailyDepositCount(userId);\n if (dailyDepositInfo.date !== today) {\n dailyDepositInfo.date = today;\n dailyDepositInfo.count = 0;\n }\n dailyDepositInfo.count++;\n await setUserDailyDepositCount(userId, dailyDepositInfo.date, dailyDepositInfo.count);\n\n await setPendingDeposit(userId, amount!, txid!, Date.now(), ctx.from.username || \"\", ctx.from.first_name);\n await deleteUserDepositState(userId);\n\n await ctx.reply(\"✅ আপনার ডিপোজিট রিকোয়েস্ট জমা দেওয়া হয়েছে। এডমিন যাচাই করে আপনার ব্যালেন্স যোগ করে দেবে।\");\n\n await bot.api.sendMessage(\n ADMIN_ID,\n `📥 নতুন ডিপোজিট রিকোয়েস্ট:\\n`\n + `👤 ইউজার: ${ctx.from.first_name} (@${ctx.from.username || \"নেই\"})\\n`\n + `🆔 ইউজার ID: ${userId}\\n`\n + `💵 পরিমাণ: ${amount}৳\\n`\n + `📝 ট্রানজেকশন ID: \\`${txid}\\``,\n {\n parse_mode: \"Markdown\",\n reply_markup: {\n inline_keyboard: [\n [\n { text: \"✅ গ্রহণ করুন\", callback_data: `deposit_accept_${userId}_${amount}` },\n { text: \"❌ বাতিল করুন\", callback_data: `deposit_reject_${userId}` },\n ],\n ],\n },\n },\n );\n return showMainMenu(ctx);\n }\n }\n\n // --- Withdraw Process Handlers ---\n const userAdminState = await getAdminState(userId);\n\n if (text === \"এডিট মেথড\") {\n await setAdminState(userId, { state: \"awaiting_method\" });\n return ctx.reply(\"📲 নতুন মেথড বাছাই করুন:\", {\n reply_markup: { keyboard: [[\"বিকাশ\", \"নগদ\"], [\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n }\n\n if (text === \"ডিলিট মেথড\") {\n await deleteWithdrawMethod(userId);\n await deleteAdminState(userId);\n await ctx.reply(\"🗑️ মেথড ও নম্বর ডিলিট হয়েছে।\");\n return showMainMenu(ctx);\n }\n\n if (userAdminState?.state === \"awaiting_number\") {\n if (!/^01[0-9]{9}$/.test(text)) return ctx.reply(\"❌ সঠিক ১১ ডিজিটের মোবাইল নম্বর দিন!\");\n const { method } = await getWithdrawMethod(userId);\n await setWithdrawMethod(userId, method!, text);\n await deleteAdminState(userId);\n await ctx.reply(`✅ নম্বর সেভ হয়েছে: ${text}`);\n return showMainMenu(ctx);\n }\n\n if (text === \"টাকা তুলুন\") {\n const { method, number } = await getWithdrawMethod(userId);\n if (!method || !number) {\n return ctx.reply(\"⚠️ আপনার উইথড্র মেথড বা নম্বর সেট করা নেই। \\\"উইথড্র\\\" বাটনে ক্লিক করে সেট করুন।\");\n }\n await setAdminState(userId, { state: \"awaiting_amount\" });\n return ctx.reply(\"💰 কত টাকা তুলতে চান? (সর্বনিম্ন ১৬৫৳):\");\n }\n\n if (userAdminState?.state === \"awaiting_amount\") {\n const amount = parseInt(text);\n const balance = await getUserBalance(userId);\n const isVipUser = await isUserVip(userId);\n\n if (isNaN(amount) || amount < 165) {\n return ctx.reply(\"❌ ১৬৫৳ বা তার বেশি টাকা দিন!\");\n }\n\n if (balance < amount) {\n return ctx.reply(\"❌ আপনার পর্যাপ্ত ব্যালেন্স নেই।\");\n }\n\n if (amount >= 165 && !isVipUser) { // Assuming VIP required for withdrawals >= 165\n await deleteAdminState(userId);\n return ctx.reply(\"❌ দুঃখিত! ১৬৫৳ বা তার বেশি টাকা উত্তোলন করতে হলে আপনাকে ভিআইপি সদস্য হতে হবে।\");\n }\n\n const { method, number } = await getWithdrawMethod(userId);\n\n await setUserWithdrawRequest(userId, amount, method!, number!, ctx.from.username || \"\", ctx.from.first_name);\n await setAdminState(userId, { state: \"awaiting_confirm\" });\n\n return ctx.reply(`✅ ${amount}৳ তুলতে যাচ্ছেন:\\n🏦 ${method}\\n📱 ${number}\\n\\n✅ কনফার্ম করুন:`, {\n reply_markup: { keyboard: [[\"✅ কনফার্ম\", \"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n }\n\n if (userAdminState?.state === \"awaiting_confirm\" && text === \"✅ কনফার্ম\") {\n const req = await getWithdrawRequest(userId);\n if (!req) return ctx.reply(\"❌ কোনো রিকোয়েস্ট নেই।\");\n await deleteAdminState(userId);\n\n await bot.api.sendMessage(\n ADMIN_ID,\n `📤 নতুন উইথড্র রিকোয়েস্ট:\\n👤 ${req.first_name} (@${\n req.username || \"নেই\"\n })\\n🆔 ID: ${userId}\\n💵 পরিমাণ: ${req.amount}৳\\n🏦 ${req.method}\\n📱 ${req.number}`,\n {\n parse_mode: \"Markdown\",\n reply_markup: {\n inline_keyboard: [\n [\n { text: \"✅ একসেপ্ট\", callback_data: `withdraw_accept_${userId}_${req.amount}` },\n { text: \"❌ রিজেক্ট\", callback_data: `withdraw_reject_${userId}` },\n ],\n ],\n },\n },\n );\n await ctx.reply(\"✅ উইথড্র রিকোয়েস্ট পাঠানো হয়েছে, অপেক্ষা করুন।\");\n return showMainMenu(ctx);\n }\n\n // --- Admin Panel Handlers ---\n if (userId === ADMIN_ID) {\n const adminState = await getAdminState(userId);\n\n if (adminState?.state === \"awaiting_chat_userid\") {\n const targetUserId = parseInt(text);\n const targetUserLiveChatState = await getLiveChatState(targetUserId);\n if (isNaN(targetUserId) || !targetUserLiveChatState || targetUserLiveChatState.state !== \"chatting\") {\n await deleteAdminState(userId);\n return ctx.reply(\"❌ সঠিক ইউজার আইডি দিন অথবা এই ইউজার বর্তমানে চ্যাটে নেই।\");\n }\n await setLiveChatState(ADMIN_ID, \"chatting_with_user\", targetUserId);\n await deleteAdminState(userId);\n await ctx.reply(`🗣️ আপনি এখন ইউজার ${targetUserId} এর সাথে লাইভ চ্যাটে আছেন। চ্যাট শেষ করতে \"বাতিল\" টাইপ করুন।`, {\n reply_markup: { keyboard: [[\"বাতিল\"]], resize_keyboard: true, one_time_keyboard: true },\n });\n return;\n }\n\n // Admin balance management\n if (\n adminState?.state === \"awaiting_main_balance_userid_add\"\n || adminState?.state === \"awaiting_main_balance_userid_remove\"\n ) {\n const targetUserId = parseInt(text);\n if (isNaN(targetUserId)) {\n return ctx.reply(\"❌ সঠিক ইউজার আইডি দিন।\");\n }\n const action = adminState.state;\n await setAdminState(userId, {\n state: \"awaiting_main_balance_amount\",\n targetUserId: targetUserId,\n action: action,\n });\n return ctx.reply(\"💰 কত টাকা যোগ/বাদ দিতে চান? (যেমন: ১৫০)\");\n }\n\n if (adminState?.state === \"awaiting_main_balance_amount\") {\n const amount = parseInt(text);\n const { targetUserId, action } = adminState;\n\n if (isNaN(amount)) {\n return ctx.reply(\"❌ সঠিক টাকার পরিমাণ দিন।\");\n }\n\n let finalAmount = amount;\n if (action === \"awaiting_main_balance_userid_remove\") {\n finalAmount = -amount;\n }\n\n await updateUserBalance(targetUserId!, finalAmount);\n await deleteAdminState(userId);\n\n const balanceMsg = `✅ ইউজার ${targetUserId} এর মেইন ব্যালেন্স আপডেট করা হয়েছে। নতুন ব্যালেন্স: ${await getUserBalance(\n targetUserId!,\n )}৳`;\n await ctx.reply(balanceMsg);\n await bot.api.sendMessage(\n targetUserId!,\n `🎉 আপনার মেইন ব্যালেন্স আপডেট করা হয়েছে। নতুন ব্যালেন্স: ${await getUserBalance(targetUserId!)}৳`,\n );\n return showAdminMenu(ctx);\n }\n\n // Admin deposit balance management\n if (\n adminState?.state === \"awaiting_deposit_balance_userid_add\"\n || adminState?.state === \"awaiting_deposit_balance_userid_remove\"\n ) {\n const targetUserId = parseInt(text);\n if (isNaN(targetUserId)) {\n return ctx.reply(\"❌ সঠিক ইউজার আইডি দিন।\");\n }\n const action = adminState.state;\n await setAdminState(userId, {\n state: \"awaiting_deposit_balance_amount\",\n targetUserId: targetUserId,\n action: action,\n });\n return ctx.reply(\"💰 কত টাকা যোগ/বাদ দিতে চান? (যেমন: ১৫০)\");\n }\n\n if (adminState?.state === \"awaiting_deposit_balance_amount\") {\n const amount = parseInt(text);\n const { targetUserId, action } = adminState;\n\n if (isNaN(amount)) {\n return ctx.reply(\"❌ সঠিক টাকার পরিমাণ দিন।\");\n }\n\n let finalAmount = amount;\n if (action === \"awaiting_deposit_balance_userid_remove\") {\n finalAmount = -amount;\n }\n\n await updateUserDepositBalance(targetUserId!, finalAmount);\n await deleteAdminState(userId);\n\n const balanceMsg =\n `✅ ইউজার ${targetUserId} এর ডিপোজিট ব্যালেন্স আপডেট করা হয়েছে। নতুন ডিপোজিট ব্যালেন্স: ${await getUserDepositBalance(\n targetUserId!,\n )}৳`;\n await ctx.reply(balanceMsg);\n await bot.api.sendMessage(\n targetUserId!,\n `🎉 আপনার ডিপোজিট ব্যালেন্স আপডেট করা হয়েছে। নতুন ডিপোজিট ব্যালেন্স: ${await getUserDepositBalance(targetUserId!)}৳`,\n );\n return showAdminMenu(ctx);\n }\n\n // Admin deposit number change\n if (adminState?.state === \"awaiting_new_deposit_number\") {\n const newNumber = text.trim();\n if (!/^[0-9]+$/.test(newNumber)) {\n return ctx.reply(\"❌ অনুগ্রহ করে শুধুমাত্র সংখ্যা লিখুন।\");\n }\n NAGAD_DEPOSIT_NUMBER = newNumber;\n await sqlite.execute(`INSERT OR REPLACE INTO ${TABLES.global_settings} (key, value) VALUES (?, ?)`, [\n \"NAGAD_DEPOSIT_NUMBER\",\n NAGAD_DEPOSIT_NUMBER,\n ]);\n await deleteAdminState(userId);\n await ctx.reply(`✅ ডিপোজিট নম্বর সফলভাবে পরিবর্তন করা হয়েছে: \\`${NAGAD_DEPOSIT_NUMBER}\\``, {\n parse_mode: \"Markdown\",\n });\n return showAdminMenu(ctx);\n }\n\n // Admin broadcast message\n if (adminState?.state === \"awaiting_broadcast_message\") {\n const broadcastMessage = text;\n let sentCount = 0;\n let failedCount = 0;\n const allUserRows = await sqlite.execute(`SELECT id FROM ${TABLES.users}`);\n for (const row of allUserRows) {\n const user = row.id;\n if (user === ADMIN_ID || (await isUserBanned(user))) {\n continue;\n }\n try {\n await bot.api.sendMessage(user, `📢 *এডমিন নোটিশ:*\\n\\n${broadcastMessage}`, { parse_mode: \"Markdown\" });\n sentCount++;\n } catch (error) {\n console.error(`Failed to send broadcast to user ${user}:`, error);\n failedCount++;\n }\n }\n await deleteAdminState(userId);\n await ctx.reply(`✅ মেসেজ সফলভাবে ${sentCount} জন ইউজারকে পাঠানো হয়েছে। ব্যর্থ: ${failedCount} জন।`);\n return showAdminMenu(ctx);\n }\n }\n});\n\n// Initialize database and start bot\nawait initializeDatabase(); // This is correctly placed now\n\nexport default {\n fetch: async (request: Request) => {\n try {\n return await bot.handleUpdate(await request.json());\n } catch (error) {\n console.error(\"Error handling update:\", error);\n return new Response(\"Error\", { status: 500 });\n }\n },\n};","deleted","label",[169,153],"backend","permalink","https://www.val.town/x/wahobd/newval/code/backend/index.ts","extension","actionData","errors"]