feat(cart): Add cart module package (#5982)

* feat: Add CartModule foundation

* remove migration

* fix ts issue

* Create hot-dingos-pay.md

packages/cart/src/index.ts

@@ -0,0 +1,7 @@
+import { moduleDefinition } from "./module-definition"
+
+export default moduleDefinition
+
+export * from "./initialize"
+export * from "./loaders"
+export * from "./scripts"

packages/cart/src/initialize/index.ts

@@ -0,0 +1,27 @@
+import {
+  ExternalModuleDeclaration,
+  InternalModuleDeclaration,
+  MedusaModule,
+  MODULE_PACKAGE_NAMES,
+  Modules,
+} from "@medusajs/modules-sdk"
+import { ICartModuleService, ModulesSdkTypes } from "@medusajs/types"
+import { moduleDefinition } from "../module-definition"
+import { InitializeModuleInjectableDependencies } from "../types"
+
+export const initialize = async (
+  options?: ModulesSdkTypes.ModuleBootstrapDeclaration,
+  injectedDependencies?: InitializeModuleInjectableDependencies
+): Promise<ICartModuleService> => {
+  const loaded = await MedusaModule.bootstrap<ICartModuleService>({
+    moduleKey: Modules.CART,
+    defaultPath: MODULE_PACKAGE_NAMES[Modules.CART],
+    declaration: options as
+      | InternalModuleDeclaration
+      | ExternalModuleDeclaration,
+    injectedDependencies,
+    moduleExports: moduleDefinition,
+  })
+
+  return loaded[Modules.CART]
+}

packages/cart/src/joiner-config.ts

@@ -0,0 +1,31 @@
+import { Modules } from "@medusajs/modules-sdk"
+import { ModuleJoinerConfig } from "@medusajs/types"
+import { MapToConfig } from "@medusajs/utils"
+import { Cart } from "@models"
+
+export const LinkableKeys = {
+  cart_id: Cart.name,
+}
+
+const entityLinkableKeysMap: MapToConfig = {}
+Object.entries(LinkableKeys).forEach(([key, value]) => {
+  entityLinkableKeysMap[value] ??= []
+  entityLinkableKeysMap[value].push({
+    mapTo: key,
+    valueFrom: key.split("_").pop()!,
+  })
+})
+
+export const entityNameToLinkableKeysMap: MapToConfig = entityLinkableKeysMap
+
+export const joinerConfig: ModuleJoinerConfig = {
+  serviceName: Modules.CART,
+  primaryKeys: ["id"],
+  linkableKeys: LinkableKeys,
+  alias: {
+    name: ["cart", "carts"],
+    args: {
+      entity: Cart.name,
+    },
+  },
+}

packages/cart/src/loaders/connection.ts

@@ -0,0 +1,36 @@
+import {
+  InternalModuleDeclaration,
+  LoaderOptions,
+  Modules,
+} from "@medusajs/modules-sdk"
+import { ModulesSdkTypes } from "@medusajs/types"
+import { ModulesSdkUtils } from "@medusajs/utils"
+import { EntitySchema } from "@mikro-orm/core"
+import * as CartModels from "../models"
+
+export default async (
+  {
+    options,
+    container,
+    logger,
+  }: LoaderOptions<
+    | ModulesSdkTypes.ModuleServiceInitializeOptions
+    | ModulesSdkTypes.ModuleServiceInitializeCustomDataLayerOptions
+  >,
+  moduleDeclaration?: InternalModuleDeclaration
+): Promise<void> => {
+  const entities = Object.values(
+    CartModels
+  ) as unknown as EntitySchema[]
+  const pathToMigrations = __dirname + "/../migrations"
+
+  await ModulesSdkUtils.mikroOrmConnectionLoader({
+    moduleName: Modules.CART,
+    entities,
+    container,
+    options,
+    moduleDeclaration,
+    logger,
+    pathToMigrations,
+  })
+}

packages/cart/src/loaders/container.ts

@@ -0,0 +1,38 @@
+import * as defaultRepositories from "@repositories"
+
+import { LoaderOptions } from "@medusajs/modules-sdk"
+import { ModulesSdkTypes } from "@medusajs/types"
+import { loadCustomRepositories } from "@medusajs/utils"
+import { asClass } from "awilix"
+
+export default async ({
+  container,
+  options,
+}: LoaderOptions<
+  | ModulesSdkTypes.ModuleServiceInitializeOptions
+  | ModulesSdkTypes.ModuleServiceInitializeCustomDataLayerOptions
+>): Promise<void> => {
+  const customRepositories = (
+    options as ModulesSdkTypes.ModuleServiceInitializeCustomDataLayerOptions
+  )?.repositories
+
+  container.register({
+    // cartService: asClass(defaultServices.CartService).singleton(),
+  })
+
+  if (customRepositories) {
+    loadCustomRepositories({
+      defaultRepositories,
+      customRepositories,
+      container,
+    })
+  } else {
+    loadDefaultRepositories({ container })
+  }
+}
+
+function loadDefaultRepositories({ container }) {
+  container.register({
+    baseRepository: asClass(defaultRepositories.BaseRepository).singleton(),
+  })
+}

packages/cart/src/loaders/index.ts

@@ -0,0 +1,2 @@
+export * from "./connection"
+export * from "./container"

packages/cart/src/models/cart.ts

@@ -0,0 +1,18 @@
+import { generateEntityId } from "@medusajs/utils"
+import { BeforeCreate, Entity, OnInit, PrimaryKey } from "@mikro-orm/core"
+
+@Entity()
+export default class Cart {
+  @PrimaryKey({ columnType: "text" })
+  id!: string
+
+  @BeforeCreate()
+  onCreate() {
+    this.id = generateEntityId(this.id, "cart")
+  }
+
+  @OnInit()
+  onInit() {
+    this.id = generateEntityId(this.id, "cart")
+  }
+}

packages/cart/src/models/index.ts

@@ -0,0 +1,2 @@
+export { default as Cart } from "./cart";
+

packages/cart/src/module-definition.ts

@@ -0,0 +1,12 @@
+import { ModuleExports } from "@medusajs/types"
+import { CartModuleService } from "@services"
+import loadConnection from "./loaders/connection"
+import loadContainer from "./loaders/container"
+
+const service = CartModuleService
+const loaders = [loadContainer, loadConnection] as any
+
+export const moduleDefinition: ModuleExports = {
+  service,
+  loaders,
+}

packages/cart/src/repositories/index.ts

@@ -0,0 +1 @@
+export { MikroOrmBaseRepository as BaseRepository } from "@medusajs/utils"

packages/cart/src/scripts/bin/run-migration-down.ts

@@ -0,0 +1,8 @@
+#!/usr/bin/env node
+
+export default (async () => {
+  const { revertMigration } = await import("../migration-down")
+  const { config } = await import("dotenv")
+  config()
+  await revertMigration()
+})()

packages/cart/src/scripts/bin/run-migration-up.ts

@@ -0,0 +1,8 @@
+#!/usr/bin/env node
+
+export default (async () => {
+  const { runMigrations } = await import("../migration-up")
+  const { config } = await import("dotenv")
+  config()
+  await runMigrations()
+})()

packages/cart/src/scripts/bin/run-seed.ts

@@ -0,0 +1,19 @@
+#!/usr/bin/env node
+
+import { EOL } from "os"
+import { run } from "../seed"
+
+const args = process.argv
+const path = args.pop() as string
+
+export default (async () => {
+  const { config } = await import("dotenv")
+  config()
+  if (!path) {
+    throw new Error(
+      `filePath is required.${EOL}Example: medusa-cart-seed <filePath>`
+    )
+  }
+
+  await run({ path })
+})()

packages/cart/src/scripts/index.ts

@@ -0,0 +1,2 @@
+export * from "./migration-up"
+export * from "./migration-down"

packages/cart/src/scripts/migration-down.ts

@@ -0,0 +1,50 @@
+import { Modules } from "@medusajs/modules-sdk";
+import { LoaderOptions, Logger, ModulesSdkTypes } from "@medusajs/types";
+import { DALUtils, ModulesSdkUtils } from "@medusajs/utils";
+import { EntitySchema } from "@mikro-orm/core";
+import * as CartModels from "@models";
+
+/**
+ * This script is only valid for mikro orm managers. If a user provide a custom manager
+ * he is in charge of reverting the migrations.
+ * @param options
+ * @param logger
+ * @param moduleDeclaration
+ */
+export async function revertMigration({
+  options,
+  logger,
+}: Pick<
+  LoaderOptions<ModulesSdkTypes.ModuleServiceInitializeOptions>,
+  "options" | "logger"
+> = {}) {
+  logger ??= console as unknown as Logger
+
+  const dbData = ModulesSdkUtils.loadDatabaseConfig(
+    Modules.CART,
+    options
+  )!
+  const entities = Object.values(
+    CartModels
+  ) as unknown as EntitySchema[]
+  const pathToMigrations = __dirname + "/../migrations"
+
+  const orm = await DALUtils.mikroOrmCreateConnection(
+    dbData,
+    entities,
+    pathToMigrations
+  )
+
+  try {
+    const migrator = orm.getMigrator()
+    await migrator.down()
+
+    logger?.info("Cart module migration executed")
+  } catch (error) {
+    logger?.error(
+      `Cart module migration failed to run - Error: ${error}`
+    )
+  }
+
+  await orm.close()
+}

packages/cart/src/scripts/migration-up.ts

@@ -0,0 +1,62 @@
+import { Modules } from "@medusajs/modules-sdk";
+import { LoaderOptions, Logger, ModulesSdkTypes } from "@medusajs/types";
+import { DALUtils, ModulesSdkUtils } from "@medusajs/utils";
+import { EntitySchema } from "@mikro-orm/core";
+import * as CartModels from "@models";
+
+/**
+ * This script is only valid for mikro orm managers. If a user provide a custom manager
+ * he is in charge of running the migrations.
+ * @param options
+ * @param logger
+ * @param moduleDeclaration
+ */
+export async function runMigrations({
+  options,
+  logger,
+}: Pick<
+  LoaderOptions<ModulesSdkTypes.ModuleServiceInitializeOptions>,
+  "options" | "logger"
+> = {}) {
+  logger ??= console as unknown as Logger
+
+  const dbData = ModulesSdkUtils.loadDatabaseConfig(
+    Modules.CART,
+    options
+  )!
+  const entities = Object.values(
+    CartModels
+  ) as unknown as EntitySchema[]
+  const pathToMigrations = __dirname + "/../migrations"
+
+  const orm = await DALUtils.mikroOrmCreateConnection(
+    dbData,
+    entities,
+    pathToMigrations
+  )
+
+  try {
+    const migrator = orm.getMigrator()
+
+    const pendingMigrations = await migrator.getPendingMigrations()
+    logger.info(
+      `Running pending migrations: ${JSON.stringify(
+        pendingMigrations,
+        null,
+        2
+      )}`
+    )
+
+    await migrator.up({
+      migrations: pendingMigrations.map((m) => m.name),
+    })
+
+    logger.info("Cart module migration executed")
+  } catch (error) {
+    logger.error(
+      `Cart module migration failed to run - Error: ${error}`
+    )
+  }
+
+  await orm.close()
+}

packages/cart/src/scripts/seed.ts

@@ -0,0 +1,63 @@
+import { Modules } from "@medusajs/modules-sdk"
+import { LoaderOptions, Logger, ModulesSdkTypes } from "@medusajs/types"
+import { DALUtils, ModulesSdkUtils } from "@medusajs/utils"
+import { EntitySchema } from "@mikro-orm/core"
+import * as CartModels from "@models"
+import { EOL } from "os"
+import { resolve } from "path"
+
+export async function run({
+  options,
+  logger,
+  path,
+}: Partial<
+  Pick<
+    LoaderOptions<ModulesSdkTypes.ModuleServiceInitializeOptions>,
+    "options" | "logger"
+  >
+> & {
+  path: string
+}) {
+  logger ??= console as unknown as Logger
+
+  logger.info(`Loading seed data from ${path}...`)
+
+  const { cartData } = await import(
+    resolve(process.cwd(), path)
+  ).catch((e) => {
+    logger?.error(
+      `Failed to load seed data from ${path}. Please, provide a relative path and check that you export the following: cartData.${EOL}${e}`
+    )
+    throw e
+  })
+
+  const dbData = ModulesSdkUtils.loadDatabaseConfig(
+    Modules.CART,
+    options
+  )!
+  const entities = Object.values(
+    CartModels
+  ) as unknown as EntitySchema[]
+  const pathToMigrations = __dirname + "/../migrations"
+
+  const orm = await DALUtils.mikroOrmCreateConnection(
+    dbData,
+    entities,
+    pathToMigrations
+  )
+
+  const manager = orm.em.fork()
+
+  try {
+    logger.info("Seeding cart data..")
+
+    // TODO: implement cart seed data
+    // await createCarts(manager, cartsData)
+  } catch (e) {
+    logger.error(
+      `Failed to insert the seed data in the PostgreSQL database ${dbData.clientUrl}.${EOL}${e}`
+    )
+  }
+
+  await orm.close(true)
+}

packages/cart/src/services/__tests__/index.spec.ts

@@ -0,0 +1,5 @@
+describe("Noop test", () => {
+  it("noop check", async () => {
+    expect(true).toBe(true)
+  })
+})

packages/cart/src/services/cart-module.ts

@@ -0,0 +1,32 @@
+import {
+  CartTypes,
+  DAL,
+  InternalModuleDeclaration,
+  ModuleJoinerConfig,
+} from "@medusajs/types"
+
+import { Cart } from "@models"
+
+import { joinerConfig } from "../joiner-config"
+
+type InjectedDependencies = {
+  baseRepository: DAL.RepositoryService
+}
+
+export default class CartModuleService<
+  TCart extends Cart = Cart
+> implements CartTypes.ICartModuleService
+{
+  protected baseRepository_: DAL.RepositoryService
+
+  constructor(
+    { baseRepository }: InjectedDependencies,
+    protected readonly moduleDeclaration: InternalModuleDeclaration
+  ) {
+    this.baseRepository_ = baseRepository
+  }
+
+  __joinerConfig(): ModuleJoinerConfig {
+    return joinerConfig
+  }
+}

packages/cart/src/services/index.ts

@@ -0,0 +1,2 @@
+export { default as CartModuleService } from "./cart-module";
+

packages/cart/src/types/index.ts

@@ -0,0 +1,5 @@
+import { Logger } from "@medusajs/types"
+
+export type InitializeModuleInjectableDependencies = {
+  logger?: Logger
+}