feat(medusa): Load PaymentProcessors + integrate in PaymentProviderService

packages/medusa/src/interfaces/index.ts

@@ -10,4 +10,5 @@ export * from "./models/base-entity"
 export * from "./models/soft-deletable-entity"
 export * from "./search-service"
 export * from "./payment-service"
+export * from "./payment-processor"
 export * from "./services"

packages/medusa/src/interfaces/payment-processor.ts

@@ -20,7 +20,7 @@ export type PaymentProcessorSessionResponse = {
 export interface PaymentProcessorError {
   error: string
   code: number
-  details: any
+  details?: any
 }
 
 /**
@@ -51,55 +51,73 @@ export interface PaymentProcessor {
    */
   updatePayment(
     context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+  ): Promise<PaymentProcessorError | PaymentProcessorSessionResponse | void>
 
   /**
    * Refund an existing session
-   * @param context
+   * @param paymentSessionData
    */
   refundPayment(
-    context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+    paymentSessionData: Record<string, unknown>
+  ): Promise<
+    PaymentProcessorError | PaymentProcessorSessionResponse["session_data"]
+  >
 
   /**
    * Authorize an existing session if it is not already authorized
+   * @param paymentSessionData
    * @param context
    */
   authorizePayment(
-    context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+    paymentSessionData: Record<string, unknown>,
+    context: Record<string, unknown>
+  ): Promise<
+    | PaymentProcessorError
+    | {
+        status: PaymentSessionStatus
+        data: PaymentProcessorSessionResponse["session_data"]
+      }
+  >
 
   /**
    * Capture an existing session
-   * @param context
+   * @param paymentSessionData
    */
   capturePayment(
-    context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+    paymentSessionData: Record<string, unknown>
+  ): Promise<
+    PaymentProcessorError | PaymentProcessorSessionResponse["session_data"]
+  >
 
   /**
    * Delete an existing session
    */
-  deletePayment(paymentId: string): Promise<PaymentProcessorError | void>
+  deletePayment(
+    paymentSessionData: Record<string, unknown>
+  ): Promise<PaymentProcessorError | void>
 
   /**
    * Retrieve an existing session
    */
   retrievePayment(
-    paymentId: string
+    paymentSessionData: Record<string, unknown>
   ): Promise<
     PaymentProcessorError | PaymentProcessorSessionResponse["session_data"]
   >
 
   /**
    * Cancel an existing session
    */
-  cancelPayment(paymentId: string): Promise<PaymentProcessorError | void>
+  cancelPayment(
+    paymentSessionData: Record<string, unknown>
+  ): Promise<PaymentProcessorError | void>
 
   /**
    * Return the status of the session
    */
-  getPaymentStatus(paymentId: string): Promise<PaymentSessionStatus>
+  getPaymentStatus(
+    paymentSessionData: Record<string, unknown>
+  ): Promise<PaymentSessionStatus>
 }
 
 /**
@@ -111,7 +129,7 @@ export abstract class AbstractPaymentProcessor implements PaymentProcessor {
     protected readonly config?: Record<string, unknown> // eslint-disable-next-line @typescript-eslint/no-empty-function
   ) {}
 
-  protected static identifier: string
+  public static identifier: string
 
   public getIdentifier(): string {
     const ctr = this.constructor as typeof AbstractPaymentProcessor
@@ -126,33 +144,46 @@ export abstract class AbstractPaymentProcessor implements PaymentProcessor {
   abstract init(): Promise<void>
 
   abstract capturePayment(
-    context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+    paymentSessionData: Record<string, unknown>
+  ): Promise<
+    PaymentProcessorError | PaymentProcessorSessionResponse["session_data"]
+  >
 
   abstract authorizePayment(
-    context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+    paymentSessionData: Record<string, unknown>,
+    context: Record<string, unknown>
+  ): Promise<
+    | PaymentProcessorError
+    | {
+        status: PaymentSessionStatus
+        data: PaymentProcessorSessionResponse["session_data"]
+      }
+  >
 
   abstract cancelPayment(
-    paymentId: string
+    paymentSessionData: Record<string, unknown>
   ): Promise<PaymentProcessorError | void>
 
   abstract initiatePayment(
     context: PaymentProcessorContext
   ): Promise<PaymentProcessorError | PaymentProcessorSessionResponse>
 
   abstract deletePayment(
-    paymentId: string
+    paymentSessionData: Record<string, unknown>
   ): Promise<PaymentProcessorError | void>
 
-  abstract getPaymentStatus(paymentId: string): Promise<PaymentSessionStatus>
+  abstract getPaymentStatus(
+    paymentSessionData: Record<string, unknown>
+  ): Promise<PaymentSessionStatus>
 
   abstract refundPayment(
-    context: PaymentProcessorContext
-  ): Promise<PaymentProcessorError | void>
+    paymentSessionData: Record<string, unknown>
+  ): Promise<
+    PaymentProcessorError | PaymentProcessorSessionResponse["session_data"]
+  >
 
   abstract retrievePayment(
-    paymentId: string
+    paymentSessionData: Record<string, unknown>
   ): Promise<
     PaymentProcessorError | PaymentProcessorSessionResponse["session_data"]
   >

packages/medusa/src/interfaces/payment-service.ts

@@ -21,11 +21,13 @@ export type PaymentContext = {
     email: string
     shipping_address: Address | null
     shipping_methods: ShippingMethod[]
+    billing_address?: Address | null
   }
   currency_code: string
   amount: number
   resource_id?: string
   customer?: Customer
+  paymentSessionData: Record<string, unknown>
 }
 
 export type PaymentSessionResponse = {
@@ -148,7 +150,7 @@ export abstract class AbstractPaymentService
     super(container, config)
   }
 
-  protected static identifier: string
+  public static identifier: string
 
   public getIdentifier(): string {
     if (!(this.constructor as typeof AbstractPaymentService).identifier) {

packages/medusa/src/loaders/__tests__/default.spec.ts

@@ -1,5 +1,5 @@
 import { asValue, createContainer } from "awilix";
-import { MockRepository, MockManager } from "medusa-test-utils"
+import { MockManager, MockRepository } from "medusa-test-utils"
 import { StoreServiceMock } from "../../services/__mocks__/store";
 import { ShippingProfileServiceMock } from "../../services/__mocks__/shipping-profile";
 import Logger from "../logger";
@@ -33,14 +33,23 @@ describe('default', () => {
         paymentProviderService: asValue(PaymentProviderServiceMock),
         notificationProviders: asValue([]),
         notificationService: asValue({
+          withTransaction: function () {
+            return this
+          },
           registerInstalledProviders: jest.fn(),
         }),
         fulfillmentProviders: asValue([]),
         fulfillmentProviderService: asValue({
+          withTransaction: function () {
+            return this
+          },
           registerInstalledProviders: jest.fn(),
         }),
         taxProviders: asValue([]),
         taxProviderService: asValue({
+          withTransaction: function () {
+            return this
+          },
           registerInstalledProviders: jest.fn(),
         }),
       })