API tools faq
paste
Advertisement
jackox

ItemAlert7.2.py

jackox
Jul 3rd, 2025
87
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 6.36 KB | None | 0 0
raw download clone embed print report
  1. #!/usr/bin/env python3
  2.  
  3. import configparser
  4. import os
  5. import sqlite3
  6. import json
  7. import requests
  8. from selenium import webdriver
  9. from selenium.webdriver.common.by import By
  10. from selenium.webdriver.common.keys import Keys
  11. from selenium.common.exceptions import WebDriverException
  12. from urllib.request import urlopen
  13. import time
  14. import re
  15. import urllib.parse
  16.  
  17. # Cargar variables desde .env
  18. config = configparser.ConfigParser()
  19. config.read('config.ini')
  20. miusuario = config['DATABASE']['USUARIO']
  21. mipass = config['DATABASE']['PASSWORD']
  22. mibusqueda = config['DATABASE']['BUSQUEDA_ID']
  23. gurl = config['DATABASE']['GURL']
  24.  
  25. def consultabd(eburl):
  26.     try:
  27.         con = sqlite3.connect('itemalert.db', isolation_level=None)
  28.         cur = con.cursor()
  29.         cur.execute("CREATE TABLE IF NOT EXISTS BD (id INTEGER PRIMARY KEY, EBURL text NOT NULL)")
  30.         cur.execute("SELECT * FROM BD WHERE EBURL=?", (eburl,))
  31.         row = cur.fetchone()
  32.         if row is None:
  33.             cur.execute("INSERT INTO BD (EBURL) VALUES (?)", (eburl,))
  34.             return 0
  35.         return 1
  36.     except Exception as e:
  37.         logWeb(f'Error en consultabd: {str(e)}', 1)
  38.         return 1
  39.     finally:
  40.         con.close()
  41.  
  42. def almacenabd():
  43.     try:
  44.         con = sqlite3.connect('itemalert.db', isolation_level=None)
  45.         cur = con.cursor()
  46.         cur.execute("DROP TABLE IF EXISTS BD")
  47.         cur.execute("CREATE TABLE IF NOT EXISTS BD (id INTEGER PRIMARY KEY, EBURL text NOT NULL)")
  48.         response = requests.get(gurl)
  49.         data = response.json()
  50.         array = json.loads(data)
  51.         for item in array:
  52.             cur.execute("INSERT INTO BD (EBURL) VALUES (?)", (str(item[0]),))
  53.     except Exception as e:
  54.         logWeb(f'Error en almacenabd: {str(e)}', 1)
  55.  
  56. def publicaciones(html, items, precios, descs, imgs):
  57.     try:
  58.         regex = r'media result resultnew ohtoe m-b".*?>(.*?)<\/div>'
  59.         publicaciones = re.findall(regex, html)
  60.         npubs = int(len(publicaciones)/2)
  61.  
  62.         for i in range(npubs):
  63.             pub = publicaciones[i]
  64.  
  65.             desc_regex = r'l l-d".*?>(.*?)<\/span>'
  66.             desc_match = re.findall(desc_regex, pub)
  67.             descs.append(desc_match[0] if desc_match else "")
  68.  
  69.             img_regex = r'images\/g\/(.*?)\/s-l225.jpg'
  70.             img_match = re.findall(img_regex, pub)
  71.             imgs.append(img_match[0] if img_match else "")
  72.  
  73.             item_regex = r'"p-r" href=.*?itm\/(.*?)\?'
  74.             item_match = re.findall(item_regex, pub)
  75.             items.append(item_match[0] if item_match else "")
  76.  
  77.             price_regex = r'Fixed Price @ (.*?) USD|Auction : (.*?) USD'
  78.             price_match = re.findall(price_regex, pub)
  79.             if price_match:
  80.                 price = price_match[0][0] or price_match[0][1]
  81.                 clean_price = re.sub(r"[(),' ]", "", str(price))
  82.                 precios.append(clean_price)
  83.             else:
  84.                 precios.append("")
  85.  
  86.         return npubs
  87.     except Exception as e:
  88.         logWeb('Error en publicaciones: ' + str(e), 1)
  89.         return 0
  90.  
  91. def logWeb(_log, _prio=0):
  92.     try:
  93.         _log = urllib.parse.quote_plus(_log)
  94.         url = gurl + "?log=" + _log
  95.         if _prio == 1:
  96.             urlopen(url)
  97.     except Exception as e:
  98.         print(f"Error en logWeb: {str(e)}")
  99.  
  100. def crear_driver():
  101.     options = webdriver.ChromeOptions()
  102.     options.add_argument("--no-sandbox")
  103.     options.add_argument("--disable-dev-shm-usage")
  104.     options.add_argument("--disable-gpu")
  105.     options.add_argument("--disable-extensions")
  106.     options.add_argument("--disable-background-networking")
  107.     options.add_argument("--disable-software-rasterizer")
  108.     options.add_argument("--headless")
  109.     return webdriver.Chrome(options=options)
  110.  
  111. # Inicio del programa
  112. logWeb('Iniciando_ItemAlert.py', 1)
  113.  
  114. items, precios, descs, imgs = [], [], [], []
  115.  
  116. driver = crear_driver()
  117.  
  118. def login_y_busqueda():
  119.     try:
  120.         driver.get("https://itemalert.com/login")
  121.         time.sleep(2)
  122.         usuario = driver.find_element(By.NAME, 'username')
  123.         pswrd = driver.find_element(By.NAME, 'password')
  124.         usuario.send_keys(miusuario)
  125.         pswrd.send_keys(mipass)
  126.         pswrd.send_keys(Keys.RETURN)
  127.         time.sleep(3)
  128.  
  129.         driver.get("https://itemalert.com/savedsearch")
  130.         time.sleep(2)
  131.         cv = driver.find_element(By.NAME, mibusqueda)
  132.         driver.execute_script("arguments[0].click();", cv)
  133.         time.sleep(1)
  134.         go = driver.find_element(By.NAME, 'go')
  135.         driver.execute_script("arguments[0].click();", go)
  136.         time.sleep(3)
  137.  
  138.     except Exception as e:
  139.         logWeb(f'Error en login_y_busqueda: {str(e)}', 1)
  140.  
  141. almacenabd()
  142. login_y_busqueda()
  143. time.sleep(20)
  144. i = 15
  145.  
  146. while True:
  147.     try:
  148.         try:
  149.             html = driver.execute_script("return document.body.innerHTML")
  150.         except WebDriverException as we:
  151.             logWeb(f'Tab crashed, reiniciando driver: {str(we)}', 1)
  152.             driver.quit()
  153.             driver = crear_driver()
  154.             login_y_busqueda()
  155.             time.sleep(20)
  156.             continue
  157.  
  158.         eterror = driver.find_element(By.XPATH, '//div[@id="error"]')
  159.         errorat = re.sub('<.*?>', '', eterror.get_attribute('innerHTML'))
  160.         errorat = "".join(char for char in errorat if char.isalnum() or char == " ")
  161.  
  162.         if i >= 15:
  163.             i = 1
  164.             logWeb(errorat, 1)
  165.         else:
  166.             i += 1
  167.  
  168.         npubs = publicaciones(html, items, precios, descs, imgs)
  169.  
  170.         for j in range(npubs):
  171.             if j < len(items) and items[j]:
  172.                 if consultabd(items[j]) == 0:
  173.                     url = gurl + "?item=" + urllib.parse.quote_plus(str(items[j])) + \
  174.                           "&pre=" + urllib.parse.quote_plus(str(precios[j] if j < len(precios) else "")) + \
  175.                           "&des=" + urllib.parse.quote_plus(str(descs[j] if j < len(descs) else ""))+ \
  176.                           "&img=" + urllib.parse.quote_plus(str(imgs[j] if j < len(imgs) else ""))
  177.                     urlopen(url)
  178.  
  179.         driver.execute_script("arguments[0].click();", driver.find_element(By.ID, 'cleardom-btn'))
  180.         items.clear()
  181.         precios.clear()
  182.         descs.clear()
  183.         imgs.clear()
  184.         time.sleep(20)
  185.  
  186.     except Exception as e:
  187.         logWeb(f'Error en bucle principal: {str(e)}', 1)
  188.         time.sleep(20)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!