const datalize = require('datalize'); // set datalize to throw an error if validation fails datalize.set('autoValidate', true); // only Koa // add to very beginning of Koa middleware chain app.use(async (ctx, next) => { try { await next(); } catch (err) { if (err instanceof datalize.Error) { ctx.status = 400; ctx.body = err.toJSON(); } else { ctx.status = 500; ctx.body = 'Internal server error'; } } }); // only Express // add to very end of Express middleware chain app.use(function(err, req, res, next) { if (err instanceof datalize.Error) { res.status(400).send(err.toJSON()); } else { res.send(500).send('Internal server error'); } });
而且我们不必检查数据是否有效，因为 datalize 将帮我们做到这些。 如果数据无效，它将返回带有无效字段列表的格式化错误消息。
查询验证
是的，你甚至可以非常轻松地验证查询参数——它不仅仅用于POST请求。 我们也可以只使用.query()辅助方法，唯一的区别是数据存储在 .data 对象而不是 .form 中。
const datalize = require('datalize'); const field = datalize.field; /** * @api {get} / List users * ... */ router.post('https://www.jb51.net/', datalize.query([ field('keywords').trim(), field('page').default(1).number(), field('perPage').required().select([10, 30, 50]), ]), (ctx) => { const limit = ctx.data.perPage; const where = { }; if (ctx.data.keywords) { where.name = {[Op.like]: ctx.data.keywords + '%'}; } const users = await User.findAll({ where, limit, offset: (ctx.data.page - 1) * limit, }); ctx.body = users; });
还有一个辅助方法用于参数验证：.params()。 通过在路由的 .post() 方法中传递两个 datalize 中间件，可以同时对查询和表单数据进行验证。
更多过滤器，数组和嵌套对象
到目前为止，我们在 Node.js 表单验证中使用了非常简单的数据。 现在让我们尝试一些更复杂的字段，如数组，嵌套对象等：
const datalize = require('datalize'); const field = datalize.field; const DOMAIN_ERROR = "Email's domain does not have a valid MX (mail) entry in its DNS record"; /** * @api {post} / Create a user * ... */ router.post('https://www.jb51.net/', datalize([ field('name').trim().required(), field('email').required().email().custom((value) => { return new Promise((resolve, reject) => { dns.resolve(value.split('@')[1], 'MX', function(err, addresses) { if (err || !addresses || !addresses.length) { return reject(new Error(DOMAIN_ERROR)); } resolve(); }); }); }), field('type').required().select(['admin', 'user']), field('languages').array().container([ field('id').required().id(), field('level').required().select(['beginner', 'intermediate', 'advanced']) ]), field('groups').array().id(), ]), async (ctx) => { const {languages, groups} = ctx.form; delete ctx.form.languages; delete ctx.form.groups; const user = await User.create(ctx.form); await UserGroup.bulkCreate(groups.map(groupId => ({ groupId, userId: user.id, }))); await UserLanguage.bulkCreate(languages.map(item => ({ languageId: item.id, userId: user.id, level: item.level, )); });
如果我们需要验证的数据没有内置规则，我们可以用 .custom() 方法创建一个自定义数据验证规则（很不错的名字，对吗？）并在那里编写必要的逻辑。 对于嵌套对象，有 .container() 方法，你可以在其中用和 datalize() 函数相同的方式指定字段列表。 你可以将容器嵌套在容器中，或使用 .array() 过滤器对其进行补充，这些过滤器会将值转换为数组。 如果在没有容器的情况下使用 .array() 过滤器，则指定的规则或过滤器将被用于数组中的每个值。
所以 .array().select(['read', 'write']) 将检查数组中的每个值是 'read' 还是 'write' ，如果有任何一个值不是其中之一，则返回所有错误的索引列表。 很酷，对吧？
PUT/PATCH
在使用 PUT/PATCH (或 POST)更新数据时，你不必重写所有逻辑、规则和过滤器。 只需添加一个额外的过滤器，如 .optional() 或 .patch() ，如果未在请求中定义，它将从上下文对象中删除任何字段。 （ .optional() 将使它始终是可选的，而 .patch() 只有在 HTTP 请求的方法是 PATCH 时才会使它成为可选项。）你可以添这个额外的过滤器，以便它可以在数据库中创建和更新数据。
const datalize = require('datalize'); const field = datalize.field; const userValidator = datalize([ field('name').patch().trim().required(), field('email').patch().required().email(), field('type').patch().required().select(['admin', 'user']), ]); const userEditMiddleware = async (ctx, next) => { const user = await User.findByPk(ctx.params.id); // cancel request here if user was not found if (!user) { throw new Error('User was not found.'); } // store user instance in the request so we can use it later ctx.user = user; return next(); }; /** * @api {post} / Create a user * ... */ router.post('https://www.jb51.net/', userValidator, async (ctx) => { const user = await User.create(ctx.form); ctx.body = user.toJSON(); }); /** * @api {put} / Update a user * ... */ router.put('/:id', userEditMiddleware, userValidator, async (ctx) => { await ctx.user.update(ctx.form); ctx.body = ctx.user.toJSON(); }); /** * @api {patch} / Patch a user * ... */ router.patch('/:id', userEditMiddleware, userValidator, async (ctx) => { if (!Object.keys(ctx.form).length) { return ctx.error(400, {message: 'Nothing to update.'}); } await ctx.user.update(ctx.form); ctx.body = ctx.user.toJSON(); });