123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472 |
- function _createForOfIteratorHelperLoose(o, allowArrayLike) {
- var it = typeof Symbol !== "undefined" && o[Symbol.iterator] || o["@@iterator"];
- if (it) return (it = it.call(o)).next.bind(it);
- if (Array.isArray(o) || (it = _unsupportedIterableToArray(o)) || allowArrayLike && o && typeof o.length === "number") {
- if (it) o = it;
- var i = 0;
- return function () {
- if (i >= o.length) return {
- done: true
- };
- return {
- done: false,
- value: o[i++]
- };
- };
- }
- throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.");
- }
- function _unsupportedIterableToArray(o, minLen) {
- if (!o) return;
- if (typeof o === "string") return _arrayLikeToArray(o, minLen);
- var n = Object.prototype.toString.call(o).slice(8, -1);
- if (n === "Object" && o.constructor) n = o.constructor.name;
- if (n === "Map" || n === "Set") return Array.from(o);
- if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen);
- }
- function _arrayLikeToArray(arr, len) {
- if (len == null || len > arr.length) len = arr.length;
- for (var i = 0, arr2 = new Array(len); i < len; i++) {
- arr2[i] = arr[i];
- }
- return arr2;
- }
- var equalObjects = require('./equals').default;
- var decode = require('./decode').default;
- var ParseError = require('./ParseError').default;
- var ParsePolygon = require('./ParsePolygon').default;
- var ParseGeoPoint = require('./ParseGeoPoint').default;
- function contains(haystack, needle) {
- if (needle && needle.__type && (needle.__type === 'Pointer' || needle.__type === 'Object')) {
- for (var i in haystack) {
- var ptr = haystack[i];
- if (typeof ptr === 'string' && ptr === needle.objectId) {
- return true;
- }
- if (ptr.className === needle.className && ptr.objectId === needle.objectId) {
- return true;
- }
- }
- return false;
- }
- return haystack.indexOf(needle) > -1;
- }
- function transformObject(object) {
- if (object._toFullJSON) {
- return object._toFullJSON();
- }
- return object;
- }
- function matchesQuery(className, object, objects, query) {
- if (object.className !== className) {
- return false;
- }
- var obj = object;
- var q = query;
- if (object.toJSON) {
- obj = object.toJSON();
- }
- if (query.toJSON) {
- q = query.toJSON().where;
- }
- obj.className = className;
- for (var field in q) {
- if (!matchesKeyConstraints(className, obj, objects, field, q[field])) {
- return false;
- }
- }
- return true;
- }
- function equalObjectsGeneric(obj, compareTo, eqlFn) {
- if (Array.isArray(obj)) {
- for (var i = 0; i < obj.length; i++) {
- if (eqlFn(obj[i], compareTo)) {
- return true;
- }
- }
- return false;
- }
- return eqlFn(obj, compareTo);
- }
- function matchesKeyConstraints(className, object, objects, key, constraints) {
- if (constraints === null) {
- return false;
- }
- if (key.indexOf('.') >= 0) {
- var keyComponents = key.split('.');
- var subObjectKey = keyComponents[0];
- var keyRemainder = keyComponents.slice(1).join('.');
- return matchesKeyConstraints(className, object[subObjectKey] || {}, objects, keyRemainder, constraints);
- }
- var i;
- if (key === '$or') {
- for (i = 0; i < constraints.length; i++) {
- if (matchesQuery(className, object, objects, constraints[i])) {
- return true;
- }
- }
- return false;
- }
- if (key === '$and') {
- for (i = 0; i < constraints.length; i++) {
- if (!matchesQuery(className, object, objects, constraints[i])) {
- return false;
- }
- }
- return true;
- }
- if (key === '$nor') {
- for (i = 0; i < constraints.length; i++) {
- if (matchesQuery(className, object, objects, constraints[i])) {
- return false;
- }
- }
- return true;
- }
- if (key === '$relatedTo') {
- return false;
- }
- if (!/^[A-Za-z][0-9A-Za-z_]*$/.test(key)) {
- throw new ParseError(ParseError.INVALID_KEY_NAME, "Invalid Key: " + key);
- }
- if (typeof constraints !== 'object') {
- if (Array.isArray(object[key])) {
- return object[key].indexOf(constraints) > -1;
- }
- return object[key] === constraints;
- }
- var compareTo;
- if (constraints.__type) {
- if (constraints.__type === 'Pointer') {
- return equalObjectsGeneric(object[key], constraints, function (obj, ptr) {
- return typeof obj !== 'undefined' && ptr.className === obj.className && ptr.objectId === obj.objectId;
- });
- }
- return equalObjectsGeneric(decode(object[key]), decode(constraints), equalObjects);
- }
- for (var condition in constraints) {
- compareTo = constraints[condition];
- if (compareTo.__type) {
- compareTo = decode(compareTo);
- }
- if (toString.call(compareTo) === '[object Date]' || typeof compareTo === 'string' && new Date(compareTo) !== 'Invalid Date' && !isNaN(new Date(compareTo))) {
- object[key] = new Date(object[key].iso ? object[key].iso : object[key]);
- }
- switch (condition) {
- case '$lt':
- if (object[key] >= compareTo) {
- return false;
- }
- break;
- case '$lte':
- if (object[key] > compareTo) {
- return false;
- }
- break;
- case '$gt':
- if (object[key] <= compareTo) {
- return false;
- }
- break;
- case '$gte':
- if (object[key] < compareTo) {
- return false;
- }
- break;
- case '$ne':
- if (equalObjects(object[key], compareTo)) {
- return false;
- }
- break;
- case '$in':
- if (!contains(compareTo, object[key])) {
- return false;
- }
- break;
- case '$nin':
- if (contains(compareTo, object[key])) {
- return false;
- }
- break;
- case '$all':
- for (i = 0; i < compareTo.length; i++) {
- if (object[key].indexOf(compareTo[i]) < 0) {
- return false;
- }
- }
- break;
- case '$exists':
- {
- var propertyExists = typeof object[key] !== 'undefined';
- var existenceIsRequired = constraints.$exists;
- if (typeof constraints.$exists !== 'boolean') {
- break;
- }
- if (!propertyExists && existenceIsRequired || propertyExists && !existenceIsRequired) {
- return false;
- }
- break;
- }
- case '$regex':
- {
- if (typeof compareTo === 'object') {
- return compareTo.test(object[key]);
- }
- var expString = '';
- var escapeEnd = -2;
- var escapeStart = compareTo.indexOf('\\Q');
- while (escapeStart > -1) {
- expString += compareTo.substring(escapeEnd + 2, escapeStart);
- escapeEnd = compareTo.indexOf('\\E', escapeStart);
- if (escapeEnd > -1) {
- expString += compareTo.substring(escapeStart + 2, escapeEnd).replace(/\\\\\\\\E/g, '\\E').replace(/\W/g, '\\$&');
- }
- escapeStart = compareTo.indexOf('\\Q', escapeEnd);
- }
- expString += compareTo.substring(Math.max(escapeStart, escapeEnd + 2));
- var modifiers = constraints.$options || '';
- modifiers = modifiers.replace('x', '').replace('s', '');
- var exp = new RegExp(expString, modifiers);
- if (!exp.test(object[key])) {
- return false;
- }
- break;
- }
- case '$nearSphere':
- {
- if (!compareTo || !object[key]) {
- return false;
- }
- var distance = compareTo.radiansTo(object[key]);
- var max = constraints.$maxDistance || Infinity;
- return distance <= max;
- }
- case '$within':
- {
- if (!compareTo || !object[key]) {
- return false;
- }
- var southWest = compareTo.$box[0];
- var northEast = compareTo.$box[1];
- if (southWest.latitude > northEast.latitude || southWest.longitude > northEast.longitude) {
- return false;
- }
- return object[key].latitude > southWest.latitude && object[key].latitude < northEast.latitude && object[key].longitude > southWest.longitude && object[key].longitude < northEast.longitude;
- }
- case '$options':
- break;
- case '$maxDistance':
- break;
- case '$select':
- {
- var subQueryObjects = objects.filter(function (obj, index, arr) {
- return matchesQuery(compareTo.query.className, obj, arr, compareTo.query.where);
- });
- for (var _i = 0; _i < subQueryObjects.length; _i += 1) {
- var subObject = transformObject(subQueryObjects[_i]);
- return equalObjects(object[key], subObject[compareTo.key]);
- }
- return false;
- }
- case '$dontSelect':
- {
- var _subQueryObjects = objects.filter(function (obj, index, arr) {
- return matchesQuery(compareTo.query.className, obj, arr, compareTo.query.where);
- });
- for (var _i2 = 0; _i2 < _subQueryObjects.length; _i2 += 1) {
- var _subObject = transformObject(_subQueryObjects[_i2]);
- return !equalObjects(object[key], _subObject[compareTo.key]);
- }
- return false;
- }
- case '$inQuery':
- {
- var _subQueryObjects2 = objects.filter(function (obj, index, arr) {
- return matchesQuery(compareTo.className, obj, arr, compareTo.where);
- });
- for (var _i3 = 0; _i3 < _subQueryObjects2.length; _i3 += 1) {
- var _subObject2 = transformObject(_subQueryObjects2[_i3]);
- if (object[key].className === _subObject2.className && object[key].objectId === _subObject2.objectId) {
- return true;
- }
- }
- return false;
- }
- case '$notInQuery':
- {
- var _subQueryObjects3 = objects.filter(function (obj, index, arr) {
- return matchesQuery(compareTo.className, obj, arr, compareTo.where);
- });
- for (var _i4 = 0; _i4 < _subQueryObjects3.length; _i4 += 1) {
- var _subObject3 = transformObject(_subQueryObjects3[_i4]);
- if (object[key].className === _subObject3.className && object[key].objectId === _subObject3.objectId) {
- return false;
- }
- }
- return true;
- }
- case '$containedBy':
- {
- for (var _iterator = _createForOfIteratorHelperLoose(object[key]), _step; !(_step = _iterator()).done;) {
- var value = _step.value;
- if (!contains(compareTo, value)) {
- return false;
- }
- }
- return true;
- }
- case '$geoWithin':
- {
- var points = compareTo.$polygon.map(function (geoPoint) {
- return [geoPoint.latitude, geoPoint.longitude];
- });
- var polygon = new ParsePolygon(points);
- return polygon.containsPoint(object[key]);
- }
- case '$geoIntersects':
- {
- var _polygon = new ParsePolygon(object[key].coordinates);
- var point = new ParseGeoPoint(compareTo.$point);
- return _polygon.containsPoint(point);
- }
- default:
- return false;
- }
- }
- return true;
- }
- function validateQuery(query) {
- var q = query;
- if (query.toJSON) {
- q = query.toJSON().where;
- }
- var specialQuerykeys = ['$and', '$or', '$nor', '_rperm', '_wperm', '_perishable_token', '_email_verify_token', '_email_verify_token_expires_at', '_account_lockout_expires_at', '_failed_login_count'];
- Object.keys(q).forEach(function (key) {
- if (q && q[key] && q[key].$regex) {
- if (typeof q[key].$options === 'string') {
- if (!q[key].$options.match(/^[imxs]+$/)) {
- throw new ParseError(ParseError.INVALID_QUERY, "Bad $options value for query: " + q[key].$options);
- }
- }
- }
- if (specialQuerykeys.indexOf(key) < 0 && !key.match(/^[a-zA-Z][a-zA-Z0-9_.]*$/)) {
- throw new ParseError(ParseError.INVALID_KEY_NAME, "Invalid key name: " + key);
- }
- });
- }
- var OfflineQuery = {
- matchesQuery: matchesQuery,
- validateQuery: validateQuery
- };
- module.exports = OfflineQuery;
|