| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420 | 'use strict';var compileSchema = require('./compile')  , resolve = require('./compile/resolve')  , Cache = require('./cache')  , SchemaObject = require('./compile/schema_obj')  , stableStringify = require('json-stable-stringify')  , formats = require('./compile/formats')  , rules = require('./compile/rules')  , v5 = require('./v5')  , util = require('./compile/util')  , async = require('./async')  , co = require('co');module.exports = Ajv;Ajv.prototype.compileAsync = async.compile;var customKeyword = require('./keyword');Ajv.prototype.addKeyword = customKeyword.add;Ajv.prototype.getKeyword = customKeyword.get;Ajv.prototype.removeKeyword = customKeyword.remove;Ajv.ValidationError = require('./compile/validation_error');var META_SCHEMA_ID = 'http://json-schema.org/draft-04/schema';var SCHEMA_URI_FORMAT = /^(?:(?:[a-z][a-z0-9+-.]*:)?\/\/)?[^\s]*$/i;function SCHEMA_URI_FORMAT_FUNC(str) {  return SCHEMA_URI_FORMAT.test(str);}var META_IGNORE_OPTIONS = [ 'removeAdditional', 'useDefaults', 'coerceTypes' ];/** * Creates validator instance. * Usage: `Ajv(opts)` * @param {Object} opts optional options * @return {Object} ajv instance */function Ajv(opts) {  if (!(this instanceof Ajv)) return new Ajv(opts);  var self = this;  opts = this._opts = util.copy(opts) || {};  this._schemas = {};  this._refs = {};  this._fragments = {};  this._formats = formats(opts.format);  this._cache = opts.cache || new Cache;  this._loadingSchemas = {};  this._compilations = [];  this.RULES = rules();  // this is done on purpose, so that methods are bound to the instance  // (without using bind) so that they can be used without the instance  this.validate = validate;  this.compile = compile;  this.addSchema = addSchema;  this.addMetaSchema = addMetaSchema;  this.validateSchema = validateSchema;  this.getSchema = getSchema;  this.removeSchema = removeSchema;  this.addFormat = addFormat;  this.errorsText = errorsText;  this._addSchema = _addSchema;  this._compile = _compile;  opts.loopRequired = opts.loopRequired || Infinity;  if (opts.async || opts.transpile) async.setup(opts);  if (opts.beautify === true) opts.beautify = { indent_size: 2 };  if (opts.errorDataPath == 'property') opts._errorDataPathProperty = true;  this._metaOpts = getMetaSchemaOptions();  if (opts.formats) addInitialFormats();  addDraft4MetaSchema();  if (opts.v5) v5.enable(this);  if (typeof opts.meta == 'object') addMetaSchema(opts.meta);  addInitialSchemas();  /**   * Validate data using schema   * Schema will be compiled and cached (using serialized JSON as key. [json-stable-stringify](https://github.com/substack/json-stable-stringify) is used to serialize.   * @param  {String|Object} schemaKeyRef key, ref or schema object   * @param  {Any} data to be validated   * @return {Boolean} validation result. Errors from the last validation will be available in `ajv.errors` (and also in compiled schema: `schema.errors`).   */  function validate(schemaKeyRef, data) {    var v;    if (typeof schemaKeyRef == 'string') {      v = getSchema(schemaKeyRef);      if (!v) throw new Error('no schema with key or ref "' + schemaKeyRef + '"');    } else {      var schemaObj = _addSchema(schemaKeyRef);      v = schemaObj.validate || _compile(schemaObj);    }    var valid = v(data);    if (v.$async === true)      return self._opts.async == '*' ? co(valid) : valid;    self.errors = v.errors;    return valid;  }  /**   * Create validating function for passed schema.   * @param  {Object} schema schema object   * @param  {Boolean} _meta true if schema is a meta-schema. Used internally to compile meta schemas of custom keywords.   * @return {Function} validating function   */  function compile(schema, _meta) {    var schemaObj = _addSchema(schema, undefined, _meta);    return schemaObj.validate || _compile(schemaObj);  }  /**   * Adds schema to the instance.   * @param {Object|Array} schema schema or array of schemas. If array is passed, `key` and other parameters will be ignored.   * @param {String} key Optional schema key. Can be passed to `validate` method instead of schema object or id/ref. One schema per instance can have empty `id` and `key`.   * @param {Boolean} _skipValidation true to skip schema validation. Used internally, option validateSchema should be used instead.   * @param {Boolean} _meta true if schema is a meta-schema. Used internally, addMetaSchema should be used instead.   */  function addSchema(schema, key, _skipValidation, _meta) {    if (Array.isArray(schema)){      for (var i=0; i<schema.length; i++) addSchema(schema[i], undefined, _skipValidation, _meta);      return;    }    // can key/id have # inside?    key = resolve.normalizeId(key || schema.id);    checkUnique(key);    self._schemas[key] = _addSchema(schema, _skipValidation, _meta, true);  }  /**   * Add schema that will be used to validate other schemas   * options in META_IGNORE_OPTIONS are alway set to false   * @param {Object} schema schema object   * @param {String} key optional schema key   * @param {Boolean} skipValidation true to skip schema validation, can be used to override validateSchema option for meta-schema   */  function addMetaSchema(schema, key, skipValidation) {    addSchema(schema, key, skipValidation, true);  }  /**   * Validate schema   * @param {Object} schema schema to validate   * @param {Boolean} throwOrLogError pass true to throw (or log) an error if invalid   * @return {Boolean} true if schema is valid   */  function validateSchema(schema, throwOrLogError) {    var $schema = schema.$schema || self._opts.defaultMeta || defaultMeta();    var currentUriFormat = self._formats.uri;    self._formats.uri = typeof currentUriFormat == 'function'                        ? SCHEMA_URI_FORMAT_FUNC                        : SCHEMA_URI_FORMAT;    var valid;    try { valid = validate($schema, schema); }    finally { self._formats.uri = currentUriFormat; }    if (!valid && throwOrLogError) {      var message = 'schema is invalid: ' + errorsText();      if (self._opts.validateSchema == 'log') console.error(message);      else throw new Error(message);    }    return valid;  }  function defaultMeta() {    var meta = self._opts.meta;    self._opts.defaultMeta = typeof meta == 'object'                              ? meta.id || meta                              : self._opts.v5                                ? v5.META_SCHEMA_ID                                : META_SCHEMA_ID;    return self._opts.defaultMeta;  }  /**   * Get compiled schema from the instance by `key` or `ref`.   * @param  {String} keyRef `key` that was passed to `addSchema` or full schema reference (`schema.id` or resolved id).   * @return {Function} schema validating function (with property `schema`).   */  function getSchema(keyRef) {    var schemaObj = _getSchemaObj(keyRef);    switch (typeof schemaObj) {      case 'object': return schemaObj.validate || _compile(schemaObj);      case 'string': return getSchema(schemaObj);      case 'undefined': return _getSchemaFragment(keyRef);    }  }  function _getSchemaFragment(ref) {    var res = resolve.schema.call(self, { schema: {} }, ref);    if (res) {      var schema = res.schema        , root = res.root        , baseId = res.baseId;      var v = compileSchema.call(self, schema, root, undefined, baseId);      self._fragments[ref] = new SchemaObject({        ref: ref,        fragment: true,        schema: schema,        root: root,        baseId: baseId,        validate: v      });      return v;    }  }  function _getSchemaObj(keyRef) {    keyRef = resolve.normalizeId(keyRef);    return self._schemas[keyRef] || self._refs[keyRef] || self._fragments[keyRef];  }  /**   * Remove cached schema(s).   * If no parameter is passed all schemas but meta-schemas are removed.   * If RegExp is passed all schemas with key/id matching pattern but meta-schemas are removed.   * Even if schema is referenced by other schemas it still can be removed as other schemas have local references.   * @param  {String|Object|RegExp} schemaKeyRef key, ref, pattern to match key/ref or schema object   */  function removeSchema(schemaKeyRef) {    if (schemaKeyRef instanceof RegExp) {      _removeAllSchemas(self._schemas, schemaKeyRef);      _removeAllSchemas(self._refs, schemaKeyRef);      return;    }    switch (typeof schemaKeyRef) {      case 'undefined':        _removeAllSchemas(self._schemas);        _removeAllSchemas(self._refs);        self._cache.clear();        return;      case 'string':        var schemaObj = _getSchemaObj(schemaKeyRef);        if (schemaObj) self._cache.del(schemaObj.jsonStr);        delete self._schemas[schemaKeyRef];        delete self._refs[schemaKeyRef];        return;      case 'object':        var jsonStr = stableStringify(schemaKeyRef);        self._cache.del(jsonStr);        var id = schemaKeyRef.id;        if (id) {          id = resolve.normalizeId(id);          delete self._schemas[id];          delete self._refs[id];        }    }  }  function _removeAllSchemas(schemas, regex) {    for (var keyRef in schemas) {      var schemaObj = schemas[keyRef];      if (!schemaObj.meta && (!regex || regex.test(keyRef))) {        self._cache.del(schemaObj.jsonStr);        delete schemas[keyRef];      }    }  }  function _addSchema(schema, skipValidation, meta, shouldAddSchema) {    if (typeof schema != 'object') throw new Error('schema should be object');    var jsonStr = stableStringify(schema);    var cached = self._cache.get(jsonStr);    if (cached) return cached;    shouldAddSchema = shouldAddSchema || self._opts.addUsedSchema !== false;    var id = resolve.normalizeId(schema.id);    if (id && shouldAddSchema) checkUnique(id);    var willValidate = self._opts.validateSchema !== false && !skipValidation;    var recursiveMeta;    if (willValidate && !(recursiveMeta = schema.id && schema.id == schema.$schema))      validateSchema(schema, true);    var localRefs = resolve.ids.call(self, schema);    var schemaObj = new SchemaObject({      id: id,      schema: schema,      localRefs: localRefs,      jsonStr: jsonStr,      meta: meta    });    if (id[0] != '#' && shouldAddSchema) self._refs[id] = schemaObj;    self._cache.put(jsonStr, schemaObj);    if (willValidate && recursiveMeta) validateSchema(schema, true);    return schemaObj;  }  function _compile(schemaObj, root) {    if (schemaObj.compiling) {      schemaObj.validate = callValidate;      callValidate.schema = schemaObj.schema;      callValidate.errors = null;      callValidate.root = root ? root : callValidate;      if (schemaObj.schema.$async === true)        callValidate.$async = true;      return callValidate;    }    schemaObj.compiling = true;    var currentOpts;    if (schemaObj.meta) {      currentOpts = self._opts;      self._opts = self._metaOpts;    }    var v;    try { v = compileSchema.call(self, schemaObj.schema, root, schemaObj.localRefs); }    finally {      schemaObj.compiling = false;      if (schemaObj.meta) self._opts = currentOpts;    }    schemaObj.validate = v;    schemaObj.refs = v.refs;    schemaObj.refVal = v.refVal;    schemaObj.root = v.root;    return v;    function callValidate() {      var _validate = schemaObj.validate;      var result = _validate.apply(null, arguments);      callValidate.errors = _validate.errors;      return result;    }  }  /**   * Convert array of error message objects to string   * @param  {Array<Object>} errors optional array of validation errors, if not passed errors from the instance are used.   * @param  {Object} options optional options with properties `separator` and `dataVar`.   * @return {String} human readable string with all errors descriptions   */  function errorsText(errors, options) {    errors = errors || self.errors;    if (!errors) return 'No errors';    options = options || {};    var separator = options.separator === undefined ? ', ' : options.separator;    var dataVar = options.dataVar === undefined ? 'data' : options.dataVar;    var text = '';    for (var i=0; i<errors.length; i++) {      var e = errors[i];      if (e) text += dataVar + e.dataPath + ' ' + e.message + separator;    }    return text.slice(0, -separator.length);  }  /**   * Add custom format   * @param {String} name format name   * @param {String|RegExp|Function} format string is converted to RegExp; function should return boolean (true when valid)   */  function addFormat(name, format) {    if (typeof format == 'string') format = new RegExp(format);    self._formats[name] = format;  }  function addDraft4MetaSchema() {    if (self._opts.meta !== false) {      var metaSchema = require('./refs/json-schema-draft-04.json');      addMetaSchema(metaSchema, META_SCHEMA_ID, true);      self._refs['http://json-schema.org/schema'] = META_SCHEMA_ID;    }  }  function addInitialSchemas() {    var optsSchemas = self._opts.schemas;    if (!optsSchemas) return;    if (Array.isArray(optsSchemas)) addSchema(optsSchemas);    else for (var key in optsSchemas) addSchema(optsSchemas[key], key);  }  function addInitialFormats() {    for (var name in self._opts.formats) {      var format = self._opts.formats[name];      addFormat(name, format);    }  }  function checkUnique(id) {    if (self._schemas[id] || self._refs[id])      throw new Error('schema with key or id "' + id + '" already exists');  }  function getMetaSchemaOptions() {    var metaOpts = util.copy(self._opts);    for (var i=0; i<META_IGNORE_OPTIONS.length; i++)      delete metaOpts[META_IGNORE_OPTIONS[i]];    return metaOpts;  }}
 |