Update server.js

server.js

@@ -1,340 +1,222 @@
-const express = require("express");
-const puppeteer = require("puppeteer-extra");
-const StealthPlugin = require("puppeteer-extra-plugin-stealth");
-const cheerio = require("cheerio");
-require('dotenv').config();
-
-// Add stealth plugin
+const express = require('express');
+const puppeteer = require('puppeteer-extra');
+const StealthPlugin = require('puppeteer-extra-plugin-stealth');
 puppeteer.use(StealthPlugin());
 
 const app = express();
-const PORT = 7860;
+const PORT = process.env.PORT || 7860;
 
-// Browser instance management
+// Store browser instance to reuse
 let browser = null;
-let authenticatedPage = null;
-let isLoggedIn = false;
-
-async function getBrowser() {
-  if (!browser) {
-    browser = await puppeteer.launch({
-      headless: "new", // Use new headless mode
-      args: [
-        '--no-sandbox',
-        '--disable-setuid-sandbox',
-        '--disable-dev-shm-usage',
-        '--disable-accelerated-2d-canvas',
-        '--no-first-run',
-        '--no-zygote',
-        '--disable-gpu',
-        '--disable-web-security',
-        '--disable-features=VizDisplayCompositor'
-      ]
-    });
-  }
-  return browser;
-}
+let loggedInPage = null;
 
-// Get or create authenticated page
-async function getAuthenticatedPage() {
-  if (!authenticatedPage || authenticatedPage.isClosed()) {
-    const browser = await getBrowser();
-    authenticatedPage = await setupPage(browser);
-    isLoggedIn = false; // Reset login status for new page
-  }
-  return authenticatedPage;
-}
+// Middleware
+app.use(express.json());
 
