如何在 Express 应用中安全添加联系人并处理常见错误-js教程-PHP中文网

如何在 Express 应用中安全添加联系人并处理常见错误

本文详解如何基于 sequelize 模型在 express 中实现用户添加联系人功能，涵盖参数校验、数据库事务逻辑、错误日志调试及 http 状态码规范使用。

本文详解如何基于 sequelize 模型在 express 中实现用户添加联系人功能，涵盖参数校验、数据库事务逻辑、错误日志调试及 http 状态码规范使用。

在 Express 应用中为已登录用户添加联系人（即向 contacts 表插入一条关联记录），需确保流程健壮、可维护且符合 REST 语义。你当前的 ContactController.store 方法逻辑基本正确，但存在几个关键隐患，导致出现模糊的 “Internal server error” 响应。下面我们将逐一优化。

✅ 1. 添加前置参数校验（防止空值崩溃）

模型中 userEmail 和 userUsername 字段均设置为 allowNull: false，若请求体缺失 email 或 username，Contact.create() 将抛出 Sequelize 验证异常，并被 catch 捕获为 400 错误——但此时实际是服务端未兜底的客户端输入问题，更应提前拦截：

const { username, email } = req.body;

// 强制校验必要字段
if (!username || !email) {
  return res.status(400).json({
    errors: ['Both "username" and "email" are required in the request body.'],
  });
}

⚠️ 注意：username 并非目标用户的数据库用户名（该信息应从 User.findOne({ where: { email } }) 查询获得），而是当前用户为该联系人自定义的昵称/备注名。因此 userUsername 字段存储的是这个备注名，而非目标用户的真实 username。这点需与业务设计对齐。

✅ 2. 修复错误状态码：500 才是真正的“内部服务器错误”

当前 catch 块统一返回 status(400)，但根据 HTTP 规范，5xx 系列专用于服务端不可预期错误（如数据库连接失败、未捕获异常、Promise 拒绝未处理等）。应改为：

} catch (e) {
  console.error('Contact creation failed:', e); // ? 关键调试步骤！
  return res.status(500).json({
    errors: ['Internal server error. Please check server logs.'],
  });
}

添加 console.error 是排查 Internal server error 的第一要务——它能暴露真实错误堆栈（例如：外键约束失败、Sequelize 初始化未完成、req.userId 为 undefined 导致 findByPk(undefined) 报错等）。

✅ 3. 优化联系人存在性检查逻辑

你当前先查 Contact 表判断是否已添加，再查 User 表确认目标用户存在。这是合理顺序，但可增强鲁棒性：

使用 transaction（可选）保证原子性（如后续需同步更新其他表）；
对 User.findOne({ where: { email } }) 结果做空判断后，建议明确返回目标用户的 id 用于后续扩展（如建立双向关系）；
若业务允许添加尚未注册的邮箱（即“邀请联系人”场景），则此处逻辑需重构；但当前代码假设仅添加已注册用户，因此 !contact 返回 404 是恰当的。

✅ 4. 完整优化后的控制器示例

import Contact from '../models/Contact';
import User from '../models/User';

class ContactController {
  async store(req, res) {
    try {
      const { username, email } = req.body;

      // 1. 参数校验
      if (!username || !email) {
        return res.status(400).json({
          errors: ['Both "username" and "email" are required.'],
        });
      }

      // 2. 验证当前用户存在
      const currentUser = await User.findByPk(req.userId);
      if (!currentUser) {
        return res.status(401).json({ errors: ['Unauthorized: Invalid or missing user session.'] });
      }

      // 3. 检查是否已添加该邮箱联系人
      const existingContact = await Contact.findOne({
        where: { userId: currentUser.id, userEmail: email },
      });
      if (existingContact) {
        return res.status(400).json({ errors: ['Contact with this email already exists.'] });
      }

      // 4. 确认目标用户存在（邮箱已注册）
      const targetUser = await User.findOne({ where: { email } });
      if (!targetUser) {
        return res.status(404).json({ errors: ['Target user not found. Email is not registered.'] });
      }

      // 5. 创建联系人记录
      await Contact.create({
        userId: currentUser.id,
        userEmail: email,
        userUsername: username, // ← 此为当前用户对联系人的备注名
      });

      return res.status(201).json({
        message: 'Contact added successfully.',
        contact: { id: null /* 可选：返回创建的 contact.id */ },
      });

    } catch (e) {
      console.error('[ContactController.store ERROR]:', e);
      return res.status(500).json({
        errors: ['Failed to add contact. Please try again later.'],
      });
    }
  }
}

export default new ContactController();