# Node.js Tour Agency API with MySQL and External API Integration I'll create a comprehensive tour agency API system with Node.js, MySQL database, and external API integration. Here's the setup: ```xml { "name": "tour-agency-api", "version": "1.0.0", "description": "Tour agency API with MySQL and external API integration", "main": "server.js", "scripts": { "start": "node server.js", "dev": "nodemon server.js" }, "dependencies": { "express": "^4.18.2", "mysql2": "^3.6.0", "sequelize": "^6.35.0", "dotenv": "^16.3.1", "cors": "^2.8.5", "axios": "^1.6.2", "jsonwebtoken": "^9.0.2", "bcryptjs": "^2.4.3", "morgan": "^1.10.0" }, "devDependencies": { "nodemon": "^3.0.2" } } require('dotenv').config(); const express = require('express'); const cors = require('cors'); const morgan = require('morgan'); const { Sequelize } = require('sequelize'); const tourRoutes = require('./routes/tours'); const bookingRoutes = require('./routes/bookings'); const userRoutes = require('./routes/users'); const externalApiRoutes = require('./routes/externalApi'); const app = express(); // Middleware app.use(cors()); app.use(express.json()); app.use(morgan('dev')); // Database connection const sequelize = new Sequelize( process.env.DB_NAME, process.env.DB_USER, process.env.DB_PASSWORD, { host: process.env.DB_HOST, dialect: 'mysql' } ); // Test DB connection sequelize.authenticate() .then(() => console.log('Database connected')) .catch(err => console.error('Unable to connect to the database:', err)); // Routes app.use('/api/tours', tourRoutes); app.use('/api/bookings', bookingRoutes); app.use('/api/users', userRoutes); app.use('/api/external', externalApiRoutes); const PORT = process.env.PORT || 5000; app.listen(PORT, () => { console.log(`Server running on port ${PORT}`); }); DB_NAME=tour_agency DB_USER=root DB_PASSWORD=your_mysql_password DB_HOST=localhost JWT_SECRET=your_jwt_secret_key WEATHER_API_KEY=your_weather_api_key CURRENCY_API_KEY=your_currency_api_key const { DataTypes } = require('sequelize'); const sequelize = require('../config/database'); const Tour = sequelize.define('Tour', { id: { type: DataTypes.INTEGER, primaryKey: true, autoIncrement: true }, title: { type: DataTypes.STRING, allowNull: false }, description: { type: DataTypes.TEXT, allowNull: false }, location: { type: DataTypes.STRING, allowNull: false }, duration: { type: DataTypes.INTEGER, allowNull: false }, price: { type: DataTypes.DECIMAL(10, 2), allowNull: false }, startDate: { type: DataTypes.DATE, allowNull: false }, endDate: { type: DataTypes.DATE, allowNull: false }, maxParticipants: { type: DataTypes.INTEGER, allowNull: false }, imageUrl: { type: DataTypes.STRING, allowNull: true } }, { timestamps: true }); module.exports = Tour; const { DataTypes } = require('sequelize'); const sequelize = require('../config/database'); const Booking = sequelize.define('Booking', { id: { type: DataTypes.INTEGER, primaryKey: true, autoIncrement: true }, tourId: { type: DataTypes.INTEGER, allowNull: false }, userId: { type: DataTypes.INTEGER, allowNull: false }, bookingDate: { type: DataTypes.DATE, defaultValue: DataTypes.NOW }, participants: { type: DataTypes.INTEGER, allowNull: false }, totalPrice: { type: DataTypes.DECIMAL(10, 2), allowNull: false }, status: { type: DataTypes.ENUM('pending', 'confirmed', 'cancelled'), defaultValue: 'pending' } }, { timestamps: true }); module.exports = Booking; const { DataTypes } = require('sequelize'); const sequelize = require('../config/database'); const bcrypt = require('bcryptjs'); const User = sequelize.define('User', { id: { type: DataTypes.INTEGER, primaryKey: true, autoIncrement: true }, name: { type: DataTypes.STRING, allowNull: false }, email: { type: DataTypes.STRING, allowNull: false, unique: true }, password: { type: DataTypes.STRING, allowNull: false }, role: { type: DataTypes.ENUM('user', 'admin'), defaultValue: 'user' } }, { timestamps: true, hooks: { beforeCreate: async (user) => { user.password = await bcrypt.hash(user.password, 10); } } }); User.prototype.validPassword = async function(password) { return await bcrypt.compare(password, this.password); }; module.exports = User; const { Sequelize } = require('sequelize'); require('dotenv').config(); const sequelize = new Sequelize( process.env.DB_NAME, process.env.DB_USER, process.env.DB_PASSWORD, { host: process.env.DB_HOST, dialect: 'mysql' } ); module.exports = sequelize; const express = require('express'); const router = express.Router(); const Tour = require('../models/Tour'); const { Op } = require('sequelize'); // Get all tours router.get('/', async (req, res) => { try { const tours = await Tour.findAll(); res.json(tours); } catch (err) { res.status(500).json({ message: err.message }); } }); // Get single tour router.get('/:id', async (req, res) => { try { const tour = await Tour.findByPk(req.params.id); if (!tour) { return res.status(404).json({ message: 'Tour not found' }); } res.json(tour); } catch (err) { res.status(500).json({ message: err.message }); } }); // Create tour (admin only) router.post('/', async (req, res) => { try { const tour = await Tour.create(req.body); res.status(201).json(tour); } catch (err) { res.status(400).json({ message: err.message }); } }); // Update tour (admin only) router.put('/:id', async (req, res) => { try { const tour = await Tour.findByPk(req.params.id); if (!tour) { return res.status(404).json({ message: 'Tour not found' }); } await tour.update(req.body); res.json(tour); } catch (err) { res.status(400).json({ message: err.message }); } }); // Delete tour (admin only) router.delete('/:id', async (req, res) => { try { const tour = await Tour.findByPk(req.params.id); if (!tour) { return res.status(404).json({ message: 'Tour not found' }); } await tour.destroy(); res.json({ message: 'Tour deleted' }); } catch (err) { res.status(500).json({ message: err.message }); } }); // Search tours router.get('/search/:query', async (req, res) => { try { const tours = await Tour.findAll({ where: { [Op.or]: [ { title: { [Op.like]: `%${req.params.query}%` } }, { location: { [Op.like]: `%${req.params.query}%` } }, { description: { [Op.like]: `%${req.params.query}%` } } ] } }); res.json(tours); } catch (err) { res.status(500).json({ message: err.message }); } }); module.exports = router; const express = require('express'); const router = express.Router(); const Booking = require('../models/Booking'); const Tour = require('../models/Tour'); const User = require('../models/User'); const { authenticate } = require('../middleware/auth'); // Get all bookings (admin only) router.get('/', authenticate, async (req, res) => { try { if (req.user.role !== 'admin') { return res.status(403).json({ message: 'Unauthorized' }); } const bookings = await Booking.findAll({ include: [Tour, User] }); res.json(bookings); } catch (err) { res.status(500).json({ message: err.message }); } }); // Get user's bookings router.get('/my-bookings', authenticate, async (req, res) => { try { const bookings = await Booking.findAll({ where: { userId: req.user.id }, include: Tour }); res.json(bookings); } catch (err) { res.status(500).json({ message: err.message }); } }); // Create booking router.post('/', authenticate, async (req, res) => { try { const tour = await Tour.findByPk(req.body.tourId); if (!tour) { return res.status(404).json({ message: 'Tour not found' }); } const booking = await Booking.create({ tourId: req.body.tourId, userId: req.user.id, participants: req.body.participants, totalPrice: tour.price * req.body.participants }); res.status(201).json(booking); } catch (err) { res.status(400).json({ message: err.message }); } }); // Cancel booking router.put('/:id/cancel', authenticate, async (req, res) => { try { const booking = await Booking.findByPk(req.params.id); if (!booking) { return res.status(404).json({ message: 'Booking not found' }); } if (booking.userId !== req.user.id && req.user.role !== 'admin') { return res.status(403).json({ message: 'Unauthorized' }); } await booking.update({ status: 'cancelled' }); res.json(booking); } catch (err) { res.status(500).json({ message: err.message }); } }); module.exports = router; const express = require('express'); const router = express.Router(); const User = require('../models/