import { type AppEnv, type Customer, LegacyVersion, OnDecrease, OnIncrease, type Organization, } from "@autumn/shared"; import { setupBefore } from "@tests/before.js"; import { TestFeature } from "@tests/setup/v2Features.js"; import { hoursToFinalizeInvoice } from "@tests/utils/constants.js"; import { attachAndExpectCorrect } from "@tests/utils/expectUtils/expectAttach.js"; import { expectProductAttached } from "@tests/utils/expectUtils/expectProductAttached.js"; import { createProducts } from "@tests/utils/productUtils.js"; import { expect } from "chai"; import chalk from "chalk"; import { addHours, addMonths } from "date-fns"; import type Stripe from "stripe"; import type { DrizzleCli } from "@/db/initDrizzle.js"; import { AutumnInt } from "@/external/autumn/autumnCli.js"; import { getMainCusProduct } from "@/internal/customers/cusProducts/cusProductUtils.js"; import { constructPrepaidItem } from "@/utils/scriptUtils/constructItem.js"; import { constructProduct } from "@/utils/scriptUtils/createTestProducts.js"; import { initCustomer } from "@/utils/scriptUtils/initCustomer.js"; import { advanceTestClock } from "@/utils/scriptUtils/testClockUtils.js"; import { addPrefixToProducts } from "../utils.js"; const testCase = "prepaid1"; export const pro = constructProduct({ items: [ constructPrepaidItem({ featureId: TestFeature.Messages, billingUnits: 100, price: 12.5, config: { on_increase: OnIncrease.ProrateImmediately, on_decrease: OnDecrease.None, }, }), ], excludeBase: true, type: "pro", }); describe(`${chalk.yellowBright(`attach/${testCase}: update quantity, no proration downgrade, single use`)}`, () => { const customerId = testCase; const autumn: AutumnInt = new AutumnInt({ version: LegacyVersion.v1_4 }); let testClockId: string; let db: DrizzleCli, org: Organization, env: AppEnv; let stripeCli: Stripe; let customer: Customer; before(async function () { await setupBefore(this); const { autumnJs } = this; db = this.db; org = this.org; env = this.env; stripeCli = this.stripeCli; const res = await initCustomer({ autumn: autumnJs, customerId, db, org, env, attachPm: "success", }); addPrefixToProducts({ products: [pro], prefix: testCase, }); await createProducts({ autumn, products: [pro], db, orgId: org.id, env, }); customer = res.customer; testClockId = res.testClockId!; }); const options = [ { feature_id: TestFeature.Messages, quantity: 300, }, ]; it("should attach pro product to customer", async () => { await attachAndExpectCorrect({ autumn, customerId, product: pro, stripeCli, db, org, env, options, }); const customer = await autumn.customers.get(customerId); expectProductAttached({ customer, product: pro, }); }); it("should reduce quantity to 200 and have correct sub item quantity + cus product quantity", async () => { await attachAndExpectCorrect({ autumn, customerId, product: pro, stripeCli, db, org, env, options: [ { feature_id: TestFeature.Messages, quantity: 200, }, ], }); }); it("should increase quantity to 400 and have correct sub item quantity + invoice..", async () => { await attachAndExpectCorrect({ autumn, customerId, product: pro, stripeCli, db, org, env, options: [ { feature_id: TestFeature.Messages, quantity: 400, }, ], waitForInvoice: 5000, }); }); const newQuantity = 200; it("should decrease quantity to 200, advance clock to next cycle and have correct balance", async () => { await attachAndExpectCorrect({ autumn, customerId, product: pro, stripeCli, db, org, env, options: [ { feature_id: TestFeature.Messages, quantity: newQuantity, }, ], }); await advanceTestClock({ stripeCli, testClockId, advanceTo: addHours( addMonths(new Date(), 1), hoursToFinalizeInvoice, ).getTime(), waitForSeconds: 40, }); const autumnCus = await autumn.customers.get(customerId); expect(autumnCus.features[TestFeature.Messages].balance).to.equal( newQuantity, ); expect(autumnCus.invoices.length).to.equal(3); expect(autumnCus.invoices[0].total).to.equal((newQuantity / 100) * 12.5); const cusProduct = await getMainCusProduct({ db, internalCustomerId: customer.internal_id, productGroup: testCase, }); expect(cusProduct?.options[0].quantity).to.equal(newQuantity / 100); expect(cusProduct?.options[0].upcoming_quantity).to.not.exist; }); });