breedr/server/routes/dogs.js

const express = require('express');
const router  = express.Router();
const { getDatabase } = require('../db/init');
const multer = require('multer');
const path   = require('path');
const fs     = require('fs');

const storage = multer.diskStorage({
  destination: (req, file, cb) => {
    const uploadPath = process.env.UPLOAD_PATH || path.join(__dirname, '../../uploads');
    cb(null, uploadPath);
  },
  filename: (req, file, cb) => {
    const uniqueName = `${Date.now()}-${Math.random().toString(36).substring(7)}${path.extname(file.originalname)}`;
    cb(null, uniqueName);
  }
});

const upload = multer({
  storage,
  limits: { fileSize: 10 * 1024 * 1024 },
  fileFilter: (req, file, cb) => {
    const allowed = /jpeg|jpg|png|gif|webp/;
    if (allowed.test(path.extname(file.originalname).toLowerCase()) && allowed.test(file.mimetype)) {
      cb(null, true);
    } else {
      cb(new Error('Only image files are allowed'));
    }
  }
});

const emptyToNull = (v) => (v === '' || v === undefined) ? null : v;

// ── Shared SELECT columns ────────────────────────────────────────────
const DOG_COLS = `
  id, name, registration_number, breed, sex, birth_date,
  color, microchip, photo_urls, notes, litter_id, is_active,
  is_champion, created_at, updated_at
`;

// ── GET all dogs ─────────────────────────────────────────────────────
router.get('/', (req, res) => {
  try {
    const db = getDatabase();
    const dogs = db.prepare(`
      SELECT ${DOG_COLS}
      FROM dogs
      WHERE is_active = 1
      ORDER BY name
    `).all();

    const parentStmt = db.prepare(`
      SELECT p.parent_type, d.id, d.name, d.is_champion
      FROM parents p
      JOIN dogs d ON p.parent_id = d.id
      WHERE p.dog_id = ?
    `);

    dogs.forEach(dog => {
      dog.photo_urls = dog.photo_urls ? JSON.parse(dog.photo_urls) : [];
      const parents = parentStmt.all(dog.id);
      dog.sire = parents.find(p => p.parent_type === 'sire') || null;
      dog.dam  = parents.find(p => p.parent_type === 'dam')  || null;
    });

    res.json(dogs);
  } catch (error) {
    console.error('Error fetching dogs:', error);
    res.status(500).json({ error: error.message });
  }
});

// ── GET single dog (with parents + offspring) ────────────────────────
router.get('/:id', (req, res) => {
  try {
    const db = getDatabase();
    const dog = db.prepare(`SELECT ${DOG_COLS} FROM dogs WHERE id = ?`).get(req.params.id);

    if (!dog) return res.status(404).json({ error: 'Dog not found' });

    dog.photo_urls = dog.photo_urls ? JSON.parse(dog.photo_urls) : [];

    const parents = db.prepare(`
      SELECT p.parent_type, d.id, d.name, d.is_champion
      FROM parents p
      JOIN dogs d ON p.parent_id = d.id
      WHERE p.dog_id = ?
    `).all(req.params.id);

    dog.sire = parents.find(p => p.parent_type === 'sire') || null;
    dog.dam  = parents.find(p => p.parent_type === 'dam')  || null;

    dog.offspring = db.prepare(`
      SELECT d.id, d.name, d.sex, d.is_champion
      FROM dogs d
      JOIN parents p ON d.id = p.dog_id
      WHERE p.parent_id = ? AND d.is_active = 1
    `).all(req.params.id);

    res.json(dog);
  } catch (error) {
    console.error('Error fetching dog:', error);
    res.status(500).json({ error: error.message });
  }
});

// ── POST create dog ──────────────────────────────────────────────────
router.post('/', (req, res) => {
  try {
    const { name, registration_number, breed, sex, birth_date, color,
            microchip, notes, sire_id, dam_id, litter_id, is_champion } = req.body;

    console.log('Creating dog:', { name, breed, sex, sire_id, dam_id, litter_id, is_champion });

    if (!name || !breed || !sex) {
      return res.status(400).json({ error: 'Name, breed, and sex are required' });
    }

    const db = getDatabase();
    const result = db.prepare(`
      INSERT INTO dogs (name, registration_number, breed, sex, birth_date, color,
                        microchip, notes, litter_id, photo_urls, is_champion)
      VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
    `).run(
      name,
      emptyToNull(registration_number),
      breed, sex,
      emptyToNull(birth_date),
      emptyToNull(color),
      emptyToNull(microchip),
      emptyToNull(notes),
      emptyToNull(litter_id),
      '[]',
      is_champion ? 1 : 0
    );

    const dogId = result.lastInsertRowid;
    console.log(`✔ Dog inserted with ID: ${dogId}`);

    if (sire_id && sire_id !== '' && sire_id !== null) {
      db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, ?)').run(dogId, sire_id, 'sire');
    }
    if (dam_id && dam_id !== '' && dam_id !== null) {
      db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, ?)').run(dogId, dam_id, 'dam');
    }

    const dog = db.prepare(`SELECT ${DOG_COLS} FROM dogs WHERE id = ?`).get(dogId);
    dog.photo_urls = [];

    console.log(`✔ Dog created: ${dog.name} (ID: ${dogId})`);
    res.status(201).json(dog);
  } catch (error) {
    console.error('Error creating dog:', error);
    res.status(500).json({ error: error.message });
  }
});

