Spaces:
Running
Running
Update app.py
Browse files
app.py
CHANGED
|
@@ -43,7 +43,6 @@ logger = logging.getLogger(__name__)
|
|
| 43 |
# ============================================================
|
| 44 |
API_TOKEN = os.environ.get("API_TOKEN", "").strip()
|
| 45 |
|
| 46 |
-
# Log para debug - verificar se o token foi carregado
|
| 47 |
if API_TOKEN:
|
| 48 |
logger.info(f"[AUTH] API_TOKEN configurado ({len(API_TOKEN)} caracteres)")
|
| 49 |
logger.info(f"[AUTH] Primeiros 4 chars: {API_TOKEN[:4]}...")
|
|
@@ -55,7 +54,7 @@ security = HTTPBearer(auto_error=False)
|
|
| 55 |
async def verify_token(credentials: HTTPAuthorizationCredentials = Depends(security)):
|
| 56 |
"""Verifica o token de autenticação"""
|
| 57 |
if not API_TOKEN:
|
| 58 |
-
return True
|
| 59 |
|
| 60 |
if not credentials:
|
| 61 |
raise HTTPException(status_code=401, detail="Token não fornecido")
|
|
@@ -73,10 +72,9 @@ class SessionManager:
|
|
| 73 |
def __init__(self):
|
| 74 |
self.sessions: Dict[str, dict] = {}
|
| 75 |
self.max_sessions = 5
|
| 76 |
-
self.session_timeout = 1800
|
| 77 |
|
| 78 |
def create_session(self, url: str) -> dict:
|
| 79 |
-
"""Cria nova sessão Selenium"""
|
| 80 |
self._cleanup_expired()
|
| 81 |
|
| 82 |
if len(self.sessions) >= self.max_sessions:
|
|
@@ -93,7 +91,6 @@ class SessionManager:
|
|
| 93 |
chrome_options.add_argument('--window-size=1920,1080')
|
| 94 |
chrome_options.add_argument('--disable-extensions')
|
| 95 |
chrome_options.add_argument('--disable-plugins')
|
| 96 |
-
chrome_options.add_argument('--disable-images')
|
| 97 |
chrome_options.add_argument('--disable-blink-features=AutomationControlled')
|
| 98 |
chrome_options.add_argument('--user-agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36')
|
| 99 |
chrome_options.binary_location = '/usr/bin/google-chrome'
|
|
@@ -104,12 +101,9 @@ class SessionManager:
|
|
| 104 |
driver = webdriver.Chrome(service=service, options=chrome_options)
|
| 105 |
driver.set_page_load_timeout(60)
|
| 106 |
driver.implicitly_wait(10)
|
| 107 |
-
|
| 108 |
-
# Habilitar logs do console
|
| 109 |
driver.execute_cdp_cmd('Runtime.enable', {})
|
| 110 |
driver.execute_cdp_cmd('Log.enable', {})
|
| 111 |
driver.execute_cdp_cmd('Network.enable', {})
|
| 112 |
-
|
| 113 |
except Exception as e:
|
| 114 |
logger.error(f"[SESSION] Erro ao criar driver: {e}")
|
| 115 |
raise HTTPException(status_code=500, detail=f"Erro ao iniciar navegador: {str(e)}")
|
|
@@ -144,21 +138,16 @@ class SessionManager:
|
|
| 144 |
}
|
| 145 |
|
| 146 |
def get_session(self, session_id: str) -> dict:
|
| 147 |
-
"""Recupera sessão ativa"""
|
| 148 |
if session_id not in self.sessions:
|
| 149 |
raise HTTPException(status_code=404, detail="Sessão não encontrada")
|
| 150 |
-
|
| 151 |
session = self.sessions[session_id]
|
| 152 |
-
|
| 153 |
if time.time() - session['last_used'] > self.session_timeout:
|
| 154 |
self.close_session(session_id)
|
| 155 |
raise HTTPException(status_code=410, detail="Sessão expirada")
|
| 156 |
-
|
| 157 |
session['last_used'] = time.time()
|
| 158 |
return session
|
| 159 |
|
| 160 |
def close_session(self, session_id: str):
|
| 161 |
-
"""Fecha sessão"""
|
| 162 |
if session_id in self.sessions:
|
| 163 |
try:
|
| 164 |
self.sessions[session_id]['driver'].quit()
|
|
@@ -168,7 +157,6 @@ class SessionManager:
|
|
| 168 |
logger.info(f"[SESSION] Fechada: {session_id[:8]}...")
|
| 169 |
|
| 170 |
def _cleanup_expired(self):
|
| 171 |
-
"""Remove sessões expiradas"""
|
| 172 |
expired = [
|
| 173 |
sid for sid, s in self.sessions.items()
|
| 174 |
if time.time() - s['last_used'] > self.session_timeout
|
|
@@ -177,7 +165,6 @@ class SessionManager:
|
|
| 177 |
self.close_session(sid)
|
| 178 |
|
| 179 |
def close_all(self):
|
| 180 |
-
"""Fecha todas as sessões"""
|
| 181 |
for sid in list(self.sessions.keys()):
|
| 182 |
self.close_session(sid)
|
| 183 |
|
|
@@ -190,7 +177,6 @@ session_manager = SessionManager()
|
|
| 190 |
|
| 191 |
@asynccontextmanager
|
| 192 |
async def lifespan(app: FastAPI):
|
| 193 |
-
"""Gerencia ciclo de vida da aplicação"""
|
| 194 |
logger.info("=" * 50)
|
| 195 |
logger.info("[SERVER] Site Backup & Error Checker v1.3.0")
|
| 196 |
logger.info(f"[SERVER] Auth: {'ATIVO (token configurado)' if API_TOKEN else 'DESATIVADO'}")
|
|
@@ -208,7 +194,6 @@ app = FastAPI(
|
|
| 208 |
lifespan=lifespan
|
| 209 |
)
|
| 210 |
|
| 211 |
-
# CORS
|
| 212 |
app.add_middleware(
|
| 213 |
CORSMiddleware,
|
| 214 |
allow_origins=["*"],
|
|
@@ -246,19 +231,6 @@ class NavigateRequest(BaseModel):
|
|
| 246 |
session_id: str
|
| 247 |
url: str
|
| 248 |
|
| 249 |
-
class InteractClickRequest(BaseModel):
|
| 250 |
-
session_id: str
|
| 251 |
-
x: int
|
| 252 |
-
y: int
|
| 253 |
-
|
| 254 |
-
class InteractTypeRequest(BaseModel):
|
| 255 |
-
session_id: str
|
| 256 |
-
text: str
|
| 257 |
-
|
| 258 |
-
class InteractKeyRequest(BaseModel):
|
| 259 |
-
session_id: str
|
| 260 |
-
key: str
|
| 261 |
-
|
| 262 |
class SearchSiteRequest(BaseModel):
|
| 263 |
session_id: str
|
| 264 |
term: str
|
|
@@ -271,7 +243,6 @@ class SearchSiteRequest(BaseModel):
|
|
| 271 |
@app.get("/")
|
| 272 |
@app.head("/")
|
| 273 |
async def root():
|
| 274 |
-
"""Status do servidor"""
|
| 275 |
return {
|
| 276 |
"status": "online",
|
| 277 |
"service": "Site Backup & Error Checker",
|
|
@@ -282,7 +253,6 @@ async def root():
|
|
| 282 |
@app.get("/health")
|
| 283 |
@app.head("/health")
|
| 284 |
async def health():
|
| 285 |
-
"""Health check"""
|
| 286 |
return {
|
| 287 |
"status": "healthy",
|
| 288 |
"timestamp": time.time(),
|
|
@@ -296,16 +266,13 @@ async def health():
|
|
| 296 |
|
| 297 |
@app.post("/auth/verify")
|
| 298 |
async def auth_verify(auth=Depends(verify_token)):
|
| 299 |
-
"""Verifica se o token é válido"""
|
| 300 |
return {"valid": True, "message": "Token válido"}
|
| 301 |
|
| 302 |
@app.post("/open")
|
| 303 |
async def open_site(request: OpenSiteRequest, auth=Depends(verify_token)):
|
| 304 |
-
"""Abre um site no Selenium"""
|
| 305 |
url = request.url.strip()
|
| 306 |
if not url.startswith(('http://', 'https://')):
|
| 307 |
url = 'https://' + url
|
| 308 |
-
|
| 309 |
try:
|
| 310 |
result = session_manager.create_session(url)
|
| 311 |
return result
|
|
@@ -317,17 +284,14 @@ async def open_site(request: OpenSiteRequest, auth=Depends(verify_token)):
|
|
| 317 |
|
| 318 |
@app.post("/session/status")
|
| 319 |
async def session_status(request: SessionRequest, auth=Depends(verify_token)):
|
| 320 |
-
"""Status da sessão"""
|
| 321 |
session = session_manager.get_session(request.session_id)
|
| 322 |
driver = session['driver']
|
| 323 |
-
|
| 324 |
try:
|
| 325 |
current_url = driver.current_url
|
| 326 |
title = driver.title
|
| 327 |
except:
|
| 328 |
current_url = session['url']
|
| 329 |
title = session['title']
|
| 330 |
-
|
| 331 |
return {
|
| 332 |
"session_id": request.session_id,
|
| 333 |
"url": current_url,
|
|
@@ -339,10 +303,8 @@ async def session_status(request: SessionRequest, auth=Depends(verify_token)):
|
|
| 339 |
|
| 340 |
@app.post("/screenshot")
|
| 341 |
async def take_screenshot(request: SessionRequest, auth=Depends(verify_token)):
|
| 342 |
-
"""Captura screenshot da página"""
|
| 343 |
session = session_manager.get_session(request.session_id)
|
| 344 |
driver = session['driver']
|
| 345 |
-
|
| 346 |
try:
|
| 347 |
screenshot = driver.get_screenshot_as_png()
|
| 348 |
return StreamingResponse(
|
|
@@ -356,23 +318,18 @@ async def take_screenshot(request: SessionRequest, auth=Depends(verify_token)):
|
|
| 356 |
|
| 357 |
@app.post("/backup")
|
| 358 |
async def backup_site(request: BackupRequest, auth=Depends(verify_token)):
|
| 359 |
-
"""Faz backup completo do site"""
|
| 360 |
session = session_manager.get_session(request.session_id)
|
| 361 |
driver = session['driver']
|
| 362 |
url = session['url']
|
| 363 |
-
|
| 364 |
try:
|
| 365 |
session['status'] = 'backing_up'
|
| 366 |
backup = SiteBackup(driver, url)
|
| 367 |
zip_buffer = backup.generate_backup_zip()
|
| 368 |
session['status'] = 'active'
|
| 369 |
-
|
| 370 |
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
|
| 371 |
folder = request.folder_name or "backup"
|
| 372 |
filename = f"{folder}_{timestamp}.zip"
|
| 373 |
-
|
| 374 |
errors_count = len(backup.errors) if hasattr(backup, 'errors') else 0
|
| 375 |
-
|
| 376 |
return StreamingResponse(
|
| 377 |
io.BytesIO(zip_buffer.getvalue()),
|
| 378 |
media_type="application/zip",
|
|
@@ -388,22 +345,18 @@ async def backup_site(request: BackupRequest, auth=Depends(verify_token)):
|
|
| 388 |
|
| 389 |
@app.post("/check-errors")
|
| 390 |
async def check_errors(request: ErrorCheckRequest, auth=Depends(verify_token)):
|
| 391 |
-
"""Verifica erros e retorna TXT"""
|
| 392 |
session = session_manager.get_session(request.session_id)
|
| 393 |
driver = session['driver']
|
| 394 |
url = session['url']
|
| 395 |
-
|
| 396 |
try:
|
| 397 |
session['status'] = 'checking_errors'
|
| 398 |
checker = SiteErrorChecker(driver, url)
|
| 399 |
checker.run_all_checks()
|
| 400 |
report = checker.generate_report_txt()
|
| 401 |
session['status'] = 'active'
|
| 402 |
-
|
| 403 |
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
|
| 404 |
folder = request.folder_name or "erros"
|
| 405 |
filename = f"{folder}_{timestamp}.txt"
|
| 406 |
-
|
| 407 |
return StreamingResponse(
|
| 408 |
io.BytesIO(report.encode('utf-8')),
|
| 409 |
media_type="text/plain; charset=utf-8",
|
|
@@ -420,18 +373,15 @@ async def check_errors(request: ErrorCheckRequest, auth=Depends(verify_token)):
|
|
| 420 |
|
| 421 |
@app.post("/check-errors-json")
|
| 422 |
async def check_errors_json(request: ErrorCheckRequest, auth=Depends(verify_token)):
|
| 423 |
-
"""Verifica erros e retorna JSON"""
|
| 424 |
session = session_manager.get_session(request.session_id)
|
| 425 |
driver = session['driver']
|
| 426 |
url = session['url']
|
| 427 |
-
|
| 428 |
try:
|
| 429 |
session['status'] = 'checking_errors'
|
| 430 |
checker = SiteErrorChecker(driver, url)
|
| 431 |
checker.run_all_checks()
|
| 432 |
report = checker.generate_report_json()
|
| 433 |
session['status'] = 'active'
|
| 434 |
-
|
| 435 |
return JSONResponse(
|
| 436 |
content=report,
|
| 437 |
headers={
|
|
@@ -446,13 +396,11 @@ async def check_errors_json(request: ErrorCheckRequest, auth=Depends(verify_toke
|
|
| 446 |
|
| 447 |
@app.post("/close")
|
| 448 |
async def close_session(request: SessionRequest, auth=Depends(verify_token)):
|
| 449 |
-
"""Fecha sessão"""
|
| 450 |
session_manager.close_session(request.session_id)
|
| 451 |
return {"status": "closed", "message": "Sessão encerrada com sucesso"}
|
| 452 |
|
| 453 |
@app.get("/sessions")
|
| 454 |
async def list_sessions(auth=Depends(verify_token)):
|
| 455 |
-
"""Lista sessões ativas"""
|
| 456 |
sessions_list = []
|
| 457 |
for sid, s in session_manager.sessions.items():
|
| 458 |
sessions_list.append({
|
|
@@ -467,24 +415,19 @@ async def list_sessions(auth=Depends(verify_token)):
|
|
| 467 |
|
| 468 |
@app.post("/navigate")
|
| 469 |
async def navigate(request: NavigateRequest, auth=Depends(verify_token)):
|
| 470 |
-
"""Navega para outra URL na mesma sessão"""
|
| 471 |
session = session_manager.get_session(request.session_id)
|
| 472 |
driver = session['driver']
|
| 473 |
-
|
| 474 |
url = request.url.strip()
|
| 475 |
if not url.startswith(('http://', 'https://')):
|
| 476 |
url = 'https://' + url
|
| 477 |
-
|
| 478 |
try:
|
| 479 |
driver.get(url)
|
| 480 |
WebDriverWait(driver, 30).until(
|
| 481 |
lambda d: d.execute_script("return document.readyState") == "complete"
|
| 482 |
)
|
| 483 |
-
|
| 484 |
session['url'] = driver.current_url
|
| 485 |
session['title'] = driver.title or "Sem título"
|
| 486 |
session['last_used'] = time.time()
|
| 487 |
-
|
| 488 |
return {
|
| 489 |
"status": "navigated",
|
| 490 |
"url": session['url'],
|
|
@@ -495,298 +438,168 @@ async def navigate(request: NavigateRequest, auth=Depends(verify_token)):
|
|
| 495 |
raise HTTPException(status_code=500, detail=str(e))
|
| 496 |
|
| 497 |
# ============================================================
|
| 498 |
-
# ROTAS DE
|
| 499 |
# ============================================================
|
| 500 |
|
| 501 |
-
@app.post("/
|
| 502 |
-
async def
|
| 503 |
-
"""
|
| 504 |
-
|
| 505 |
-
|
| 506 |
-
|
| 507 |
-
try:
|
| 508 |
-
# Pegar tamanho real do viewport
|
| 509 |
-
viewport = driver.execute_script("""
|
| 510 |
-
return {
|
| 511 |
-
width: window.innerWidth,
|
| 512 |
-
height: window.innerHeight,
|
| 513 |
-
scrollX: window.scrollX,
|
| 514 |
-
scrollY: window.scrollY,
|
| 515 |
-
pageWidth: document.documentElement.scrollWidth,
|
| 516 |
-
pageHeight: document.documentElement.scrollHeight
|
| 517 |
-
};
|
| 518 |
-
""")
|
| 519 |
-
|
| 520 |
-
screenshot = driver.get_screenshot_as_png()
|
| 521 |
-
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 522 |
-
|
| 523 |
-
return {
|
| 524 |
-
"screenshot": screenshot_b64,
|
| 525 |
-
"viewport": viewport,
|
| 526 |
-
"url": driver.current_url,
|
| 527 |
-
"title": driver.title
|
| 528 |
-
}
|
| 529 |
-
except Exception as e:
|
| 530 |
-
logger.error(f"[INTERACT-SCREENSHOT] Erro: {e}")
|
| 531 |
-
raise HTTPException(status_code=500, detail=str(e))
|
| 532 |
|
|
|
|
|
|
|
|
|
|
|
|
|
| 533 |
|
| 534 |
-
|
| 535 |
-
async def interact_click(request: InteractClickRequest, auth=Depends(verify_token)):
|
| 536 |
-
"""Clica em coordenada específica na página usando ActionChains"""
|
| 537 |
-
session = session_manager.get_session(request.session_id)
|
| 538 |
driver = session['driver']
|
| 539 |
|
| 540 |
try:
|
| 541 |
-
|
| 542 |
-
|
| 543 |
|
| 544 |
-
|
| 545 |
-
|
| 546 |
-
|
| 547 |
-
|
| 548 |
-
|
| 549 |
-
|
| 550 |
-
actions.perform()
|
| 551 |
-
except Exception:
|
| 552 |
-
# Método 2: JavaScript com elementFromPoint + click + focus
|
| 553 |
-
driver.execute_script("""
|
| 554 |
-
var x = arguments[0];
|
| 555 |
-
var y = arguments[1];
|
| 556 |
-
|
| 557 |
-
// Scroll para a posição se necessário
|
| 558 |
-
var vpHeight = window.innerHeight;
|
| 559 |
-
if (y > vpHeight) {
|
| 560 |
-
window.scrollTo(0, y - vpHeight / 2);
|
| 561 |
-
y = vpHeight / 2;
|
| 562 |
-
}
|
| 563 |
-
|
| 564 |
-
var element = document.elementFromPoint(x, y);
|
| 565 |
-
if (element) {
|
| 566 |
-
// Simular eventos de mouse reais
|
| 567 |
-
var events = ['mousedown', 'mouseup', 'click'];
|
| 568 |
-
events.forEach(function(eventType) {
|
| 569 |
-
var event = new MouseEvent(eventType, {
|
| 570 |
-
view: window,
|
| 571 |
-
bubbles: true,
|
| 572 |
-
cancelable: true,
|
| 573 |
-
clientX: x,
|
| 574 |
-
clientY: y
|
| 575 |
-
});
|
| 576 |
-
element.dispatchEvent(event);
|
| 577 |
-
});
|
| 578 |
-
|
| 579 |
-
// Focar no elemento
|
| 580 |
-
if (element.focus) element.focus();
|
| 581 |
-
|
| 582 |
-
// Se for input/textarea, colocar cursor no final
|
| 583 |
-
if (element.tagName === 'INPUT' || element.tagName === 'TEXTAREA') {
|
| 584 |
-
element.selectionStart = element.selectionEnd = element.value.length;
|
| 585 |
-
}
|
| 586 |
}
|
| 587 |
-
""", x, y)
|
| 588 |
|
| 589 |
-
|
|
|
|
|
|
|
| 590 |
|
| 591 |
-
|
| 592 |
-
|
| 593 |
|
| 594 |
-
|
| 595 |
-
|
| 596 |
-
var el = document.activeElement;
|
| 597 |
-
if (el) {
|
| 598 |
-
return {
|
| 599 |
-
tag: el.tagName,
|
| 600 |
-
type: el.type || '',
|
| 601 |
-
id: el.id || '',
|
| 602 |
-
name: el.name || '',
|
| 603 |
-
isInput: (el.tagName === 'INPUT' || el.tagName === 'TEXTAREA' || el.isContentEditable)
|
| 604 |
-
};
|
| 605 |
-
}
|
| 606 |
-
return null;
|
| 607 |
-
""")
|
| 608 |
|
| 609 |
-
|
| 610 |
-
|
| 611 |
-
|
| 612 |
-
"y": request.y,
|
| 613 |
-
"focused_element": focused,
|
| 614 |
-
"screenshot": screenshot_b64,
|
| 615 |
-
"url": driver.current_url,
|
| 616 |
-
"title": driver.title
|
| 617 |
-
}
|
| 618 |
-
except Exception as e:
|
| 619 |
-
logger.error(f"[INTERACT-CLICK] Erro: {e}")
|
| 620 |
-
raise HTTPException(status_code=500, detail=str(e))
|
| 621 |
|
|
|
|
|
|
|
| 622 |
|
| 623 |
-
|
| 624 |
-
|
| 625 |
-
"""Digita texto no elemento focado usando ActionChains"""
|
| 626 |
-
session = session_manager.get_session(request.session_id)
|
| 627 |
-
driver = session['driver']
|
| 628 |
|
| 629 |
-
|
| 630 |
-
|
| 631 |
|
| 632 |
-
#
|
| 633 |
-
|
| 634 |
-
|
| 635 |
-
|
| 636 |
-
|
| 637 |
-
|
| 638 |
-
# Método 2: JavaScript direto
|
| 639 |
-
driver.execute_script("""
|
| 640 |
-
var text = arguments[0];
|
| 641 |
-
var el = document.activeElement;
|
| 642 |
-
if (el && (el.tagName === 'INPUT' || el.tagName === 'TEXTAREA' || el.isContentEditable)) {
|
| 643 |
-
if (el.isContentEditable) {
|
| 644 |
-
el.textContent += text;
|
| 645 |
-
} else {
|
| 646 |
-
var start = el.selectionStart || el.value.length;
|
| 647 |
-
var end = el.selectionEnd || el.value.length;
|
| 648 |
-
var before = el.value.substring(0, start);
|
| 649 |
-
var after = el.value.substring(end);
|
| 650 |
-
el.value = before + text + after;
|
| 651 |
-
el.selectionStart = el.selectionEnd = start + text.length;
|
| 652 |
-
}
|
| 653 |
-
el.dispatchEvent(new Event('input', { bubbles: true }));
|
| 654 |
-
el.dispatchEvent(new Event('change', { bubbles: true }));
|
| 655 |
-
// KeyUp para frameworks reativos
|
| 656 |
-
text.split('').forEach(function(char) {
|
| 657 |
-
el.dispatchEvent(new KeyboardEvent('keydown', { key: char, bubbles: true }));
|
| 658 |
-
el.dispatchEvent(new KeyboardEvent('keypress', { key: char, bubbles: true }));
|
| 659 |
-
el.dispatchEvent(new KeyboardEvent('keyup', { key: char, bubbles: true }));
|
| 660 |
-
});
|
| 661 |
-
}
|
| 662 |
-
""", text)
|
| 663 |
|
| 664 |
-
|
|
|
|
|
|
|
| 665 |
|
| 666 |
screenshot = driver.get_screenshot_as_png()
|
| 667 |
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 668 |
|
|
|
|
|
|
|
| 669 |
return {
|
| 670 |
-
"status": "
|
| 671 |
-
"
|
| 672 |
-
"
|
| 673 |
-
"
|
| 674 |
-
"
|
|
|
|
|
|
|
| 675 |
}
|
|
|
|
| 676 |
except Exception as e:
|
| 677 |
-
logger.error(f"[
|
| 678 |
raise HTTPException(status_code=500, detail=str(e))
|
| 679 |
|
| 680 |
|
| 681 |
-
@app.post("/
|
| 682 |
-
async def
|
| 683 |
-
"""
|
| 684 |
session = session_manager.get_session(request.session_id)
|
| 685 |
driver = session['driver']
|
| 686 |
|
| 687 |
-
key_map = {
|
| 688 |
-
'enter': Keys.ENTER,
|
| 689 |
-
'tab': Keys.TAB,
|
| 690 |
-
'escape': Keys.ESCAPE,
|
| 691 |
-
'backspace': Keys.BACKSPACE,
|
| 692 |
-
'delete': Keys.DELETE,
|
| 693 |
-
'space': Keys.SPACE,
|
| 694 |
-
'up': Keys.UP,
|
| 695 |
-
'down': Keys.DOWN,
|
| 696 |
-
'left': Keys.LEFT,
|
| 697 |
-
'right': Keys.RIGHT
|
| 698 |
-
}
|
| 699 |
-
|
| 700 |
try:
|
| 701 |
-
key = key_map.get(request.key.lower())
|
| 702 |
-
if not key:
|
| 703 |
-
raise HTTPException(status_code=400, detail=f"Tecla não suportada: {request.key}")
|
| 704 |
-
|
| 705 |
-
actions = ActionChains(driver)
|
| 706 |
-
actions.send_keys(key)
|
| 707 |
-
actions.perform()
|
| 708 |
-
|
| 709 |
-
time.sleep(0.8)
|
| 710 |
-
|
| 711 |
screenshot = driver.get_screenshot_as_png()
|
| 712 |
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 713 |
|
| 714 |
-
|
| 715 |
-
|
| 716 |
-
|
| 717 |
-
|
| 718 |
-
|
| 719 |
-
|
| 720 |
-
|
| 721 |
-
|
| 722 |
-
|
| 723 |
-
|
| 724 |
-
|
| 725 |
-
|
| 726 |
-
|
| 727 |
-
|
| 728 |
-
|
| 729 |
-
|
| 730 |
-
|
| 731 |
-
|
| 732 |
-
driver = session['driver']
|
| 733 |
-
|
| 734 |
-
try:
|
| 735 |
-
driver.execute_script("window.scrollBy(0, 300);")
|
| 736 |
-
time.sleep(0.3)
|
| 737 |
|
| 738 |
-
|
| 739 |
-
|
|
|
|
|
|
|
| 740 |
|
| 741 |
return {
|
| 742 |
-
"status": "scrolled",
|
| 743 |
-
"screenshot": screenshot_b64,
|
| 744 |
"url": driver.current_url,
|
| 745 |
-
"title": driver.title
|
|
|
|
|
|
|
|
|
|
| 746 |
}
|
|
|
|
| 747 |
except Exception as e:
|
| 748 |
-
logger.error(f"[
|
| 749 |
raise HTTPException(status_code=500, detail=str(e))
|
| 750 |
|
| 751 |
|
| 752 |
-
@app.post("/
|
| 753 |
-
async def
|
| 754 |
-
"""
|
| 755 |
session = session_manager.get_session(request.session_id)
|
| 756 |
driver = session['driver']
|
| 757 |
|
| 758 |
try:
|
| 759 |
-
|
| 760 |
-
|
| 761 |
-
|
| 762 |
-
|
| 763 |
-
|
| 764 |
-
|
| 765 |
-
time.sleep(0.2)
|
| 766 |
-
|
| 767 |
-
# Digitar novo texto
|
| 768 |
-
actions = ActionChains(driver)
|
| 769 |
-
actions.send_keys(request.text)
|
| 770 |
-
actions.perform()
|
| 771 |
|
| 772 |
-
|
|
|
|
|
|
|
| 773 |
|
| 774 |
screenshot = driver.get_screenshot_as_png()
|
| 775 |
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 776 |
|
| 777 |
return {
|
| 778 |
-
"status": "
|
| 779 |
-
"
|
| 780 |
-
"
|
| 781 |
-
"
|
| 782 |
-
"title": driver.title
|
| 783 |
}
|
|
|
|
| 784 |
except Exception as e:
|
| 785 |
-
logger.error(f"[
|
| 786 |
raise HTTPException(status_code=500, detail=str(e))
|
| 787 |
|
| 788 |
|
| 789 |
-
|
| 790 |
# ============================================================
|
| 791 |
# ROTAS DE BUSCA NO SITE
|
| 792 |
# ============================================================
|
|
@@ -807,28 +620,23 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 807 |
if any(kw in term for kw in ['api', 'endpoint', 'fetch', 'ajax', 'request', 'requisição', 'requisicao']):
|
| 808 |
apis = driver.execute_script("""
|
| 809 |
var results = [];
|
| 810 |
-
// Scripts inline com fetch/axios/XMLHttpRequest
|
| 811 |
var scripts = document.querySelectorAll('script');
|
| 812 |
scripts.forEach(function(s) {
|
| 813 |
var text = s.textContent || s.innerText || '';
|
| 814 |
-
// Buscar URLs de API
|
| 815 |
var urlPattern = /(?:fetch|axios\\.(?:get|post|put|delete)|XMLHttpRequest)\\s*\\(\\s*['\"`]([^'\"`]+)['\"`]/g;
|
| 816 |
var match;
|
| 817 |
while ((match = urlPattern.exec(text)) !== null) {
|
| 818 |
results.push({type: 'API Endpoint (fetch/axios)', value: match[1], details: 'Encontrado em script inline'});
|
| 819 |
}
|
| 820 |
-
// Buscar URLs com /api/
|
| 821 |
var apiPattern = /['\"`]((?:https?:\\/\\/[^'\"`]*\\/api\\/[^'\"`]*)|(?:\\/api\\/[^'\"`]*))['\"`]/g;
|
| 822 |
while ((match = apiPattern.exec(text)) !== null) {
|
| 823 |
results.push({type: 'API URL', value: match[1], details: 'URL contendo /api/'});
|
| 824 |
}
|
| 825 |
});
|
| 826 |
-
// Links com /api/
|
| 827 |
var links = document.querySelectorAll('a[href*="/api/"]');
|
| 828 |
links.forEach(function(l) {
|
| 829 |
results.push({type: 'Link para API', value: l.href, details: l.textContent.trim().substring(0, 100)});
|
| 830 |
});
|
| 831 |
-
// Data attributes com URLs
|
| 832 |
var allElements = document.querySelectorAll('[data-api], [data-url], [data-endpoint]');
|
| 833 |
allElements.forEach(function(el) {
|
| 834 |
var api = el.getAttribute('data-api') || el.getAttribute('data-url') || el.getAttribute('data-endpoint');
|
|
@@ -877,7 +685,6 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 877 |
});
|
| 878 |
}
|
| 879 |
});
|
| 880 |
-
// Background images
|
| 881 |
var allEls = document.querySelectorAll('*');
|
| 882 |
for (var i = 0; i < Math.min(allEls.length, 500); i++) {
|
| 883 |
var bg = window.getComputedStyle(allEls[i]).backgroundImage;
|
|
@@ -984,7 +791,6 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 984 |
links.forEach(function(l) {
|
| 985 |
results.push({type: 'Fonte Externa', value: l.href, details: 'Rel: ' + l.rel});
|
| 986 |
});
|
| 987 |
-
// Verificar @font-face
|
| 988 |
for (var i = 0; i < document.styleSheets.length; i++) {
|
| 989 |
try {
|
| 990 |
var rules = document.styleSheets[i].cssRules || [];
|
|
@@ -1007,7 +813,6 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 1007 |
if any(kw in term for kw in ['cookie', 'cookies', 'storage', 'localstorage', 'sessionstorage', 'armazenamento']):
|
| 1008 |
storage = driver.execute_script("""
|
| 1009 |
var results = [];
|
| 1010 |
-
// Cookies
|
| 1011 |
var cookies = document.cookie.split(';');
|
| 1012 |
cookies.forEach(function(c) {
|
| 1013 |
c = c.trim();
|
|
@@ -1016,13 +821,11 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 1016 |
results.push({type: 'Cookie', value: parts[0], details: 'Valor: ' + (parts.slice(1).join('=') || '[vazio]')});
|
| 1017 |
}
|
| 1018 |
});
|
| 1019 |
-
// LocalStorage
|
| 1020 |
for (var i = 0; i < localStorage.length; i++) {
|
| 1021 |
var key = localStorage.key(i);
|
| 1022 |
var val = localStorage.getItem(key);
|
| 1023 |
results.push({type: 'LocalStorage', value: key, details: 'Valor: ' + (val ? val.substring(0, 100) : '[vazio]')});
|
| 1024 |
}
|
| 1025 |
-
// SessionStorage
|
| 1026 |
for (var i = 0; i < sessionStorage.length; i++) {
|
| 1027 |
var key = sessionStorage.key(i);
|
| 1028 |
var val = sessionStorage.getItem(key);
|
|
@@ -1039,7 +842,6 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 1039 |
generic = driver.execute_script("""
|
| 1040 |
var term = arguments[0];
|
| 1041 |
var results = [];
|
| 1042 |
-
// Buscar no HTML
|
| 1043 |
var body = document.body.innerHTML;
|
| 1044 |
var regex = new RegExp('([^<>]{0,50}' + term.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\$&') + '[^<>]{0,50})', 'gi');
|
| 1045 |
var matches = body.match(regex);
|
|
@@ -1049,7 +851,6 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 1049 |
results.push({type: 'Texto encontrado', value: m.trim(), details: 'Encontrado no conteúdo da página'});
|
| 1050 |
});
|
| 1051 |
}
|
| 1052 |
-
// Buscar em atributos
|
| 1053 |
var allEls = document.querySelectorAll('*');
|
| 1054 |
for (var i = 0; i < Math.min(allEls.length, 1000); i++) {
|
| 1055 |
var attrs = allEls[i].attributes;
|
|
@@ -1084,27 +885,33 @@ async def search_site(request: SearchSiteRequest, auth=Depends(verify_token)):
|
|
| 1084 |
@app.post("/search-site-txt")
|
| 1085 |
async def search_site_txt(request: SearchSiteRequest, auth=Depends(verify_token)):
|
| 1086 |
"""Busca no site e retorna relatório TXT"""
|
| 1087 |
-
# Reutilizar a lógica de busca
|
| 1088 |
session = session_manager.get_session(request.session_id)
|
| 1089 |
driver = session['driver']
|
| 1090 |
|
| 1091 |
term = request.term.strip().lower()
|
| 1092 |
|
| 1093 |
try:
|
| 1094 |
-
# Chamar a mesma lógica
|
| 1095 |
fake_request = SearchSiteRequest(
|
| 1096 |
session_id=request.session_id,
|
| 1097 |
term=request.term,
|
| 1098 |
folder_name=request.folder_name
|
| 1099 |
)
|
| 1100 |
|
| 1101 |
-
# Executar busca diretamente
|
| 1102 |
search_data = await search_site(fake_request)
|
| 1103 |
|
| 1104 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1105 |
report = generate_search_report(
|
| 1106 |
term=request.term,
|
| 1107 |
-
findings=
|
| 1108 |
url=driver.current_url,
|
| 1109 |
title=driver.title
|
| 1110 |
)
|
|
@@ -1158,7 +965,6 @@ def generate_search_report(term: str, findings: list, url: str, title: str) -> s
|
|
| 1158 |
report.append(" - O termo pode estar escrito de forma diferente")
|
| 1159 |
report.append("")
|
| 1160 |
else:
|
| 1161 |
-
# Agrupar por categoria
|
| 1162 |
grouped = {}
|
| 1163 |
for f in findings:
|
| 1164 |
cat = f.get("category", "geral")
|
|
@@ -1182,7 +988,6 @@ def generate_search_report(term: str, findings: list, url: str, title: str) -> s
|
|
| 1182 |
|
| 1183 |
report.append("")
|
| 1184 |
|
| 1185 |
-
# Explicação didática por tipo
|
| 1186 |
item_type = item.get("type", "").lower()
|
| 1187 |
|
| 1188 |
if "api" in item_type or "endpoint" in item_type or "api" in cat.lower():
|
|
|
|
| 43 |
# ============================================================
|
| 44 |
API_TOKEN = os.environ.get("API_TOKEN", "").strip()
|
| 45 |
|
|
|
|
| 46 |
if API_TOKEN:
|
| 47 |
logger.info(f"[AUTH] API_TOKEN configurado ({len(API_TOKEN)} caracteres)")
|
| 48 |
logger.info(f"[AUTH] Primeiros 4 chars: {API_TOKEN[:4]}...")
|
|
|
|
| 54 |
async def verify_token(credentials: HTTPAuthorizationCredentials = Depends(security)):
|
| 55 |
"""Verifica o token de autenticação"""
|
| 56 |
if not API_TOKEN:
|
| 57 |
+
return True
|
| 58 |
|
| 59 |
if not credentials:
|
| 60 |
raise HTTPException(status_code=401, detail="Token não fornecido")
|
|
|
|
| 72 |
def __init__(self):
|
| 73 |
self.sessions: Dict[str, dict] = {}
|
| 74 |
self.max_sessions = 5
|
| 75 |
+
self.session_timeout = 1800
|
| 76 |
|
| 77 |
def create_session(self, url: str) -> dict:
|
|
|
|
| 78 |
self._cleanup_expired()
|
| 79 |
|
| 80 |
if len(self.sessions) >= self.max_sessions:
|
|
|
|
| 91 |
chrome_options.add_argument('--window-size=1920,1080')
|
| 92 |
chrome_options.add_argument('--disable-extensions')
|
| 93 |
chrome_options.add_argument('--disable-plugins')
|
|
|
|
| 94 |
chrome_options.add_argument('--disable-blink-features=AutomationControlled')
|
| 95 |
chrome_options.add_argument('--user-agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36')
|
| 96 |
chrome_options.binary_location = '/usr/bin/google-chrome'
|
|
|
|
| 101 |
driver = webdriver.Chrome(service=service, options=chrome_options)
|
| 102 |
driver.set_page_load_timeout(60)
|
| 103 |
driver.implicitly_wait(10)
|
|
|
|
|
|
|
| 104 |
driver.execute_cdp_cmd('Runtime.enable', {})
|
| 105 |
driver.execute_cdp_cmd('Log.enable', {})
|
| 106 |
driver.execute_cdp_cmd('Network.enable', {})
|
|
|
|
| 107 |
except Exception as e:
|
| 108 |
logger.error(f"[SESSION] Erro ao criar driver: {e}")
|
| 109 |
raise HTTPException(status_code=500, detail=f"Erro ao iniciar navegador: {str(e)}")
|
|
|
|
| 138 |
}
|
| 139 |
|
| 140 |
def get_session(self, session_id: str) -> dict:
|
|
|
|
| 141 |
if session_id not in self.sessions:
|
| 142 |
raise HTTPException(status_code=404, detail="Sessão não encontrada")
|
|
|
|
| 143 |
session = self.sessions[session_id]
|
|
|
|
| 144 |
if time.time() - session['last_used'] > self.session_timeout:
|
| 145 |
self.close_session(session_id)
|
| 146 |
raise HTTPException(status_code=410, detail="Sessão expirada")
|
|
|
|
| 147 |
session['last_used'] = time.time()
|
| 148 |
return session
|
| 149 |
|
| 150 |
def close_session(self, session_id: str):
|
|
|
|
| 151 |
if session_id in self.sessions:
|
| 152 |
try:
|
| 153 |
self.sessions[session_id]['driver'].quit()
|
|
|
|
| 157 |
logger.info(f"[SESSION] Fechada: {session_id[:8]}...")
|
| 158 |
|
| 159 |
def _cleanup_expired(self):
|
|
|
|
| 160 |
expired = [
|
| 161 |
sid for sid, s in self.sessions.items()
|
| 162 |
if time.time() - s['last_used'] > self.session_timeout
|
|
|
|
| 165 |
self.close_session(sid)
|
| 166 |
|
| 167 |
def close_all(self):
|
|
|
|
| 168 |
for sid in list(self.sessions.keys()):
|
| 169 |
self.close_session(sid)
|
| 170 |
|
|
|
|
| 177 |
|
| 178 |
@asynccontextmanager
|
| 179 |
async def lifespan(app: FastAPI):
|
|
|
|
| 180 |
logger.info("=" * 50)
|
| 181 |
logger.info("[SERVER] Site Backup & Error Checker v1.3.0")
|
| 182 |
logger.info(f"[SERVER] Auth: {'ATIVO (token configurado)' if API_TOKEN else 'DESATIVADO'}")
|
|
|
|
| 194 |
lifespan=lifespan
|
| 195 |
)
|
| 196 |
|
|
|
|
| 197 |
app.add_middleware(
|
| 198 |
CORSMiddleware,
|
| 199 |
allow_origins=["*"],
|
|
|
|
| 231 |
session_id: str
|
| 232 |
url: str
|
| 233 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 234 |
class SearchSiteRequest(BaseModel):
|
| 235 |
session_id: str
|
| 236 |
term: str
|
|
|
|
| 243 |
@app.get("/")
|
| 244 |
@app.head("/")
|
| 245 |
async def root():
|
|
|
|
| 246 |
return {
|
| 247 |
"status": "online",
|
| 248 |
"service": "Site Backup & Error Checker",
|
|
|
|
| 253 |
@app.get("/health")
|
| 254 |
@app.head("/health")
|
| 255 |
async def health():
|
|
|
|
| 256 |
return {
|
| 257 |
"status": "healthy",
|
| 258 |
"timestamp": time.time(),
|
|
|
|
| 266 |
|
| 267 |
@app.post("/auth/verify")
|
| 268 |
async def auth_verify(auth=Depends(verify_token)):
|
|
|
|
| 269 |
return {"valid": True, "message": "Token válido"}
|
| 270 |
|
| 271 |
@app.post("/open")
|
| 272 |
async def open_site(request: OpenSiteRequest, auth=Depends(verify_token)):
|
|
|
|
| 273 |
url = request.url.strip()
|
| 274 |
if not url.startswith(('http://', 'https://')):
|
| 275 |
url = 'https://' + url
|
|
|
|
| 276 |
try:
|
| 277 |
result = session_manager.create_session(url)
|
| 278 |
return result
|
|
|
|
| 284 |
|
| 285 |
@app.post("/session/status")
|
| 286 |
async def session_status(request: SessionRequest, auth=Depends(verify_token)):
|
|
|
|
| 287 |
session = session_manager.get_session(request.session_id)
|
| 288 |
driver = session['driver']
|
|
|
|
| 289 |
try:
|
| 290 |
current_url = driver.current_url
|
| 291 |
title = driver.title
|
| 292 |
except:
|
| 293 |
current_url = session['url']
|
| 294 |
title = session['title']
|
|
|
|
| 295 |
return {
|
| 296 |
"session_id": request.session_id,
|
| 297 |
"url": current_url,
|
|
|
|
| 303 |
|
| 304 |
@app.post("/screenshot")
|
| 305 |
async def take_screenshot(request: SessionRequest, auth=Depends(verify_token)):
|
|
|
|
| 306 |
session = session_manager.get_session(request.session_id)
|
| 307 |
driver = session['driver']
|
|
|
|
| 308 |
try:
|
| 309 |
screenshot = driver.get_screenshot_as_png()
|
| 310 |
return StreamingResponse(
|
|
|
|
| 318 |
|
| 319 |
@app.post("/backup")
|
| 320 |
async def backup_site(request: BackupRequest, auth=Depends(verify_token)):
|
|
|
|
| 321 |
session = session_manager.get_session(request.session_id)
|
| 322 |
driver = session['driver']
|
| 323 |
url = session['url']
|
|
|
|
| 324 |
try:
|
| 325 |
session['status'] = 'backing_up'
|
| 326 |
backup = SiteBackup(driver, url)
|
| 327 |
zip_buffer = backup.generate_backup_zip()
|
| 328 |
session['status'] = 'active'
|
|
|
|
| 329 |
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
|
| 330 |
folder = request.folder_name or "backup"
|
| 331 |
filename = f"{folder}_{timestamp}.zip"
|
|
|
|
| 332 |
errors_count = len(backup.errors) if hasattr(backup, 'errors') else 0
|
|
|
|
| 333 |
return StreamingResponse(
|
| 334 |
io.BytesIO(zip_buffer.getvalue()),
|
| 335 |
media_type="application/zip",
|
|
|
|
| 345 |
|
| 346 |
@app.post("/check-errors")
|
| 347 |
async def check_errors(request: ErrorCheckRequest, auth=Depends(verify_token)):
|
|
|
|
| 348 |
session = session_manager.get_session(request.session_id)
|
| 349 |
driver = session['driver']
|
| 350 |
url = session['url']
|
|
|
|
| 351 |
try:
|
| 352 |
session['status'] = 'checking_errors'
|
| 353 |
checker = SiteErrorChecker(driver, url)
|
| 354 |
checker.run_all_checks()
|
| 355 |
report = checker.generate_report_txt()
|
| 356 |
session['status'] = 'active'
|
|
|
|
| 357 |
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
|
| 358 |
folder = request.folder_name or "erros"
|
| 359 |
filename = f"{folder}_{timestamp}.txt"
|
|
|
|
| 360 |
return StreamingResponse(
|
| 361 |
io.BytesIO(report.encode('utf-8')),
|
| 362 |
media_type="text/plain; charset=utf-8",
|
|
|
|
| 373 |
|
| 374 |
@app.post("/check-errors-json")
|
| 375 |
async def check_errors_json(request: ErrorCheckRequest, auth=Depends(verify_token)):
|
|
|
|
| 376 |
session = session_manager.get_session(request.session_id)
|
| 377 |
driver = session['driver']
|
| 378 |
url = session['url']
|
|
|
|
| 379 |
try:
|
| 380 |
session['status'] = 'checking_errors'
|
| 381 |
checker = SiteErrorChecker(driver, url)
|
| 382 |
checker.run_all_checks()
|
| 383 |
report = checker.generate_report_json()
|
| 384 |
session['status'] = 'active'
|
|
|
|
| 385 |
return JSONResponse(
|
| 386 |
content=report,
|
| 387 |
headers={
|
|
|
|
| 396 |
|
| 397 |
@app.post("/close")
|
| 398 |
async def close_session(request: SessionRequest, auth=Depends(verify_token)):
|
|
|
|
| 399 |
session_manager.close_session(request.session_id)
|
| 400 |
return {"status": "closed", "message": "Sessão encerrada com sucesso"}
|
| 401 |
|
| 402 |
@app.get("/sessions")
|
| 403 |
async def list_sessions(auth=Depends(verify_token)):
|
|
|
|
| 404 |
sessions_list = []
|
| 405 |
for sid, s in session_manager.sessions.items():
|
| 406 |
sessions_list.append({
|
|
|
|
| 415 |
|
| 416 |
@app.post("/navigate")
|
| 417 |
async def navigate(request: NavigateRequest, auth=Depends(verify_token)):
|
|
|
|
| 418 |
session = session_manager.get_session(request.session_id)
|
| 419 |
driver = session['driver']
|
|
|
|
| 420 |
url = request.url.strip()
|
| 421 |
if not url.startswith(('http://', 'https://')):
|
| 422 |
url = 'https://' + url
|
|
|
|
| 423 |
try:
|
| 424 |
driver.get(url)
|
| 425 |
WebDriverWait(driver, 30).until(
|
| 426 |
lambda d: d.execute_script("return document.readyState") == "complete"
|
| 427 |
)
|
|
|
|
| 428 |
session['url'] = driver.current_url
|
| 429 |
session['title'] = driver.title or "Sem título"
|
| 430 |
session['last_used'] = time.time()
|
|
|
|
| 431 |
return {
|
| 432 |
"status": "navigated",
|
| 433 |
"url": session['url'],
|
|
|
|
| 438 |
raise HTTPException(status_code=500, detail=str(e))
|
| 439 |
|
| 440 |
# ============================================================
|
| 441 |
+
# ROTAS DE LOGIN / COOKIES
|
| 442 |
# ============================================================
|
| 443 |
|
| 444 |
+
@app.post("/inject-cookies")
|
| 445 |
+
async def inject_cookies(request: dict, auth=Depends(verify_token)):
|
| 446 |
+
"""Injeta cookies no Selenium para manter sessão de login"""
|
| 447 |
+
session_id = request.get("session_id")
|
| 448 |
+
cookies = request.get("cookies", [])
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 449 |
|
| 450 |
+
if not session_id:
|
| 451 |
+
raise HTTPException(status_code=400, detail="session_id é obrigatório")
|
| 452 |
+
if not cookies:
|
| 453 |
+
raise HTTPException(status_code=400, detail="Nenhum cookie fornecido")
|
| 454 |
|
| 455 |
+
session = session_manager.get_session(session_id)
|
|
|
|
|
|
|
|
|
|
| 456 |
driver = session['driver']
|
| 457 |
|
| 458 |
try:
|
| 459 |
+
injected = 0
|
| 460 |
+
errors = []
|
| 461 |
|
| 462 |
+
for cookie in cookies:
|
| 463 |
+
try:
|
| 464 |
+
selenium_cookie = {
|
| 465 |
+
"name": cookie.get("name", ""),
|
| 466 |
+
"value": cookie.get("value", ""),
|
| 467 |
+
"path": cookie.get("path", "/"),
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 468 |
}
|
|
|
|
| 469 |
|
| 470 |
+
domain = cookie.get("domain", "")
|
| 471 |
+
if domain:
|
| 472 |
+
selenium_cookie["domain"] = domain
|
| 473 |
|
| 474 |
+
if cookie.get("secure"):
|
| 475 |
+
selenium_cookie["secure"] = True
|
| 476 |
|
| 477 |
+
if cookie.get("httpOnly"):
|
| 478 |
+
selenium_cookie["httpOnly"] = True
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 479 |
|
| 480 |
+
same_site = cookie.get("sameSite", "")
|
| 481 |
+
if same_site and same_site != "unspecified":
|
| 482 |
+
selenium_cookie["sameSite"] = same_site
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 483 |
|
| 484 |
+
if cookie.get("expirationDate"):
|
| 485 |
+
selenium_cookie["expiry"] = int(cookie["expirationDate"])
|
| 486 |
|
| 487 |
+
driver.add_cookie(selenium_cookie)
|
| 488 |
+
injected += 1
|
|
|
|
|
|
|
|
|
|
| 489 |
|
| 490 |
+
except Exception as e:
|
| 491 |
+
errors.append(f"Cookie '{cookie.get('name', '?')}': {str(e)}")
|
| 492 |
|
| 493 |
+
# Recarregar página com os cookies
|
| 494 |
+
driver.refresh()
|
| 495 |
+
WebDriverWait(driver, 30).until(
|
| 496 |
+
lambda d: d.execute_script("return document.readyState") == "complete"
|
| 497 |
+
)
|
| 498 |
+
time.sleep(2)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 499 |
|
| 500 |
+
session['url'] = driver.current_url
|
| 501 |
+
session['title'] = driver.title or "Sem título"
|
| 502 |
+
session['last_used'] = time.time()
|
| 503 |
|
| 504 |
screenshot = driver.get_screenshot_as_png()
|
| 505 |
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 506 |
|
| 507 |
+
logger.info(f"[COOKIES] Injetados {injected}/{len(cookies)} cookies na sessão {session_id[:8]}...")
|
| 508 |
+
|
| 509 |
return {
|
| 510 |
+
"status": "success",
|
| 511 |
+
"injected": injected,
|
| 512 |
+
"total": len(cookies),
|
| 513 |
+
"errors": errors,
|
| 514 |
+
"url": session['url'],
|
| 515 |
+
"title": session['title'],
|
| 516 |
+
"screenshot": screenshot_b64
|
| 517 |
}
|
| 518 |
+
|
| 519 |
except Exception as e:
|
| 520 |
+
logger.error(f"[COOKIES] Erro: {e}")
|
| 521 |
raise HTTPException(status_code=500, detail=str(e))
|
| 522 |
|
| 523 |
|
| 524 |
+
@app.post("/get-current-state")
|
| 525 |
+
async def get_current_state(request: SessionRequest, auth=Depends(verify_token)):
|
| 526 |
+
"""Retorna estado atual da página (URL, título, screenshot)"""
|
| 527 |
session = session_manager.get_session(request.session_id)
|
| 528 |
driver = session['driver']
|
| 529 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 530 |
try:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 531 |
screenshot = driver.get_screenshot_as_png()
|
| 532 |
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 533 |
|
| 534 |
+
login_indicators = driver.execute_script("""
|
| 535 |
+
var indicators = {
|
| 536 |
+
has_logout_btn: false,
|
| 537 |
+
has_dashboard: false,
|
| 538 |
+
has_profile: false,
|
| 539 |
+
has_login_form: false,
|
| 540 |
+
page_text_preview: ''
|
| 541 |
+
};
|
| 542 |
+
|
| 543 |
+
var allText = document.body.innerText.toLowerCase();
|
| 544 |
+
indicators.has_logout_btn = /logout|sair|log\\s?out|sign\\s?out|desconectar/i.test(allText);
|
| 545 |
+
indicators.has_dashboard = /dashboard|painel|meu\\s?perfil|minha\\s?conta|bem.vindo|welcome/i.test(allText);
|
| 546 |
+
indicators.has_profile = document.querySelector('[class*="profile"], [class*="avatar"], [class*="user-menu"], [class*="account"]') !== null;
|
| 547 |
+
indicators.has_login_form = document.querySelector('input[type="password"]') !== null;
|
| 548 |
+
indicators.page_text_preview = allText.substring(0, 300);
|
| 549 |
+
|
| 550 |
+
return indicators;
|
| 551 |
+
""")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 552 |
|
| 553 |
+
probably_logged = (
|
| 554 |
+
(login_indicators.get('has_logout_btn') or login_indicators.get('has_dashboard') or login_indicators.get('has_profile'))
|
| 555 |
+
and not login_indicators.get('has_login_form')
|
| 556 |
+
)
|
| 557 |
|
| 558 |
return {
|
|
|
|
|
|
|
| 559 |
"url": driver.current_url,
|
| 560 |
+
"title": driver.title,
|
| 561 |
+
"screenshot": screenshot_b64,
|
| 562 |
+
"probably_logged_in": probably_logged,
|
| 563 |
+
"indicators": login_indicators
|
| 564 |
}
|
| 565 |
+
|
| 566 |
except Exception as e:
|
| 567 |
+
logger.error(f"[STATE] Erro: {e}")
|
| 568 |
raise HTTPException(status_code=500, detail=str(e))
|
| 569 |
|
| 570 |
|
| 571 |
+
@app.post("/refresh-page")
|
| 572 |
+
async def refresh_page(request: SessionRequest, auth=Depends(verify_token)):
|
| 573 |
+
"""Recarrega a página atual"""
|
| 574 |
session = session_manager.get_session(request.session_id)
|
| 575 |
driver = session['driver']
|
| 576 |
|
| 577 |
try:
|
| 578 |
+
driver.refresh()
|
| 579 |
+
WebDriverWait(driver, 30).until(
|
| 580 |
+
lambda d: d.execute_script("return document.readyState") == "complete"
|
| 581 |
+
)
|
| 582 |
+
time.sleep(1)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 583 |
|
| 584 |
+
session['url'] = driver.current_url
|
| 585 |
+
session['title'] = driver.title or "Sem título"
|
| 586 |
+
session['last_used'] = time.time()
|
| 587 |
|
| 588 |
screenshot = driver.get_screenshot_as_png()
|
| 589 |
screenshot_b64 = base64.b64encode(screenshot).decode('utf-8')
|
| 590 |
|
| 591 |
return {
|
| 592 |
+
"status": "refreshed",
|
| 593 |
+
"url": session['url'],
|
| 594 |
+
"title": session['title'],
|
| 595 |
+
"screenshot": screenshot_b64
|
|
|
|
| 596 |
}
|
| 597 |
+
|
| 598 |
except Exception as e:
|
| 599 |
+
logger.error(f"[REFRESH] Erro: {e}")
|
| 600 |
raise HTTPException(status_code=500, detail=str(e))
|
| 601 |
|
| 602 |
|
|
|
|
| 603 |
# ============================================================
|
| 604 |
# ROTAS DE BUSCA NO SITE
|
| 605 |
# ============================================================
|
|
|
|
| 620 |
if any(kw in term for kw in ['api', 'endpoint', 'fetch', 'ajax', 'request', 'requisição', 'requisicao']):
|
| 621 |
apis = driver.execute_script("""
|
| 622 |
var results = [];
|
|
|
|
| 623 |
var scripts = document.querySelectorAll('script');
|
| 624 |
scripts.forEach(function(s) {
|
| 625 |
var text = s.textContent || s.innerText || '';
|
|
|
|
| 626 |
var urlPattern = /(?:fetch|axios\\.(?:get|post|put|delete)|XMLHttpRequest)\\s*\\(\\s*['\"`]([^'\"`]+)['\"`]/g;
|
| 627 |
var match;
|
| 628 |
while ((match = urlPattern.exec(text)) !== null) {
|
| 629 |
results.push({type: 'API Endpoint (fetch/axios)', value: match[1], details: 'Encontrado em script inline'});
|
| 630 |
}
|
|
|
|
| 631 |
var apiPattern = /['\"`]((?:https?:\\/\\/[^'\"`]*\\/api\\/[^'\"`]*)|(?:\\/api\\/[^'\"`]*))['\"`]/g;
|
| 632 |
while ((match = apiPattern.exec(text)) !== null) {
|
| 633 |
results.push({type: 'API URL', value: match[1], details: 'URL contendo /api/'});
|
| 634 |
}
|
| 635 |
});
|
|
|
|
| 636 |
var links = document.querySelectorAll('a[href*="/api/"]');
|
| 637 |
links.forEach(function(l) {
|
| 638 |
results.push({type: 'Link para API', value: l.href, details: l.textContent.trim().substring(0, 100)});
|
| 639 |
});
|
|
|
|
| 640 |
var allElements = document.querySelectorAll('[data-api], [data-url], [data-endpoint]');
|
| 641 |
allElements.forEach(function(el) {
|
| 642 |
var api = el.getAttribute('data-api') || el.getAttribute('data-url') || el.getAttribute('data-endpoint');
|
|
|
|
| 685 |
});
|
| 686 |
}
|
| 687 |
});
|
|
|
|
| 688 |
var allEls = document.querySelectorAll('*');
|
| 689 |
for (var i = 0; i < Math.min(allEls.length, 500); i++) {
|
| 690 |
var bg = window.getComputedStyle(allEls[i]).backgroundImage;
|
|
|
|
| 791 |
links.forEach(function(l) {
|
| 792 |
results.push({type: 'Fonte Externa', value: l.href, details: 'Rel: ' + l.rel});
|
| 793 |
});
|
|
|
|
| 794 |
for (var i = 0; i < document.styleSheets.length; i++) {
|
| 795 |
try {
|
| 796 |
var rules = document.styleSheets[i].cssRules || [];
|
|
|
|
| 813 |
if any(kw in term for kw in ['cookie', 'cookies', 'storage', 'localstorage', 'sessionstorage', 'armazenamento']):
|
| 814 |
storage = driver.execute_script("""
|
| 815 |
var results = [];
|
|
|
|
| 816 |
var cookies = document.cookie.split(';');
|
| 817 |
cookies.forEach(function(c) {
|
| 818 |
c = c.trim();
|
|
|
|
| 821 |
results.push({type: 'Cookie', value: parts[0], details: 'Valor: ' + (parts.slice(1).join('=') || '[vazio]')});
|
| 822 |
}
|
| 823 |
});
|
|
|
|
| 824 |
for (var i = 0; i < localStorage.length; i++) {
|
| 825 |
var key = localStorage.key(i);
|
| 826 |
var val = localStorage.getItem(key);
|
| 827 |
results.push({type: 'LocalStorage', value: key, details: 'Valor: ' + (val ? val.substring(0, 100) : '[vazio]')});
|
| 828 |
}
|
|
|
|
| 829 |
for (var i = 0; i < sessionStorage.length; i++) {
|
| 830 |
var key = sessionStorage.key(i);
|
| 831 |
var val = sessionStorage.getItem(key);
|
|
|
|
| 842 |
generic = driver.execute_script("""
|
| 843 |
var term = arguments[0];
|
| 844 |
var results = [];
|
|
|
|
| 845 |
var body = document.body.innerHTML;
|
| 846 |
var regex = new RegExp('([^<>]{0,50}' + term.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\$&') + '[^<>]{0,50})', 'gi');
|
| 847 |
var matches = body.match(regex);
|
|
|
|
| 851 |
results.push({type: 'Texto encontrado', value: m.trim(), details: 'Encontrado no conteúdo da página'});
|
| 852 |
});
|
| 853 |
}
|
|
|
|
| 854 |
var allEls = document.querySelectorAll('*');
|
| 855 |
for (var i = 0; i < Math.min(allEls.length, 1000); i++) {
|
| 856 |
var attrs = allEls[i].attributes;
|
|
|
|
| 885 |
@app.post("/search-site-txt")
|
| 886 |
async def search_site_txt(request: SearchSiteRequest, auth=Depends(verify_token)):
|
| 887 |
"""Busca no site e retorna relatório TXT"""
|
|
|
|
| 888 |
session = session_manager.get_session(request.session_id)
|
| 889 |
driver = session['driver']
|
| 890 |
|
| 891 |
term = request.term.strip().lower()
|
| 892 |
|
| 893 |
try:
|
|
|
|
| 894 |
fake_request = SearchSiteRequest(
|
| 895 |
session_id=request.session_id,
|
| 896 |
term=request.term,
|
| 897 |
folder_name=request.folder_name
|
| 898 |
)
|
| 899 |
|
|
|
|
| 900 |
search_data = await search_site(fake_request)
|
| 901 |
|
| 902 |
+
findings = []
|
| 903 |
+
if isinstance(search_data, dict):
|
| 904 |
+
findings = search_data.get('findings', [])
|
| 905 |
+
elif hasattr(search_data, 'body'):
|
| 906 |
+
try:
|
| 907 |
+
body_data = json.loads(search_data.body.decode())
|
| 908 |
+
findings = body_data.get('findings', [])
|
| 909 |
+
except:
|
| 910 |
+
findings = []
|
| 911 |
+
|
| 912 |
report = generate_search_report(
|
| 913 |
term=request.term,
|
| 914 |
+
findings=findings,
|
| 915 |
url=driver.current_url,
|
| 916 |
title=driver.title
|
| 917 |
)
|
|
|
|
| 965 |
report.append(" - O termo pode estar escrito de forma diferente")
|
| 966 |
report.append("")
|
| 967 |
else:
|
|
|
|
| 968 |
grouped = {}
|
| 969 |
for f in findings:
|
| 970 |
cat = f.get("category", "geral")
|
|
|
|
| 988 |
|
| 989 |
report.append("")
|
| 990 |
|
|
|
|
| 991 |
item_type = item.get("type", "").lower()
|
| 992 |
|
| 993 |
if "api" in item_type or "endpoint" in item_type or "api" in cat.lower():
|