One post tagged with "express"

// Tạo schema mới trong db.ts
const newSchema = new mongoose.Schema({
  field1: { type: String, required: true },
  field2: { type: Number, default: 0 },
  timestamps: true
});

// Export model
export const NewModel = mongoose.model('NewModel', newSchema);

// 1. Định nghĩa route trong routes.ts
app.get("/api/endpoint", async (req, res) => {
  try {
    // Validation
    const { param } = req.params;
    const { query } = req.query;
    
    // Business logic
    const result = await storage.methodName(param, query);
    
    // Response
    res.json(result);
  } catch (error) {
    console.error("Error:", error);
    res.status(500).json({ message: "Internal server error" });
  }
});

// 2. Implement logic trong mongoStorage.ts
async methodName(param: string, query?: string): Promise<ResultType> {
  try {
    const data = await Model.find({ conditions });
    return data.map(item => ({
      // Transform data
    }));
  } catch (error) {
    console.error("Database error:", error);
    throw error;
  }
}

// Create
const newItem = new Model(data);
await newItem.save();

// Read
const items = await Model.find(query)
  .populate('relatedField')
  .sort({ createdAt: -1 });

// Update
await Model.findByIdAndUpdate(id, updateData, { new: true });

// Delete
await Model.findByIdAndDelete(id);

// Date range query
const bookings = await Booking.find({
  bookingDate: {
    $gte: startDate,
    $lt: endDate
  }
});

// Text search
const facilities = await Facility.find({
  $or: [
    { name: { $regex: searchTerm, $options: 'i' }},
    { address: { $regex: searchTerm, $options: 'i' }}
  ]
});

// Aggregation
const stats = await Booking.aggregate([
  { $match: { status: 'confirmed' }},
  { $group: { _id: '$facilityId', total: { $sum: '$totalPrice' }}}
]);

// Login endpoint
app.post("/api/auth/login", async (req, res) => {
  const { username, password } = req.body;
  
  // Verify credentials
  const user = await storage.getUserByUsername(username);
  const isValid = await bcrypt.compare(password, user.password);
  
  if (isValid) {
    // Set session
    req.session.user = { id: user._id, username: user.username };
    res.json(userInfo);
  } else {
    res.status(401).json({ message: "Invalid credentials" });
  }
});

// Protected route middleware
const requireAuth = (req, res, next) => {
  if (!req.session.user) {
    return res.status(401).json({ message: "Not authenticated" });
  }
  next();
};

// Standard error response
{
  "message": "Human readable error message",
  "code": "ERROR_CODE",
  "details": "Additional error details"
}

// Validation error response
{
  "message": "Validation failed",
  "errors": [
    {
      "field": "fieldName",
      "message": "Field specific error"
    }
  ]
}

try {
  // Business logic
  const result = await operationThatMightFail();
  res.json(result);
} catch (error) {
  // Log error for debugging
  console.error("Operation failed:", error);
  
  // Return appropriate error response
  if (error.name === 'ValidationError') {
    res.status(400).json({ message: "Invalid input data" });
  } else if (error.name === 'CastError') {
    res.status(400).json({ message: "Invalid ID format" });
  } else {
    res.status(500).json({ message: "Internal server error" });
  }
}

// Tạo index cho truy vấn thường xuyên
facilitySchema.index({ name: 'text', address: 'text' });
bookingSchema.index({ facilityId: 1, bookingDate: 1 });
userSchema.index({ username: 1 }, { unique: true });

// Sử dụng lean() cho read-only queries
const facilities = await Facility.find(query).lean();

// Limit fields với select()
const users = await User.find().select('name email phone');

// Pagination
const page = parseInt(req.query.page) || 1;
const limit = parseInt(req.query.limit) || 10;
const skip = (page - 1) * limit;

const results = await Model.find(query)
  .skip(skip)
  .limit(limit);

/**
 * GET /api/facilities/:id/bookings
 * 
 * Lấy danh sách booking của một cơ sở thể thao
 * 
 * @param {string} id - ID của cơ sở thể thao
 * @query {string} date - Ngày cần lọc (YYYY-MM-DD) - optional
 * 
 * @returns {Array} Danh sách booking
 * @example
 * // Request
 * GET /api/facilities/123/bookings?date=2025-05-27
 * 
 * // Response
 * [
 *   {
 *     "id": "booking_id",
 *     "customerName": "Tên khách",
 *     "selectedSlots": [...],
 *     "totalPrice": 350000
 *   }
 * ]
 */

// Xử lý logic đặt sân với multiple time slots
const processBookingSlots = (selectedSlots) => {
  // Validate từng slot
  selectedSlots.forEach(slot => {
    if (!slot.fieldId || !slot.timeRange) {
      throw new Error('Missing required slot data');
    }
  });
  
  // Tính tổng thời gian và giá
  const totalDuration = calculateTotalDuration(selectedSlots);
  const totalPrice = selectedSlots.reduce((sum, slot) => sum + slot.price, 0);
  
  return { totalDuration, totalPrice };
};

// Check MongoDB connection
if (mongoose.connection.readyState !== 1) {
  console.error('MongoDB not connected');
  // Implement reconnection logic
}

// Debug session issues
app.use((req, res, next) => {
  console.log('Session:', req.session);
  console.log('User:', req.session?.user);
  next();
});

// Enable CORS for development
app.use(cors({
  origin: 'http://localhost:3000',
  credentials: true
}));