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'); // Configure multer for photo uploads 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 }, // 10MB limit fileFilter: (req, file, cb) => { const allowedTypes = /jpeg|jpg|png|gif|webp/; const extname = allowedTypes.test(path.extname(file.originalname).toLowerCase()); const mimetype = allowedTypes.test(file.mimetype); if (extname && mimetype) { cb(null, true); } else { cb(new Error('Only image files are allowed')); } } }); // GET all dogs router.get('/', (req, res) => { try { const db = getDatabase(); const dogs = db.prepare('SELECT * FROM dogs WHERE is_active = 1 ORDER BY name').all(); // Parse photo_urls JSON dogs.forEach(dog => { dog.photo_urls = dog.photo_urls ? JSON.parse(dog.photo_urls) : []; }); res.json(dogs); } catch (error) { res.status(500).json({ error: error.message }); } }); // GET single dog by ID router.get('/:id', (req, res) => { try { const db = getDatabase(); const dog = db.prepare('SELECT * 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) : []; // Get parents const parents = db.prepare(` SELECT p.parent_type, d.* 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; // Get offspring dog.offspring = db.prepare(` SELECT d.* 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) { res.status(500).json({ error: error.message }); } }); // POST create new dog router.post('/', (req, res) => { try { const { name, registration_number, breed, sex, birth_date, color, microchip, notes, sire_id, dam_id } = req.body; 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, photo_urls) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) `).run(name, registration_number, breed, sex, birth_date, color, microchip, notes, '[]'); const dogId = result.lastInsertRowid; // Add parent relationships if (sire_id) { db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, "sire")').run(dogId, sire_id); } if (dam_id) { db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, "dam")').run(dogId, dam_id); } const dog = db.prepare('SELECT * FROM dogs WHERE id = ?').get(dogId); dog.photo_urls = []; res.status(201).json(dog); } catch (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 } = req.body; const db = getDatabase(); db.prepare(` UPDATE dogs SET name = ?, registration_number = ?, breed = ?, sex = ?, birth_date = ?, color = ?, microchip = ?, notes = ? WHERE id = ? `).run(name, registration_number, breed, sex, birth_date, color, microchip, notes, req.params.id); // Update parent relationships db.prepare('DELETE FROM parents WHERE dog_id = ?').run(req.params.id); if (sire_id) { db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, "sire")').run(req.params.id, sire_id); } if (dam_id) { db.prepare('INSERT INTO parents (dog_id, parent_id, parent_type) VALUES (?, ?, "dam")').run(req.params.id, dam_id); } const dog = db.prepare('SELECT * FROM dogs WHERE id = ?').get(req.params.id); dog.photo_urls = dog.photo_urls ? JSON.parse(dog.photo_urls) : []; res.json(dog); } catch (error) { res.status(500).json({ error: error.message }); } }); // DELETE dog (soft delete) router.delete('/:id', (req, res) => { try { const db = getDatabase(); db.prepare('UPDATE dogs SET is_active = 0 WHERE id = ?').run(req.params.id); res.json({ message: 'Dog deleted successfully' }); } catch (error) { res.status(500).json({ error: error.message }); } }); // POST upload photo for dog 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) { res.status(500).json({ error: error.message }); } }); // DELETE photo from dog 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])); // Delete file from disk 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) { res.status(500).json({ error: error.message }); } }); module.exports = router;