import express from 'express';
import { backgroundJobService } from '../services/backgroundJobService.js';

const router = express.Router();

/**
 * Start a new background job
 */
router.post('/start', async (req, res) => {
  try {
    const { type, options } = req.body;
    
    if (!type || !['s3-sync', 'song-matching'].includes(type)) {
      return res.status(400).json({ error: 'Invalid job type. Must be "s3-sync" or "song-matching"' });
    }
    
    console.log(`🚀 Starting background job: ${type}`);
    const jobId = await backgroundJobService.startJob({ type, options });
    
    res.json({
      message: 'Background job started',
      jobId,
      type
    });
  } catch (error) {
    console.error('Error starting background job:', error);
    res.status(500).json({ error: 'Failed to start background job' });
  }
});

/**
 * Get job progress
 */
router.get('/progress/:jobId', async (req, res) => {
  try {
    const { jobId } = req.params;
    const progress = backgroundJobService.getJobProgress(jobId);
    
    if (!progress) {
      return res.status(404).json({ error: 'Job not found' });
    }
    
    res.json(progress);
  } catch (error) {
    console.error('Error getting job progress:', error);
    res.status(500).json({ error: 'Failed to get job progress' });
  }
});



/**
 * Get all jobs
 */
router.get('/jobs', async (req, res) => {
  try {
    const jobs = backgroundJobService.getAllJobs();
    res.json({ jobs });
  } catch (error) {
    console.error('Error getting jobs:', error);
    res.status(500).json({ error: 'Failed to get jobs' });
  }
});

/**
 * Clean up old jobs
 */
router.post('/cleanup', async (req, res) => {
  try {
    backgroundJobService.cleanupOldJobs();
    res.json({ message: 'Old jobs cleaned up successfully' });
  } catch (error) {
    console.error('Error cleaning up jobs:', error);
    res.status(500).json({ error: 'Failed to clean up jobs' });
  }
});

export default router;