var common = require('../lib/common'), request = require('../lib/request'), imageLib = require('../lib/image'), urlUtils = require('../lib/url-utils'), urlService = require('../../frontend/services/url'), settingsCache = require('./settings/cache'), schema = require('../data/schema').checks, moment = require('moment'), defaultPostSlugs = [ 'welcome', 'the-editor', 'using-tags', 'managing-users', 'private-sites', 'advanced-markdown', 'themes' ]; function getSlackSettings() { var setting = settingsCache.get('slack'); // This might one day have multiple entries, for now its always a array // and we return the first item or an empty object return setting ? setting[0] : {}; } function ping(post) { let message, title, author, slackData = {}, slackSettings = getSlackSettings(), blogTitle = settingsCache.get('title'); // If this is a post, we want to send the link of the post if (schema.isPost(post)) { message = urlService.getUrlByResourceId(post.id, {absolute: true}); title = post.title ? post.title : null; author = post.authors ? post.authors[0] : null; } else { message = post.message; } // Quit here if slack integration is not activated if (slackSettings && slackSettings.url && slackSettings.url !== '') { slackSettings.username = slackSettings.username ? slackSettings.username : 'Ghost'; // Only ping when not a page if (post.type === 'page') { return; } // Don't ping for the default posts. // This also handles the case where during ghost's first run // models.init() inserts this post but permissions.init() hasn't // (can't) run yet. if (defaultPostSlugs.indexOf(post.slug) > -1) { return; } if (schema.isPost(post)) { slackData = { // We are handling the case of test notification here by checking // if it is a post or a test message to check webhook working. text: `Notification from *${blogTitle}* :ghost:`, unfurl_links: true, icon_url: imageLib.blogIcon.getIconUrl(true), username: slackSettings.username, // We don't want to send attachment if it is a test notification. attachments: [ { fallback: 'Sorry, content cannot be shown.', title: title, title_link: message, author_name: blogTitle, image_url: post ? urlUtils.urlFor('image', {image: post.feature_image}, true) : null, color: '#008952', fields: [ { title: 'Description', value: post.custom_excerpt ? post.custom_excerpt : `${post.html.replace(/<[^>]+>/g, '').split('.').slice(0, 3).join('.')}.`, short: false } ] }, { fallback: 'Sorry, content cannot be shown.', color: '#008952', thumb_url: author ? urlUtils.urlFor('image', {image: author.profile_image}, true) : null, fields: [ { title: 'Author', value: author ? `<${urlService.getUrlByResourceId(author.id, {absolute: true})} | ${author.name}>` : null, short: true } ], footer: blogTitle, footer_icon: imageLib.blogIcon.getIconUrl(true), ts: moment().unix() } ] }; } else { slackData = { text: message, unfurl_links: true, icon_url: imageLib.blogIcon.getIconUrl(true), username: slackSettings.username }; } return request(slackSettings.url, { body: JSON.stringify(slackData), headers: { 'Content-type': 'application/json' } }).catch(function (err) { common.logging.error(new common.errors.GhostError({ err: err, context: common.i18n.t('errors.services.ping.requestFailed.error', {service: 'slack'}), help: common.i18n.t('errors.services.ping.requestFailed.help', {url: 'https://ghost.org/docs/'}) })); }); } } function listener(model, options) { // CASE: do not ping slack if we import a database // TODO: refactor post.published events to never fire on importing if (options && options.importing) { return; } ping(model.toJSON()); } function testPing() { ping({ message: 'Heya! This is a test notification from your Ghost blog :smile:. Seems to work fine!' }); } function listen() { common.events.on('post.published', listener); common.events.on('slack.test', testPing); } // Public API module.exports = { listen: listen };