// ── PUT update dog ───────────────────────────────────────────────────
router.put('/:id', (req, res) => {
  try {
    const { name, registration_number, breed, sex, birth_date, color,
            microchip, notes, sire_id, dam_id, litter_id, is_champion } = req.body;

    console.log(`Updating dog ${req.params.id}:`, { name, breed, sex, sire_id, dam_id, is_champion });

    const db = getDatabase();
    db.prepare(`
      UPDATE dogs
      SET name = ?, registration_number = ?, breed = ?, sex = ?,
          birth_date = ?, color = ?, microchip = ?, notes = ?,
          litter_id = ?, is_champion = ?, updated_at = datetime('now')
      WHERE id = ?
    `).run(
      name,
      emptyToNull(registration_number),
      breed, sex,
      emptyToNull(birth_date),
      emptyToNull(color),
      emptyToNull(microchip),
      emptyToNull(notes),
      emptyToNull(litter_id),
      is_champion ? 1 : 0,
      req.params.id
    );

    db.prepare('DELETE FROM parents WHERE dog_id = ?').run(req.params.id);
    if (sire_id && sire_id !== '' && sire_id !== null) {
      db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, ?)').run(req.params.id, sire_id, 'sire');
    }
    if (dam_id && dam_id !== '' && dam_id !== null) {
      db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, ?)').run(req.params.id, dam_id, 'dam');
    }

    const dog = db.prepare(`SELECT ${DOG_COLS} FROM dogs WHERE id = ?`).get(req.params.id);
    dog.photo_urls = dog.photo_urls ? JSON.parse(dog.photo_urls) : [];

    console.log(`✔ Dog updated: ${dog.name} (ID: ${req.params.id})`);
    res.json(dog);
  } catch (error) {
    console.error('Error updating dog:', error);
    res.status(500).json({ error: error.message });
  }
});

// ── DELETE dog (hard delete with cascade) ────────────────────────────
// Removes: parent relationships (both directions), health records,
// heat cycles, and the dog record itself.
// Photo files on disk are NOT removed here — run a gc job if needed.
router.delete('/:id', (req, res) => {
  try {
    const db = getDatabase();
    const existing = db.prepare('SELECT id, name FROM dogs WHERE id = ?').get(req.params.id);
    if (!existing) return res.status(404).json({ error: 'Dog not found' });

    const id = req.params.id;

    // Cascade cleanup
    db.prepare('DELETE FROM parents       WHERE parent_id = ?').run(id); // remove as parent
    db.prepare('DELETE FROM parents       WHERE dog_id    = ?').run(id); // remove own parents
    db.prepare('DELETE FROM health_records WHERE dog_id   = ?').run(id);
    db.prepare('DELETE FROM heat_cycles   WHERE dog_id    = ?').run(id);
    db.prepare('DELETE FROM dogs          WHERE id        = ?').run(id);

    console.log(`✔ Dog #${id} (${existing.name}) permanently deleted`);
    res.json({ success: true, message: `${existing.name} has been deleted` });
  } catch (error) {
    console.error('Error deleting dog:', error);
    res.status(500).json({ error: error.message });
  }
});

// ── POST upload photo ────────────────────────────────────────────────
router.post('/:id/photos', upload.single('photo'), (req, res) => {
  try {
    if (!req.file) return res.status(400).json({ error: 'No file uploaded' });

    const db = getDatabase();
    const dog = db.prepare('SELECT photo_urls FROM dogs WHERE id = ?').get(req.params.id);
    if (!dog) return res.status(404).json({ error: 'Dog not found' });

    const photoUrls = dog.photo_urls ? JSON.parse(dog.photo_urls) : [];
    photoUrls.push(`/uploads/${req.file.filename}`);
    db.prepare('UPDATE dogs SET photo_urls = ? WHERE id = ?').run(JSON.stringify(photoUrls), req.params.id);

    res.json({ url: `/uploads/${req.file.filename}`, photos: photoUrls });
  } catch (error) {
    console.error('Error uploading photo:', error);
    res.status(500).json({ error: error.message });
  }
});

// ── DELETE photo ─────────────────────────────────────────────────────
router.delete('/:id/photos/:photoIndex', (req, res) => {
  try {
    const db = getDatabase();
    const dog = db.prepare('SELECT photo_urls FROM dogs WHERE id = ?').get(req.params.id);
    if (!dog) return res.status(404).json({ error: 'Dog not found' });

    const photoUrls  = dog.photo_urls ? JSON.parse(dog.photo_urls) : [];
    const photoIndex = parseInt(req.params.photoIndex);

    if (photoIndex >= 0 && photoIndex < photoUrls.length) {
      const photoPath = path.join(
        process.env.UPLOAD_PATH || path.join(__dirname, '../../uploads'),
        path.basename(photoUrls[photoIndex])
      );
      if (fs.existsSync(photoPath)) fs.unlinkSync(photoPath);
      photoUrls.splice(photoIndex, 1);
      db.prepare('UPDATE dogs SET photo_urls = ? WHERE id = ?').run(JSON.stringify(photoUrls), req.params.id);
    }

    res.json({ photos: photoUrls });
  } catch (error) {
    console.error('Error deleting photo:', error);
    res.status(500).json({ error: error.message });
  }
});

module.exports = router;