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(); // Also pull sire/dam so list page can compute bloodline status 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) : []; // Parents — include is_champion so frontend can render bloodline badge 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; // Offspring — include is_champion for badge on offspring cards 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 ); // Re-link parents 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 (soft) ─────────────────────────────────────────────── router.delete('/:id', (req, res) => { try { const db = getDatabase(); db.prepare('UPDATE dogs SET is_active = 0 WHERE id = ?').run(req.params.id); console.log(`✓ Dog soft-deleted: ID ${req.params.id}`); res.json({ message: 'Dog deleted successfully' }); } 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;