const {URL} = require('url'); const crypto = require('crypto'); const path = require('path'); const COMPLIMENTARY_PLAN = { name: 'Complimentary', currency: 'usd', interval: 'year', amount: '0' }; class MembersConfigProvider { /** * @param {object} options * @param {{get: (key: string) => any}} options.settingsCache * @param {{get: (key: string) => any}} options.config * @param {any} options.urlUtils * @param {any} options.logging * @param {{original: string}} options.ghostVersion */ constructor(options) { this._settingsCache = options.settingsCache; this._config = options.config; this._urlUtils = options.urlUtils; this._logging = options.logging; this._ghostVersion = options.ghostVersion; } /** * @private */ _getDomain() { const domain = this._urlUtils.urlFor('home', true).match(new RegExp('^https?://([^/:?#]+)(?:[/:?#]|$)', 'i')); return domain && domain[1]; } getEmailFromAddress() { const fromAddress = this._settingsCache.get('members_from_address') || 'noreply'; // Any fromAddress without domain uses site domain, like default setting `noreply` if (fromAddress.indexOf('@') < 0) { return `${fromAddress}@${this._getDomain()}`; } return fromAddress; } getPublicPlans() { const CURRENCY_SYMBOLS = { USD: '$', AUD: '$', CAD: '$', GBP: '£', EUR: '€', INR: '₹' }; const defaultPriceData = { monthly: 0, yearly: 0, currency: 'USD', currency_symbol: CURRENCY_SYMBOLS.USD }; try { const plans = this._settingsCache.get('stripe_plans') || []; const priceData = plans.reduce((prices, plan) => { const numberAmount = 0 + plan.amount; const dollarAmount = numberAmount ? Math.round(numberAmount / 100) : 0; return Object.assign(prices, { [plan.name.toLowerCase()]: dollarAmount }); }, {}); priceData.currency = plans[0].currency || 'USD'; priceData.currency_symbol = CURRENCY_SYMBOLS[priceData.currency.toUpperCase()]; if (Number.isInteger(priceData.monthly) && Number.isInteger(priceData.yearly)) { return priceData; } return defaultPriceData; } catch (err) { return defaultPriceData; } } /** * @param {'direct' | 'connect'} type - The "type" of keys to fetch from settings * @returns {{publicKey: string, secretKey: string} | null} */ getStripeKeys(type) { if (type !== 'direct' && type !== 'connect') { throw new Error(); } const secretKey = this._settingsCache.get(`stripe_${type === 'connect' ? 'connect_' : ''}secret_key`); const publicKey = this._settingsCache.get(`stripe_${type === 'connect' ? 'connect_' : ''}publishable_key`); if (!secretKey || !publicKey) { return null; } return { secretKey, publicKey }; } /** * @returns {{publicKey: string, secretKey: string} | null} */ getActiveStripeKeys() { const stripeDirect = this._config.get('stripeDirect'); if (stripeDirect) { return this.getStripeKeys('direct'); } const connectKeys = this.getStripeKeys('connect'); if (!connectKeys) { return this.getStripeKeys('direct'); } return connectKeys; } isStripeConnected() { return this.getActiveStripeKeys() !== null; } getStripeUrlConfig() { const siteUrl = this._urlUtils.getSiteUrl(); const webhookHandlerUrl = new URL('members/webhooks/stripe/', siteUrl); const checkoutSuccessUrl = new URL(siteUrl); checkoutSuccessUrl.searchParams.set('stripe', 'success'); const checkoutCancelUrl = new URL(siteUrl); checkoutCancelUrl.searchParams.set('stripe', 'cancel'); const billingSuccessUrl = new URL(siteUrl); billingSuccessUrl.searchParams.set('stripe', 'billing-update-success'); const billingCancelUrl = new URL(siteUrl); billingCancelUrl.searchParams.set('stripe', 'billing-update-cancel'); return { checkoutSuccess: checkoutSuccessUrl.href, checkoutCancel: checkoutCancelUrl.href, billingSuccess: billingSuccessUrl.href, billingCancel: billingCancelUrl.href, webhookHandler: webhookHandlerUrl.href }; } getStripePaymentConfig() { if (!this.isStripeConnected()) { return null; } const stripeApiKeys = this.getActiveStripeKeys(); const urls = this.getStripeUrlConfig(); if (!stripeApiKeys) { return null; } return { publicKey: stripeApiKeys.publicKey, secretKey: stripeApiKeys.secretKey, checkoutSuccessUrl: urls.checkoutSuccess, checkoutCancelUrl: urls.checkoutCancel, billingSuccessUrl: urls.billingSuccess, billingCancelUrl: urls.billingCancel, webhookHandlerUrl: urls.webhookHandler, webhook: { id: this._settingsCache.get('members_stripe_webhook_id'), secret: this._settingsCache.get('members_stripe_webhook_secret') }, product: { name: this._settingsCache.get('stripe_product_name') }, plans: [COMPLIMENTARY_PLAN].concat(this._settingsCache.get('stripe_plans') || []), appInfo: { name: 'Ghost', partner_id: 'pp_partner_DKmRVtTs4j9pwZ', version: this._ghostVersion.original, url: 'https://ghost.org/' } }; } getAuthSecret() { const hexSecret = this._settingsCache.get('members_email_auth_secret'); if (!hexSecret) { this._logging.warn('Could not find members_email_auth_secret, using dynamically generated secret'); return crypto.randomBytes(64); } const secret = Buffer.from(hexSecret, 'hex'); if (secret.length < 64) { this._logging.warn('members_email_auth_secret not large enough (64 bytes), using dynamically generated secret'); return crypto.randomBytes(64); } return secret; } getAllowSelfSignup() { return this._settingsCache.get('members_allow_free_signup'); } getTokenConfig() { const {href: membersApiUrl} = new URL( this._urlUtils.getApiPath({version: 'v3', type: 'members'}), this._urlUtils.urlFor('admin', true) ); return { issuer: membersApiUrl, publicKey: this._settingsCache.get('members_public_key'), privateKey: this._settingsCache.get('members_private_key') }; } getSigninURL(token, type) { const siteUrl = this._urlUtils.getSiteUrl(); const signinURL = new URL(siteUrl); signinURL.pathname = path.join(signinURL.pathname, '/members/'); signinURL.searchParams.set('token', token); signinURL.searchParams.set('action', type); return signinURL.href; } } module.exports = MembersConfigProvider;