Ghost/ghost/data-generator/lib/tables/members-stripe-customers-subscriptions.js

const {faker} = require('@faker-js/faker');
const TableImporter = require('./base');

class MembersStripeCustomersSubscriptionsImporter extends TableImporter {
    constructor(knex, {membersStripeCustomers, products, stripeProducts, stripePrices}) {
        super('members_stripe_customers_subscriptions', knex);
        this.membersStripeCustomers = membersStripeCustomers;
        this.products = products;
        this.stripeProducts = stripeProducts;
        this.stripePrices = stripePrices;
    }

    setImportOptions({model}) {
        this.model = model;
    }

    generate() {
        const customer = this.membersStripeCustomers.find(c => this.model.member_id === c.member_id);
        const isMonthly = this.model.cadence === 'month';
        const ghostProduct = this.products.find(product => product.id === this.model.tier_id);
        const stripeProduct = this.stripeProducts.find(product => product.product_id === this.model.tier_id);
        const stripePrice = this.stripePrices.find((price) => {
            return price.stripe_product_id === stripeProduct.stripe_product_id &&
                (isMonthly ? price.interval === 'month' : price.interval === 'year');
        });
        const mrr = isMonthly ? stripePrice.amount : Math.floor(stripePrice.amount / 12);
        return {
            id: faker.database.mongodbObjectId(),
            customer_id: customer.customer_id,
            subscription_id: this.model.id,
            stripe_price_id: stripePrice.stripe_price_id,
            status: 'active',
            cancel_at_period_end: false,
            current_period_end: this.model.expires_at,
            start_date: this.model.created_at,
            created_at: this.model.created_at,
            created_by: 'unused',
            mrr,
            plan_id: stripeProduct.stripe_product_id,
            plan_nickname: `${ghostProduct.name} - ${stripePrice.nickname}`,
            plan_interval: stripePrice.interval,
            plan_amount: stripePrice.amount,
            plan_currency: stripePrice.currency
        };
    }
}

module.exports = MembersStripeCustomersSubscriptionsImporter;