Phone Validation Middleware for Express.js API

const axios = require('axios');

/**
 * Middleware to validate phone numbers using Phone Validator API
 * @param {string} fieldName - The field name in req.body (default: 'phone')
 */
const validatePhone = (fieldName = 'phone') => {
  return async (req, res, next) => {
    const phoneNumber = req.body[fieldName];
    
    // Check if phone number is provided
    if (!phoneNumber) {
      return res.status(400).json({
        success: false,
        error: `${fieldName} is required`
      });
    }
    
    try {
      // Call Phone Validator API
      const response = await axios.get(
        'https://phone-validator7.p.rapidapi.com/validate',
        {
          params: { phone: phoneNumber },
          headers: {
            'X-RapidAPI-Key': process.env.RAPIDAPI_KEY,
            'X-RapidAPI-Host': 'phone-validator7.p.rapidapi.com'
          },
          timeout: 5000 // 5 second timeout
        }
      );
      
      const validationResult = response.data;
      
      // Check if phone is valid
      if (!validationResult.valid) {
        return res.status(400).json({
          success: false,
          error: 'Invalid phone number. Please provide a valid phone number.'
        });
      }
      
      // Attach validation data to request for use in route handler
      req.phoneValidation = validationResult;
      
      // Continue to next middleware/route handler
      next();
      
    } catch (error) {
      console.error('Phone validation error:', error.message);
      
      // Fail open: allow request to continue if API is down
      // Change this behavior based on your requirements
      if (error.code === 'ECONNABORTED' || error.code === 'ETIMEDOUT') {
        console.warn('Phone validation timeout - allowing request');
        next();
      } else {
        res.status(500).json({
          success: false,
          error: 'Phone validation service temporarily unavailable'
        });
      }
    }
  };
};

module.exports = validatePhone;

const express = require('express');
const validatePhone = require('../middleware/validatePhone');

const router = express.Router();

// Registration endpoint with phone validation
router.post('/register', validatePhone('phone'), async (req, res) => {
  try {
    const { email, phone, password } = req.body;
    
    // Phone is already validated by middleware
    // Access validation data if needed
    const phoneData = req.phoneValidation;
    
    // Create user account
    const user = await User.create({
      email,
      phone: phoneData.number, // Use formatted number from API
      phoneCountry: phoneData.country_code,
      phoneCarrier: phoneData.carrier,
      password: await hashPassword(password)
    });
    
    res.status(201).json({
      success: true,
      message: 'Registration successful',
      user: {
        id: user.id,
        email: user.email,
        phone: user.phone
      }
    });
    
  } catch (error) {
    res.status(500).json({
      success: false,
      error: 'Registration failed'
    });
  }
});

// Profile update endpoint
router.put('/profile/phone', 
  authenticateUser, 
  validatePhone('newPhone'), 
  async (req, res) => {
    try {
      const { newPhone } = req.body;
      const phoneData = req.phoneValidation;
      
      await User.update(req.user.id, {
        phone: phoneData.number,
        phoneCountry: phoneData.country_code
      });
      
      res.json({
        success: true,
        message: 'Phone number updated successfully'
      });
      
    } catch (error) {
      res.status(500).json({
        success: false,
        error: 'Failed to update phone number'
      });
    }
  }
);

module.exports = router;

require('dotenv').config();
const express = require('express');
const authRoutes = require('./routes/auth');

const app = express();

// Middleware
app.use(express.json());
app.use(express.urlencoded({ extended: true }));

// Routes
app.use('/api/auth', authRoutes);

// Error handling
app.use((err, req, res, next) => {
  console.error(err.stack);
  res.status(500).json({
    success: false,
    error: 'Something went wrong'
  });
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server running on port ${PORT}`);
});