-// Login function with extensive debugging
-async function performLogin() {
-  if (isLoggedIn) return true;
-  
-  const page = await getAuthenticatedPage();
-  
+// Initialize browser and login once on startup
+async function initializeBrowser() {
   try {
-    console.log('Performing login...');
-    console.log('Using email:', process.env.LOGIN_EMAIL ? 'Found' : 'Missing');
-    console.log('Using password:', process.env.LOGIN_PASSWORD ? 'Found' : 'Missing');
-    
-    // Navigate to login page
-    await page.goto('https://getsms.cc/auth/login', {
-      waitUntil: 'networkidle2',
-      timeout: 30000
-    });
-    
-    console.log('Loaded login page');
-    
-    // Wait for form to be visible
-    await page.waitForSelector('form#login', { timeout: 10000 });
-    console.log('Found login form');
-    
-    // Take screenshot before login (for debugging)
-    // await page.screenshot({ path: 'before-login.png' });
-    
-    // Clear and fill email field
-    await page.evaluate(() => {
-      const emailField = document.querySelector('input[name="mail"]');
-      if (emailField) emailField.value = '';
-    });
-    await page.focus('input[name="mail"]');
-    await page.type('input[name="mail"]', process.env.LOGIN_EMAIL, { delay: 50 });
+    console.log('🚀 Initializing browser and logging in...');
     
-    // Clear and fill password field  
-    await page.evaluate(() => {
-      const passwordField = document.querySelector('input[name="password"]');
-      if (passwordField) passwordField.value = '';
+    browser = await puppeteer.launch({
+      headless: true, // Set to false for debugging
+      args: ["--no-sandbox", "--disable-setuid-sandbox"]
     });
-    await page.focus('input[name="password"]');
-    await page.type('input[name="password"]', process.env.LOGIN_PASSWORD, { delay: 50 });
-    
-    console.log('Filled login form');
-    
-    // Wait a moment before submitting
-    await new Promise(resolve => setTimeout(resolve, 1000));
+
+    loggedInPage = await browser.newPage();
     
-    // Submit form with different approach
-    await page.evaluate(() => {
-      const form = document.querySelector('form#login');
-      if (form) {
-        form.submit();
-      }
+    // Login process
+    await loggedInPage.goto("https://getsms.cc/auth/login", {
+      waitUntil: "networkidle2"
     });
+
+    // Replace with your actual credentials
+    await loggedInPage.type("#email", "your@email.com", { delay: 50 });
+    await loggedInPage.type("#password", "yourpassword", { delay: 50 });
+
+    await Promise.all([
+      loggedInPage.click("input[type=submit]"),
+      loggedInPage.waitForNavigation({ waitUntil: "networkidle2" })
+    ]);
+
+    console.log("✅ Browser initialized and logged in successfully!");
     
-    console.log('Submitted form, waiting for response...');
+  } catch (error) {
+    console.error("❌ Failed to initialize browser:", error);
+    throw error;
+  }
+}
+
+// API endpoint to get messages for a phone number
+app.get('/api/messages', async (req, res) => {
+  try {
+    const { number } = req.query;
     
-    // Wait for either navigation or page update
-    try {
-      await page.waitForNavigation({ waitUntil: 'networkidle2', timeout: 15000 });
-      console.log('Navigation detected');
-    } catch (e) {
-      console.log('No navigation, checking for page updates...');
-      await new Promise(resolve => setTimeout(resolve, 3000));
+    if (!number) {
+      return res.status(400).json({
+        error: 'Phone number is required',
+        message: 'Please provide a phone number in the query parameter: ?number=447414848795'
+      });
     }
-    
-    const currentUrl = page.url();
-    console.log('Current URL after login attempt:', currentUrl);
-    
-    // Take screenshot after login (for debugging)
-    // await page.screenshot({ path: 'after-login.png' });
-    
-    // Check for error messages on the page
-    const errorMessage = await page.evaluate(() => {
-      const errorElements = document.querySelectorAll('.alert-danger, .text-danger, .error, .alert-error');
-      for (let el of errorElements) {
-        if (el.textContent.trim()) {
-          return el.textContent.trim();
-        }
-      }
-      return null;
+
+    console.log(`📱 Fetching messages for number: ${number}`);
+
+    // Check if we're still logged in by checking for login indicators
+    const currentUrl = loggedInPage.url();
+    console.log(`Current page URL: ${currentUrl}`);
+
+    // Navigate to the specific info page using the same logged-in page
+    const url = `https://getsms.cc/info/${number}`;
+    await loggedInPage.goto(url, {
+      waitUntil: "networkidle2"
     });
-    
-    if (errorMessage) {
-      console.log('Login error message:', errorMessage);
-      return false;
+
+    // Verify we didn't get redirected to login page
+    const finalUrl = loggedInPage.url();
+    if (finalUrl.includes('/auth/login')) {
+      throw new Error('Session expired - redirected to login page');
     }
-    
-    // More comprehensive login success check
-    const loginCheck = await page.evaluate(() => {
-      const url = window.location.href;
-      const bodyText = document.body.innerText.toLowerCase();
-      
-      // Check various indicators of successful login
-      const indicators = {
-        notOnLoginPage: !url.includes('/auth/login'),
-        hasLogoutLink: document.querySelector('[href*="logout"]') !== null,
-        hasUserDropdown: document.querySelector('.dropdown-toggle') !== null,
-        hasUserProfile: document.querySelector('.user-profile') !== null,
-        hasDashboard: bodyText.includes('dashboard'),
-        hasWelcome: bodyText.includes('welcome'),
-        hasMyAccount: bodyText.includes('my account'),
-        urlIndicatesSuccess: url.includes('/dashboard') || url.includes('/account') || url === 'https://getsms.cc/'
-      };
-      
-      console.log('Login indicators:', indicators);
-      
-      return {
-        success: Object.values(indicators).some(v => v),
-        indicators,
-        url,
-        pageTitle: document.title
-      };
+
+    console.log(`✅ Successfully navigated to: ${finalUrl}`);
+
+    // Wait a moment for any dynamic content to load
+    await loggedInPage.waitForTimeout(2000);
+
+    // Check if we need to login (session expired)
+    const needsLogin = await loggedInPage.evaluate(() => {
+      // Check for "Login to view" text or similar indicators
+      const bodyText = document.body.textContent || '';
+      return bodyText.includes('Login to view') || 
+             bodyText.includes('Please login') ||
+             bodyText.includes('You need to login') ||
+             document.querySelector('.login-required') !== null;
     });
-    
-    console.log('Login check result:', loginCheck);
-    
-    if (loginCheck.success) {
-      isLoggedIn = true;
-      console.log('✅ Login successful - authenticated session established');
-      return true;
-    } else {
-      console.log('❌ Login failed - no success indicators found');
+
+    if (needsLogin) {
+      console.log('🔄 Session expired, re-logging in...');
       
-      // Get page content for debugging
-      const pageContent = await page.evaluate(() => {
-        return document.body.innerText.substring(0, 1000);
+      // Re-login process
+      await loggedInPage.goto("https://getsms.cc/auth/login", {
+        waitUntil: "networkidle2"
       });
-      console.log('Page content after login:', pageContent);
-      
-      return false;
-    }
-  } catch (error) {
-    console.error('Login error:', error);
-    return false;
-  }
-}
 
-// Enhanced page setup for maximum stealth
-async function setupPage(browser) {
-  const page = await browser.newPage();
-  
-  // Set viewport to common resolution
-  await page.setViewport({ width: 1366, height: 768 });
-  
-  // Set realistic user agent
-  await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36');
-  
-  // Set additional headers
-  await page.setExtraHTTPHeaders({
-    'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8',
-    'Accept-Language': 'en-US,en;q=0.9',
-    'Accept-Encoding': 'gzip, deflate, br',
-    'DNT': '1',
-    'Connection': 'keep-alive',
-    'Upgrade-Insecure-Requests': '1',
-  });
-  
-  return page;
-}
+      // Clear any existing form data and re-enter credentials
+      await loggedInPage.evaluate(() => {
+        const emailInput = document.querySelector('#email');
+        const passwordInput = document.querySelector('#password');
+        if (emailInput) emailInput.value = '';
+        if (passwordInput) passwordInput.value = '';
+      });
 
-// Scraper function for numbers list with stealth
-async function scrapeUK(pageNum = 1) {
-  const browser = await getBrowser();
-  const page = await setupPage(browser);
-  
-  try {
-    const url = pageNum === 1
-      ? "https://getsms.cc/temporary-phone-numbers/UK"
-      : `https://getsms.cc/temporary-phone-numbers/UK/${pageNum}`;
-    
-    // Navigate with realistic options
-    await page.goto(url, {
-      waitUntil: 'networkidle2',
-      timeout: 30000
-    });
-    
-    // Add random delay to mimic human behavior
-    await new Promise(resolve => setTimeout(resolve, Math.random() * 2000 + 1000));
-    
-    // Get page content
-    const content = await page.content();
-    const $ = cheerio.load(content);
-    
-    const results = [];
-    $(".card").each((i, el) => {
-      const number = $(el).find("p.p-0.m-0.font-weight-bold").text().trim();
-      const timeAgo = $(el).find("p.p-0.m-0.small").text().trim();
-      const link = $(el).find("a.btn.btn-primary").attr("href");
+      await loggedInPage.type("#email", "your@email.com", { delay: 50 });
+      await loggedInPage.type("#password", "yourpassword", { delay: 50 });
+
+      await Promise.all([
+        loggedInPage.click("input[type=submit]"),
+        loggedInPage.waitForNavigation({ waitUntil: "networkidle2" })
+      ]);
+
+      console.log("✅ Re-logged in successfully!");
+
+      // Navigate back to the number page
+      await loggedInPage.goto(url, {
+        waitUntil: "networkidle2"
+      });
+
+      // Wait for content to load
+      await loggedInPage.waitForTimeout(2000);
+    }
+
+    // Extract the last 3 messages
+    const lastMessages = await loggedInPage.evaluate(() => {
+      const messageElements = document.querySelectorAll('.direct-chat-msg');
       
-      if (number && timeAgo && link) {
-        results.push({
-          number,
-          timeAgo,
-          link: `https://getsms.cc${link}`,
-        });
+      // Double-check we're not seeing login messages
+      const bodyText = document.body.textContent || '';
+      if (bodyText.includes('Login to view')) {
+        return []; // Return empty array if still showing login message
       }
+      
+      const messages = Array.from(messageElements).map(msg => {
+        const nameElement = msg.querySelector('.direct-chat-name');
+        const timeElement = msg.querySelector('.direct-chat-timestamp');
+        const textElement = msg.querySelector('.direct-chat-text');
+        
+        // Skip ads/empty messages
+        const text = textElement?.textContent?.trim() || '';
+        if (text.includes('adsbygoogle') || text === '' || text.includes('Login to view')) {
+          return null;
+        }
+        
+        return {
+          sender: nameElement?.textContent?.trim() || 'Unknown',
+          time: timeElement?.textContent?.trim() || 'Unknown time',
+          message: text
+        };
+      }).filter(msg => msg !== null); // Remove null entries (ads)
+      
+      // Return last 3 messages
+      return messages.slice(-3);
     });
-    
-    return results;
-  } catch (error) {
-    console.error('Error scraping UK numbers:', error);
-    throw error;
-  } finally {
-    await page.close();
-  }
-}
 
-// Scraper function for messages with stealth
-async function scrapeMessages(number) {
-  const browser = await getBrowser();
-  const page = await setupPage(browser);
-  
-  try {
-    const url = `https://getsms.cc/info/${number}`;
-    
-    // Navigate with realistic options
-    await page.goto(url, {
-      waitUntil: 'networkidle2',
-      timeout: 30000
-    });
-    
-    // Add random delay
-    await new Promise(resolve => setTimeout(resolve, Math.random() * 2000 + 1000));
-    
-    // Get page content
-    const content = await page.content();
-    const $ = cheerio.load(content);
-    
-    const messages = [];
-    $(".direct-chat-msg").each((i, el) => {
-      const from = $(el).find(".direct-chat-name").text().trim();
-      const timeAgo = $(el).find("time").text().trim();
-      const text = $(el).find(".direct-chat-text").text().trim();
-      
-      // Skip ads/empty messages
-      if (from && text) {
-        messages.push({ from, timeAgo, text });
+    // Check if we got empty results due to login requirement
+    if (lastMessages.length === 0) {
+      const pageContent = await loggedInPage.evaluate(() => document.body.textContent);
+      if (pageContent.includes('Login to view')) {
+        throw new Error('Session expired and re-login failed - still showing "Login to view"');
       }
-    });
-    
-    // Return latest 3 (newest first)
-    return messages.slice(-3).reverse();
-  } catch (error) {
-    console.error('Error scraping messages:', error);
-    throw error;
-  } finally {
-    await page.close();
-  }
-}
+    }
 
-// Endpoint: UK numbers
-app.get(["/uk", "/uk/:page"], async (req, res) => {
-  try {
-    const page = parseInt(req.params.page) || 1;
-    const numbers = await scrapeUK(page);
+    console.log(`✅ Found ${lastMessages.length} messages for ${number}`);
+
+    // Return the response
     res.json({
-      country: "United Kingdom",
-      page,
-      count: numbers.length,
-      numbers,
+      success: true,
+      number: number,
+      timestamp: new Date().toISOString(),
+      messageCount: lastMessages.length,
+      messages: lastMessages
     });
-  } catch (err) {
-    console.error("Error:", err.message);
-    res.status(500).json({ error: "Failed to scrape numbers" });
-  }
-});
 
-// Endpoint: messages
-app.get("/msg/:number", async (req, res) => {
-  try {
-    const number = req.params.number;
-    const messages = await scrapeMessages(number);
-    res.json({
-      number,
-      count: messages.length,
-      messages,
+  } catch (error) {
+    console.error(`❌ Error fetching messages for ${req.query.number}:`, error);
+    res.status(500).json({
+      success: false,
+      error: 'Failed to fetch messages',
+      message: error.message
     });
-  } catch (err) {
-    console.error("Error:", err.message);
-    res.status(500).json({ error: "Failed to scrape messages" });
   }
 });
 
+// Health check endpoint
+app.get('/api/health', (req, res) => {
+  res.json({
+    status: 'OK',
+    message: 'GetSMS API is running',
+    timestamp: new Date().toISOString(),
+    browserStatus: browser ? 'Connected' : 'Disconnected'
+  });
+});
+
+// Get available endpoints
+app.get('/', (req, res) => {
+  res.json({
+    message: 'GetSMS Message Extraction API',
+    endpoints: {
+      'GET /api/messages?number={phone_number}': 'Get last 3 messages for a phone number',
+      'GET /api/health': 'Check API health status',
+      'GET /': 'This help page'
+    },
+    example: {
+      url: '/api/messages?number=447414848795',
+      description: 'Get messages for phone number 447414848795'
+    }
+  });
+});
+
 // Graceful shutdown
 process.on('SIGINT', async () => {
-  console.log('Shutting down gracefully...');
-  if (authenticatedPage && !authenticatedPage.isClosed()) {
-    await authenticatedPage.close();
-  }
+  console.log('\n🔄 Shutting down gracefully...');
   if (browser) {
     await browser.close();
   }
@@ -342,10 +224,7 @@ process.on('SIGINT', async () => {
 });
 
 process.on('SIGTERM', async () => {
-  console.log('Shutting down gracefully...');
-  if (authenticatedPage && !authenticatedPage.isClosed()) {
-    await authenticatedPage.close();
-  }
+  console.log('\n🔄 Shutting down gracefully...');
   if (browser) {
     await browser.close();
   }
@@ -353,7 +232,22 @@ process.on('SIGTERM', async () => {
 });
 
 // Start server
-app.listen(PORT, () => {
-  console.log(`Server running on http://localhost:${PORT}`);
-  console.log('Using Puppeteer with stealth mode to avoid detection');
-});
+async function startServer() {
+  try {
+    await initializeBrowser();
+    
+    app.listen(PORT, () => {
+      console.log(`\n🌟 GetSMS API Server running on port ${PORT}`);
+      console.log(`📋 Available endpoints:`);
+      console.log(`   GET http://localhost:${PORT}/api/messages?number=447414848795`);
+      console.log(`   GET http://localhost:${PORT}/api/health`);
+      console.log(`   GET http://localhost:${PORT}/`);
+    });
+  } catch (error) {
+    console.error('❌ Failed to start server:', error);
+    process.exit(1);
+  }
+}
+
+// Start the server
+startServer();