mirror of
https://github.com/TryGhost/Ghost.git
synced 2024-12-18 16:01:40 +03:00
20710b9eba
refs #4605 - Move as much code as possible out of the DB API - Split the importer into 2 concepts, code which handles different filetypes and code which takes the content of files and imports it into Ghost in some way - Split the import process into 4 steps, load the file into a useful format, preprocess the data, do the import, generate a report - Reporting is currently a no-op - Adds a basic level of testing
104 lines
3.5 KiB
JavaScript
104 lines
3.5 KiB
JavaScript
// # DB API
|
|
// API for DB operations
|
|
var _ = require('lodash'),
|
|
Promise = require('bluebird'),
|
|
dataExport = require('../data/export'),
|
|
importer = require('../data/importer'),
|
|
models = require('../models'),
|
|
errors = require('../errors'),
|
|
canThis = require('../permissions').canThis,
|
|
utils = require('./utils'),
|
|
|
|
api = {},
|
|
db;
|
|
|
|
api.settings = require('./settings');
|
|
|
|
/**
|
|
* ## DB API Methods
|
|
*
|
|
* **See:** [API Methods](index.js.html#api%20methods)
|
|
*/
|
|
db = {
|
|
/**
|
|
* ### Export Content
|
|
* Generate the JSON to export
|
|
*
|
|
* @public
|
|
* @param {{context}} options
|
|
* @returns {Promise} Ghost Export JSON format
|
|
*/
|
|
exportContent: function (options) {
|
|
options = options || {};
|
|
|
|
// Export data, otherwise send error 500
|
|
return canThis(options.context).exportContent.db().then(function () {
|
|
return dataExport().then(function (exportedData) {
|
|
return {db: [exportedData]};
|
|
}).catch(function (error) {
|
|
return Promise.reject(new errors.InternalServerError(error.message || error));
|
|
});
|
|
}, function () {
|
|
return Promise.reject(new errors.NoPermissionError('You do not have permission to export data (no rights).'));
|
|
});
|
|
},
|
|
/**
|
|
* ### Import Content
|
|
* Import posts, tags etc from a JSON blob
|
|
*
|
|
* @public
|
|
* @param {{context}} options
|
|
* @returns {Promise} Success
|
|
*/
|
|
importContent: function (options) {
|
|
options = options || {};
|
|
|
|
// Check if a file was provided
|
|
if (!utils.checkFileExists(options, 'importfile')) {
|
|
return Promise.reject(new errors.NoPermissionError('Please select a file to import.'));
|
|
}
|
|
|
|
// Check if the file is valid
|
|
if (!utils.checkFileIsValid(options.importfile, importer.getTypes(), importer.getExtensions())) {
|
|
return Promise.reject(new errors.UnsupportedMediaTypeError(
|
|
'Unsupported file. Please try any of the following formats: ' +
|
|
_.reduce(importer.getExtensions(), function (memo, ext) {
|
|
return memo ? memo + ', ' + ext : ext;
|
|
})
|
|
));
|
|
}
|
|
|
|
// Permissions check
|
|
return canThis(options.context).importContent.db().then(function () {
|
|
return importer.importFromFile(options.importfile)
|
|
.then(api.settings.updateSettingsCache)
|
|
.return({db: []});
|
|
}, function () {
|
|
return Promise.reject(new errors.NoPermissionError('You do not have permission to import data (no rights).'));
|
|
});
|
|
},
|
|
/**
|
|
* ### Delete All Content
|
|
* Remove all posts and tags
|
|
*
|
|
* @public
|
|
* @param {{context}} options
|
|
* @returns {Promise} Success
|
|
*/
|
|
deleteAllContent: function (options) {
|
|
options = options || {};
|
|
|
|
return canThis(options.context).deleteAllContent.db().then(function () {
|
|
return Promise.resolve(models.deleteAllContent())
|
|
.return({db: []})
|
|
.catch(function (error) {
|
|
return Promise.reject(new errors.InternalServerError(error.message || error));
|
|
});
|
|
}, function () {
|
|
return Promise.reject(new errors.NoPermissionError('You do not have permission to export data (no rights).'));
|
|
});
|
|
}
|
|
};
|
|
|
|
module.exports = db;
|