mirror of
https://github.com/TryGhost/Ghost.git
synced 2025-04-01 02:41:39 -05:00
Deleted all v1/v2/v3 migrations
refs https://github.com/TryGhost/Toolbox/issues/300 - due to Node compatibility, it only makes sense that users on the latest v3 (and v4) can update to v5 - therefore, we don't need v1/2/3 migrations as it's more maintenance in the long run - this deletes over 5000 lines of code (!!)
This commit is contained in:
Daniel Lockyer
parent
19852de5cb
commit
145dc4651a
151 changed files with 0 additions and 5275 deletions
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('posts', 'custom_template', {
|
||||
type: 'string',
|
||||
maxlength: 100,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,58 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Browse themes',
|
||||
action: 'browse',
|
||||
object: 'theme'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration',
|
||||
'Editor',
|
||||
'Author',
|
||||
'Contributor'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Edit themes',
|
||||
action: 'edit',
|
||||
object: 'theme'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Activate themes',
|
||||
action: 'activate',
|
||||
object: 'theme'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Upload themes',
|
||||
action: 'add',
|
||||
object: 'theme'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Download themes',
|
||||
action: 'read',
|
||||
object: 'theme'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete themes',
|
||||
action: 'destroy',
|
||||
object: 'theme'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('webhooks');
|
||||
|
|
@ -1,31 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Add webhooks',
|
||||
action: 'add',
|
||||
object: 'webhook'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Edit webhooks',
|
||||
action: 'edit',
|
||||
object: 'webhook'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete webhooks',
|
||||
action: 'destroy',
|
||||
object: 'webhook'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,65 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const models = require('../../../../models');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = function removeSettingKeys(options) {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return models.Settings.findOne({key: 'display_update_notification'}, localOptions)
|
||||
.then(function (settingsModel) {
|
||||
if (!settingsModel) {
|
||||
logging.warn('Deleted Settings Key `display_update_notification`.');
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info('Deleted Settings Key `display_update_notification`.');
|
||||
return models.Settings.destroy(_.merge({id: settingsModel.id}, localOptions));
|
||||
})
|
||||
.then(function () {
|
||||
return models.Settings.findOne({key: 'seen_notifications'}, localOptions);
|
||||
})
|
||||
.then(function (settingsModel) {
|
||||
if (!settingsModel) {
|
||||
logging.warn('Deleted Settings Key `seen_notifications`.');
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info('Deleted Settings Key `seen_notifications`.');
|
||||
return models.Settings.destroy(_.merge({id: settingsModel.id}, localOptions));
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = function addSettingsKeys(options) {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return models.Settings.findOne({key: 'display_update_notification'}, localOptions)
|
||||
.then(function (settingsModel) {
|
||||
if (settingsModel) {
|
||||
logging.warn('Added Settings Key `display_update_notification`.');
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info('Added Settings Key `display_update_notification`.');
|
||||
return models.Settings.forge({key: 'display_update_notification'}).save(null, localOptions);
|
||||
})
|
||||
.then(function () {
|
||||
return models.Settings.findOne({key: 'seen_notifications'}, localOptions);
|
||||
})
|
||||
.then(function (settingsModel) {
|
||||
if (settingsModel) {
|
||||
logging.warn('Added Settings Key `seen_notifications`.');
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info('Added Settings Key `seen_notifications`.');
|
||||
return models.Settings.forge({key: 'seen_notifications', value: '[]'}).save([], localOptions);
|
||||
});
|
||||
};
|
||||
|
|
@ -1,58 +0,0 @@
|
|||
const merge = require('lodash/merge');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
const models = require('../../../../models');
|
||||
const permissions = require('../../../../services/permissions');
|
||||
const logging = require('@tryghost/logging');
|
||||
const _private = {};
|
||||
|
||||
_private.addRole = function addRole(options) {
|
||||
const contributorRole = fixtureManager.findModelFixtureEntry('Role', {name: 'Contributor'});
|
||||
const message = 'Adding "Contributor" role to roles table';
|
||||
|
||||
return models.Role.findOne({name: contributorRole.name}, options)
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
logging.info(message);
|
||||
return fixtureManager.addFixturesForModel({name: 'Role', entries: [contributorRole]}, options);
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
return Promise.resolve();
|
||||
});
|
||||
};
|
||||
|
||||
_private.addContributorPermissions = function getPermissions(options) {
|
||||
const relations = fixtureManager.findRelationFixture('Role', 'Permission');
|
||||
const message = 'Adding permissions_roles fixtures for the contributor role';
|
||||
|
||||
return fixtureManager.addFixturesForRelation({
|
||||
from: relations.from,
|
||||
to: relations.to,
|
||||
entries: {
|
||||
Contributor: relations.entries.Contributor
|
||||
}
|
||||
}, options).then((result) => {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
return;
|
||||
}
|
||||
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = function addContributorRole(options) {
|
||||
const localOptions = merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return _private.addRole(localOptions).then(() => {
|
||||
return _private.addContributorPermissions(localOptions);
|
||||
}).then(() => {
|
||||
return permissions.init(localOptions);
|
||||
});
|
||||
};
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('posts_authors');
|
||||
|
|
@ -1,63 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const ObjectId = require('bson-objectid');
|
||||
const logging = require('@tryghost/logging');
|
||||
const models = require('../../../../models');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = function handleMultipleAuthors(options) {
|
||||
const postAllColumns = ['id', 'author_id'];
|
||||
const userColumns = ['id'];
|
||||
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return models.User.getOwnerUser(_.merge({columns: userColumns}, localOptions))
|
||||
.then(function (ownerUser) {
|
||||
return models.Post.findAll(_.merge({columns: postAllColumns}, localOptions))
|
||||
.then(function (posts) {
|
||||
logging.info('Adding `posts_authors` relations');
|
||||
|
||||
return Promise.map(posts.models, function (post) {
|
||||
let invalidAuthorId = false;
|
||||
|
||||
// CASE: ensure `post.author_id` is a valid user id
|
||||
return models.User.findOne({id: post.get('author_id')}, _.merge({columns: userColumns}, localOptions))
|
||||
.then(function (user) {
|
||||
if (!user) {
|
||||
invalidAuthorId = true;
|
||||
|
||||
// NOTE: updating the `author_id`, will auto initialize `post.authors`.
|
||||
// This is an edge case and should not happen for many blogs. We skip the manual insert.
|
||||
return models.Post.edit({
|
||||
author_id: ownerUser.id
|
||||
}, _.merge({id: post.id}, localOptions));
|
||||
}
|
||||
|
||||
return post;
|
||||
})
|
||||
.then(function (editedPost) {
|
||||
if (invalidAuthorId) {
|
||||
return;
|
||||
}
|
||||
|
||||
return options.transacting('posts_authors').insert({
|
||||
id: ObjectId().toHexString(),
|
||||
post_id: editedPost.id,
|
||||
author_id: editedPost.get('author_id'),
|
||||
sort_order: 0
|
||||
});
|
||||
});
|
||||
}, {concurrency: 100});
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = function handleMultipleAuthors(options) {
|
||||
logging.info('Removing `posts_authors` relations');
|
||||
return options.connection('posts_authors').truncate();
|
||||
};
|
||||
|
|
@ -1,70 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const mobiledocLib = require('../../../../lib/mobiledoc');
|
||||
const models = require('../../../../models');
|
||||
const message1 = 'Migrating Koenig beta post\'s mobiledoc/HTML to 2.0 format';
|
||||
const message2 = 'Migrated Koenig beta post\'s mobiledoc/HTML to 2.0 format';
|
||||
|
||||
const mobiledocIsCompatibleWithV1 = function mobiledocIsCompatibleWithV1(doc) {
|
||||
if (doc
|
||||
&& doc.markups.length === 0
|
||||
&& doc.cards.length === 1
|
||||
&& doc.cards[0][0].match(/(?:card-)?markdown/)
|
||||
&& doc.sections.length === 1
|
||||
&& doc.sections[0].length === 2
|
||||
&& doc.sections[0][0] === 10
|
||||
&& doc.sections[0][1] === 0
|
||||
) {
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = function regenerateKoenigBetaHTML(options) {
|
||||
let postAllColumns = ['id', 'html', 'mobiledoc'];
|
||||
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
logging.info(message1);
|
||||
|
||||
return models.Post.findAll(_.merge({columns: postAllColumns}, localOptions))
|
||||
.then(function (posts) {
|
||||
return Promise.map(posts.models, function (post) {
|
||||
let mobiledoc = JSON.parse(post.get('mobiledoc') || null);
|
||||
|
||||
if (
|
||||
post.get('html') && post.get('html').match(/^<div class="kg-post">/)
|
||||
|| (mobiledoc && !mobiledocIsCompatibleWithV1(mobiledoc))
|
||||
) {
|
||||
// change imagecard.payload.imageStyle to imagecard.payload.cardWidth
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
mobiledoc.cards.forEach((card) => {
|
||||
if (card[0] === 'image') {
|
||||
card[1].cardWidth = card[1].imageStyle;
|
||||
delete card[1].imageStyle;
|
||||
}
|
||||
});
|
||||
|
||||
// re-render the html to remove .kg-post wrapper and adjust image classes
|
||||
let version = 2;
|
||||
let html = mobiledocLib.mobiledocHtmlRenderer.render(mobiledoc, {version});
|
||||
|
||||
return models.Post.edit({
|
||||
html,
|
||||
mobiledoc: JSON.stringify(mobiledoc)
|
||||
}, _.merge({id: post.id}, localOptions));
|
||||
}
|
||||
}, {concurrency: 100});
|
||||
})
|
||||
.then(() => {
|
||||
logging.info(message2);
|
||||
});
|
||||
};
|
||||
|
|
@ -1,55 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const logging = require('@tryghost/logging');
|
||||
const models = require('../../../../models');
|
||||
const fixtures = require('../../../../data/schema/fixtures');
|
||||
const message1 = 'Adding demo post.';
|
||||
const message2 = 'Added demo post.';
|
||||
const message3 = 'Skipped: Adding demo post. Slug already in use.';
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true},
|
||||
columns: ['id']
|
||||
}, options);
|
||||
|
||||
let userId;
|
||||
|
||||
logging.info(message1);
|
||||
|
||||
const demoPost = _.cloneDeep(fixtures.models[5].entries[0]);
|
||||
|
||||
return models.Post.findOne({slug: demoPost.slug, status: 'all'}, localOptions)
|
||||
.then((model) => {
|
||||
if (model) {
|
||||
logging.warn(message3);
|
||||
return;
|
||||
}
|
||||
|
||||
return models.User.findOne({id: fixtures.models[4].entries[1].id}, localOptions)
|
||||
.then((ghostAuthor) => {
|
||||
if (ghostAuthor) {
|
||||
userId = ghostAuthor.id;
|
||||
return;
|
||||
}
|
||||
|
||||
return models.User.getOwnerUser(localOptions);
|
||||
})
|
||||
.then((ownerUser) => {
|
||||
if (!userId) {
|
||||
userId = ownerUser.id;
|
||||
}
|
||||
|
||||
demoPost.created_by = userId;
|
||||
demoPost.author_id = userId;
|
||||
|
||||
return models.Post.add(demoPost, localOptions);
|
||||
})
|
||||
.then(() => {
|
||||
logging.info(message2);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('posts', 'custom_excerpt', {
|
||||
type: 'string',
|
||||
maxlength: 2000,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,14 +0,0 @@
|
|||
const {combineNonTransactionalMigrations, createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createAddColumnMigration('posts', 'codeinjection_head', {
|
||||
type: 'text',
|
||||
maxlength: 65535,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('posts', 'codeinjection_foot', {
|
||||
type: 'text',
|
||||
maxlength: 65535,
|
||||
nullable: true
|
||||
})
|
||||
);
|
||||
|
|
@ -1,34 +0,0 @@
|
|||
const {createAddColumnMigration, combineNonTransactionalMigrations} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createAddColumnMigration('posts', 'og_image', {
|
||||
type: 'string',
|
||||
maxlength: 2000,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('posts', 'og_title', {
|
||||
type: 'string',
|
||||
maxlength: 300,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('posts', 'og_description', {
|
||||
type: 'string',
|
||||
maxlength: 500,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('posts', 'twitter_image', {
|
||||
type: 'string',
|
||||
maxlength: 2000,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('posts', 'twitter_title', {
|
||||
type: 'string',
|
||||
maxlength: 300,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('posts', 'twitter_description', {
|
||||
type: 'string',
|
||||
maxlength: 500,
|
||||
nullable: true
|
||||
})
|
||||
);
|
||||
|
|
@ -1,10 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
|
||||
// NB: clients and client_trusted_domains were removed in 3.0 so the fixtures previously used here no longer exist
|
||||
module.exports.up = function addGhostBackupClient() {
|
||||
return Promise.resolve();
|
||||
};
|
||||
|
||||
module.exports.down = function removeGhostBackupClient() {
|
||||
return Promise.resolve();
|
||||
};
|
||||
|
|
@ -1,23 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Download redirects',
|
||||
action: 'download',
|
||||
object: 'redirect'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Upload redirects',
|
||||
action: 'download',
|
||||
object: 'redirect'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,44 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const table = 'posts';
|
||||
const columnNameOld = 'amp';
|
||||
const columnNameNew = 'comment_id';
|
||||
const message1 = `Renaming column ${columnNameOld} to ${columnNameNew}`;
|
||||
const message2 = `Rollback: Renaming column ${columnNameNew} to ${columnNameOld}`;
|
||||
const message3 = `Renamed column ${columnNameOld} to ${columnNameNew}`;
|
||||
const message4 = `Rollback: Renamed column ${columnNameNew} to ${columnNameOld}`;
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const connection = options.connection;
|
||||
|
||||
logging.info(message1);
|
||||
|
||||
return connection.schema.hasColumn(table, columnNameOld)
|
||||
.then((exists) => {
|
||||
if (exists) {
|
||||
return connection.schema.table(table, function (t) {
|
||||
t.renameColumn(columnNameOld, columnNameNew);
|
||||
});
|
||||
}
|
||||
})
|
||||
.then(() => {
|
||||
logging.info(message3);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
let connection = options.connection;
|
||||
|
||||
logging.warn(message2);
|
||||
|
||||
return connection.schema.hasColumn(table, columnNameNew)
|
||||
.then((exists) => {
|
||||
if (exists) {
|
||||
return connection.schema.table(table, function (t) {
|
||||
t.renameColumn(columnNameNew, columnNameOld);
|
||||
});
|
||||
}
|
||||
})
|
||||
.then(() => {
|
||||
logging.warn(message4);
|
||||
});
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
module.exports.up = () => {
|
||||
// noop - superceded by later majors performing re-render
|
||||
};
|
||||
|
||||
module.exports.down = () => {
|
||||
// noop - superceded by later majors performing re-render
|
||||
};
|
||||
|
|
@ -1,42 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const models = require('../../../../models');
|
||||
const message1 = 'Removing `koenigEditor` from labs.';
|
||||
const message2 = 'Removed `koenigEditor` from labs.';
|
||||
const message3 = 'Rollback: Please re-enable König Beta if required. We can\'t rollback this change.';
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return models.Settings.findOne({key: 'labs'}, localOptions)
|
||||
.then(function (settingsModel) {
|
||||
if (!settingsModel) {
|
||||
logging.warn('Labs field does not exist.');
|
||||
return;
|
||||
}
|
||||
|
||||
const labsValue = JSON.parse(settingsModel.get('value'));
|
||||
delete labsValue.koenigEditor;
|
||||
|
||||
logging.info(message1);
|
||||
return models.Settings.edit({
|
||||
key: 'labs',
|
||||
value: JSON.stringify(labsValue)
|
||||
}, localOptions);
|
||||
})
|
||||
.then(() => {
|
||||
logging.info(message2);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = () => {
|
||||
logging.warn(message3);
|
||||
return Promise.resolve();
|
||||
};
|
||||
|
|
@ -1,85 +0,0 @@
|
|||
const path = require('path');
|
||||
const fs = require('fs-extra');
|
||||
const config = require('../../../../../shared/config');
|
||||
const logging = require('@tryghost/logging');
|
||||
const models = require('../../../../models');
|
||||
const message1 = 'Removing `globals.permalinks` from routes.yaml.';
|
||||
const message2 = 'Removed `globals.permalinks` from routes.yaml.';
|
||||
const message3 = 'Skip: Removing `globals.permalinks` from routes.yaml.';
|
||||
const message4 = 'Rollback: Removing `globals.permalink` from routes.yaml. Nothing todo.';
|
||||
const message5 = 'Skip Rollback: Removing `globals.permalinks` from routes.yaml. Nothing todo.';
|
||||
|
||||
module.exports.up = () => {
|
||||
let localOptions = {
|
||||
context: {internal: true}
|
||||
};
|
||||
|
||||
const fileName = 'routes.yaml';
|
||||
const contentPath = config.getContentPath('settings');
|
||||
const filePath = path.join(contentPath, fileName);
|
||||
let settingsModel;
|
||||
|
||||
logging.info(message1);
|
||||
|
||||
return fs.readFile(filePath, 'utf8')
|
||||
.then((content) => {
|
||||
if (content.match(/globals\.permalinks/)) {
|
||||
return models.Settings.findOne({key: 'permalinks'}, localOptions)
|
||||
.then((model) => {
|
||||
// CASE: the permalinks setting get's inserted when you first start Ghost
|
||||
if (!model) {
|
||||
model = {
|
||||
get: () => {
|
||||
return '/:slug/';
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
settingsModel = model;
|
||||
|
||||
// CASE: create a backup
|
||||
return fs.copy(
|
||||
path.join(filePath),
|
||||
path.join(contentPath, 'routes-1.0-backup.yaml')
|
||||
);
|
||||
})
|
||||
.then(() => {
|
||||
const permalinkValue = settingsModel.get('value');
|
||||
let modifiedContent = content.replace(/\/?'?{globals.permalinks}'?\/?/g, permalinkValue.replace(/:(\w+)/g, '{$1}'));
|
||||
|
||||
if (modifiedContent.indexOf('# special 1.0 compatibility setting. See the docs for details.') !== -1) {
|
||||
modifiedContent = modifiedContent.replace('# special 1.0 compatibility setting. See the docs for details.', '');
|
||||
}
|
||||
|
||||
return fs.writeFile(filePath, modifiedContent, 'utf8');
|
||||
})
|
||||
.then(() => {
|
||||
logging.info(message2);
|
||||
});
|
||||
} else {
|
||||
logging.warn(message3);
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = () => {
|
||||
const fileName = 'routes-1.0-backup.yaml';
|
||||
const contentPath = config.getContentPath('settings');
|
||||
const filePath = path.join(contentPath, fileName);
|
||||
|
||||
logging.info(message4);
|
||||
|
||||
return fs.readFile(filePath, 'utf8')
|
||||
.then(() => {
|
||||
return fs.copy(
|
||||
path.join(filePath),
|
||||
path.join(contentPath, 'routes.yaml')
|
||||
);
|
||||
})
|
||||
.then(() => {
|
||||
return fs.remove(filePath);
|
||||
})
|
||||
.catch(() => {
|
||||
logging.warn(message5);
|
||||
});
|
||||
};
|
||||
File diff suppressed because one or more lines are too long
|
|
@ -1,10 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
|
||||
// @NOTE: the logic of this migration script was removed.
|
||||
module.exports.up = () => {
|
||||
return Promise.resolve();
|
||||
};
|
||||
|
||||
module.exports.down = () => {
|
||||
return Promise.resolve();
|
||||
};
|
||||
|
|
@ -1,5 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
|
||||
module.exports.up = () => Promise.resolve();
|
||||
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('actions');
|
||||
|
|
@ -1,12 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = addPermissionWithRoles({
|
||||
name: 'Browse Actions',
|
||||
action: 'browse',
|
||||
object: 'action'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]);
|
||||
|
|
@ -1,8 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('integrations', 'type', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: false,
|
||||
defaultTo: 'custom'
|
||||
});
|
||||
|
|
@ -1,69 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const merge = require('lodash/merge');
|
||||
const models = require('../../../../models');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
|
||||
const _private = {};
|
||||
|
||||
_private.printResult = function printResult(result, message) {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
} else {
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
}
|
||||
};
|
||||
|
||||
_private.addZapierIntegration = (options) => {
|
||||
const message = 'Adding "Zapier" integration';
|
||||
const fixtureIntegration = fixtureManager.findModelFixtureEntry('Integration', {slug: 'zapier'});
|
||||
|
||||
return models.Integration.findOne({slug: fixtureIntegration.slug}, options)
|
||||
.then((integration) => {
|
||||
if (!integration) {
|
||||
return fixtureManager.addFixturesForModel({
|
||||
name: 'Integration',
|
||||
entries: [fixtureIntegration]
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
});
|
||||
};
|
||||
|
||||
_private.removeZapierIntegration = (options) => {
|
||||
const message = 'Rollback: Removing "Zapier" integration';
|
||||
|
||||
return models.Integration.findOne({slug: 'zapier'}, options)
|
||||
.then((integration) => {
|
||||
if (!integration) {
|
||||
logging.warn(message);
|
||||
return;
|
||||
}
|
||||
|
||||
return integration.destroy().then(() => {
|
||||
logging.info(message);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.addZapierIntegration(localOptions);
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.removeZapierIntegration(localOptions);
|
||||
};
|
||||
|
|
@ -1 +0,0 @@
|
|||
module.exports.up = module.exports.down = () => Promise.resolve();
|
||||
|
|
@ -1,74 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.then((response) => {
|
||||
if (!response) {
|
||||
logging.warn('Cannot find settings.');
|
||||
return;
|
||||
}
|
||||
|
||||
return Promise.each(response, (entry) => {
|
||||
// @NOTE: ensure we only transform real boolean fields to ensure we won't modify any customer data
|
||||
if (['is_private', 'force_i18n', 'amp'].includes(entry.key)) {
|
||||
// @NOTE: sending false to db for type TEXT will transform to "0"
|
||||
if ((entry.value === '0' || entry.value === '1')) {
|
||||
const value = (!!+entry.value).toString();
|
||||
|
||||
logging.info(`Setting ${entry.key} to ${value} because it was ${entry.value}`);
|
||||
|
||||
/**
|
||||
* @NOTE: we have update raw data, because otherwise the `Settings.edit` fn will re-fetch the data
|
||||
* using Bookshelf and normalize "0" to false. The save won't happen then.
|
||||
*/
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.where('key', entry.key)
|
||||
.update({
|
||||
value: value
|
||||
});
|
||||
}
|
||||
|
||||
// @NOTE: null or undefined were obviously intended to be false
|
||||
if (entry.value === null || entry.value === undefined || entry.value === 'null' || entry.value === 'undefined') {
|
||||
const value = 'false';
|
||||
logging.info(`Setting ${entry.key} to ${value} because it was ${entry.value}`);
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.where('key', entry.key)
|
||||
.update({
|
||||
value
|
||||
});
|
||||
}
|
||||
|
||||
// @NOTE: Something other than true/false is stored, set to true, because that's how it would have behaved
|
||||
if (entry.value !== 'false' && entry.value !== 'true') {
|
||||
const value = 'true';
|
||||
logging.info(`Setting ${entry.key} to ${value} because it was ${entry.value}`);
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.where('key', entry.key)
|
||||
.update({
|
||||
value
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
logging.info(`Skip setting ${entry.key}`);
|
||||
return Promise.resolve();
|
||||
});
|
||||
});
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('posts', 'canonical_url', {
|
||||
type: 'text',
|
||||
maxlength: 2000,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,134 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const settingsCache = require('../../../../../shared/settings-cache');
|
||||
const config = require('../../../../../shared/config');
|
||||
const moment = require('moment');
|
||||
const fs = require('fs-extra');
|
||||
const path = require('path');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
const backupFileRegex = /ghost.([\d]{4}-[\d]{2}-[\d]{2}).json$/;
|
||||
|
||||
// @NOTE: spagetthi
|
||||
module.exports.up = (options) => {
|
||||
const contentPath = config.get('paths').contentPath;
|
||||
const dataPath = path.join(contentPath, 'data');
|
||||
|
||||
const localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
return fs.readdir(dataPath).then(function (files) {
|
||||
return files;
|
||||
}).catch(function () {
|
||||
logging.warn(`Error reading ${dataPath} whilst trying to ensure boolean settings are correct. Please double check your settings after this upgrade`);
|
||||
return [];
|
||||
}).then(function (files) {
|
||||
const backups = files.filter(function (filename) {
|
||||
return backupFileRegex.test(filename);
|
||||
}).sort(function (a, b) {
|
||||
const dateA = new Date(a.match(backupFileRegex)[1]);
|
||||
const dateB = new Date(b.match(backupFileRegex)[1]);
|
||||
|
||||
return dateB - dateA;
|
||||
});
|
||||
|
||||
if (backups.length === 0) {
|
||||
logging.warn('No backup files found, skipping...');
|
||||
return;
|
||||
}
|
||||
|
||||
const mostRecentBackup = backups[0];
|
||||
|
||||
logging.info(`Using backupfile ${path.join(dataPath, mostRecentBackup)}`);
|
||||
|
||||
let backup;
|
||||
try {
|
||||
backup = require(path.join(dataPath, mostRecentBackup));
|
||||
} catch (e) {
|
||||
logging.warn(`Could not read ${path.join(dataPath, mostRecentBackup)} whilst trying to ensure boolean settings are correct. Please double check your settings after this upgrade`);
|
||||
return;
|
||||
}
|
||||
const settings = backup && backup.data && backup.data.settings;
|
||||
|
||||
if (!settings) {
|
||||
logging.warn('Could not read settings from backup file, skipping...');
|
||||
return;
|
||||
}
|
||||
|
||||
return localOptions
|
||||
.transacting('migrations')
|
||||
.then((response) => {
|
||||
if (!response) {
|
||||
logging.warn('Cannot find migrations.');
|
||||
return;
|
||||
}
|
||||
|
||||
// NOTE: You are only affected if you migrated to 2.17
|
||||
// 2.18 fixed the 2.17 migration (!)
|
||||
const isAffected = _.find(response, {currentVersion: '2.17', version: '2.17'});
|
||||
|
||||
if (!isAffected) {
|
||||
logging.warn('Skipping migration. Not affected.');
|
||||
return;
|
||||
}
|
||||
|
||||
logging.warn('...is affected.');
|
||||
|
||||
const relevantBackupSettings = settings.filter(function (entry) {
|
||||
return ['is_private', 'force_i18n', 'amp'].includes(entry.key);
|
||||
}).reduce(function (obj, entry) {
|
||||
return Object.assign(obj, {
|
||||
[entry.key]: entry
|
||||
});
|
||||
}, {});
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.then((settingsResponse) => {
|
||||
if (!settingsResponse) {
|
||||
logging.warn('Cannot find settings.');
|
||||
return;
|
||||
}
|
||||
|
||||
const relevantLiveSettings = settingsResponse.filter(function (entry) {
|
||||
return ['is_private', 'force_i18n', 'amp'].includes(entry.key);
|
||||
});
|
||||
|
||||
return Promise.each(relevantLiveSettings, (liveSetting) => {
|
||||
const backupSetting = relevantBackupSettings[liveSetting.key];
|
||||
|
||||
if (liveSetting.value === 'false' && backupSetting.value === 'true') {
|
||||
logging.info(`Reverting setting ${liveSetting.key}`);
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.where('key', liveSetting.key)
|
||||
.update({
|
||||
value: backupSetting.value
|
||||
})
|
||||
.then(() => {
|
||||
// CASE: we have to update settings cache, because Ghost is able to run migrations on the same process
|
||||
settingsCache.set(liveSetting.key, {
|
||||
id: liveSetting.id,
|
||||
key: liveSetting.key,
|
||||
type: liveSetting.type,
|
||||
created_at: moment(liveSetting.created_at).startOf('seconds').toDate(),
|
||||
updated_at: moment().startOf('seconds').toDate(),
|
||||
updated_by: liveSetting.updated_by,
|
||||
created_by: liveSetting.created_by,
|
||||
value: backupSetting.value === 'true'
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
return Promise.resolve();
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
};
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('sessions');
|
||||
|
|
@ -1,6 +0,0 @@
|
|||
const {addTable, combineNonTransactionalMigrations} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
addTable('integrations'),
|
||||
addTable('api_keys')
|
||||
);
|
||||
|
|
@ -1,83 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const merge = require('lodash/merge');
|
||||
const models = require('../../../../models');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
|
||||
const _private = {};
|
||||
|
||||
_private.printResult = function printResult(result, message) {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
} else {
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
}
|
||||
};
|
||||
|
||||
_private.addApiKeyRole = (options) => {
|
||||
const message = 'Adding "Admin Integration" role to roles table';
|
||||
const apiKeyRole = fixtureManager.findModelFixtureEntry('Role', {name: 'Admin Integration'});
|
||||
|
||||
return models.Role.findOne({name: apiKeyRole.name}, options)
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
return fixtureManager.addFixturesForModel({
|
||||
name: 'Role',
|
||||
entries: [apiKeyRole]
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
});
|
||||
};
|
||||
|
||||
_private.addApiKeyPermissions = (options) => {
|
||||
const message = 'Adding permissions for the "Admin Integration" role';
|
||||
const relations = fixtureManager.findRelationFixture('Role', 'Permission');
|
||||
|
||||
return fixtureManager.addFixturesForRelation({
|
||||
from: relations.from,
|
||||
to: relations.to,
|
||||
entries: {
|
||||
'Admin Integration': relations.entries['Admin Integration']
|
||||
}
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
};
|
||||
|
||||
_private.removeApiKeyPermissionsAndRole = (options) => {
|
||||
const message = 'Rollback: Removing "Admin Integration" role and permissions';
|
||||
|
||||
return models.Role.findOne({name: 'Admin Integration'}, options)
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
logging.warn(message);
|
||||
return;
|
||||
}
|
||||
|
||||
return role.destroy(options).then(() => {
|
||||
logging.info(message);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.addApiKeyRole(localOptions)
|
||||
.then(() => _private.addApiKeyPermissions(localOptions));
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.removeApiKeyPermissionsAndRole(localOptions);
|
||||
};
|
||||
|
|
@ -1,77 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Browse integrations',
|
||||
action: 'browse',
|
||||
object: 'integration'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Read integrations',
|
||||
action: 'read',
|
||||
object: 'integration'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Edit integrations',
|
||||
action: 'edit',
|
||||
object: 'integration'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Add integrations',
|
||||
action: 'add',
|
||||
object: 'integration'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete integrations',
|
||||
action: 'destroy',
|
||||
object: 'integration'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Browse API keys',
|
||||
action: 'browse',
|
||||
object: 'api_key'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Read API keys',
|
||||
action: 'read',
|
||||
object: 'api_key'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Edit API keys',
|
||||
action: 'edit',
|
||||
object: 'api_key'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Add API keys',
|
||||
action: 'add',
|
||||
object: 'api_key'
|
||||
}, [
|
||||
'Administrator'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete API keys',
|
||||
action: 'destroy',
|
||||
object: 'api_key'
|
||||
}, [
|
||||
'Administrator'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('mobiledoc_revisions');
|
||||
|
|
@ -1,28 +0,0 @@
|
|||
const {
|
||||
combineTransactionalMigrations,
|
||||
addPermissionWithRoles
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Browse notifications',
|
||||
action: 'browse',
|
||||
object: 'notification'
|
||||
}, [
|
||||
'Editor'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Add notifications',
|
||||
action: 'add',
|
||||
object: 'notification'
|
||||
}, [
|
||||
'Editor'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete notifications',
|
||||
action: 'destroy',
|
||||
object: 'notification'
|
||||
}, [
|
||||
'Editor'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,47 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Browse Members',
|
||||
action: 'browse',
|
||||
object: 'member'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Read Members',
|
||||
action: 'read',
|
||||
object: 'member'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Edit Members',
|
||||
action: 'edit',
|
||||
object: 'member'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Add Members',
|
||||
action: 'add',
|
||||
object: 'member'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete Members',
|
||||
action: 'destroy',
|
||||
object: 'member'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,83 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const merge = require('lodash/merge');
|
||||
const models = require('../../../../models');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
|
||||
const _private = {};
|
||||
|
||||
_private.printResult = function printResult(result, message) {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
} else {
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
}
|
||||
};
|
||||
|
||||
_private.addApiKeyRole = (options) => {
|
||||
const message = 'Adding "DB Backup Integration" role to roles table';
|
||||
const apiKeyRole = fixtureManager.findModelFixtureEntry('Role', {name: 'DB Backup Integration'});
|
||||
|
||||
return models.Role.findOne({name: apiKeyRole.name}, options)
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
return fixtureManager.addFixturesForModel({
|
||||
name: 'Role',
|
||||
entries: [apiKeyRole]
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
});
|
||||
};
|
||||
|
||||
_private.addApiKeyPermissions = (options) => {
|
||||
const message = 'Adding permissions for the "DB Backup Integration" role';
|
||||
const relations = fixtureManager.findRelationFixture('Role', 'Permission');
|
||||
|
||||
return fixtureManager.addFixturesForRelation({
|
||||
from: relations.from,
|
||||
to: relations.to,
|
||||
entries: {
|
||||
'DB Backup Integration': relations.entries['DB Backup Integration']
|
||||
}
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
};
|
||||
|
||||
_private.removeApiKeyPermissionsAndRole = (options) => {
|
||||
const message = 'Rollback: Removing "DB Backup Integration" role and permissions';
|
||||
|
||||
return models.Role.findOne({name: 'DB Backup Integration'}, options)
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
logging.warn(message);
|
||||
return;
|
||||
}
|
||||
|
||||
return role.destroy(options).then(() => {
|
||||
logging.info(message);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.addApiKeyRole(localOptions)
|
||||
.then(() => _private.addApiKeyPermissions(localOptions));
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.removeApiKeyPermissionsAndRole(localOptions);
|
||||
};
|
||||
|
|
@ -1,69 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const merge = require('lodash/merge');
|
||||
const models = require('../../../../models');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
|
||||
const _private = {};
|
||||
|
||||
_private.printResult = function printResult(result, message) {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
} else {
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
}
|
||||
};
|
||||
|
||||
_private.addGhostBackupIntegration = (options) => {
|
||||
const message = 'Adding "Ghost Backup DB" integration';
|
||||
const fixtureIntegration = fixtureManager.findModelFixtureEntry('Integration', {slug: 'ghost-backup'});
|
||||
|
||||
return models.Integration.findOne({slug: fixtureIntegration.slug}, options)
|
||||
.then((integration) => {
|
||||
if (!integration) {
|
||||
return fixtureManager.addFixturesForModel({
|
||||
name: 'Integration',
|
||||
entries: [fixtureIntegration]
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
});
|
||||
};
|
||||
|
||||
_private.removeGhostBackupIntegration = (options) => {
|
||||
const message = 'Rollback: Removing "Ghost Backup DB" integration';
|
||||
|
||||
return models.Integration.findOne({slug: 'ghost-backup'}, options)
|
||||
.then((integration) => {
|
||||
if (!integration) {
|
||||
logging.warn(message);
|
||||
return;
|
||||
}
|
||||
|
||||
return integration.destroy(options).then(() => {
|
||||
logging.info(message);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.addGhostBackupIntegration(localOptions);
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.removeGhostBackupIntegration(localOptions);
|
||||
};
|
||||
|
|
@ -1,100 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const config = require('../../../../../shared/config');
|
||||
const {URL} = require('url');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
// We've been incorrectly saving canonical_url fields without a subdirectory.
|
||||
// We need this column to be consistent with all other relative URLs, so...
|
||||
|
||||
// if we have a configured url with a subdirectory
|
||||
// find all posts that have a canonical_url starting with / but not //
|
||||
// prefix the subdirectory to the canonical_url and save the post
|
||||
module.exports.up = (options) => {
|
||||
// normalize config url to always have a trailing-slash
|
||||
let configUrl = config.get('url');
|
||||
if (!configUrl.endsWith('/')) {
|
||||
configUrl = `${configUrl}/`;
|
||||
}
|
||||
const url = new URL(configUrl);
|
||||
|
||||
const localOptions = Object.assign({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
if (url.pathname === '/') {
|
||||
logging.info('Skipping posts.canonical_url subdirectory fix: no subdirectory configured');
|
||||
return Promise.resolve();
|
||||
}
|
||||
|
||||
// perform a specific query for the type of canonical URLs we're looking for
|
||||
// so we're not fetching and manually looping over a ton of post models
|
||||
return localOptions
|
||||
.transacting('posts')
|
||||
.where('canonical_url', 'like', '/%')
|
||||
.whereNot('canonical_url', 'like', '//%')
|
||||
.select().then((posts) => {
|
||||
if (posts) {
|
||||
return Promise.mapSeries(posts, (post) => {
|
||||
const canonicalUrl = post.canonical_url.replace('/', url.pathname);
|
||||
return localOptions
|
||||
.transacting('posts')
|
||||
.where('id', '=', post.id)
|
||||
.update({
|
||||
canonical_url: canonicalUrl
|
||||
});
|
||||
}).then(() => {
|
||||
logging.info(`Added subdirectory prefix to canonical_url in ${posts.length} posts`);
|
||||
});
|
||||
}
|
||||
|
||||
logging.info('Skipping posts.canonical_url subdirectory fix: no canonical_urls to fix');
|
||||
return Promise.resolve();
|
||||
});
|
||||
};
|
||||
|
||||
// if we have a configured url with a subdirectory
|
||||
// find all posts with a canonical_url starting with the subdirectory
|
||||
// remove it and save the post
|
||||
module.exports.down = (options) => {
|
||||
// normalize config url to always have a trailing-slash
|
||||
let configUrl = config.get('url');
|
||||
if (!configUrl.endsWith('/')) {
|
||||
configUrl = `${configUrl}/`;
|
||||
}
|
||||
const url = new URL(configUrl);
|
||||
|
||||
const localOptions = Object.assign({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
|
||||
if (url.pathname === '/') {
|
||||
logging.info('Skipping posts.canonical_url subdirectory fix: no subdirectory configured');
|
||||
return Promise.resolve();
|
||||
}
|
||||
|
||||
return localOptions
|
||||
.transacting('posts')
|
||||
.where('canonical_url', 'like', `${url.pathname}%`)
|
||||
.select().then((posts) => {
|
||||
if (posts) {
|
||||
return Promise.mapSeries(posts, (post) => {
|
||||
const canonicalUrl = post.canonical_url.replace(url.pathname, '/');
|
||||
return localOptions
|
||||
.transacting('posts')
|
||||
.where('id', '=', post.id)
|
||||
.update({
|
||||
canonical_url: canonicalUrl
|
||||
});
|
||||
}).then(() => {
|
||||
logging.info(`Removed subdirectory prefix from canonical_url in ${posts.length} posts`);
|
||||
});
|
||||
}
|
||||
|
||||
logging.info('Skipping posts.canonical_url subdirectory fix: no canonical_urls to fix');
|
||||
return Promise.resolve();
|
||||
});
|
||||
};
|
||||
|
|
@ -1,9 +0,0 @@
|
|||
const {
|
||||
addPermission
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = addPermission({
|
||||
name: 'Backup database',
|
||||
action: 'backupContent',
|
||||
object: 'db'
|
||||
});
|
||||
|
|
@ -1,15 +0,0 @@
|
|||
const {
|
||||
addPermissionToRole,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionToRole({
|
||||
permission: 'Backup database',
|
||||
role: 'Administrator'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Backup database',
|
||||
role: 'DB Backup Integration'
|
||||
})
|
||||
);
|
||||
|
|
@ -1,84 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const merge = require('lodash/merge');
|
||||
const models = require('../../../../models');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
|
||||
const resource = 'post';
|
||||
const _private = {};
|
||||
|
||||
_private.printResult = function printResult(result, message) {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
} else {
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
}
|
||||
};
|
||||
|
||||
_private.addSchedulerRole = (options) => {
|
||||
const message = 'Adding "Scheduler Integration" role to roles table';
|
||||
const apiKeyRole = fixtureManager.findModelFixtureEntry('Role', {name: 'Scheduler Integration'});
|
||||
|
||||
return models.Role.findOne({name: apiKeyRole.name}, options)
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
return fixtureManager.addFixturesForModel({
|
||||
name: 'Role',
|
||||
entries: [apiKeyRole]
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
});
|
||||
};
|
||||
|
||||
_private.addPublishPermission = (options) => {
|
||||
const modelToAdd = fixtureManager.findModelFixtures('Permission', {object_type: resource, action_type: 'publish'});
|
||||
|
||||
return fixtureManager.addFixturesForModel(modelToAdd, options)
|
||||
.then(result => _private.printResult(result, `Adding "publish" permissions fixtures for ${resource}s`));
|
||||
};
|
||||
|
||||
_private.removeApiKeyPermissionsAndRole = (options) => {
|
||||
const message = 'Rollback: Removing "Scheduler Integration" role and permissions';
|
||||
|
||||
const modelToRemove = fixtureManager.findModelFixtures('Permission', {object_type: resource, action_type: 'publish'});
|
||||
|
||||
// permission model automatically cleans up permissions_roles on .destroy()
|
||||
return fixtureManager.removeFixturesForModel(modelToRemove, options)
|
||||
.then(result => _private.printResult(result, `Removing "publish" permissions fixtures for ${resource}s`))
|
||||
.then(() => models.Role.findOne({name: 'Scheduler Integration'}, options))
|
||||
.then((role) => {
|
||||
if (!role) {
|
||||
logging.warn(message);
|
||||
return;
|
||||
}
|
||||
|
||||
return role.destroy(options);
|
||||
})
|
||||
.then(() => {
|
||||
logging.info(message);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.addSchedulerRole(localOptions)
|
||||
.then(() => _private.addPublishPermission(localOptions));
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.removeApiKeyPermissionsAndRole(localOptions);
|
||||
};
|
||||
|
|
@ -1,69 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const merge = require('lodash/merge');
|
||||
const models = require('../../../../models');
|
||||
const {fixtureManager} = require('../../../schema/fixtures');
|
||||
|
||||
const _private = {};
|
||||
|
||||
_private.printResult = function printResult(result, message) {
|
||||
if (result.done === result.expected) {
|
||||
logging.info(message);
|
||||
} else {
|
||||
logging.warn(`(${result.done}/${result.expected}) ${message}`);
|
||||
}
|
||||
};
|
||||
|
||||
_private.addGhostSchedulerIntegration = (options) => {
|
||||
const message = 'Adding "Ghost Scheduler" integration';
|
||||
const fixtureIntegration = fixtureManager.findModelFixtureEntry('Integration', {slug: 'ghost-scheduler'});
|
||||
|
||||
return models.Integration.findOne({slug: fixtureIntegration.slug}, options)
|
||||
.then((integration) => {
|
||||
if (!integration) {
|
||||
return fixtureManager.addFixturesForModel({
|
||||
name: 'Integration',
|
||||
entries: [fixtureIntegration]
|
||||
}, options).then(result => _private.printResult(result, message));
|
||||
}
|
||||
|
||||
logging.warn(message);
|
||||
});
|
||||
};
|
||||
|
||||
_private.removeGhostSchedulerIntegration = (options) => {
|
||||
const message = 'Rollback: Removing "Ghost Scheduler" integration';
|
||||
|
||||
return models.Integration.findOne({slug: 'ghost-scheduler'}, options)
|
||||
.then((integration) => {
|
||||
if (!integration) {
|
||||
logging.warn(message);
|
||||
return;
|
||||
}
|
||||
|
||||
return integration.destroy(options).then(() => {
|
||||
logging.info(message);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.addGhostSchedulerIntegration(localOptions);
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const localOptions = merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
return _private.removeGhostSchedulerIntegration(localOptions);
|
||||
};
|
||||
|
|
@ -1,23 +0,0 @@
|
|||
const {
|
||||
addPermissionToRole,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionToRole({
|
||||
permission: 'Publish posts',
|
||||
role: 'Administrator'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Publish posts',
|
||||
role: 'Admin Integration'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Publish posts',
|
||||
role: 'Editor'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Publish posts',
|
||||
role: 'Scheduler Integration'
|
||||
})
|
||||
);
|
||||
|
|
@ -1,6 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
|
||||
// adding/removing columns is too slow for a minor release
|
||||
// noop'd, will be re-introduced in Ghost 3.0
|
||||
module.exports.up = () => Promise.resolve();
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
|
@ -1,6 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
|
||||
// adding/removing columns is too slow for a minor release
|
||||
// noop'd, will be re-introduced in Ghost 3.0
|
||||
module.exports.up = () => Promise.resolve();
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
|
@ -1,6 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
|
||||
// adding/removing columns is too slow for a minor release
|
||||
// noop'd, will be re-introduced in Ghost 3.0
|
||||
module.exports.up = () => Promise.resolve();
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
const {createNonTransactionalMigration} = require('../../utils');
|
||||
const commands = require('../../../schema/commands');
|
||||
|
||||
module.exports = createNonTransactionalMigration(
|
||||
commands.createColumnMigration({
|
||||
table: 'posts',
|
||||
column: 'page',
|
||||
dbIsInCorrectState(columnExists) {
|
||||
return columnExists === true;
|
||||
},
|
||||
operation: commands.addColumn,
|
||||
operationVerb: 'Adding',
|
||||
columnDefinition: {
|
||||
type: 'bool',
|
||||
nullable: false,
|
||||
defaultTo: false
|
||||
}
|
||||
}),
|
||||
() => Promise.resolve()
|
||||
);
|
||||
|
|
@ -1,98 +0,0 @@
|
|||
const toPairs = require('lodash/toPairs');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
/*
|
||||
* @param from: object with a SINGLE entry { 'fromColumn': 'fromValue' }
|
||||
* @param to: object with a SINGLE entry { 'toColumn': 'toValue' }
|
||||
*/
|
||||
const createColumnToColumnMap = ({from, to, tableName}) => (connection) => {
|
||||
return connection.schema.hasTable(tableName)
|
||||
.then((tableExists) => {
|
||||
if (!tableExists) {
|
||||
logging.warn(
|
||||
`Table ${tableName} does not exist`
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
const [fromColumn, fromValue] = toPairs(from)[0];
|
||||
const [toColumn, toValue] = toPairs(to)[0];
|
||||
|
||||
return Promise.all([
|
||||
connection.schema.hasColumn(tableName, fromColumn),
|
||||
connection.schema.hasColumn(tableName, toColumn)
|
||||
]).then(([fromColumnExists, toColumnExists]) => {
|
||||
if (!fromColumnExists) {
|
||||
logging.warn(
|
||||
`Table '${tableName}' does not have column '${fromColumn}'`
|
||||
);
|
||||
}
|
||||
if (!toColumnExists) {
|
||||
logging.warn(
|
||||
`Table '${tableName}' does not have column '${toColumn}'`
|
||||
);
|
||||
}
|
||||
if (!fromColumnExists || !toColumnExists) {
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info(
|
||||
`Updating ${tableName}, setting "${toColumn}" column to "${toValue}" where "${fromColumn}" column is "${fromValue}"`
|
||||
);
|
||||
|
||||
return connection(tableName)
|
||||
.where(fromColumn, fromValue)
|
||||
.update(toColumn, toValue);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
const createColumnToColumnMigration = ({tableName, from, to}) => {
|
||||
return {
|
||||
up: createColumnToColumnMap({from, to, tableName}),
|
||||
down: createColumnToColumnMap({from: to, to: from, tableName})
|
||||
};
|
||||
};
|
||||
|
||||
const typeColumnToPageTrue = createColumnToColumnMigration({
|
||||
tableName: 'posts',
|
||||
from: {
|
||||
type: 'page'
|
||||
},
|
||||
to: {
|
||||
page: true
|
||||
}
|
||||
});
|
||||
|
||||
const typeColumnToPageFalse = createColumnToColumnMigration({
|
||||
tableName: 'posts',
|
||||
from: {
|
||||
type: 'post'
|
||||
},
|
||||
to: {
|
||||
page: false
|
||||
}
|
||||
});
|
||||
|
||||
module.exports.up = ({transacting}) => {
|
||||
return transacting.schema.hasColumn('posts', 'type').then((hasTypeColumn) => {
|
||||
if (!hasTypeColumn) {
|
||||
// no-op'd post.page->post.type migrations were never run
|
||||
return Promise.resolve();
|
||||
}
|
||||
|
||||
return Promise.all([
|
||||
typeColumnToPageTrue.up(transacting),
|
||||
typeColumnToPageFalse.up(transacting)
|
||||
]);
|
||||
});
|
||||
};
|
||||
|
||||
// `up` only runs in order to fix a previous migration so we don't want to do
|
||||
// anything in `down` because it would put previously-fine sites into the wrong
|
||||
// state
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,15 +0,0 @@
|
|||
const {createNonTransactionalMigration} = require('../../utils');
|
||||
const commands = require('../../../schema/commands');
|
||||
|
||||
module.exports = createNonTransactionalMigration(
|
||||
commands.createColumnMigration({
|
||||
table: 'posts',
|
||||
column: 'type',
|
||||
dbIsInCorrectState(columnExists) {
|
||||
return columnExists === false;
|
||||
},
|
||||
operation: commands.dropColumn,
|
||||
operationVerb: 'Removing'
|
||||
}),
|
||||
() => Promise.resolve()
|
||||
);
|
||||
|
|
@ -1,45 +0,0 @@
|
|||
const {createAddColumnMigration, combineNonTransactionalMigrations} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createAddColumnMigration('webhooks', 'name', {
|
||||
type: 'string',
|
||||
maxlength: 191,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'secret', {
|
||||
type: 'string',
|
||||
maxlength: 191,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'api_version', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: false,
|
||||
defaultTo: 'v2'
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'integration_id', {
|
||||
type: 'string',
|
||||
maxlength: 24,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'status', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: false,
|
||||
defaultTo: 'available'
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'last_triggered_at', {
|
||||
type: 'dateTime',
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'last_triggered_status', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: true
|
||||
}),
|
||||
createAddColumnMigration('webhooks', 'last_triggered_error', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: true
|
||||
})
|
||||
);
|
||||
|
|
@ -1,9 +0,0 @@
|
|||
const {
|
||||
addPermission
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = addPermission({
|
||||
name: 'Edit webhooks',
|
||||
action: 'edit',
|
||||
object: 'webhook'
|
||||
});
|
||||
|
|
@ -1,15 +0,0 @@
|
|||
const {combineNonTransactionalMigrations, createDropColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createDropColumnMigration('members', 'password', {
|
||||
type: 'string',
|
||||
maxlength: 60,
|
||||
nullable: true
|
||||
}),
|
||||
createDropColumnMigration('members', 'name', {
|
||||
type: 'string',
|
||||
maxlength: 191,
|
||||
nullable: false,
|
||||
defaultTo: ''
|
||||
})
|
||||
);
|
||||
|
|
@ -1,4 +0,0 @@
|
|||
module.exports = {
|
||||
async up(){},
|
||||
async down(){}
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members', 'name', {
|
||||
type: 'string',
|
||||
maxlength: 191,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,37 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const commands = require('../../../schema/commands');
|
||||
|
||||
module.exports = {
|
||||
config: {
|
||||
transaction: true
|
||||
},
|
||||
|
||||
async up(options){
|
||||
const conn = options.transacting || options.connection;
|
||||
const hasTable = await conn.schema.hasTable('members_stripe_customers');
|
||||
|
||||
if (hasTable) {
|
||||
logging.info('Dropping table: members_stripe_customers');
|
||||
await commands.deleteTable('members_stripe_customers', conn);
|
||||
} else {
|
||||
logging.warn('Dropping table: members_stripe_customers');
|
||||
}
|
||||
|
||||
logging.info('Adding table: members_stripe_customers');
|
||||
return commands.createTable('members_stripe_customers', conn);
|
||||
},
|
||||
|
||||
async down(options){
|
||||
const conn = options.transacting || options.connection;
|
||||
const hasTable = await conn.schema.hasTable('members_stripe_customers');
|
||||
|
||||
if (!hasTable) {
|
||||
logging.warn('Dropping table: members_stripe_customers');
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info('Dropping table: members_stripe_customers');
|
||||
return commands.deleteTable('members_stripe_customers', conn);
|
||||
}
|
||||
};
|
||||
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('members_stripe_customers_subscriptions');
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members_stripe_customers', 'email', {
|
||||
type: 'string',
|
||||
maxlength: 191,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members_stripe_customers', 'name', {
|
||||
type: 'string',
|
||||
maxlength: 191,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members', 'note', {
|
||||
type: 'string',
|
||||
maxlength: 2000,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,67 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
const settingsKey = 'members_subscription_settings';
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.then((response) => {
|
||||
if (!response) {
|
||||
logging.warn('Cannot find settings.');
|
||||
return;
|
||||
}
|
||||
let subscriptionSettingsEntry = response.find((entry) => {
|
||||
return entry.key === settingsKey;
|
||||
});
|
||||
|
||||
if (!subscriptionSettingsEntry) {
|
||||
logging.warn('Cannot find members subscription settings.');
|
||||
return;
|
||||
}
|
||||
let subscriptionSettings = JSON.parse(subscriptionSettingsEntry.value);
|
||||
|
||||
let hasRequirePaymentProperty = Object.prototype.hasOwnProperty.call(subscriptionSettings, 'requirePaymentForSignup');
|
||||
let hasSelfSignupProperty = Object.prototype.hasOwnProperty.call(subscriptionSettings, 'allowSelfSignup');
|
||||
let hasFromAddressProperty = Object.prototype.hasOwnProperty.call(subscriptionSettings, 'fromAddress');
|
||||
|
||||
if (!hasFromAddressProperty) {
|
||||
subscriptionSettings.fromAddress = 'noreply';
|
||||
}
|
||||
|
||||
if (!hasRequirePaymentProperty && !hasSelfSignupProperty) {
|
||||
subscriptionSettings.allowSelfSignup = true;
|
||||
}
|
||||
|
||||
if (hasRequirePaymentProperty) {
|
||||
if (!hasSelfSignupProperty) {
|
||||
logging.info(`Adding allowSelfSignup property from requirePaymentForSignup in member settings`);
|
||||
subscriptionSettings.allowSelfSignup = !subscriptionSettings.requirePaymentForSignup;
|
||||
}
|
||||
logging.info(`Removing requirePaymentForSignup property in member settings`);
|
||||
delete subscriptionSettings.requirePaymentForSignup;
|
||||
}
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.update({
|
||||
value: JSON.stringify(subscriptionSettings)
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
// `up` only runs in order to normalize member subscription settings which was added
|
||||
// no need for down migration as its non-breaking up migration for future versions only
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,31 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles,
|
||||
combineTransactionalMigrations
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Add webhooks',
|
||||
action: 'add',
|
||||
object: 'webhook'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Edit webhooks',
|
||||
action: 'edit',
|
||||
object: 'webhook'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Delete webhooks',
|
||||
action: 'destroy',
|
||||
object: 'webhook'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('members');
|
||||
|
|
@ -1,14 +0,0 @@
|
|||
const {combineNonTransactionalMigrations, createDropColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createDropColumnMigration('users', 'ghost_auth_access_token', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 32
|
||||
}),
|
||||
createDropColumnMigration('users', 'ghost_auth_id', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 24
|
||||
})
|
||||
);
|
||||
|
|
@ -1,31 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const commands = require('../../../schema').commands;
|
||||
|
||||
const tables = [
|
||||
'accesstokens',
|
||||
'refreshtokens'
|
||||
];
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const connection = options.connection;
|
||||
|
||||
return Promise.each(tables, function (table) {
|
||||
return connection.schema.hasTable(table)
|
||||
.then(function (exists) {
|
||||
if (!exists) {
|
||||
logging.warn(`Dropping table: ${table}`);
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info(`Dropping table: ${table}`);
|
||||
return commands.deleteTable(table, connection);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
// the schemas for the deleted tables no longer exist so there's nothing for
|
||||
// `commands.createTable` to draw from for the table structure
|
||||
module.exports.down = () => {
|
||||
return Promise.resolve();
|
||||
};
|
||||
|
|
@ -1,35 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const commands = require('../../../schema').commands;
|
||||
|
||||
const tables = [
|
||||
'client_trusted_domains', // first due to foreign key constraint on client_id
|
||||
'clients'
|
||||
];
|
||||
|
||||
module.exports.config = {
|
||||
irreversible: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const connection = options.connection;
|
||||
|
||||
return Promise.each(tables, function (table) {
|
||||
return connection.schema.hasTable(table)
|
||||
.then(function (exists) {
|
||||
if (!exists) {
|
||||
logging.warn(`Dropping table: ${table}`);
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info(`Dropping table: ${table}`);
|
||||
return commands.deleteTable(table, connection);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
// the schemas for the deleted tables no longer exist so there's nothing for
|
||||
// `commands.createTable` to draw from for the table structure
|
||||
module.exports.down = () => {
|
||||
return Promise.reject();
|
||||
};
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('posts_meta');
|
||||
|
|
@ -1,83 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const postsMetaSchema = require('../../../schema').tables.posts_meta;
|
||||
const ObjectId = require('bson-objectid');
|
||||
const _ = require('lodash');
|
||||
const models = require('../../../../models');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = _.merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
const metaAttrs = _.keys(postsMetaSchema);
|
||||
|
||||
return models.Posts
|
||||
.forge()
|
||||
.query((qb) => {
|
||||
// We only want to add entries in new table for posts which have any metadata
|
||||
qb.whereNotNull('meta_title');
|
||||
qb.orWhereNotNull('meta_description');
|
||||
qb.orWhereNotNull('twitter_title');
|
||||
qb.orWhereNotNull('twitter_description');
|
||||
qb.orWhereNotNull('twitter_image');
|
||||
qb.orWhereNotNull('og_description');
|
||||
qb.orWhereNotNull('og_title');
|
||||
qb.orWhereNotNull('og_image');
|
||||
})
|
||||
.fetch(localOptions)
|
||||
.then(({models: posts}) => {
|
||||
if (posts.length > 0) {
|
||||
logging.info(`Adding ${posts.length} entries to posts_meta`);
|
||||
let postsMetaEntries = _.map(posts, (post) => {
|
||||
let postsMetaEntry = metaAttrs.reduce(function (obj, entry) {
|
||||
return Object.assign(obj, {
|
||||
[entry]: post.get(entry) || null
|
||||
});
|
||||
}, {});
|
||||
postsMetaEntry.post_id = post.get('id');
|
||||
postsMetaEntry.id = ObjectId().toHexString();
|
||||
return postsMetaEntry;
|
||||
});
|
||||
|
||||
// NOTE: iterative method is needed to prevent from `SQLITE_ERROR: too many variables` error
|
||||
return Promise.map(postsMetaEntries, (postsMeta) => {
|
||||
return localOptions.transacting('posts_meta').insert(postsMeta);
|
||||
});
|
||||
} else {
|
||||
logging.info('Skipping populating posts_meta table: found 0 posts with metadata');
|
||||
return Promise.resolve();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = function (options) {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
const metaAttrs = _.keys(_.omit(postsMetaSchema, ['id', 'post_id']));
|
||||
|
||||
return models.PostsMeta
|
||||
.findAll(localOptions)
|
||||
.then(({models: postsMeta}) => {
|
||||
if (postsMeta.length > 0) {
|
||||
logging.info(`Adding metadata for ${postsMeta.length} posts from posts_meta table`);
|
||||
return Promise.map(postsMeta, (meta) => {
|
||||
let data = metaAttrs.reduce(function (obj, entry) {
|
||||
return Object.assign(obj, {
|
||||
[entry]: meta.get(entry)
|
||||
});
|
||||
}, {});
|
||||
return localOptions.transacting('posts').where({id: meta.get('post_id')}).update(data);
|
||||
});
|
||||
} else {
|
||||
logging.info('Skipping populating meta fields from posts_meta: found 0 entries');
|
||||
return Promise.resolve();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
|
@ -1,44 +0,0 @@
|
|||
const {combineNonTransactionalMigrations, createDropColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createDropColumnMigration('posts', 'meta_title', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 2000
|
||||
}),
|
||||
createDropColumnMigration('posts', 'meta_description', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 2000
|
||||
}),
|
||||
createDropColumnMigration('posts', 'og_image', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 2000
|
||||
}),
|
||||
createDropColumnMigration('posts', 'og_title', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 300
|
||||
}),
|
||||
createDropColumnMigration('posts', 'og_description', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 500
|
||||
}),
|
||||
createDropColumnMigration('posts', 'twitter_image', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 2000
|
||||
}),
|
||||
createDropColumnMigration('posts', 'twitter_title', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 300
|
||||
}),
|
||||
createDropColumnMigration('posts', 'twitter_description', {
|
||||
type: 'string',
|
||||
nullable: true,
|
||||
maxlength: 500
|
||||
})
|
||||
);
|
||||
|
|
@ -1,8 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('posts', 'type', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: false,
|
||||
defaultTo: 'post'
|
||||
});
|
||||
|
|
@ -1,94 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const toPairs = require('lodash/toPairs');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
/*
|
||||
* @param from: object with a SINGLE entry { 'fromColumn': 'fromValue' }
|
||||
* @param to: object with a SINGLE entry { 'toColumn': 'toValue' }
|
||||
*/
|
||||
const createColumnToColumnMap = ({from, to, tableName}) => (connection) => {
|
||||
return connection.schema.hasTable(tableName)
|
||||
.then((tableExists) => {
|
||||
if (!tableExists) {
|
||||
logging.warn(
|
||||
`Table ${tableName} does not exist`
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
const [fromColumn, fromValue] = toPairs(from)[0];
|
||||
const [toColumn, toValue] = toPairs(to)[0];
|
||||
|
||||
return Promise.all([
|
||||
connection.schema.hasColumn(tableName, fromColumn),
|
||||
connection.schema.hasColumn(tableName, toColumn)
|
||||
]).then(([fromColumnExists, toColumnExists]) => {
|
||||
if (!fromColumnExists) {
|
||||
logging.warn(
|
||||
`Table '${tableName}' does not have column '${fromColumn}'`
|
||||
);
|
||||
}
|
||||
if (!toColumnExists) {
|
||||
logging.warn(
|
||||
`Table '${tableName}' does not have column '${toColumn}'`
|
||||
);
|
||||
}
|
||||
if (!fromColumnExists || !toColumnExists) {
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info(
|
||||
`Updating ${tableName}, setting "${toColumn}" column to "${toValue}" where "${fromColumn}" column is "${fromValue}"`
|
||||
);
|
||||
|
||||
return connection(tableName)
|
||||
.where(fromColumn, fromValue)
|
||||
.update(toColumn, toValue);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
const createColumnToColumnMigration = ({tableName, from, to}) => {
|
||||
return {
|
||||
up: createColumnToColumnMap({from, to, tableName}),
|
||||
down: createColumnToColumnMap({from: to, to: from, tableName})
|
||||
};
|
||||
};
|
||||
|
||||
const pageColumnToPageType = createColumnToColumnMigration({
|
||||
tableName: 'posts',
|
||||
from: {
|
||||
page: true
|
||||
},
|
||||
to: {
|
||||
type: 'page'
|
||||
}
|
||||
});
|
||||
|
||||
const pageColumnToPostType = createColumnToColumnMigration({
|
||||
tableName: 'posts',
|
||||
from: {
|
||||
page: false
|
||||
},
|
||||
to: {
|
||||
type: 'post'
|
||||
}
|
||||
});
|
||||
|
||||
module.exports.up = ({transacting}) => {
|
||||
return Promise.all([
|
||||
pageColumnToPageType.up(transacting),
|
||||
pageColumnToPostType.up(transacting)
|
||||
]);
|
||||
};
|
||||
|
||||
module.exports.down = ({transacting}) => {
|
||||
return Promise.all([
|
||||
pageColumnToPageType.down(transacting),
|
||||
pageColumnToPostType.down(transacting)
|
||||
]);
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createDropColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createDropColumnMigration('posts', 'page', {
|
||||
type: 'bool',
|
||||
nullable: false,
|
||||
defaultTo: false
|
||||
});
|
||||
|
|
@ -1,81 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const schema = require('../../../schema');
|
||||
|
||||
/*
|
||||
* [{
|
||||
* tableName: 'posts',
|
||||
* columns: ['custom_excerpt', 'description', 'etc...']
|
||||
* }]
|
||||
* */
|
||||
const tablesToUpdate = Object.keys(schema.tables).reduce((tables, tableName) => {
|
||||
const table = schema.tables[tableName];
|
||||
const columns = Object.keys(table).filter((columnName) => {
|
||||
const column = table[columnName];
|
||||
return column.nullable && ['string', 'text'].includes(column.type);
|
||||
});
|
||||
if (!columns.length) {
|
||||
return tables;
|
||||
}
|
||||
return tables.concat({
|
||||
tableName,
|
||||
columns
|
||||
});
|
||||
}, []);
|
||||
|
||||
const createReplace = (connection, from, to) => (tableName, columnName) => {
|
||||
return connection.schema.hasTable(tableName)
|
||||
.then((tableExists) => {
|
||||
if (!tableExists) {
|
||||
logging.warn(
|
||||
`Table ${tableName} does not exist`
|
||||
);
|
||||
return;
|
||||
}
|
||||
return connection.schema.hasColumn(tableName, columnName)
|
||||
.then((columnExists) => {
|
||||
if (!columnExists) {
|
||||
logging.warn(
|
||||
`Table '${tableName}' does not have column '${columnName}'`
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info(
|
||||
`Updating ${tableName}, setting '${from}' in ${columnName} to '${to}'`
|
||||
);
|
||||
|
||||
return connection(tableName)
|
||||
.where(columnName, from)
|
||||
.update(columnName, to);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.up = ({transacting}) => {
|
||||
const replaceEmptyStringWithNull = createReplace(transacting, '', null);
|
||||
|
||||
return Promise.all(
|
||||
tablesToUpdate.map(({tableName, columns}) => Promise.all(
|
||||
columns.map(
|
||||
columnName => replaceEmptyStringWithNull(tableName, columnName)
|
||||
)
|
||||
))
|
||||
);
|
||||
};
|
||||
|
||||
module.exports.down = ({transacting}) => {
|
||||
const replaceNullWithEmptyString = createReplace(transacting, null, '');
|
||||
|
||||
return Promise.all(
|
||||
tablesToUpdate.map(({tableName, columns}) => Promise.all(
|
||||
columns.map(
|
||||
columnName => replaceNullWithEmptyString(tableName, columnName)
|
||||
)
|
||||
))
|
||||
);
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
module.exports.up = () => {
|
||||
// noop - superceded by later majors performing re-render
|
||||
};
|
||||
|
||||
module.exports.down = () => {
|
||||
// noop - superceded by later majors performing re-render
|
||||
};
|
||||
|
|
@ -1,54 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const ObjectId = require('bson-objectid');
|
||||
const _ = require('lodash');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true,
|
||||
irreversible: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const localOptions = _.merge({
|
||||
context: {internal: true},
|
||||
migrating: true
|
||||
}, options);
|
||||
|
||||
const memberAttrs = [
|
||||
'name',
|
||||
'email',
|
||||
'created_at',
|
||||
'created_by',
|
||||
'updated_at',
|
||||
'updated_by'
|
||||
];
|
||||
|
||||
return localOptions.transacting('subscribers').select()
|
||||
.then((subscribers) => {
|
||||
if (subscribers && subscribers.length > 0) {
|
||||
logging.info(`Adding ${subscribers.length} entries to members`);
|
||||
|
||||
let members = _.map(subscribers, (subscriber) => {
|
||||
let member = memberAttrs.reduce(function (obj, prop) {
|
||||
return Object.assign(obj, {
|
||||
[prop]: subscriber[prop]
|
||||
});
|
||||
}, {});
|
||||
member.id = ObjectId().toHexString();
|
||||
|
||||
return member;
|
||||
});
|
||||
|
||||
return Promise.map(members, (member) => {
|
||||
return localOptions.transacting('members').insert(member);
|
||||
});
|
||||
} else {
|
||||
logging.info('Skipping populating members table: found 0 subscribers');
|
||||
return Promise.resolve();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = () => {
|
||||
return Promise.reject();
|
||||
};
|
||||
|
|
@ -1,34 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const commands = require('../../../schema').commands;
|
||||
|
||||
const tables = [
|
||||
'subscribers'
|
||||
];
|
||||
|
||||
module.exports.config = {
|
||||
irreversible: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const connection = options.connection;
|
||||
|
||||
return Promise.each(tables, function (table) {
|
||||
return connection.schema.hasTable(table)
|
||||
.then(function (exists) {
|
||||
if (!exists) {
|
||||
logging.warn(`Dropping table: ${table}`);
|
||||
return;
|
||||
}
|
||||
|
||||
logging.info(`Dropping table: ${table}`);
|
||||
return commands.deleteTable(table, connection);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
// the schemas for the deleted tables no longer exist so there's nothing for
|
||||
// `commands.createTable` to draw from for the table structure
|
||||
module.exports.down = () => {
|
||||
return Promise.reject();
|
||||
};
|
||||
|
|
@ -1,24 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const {createIrreversibleMigration} = require('../../utils');
|
||||
|
||||
module.exports = createIrreversibleMigration(async (knex) => {
|
||||
let result = await knex('settings')
|
||||
.where('key', '=', 'labs')
|
||||
.select('value');
|
||||
|
||||
if (!result || !result[0]) {
|
||||
logging.warn(`Could not find labs setting`);
|
||||
result = [{}];
|
||||
}
|
||||
|
||||
const labs = JSON.parse(result[0].value);
|
||||
|
||||
labs.members = !!labs.members || !!labs.subscribers;
|
||||
|
||||
logging.info(`Updating labs setting removing subscribers (was ${labs.subscribers}) settings members to ${labs.members}`);
|
||||
labs.subscribers = undefined;
|
||||
|
||||
await knex('settings')
|
||||
.where('key', '=', 'labs')
|
||||
.update('value', JSON.stringify(labs));
|
||||
});
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('posts', 'send_email_when_published', {
|
||||
type: 'bool',
|
||||
nullable: true,
|
||||
defaultTo: false
|
||||
});
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('posts_meta', 'email_subject', {
|
||||
type: 'string',
|
||||
maxlength: 300,
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,18 +0,0 @@
|
|||
const {
|
||||
combineTransactionalMigrations,
|
||||
addPermission
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermission({
|
||||
name: 'Email preview',
|
||||
object: 'email_preview',
|
||||
action: 'read'
|
||||
}),
|
||||
|
||||
addPermission({
|
||||
name: 'Send test email',
|
||||
object: 'email_preview',
|
||||
action: 'sendTestEmail'
|
||||
})
|
||||
);
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members', 'subscribed', {
|
||||
type: 'bool',
|
||||
nullable: true,
|
||||
defaultTo: true
|
||||
});
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
const {addTable} = require('../../utils');
|
||||
module.exports = addTable('emails');
|
||||
|
|
@ -1,15 +0,0 @@
|
|||
const {
|
||||
addPermissionWithRoles
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = addPermissionWithRoles({
|
||||
name: 'Read emails',
|
||||
action: 'read',
|
||||
object: 'email'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration',
|
||||
'Editor',
|
||||
'Author',
|
||||
'Contributor'
|
||||
]);
|
||||
|
|
@ -1,8 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members', 'uuid', {
|
||||
type: 'string',
|
||||
maxlength: 36,
|
||||
nullable: true,
|
||||
unique: true
|
||||
});
|
||||
|
|
@ -1,23 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const uuid = require('uuid');
|
||||
|
||||
module.exports = {
|
||||
config: {
|
||||
transaction: true
|
||||
},
|
||||
async up(options) {
|
||||
const conn = options.connection || options.transacting;
|
||||
|
||||
const membersWithoutUUID = await conn.select('id').from('members').whereNull('uuid');
|
||||
|
||||
logging.info(`Adding uuid field value to ${membersWithoutUUID.length} members.`);
|
||||
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
for (const member of membersWithoutUUID) {
|
||||
await conn('members').update('uuid', uuid.v4()).where('id', member.id);
|
||||
}
|
||||
},
|
||||
async down() {
|
||||
// noop
|
||||
}
|
||||
};
|
||||
|
|
@ -1,25 +0,0 @@
|
|||
const {
|
||||
combineTransactionalMigrations,
|
||||
addPermissionWithRoles
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionWithRoles({
|
||||
name: 'Browse emails',
|
||||
action: 'browse',
|
||||
object: 'email'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration',
|
||||
'Editor'
|
||||
]),
|
||||
addPermissionWithRoles({
|
||||
name: 'Retry emails',
|
||||
action: 'retry',
|
||||
object: 'email'
|
||||
}, [
|
||||
'Administrator',
|
||||
'Admin Integration',
|
||||
'Editor'
|
||||
])
|
||||
);
|
||||
|
|
@ -1,8 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('emails', 'error_data', {
|
||||
type: 'text',
|
||||
maxlength: 1000000000,
|
||||
fieldtype: 'long',
|
||||
nullable: true
|
||||
});
|
||||
|
|
@ -1,68 +0,0 @@
|
|||
const _ = require('lodash');
|
||||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
const debug = require('@tryghost/debug')('migrations');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
let localOptions = _.merge({
|
||||
context: {internal: true}
|
||||
}, options);
|
||||
const settingsKey = 'members_subscription_settings';
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.then((response) => {
|
||||
if (!response) {
|
||||
logging.warn('Cannot find settings.');
|
||||
return;
|
||||
}
|
||||
|
||||
let subscriptionSettingsEntry = response.find((entry) => {
|
||||
return entry.key === settingsKey;
|
||||
});
|
||||
|
||||
if (!subscriptionSettingsEntry) {
|
||||
logging.warn('Cannot find members subscription settings.');
|
||||
return;
|
||||
}
|
||||
|
||||
let subscriptionSettings = JSON.parse(subscriptionSettingsEntry.value);
|
||||
|
||||
debug('before cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
const stripePaymentProcessor = subscriptionSettings.paymentProcessors.find(
|
||||
paymentProcessor => paymentProcessor.adapter === 'stripe'
|
||||
);
|
||||
|
||||
// Remove "broken" complimentary plans that were introduced with 3.10.0, they didn't have
|
||||
// interval property defined unlike regular plans
|
||||
if (stripePaymentProcessor && stripePaymentProcessor.config.public_token && stripePaymentProcessor.config.secret_token) {
|
||||
stripePaymentProcessor.config.plans = stripePaymentProcessor.config.plans.filter((plan) => {
|
||||
return plan.interval !== undefined;
|
||||
});
|
||||
}
|
||||
|
||||
debug('after cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
return localOptions
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.update({
|
||||
value: JSON.stringify(subscriptionSettings)
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
// `up` is only run to fix a problem that is introduced with 3.10.0,
|
||||
// it doesn't make sense to "reintroduced" broken state with down migration
|
||||
module.exports.down = () => Promise.resolve();
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {addPermission} = require('../../utils');
|
||||
|
||||
module.exports = addPermission({
|
||||
name: 'Read identities',
|
||||
action: 'read',
|
||||
object: 'identity'
|
||||
});
|
||||
|
|
@ -1,93 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const debug = require('@tryghost/debug')('migrations');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const settingsKey = 'members_subscription_settings';
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.select('value')
|
||||
.first()
|
||||
.then((subscriptionSettingsEntry) => {
|
||||
debug(subscriptionSettingsEntry);
|
||||
if (!subscriptionSettingsEntry) {
|
||||
logging.warn(`Cannot find ${settingsKey} settings.`);
|
||||
return;
|
||||
}
|
||||
|
||||
let subscriptionSettings = JSON.parse(subscriptionSettingsEntry.value);
|
||||
|
||||
debug('before cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
const hasIsPaid = Object.prototype.hasOwnProperty.call(subscriptionSettings, 'isPaid');
|
||||
|
||||
if (hasIsPaid) {
|
||||
debug('Removing legacy isPaid flag from members settings');
|
||||
delete subscriptionSettings.isPaid;
|
||||
|
||||
debug('after cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.update({
|
||||
value: JSON.stringify(subscriptionSettings)
|
||||
});
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const settingsKey = 'members_subscription_settings';
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.select('value')
|
||||
.first()
|
||||
.then((subscriptionSettingsEntry) => {
|
||||
debug(subscriptionSettingsEntry);
|
||||
if (!subscriptionSettingsEntry) {
|
||||
logging.warn(`Cannot find ${settingsKey} settings.`);
|
||||
return;
|
||||
}
|
||||
|
||||
let subscriptionSettings = JSON.parse(subscriptionSettingsEntry.value);
|
||||
|
||||
debug('before cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
let isPaid = false;
|
||||
|
||||
const stripePaymentProcessor = subscriptionSettings.paymentProcessors.find(
|
||||
paymentProcessor => paymentProcessor.adapter === 'stripe'
|
||||
);
|
||||
|
||||
if (stripePaymentProcessor && stripePaymentProcessor.config.public_token && stripePaymentProcessor.config.secret_token) {
|
||||
isPaid = true;
|
||||
}
|
||||
|
||||
subscriptionSettings.isPaid = isPaid;
|
||||
|
||||
debug('after cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.update({
|
||||
value: JSON.stringify(subscriptionSettings)
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,39 +0,0 @@
|
|||
const {
|
||||
combineTransactionalMigrations,
|
||||
addPermissionToRole
|
||||
} = require('../../utils');
|
||||
|
||||
module.exports = combineTransactionalMigrations(
|
||||
addPermissionToRole({
|
||||
permission: 'Email preview',
|
||||
role: 'Administrator'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Email preview',
|
||||
role: 'Admin Integration'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Email preview',
|
||||
role: 'Editor'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Email preview',
|
||||
role: 'Author'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Email preview',
|
||||
role: 'Contributor'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Send test email',
|
||||
role: 'Administrator'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Send test email',
|
||||
role: 'Admin Integration'
|
||||
}),
|
||||
addPermissionToRole({
|
||||
permission: 'Send test email',
|
||||
role: 'Editor'
|
||||
})
|
||||
);
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {addPermission} = require('../../utils');
|
||||
|
||||
module.exports = addPermission({
|
||||
name: 'Auth Stripe Connect for Members',
|
||||
action: 'auth',
|
||||
object: 'members_stripe_connect'
|
||||
});
|
||||
|
|
@ -1,91 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const urlUtils = require('../../../../../shared/url-utils');
|
||||
const debug = require('@tryghost/debug')('migrations');
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
||||
module.exports.up = (options) => {
|
||||
const settingsKey = 'members_subscription_settings';
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.select('value')
|
||||
.first()
|
||||
.then((subscriptionSettingsEntry) => {
|
||||
debug(subscriptionSettingsEntry);
|
||||
if (!subscriptionSettingsEntry) {
|
||||
logging.warn(`Cannot find ${settingsKey} settings.`);
|
||||
return;
|
||||
}
|
||||
|
||||
let subscriptionSettings = JSON.parse(subscriptionSettingsEntry.value);
|
||||
|
||||
debug('before cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
const hasFromAddress = Object.prototype.hasOwnProperty.call(subscriptionSettings, 'fromAddress');
|
||||
const domain = urlUtils.urlFor('home', true).match(new RegExp('^https?://([^/:?#]+)(?:[/:?#]|$)', 'i'));
|
||||
const blogDomain = domain && domain[1];
|
||||
if (hasFromAddress && blogDomain) {
|
||||
logging.info(`Updating fromAddress in members settings with domain ${blogDomain}`);
|
||||
|
||||
subscriptionSettings.fromAddress = `${subscriptionSettings.fromAddress}@${blogDomain}`;
|
||||
|
||||
debug('after cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.update({
|
||||
value: JSON.stringify(subscriptionSettings)
|
||||
});
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.down = (options) => {
|
||||
const settingsKey = 'members_subscription_settings';
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.select('value')
|
||||
.first()
|
||||
.then((subscriptionSettingsEntry) => {
|
||||
debug(subscriptionSettingsEntry);
|
||||
if (!subscriptionSettingsEntry) {
|
||||
logging.warn(`Cannot find ${settingsKey} settings.`);
|
||||
return;
|
||||
}
|
||||
|
||||
let subscriptionSettings = JSON.parse(subscriptionSettingsEntry.value);
|
||||
|
||||
debug('before cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
const hasFromAddress = Object.prototype.hasOwnProperty.call(subscriptionSettings, 'fromAddress');
|
||||
|
||||
if (hasFromAddress) {
|
||||
logging.info('Removing domain in fromAddress in members settings');
|
||||
subscriptionSettings.fromAddress = subscriptionSettings.fromAddress.split('@')[0];
|
||||
|
||||
debug('after cleanup');
|
||||
debug(JSON.stringify(subscriptionSettings, null, 2));
|
||||
|
||||
return options
|
||||
.transacting('settings')
|
||||
.where('key', settingsKey)
|
||||
.update({
|
||||
value: JSON.stringify(subscriptionSettings)
|
||||
});
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports.config = {
|
||||
transaction: true
|
||||
};
|
||||
|
|
@ -1,7 +0,0 @@
|
|||
const {createAddColumnMigration} = require('../../utils');
|
||||
|
||||
module.exports = createAddColumnMigration('members_stripe_customers_subscriptions', 'cancel_at_period_end', {
|
||||
type: 'bool',
|
||||
nullable: false,
|
||||
defaultTo: false
|
||||
});
|
||||
|
|
@ -1,65 +0,0 @@
|
|||
const ObjectId = require('bson-objectid');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
module.exports = {
|
||||
config: {
|
||||
transaction: true
|
||||
},
|
||||
|
||||
async up(options) {
|
||||
const settingsKeys = ['force_i18n', 'permalinks', 'members_session_secret'];
|
||||
|
||||
logging.info(`Removing ${settingsKeys.join(',')} from "settings" table.`);
|
||||
|
||||
return await options
|
||||
.transacting('settings')
|
||||
.whereIn('key', settingsKeys)
|
||||
.del();
|
||||
},
|
||||
|
||||
async down(options) {
|
||||
const currentTimestamp = options.transacting.raw('CURRENT_TIMESTAMP');
|
||||
|
||||
const forceI18nSetting = {
|
||||
id: ObjectId().toHexString(),
|
||||
key: 'force_i18n',
|
||||
value: 'true',
|
||||
type: 'blog',
|
||||
created_at: currentTimestamp,
|
||||
created_by: 1,
|
||||
updated_at: currentTimestamp,
|
||||
updated_by: 1
|
||||
};
|
||||
|
||||
const permalinksSetting = {
|
||||
id: ObjectId().toHexString(),
|
||||
key: 'permalinks',
|
||||
value: '/:slug/',
|
||||
type: 'blog',
|
||||
created_at: currentTimestamp,
|
||||
created_by: 1,
|
||||
updated_at: currentTimestamp,
|
||||
updated_by: 1
|
||||
};
|
||||
|
||||
const membersSessionSecretSetting = {
|
||||
id: ObjectId().toHexString(),
|
||||
key: 'members_session_secret',
|
||||
value: null,
|
||||
type: 'members',
|
||||
created_at: currentTimestamp,
|
||||
created_by: 1,
|
||||
updated_at: currentTimestamp,
|
||||
updated_by: 1
|
||||
};
|
||||
|
||||
logging.info('Adding force_i18n, permalinks, and members_session_secret to "settings" table.');
|
||||
|
||||
return options.transacting('settings')
|
||||
.insert([
|
||||
forceI18nSetting,
|
||||
permalinksSetting,
|
||||
membersSessionSecretSetting
|
||||
]);
|
||||
}
|
||||
};
|
||||
|
|
@ -1,90 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
|
||||
const renameMappings = [{
|
||||
from: 'default_locale',
|
||||
to: 'lang'
|
||||
}, {
|
||||
from: 'active_timezone',
|
||||
to: 'timezone'
|
||||
}, {
|
||||
from: 'ghost_head',
|
||||
to: 'codeinjection_head'
|
||||
}, {
|
||||
from: 'ghost_foot',
|
||||
to: 'codeinjection_foot'
|
||||
}, {
|
||||
from: 'brand',
|
||||
to: 'accent_color',
|
||||
getToValue: (fromValue) => {
|
||||
try {
|
||||
return JSON.parse(fromValue).primaryColor || '';
|
||||
} catch (err) {
|
||||
return '';
|
||||
}
|
||||
},
|
||||
getFromValue: (toValue) => {
|
||||
return JSON.stringify({
|
||||
primaryColor: toValue || ''
|
||||
});
|
||||
}
|
||||
}];
|
||||
|
||||
module.exports = {
|
||||
config: {
|
||||
transaction: true
|
||||
},
|
||||
|
||||
async up(options) {
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
for (const renameMapping of renameMappings) {
|
||||
const oldSetting = await options.transacting('settings')
|
||||
.where('key', renameMapping.from)
|
||||
.select('value')
|
||||
.first();
|
||||
|
||||
if (!oldSetting) {
|
||||
logging.warn(`Could not find setting ${renameMapping.from}, not updating ${renameMapping.to} value`);
|
||||
continue;
|
||||
}
|
||||
|
||||
const updatedValue = renameMapping.getToValue ? renameMapping.getToValue(oldSetting.value) : oldSetting.value;
|
||||
|
||||
logging.info(`Updating ${renameMapping.to} with value from ${renameMapping.from}`);
|
||||
await options.transacting('settings')
|
||||
.where('key', renameMapping.to)
|
||||
.update('value', updatedValue);
|
||||
|
||||
logging.info(`Deleting ${renameMapping.from}`);
|
||||
await options.transacting('settings')
|
||||
.where('key', renameMapping.from)
|
||||
.del();
|
||||
}
|
||||
},
|
||||
|
||||
async down(options) {
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
for (const renameMapping of renameMappings) {
|
||||
const newSetting = await options.transacting('settings')
|
||||
.where('key', renameMapping.to)
|
||||
.select('value')
|
||||
.first();
|
||||
|
||||
if (!newSetting) {
|
||||
logging.warn(`Could not find setting ${renameMapping.to}, not updating ${renameMapping.from} value`);
|
||||
continue;
|
||||
}
|
||||
|
||||
const updatedValue = renameMapping.getFromValue ? renameMapping.getFromValue(newSetting.value) : newSetting.value;
|
||||
|
||||
logging.info(`Updating ${renameMapping.from} with value from ${renameMapping.to}`);
|
||||
await options.transacting('settings')
|
||||
.where('key', renameMapping.from)
|
||||
.update('value', updatedValue);
|
||||
|
||||
logging.info(`Deleting ${renameMapping.from}`);
|
||||
await options.transacting('settings')
|
||||
.where('key', renameMapping.from)
|
||||
.del();
|
||||
}
|
||||
}
|
||||
};
|
||||
|
|
@ -1,15 +0,0 @@
|
|||
const {createAddColumnMigration, combineNonTransactionalMigrations} = require('../../utils');
|
||||
|
||||
module.exports = combineNonTransactionalMigrations(
|
||||
createAddColumnMigration('settings', 'group', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: false,
|
||||
defaultTo: 'core'
|
||||
}),
|
||||
createAddColumnMigration('settings', 'flags', {
|
||||
type: 'string',
|
||||
maxlength: 50,
|
||||
nullable: true
|
||||
})
|
||||
);
|
||||
|
|
@ -1,194 +0,0 @@
|
|||
const Promise = require('bluebird');
|
||||
const logging = require('@tryghost/logging');
|
||||
|
||||
// settings with new groups
|
||||
const typeGroupMapping = [{
|
||||
keys: [
|
||||
'members_public_key',
|
||||
'members_private_key',
|
||||
'members_email_auth_secret'
|
||||
],
|
||||
from: 'members',
|
||||
to: 'core'
|
||||
}, {
|
||||
keys: [
|
||||
'title',
|
||||
'description',
|
||||
'logo',
|
||||
'cover_image',
|
||||
'icon',
|
||||
'accent_color',
|
||||
'lang',
|
||||
'timezone',
|
||||
'codeinjection_head',
|
||||
'codeinjection_foot',
|
||||
'facebook',
|
||||
'twitter',
|
||||
'navigation',
|
||||
'secondary_navigation',
|
||||
'meta_title',
|
||||
'meta_description',
|
||||
'og_image',
|
||||
'og_title',
|
||||
'og_description',
|
||||
'twitter_image',
|
||||
'twitter_title',
|
||||
'twitter_description'
|
||||
|
||||
],
|
||||
from: 'blog',
|
||||
to: 'site'
|
||||
}, {
|
||||
keys: ['amp'],
|
||||
from: 'blog',
|
||||
to: 'amp'
|
||||
}, {
|
||||
keys: ['labs'],
|
||||
from: 'blog',
|
||||
to: 'labs'
|
||||
}, {
|
||||
keys: ['slack'],
|
||||
from: 'blog',
|
||||
to: 'slack'
|
||||
}, {
|
||||
keys: ['unsplash'],
|
||||
from: 'blog',
|
||||
to: 'unsplash'
|
||||
}, {
|
||||
keys: ['shared_views'],
|
||||
from: 'blog',
|
||||
to: 'views'
|
||||
}, {
|
||||
keys: ['bulk_email_settings'],
|
||||
from: 'bulk_email',
|
||||
to: 'email'
|
||||
}];
|
||||
|
||||
// settings with the same groups
|
||||
const groupMapping = [{
|
||||
group: 'core',
|
||||
keys: [
|
||||
'db_hash',
|
||||
'next_update_check',
|
||||
'notifications',
|
||||
'session_secret',
|
||||
'theme_session_secret',
|
||||
'ghost_public_key',
|
||||
'ghost_private_key'
|
||||
]
|
||||
}, {
|
||||
group: 'theme',
|
||||
keys: ['active_theme']
|
||||
}, {
|
||||
group: 'private',
|
||||
keys: [
|
||||
'is_private',
|
||||
'password',
|
||||
'public_hash'
|
||||
]
|
||||
}, {
|
||||
group: 'members',
|
||||
keys: [
|
||||
'default_content_visibility',
|
||||
'members_subscription_settings',
|
||||
'stripe_connect_integration'
|
||||
]
|
||||
}, {
|
||||
group: 'portal',
|
||||
keys: [
|
||||
'portal_name',
|
||||
'portal_button',
|
||||
'portal_plans'
|
||||
]
|
||||
}];
|
||||
|
||||
// flags to be added to settings
|
||||
const flagMapping = [{
|
||||
key: 'title',
|
||||
flags: 'PUBLIC'
|
||||
}, {
|
||||
key: 'description',
|
||||
flags: 'PUBLIC'
|
||||
}, {
|
||||
key: 'logo',
|
||||
flags: 'PUBLIC'
|
||||
}, {
|
||||
key: 'accent_color',
|
||||
flags: 'PUBLIC'
|
||||
}, {
|
||||
key: 'active_theme',
|
||||
flags: 'RO'
|
||||
}];
|
||||
|
||||
module.exports = {
|
||||
config: {
|
||||
transaction: true
|
||||
},
|
||||
|
||||
async up(options) {
|
||||
// set the new group for each changed setting and rename type
|
||||
await Promise.map(typeGroupMapping, async (typeGroupMap) => {
|
||||
return await Promise.map(typeGroupMap.keys, async (key) => {
|
||||
logging.info(`Moving setting ${key} from ${typeGroupMap.from} to ${typeGroupMap.to}`);
|
||||
|
||||
return await options
|
||||
.transacting('settings')
|
||||
.where('key', key)
|
||||
.update({
|
||||
group: typeGroupMap.to,
|
||||
type: typeGroupMap.to
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
// set the correct group value settings which aren't changing type
|
||||
await Promise.map(groupMapping, async (groupMap) => {
|
||||
return await Promise.map(groupMap.keys, async (key) => {
|
||||
logging.info(`Adding setting ${key} to ${groupMap.group}`);
|
||||
|
||||
return await options
|
||||
.transacting('settings')
|
||||
.where('key', key)
|
||||
.update({
|
||||
group: groupMap.group
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
return await Promise.map(flagMapping, async (flagMap) => {
|
||||
logging.info(`Adding ${flagMap.flags} flag to ${flagMap.key} setting`);
|
||||
|
||||
return await options
|
||||
.transacting('settings')
|
||||
.where('key', flagMap.key)
|
||||
.update({
|
||||
flags: flagMap.flags
|
||||
});
|
||||
});
|
||||
},
|
||||
|
||||
async down(options) {
|
||||
// clear all flags values
|
||||
logging.info('Clearing all settings flags values');
|
||||
await options
|
||||
.transacting('settings')
|
||||
.update({
|
||||
flags: null
|
||||
});
|
||||
|
||||
// put type values back but leave all group values as-is because we
|
||||
// didn't change them from anything specific in `up`
|
||||
return await Promise.map(typeGroupMapping, async (typeGroupMap) => {
|
||||
return await Promise.map(typeGroupMap.keys, async (key) => {
|
||||
logging.info(`Moving setting ${key} from ${typeGroupMap.from} to ${typeGroupMap.to}`);
|
||||
|
||||
return await options
|
||||
.transacting('settings')
|
||||
.where('key', key)
|
||||
.update({
|
||||
type: typeGroupMap.from
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
};
|
||||
|
|
@ -1,182 +0,0 @@
|
|||
const logging = require('@tryghost/logging');
|
||||
const ObjectId = require('bson-objectid').default;
|
||||
|
||||
module.exports = {
|
||||
config: {
|
||||
transaction: true
|
||||
},
|
||||
|
||||
async up(config) {
|
||||
const knex = config.transacting;
|
||||
|
||||
const defaultOperations = [{
|
||||
key: 'members_from_address',
|
||||
flags: 'RO'
|
||||
}, {
|
||||
key: 'members_allow_free_signup'
|
||||
}, {
|
||||
key: 'stripe_product_name'
|
||||
}, {
|
||||
key: 'stripe_secret_key'
|
||||
}, {
|
||||
key: 'stripe_publishable_key'
|
||||
}, {
|
||||
key: 'stripe_plans'
|
||||
}];
|
||||
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
for (const operation of defaultOperations) {
|
||||
logging.info(`Updating ${operation.key} setting group,type,flags`);
|
||||
await knex('settings')
|
||||
.where({
|
||||
key: operation.key
|
||||
})
|
||||
.update({
|
||||
group: 'members',
|
||||
type: 'members',
|
||||
flags: operation.flags || ''
|
||||
});
|
||||
}
|
||||
|
||||
const membersSubscriptionSettingsJSON = await knex('settings')
|
||||
.select('value')
|
||||
.where('key', 'members_subscription_settings')
|
||||
.first();
|
||||
|
||||
if (!membersSubscriptionSettingsJSON || !membersSubscriptionSettingsJSON.value) {
|
||||
logging.warn(`Could not find members_subscription_settings - using default values`);
|
||||
return;
|
||||
}
|
||||
|
||||
const membersSubscriptionSettings = JSON.parse(membersSubscriptionSettingsJSON.value);
|
||||
|
||||
const membersFromAddress = typeof membersSubscriptionSettings.fromAddress === 'string' ? membersSubscriptionSettings.fromAddress : 'noreply';
|
||||
const membersAllowSelfSignup = typeof membersSubscriptionSettings.allowSelfSignup === 'boolean' ? membersSubscriptionSettings.allowSelfSignup : true;
|
||||
|
||||
const stripe = membersSubscriptionSettings && membersSubscriptionSettings.paymentProcessors && membersSubscriptionSettings.paymentProcessors[0];
|
||||
|
||||
const stripeConfig = stripe && stripe.config || {};
|
||||
|
||||
const stripeDirectSecretKey = stripeConfig.secret_token || '';
|
||||
const stripeDirectPublishableKey = stripeConfig.public_token || '';
|
||||
const stripeProductName = stripeConfig.product && stripeConfig.product.name || 'Ghost Members';
|
||||
|
||||
const stripePlans = (stripeConfig.plans || []).map((plan) => {
|
||||
return Object.assign(plan, {
|
||||
amount: plan.amount || 0
|
||||
});
|
||||
});
|
||||
|
||||
const valueOperations = [{
|
||||
key: 'members_from_address',
|
||||
value: membersFromAddress
|
||||
}, {
|
||||
key: 'members_allow_free_signup',
|
||||
value: membersAllowSelfSignup.toString()
|
||||
}, {
|
||||
key: 'stripe_product_name',
|
||||
value: stripeProductName
|
||||
}, {
|
||||
key: 'stripe_secret_key',
|
||||
value: stripeDirectSecretKey
|
||||
}, {
|
||||
key: 'stripe_publishable_key',
|
||||
value: stripeDirectPublishableKey
|
||||
}, {
|
||||
key: 'stripe_plans',
|
||||
value: JSON.stringify(stripePlans)
|
||||
}];
|
||||
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
for (const operation of valueOperations) {
|
||||
logging.info(`Updating ${operation.key} setting value`);
|
||||
await knex('settings')
|
||||
.where({
|
||||
key: operation.key
|
||||
})
|
||||
.update({
|
||||
value: operation.value
|
||||
});
|
||||
}
|
||||
|
||||
logging.info(`Deleting members_subscription_settings setting`);
|
||||
await knex('settings')
|
||||
.where('key', 'members_subscription_settings')
|
||||
.del();
|
||||
},
|
||||
|
||||
async down(config) {
|
||||
const knex = config.transacting;
|
||||
|
||||
const getSetting = key => knex.select('value').from('settings').where('key', key).first();
|
||||
|
||||
const membersFromAddress = await getSetting('members_from_address');
|
||||
const allowSelfSignup = await getSetting('members_allow_free_signup');
|
||||
const stripeDirectSecretKey = await getSetting('stripe_secret_key');
|
||||
const stripeDirectPublishableKey = await getSetting('stripe_publishable_key');
|
||||
const stripeProductName = await getSetting('stripe_product_name');
|
||||
|
||||
const stripePlans = await getSetting('stripe_plans');
|
||||
|
||||
const allowSelfSignupBoolean = allowSelfSignup && allowSelfSignup.value === 'true';
|
||||
|
||||
const membersSubscriptionSettings = {
|
||||
fromAddress: membersFromAddress ? membersFromAddress.value : 'noreply',
|
||||
allowSelfSignup: allowSelfSignupBoolean,
|
||||
paymentProcessors: [{
|
||||
adapter: 'stripe',
|
||||
config: {
|
||||
secret_token: stripeDirectSecretKey ? stripeDirectSecretKey.value : null,
|
||||
public_token: stripeDirectPublishableKey ? stripeDirectPublishableKey.value : null,
|
||||
product: {
|
||||
name: stripeProductName ? stripeProductName.value : 'Ghost Subscription'
|
||||
},
|
||||
plans: stripePlans ? JSON.parse(stripePlans.value) : [{
|
||||
name: 'Monthly',
|
||||
currency: 'usd',
|
||||
interval: 'month',
|
||||
amount: 500
|
||||
}, {
|
||||
name: 'Yearly',
|
||||
currency: 'usd',
|
||||
interval: 'year',
|
||||
amount: 5000
|
||||
}]
|
||||
}
|
||||
}]
|
||||
};
|
||||
|
||||
const now = knex.raw('CURRENT_TIMESTAMP');
|
||||
|
||||
logging.info(`Inserting members_subscription_settings setting`);
|
||||
await knex('settings')
|
||||
.insert({
|
||||
id: ObjectId().toHexString(),
|
||||
key: 'members_subscription_settings',
|
||||
value: JSON.stringify(membersSubscriptionSettings),
|
||||
group: 'members',
|
||||
type: 'members',
|
||||
flags: '',
|
||||
created_at: now,
|
||||
created_by: 1,
|
||||
updated_at: now,
|
||||
updated_by: 1
|
||||
});
|
||||
|
||||
const settingsToDelete = [
|
||||
'members_from_address',
|
||||
'members_allow_free_signup',
|
||||
'stripe_plans',
|
||||
'stripe_product_name',
|
||||
'stripe_publishable_key',
|
||||
'stripe_secret_key'
|
||||
];
|
||||
|
||||
// eslint-disable-next-line no-restricted-syntax
|
||||
for (const setting of settingsToDelete) {
|
||||
logging.info(`Deleting ${setting} setting`);
|
||||
}
|
||||
await knex('settings').whereIn('key', settingsToDelete).del();
|
||||
}
|
||||
};
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show more
Loading…
Add table
Reference in a new issue