Added paid member welcome email sending

Author: troyciesco

ghost/core/core/server/services/members/members-api/repositories/MemberRepository.js

@@ -971,10 +971,35 @@ module.exports = class MemberRepository {
             options.batch_id = ObjectId().toHexString();
         }
 
+        const context = options?.context || {};
+        const source = this._resolveContextSource(context);
+        const shouldSendPaidWelcomeEmail = config.get('memberWelcomeEmailTestInbox') && WELCOME_EMAIL_SOURCES.includes(source);
+        let isPaidWelcomeEmailActive = false;
+        if (shouldSendPaidWelcomeEmail && this._AutomatedEmail) {
+            const paidWelcomeEmail = await this._AutomatedEmail.findOne({slug: MEMBER_WELCOME_EMAIL_SLUGS.paid}, options);
+            isPaidWelcomeEmailActive = paidWelcomeEmail && paidWelcomeEmail.get('lexical') && paidWelcomeEmail.get('status') === 'active';
+        }
+
         const memberModel = await this._Member.findOne({
             id: data.id
         }, {...options, forUpdate: true});
 
+        const queuePaidWelcomeEmail = async (subscriptionModel) => {
+            await this._Outbox.add({
+                id: ObjectId().toHexString(),
+                event_type: MemberCreatedEvent.name,
+                payload: JSON.stringify({
+                    memberId: memberModel.id,
+                    email: memberModel.get('email'),
+                    name: memberModel.get('name'),
+                    source,
+                    timestamp: subscriptionModel.get('created_at'),
+                    memberStatus: 'paid'
+                })
+            }, options);
+            this.dispatchEvent(StartOutboxProcessingEvent.create({memberId: memberModel.id}), options);
+        };
+
         const memberStripeCustomerModel = await memberModel.related('stripeCustomers').query({
             where: {
                 customer_id: data.subscription.customer
@@ -1189,6 +1214,9 @@ module.exports = class MemberRepository {
                         batchId: options.batch_id
                     });
                     this.dispatchEvent(subscriptionActivatedEvent, options);
+                    if (isPaidWelcomeEmailActive) {
+                        await queuePaidWelcomeEmail(updatedStripeCustomerSubscriptionModel);
+                    }
                 }
 
                 // Dispatch cancellation event, i.e. send paid cancellation staff notification, if:
@@ -1277,6 +1305,9 @@ module.exports = class MemberRepository {
                     batchId: options.batch_id
                 });
                 this.dispatchEvent(subscriptionActivatedEvent, options);
+                if (isPaidWelcomeEmailActive) {
+                    await queuePaidWelcomeEmail(newStripeCustomerSubscriptionModel);
+                }
             }
         }
 

ghost/core/test/integration/services/member-welcome-emails.test.js

@@ -46,6 +46,16 @@ describe('Member Welcome Emails Integration', function () {
             lexical,
             created_at: new Date()
         });
+
+        await db.knex('automated_emails').insert({
+            id: ObjectId().toHexString(),
+            status: 'active',
+            name: 'Paid Member Welcome Email',
+            slug: MEMBER_WELCOME_EMAIL_SLUGS.paid,
+            subject: 'Welcome paid member to {{site.title}}',
+            lexical,
+            created_at: new Date()
+        });
     });
 
     afterEach(async function () {
@@ -235,6 +245,54 @@ describe('Member Welcome Emails Integration', function () {
             assert.equal(entriesAfterJob.length, 1);
             assert.ok(entriesAfterJob.models[0].get('message'));
         });
+
+        it('does not send email when paid template is inactive but entry has memberStatus paid', async function () {
+            await db.knex('automated_emails')
+                .where('slug', MEMBER_WELCOME_EMAIL_SLUGS.paid)
+                .update({status: 'inactive'});
+
+            await models.Outbox.add({
+                event_type: 'MemberCreatedEvent',
+                payload: JSON.stringify({
+                    memberId: 'paid_member_1',
+                    email: 'paid-inactive@example.com',
+                    name: 'Paid Inactive Template Member',
+                    memberStatus: 'paid'
+                }),
+                status: OUTBOX_STATUSES.PENDING
+            });
+
+            await scheduleInlineJob();
+
+            assert.equal(mailService.GhostMailer.prototype.send.callCount, 0);
+
+            const entriesAfterJob = await models.Outbox.findAll();
+            assert.equal(entriesAfterJob.length, 1);
+            assert.ok(entriesAfterJob.models[0].get('message').includes('inactive'));
+        });
+
+        it('does not send email when no paid template exists but entry has memberStatus paid', async function () {
+            await db.knex('automated_emails').where('slug', MEMBER_WELCOME_EMAIL_SLUGS.paid).del();
+
+            await models.Outbox.add({
+                event_type: 'MemberCreatedEvent',
+                payload: JSON.stringify({
+                    memberId: 'paid_member_2',
+                    email: 'paid-notemplate@example.com',
+                    name: 'Paid No Template Member',
+                    memberStatus: 'paid'
+                }),
+                status: OUTBOX_STATUSES.PENDING
+            });
+
+            await scheduleInlineJob();
+
+            assert.equal(mailService.GhostMailer.prototype.send.callCount, 0);
+
+            const entriesAfterJob = await models.Outbox.findAll();
+            assert.equal(entriesAfterJob.length, 1);
+            assert.ok(entriesAfterJob.models[0].get('message'));
+        });
     });
 });