"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.default = void 0;
var _typeof2 = _interopRequireDefault(require("@babel/runtime/helpers/typeof"));
var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
var _CoreManager = _interopRequireDefault(require("./CoreManager"));
var _encode = _interopRequireDefault(require("./encode"));
var _promiseUtils = require("./promiseUtils");
var _ParseError = _interopRequireDefault(require("./ParseError"));
var _ParseGeoPoint = _interopRequireDefault(require("./ParseGeoPoint"));
var _ParseObject = _interopRequireDefault(require("./ParseObject"));
var _OfflineQuery = _interopRequireDefault(require("./OfflineQuery"));
var _LocalDatastoreUtils = require("./LocalDatastoreUtils");
/*
* Copyright (c) 2015-present, Parse, LLC.
* All rights reserved.
*
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*
* @flow
*/
/**
* Converts a string into a regex that matches it.
* Surrounding with \Q .. \E does this, we just need to escape any \E's in
* the text separately.
* @private
*/
function quote(s
/*: string*/
) {
return '\\Q' + s.replace('\\E', '\\E\\\\E\\Q') + '\\E';
}
/**
* Extracts the class name from queries. If not all queries have the same
* class name an error will be thrown.
*/
function _getClassNameFromQueries(queries
/*: Array*/
)
/*: ?string*/
{
var className = null;
queries.forEach(function (q) {
if (!className) {
className = q.className;
}
if (className !== q.className) {
throw new Error('All queries must be for the same class.');
}
});
return className;
}
/*
* Handles pre-populating the result data of a query with select fields,
* making sure that the data object contains keys for all objects that have
* been requested with a select, so that our cached state updates correctly.
*/
function handleSelectResult(data
/*: any*/
, select
/*: Array*/
) {
var serverDataMask = {};
select.forEach(function (field) {
var hasSubObjectSelect = field.indexOf(".") !== -1;
if (!hasSubObjectSelect && !data.hasOwnProperty(field)) {
// this field was selected, but is missing from the retrieved data
data[field] = undefined;
} else if (hasSubObjectSelect) {
// this field references a sub-object,
// so we need to walk down the path components
var pathComponents = field.split(".");
var _obj = data;
var serverMask = serverDataMask;
pathComponents.forEach(function (component, index, arr) {
// add keys if the expected data is missing
if (_obj && !_obj.hasOwnProperty(component)) {
_obj[component] = undefined;
}
if (_obj !== undefined) {
_obj = _obj[component];
} //add this path component to the server mask so we can fill it in later if needed
if (index < arr.length - 1) {
if (!serverMask[component]) {
serverMask[component] = {};
}
serverMask = serverMask[component];
}
});
}
});
if (Object.keys(serverDataMask).length > 0) {
// When selecting from sub-objects, we don't want to blow away the missing
// information that we may have retrieved before. We've already added any
// missing selected keys to sub-objects, but we still need to add in the
// data for any previously retrieved sub-objects that were not selected.
var serverData = _CoreManager.default.getObjectStateController().getServerData({
id: data.objectId,
className: data.className
});
copyMissingDataWithMask(serverData, data, serverDataMask, false);
}
}
function copyMissingDataWithMask(src, dest, mask, copyThisLevel) {
//copy missing elements at this level
if (copyThisLevel) {
for (var _key in src) {
if (src.hasOwnProperty(_key) && !dest.hasOwnProperty(_key)) {
dest[_key] = src[_key];
}
}
}
for (var _key2 in mask) {
if (dest[_key2] !== undefined && dest[_key2] !== null && src !== undefined && src !== null) {
//traverse into objects as needed
copyMissingDataWithMask(src[_key2], dest[_key2], mask[_key2], true);
}
}
}
function handleOfflineSort(a, b, sorts) {
var order = sorts[0];
var operator = order.slice(0, 1);
var isDescending = operator === '-';
if (isDescending) {
order = order.substring(1);
}
if (order === '_created_at') {
order = 'createdAt';
}
if (order === '_updated_at') {
order = 'updatedAt';
}
if (!/^[A-Za-z][0-9A-Za-z_]*$/.test(order) || order === 'password') {
throw new _ParseError.default(_ParseError.default.INVALID_KEY_NAME, "Invalid Key: ".concat(order));
}
var field1 = a.get(order);
var field2 = b.get(order);
if (field1 < field2) {
return isDescending ? 1 : -1;
}
if (field1 > field2) {
return isDescending ? -1 : 1;
}
if (sorts.length > 1) {
var remainingSorts = sorts.slice(1);
return handleOfflineSort(a, b, remainingSorts);
}
return 0;
}
/**
* Creates a new parse Parse.Query for the given Parse.Object subclass.
*
* Parse.Query defines a query that is used to fetch Parse.Objects. The
* most common use case is finding all objects that match a query through the
* find
method. for example, this sample code fetches all objects
* of class myclass
. it calls a different function depending on
* whether the fetch succeeded or not.
*
*
* var query = new Parse.Query(myclass);
* query.find().then((results) => {
* // results is an array of parse.object.
* }).catch((error) => {
* // error is an instance of parse.error.
* });
*
* a Parse.Query can also be used to retrieve a single object whose id is
* known, through the get method. for example, this sample code fetches an
* object of class myclass
and id myid
. it calls a
* different function depending on whether the fetch succeeded or not.
*
*
* var query = new Parse.Query(myclass);
* query.get(myid).then((object) => {
* // object is an instance of parse.object.
* }).catch((error) => {
* // error is an instance of parse.error.
* });
*
* a Parse.Query can also be used to count the number of objects that match
* the query without retrieving all of those objects. for example, this
* sample code counts the number of objects of the class myclass
*
* var query = new Parse.Query(myclass);
* query.count().then((number) => {
* // there are number instances of myclass.
* }).catch((error) => {
* // error is an instance of Parse.Error.
* });
* @alias Parse.Query
*/
var ParseQuery =
/*#__PURE__*/
function () {
/**
* @property className
* @type String
*/
/**
* @param {(String|Parse.Object)} objectClass An instance of a subclass of Parse.Object, or a Parse className string.
*/
function ParseQuery(objectClass
/*: string | ParseObject*/
) {
(0, _classCallCheck2.default)(this, ParseQuery);
(0, _defineProperty2.default)(this, "className", void 0);
(0, _defineProperty2.default)(this, "_where", void 0);
(0, _defineProperty2.default)(this, "_include", void 0);
(0, _defineProperty2.default)(this, "_exclude", void 0);
(0, _defineProperty2.default)(this, "_select", void 0);
(0, _defineProperty2.default)(this, "_limit", void 0);
(0, _defineProperty2.default)(this, "_skip", void 0);
(0, _defineProperty2.default)(this, "_count", void 0);
(0, _defineProperty2.default)(this, "_order", void 0);
(0, _defineProperty2.default)(this, "_readPreference", void 0);
(0, _defineProperty2.default)(this, "_includeReadPreference", void 0);
(0, _defineProperty2.default)(this, "_subqueryReadPreference", void 0);
(0, _defineProperty2.default)(this, "_queriesLocalDatastore", void 0);
(0, _defineProperty2.default)(this, "_localDatastorePinName", void 0);
(0, _defineProperty2.default)(this, "_extraOptions", void 0);
if (typeof objectClass === 'string') {
if (objectClass === 'User' && _CoreManager.default.get('PERFORM_USER_REWRITE')) {
this.className = '_User';
} else {
this.className = objectClass;
}
} else if (objectClass instanceof _ParseObject.default) {
this.className = objectClass.className;
} else if (typeof objectClass === 'function') {
if (typeof objectClass.className === 'string') {
this.className = objectClass.className;
} else {
var _obj2 = new objectClass();
this.className = _obj2.className;
}
} else {
throw new TypeError('A ParseQuery must be constructed with a ParseObject or class name.');
}
this._where = {};
this._include = [];
this._exclude = [];
this._count = false;
this._limit = -1; // negative limit is not sent in the server request
this._skip = 0;
this._readPreference = null;
this._includeReadPreference = null;
this._subqueryReadPreference = null;
this._queriesLocalDatastore = false;
this._localDatastorePinName = null;
this._extraOptions = {};
}
/**
* Adds constraint that at least one of the passed in queries matches.
* @param {Array} queries
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
(0, _createClass2.default)(ParseQuery, [{
key: "_orQuery",
value: function (queries
/*: Array*/
)
/*: ParseQuery*/
{
var queryJSON = queries.map(function (q) {
return q.toJSON().where;
});
this._where.$or = queryJSON;
return this;
}
/**
* Adds constraint that all of the passed in queries match.
* @param {Array} queries
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "_andQuery",
value: function (queries
/*: Array*/
)
/*: ParseQuery*/
{
var queryJSON = queries.map(function (q) {
return q.toJSON().where;
});
this._where.$and = queryJSON;
return this;
}
/**
* Adds constraint that none of the passed in queries match.
* @param {Array} queries
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "_norQuery",
value: function (queries
/*: Array*/
)
/*: ParseQuery*/
{
var queryJSON = queries.map(function (q) {
return q.toJSON().where;
});
this._where.$nor = queryJSON;
return this;
}
/**
* Helper for condition queries
*/
}, {
key: "_addCondition",
value: function (key
/*: string*/
, condition
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
if (!this._where[key] || typeof this._where[key] === 'string') {
this._where[key] = {};
}
this._where[key][condition] = (0, _encode.default)(value, false, true);
return this;
}
/**
* Converts string for regular expression at the beginning
*/
}, {
key: "_regexStartWith",
value: function (string
/*: string*/
)
/*: string*/
{
return '^' + quote(string);
}
}, {
key: "_handleOfflineQuery",
value: function () {
var _handleOfflineQuery2 = (0, _asyncToGenerator2.default)(
/*#__PURE__*/
_regenerator.default.mark(function _callee(params
/*: any*/
) {
var _this2 = this;
var localDatastore, objects, results, keys, alwaysSelectedKeys, sorts, count, limit;
return _regenerator.default.wrap(function (_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
_OfflineQuery.default.validateQuery(this);
localDatastore = _CoreManager.default.getLocalDatastore();
_context.next = 4;
return localDatastore._serializeObjectsFromPinName(this._localDatastorePinName);
case 4:
objects = _context.sent;
results = objects.map(function (json, index, arr) {
var object = _ParseObject.default.fromJSON(json, false);
if (json._localId && !json.objectId) {
object._localId = json._localId;
}
if (!_OfflineQuery.default.matchesQuery(_this2.className, object, arr, _this2)) {
return null;
}
return object;
}).filter(function (object) {
return object !== null;
});
if (params.keys) {
keys = params.keys.split(',');
alwaysSelectedKeys = ['className', 'objectId', 'createdAt', 'updatedAt', 'ACL'];
keys = keys.concat(alwaysSelectedKeys);
results = results.map(function (object) {
var json = object._toFullJSON();
Object.keys(json).forEach(function (key) {
if (!keys.includes(key)) {
delete json[key];
}
});
return _ParseObject.default.fromJSON(json, false);
});
}
if (params.order) {
sorts = params.order.split(',');
results.sort(function (a, b) {
return handleOfflineSort(a, b, sorts);
});
} // count total before applying limit/skip
if (params.count) {
count = results.length; // total count from response
}
if (params.skip) {
if (params.skip >= results.length) {
results = [];
} else {
results = results.splice(params.skip, results.length);
}
}
limit = results.length;
if (params.limit !== 0 && params.limit < results.length) {
limit = params.limit;
}
results = results.splice(0, limit);
if (!(typeof count === 'number')) {
_context.next = 15;
break;
}
return _context.abrupt("return", {
results: results,
count: count
});
case 15:
return _context.abrupt("return", results);
case 16:
case "end":
return _context.stop();
}
}
}, _callee, this);
}));
return function () {
return _handleOfflineQuery2.apply(this, arguments);
};
}()
/**
* Returns a JSON representation of this query.
* @return {Object} The JSON representation of the query.
*/
}, {
key: "toJSON",
value: function ()
/*: QueryJSON*/
{
var params
/*: QueryJSON*/
= {
where: this._where
};
if (this._include.length) {
params.include = this._include.join(',');
}
if (this._exclude.length) {
params.excludeKeys = this._exclude.join(',');
}
if (this._select) {
params.keys = this._select.join(',');
}
if (this._count) {
params.count = 1;
}
if (this._limit >= 0) {
params.limit = this._limit;
}
if (this._skip > 0) {
params.skip = this._skip;
}
if (this._order) {
params.order = this._order.join(',');
}
if (this._readPreference) {
params.readPreference = this._readPreference;
}
if (this._includeReadPreference) {
params.includeReadPreference = this._includeReadPreference;
}
if (this._subqueryReadPreference) {
params.subqueryReadPreference = this._subqueryReadPreference;
}
for (var _key3 in this._extraOptions) {
params[_key3] = this._extraOptions[_key3];
}
return params;
}
/**
* Return a query with conditions from json, can be useful to send query from server side to client
* Not static, all query conditions was set before calling this method will be deleted.
* For example on the server side we have
* var query = new Parse.Query("className");
* query.equalTo(key: value);
* query.limit(100);
* ... (others queries)
* Create JSON representation of Query Object
* var jsonFromServer = query.fromJSON();
*
* On client side getting query:
* var query = new Parse.Query("className");
* query.fromJSON(jsonFromServer);
*
* and continue to query...
* query.skip(100).find().then(...);
* @param {QueryJSON} json from Parse.Query.toJSON() method
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withJSON",
value: function (json
/*: QueryJSON*/
)
/*: ParseQuery*/
{
if (json.where) {
this._where = json.where;
}
if (json.include) {
this._include = json.include.split(",");
}
if (json.keys) {
this._select = json.keys.split(",");
}
if (json.excludeKeys) {
this._exclude = json.excludeKeys.split(",");
}
if (json.count) {
this._count = json.count === 1;
}
if (json.limit) {
this._limit = json.limit;
}
if (json.skip) {
this._skip = json.skip;
}
if (json.order) {
this._order = json.order.split(",");
}
if (json.readPreference) {
this._readPreference = json.readPreference;
}
if (json.includeReadPreference) {
this._includeReadPreference = json.includeReadPreference;
}
if (json.subqueryReadPreference) {
this._subqueryReadPreference = json.subqueryReadPreference;
}
for (var _key4 in json) {
if (json.hasOwnProperty(_key4)) {
if (["where", "include", "keys", "count", "limit", "skip", "order", "readPreference", "includeReadPreference", "subqueryReadPreference"].indexOf(_key4) === -1) {
this._extraOptions[_key4] = json[_key4];
}
}
}
return this;
}
/**
* Static method to restore Parse.Query by json representation
* Internally calling Parse.Query.withJSON
* @param {String} className
* @param {QueryJSON} json from Parse.Query.toJSON() method
* @returns {Parse.Query} new created query
*/
}, {
key: "get",
/**
* Constructs a Parse.Object whose id is already known by fetching data from
* the server. Either options.success or options.error is called when the
* find completes. Unlike the first
method, it never returns undefined.
*
* @param {String} objectId The id of the object to be fetched.
* @param {Object} options
* Valid options are:
* - useMasterKey: In Cloud Code and Node only, causes the Master Key to
* be used for this request.
*
- sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
*
* @return {Promise} A promise that is resolved with the result when
* the query completes.
*/
value: function (objectId
/*: string*/
, options
/*:: ?: FullOptions*/
)
/*: Promise*/
{
this.equalTo('objectId', objectId);
var firstOptions = {};
if (options && options.hasOwnProperty('useMasterKey')) {
firstOptions.useMasterKey = options.useMasterKey;
}
if (options && options.hasOwnProperty('sessionToken')) {
firstOptions.sessionToken = options.sessionToken;
}
return this.first(firstOptions).then(function (response) {
if (response) {
return response;
}
var errorObject = new _ParseError.default(_ParseError.default.OBJECT_NOT_FOUND, 'Object not found.');
return Promise.reject(errorObject);
});
}
/**
* Retrieves a list of ParseObjects that satisfy this query.
* Either options.success or options.error is called when the find
* completes.
*
* @param {Object} options Valid options
* are:
* - useMasterKey: In Cloud Code and Node only, causes the Master Key to
* be used for this request.
*
- sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
*
* @return {Promise} A promise that is resolved with the results when
* the query completes.
*/
}, {
key: "find",
value: function (options
/*:: ?: FullOptions*/
)
/*: Promise>*/
{
var _this3 = this;
options = options || {};
var findOptions = {};
if (options.hasOwnProperty('useMasterKey')) {
findOptions.useMasterKey = options.useMasterKey;
}
if (options.hasOwnProperty('sessionToken')) {
findOptions.sessionToken = options.sessionToken;
}
var controller = _CoreManager.default.getQueryController();
var select = this._select;
if (this._queriesLocalDatastore) {
return this._handleOfflineQuery(this.toJSON());
}
return controller.find(this.className, this.toJSON(), findOptions).then(function (response) {
var results = response.results.map(function (data) {
// In cases of relations, the server may send back a className
// on the top level of the payload
var override = response.className || _this3.className;
if (!data.className) {
data.className = override;
} // Make sure the data object contains keys for all objects that
// have been requested with a select, so that our cached state
// updates correctly.
if (select) {
handleSelectResult(data, select);
}
return _ParseObject.default.fromJSON(data, !select);
});
var count = response.count;
if (typeof count === "number") {
return {
results: results,
count: count
};
} else {
return results;
}
});
}
/**
* Counts the number of objects that match this query.
* Either options.success or options.error is called when the count
* completes.
*
* @param {Object} options
* Valid options are:
* - useMasterKey: In Cloud Code and Node only, causes the Master Key to
* be used for this request.
*
- sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
*
* @return {Promise} A promise that is resolved with the count when
* the query completes.
*/
}, {
key: "count",
value: function (options
/*:: ?: FullOptions*/
)
/*: Promise*/
{
options = options || {};
var findOptions = {};
if (options.hasOwnProperty('useMasterKey')) {
findOptions.useMasterKey = options.useMasterKey;
}
if (options.hasOwnProperty('sessionToken')) {
findOptions.sessionToken = options.sessionToken;
}
var controller = _CoreManager.default.getQueryController();
var params = this.toJSON();
params.limit = 0;
params.count = 1;
return controller.find(this.className, params, findOptions).then(function (result) {
return result.count;
});
}
/**
* Executes a distinct query and returns unique values
*
* @param {String} key A field to find distinct values
* @param {Object} options
* Valid options are:
* - sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
*
* @return {Promise} A promise that is resolved with the query completes.
*/
}, {
key: "distinct",
value: function (key
/*: string*/
, options
/*:: ?: FullOptions*/
)
/*: Promise>*/
{
options = options || {};
var distinctOptions = {};
distinctOptions.useMasterKey = true;
if (options.hasOwnProperty('sessionToken')) {
distinctOptions.sessionToken = options.sessionToken;
}
var controller = _CoreManager.default.getQueryController();
var params = {
distinct: key,
where: this._where
};
return controller.aggregate(this.className, params, distinctOptions).then(function (results) {
return results.results;
});
}
/**
* Executes an aggregate query and returns aggregate results
*
* @param {Mixed} pipeline Array or Object of stages to process query
* @param {Object} options Valid options are:
* - sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
*
* @return {Promise} A promise that is resolved with the query completes.
*/
}, {
key: "aggregate",
value: function (pipeline
/*: mixed*/
, options
/*:: ?: FullOptions*/
)
/*: Promise>*/
{
options = options || {};
var aggregateOptions = {};
aggregateOptions.useMasterKey = true;
if (options.hasOwnProperty('sessionToken')) {
aggregateOptions.sessionToken = options.sessionToken;
}
var controller = _CoreManager.default.getQueryController();
if (!Array.isArray(pipeline) && (0, _typeof2.default)(pipeline) !== 'object') {
throw new Error('Invalid pipeline must be Array or Object');
}
return controller.aggregate(this.className, {
pipeline: pipeline
}, aggregateOptions).then(function (results) {
return results.results;
});
}
/**
* Retrieves at most one Parse.Object that satisfies this query.
*
* Either options.success or options.error is called when it completes.
* success is passed the object if there is one. otherwise, undefined.
*
* @param {Object} options Valid options are:
* - useMasterKey: In Cloud Code and Node only, causes the Master Key to
* be used for this request.
*
- sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
*
* @return {Promise} A promise that is resolved with the object when
* the query completes.
*/
}, {
key: "first",
value: function (options
/*:: ?: FullOptions*/
)
/*: Promise*/
{
var _this4 = this;
options = options || {};
var findOptions = {};
if (options.hasOwnProperty('useMasterKey')) {
findOptions.useMasterKey = options.useMasterKey;
}
if (options.hasOwnProperty('sessionToken')) {
findOptions.sessionToken = options.sessionToken;
}
var controller = _CoreManager.default.getQueryController();
var params = this.toJSON();
params.limit = 1;
var select = this._select;
if (this._queriesLocalDatastore) {
return this._handleOfflineQuery(params).then(function (objects) {
if (!objects[0]) {
return undefined;
}
return objects[0];
});
}
return controller.find(this.className, params, findOptions).then(function (response) {
var objects = response.results;
if (!objects[0]) {
return undefined;
}
if (!objects[0].className) {
objects[0].className = _this4.className;
} // Make sure the data object contains keys for all objects that
// have been requested with a select, so that our cached state
// updates correctly.
if (select) {
handleSelectResult(objects[0], select);
}
return _ParseObject.default.fromJSON(objects[0], !select);
});
}
/**
* Iterates over each result of a query, calling a callback for each one. If
* the callback returns a promise, the iteration will not continue until
* that promise has been fulfilled. If the callback returns a rejected
* promise, then iteration will stop with that error. The items are
* processed in an unspecified order. The query may not have any sort order,
* and may not use limit or skip.
* @param {Function} callback Callback that will be called with each result
* of the query.
* @param {Object} options Valid options are:
* - useMasterKey: In Cloud Code and Node only, causes the Master Key to
* be used for this request.
*
- sessionToken: A valid session token, used for making a request on
* behalf of a specific user.
*
* @return {Promise} A promise that will be fulfilled once the
* iteration has completed.
*/
}, {
key: "each",
value: function (callback
/*: (obj: ParseObject) => any*/
, options
/*:: ?: BatchOptions*/
)
/*: Promise>*/
{
options = options || {};
if (this._order || this._skip || this._limit >= 0) {
return Promise.reject('Cannot iterate on a query with sort, skip, or limit.');
}
var query = new ParseQuery(this.className); // We can override the batch size from the options.
// This is undocumented, but useful for testing.
query._limit = options.batchSize || 100;
query._include = this._include.map(function (i) {
return i;
});
if (this._select) {
query._select = this._select.map(function (s) {
return s;
});
}
query._where = {};
for (var _attr in this._where) {
var val = this._where[_attr];
if (Array.isArray(val)) {
query._where[_attr] = val.map(function (v) {
return v;
});
} else if (val && (0, _typeof2.default)(val) === 'object') {
var conditionMap = {};
query._where[_attr] = conditionMap;
for (var cond in val) {
conditionMap[cond] = val[cond];
}
} else {
query._where[_attr] = val;
}
}
query.ascending('objectId');
var findOptions = {};
if (options.hasOwnProperty('useMasterKey')) {
findOptions.useMasterKey = options.useMasterKey;
}
if (options.hasOwnProperty('sessionToken')) {
findOptions.sessionToken = options.sessionToken;
}
var finished = false;
return (0, _promiseUtils.continueWhile)(function () {
return !finished;
}, function () {
return query.find(findOptions).then(function (results) {
var callbacksDone = Promise.resolve();
results.forEach(function (result) {
callbacksDone = callbacksDone.then(function () {
return callback(result);
});
});
return callbacksDone.then(function () {
if (results.length >= query._limit) {
query.greaterThan('objectId', results[results.length - 1].id);
} else {
finished = true;
}
});
});
});
}
/** Query Conditions **/
/**
* Adds a constraint to the query that requires a particular key's value to
* be equal to the provided value.
* @param {String} key The key to check.
* @param value The value that the Parse.Object must contain.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "equalTo",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
if (typeof value === 'undefined') {
return this.doesNotExist(key);
}
this._where[key] = (0, _encode.default)(value, false, true);
return this;
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be not equal to the provided value.
* @param {String} key The key to check.
* @param value The value that must not be equalled.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "notEqualTo",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$ne', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be less than the provided value.
* @param {String} key The key to check.
* @param value The value that provides an upper bound.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "lessThan",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$lt', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be greater than the provided value.
* @param {String} key The key to check.
* @param value The value that provides an lower bound.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "greaterThan",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$gt', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be less than or equal to the provided value.
* @param {String} key The key to check.
* @param value The value that provides an upper bound.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "lessThanOrEqualTo",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$lte', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be greater than or equal to the provided value.
* @param {String} key The key to check.
* @param value The value that provides an lower bound.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "greaterThanOrEqualTo",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$gte', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be contained in the provided list of values.
* @param {String} key The key to check.
* @param {Array} values The values that will match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "containedIn",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$in', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* not be contained in the provided list of values.
* @param {String} key The key to check.
* @param {Array} values The values that will not match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "notContainedIn",
value: function (key
/*: string*/
, value
/*: mixed*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$nin', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* be contained by the provided list of values. Get objects where all array elements match.
* @param {String} key The key to check.
* @param {Array} values The values that will match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "containedBy",
value: function (key
/*: string*/
, value
/*: Array*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$containedBy', value);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* contain each one of the provided list of values.
* @param {String} key The key to check. This key's value must be an array.
* @param {Array} values The values that will match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "containsAll",
value: function (key
/*: string*/
, values
/*: Array*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$all', values);
}
/**
* Adds a constraint to the query that requires a particular key's value to
* contain each one of the provided list of values starting with given strings.
* @param {String} key The key to check. This key's value must be an array.
* @param {Array} values The string values that will match as starting string.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "containsAllStartingWith",
value: function (key
/*: string*/
, values
/*: Array*/
)
/*: ParseQuery*/
{
var _this = this;
if (!Array.isArray(values)) {
values = [values];
}
var regexObject = values.map(function (value) {
return {
'$regex': _this._regexStartWith(value)
};
});
return this.containsAll(key, regexObject);
}
/**
* Adds a constraint for finding objects that contain the given key.
* @param {String} key The key that should exist.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "exists",
value: function (key
/*: string*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$exists', true);
}
/**
* Adds a constraint for finding objects that do not contain a given key.
* @param {String} key The key that should not exist
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "doesNotExist",
value: function (key
/*: string*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$exists', false);
}
/**
* Adds a regular expression constraint for finding string values that match
* the provided regular expression.
* This may be slow for large datasets.
* @param {String} key The key that the string to match is stored in.
* @param {RegExp} regex The regular expression pattern to match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "matches",
value: function (key
/*: string*/
, regex
/*: RegExp*/
, modifiers
/*: string*/
)
/*: ParseQuery*/
{
this._addCondition(key, '$regex', regex);
if (!modifiers) {
modifiers = '';
}
if (regex.ignoreCase) {
modifiers += 'i';
}
if (regex.multiline) {
modifiers += 'm';
}
if (modifiers.length) {
this._addCondition(key, '$options', modifiers);
}
return this;
}
/**
* Adds a constraint that requires that a key's value matches a Parse.Query
* constraint.
* @param {String} key The key that the contains the object to match the
* query.
* @param {Parse.Query} query The query that should match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "matchesQuery",
value: function (key
/*: string*/
, query
/*: ParseQuery*/
)
/*: ParseQuery*/
{
var queryJSON = query.toJSON();
queryJSON.className = query.className;
return this._addCondition(key, '$inQuery', queryJSON);
}
/**
* Adds a constraint that requires that a key's value not matches a
* Parse.Query constraint.
* @param {String} key The key that the contains the object to match the
* query.
* @param {Parse.Query} query The query that should not match.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "doesNotMatchQuery",
value: function (key
/*: string*/
, query
/*: ParseQuery*/
)
/*: ParseQuery*/
{
var queryJSON = query.toJSON();
queryJSON.className = query.className;
return this._addCondition(key, '$notInQuery', queryJSON);
}
/**
* Adds a constraint that requires that a key's value matches a value in
* an object returned by a different Parse.Query.
* @param {String} key The key that contains the value that is being
* matched.
* @param {String} queryKey The key in the objects returned by the query to
* match against.
* @param {Parse.Query} query The query to run.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "matchesKeyInQuery",
value: function (key
/*: string*/
, queryKey
/*: string*/
, query
/*: ParseQuery*/
)
/*: ParseQuery*/
{
var queryJSON = query.toJSON();
queryJSON.className = query.className;
return this._addCondition(key, '$select', {
key: queryKey,
query: queryJSON
});
}
/**
* Adds a constraint that requires that a key's value not match a value in
* an object returned by a different Parse.Query.
* @param {String} key The key that contains the value that is being
* excluded.
* @param {String} queryKey The key in the objects returned by the query to
* match against.
* @param {Parse.Query} query The query to run.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "doesNotMatchKeyInQuery",
value: function (key
/*: string*/
, queryKey
/*: string*/
, query
/*: ParseQuery*/
)
/*: ParseQuery*/
{
var queryJSON = query.toJSON();
queryJSON.className = query.className;
return this._addCondition(key, '$dontSelect', {
key: queryKey,
query: queryJSON
});
}
/**
* Adds a constraint for finding string values that contain a provided
* string. This may be slow for large datasets.
* @param {String} key The key that the string to match is stored in.
* @param {String} substring The substring that the value must contain.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "contains",
value: function (key
/*: string*/
, value
/*: string*/
)
/*: ParseQuery*/
{
if (typeof value !== 'string') {
throw new Error('The value being searched for must be a string.');
}
return this._addCondition(key, '$regex', quote(value));
}
/**
* Adds a constraint for finding string values that contain a provided
* string. This may be slow for large datasets. Requires Parse-Server > 2.5.0
*
* In order to sort you must use select and ascending ($score is required)
*
* query.fullText('field', 'term');
* query.ascending('$score');
* query.select('$score');
*
*
* To retrieve the weight / rank
*
* object->get('score');
*
*
* You can define optionals by providing an object as a third parameter
*
* query.fullText('field', 'term', { language: 'es', diacriticSensitive: true });
*
*
* @param {String} key The key that the string to match is stored in.
* @param {String} value The string to search
* @param {Object} options (Optional)
* @param {String} options.language The language that determines the list of stop words for the search and the rules for the stemmer and tokenizer.
* @param {Boolean} options.caseSensitive A boolean flag to enable or disable case sensitive search.
* @param {Boolean} options.diacriticSensitive A boolean flag to enable or disable diacritic sensitive search.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "fullText",
value: function (key
/*: string*/
, value
/*: string*/
, options
/*: ?Object*/
)
/*: ParseQuery*/
{
options = options || {};
if (!key) {
throw new Error('A key is required.');
}
if (!value) {
throw new Error('A search term is required');
}
if (typeof value !== 'string') {
throw new Error('The value being searched for must be a string.');
}
var fullOptions = {};
fullOptions.$term = value;
for (var option in options) {
switch (option) {
case 'language':
fullOptions.$language = options[option];
break;
case 'caseSensitive':
fullOptions.$caseSensitive = options[option];
break;
case 'diacriticSensitive':
fullOptions.$diacriticSensitive = options[option];
break;
default:
throw new Error("Unknown option: ".concat(option));
}
}
return this._addCondition(key, '$text', {
$search: fullOptions
});
}
/**
* Method to sort the full text search by text score
*
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "sortByTextScore",
value: function () {
this.ascending('$score');
this.select(['$score']);
return this;
}
/**
* Adds a constraint for finding string values that start with a provided
* string. This query will use the backend index, so it will be fast even
* for large datasets.
* @param {String} key The key that the string to match is stored in.
* @param {String} prefix The substring that the value must start with.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "startsWith",
value: function (key
/*: string*/
, value
/*: string*/
)
/*: ParseQuery*/
{
if (typeof value !== 'string') {
throw new Error('The value being searched for must be a string.');
}
return this._addCondition(key, '$regex', this._regexStartWith(value));
}
/**
* Adds a constraint for finding string values that end with a provided
* string. This will be slow for large datasets.
* @param {String} key The key that the string to match is stored in.
* @param {String} suffix The substring that the value must end with.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "endsWith",
value: function (key
/*: string*/
, value
/*: string*/
)
/*: ParseQuery*/
{
if (typeof value !== 'string') {
throw new Error('The value being searched for must be a string.');
}
return this._addCondition(key, '$regex', quote(value) + '$');
}
/**
* Adds a proximity based constraint for finding objects with key point
* values near the point given.
* @param {String} key The key that the Parse.GeoPoint is stored in.
* @param {Parse.GeoPoint} point The reference Parse.GeoPoint that is used.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "near",
value: function (key
/*: string*/
, point
/*: ParseGeoPoint*/
)
/*: ParseQuery*/
{
if (!(point instanceof _ParseGeoPoint.default)) {
// Try to cast it as a GeoPoint
point = new _ParseGeoPoint.default(point);
}
return this._addCondition(key, '$nearSphere', point);
}
/**
* Adds a proximity based constraint for finding objects with key point
* values near the point given and within the maximum distance given.
* @param {String} key The key that the Parse.GeoPoint is stored in.
* @param {Parse.GeoPoint} point The reference Parse.GeoPoint that is used.
* @param {Number} maxDistance Maximum distance (in radians) of results to
* return.
* @param {Boolean} sorted A Bool value that is true if results should be
* sorted by distance ascending, false is no sorting is required,
* defaults to true.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withinRadians",
value: function (key
/*: string*/
, point
/*: ParseGeoPoint*/
, distance
/*: number*/
, sorted
/*: boolean*/
)
/*: ParseQuery*/
{
if (sorted || sorted === undefined) {
this.near(key, point);
return this._addCondition(key, '$maxDistance', distance);
} else {
return this._addCondition(key, '$geoWithin', {
'$centerSphere': [[point.longitude, point.latitude], distance]
});
}
}
/**
* Adds a proximity based constraint for finding objects with key point
* values near the point given and within the maximum distance given.
* Radius of earth used is 3958.8 miles.
* @param {String} key The key that the Parse.GeoPoint is stored in.
* @param {Parse.GeoPoint} point The reference Parse.GeoPoint that is used.
* @param {Number} maxDistance Maximum distance (in miles) of results to
* return.
* @param {Boolean} sorted A Bool value that is true if results should be
* sorted by distance ascending, false is no sorting is required,
* defaults to true.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withinMiles",
value: function (key
/*: string*/
, point
/*: ParseGeoPoint*/
, distance
/*: number*/
, sorted
/*: boolean*/
)
/*: ParseQuery*/
{
return this.withinRadians(key, point, distance / 3958.8, sorted);
}
/**
* Adds a proximity based constraint for finding objects with key point
* values near the point given and within the maximum distance given.
* Radius of earth used is 6371.0 kilometers.
* @param {String} key The key that the Parse.GeoPoint is stored in.
* @param {Parse.GeoPoint} point The reference Parse.GeoPoint that is used.
* @param {Number} maxDistance Maximum distance (in kilometers) of results
* to return.
* @param {Boolean} sorted A Bool value that is true if results should be
* sorted by distance ascending, false is no sorting is required,
* defaults to true.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withinKilometers",
value: function (key
/*: string*/
, point
/*: ParseGeoPoint*/
, distance
/*: number*/
, sorted
/*: boolean*/
)
/*: ParseQuery*/
{
return this.withinRadians(key, point, distance / 6371.0, sorted);
}
/**
* Adds a constraint to the query that requires a particular key's
* coordinates be contained within a given rectangular geographic bounding
* box.
* @param {String} key The key to be constrained.
* @param {Parse.GeoPoint} southwest
* The lower-left inclusive corner of the box.
* @param {Parse.GeoPoint} northeast
* The upper-right inclusive corner of the box.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withinGeoBox",
value: function (key
/*: string*/
, southwest
/*: ParseGeoPoint*/
, northeast
/*: ParseGeoPoint*/
)
/*: ParseQuery*/
{
if (!(southwest instanceof _ParseGeoPoint.default)) {
southwest = new _ParseGeoPoint.default(southwest);
}
if (!(northeast instanceof _ParseGeoPoint.default)) {
northeast = new _ParseGeoPoint.default(northeast);
}
this._addCondition(key, '$within', {
'$box': [southwest, northeast]
});
return this;
}
/**
* Adds a constraint to the query that requires a particular key's
* coordinates be contained within and on the bounds of a given polygon.
* Supports closed and open (last point is connected to first) paths
*
* Polygon must have at least 3 points
*
* @param {String} key The key to be constrained.
* @param {Array} array of geopoints
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withinPolygon",
value: function (key
/*: string*/
, points
/*: Array>*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$geoWithin', {
'$polygon': points
});
}
/**
* Add a constraint to the query that requires a particular key's
* coordinates that contains a ParseGeoPoint
*
* @param {String} key The key to be constrained.
* @param {Parse.GeoPoint} GeoPoint
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "polygonContains",
value: function (key
/*: string*/
, point
/*: ParseGeoPoint*/
)
/*: ParseQuery*/
{
return this._addCondition(key, '$geoIntersects', {
'$point': point
});
}
/** Query Orderings **/
/**
* Sorts the results in ascending order by the given key.
*
* @param {(String|String[]|...String)} key The key to order by, which is a
* string of comma separated values, or an Array of keys, or multiple keys.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "ascending",
value: function ()
/*: ParseQuery*/
{
this._order = [];
for (var _len = arguments.length, keys = new Array(_len), _key5 = 0; _key5 < _len; _key5++) {
keys[_key5] = arguments[_key5];
}
return this.addAscending.apply(this, keys);
}
/**
* Sorts the results in ascending order by the given key,
* but can also add secondary sort descriptors without overwriting _order.
*
* @param {(String|String[]|...String)} key The key to order by, which is a
* string of comma separated values, or an Array of keys, or multiple keys.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "addAscending",
value: function ()
/*: ParseQuery*/
{
var _this5 = this;
if (!this._order) {
this._order = [];
}
for (var _len2 = arguments.length, keys = new Array(_len2), _key6 = 0; _key6 < _len2; _key6++) {
keys[_key6] = arguments[_key6];
}
keys.forEach(function (key) {
if (Array.isArray(key)) {
key = key.join();
}
_this5._order = _this5._order.concat(key.replace(/\s/g, '').split(','));
});
return this;
}
/**
* Sorts the results in descending order by the given key.
*
* @param {(String|String[]|...String)} key The key to order by, which is a
* string of comma separated values, or an Array of keys, or multiple keys.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "descending",
value: function ()
/*: ParseQuery*/
{
this._order = [];
for (var _len3 = arguments.length, keys = new Array(_len3), _key7 = 0; _key7 < _len3; _key7++) {
keys[_key7] = arguments[_key7];
}
return this.addDescending.apply(this, keys);
}
/**
* Sorts the results in descending order by the given key,
* but can also add secondary sort descriptors without overwriting _order.
*
* @param {(String|String[]|...String)} key The key to order by, which is a
* string of comma separated values, or an Array of keys, or multiple keys.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "addDescending",
value: function ()
/*: ParseQuery*/
{
var _this6 = this;
if (!this._order) {
this._order = [];
}
for (var _len4 = arguments.length, keys = new Array(_len4), _key8 = 0; _key8 < _len4; _key8++) {
keys[_key8] = arguments[_key8];
}
keys.forEach(function (key) {
if (Array.isArray(key)) {
key = key.join();
}
_this6._order = _this6._order.concat(key.replace(/\s/g, '').split(',').map(function (k) {
return '-' + k;
}));
});
return this;
}
/** Query Options **/
/**
* Sets the number of results to skip before returning any results.
* This is useful for pagination.
* Default is to skip zero results.
* @param {Number} n the number of results to skip.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "skip",
value: function (n
/*: number*/
)
/*: ParseQuery*/
{
if (typeof n !== 'number' || n < 0) {
throw new Error('You can only skip by a positive number');
}
this._skip = n;
return this;
}
/**
* Sets the limit of the number of results to return. The default limit is
* 100, with a maximum of 1000 results being returned at a time.
* @param {Number} n the number of results to limit to.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "limit",
value: function (n
/*: number*/
)
/*: ParseQuery*/
{
if (typeof n !== 'number') {
throw new Error('You can only set the limit to a numeric value');
}
this._limit = n;
return this;
}
/**
* Sets the flag to include with response the total number of objects satisfying this query,
* despite limits/skip. Might be useful for pagination.
* Note that result of this query will be wrapped as an object with
*`results`: holding {ParseObject} array and `count`: integer holding total number
* @param {boolean} b false - disable, true - enable.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "withCount",
value: function ()
/*: ParseQuery*/
{
var includeCount
/*: boolean*/
= arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : true;
if (typeof includeCount !== 'boolean') {
throw new Error('You can only set withCount to a boolean value');
}
this._count = includeCount;
return this;
}
/**
* Includes nested Parse.Objects for the provided key. You can use dot
* notation to specify which fields in the included object are also fetched.
*
* You can include all nested Parse.Objects by passing in '*'.
* Requires Parse Server 3.0.0+
* query.include('*');
*
* @param {...String|Array} key The name(s) of the key(s) to include.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "include",
value: function ()
/*: ParseQuery*/
{
var _this7 = this;
for (var _len5 = arguments.length, keys = new Array(_len5), _key9 = 0; _key9 < _len5; _key9++) {
keys[_key9] = arguments[_key9];
}
keys.forEach(function (key) {
if (Array.isArray(key)) {
_this7._include = _this7._include.concat(key);
} else {
_this7._include.push(key);
}
});
return this;
}
/**
* Includes all nested Parse.Objects.
*
* Requires Parse Server 3.0.0+
*
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "includeAll",
value: function ()
/*: ParseQuery*/
{
return this.include('*');
}
/**
* Restricts the fields of the returned Parse.Objects to include only the
* provided keys. If this is called multiple times, then all of the keys
* specified in each of the calls will be included.
* @param {...String|Array} keys The name(s) of the key(s) to include.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "select",
value: function ()
/*: ParseQuery*/
{
var _this8 = this;
if (!this._select) {
this._select = [];
}
for (var _len6 = arguments.length, keys = new Array(_len6), _key10 = 0; _key10 < _len6; _key10++) {
keys[_key10] = arguments[_key10];
}
keys.forEach(function (key) {
if (Array.isArray(key)) {
_this8._select = _this8._select.concat(key);
} else {
_this8._select.push(key);
}
});
return this;
}
/**
* Restricts the fields of the returned Parse.Objects to all keys except the
* provided keys. Exclude takes precedence over select and include.
*
* Requires Parse Server 3.6.0+
*
* @param {...String|Array} keys The name(s) of the key(s) to exclude.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "exclude",
value: function ()
/*: ParseQuery*/
{
var _this9 = this;
for (var _len7 = arguments.length, keys = new Array(_len7), _key11 = 0; _key11 < _len7; _key11++) {
keys[_key11] = arguments[_key11];
}
keys.forEach(function (key) {
if (Array.isArray(key)) {
_this9._exclude = _this9._exclude.concat(key);
} else {
_this9._exclude.push(key);
}
});
return this;
}
/**
* Changes the read preference that the backend will use when performing the query to the database.
* @param {String} readPreference The read preference for the main query.
* @param {String} includeReadPreference The read preference for the queries to include pointers.
* @param {String} subqueryReadPreference The read preference for the sub queries.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "readPreference",
value: function (_readPreference
/*: string*/
, includeReadPreference
/*:: ?: string*/
, subqueryReadPreference
/*:: ?: string*/
)
/*: ParseQuery*/
{
this._readPreference = _readPreference;
this._includeReadPreference = includeReadPreference;
this._subqueryReadPreference = subqueryReadPreference;
return this;
}
/**
* Subscribe this query to get liveQuery updates
*
* @param {String} sessionToken (optional) Defaults to the currentUser
* @return {Promise} Returns the liveQuerySubscription, it's an event emitter
* which can be used to get liveQuery updates.
*/
}, {
key: "subscribe",
value: function () {
var _subscribe = (0, _asyncToGenerator2.default)(
/*#__PURE__*/
_regenerator.default.mark(function _callee2(sessionToken
/*:: ?: string*/
) {
var currentUser, liveQueryClient, subscription;
return _regenerator.default.wrap(function (_context2) {
while (1) {
switch (_context2.prev = _context2.next) {
case 0:
_context2.next = 2;
return _CoreManager.default.getUserController().currentUserAsync();
case 2:
currentUser = _context2.sent;
if (!sessionToken) {
sessionToken = currentUser ? currentUser.getSessionToken() : undefined;
}
_context2.next = 6;
return _CoreManager.default.getLiveQueryController().getDefaultLiveQueryClient();
case 6:
liveQueryClient = _context2.sent;
if (liveQueryClient.shouldOpen()) {
liveQueryClient.open();
}
subscription = liveQueryClient.subscribe(this, sessionToken);
return _context2.abrupt("return", subscription);
case 10:
case "end":
return _context2.stop();
}
}
}, _callee2, this);
}));
return function () {
return _subscribe.apply(this, arguments);
};
}()
/**
* Constructs a Parse.Query that is the OR of the passed in queries. For
* example:
* var compoundQuery = Parse.Query.or(query1, query2, query3);
*
* will create a compoundQuery that is an or of the query1, query2, and
* query3.
* @param {...Parse.Query} var_args The list of queries to OR.
* @static
* @return {Parse.Query} The query that is the OR of the passed in queries.
*/
}, {
key: "fromLocalDatastore",
/**
* Changes the source of this query to all pinned objects.
*
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
value: function ()
/*: ParseQuery*/
{
return this.fromPinWithName(null);
}
/**
* Changes the source of this query to the default group of pinned objects.
*
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "fromPin",
value: function ()
/*: ParseQuery*/
{
return this.fromPinWithName(_LocalDatastoreUtils.DEFAULT_PIN);
}
/**
* Changes the source of this query to a specific group of pinned objects.
*
* @param {String} name The name of query source.
* @return {Parse.Query} Returns the query, so you can chain this call.
*/
}, {
key: "fromPinWithName",
value: function (name
/*:: ?: string*/
)
/*: ParseQuery*/
{
var localDatastore = _CoreManager.default.getLocalDatastore();
if (localDatastore.checkIfEnabled()) {
this._queriesLocalDatastore = true;
this._localDatastorePinName = name;
}
return this;
}
}], [{
key: "fromJSON",
value: function (className
/*: string*/
, json
/*: QueryJSON*/
)
/*: ParseQuery*/
{
var query = new ParseQuery(className);
return query.withJSON(json);
}
}, {
key: "or",
value: function ()
/*: ParseQuery*/
{
for (var _len8 = arguments.length, queries = new Array(_len8), _key12 = 0; _key12 < _len8; _key12++) {
queries[_key12] = arguments[_key12];
}
var className = _getClassNameFromQueries(queries);
var query = new ParseQuery(className);
query._orQuery(queries);
return query;
}
/**
* Constructs a Parse.Query that is the AND of the passed in queries. For
* example:
* var compoundQuery = Parse.Query.and(query1, query2, query3);
*
* will create a compoundQuery that is an and of the query1, query2, and
* query3.
* @param {...Parse.Query} var_args The list of queries to AND.
* @static
* @return {Parse.Query} The query that is the AND of the passed in queries.
*/
}, {
key: "and",
value: function ()
/*: ParseQuery*/
{
for (var _len9 = arguments.length, queries = new Array(_len9), _key13 = 0; _key13 < _len9; _key13++) {
queries[_key13] = arguments[_key13];
}
var className = _getClassNameFromQueries(queries);
var query = new ParseQuery(className);
query._andQuery(queries);
return query;
}
/**
* Constructs a Parse.Query that is the NOR of the passed in queries. For
* example:
* const compoundQuery = Parse.Query.nor(query1, query2, query3);
*
* will create a compoundQuery that is a nor of the query1, query2, and
* query3.
* @param {...Parse.Query} var_args The list of queries to NOR.
* @static
* @return {Parse.Query} The query that is the NOR of the passed in queries.
*/
}, {
key: "nor",
value: function ()
/*: ParseQuery*/
{
for (var _len10 = arguments.length, queries = new Array(_len10), _key14 = 0; _key14 < _len10; _key14++) {
queries[_key14] = arguments[_key14];
}
var className = _getClassNameFromQueries(queries);
var query = new ParseQuery(className);
query._norQuery(queries);
return query;
}
}]);
return ParseQuery;
}();
var DefaultController = {
find: function (className
/*: string*/
, params
/*: QueryJSON*/
, options
/*: RequestOptions*/
)
/*: Promise>*/
{
var RESTController = _CoreManager.default.getRESTController();
return RESTController.request('GET', 'classes/' + className, params, options);
},
aggregate: function (className
/*: string*/
, params
/*: any*/
, options
/*: RequestOptions*/
)
/*: Promise>*/
{
var RESTController = _CoreManager.default.getRESTController();
return RESTController.request('GET', 'aggregate/' + className, params, options);
}
};
_CoreManager.default.setQueryController(DefaultController);
var _default = ParseQuery;
exports.default = _default;