зеркало из https://github.com/mozilla/gecko-dev.git
Bug 1563213 - Upgrade kinto-http-client.js to 4.7.2 r=glasserc
Differential Revision: https://phabricator.services.mozilla.com/D36752 --HG-- extra : moz-landing-system : lando
This commit is contained in:
Mathieu Leplatre
Родитель
74837c0281
Коммит
326c302870
|
|
@ -20,10 +20,14 @@
|
|||
|
||||
const global = this;
|
||||
|
||||
this.EXPORTED_SYMBOLS = ["KintoHttpClient"];
|
||||
var EXPORTED_SYMBOLS = ["KintoHttpClient"];
|
||||
|
||||
const { setTimeout, clearTimeout } = ChromeUtils.import("resource://gre/modules/Timer.jsm");
|
||||
const { XPCOMUtils } = ChromeUtils.import("resource://gre/modules/XPCOMUtils.jsm");
|
||||
XPCOMUtils.defineLazyGlobalGetters(global, ["fetch"]);
|
||||
|
||||
/*
|
||||
* Version 4.6.1 - 97e2200
|
||||
* Version 4.7.2 - bd29c19
|
||||
*/
|
||||
|
||||
(function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.KintoHttpClient = f()}})(function(){var define,module,exports;return (function(){function r(e,n,t){function o(i,f){if(!n[i]){if(!e[i]){var c="function"==typeof require&&require;if(!f&&c)return c(i,!0);if(u)return u(i,!0);var a=new Error("Cannot find module '"+i+"'");throw a.code="MODULE_NOT_FOUND",a}var p=n[i]={exports:{}};e[i][0].call(p.exports,function(r){var n=e[i][1][r];return o(n||r)},p,p.exports,r,e,n,t)}return n[i].exports}for(var u="function"==typeof require&&require,i=0;i<t.length;i++)o(t[i]);return o}return r})()({1:[function(require,module,exports){
|
||||
|
|
@ -56,9 +60,6 @@ function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj;
|
|||
|
||||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
||||
|
||||
ChromeUtils.import("resource://gre/modules/Timer.jsm", global);
|
||||
const {XPCOMUtils} = ChromeUtils.import("resource://gre/modules/XPCOMUtils.jsm");
|
||||
XPCOMUtils.defineLazyGlobalGetters(global, ["fetch"]);
|
||||
const {
|
||||
EventEmitter
|
||||
} = ChromeUtils.import("resource://gre/modules/EventEmitter.jsm");
|
||||
|
|
@ -106,14 +107,15 @@ for (var i = 0; i < 256; ++i) {
|
|||
function bytesToUuid(buf, offset) {
|
||||
var i = offset || 0;
|
||||
var bth = byteToHex;
|
||||
return bth[buf[i++]] + bth[buf[i++]] +
|
||||
bth[buf[i++]] + bth[buf[i++]] + '-' +
|
||||
bth[buf[i++]] + bth[buf[i++]] + '-' +
|
||||
bth[buf[i++]] + bth[buf[i++]] + '-' +
|
||||
bth[buf[i++]] + bth[buf[i++]] + '-' +
|
||||
bth[buf[i++]] + bth[buf[i++]] +
|
||||
bth[buf[i++]] + bth[buf[i++]] +
|
||||
bth[buf[i++]] + bth[buf[i++]];
|
||||
// join used to fix memory issue caused by concatenation: https://bugs.chromium.org/p/v8/issues/detail?id=3175#c4
|
||||
return ([bth[buf[i++]], bth[buf[i++]],
|
||||
bth[buf[i++]], bth[buf[i++]], '-',
|
||||
bth[buf[i++]], bth[buf[i++]], '-',
|
||||
bth[buf[i++]], bth[buf[i++]], '-',
|
||||
bth[buf[i++]], bth[buf[i++]], '-',
|
||||
bth[buf[i++]], bth[buf[i++]],
|
||||
bth[buf[i++]], bth[buf[i++]],
|
||||
bth[buf[i++]], bth[buf[i++]]]).join('');
|
||||
}
|
||||
|
||||
module.exports = bytesToUuid;
|
||||
|
|
@ -124,9 +126,11 @@ module.exports = bytesToUuid;
|
|||
// and inconsistent support for the `crypto` API. We do the best we can via
|
||||
// feature-detection
|
||||
|
||||
// getRandomValues needs to be invoked in a context where "this" is a Crypto implementation.
|
||||
var getRandomValues = (typeof(crypto) != 'undefined' && crypto.getRandomValues.bind(crypto)) ||
|
||||
(typeof(msCrypto) != 'undefined' && msCrypto.getRandomValues.bind(msCrypto));
|
||||
// getRandomValues needs to be invoked in a context where "this" is a Crypto
|
||||
// implementation. Also, find the complete implementation of crypto on IE11.
|
||||
var getRandomValues = (typeof(crypto) != 'undefined' && crypto.getRandomValues && crypto.getRandomValues.bind(crypto)) ||
|
||||
(typeof(msCrypto) != 'undefined' && typeof window.msCrypto.getRandomValues == 'function' && msCrypto.getRandomValues.bind(msCrypto));
|
||||
|
||||
if (getRandomValues) {
|
||||
// WHATWG crypto RNG - http://wiki.whatwg.org/wiki/Crypto
|
||||
var rnds8 = new Uint8Array(16); // eslint-disable-line no-undef
|
||||
|
|
@ -314,13 +318,13 @@ var _batch = require("./batch");
|
|||
|
||||
var _bucket = _interopRequireDefault(require("./bucket"));
|
||||
|
||||
var _dec, _dec2, _dec3, _dec4, _dec5, _dec6, _dec7, _class;
|
||||
var _dec, _dec2, _dec3, _dec4, _dec5, _dec6, _dec7, _dec8, _class;
|
||||
|
||||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }
|
||||
|
||||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
||||
|
||||
function _applyDecoratedDescriptor(target, property, decorators, descriptor, context) { var desc = {}; Object['ke' + 'ys'](descriptor).forEach(function (key) { desc[key] = descriptor[key]; }); desc.enumerable = !!desc.enumerable; desc.configurable = !!desc.configurable; if ('value' in desc || desc.initializer) { desc.writable = true; } desc = decorators.slice().reverse().reduce(function (desc, decorator) { return decorator(target, property, desc) || desc; }, desc); if (context && desc.initializer !== void 0) { desc.value = desc.initializer ? desc.initializer.call(context) : void 0; desc.initializer = undefined; } if (desc.initializer === void 0) { Object['define' + 'Property'](target, property, desc); desc = null; } return desc; }
|
||||
function _applyDecoratedDescriptor(target, property, decorators, descriptor, context) { var desc = {}; Object.keys(descriptor).forEach(function (key) { desc[key] = descriptor[key]; }); desc.enumerable = !!desc.enumerable; desc.configurable = !!desc.configurable; if ('value' in desc || desc.initializer) { desc.writable = true; } desc = decorators.slice().reverse().reduce(function (desc, decorator) { return decorator(target, property, desc) || desc; }, desc); if (context && desc.initializer !== void 0) { desc.value = desc.initializer ? desc.initializer.call(context) : void 0; desc.initializer = undefined; } if (desc.initializer === void 0) { Object.defineProperty(target, property, desc); desc = null; } return desc; }
|
||||
|
||||
/**
|
||||
* Currently supported protocol version.
|
||||
|
|
@ -340,7 +344,7 @@ const SUPPORTED_PROTOCOL_VERSION = "v1";
|
|||
*/
|
||||
|
||||
exports.SUPPORTED_PROTOCOL_VERSION = SUPPORTED_PROTOCOL_VERSION;
|
||||
let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec2 = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec3 = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec4 = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec5 = (0, _utils.nobatch)("Can't use batch within a batch!"), _dec6 = (0, _utils.capable)(["permissions_endpoint"]), _dec7 = (0, _utils.support)("1.4", "2.0"), (_class = class KintoClientBase {
|
||||
let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec2 = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec3 = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec4 = (0, _utils.nobatch)("This operation is not supported within a batch operation."), _dec5 = (0, _utils.nobatch)("Can't use batch within a batch!"), _dec6 = (0, _utils.capable)(["permissions_endpoint"]), _dec7 = (0, _utils.support)("1.4", "2.0"), _dec8 = (0, _utils.capable)(["accounts"]), (_class = class KintoClientBase {
|
||||
/**
|
||||
* Constructor.
|
||||
*
|
||||
|
|
@ -842,6 +846,8 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
* Infinity to fetch everything.
|
||||
* @param {String} [params.since=undefined]
|
||||
* The ETag from which to start fetching.
|
||||
* @param {Array} [params.fields]
|
||||
* Limit response to just some fields.
|
||||
* @param {Object} [options={}]
|
||||
* Additional request-level parameters to use in all requests.
|
||||
* @param {Object} [options.headers={}]
|
||||
|
|
@ -861,7 +867,8 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
filters,
|
||||
limit,
|
||||
pages,
|
||||
since
|
||||
since,
|
||||
fields
|
||||
} = {
|
||||
sort: "-last_modified",
|
||||
...params
|
||||
|
|
@ -871,11 +878,17 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
throw new Error(`Invalid value for since (${since}), should be ETag value.`);
|
||||
}
|
||||
|
||||
const querystring = (0, _utils.qsify)({ ...filters,
|
||||
const query = { ...filters,
|
||||
_sort: sort,
|
||||
_limit: limit,
|
||||
_since: since
|
||||
});
|
||||
};
|
||||
|
||||
if (fields) {
|
||||
query._fields = fields;
|
||||
}
|
||||
|
||||
const querystring = (0, _utils.qsify)(query);
|
||||
let results = [],
|
||||
current = 0;
|
||||
|
||||
|
|
@ -896,15 +909,14 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
})));
|
||||
};
|
||||
|
||||
const pageResults = (results, nextPage, etag, totalRecords) => {
|
||||
const pageResults = (results, nextPage, etag) => {
|
||||
// ETag string is supposed to be opaque and stored «as-is».
|
||||
// ETag header values are quoted (because of * and W/"foo").
|
||||
return {
|
||||
last_modified: etag ? etag.replace(/"/g, "") : etag,
|
||||
data: results,
|
||||
next: next.bind(null, nextPage),
|
||||
hasNextPage: !!nextPage,
|
||||
totalRecords
|
||||
hasNextPage: !!nextPage
|
||||
};
|
||||
};
|
||||
|
||||
|
|
@ -914,10 +926,9 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
}) {
|
||||
const nextPage = headers.get("Next-Page");
|
||||
const etag = headers.get("ETag");
|
||||
const totalRecords = parseInt(headers.get("Total-Records"), 10);
|
||||
|
||||
if (!pages) {
|
||||
return pageResults(json.data, nextPage, etag, totalRecords);
|
||||
return pageResults(json.data, nextPage, etag);
|
||||
} // Aggregate new results with previous ones
|
||||
|
||||
|
||||
|
|
@ -926,7 +937,7 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
|
||||
if (current >= pages || !nextPage) {
|
||||
// Pagination exhausted
|
||||
return pageResults(results, nextPage, etag, totalRecords);
|
||||
return pageResults(results, nextPage, etag);
|
||||
} // Follow next page
|
||||
|
||||
|
||||
|
|
@ -980,6 +991,9 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
* this request.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @param {Object} [options.filters={}] The filters object.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @return {Promise<Object[], Error>}
|
||||
*/
|
||||
|
||||
|
|
@ -1085,7 +1099,17 @@ let KintoClientBase = (_dec = (0, _utils.nobatch)("This operation is not support
|
|||
});
|
||||
}
|
||||
|
||||
}, (_applyDecoratedDescriptor(_class.prototype, "fetchServerSettings", [_dec], Object.getOwnPropertyDescriptor(_class.prototype, "fetchServerSettings"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "fetchServerCapabilities", [_dec2], Object.getOwnPropertyDescriptor(_class.prototype, "fetchServerCapabilities"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "fetchUser", [_dec3], Object.getOwnPropertyDescriptor(_class.prototype, "fetchUser"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "fetchHTTPApiVersion", [_dec4], Object.getOwnPropertyDescriptor(_class.prototype, "fetchHTTPApiVersion"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "batch", [_dec5], Object.getOwnPropertyDescriptor(_class.prototype, "batch"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "listPermissions", [_dec6], Object.getOwnPropertyDescriptor(_class.prototype, "listPermissions"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "deleteBuckets", [_dec7], Object.getOwnPropertyDescriptor(_class.prototype, "deleteBuckets"), _class.prototype)), _class));
|
||||
async createAccount(username, password) {
|
||||
return this.execute(requests.createRequest(`/accounts/${username}`, {
|
||||
data: {
|
||||
password
|
||||
}
|
||||
}, {
|
||||
method: "PUT"
|
||||
}));
|
||||
}
|
||||
|
||||
}, (_applyDecoratedDescriptor(_class.prototype, "fetchServerSettings", [_dec], Object.getOwnPropertyDescriptor(_class.prototype, "fetchServerSettings"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "fetchServerCapabilities", [_dec2], Object.getOwnPropertyDescriptor(_class.prototype, "fetchServerCapabilities"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "fetchUser", [_dec3], Object.getOwnPropertyDescriptor(_class.prototype, "fetchUser"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "fetchHTTPApiVersion", [_dec4], Object.getOwnPropertyDescriptor(_class.prototype, "fetchHTTPApiVersion"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "batch", [_dec5], Object.getOwnPropertyDescriptor(_class.prototype, "batch"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "listPermissions", [_dec6], Object.getOwnPropertyDescriptor(_class.prototype, "listPermissions"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "deleteBuckets", [_dec7], Object.getOwnPropertyDescriptor(_class.prototype, "deleteBuckets"), _class.prototype), _applyDecoratedDescriptor(_class.prototype, "createAccount", [_dec8], Object.getOwnPropertyDescriptor(_class.prototype, "createAccount"), _class.prototype)), _class));
|
||||
exports.default = KintoClientBase;
|
||||
|
||||
},{"./batch":8,"./bucket":9,"./endpoint":11,"./http":13,"./requests":14,"./utils":15}],8:[function(require,module,exports){
|
||||
|
|
@ -1174,7 +1198,7 @@ function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj;
|
|||
|
||||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
||||
|
||||
function _applyDecoratedDescriptor(target, property, decorators, descriptor, context) { var desc = {}; Object['ke' + 'ys'](descriptor).forEach(function (key) { desc[key] = descriptor[key]; }); desc.enumerable = !!desc.enumerable; desc.configurable = !!desc.configurable; if ('value' in desc || desc.initializer) { desc.writable = true; } desc = decorators.slice().reverse().reduce(function (desc, decorator) { return decorator(target, property, desc) || desc; }, desc); if (context && desc.initializer !== void 0) { desc.value = desc.initializer ? desc.initializer.call(context) : void 0; desc.initializer = undefined; } if (desc.initializer === void 0) { Object['define' + 'Property'](target, property, desc); desc = null; } return desc; }
|
||||
function _applyDecoratedDescriptor(target, property, decorators, descriptor, context) { var desc = {}; Object.keys(descriptor).forEach(function (key) { desc[key] = descriptor[key]; }); desc.enumerable = !!desc.enumerable; desc.configurable = !!desc.configurable; if ('value' in desc || desc.initializer) { desc.writable = true; } desc = decorators.slice().reverse().reduce(function (desc, decorator) { return decorator(target, property, desc) || desc; }, desc); if (context && desc.initializer !== void 0) { desc.value = desc.initializer ? desc.initializer.call(context) : void 0; desc.initializer = undefined; } if (desc.initializer === void 0) { Object.defineProperty(target, property, desc); desc = null; } return desc; }
|
||||
|
||||
/**
|
||||
* Abstract representation of a selected bucket.
|
||||
|
|
@ -1277,11 +1301,68 @@ let Bucket = (_dec = (0, _utils.capable)(["history"]), (_class = class Bucket {
|
|||
safe: this._getSafe(options)
|
||||
});
|
||||
}
|
||||
/**
|
||||
* Retrieves the ETag of the collection list, for use with the `since` filtering option.
|
||||
*
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @return {Promise<String, Error>}
|
||||
*/
|
||||
|
||||
|
||||
async getCollectionsTimestamp(options = {}) {
|
||||
const path = (0, _endpoint.default)("collection", this.name);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path,
|
||||
method: "HEAD"
|
||||
};
|
||||
const {
|
||||
headers
|
||||
} = await this.client.execute(request, {
|
||||
raw: true,
|
||||
retry: this._getRetry(options)
|
||||
});
|
||||
return headers.get("ETag");
|
||||
}
|
||||
/**
|
||||
* Retrieves the ETag of the group list, for use with the `since` filtering option.
|
||||
*
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @return {Promise<String, Error>}
|
||||
*/
|
||||
|
||||
|
||||
async getGroupsTimestamp(options = {}) {
|
||||
const path = (0, _endpoint.default)("group", this.name);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path,
|
||||
method: "HEAD"
|
||||
};
|
||||
const {
|
||||
headers
|
||||
} = await this.client.execute(request, {
|
||||
raw: true,
|
||||
retry: this._getRetry(options)
|
||||
});
|
||||
return headers.get("ETag");
|
||||
}
|
||||
/**
|
||||
* Retrieves bucket data.
|
||||
*
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Object} [options.query] Query parameters to pass in
|
||||
* the request. This might be useful for features that aren't
|
||||
* yet supported by this library.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @return {Promise<Object, Error>}
|
||||
|
|
@ -1289,9 +1370,11 @@ let Bucket = (_dec = (0, _utils.capable)(["history"]), (_class = class Bucket {
|
|||
|
||||
|
||||
async getData(options = {}) {
|
||||
let path = (0, _endpoint.default)("bucket", this.name);
|
||||
path = (0, _utils.addEndpointOptions)(path, options);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path: (0, _endpoint.default)("bucket", this.name)
|
||||
path
|
||||
};
|
||||
const {
|
||||
data
|
||||
|
|
@ -1375,9 +1458,12 @@ let Bucket = (_dec = (0, _utils.capable)(["history"]), (_class = class Bucket {
|
|||
* Retrieves the list of collections in the current bucket.
|
||||
*
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.filters={}] The filters object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @return {Promise<Array<Object>, Error>}
|
||||
*/
|
||||
|
||||
|
|
@ -1465,9 +1551,12 @@ let Bucket = (_dec = (0, _utils.capable)(["history"]), (_class = class Bucket {
|
|||
* Retrieves the list of groups in the current bucket.
|
||||
*
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.filters={}] The filters object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @return {Promise<Array<Object>, Error>}
|
||||
*/
|
||||
|
||||
|
|
@ -1480,21 +1569,28 @@ let Bucket = (_dec = (0, _utils.capable)(["history"]), (_class = class Bucket {
|
|||
});
|
||||
}
|
||||
/**
|
||||
* Creates a new group in current bucket.
|
||||
* Fetches a group in current bucket.
|
||||
*
|
||||
* @param {String} id The group id.
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @param {Object} [options.query] Query parameters to pass in
|
||||
* the request. This might be useful for features that aren't
|
||||
* yet supported by this library.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @return {Promise<Object, Error>}
|
||||
*/
|
||||
|
||||
|
||||
async getGroup(id, options = {}) {
|
||||
let path = (0, _endpoint.default)("group", this.name, id);
|
||||
path = (0, _utils.addEndpointOptions)(path, options);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path: (0, _endpoint.default)("group", this.name, id)
|
||||
path
|
||||
};
|
||||
return this.client.execute(request, {
|
||||
retry: this._getRetry(options)
|
||||
|
|
@ -1793,7 +1889,7 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de
|
|||
|
||||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }
|
||||
|
||||
function _applyDecoratedDescriptor(target, property, decorators, descriptor, context) { var desc = {}; Object['ke' + 'ys'](descriptor).forEach(function (key) { desc[key] = descriptor[key]; }); desc.enumerable = !!desc.enumerable; desc.configurable = !!desc.configurable; if ('value' in desc || desc.initializer) { desc.writable = true; } desc = decorators.slice().reverse().reduce(function (desc, decorator) { return decorator(target, property, desc) || desc; }, desc); if (context && desc.initializer !== void 0) { desc.value = desc.initializer ? desc.initializer.call(context) : void 0; desc.initializer = undefined; } if (desc.initializer === void 0) { Object['define' + 'Property'](target, property, desc); desc = null; } return desc; }
|
||||
function _applyDecoratedDescriptor(target, property, decorators, descriptor, context) { var desc = {}; Object.keys(descriptor).forEach(function (key) { desc[key] = descriptor[key]; }); desc.enumerable = !!desc.enumerable; desc.configurable = !!desc.configurable; if ('value' in desc || desc.initializer) { desc.writable = true; } desc = decorators.slice().reverse().reduce(function (desc, decorator) { return decorator(target, property, desc) || desc; }, desc); if (context && desc.initializer !== void 0) { desc.value = desc.initializer ? desc.initializer.call(context) : void 0; desc.initializer = undefined; } if (desc.initializer === void 0) { Object.defineProperty(target, property, desc); desc = null; } return desc; }
|
||||
|
||||
/**
|
||||
* Abstract representation of a selected collection.
|
||||
|
|
@ -1915,6 +2011,32 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
});
|
||||
return parseInt(headers.get("Total-Records"), 10);
|
||||
}
|
||||
/**
|
||||
* Retrieves the ETag of the records list, for use with the `since` filtering option.
|
||||
*
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @return {Promise<String, Error>}
|
||||
*/
|
||||
|
||||
|
||||
async getRecordsTimestamp(options = {}) {
|
||||
const path = (0, _endpoint.default)("record", this.bucket.name, this.name);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path,
|
||||
method: "HEAD"
|
||||
};
|
||||
const {
|
||||
headers
|
||||
} = await this.client.execute(request, {
|
||||
raw: true,
|
||||
retry: this._getRetry(options)
|
||||
});
|
||||
return headers.get("ETag");
|
||||
}
|
||||
/**
|
||||
* Retrieves collection data.
|
||||
*
|
||||
|
|
@ -1923,6 +2045,8 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
* @param {Object} [options.query] Query parameters to pass in
|
||||
* the request. This might be useful for features that aren't
|
||||
* yet supported by this library.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @return {Promise<Object, Error>}
|
||||
|
|
@ -1931,12 +2055,7 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
|
||||
async getData(options = {}) {
|
||||
let path = (0, _endpoint.default)("collection", this.bucket.name, this.name);
|
||||
|
||||
if (options.query) {
|
||||
const querystring = (0, _utils.qsify)(options.query);
|
||||
path = path + "?" + querystring;
|
||||
}
|
||||
|
||||
path = (0, _utils.addEndpointOptions)(path, options);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path
|
||||
|
|
@ -2307,6 +2426,11 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
* @param {String} id The record id to retrieve.
|
||||
* @param {Object} [options={}] The options object.
|
||||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Object} [options.query] Query parameters to pass in
|
||||
* the request. This might be useful for features that aren't
|
||||
* yet supported by this library.
|
||||
* @param {Array} [options.fields] Limit response to
|
||||
* just some fields.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @return {Promise<Object, Error>}
|
||||
|
|
@ -2314,7 +2438,8 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
|
||||
|
||||
async getRecord(id, options = {}) {
|
||||
const path = (0, _endpoint.default)("record", this.bucket.name, this.name, id);
|
||||
let path = (0, _endpoint.default)("record", this.bucket.name, this.name, id);
|
||||
path = (0, _utils.addEndpointOptions)(path, options);
|
||||
const request = {
|
||||
headers: this._getHeaders(options),
|
||||
path
|
||||
|
|
@ -2350,12 +2475,13 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
* @param {Object} [options.headers] The headers object option.
|
||||
* @param {Number} [options.retry=0] Number of retries to make
|
||||
* when faced with transient errors.
|
||||
* @param {Object} [options.filters=[]] The filters object.
|
||||
* @param {Object} [options.filters={}] The filters object.
|
||||
* @param {String} [options.sort="-last_modified"] The sort field.
|
||||
* @param {String} [options.at] The timestamp to get a snapshot at.
|
||||
* @param {String} [options.limit=null] The limit field.
|
||||
* @param {String} [options.pages=1] The number of result pages to aggregate.
|
||||
* @param {Number} [options.since=null] Only retrieve records modified since the provided timestamp.
|
||||
* @param {Array} [options.fields] Limit response to just some fields.
|
||||
* @return {Promise<Object, Error>}
|
||||
*/
|
||||
|
||||
|
|
@ -2363,7 +2489,7 @@ let Collection = (_dec = (0, _utils.capable)(["attachments"]), _dec2 = (0, _util
|
|||
async listRecords(options = {}) {
|
||||
const path = (0, _endpoint.default)("record", this.bucket.name, this.name);
|
||||
|
||||
if (options.hasOwnProperty("at")) {
|
||||
if (Object.prototype.hasOwnProperty.call(options, "at")) {
|
||||
return this.getSnapshot(options.at);
|
||||
} else {
|
||||
return this.client.paginatedList(path, options, {
|
||||
|
|
@ -2971,8 +3097,9 @@ function createRequest(path, {
|
|||
} = { ...requestDefaults,
|
||||
...options
|
||||
};
|
||||
const method = options.method || data && data.id ? "PUT" : "POST";
|
||||
return {
|
||||
method: data && data.id ? "PUT" : "POST",
|
||||
method,
|
||||
path,
|
||||
headers: { ...headers,
|
||||
...safeHeader(safe)
|
||||
|
|
@ -3139,6 +3266,7 @@ exports.parseDataURL = parseDataURL;
|
|||
exports.extractFileInfo = extractFileInfo;
|
||||
exports.createFormData = createFormData;
|
||||
exports.cleanUndefinedProperties = cleanUndefinedProperties;
|
||||
exports.addEndpointOptions = addEndpointOptions;
|
||||
|
||||
/**
|
||||
* Chunks an array into n pieces.
|
||||
|
|
@ -3189,7 +3317,8 @@ async function pMap(list, fn) {
|
|||
let results = [];
|
||||
await list.reduce(async function (promise, entry) {
|
||||
await promise;
|
||||
results = results.concat((await fn(entry)));
|
||||
const out = await fn(entry);
|
||||
results = results.concat(out);
|
||||
}, Promise.resolve());
|
||||
return results;
|
||||
}
|
||||
|
|
@ -3505,6 +3634,32 @@ function cleanUndefinedProperties(obj) {
|
|||
|
||||
return result;
|
||||
}
|
||||
/**
|
||||
* Handle common query parameters for Kinto requests.
|
||||
*
|
||||
* @param {String} [path] The endpoint base path.
|
||||
* @param {Array} [options.fields] Fields to limit the
|
||||
* request to.
|
||||
* @param {Object} [options.query={}] Additional query arguments.
|
||||
*/
|
||||
|
||||
|
||||
function addEndpointOptions(path, options = {}) {
|
||||
const query = { ...options.query
|
||||
};
|
||||
|
||||
if (options.fields) {
|
||||
query._fields = options.fields;
|
||||
}
|
||||
|
||||
const queryString = qsify(query);
|
||||
|
||||
if (queryString) {
|
||||
return path + "?" + queryString;
|
||||
}
|
||||
|
||||
return path;
|
||||
}
|
||||
|
||||
},{}]},{},[1])(1)
|
||||
});
|
||||
|
|
|
|||
Загрузка…
Ссылка в новой задаче