'use strict';
Object.defineProperty(exports, "__esModule", {
value: true
});
var _keys = require('babel-runtime/core-js/object/keys');
var _keys2 = _interopRequireDefault(_keys);
var _promise = require('babel-runtime/core-js/promise');
var _promise2 = _interopRequireDefault(_promise);
exports.wrapAsset = wrapAsset;
exports.wrapAssetCollection = wrapAssetCollection;
var _cloneDeep = require('lodash/cloneDeep');
var _cloneDeep2 = _interopRequireDefault(_cloneDeep);
var _freezeSys = require('contentful-sdk-core/freeze-sys');
var _freezeSys2 = _interopRequireDefault(_freezeSys);
var _enhanceWithMethods = require('../enhance-with-methods');
var _enhanceWithMethods2 = _interopRequireDefault(_enhanceWithMethods);
var _toPlainObject = require('contentful-sdk-core/mixins/to-plain-object');
var _toPlainObject2 = _interopRequireDefault(_toPlainObject);
var _errorHandler = require('../error-handler');
var _errorHandler2 = _interopRequireDefault(_errorHandler);
var _instanceActions = require('../instance-actions');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
/**
* Asset instances
* @namespace Asset
*/
var ASSET_PROCESSING_CHECK_WAIT = 500;
var ASSET_PROCESSING_CHECK_RETRIES = 5;
/**
* @memberof Asset
* @typedef Asset
* @prop {Meta.Sys} sys - Standard system metadata with additional asset specific properties
* @prop {string=} sys.locale - If present, indicates the locale which this asset uses
* @prop {Object} fields - Object with content for each field
* @prop {string} fields.title - Title for this asset
* @prop {string} fields.description - Description for this asset
* @prop {Object} fields.file - File object for this asset
* @prop {Object} fields.file.fileName - Name for the file
* @prop {string} fields.file.contentType - Mime type for the file
* @prop {string=} fields.file.upload - Url where the file is available to be downloaded from, into the Contentful asset system. After the asset is processed this field is gone.
* @prop {string=} fields.file.url - Url where the file is available at the Contentful media asset system. This field won't be available until the asset is processed.
* @prop {Object} fields.file.details - Details for the file, depending on file type (example: image size in bytes, etc)
* @prop {function(): Object} toPlainObject() - Returns this Asset as a plain JS object
*/
function createAssetApi(http) {
function checkIfAssetHasUrl(_ref) {
var resolve = _ref.resolve;
var reject = _ref.reject;
var id = _ref.id;
var locale = _ref.locale;
var _ref$processingCheckW = _ref.processingCheckWait;
var processingCheckWait = _ref$processingCheckW === undefined ? ASSET_PROCESSING_CHECK_WAIT : _ref$processingCheckW;
var _ref$processingCheckR = _ref.processingCheckRetries;
var processingCheckRetries = _ref$processingCheckR === undefined ? ASSET_PROCESSING_CHECK_RETRIES : _ref$processingCheckR;
var _ref$checkCount = _ref.checkCount;
var checkCount = _ref$checkCount === undefined ? 0 : _ref$checkCount;
http.get('assets/' + id).then(function (response) {
return wrapAsset(http, response.data);
}, _errorHandler2.default).then(function (asset) {
if (asset.fields.file[locale].url) {
resolve(asset);
} else if (checkCount === processingCheckRetries) {
var error = new Error();
error.name = 'AssetProcessingTimeout';
error.message = 'Asset is taking longer then expected to process.';
reject(error);
} else {
checkCount++;
setTimeout(function () {
return checkIfAssetHasUrl({
resolve: resolve,
reject: reject,
id: id,
locale: locale,
checkCount: checkCount
});
}, processingCheckWait);
}
});
}
function processForLocale(locale) {
var _ref2 = arguments.length <= 1 || arguments[1] === undefined ? {} : arguments[1];
var processingCheckWait = _ref2.processingCheckWait;
var processingCheckRetries = _ref2.processingCheckRetries;
var assetId = this.sys.id;
return http.put('assets/' + this.sys.id + '/files/' + locale + '/process', null, {
headers: {
'X-Contentful-Version': this.sys.version
}
}).then(function () {
return new _promise2.default(function (resolve, reject) {
return checkIfAssetHasUrl({
resolve: resolve,
reject: reject,
id: assetId,
locale: locale,
processingCheckWait: processingCheckWait,
processingCheckRetries: processingCheckRetries
});
});
}, _errorHandler2.default);
}
function processForAllLocales() {
var options = arguments.length <= 0 || arguments[0] === undefined ? {} : arguments[0];
var self = this;
var locales = (0, _keys2.default)(this.fields.file);
return _promise2.default.all(locales.map(function (locale) {
return processForLocale.call(self, locale, options);
})).then(function (assets) {
return assets[0];
});
}
return {
/**
* Sends an update to the server with any changes made to the object's properties
* @memberof Asset
* @func update
* @return {Promise<Asset>} Object returned from the server with updated changes.
* @example
* contentType.fields.name['en-US'] = 'Blog Post'
* asset.update()
* .then(asset => console.log(asset.fields.name['en-US']))
*/
update: (0, _instanceActions.createUpdateEntity)({
http: http,
entityPath: 'assets',
wrapperMethod: wrapAsset
}),
/**
* Deletes this object on the server.
* @memberof Asset
* @func delete
* @return {Promise} Promise for the deletion. It contains no data, but the Promise error case should be handled.
* @example
* asset.delete()
* .catch(err => console.log(err))
*/
delete: (0, _instanceActions.createDeleteEntity)({
http: http,
entityPath: 'assets'
}),
/**
* Publishes the object
* @memberof Asset
* @func publish
* @return {Promise<Asset>} Object returned from the server with updated metadata.
* @example
* asset.publish()
* .then(asset => console.log(asset.sys.publishedVersion))
*/
publish: (0, _instanceActions.createPublishEntity)({
http: http,
entityPath: 'assets',
wrapperMethod: wrapAsset
}),
/**
* Unpublishes the object
* @memberof Asset
* @func unpublish
* @return {Promise<Asset>} Object returned from the server with updated metadata.
* @example
* asset.unpublish()
* .then(asset => console.log(asset.sys))
*/
unpublish: (0, _instanceActions.createUnpublishEntity)({
http: http,
entityPath: 'assets',
wrapperMethod: wrapAsset
}),
/**
* Archives the object
* @memberof Asset
* @func archive
* @return {Promise<Asset>} Object returned from the server with updated metadata.
* @example
* asset.archive()
* .then(asset => console.log(asset.sys.archivedVersion))
*/
archive: (0, _instanceActions.createArchiveEntity)({
http: http,
entityPath: 'assets',
wrapperMethod: wrapAsset
}),
/**
* Unarchives the object
* @memberof Asset
* @func unarchive
* @return {Promise<Asset>} Object returned from the server with updated metadata.
* @example
* asset.unarchive()
* .then(asset => console.log(asset.sys))
*/
unarchive: (0, _instanceActions.createUnarchiveEntity)({
http: http,
entityPath: 'assets',
wrapperMethod: wrapAsset
}),
/**
* Triggers asset processing after an upload, for the file uploaded to a specific locale.
* @memberof Asset
* @func processForLocale
* @param {string} locale - Locale which processing should be triggered for
* @param {object} options - Additional options for processing
* @prop {number} options.processingCheckWait - Time in milliseconds to wait before checking again if the asset has been processed (default: 500ms)
* @prop {number} options.processingCheckRetries - Maximum amount of times to check if the asset has been processed (default: 5)
* @return {Promise<Asset>} Object returned from the server with updated metadata.
* @throws {AssetProcessingTimeout} If the asset takes too long to process. If this happens, retrieve the asset again, and if the url property is available, then processing has succeeded. If not, your file might be damaged.
* @example
* asset.processForLocale('en-US')
* .then(asset => console.log(asset.fields.file['en-US'].url))
*/
processForLocale: processForLocale,
/**
* Triggers asset processing after an upload, for the files uploaded to all locales of an asset.
* @memberof Asset
* @func processForAllLocales
* @param {object} options - Additional options for processing
* @prop {number} options.processingCheckWait - Time in milliseconds to wait before checking again if the asset has been processed (default: 500ms)
* @prop {number} options.processingCheckRetries - Maximum amount of times to check if the asset has been processed (default: 5)
* @return {Promise<Asset>} Object returned from the server with updated metadata.
* @throws {AssetProcessingTimeout} If the asset takes too long to process. If this happens, retrieve the asset again, and if the url property is available, then processing has succeeded. If not, your file might be damaged.
* @example
* asset.processForAllLocales()
* .then(asset => console.log(asset.fields.file['en-US'].url, asset.fields.file['de-DE'].url))
*/
processForAllLocales: processForAllLocales,
/**
* Checks if the asset is published. A published asset might have unpublished changes (@see {Asset.isUpdated})
* @memberof Asset
* @func isPublished
* @return {boolean}
*/
isPublished: (0, _instanceActions.createPublishedChecker)(),
/**
* Checks if the asset is updated. This means the asset was previously published but has unpublished changes.
* @memberof Asset
* @func isUpdated
* @return {boolean}
*/
isUpdated: (0, _instanceActions.createUpdatedChecker)(),
/**
* Checks if the asset is in draft mode. This means it is not published.
* @memberof Asset
* @func isDraft
* @return {boolean}
*/
isDraft: (0, _instanceActions.createDraftChecker)(),
/**
* Checks if asset is archived. This means it's not exposed to the Delivery/Preview APIs.
* @memberof Asset
* @func isArchived
* @return {boolean}
*/
isArchived: (0, _instanceActions.createArchivedChecker)()
};
}
/**
* @private
* @param {Object} http - HTTP client instance
* @param {Object} data - Raw asset data
* @return {Asset} Wrapped asset data
*/
function wrapAsset(http, data) {
var asset = (0, _toPlainObject2.default)((0, _cloneDeep2.default)(data));
(0, _enhanceWithMethods2.default)(asset, createAssetApi(http));
return (0, _freezeSys2.default)(asset);
}
/**
* @memberof Asset
* @typedef AssetCollection
* @prop {number} total
* @prop {number} skip
* @prop {number} limit
* @prop {Array<Asset.Asset>} items
* @prop {function(): Object} toPlainObject() - Returns this Asset collection as a plain JS object
*/
/**
* @private
* @param {Object} http - HTTP client instance
* @param {Object} data - Raw asset collection data
* @return {AssetCollection} Wrapped asset collection data
*/
function wrapAssetCollection(http, data) {
var assets = (0, _toPlainObject2.default)((0, _cloneDeep2.default)(data));
assets.items = assets.items.map(function (entity) {
return wrapAsset(http, entity);
});
return (0, _freezeSys2.default)(assets);
}