server.js

import express from 'express';
import cors from 'cors';
import { dirname, join } from 'path';
import { fileURLToPath } from 'url';
import { runPipeline } from './src/index.js';

const __dirname = dirname(fileURLToPath(import.meta.url));

const app = express();
const PORT = 3000;

// Armazena os últimos dados extraídos em memória
let lastScrapeData = null;

app.use(cors());
app.use(express.static(join(__dirname, 'public')));

// GET /api/data — retorna os dados do último scrape (se houver)
app.get('/api/data', (req, res) => {
  if (!lastScrapeData) {
    return res.json({ success: false, message: 'Nenhum dado disponível. Execute o scrape primeiro.' });
  }
  res.json({ success: true, data: lastScrapeData });
});

// POST /api/scrape — dispara uma nova extração e retorna os dados
app.post('/api/scrape', async (req, res) => {
  try {
    console.log('[API] Disparando extração...');
    const result = await runPipeline();

    lastScrapeData = {
      listings: result.processedListings,
      stats: result.stats,
      dealsCount: result.deals.length,
      elapsed: result.elapsed,
      scrapedAt: new Date().toLocaleString('pt-BR'),
    };

    res.json({ success: true, data: lastScrapeData });
  } catch (error) {
    console.error('[API] Erro:', error.message);
    res.status(500).json({ success: false, error: error.message });
  }
});

app.listen(PORT, () => {
  console.log(`\n======================================================`);
  console.log(`🚀 Frontend rodando: http://localhost:${PORT}`);
  console.log(`======================================================\n`);
});