chore: wip

Author: glennmichael123

storage/framework/core/payments/src/billable/payment-method.ts

@@ -0,0 +1,76 @@
+import type Stripe from 'stripe'
+import type { UserModel } from '../../../../orm/src/models/User'
+import { stripe } from '..'
+
+
+export interface ManageCharge {
+    addPaymentMethod: (user: UserModel, paymentMethod: string | Stripe.PaymentMethod) =>  Promise<Stripe.PaymentMethod>
+}
+
+export const managePaymentMethod: ManageCharge = (() => {
+  async function addPaymentMethod(user: UserModel, paymentMethod: string | Stripe.PaymentMethod): Promise<Stripe.PaymentMethod> {
+    if (!user.hasStripeId()) {
+      throw new Error('Customer does not exist in Stripe')
+    }
+
+    let stripePaymentMethod: Stripe.PaymentMethod
+
+    if (typeof paymentMethod === 'string') {
+      stripePaymentMethod = await stripe.paymentMethod.retrieve(paymentMethod)
+    } else {
+      stripePaymentMethod = paymentMethod
+    }
+
+    if (stripePaymentMethod.customer !== user.stripe_id) {
+      stripePaymentMethod = await stripe.paymentMethod.attach(stripePaymentMethod.id, {
+        customer: user.stripe_id || '',
+      })
+    }
+
+    return stripePaymentMethod
+  }
+
+  async function deletePaymentMethod(user: UserModel, paymentMethodId: string): Promise<Stripe.PaymentMethod> {
+    if (!user.hasStripeId()) {
+      throw new Error('Customer does not exist in Stripe')
+    }
+
+    const paymentMethod = await stripe.paymentMethod.retrieve(paymentMethodId)
+
+    if (paymentMethod.customer !== user.stripe_id) {
+      throw new Error('Payment method does not belong to this customer')
+    }
+
+    return await stripe.paymentMethod.detach(paymentMethodId)
+  }
+
+  async function updatePaymentMethod(user: UserModel, paymentMethodId: string, updateParams: Stripe.PaymentMethodUpdateParams): Promise<Stripe.PaymentMethod> {
+    if (!user.hasStripeId()) {
+      throw new Error('Customer does not exist in Stripe')
+    }
+
+    const paymentMethod = await stripe.paymentMethod.retrieve(paymentMethodId)
+
+    if (paymentMethod.customer !== user.stripe_id) {
+      throw new Error('Payment method does not belong to this customer')
+    }
+
+    return await stripe.paymentMethod.update(paymentMethodId, updateParams)
+  }
+
+  async function retrievePaymentMethod(user: UserModel, paymentMethodId: string): Promise<Stripe.PaymentMethod> {
+    if (!user.hasStripeId()) {
+      throw new Error('Customer does not exist in Stripe')
+    }
+
+    const paymentMethod = await stripe.paymentMethod.retrieve(paymentMethodId)
+
+    if (paymentMethod.customer !== user.stripe_id) {
+      throw new Error('Payment method does not belong to this customer')
+    }
+
+    return paymentMethod
+  }
+
+  return { addPaymentMethod, deletePaymentMethod, retrievePaymentMethod, updatePaymentMethod }
+})()

storage/framework/core/payments/src/drivers/stripe.ts

@@ -140,6 +140,44 @@ export const refund: Refund = (() => {
   return { create, retrieve, update, list }
 })()
 
+export interface PaymentMethod {
+  create: (params: Stripe.PaymentMethodCreateParams) => Promise<Stripe.Response<Stripe.PaymentMethod>>
+  retrieve: (paymentMethodId: string) => Promise<Stripe.Response<Stripe.PaymentMethod>>
+  update: (paymentMethodId: string, params: Stripe.PaymentMethodUpdateParams) => Promise<Stripe.Response<Stripe.PaymentMethod>>
+  list: (params: Stripe.PaymentMethodListParams) => Promise<Stripe.Response<Stripe.ApiList<Stripe.PaymentMethod>>>
+  attach: (paymentMethodId: string, params: Stripe.PaymentMethodAttachParams) => Promise<Stripe.Response<Stripe.PaymentMethod>>
+  detach: (paymentMethodId: string) => Promise<Stripe.Response<Stripe.PaymentMethod>>
+}
+
+export const paymentMethod: PaymentMethod = (() => {
+  async function create(params: Stripe.PaymentMethodCreateParams): Promise<Stripe.Response<Stripe.PaymentMethod>> {
+    return await client.paymentMethods.create(params)
+  }
+
+  async function retrieve(paymentMethodId: string): Promise<Stripe.Response<Stripe.PaymentMethod>> {
+    return await client.paymentMethods.retrieve(paymentMethodId)
+  }
+
+  async function update(paymentMethodId: string, params: Stripe.PaymentMethodUpdateParams): Promise<Stripe.Response<Stripe.PaymentMethod>> {
+    return await client.paymentMethods.update(paymentMethodId, params)
+  }
+
+  async function list(params: Stripe.PaymentMethodListParams): Promise<Stripe.Response<Stripe.ApiList<Stripe.PaymentMethod>>> {
+    return await client.paymentMethods.list(params)
+  }
+
+  async function attach(paymentMethodId: string, params: Stripe.PaymentMethodAttachParams): Promise<Stripe.Response<Stripe.PaymentMethod>> {
+    return await client.paymentMethods.attach(paymentMethodId, params)
+  }
+
+  async function detach(paymentMethodId: string): Promise<Stripe.Response<Stripe.PaymentMethod>> {
+    return await client.paymentMethods.detach(paymentMethodId)
+  }
+
+  return { create, retrieve, update, list, attach, detach }
+})()
+
+
 export interface BalanceTransactions {
   retrieve: (stripeId: string) => Promise<Stripe.Response<Stripe.BalanceTransaction>>
   list: (limit: number) => Promise<Stripe.Response<Stripe.ApiList<Stripe.BalanceTransaction>>>