Create Subscription adjustments

Author: GTFalcao

components/chargebee/actions/create-subscription/create-subscription.mjs

@@ -15,6 +15,22 @@ export default {
         "customerId",
       ],
     },
+    itemPriceId: {
+      propDefinition: [
+        chargebee,
+        "itemPriceId"
+      ],
+    },
+    unitPrice: {
+      type: "integer",
+      label: "Unit Price",
+      description: "The unit price of the plan item.",
+    },
+    quantity: {
+      type: "integer",
+      label: "Quantity",
+      description: "The quantity of the plan item.",
+    },
     id: {
       type: "string",
       label: "ID",
@@ -41,14 +57,27 @@ export default {
     },
   },
   async run({ $ }) {
-    const response = await this.chargebee.createCustomer(this.customerId, clearObject({
+    try {
+    const response = await this.chargebee.createSubscription(this.customerId, clearObject({
       id: this.id,
       net_term_days: this.netTermDays,
       start_date: this.startDate && (Date.parse(this.startDate) / 1000),
+      subscription_items: [
+        {
+          item_price_id: this.itemPriceId,
+          item_type: "plan",
+          unit_price: this.unitPrice,
+          quantity: this.quantity,
+        }
+      ],
       ...this.additionalFields,
     }));
 
     $.export("$summary", `Successfully created subscription (ID: ${response?.subscription?.id})`);
     return response;
+  } catch (error) {
+    $.export("debug", error);
+    throw new Error("Error creating subscription. Check the debug export for more information.")
+  }
   },
 };

components/chargebee/chargebee.app.mjs

@@ -1,4 +1,4 @@
-import chargebee from "chargebee";
+import Chargebee from "chargebee";
 
 export default {
   type: "app",
@@ -10,44 +10,58 @@ export default {
       description: "The ID of the customer to create the subscription for.",
       async options() {
         const customers = await this.getCustomers();
-        return customers.list.map((customer) => ({
+        return customers.list.map(({ customer }) => ({
           label: `${customer.first_name ?? ""} ${customer.last_name ?? ""} (${customer.email ?? customer.id})`,
           value: customer.id,
         }));
       },
     },
+    itemPriceId: {
+      type: "string",
+      label: "Item Price ID",
+      description: "The unique identifier of the plan item price.",
+      async options() {
+        const itemPrices = await this.getItemPrices();
+        return itemPrices.list.map(({ item_price: { name, id } }) => ({
+          label: name,
+          value: id,
+        }));
+      },
+    },
   },
   methods: {
     instance() {
-      chargebee.configure({
+      return new Chargebee({
         site: this.$auth.sub_url,
-        api_key: this.$auth.api_key,
+        apiKey: this.$auth.api_key,
       });
-      return chargebee;
     },
     getSubscriptions(args = {}) {
-      return this.instance().subscription.list(args).request();
+      return this.instance().subscription.list(args);
     },
     getTransactions(args = {}) {
-      return this.instance().transaction.list(args).request();
+      return this.instance().transaction.list(args);
     },
     getCustomers(args = {}) {
-      return this.instance().customer.list(args).request();
+      return this.instance().customer.list(args);
     },
     getInvoices(args = {}) {
-      return this.instance().invoice.list(args).request();
+      return this.instance().invoice.list(args);
     },
     getPaymentSources(args = {}) {
-      return this.instance().payment_source.list(args).request();
+      return this.instance().paymentSource.list(args);
     },
     getEvents(args = {}) {
-      return this.instance().event.list(args).request();
+      return this.instance().event.list(args);
     },
     createCustomer(args = {}) {
-      return this.instance().customer.create(args).request();
+      return this.instance().customer.create(args);
     },
     createSubscription(customerId, args = {}) {
-      return this.instance().subscription.create_for_customer(customerId, args).request();
+      return this.instance().subscription.createWithItems(customerId, args);
+    },
+    getItemPrices(args = {}) {
+      return this.instance().itemPrice.list(args);
     },
   },
 };

components/chargebee/package.json

@@ -12,7 +12,7 @@
   "license": "MIT",
   "dependencies": {
     "@pipedream/platform": "^3.0.3",
-    "chargebee": "^2.22.3"
+    "chargebee": "^3.2.1"
   },
   "publishConfig": {
     "access": "public"