feat: convert MikroORM entities to DML entities

integration-tests/http/__tests__/product/admin/product.spec.ts

@@ -74,7 +74,8 @@ medusaIntegrationTestRunner({
             // BREAKING: Type input changed from {type: {value: string}} to {type_id: string}
             type_id: baseType.id,
             tags: [{ id: baseTag1.id }, { id: baseTag2.id }],
-            images: [{
+            images: [
+              {
                 url: "image-one",
               },
               {
@@ -139,7 +140,6 @@ medusaIntegrationTestRunner({
             ])
           )
         })
-
 
         it("returns a list of products with all statuses when no status or invalid status is provided", async () => {
           const res = await api
@@ -991,7 +991,10 @@ medusaIntegrationTestRunner({
         })
 
         it("should get a product with images ordered by rank", async () => {
-          const res = await api.get(`/admin/products/${baseProduct.id}`, adminHeaders)
+          const res = await api.get(
+            `/admin/products/${baseProduct.id}`,
+            adminHeaders
+          )
 
           expect(res.data.product.images).toEqual(
             expect.arrayContaining([

integration-tests/http/__tests__/product/store/product.spec.ts

@@ -1436,7 +1436,7 @@ medusaIntegrationTestRunner({
             },
             {
               url: "image-two",
-            }
+            },
           ],
         })
 
@@ -1487,7 +1487,10 @@ medusaIntegrationTestRunner({
       })
 
       it("should retrieve product with images ordered by rank", async () => {
-        const response = await api.get(`/store/products/${product.id}`, storeHeaders)
+        const response = await api.get(
+          `/store/products/${product.id}`,
+          storeHeaders
+        )
 
         expect(response.data.product.images).toEqual(
           expect.arrayContaining([

packages/core/types/src/dal/index.ts

@@ -1,3 +1,4 @@
+import { InferEntityType } from "../dml"
 import { Dictionary, FilterQuery, Order } from "./utils"
 
 export { FilterQuery, OperatorMap } from "./utils"
@@ -22,7 +23,7 @@ export interface BaseFilterable<T> {
 /**
  * The options to apply when retrieving an item.
  */
-export interface OptionsQuery<T, P extends string = never> {
+export interface OptionsQuery<T> {
   /**
    * Relations to populate in the retrieved items.
    */
@@ -54,7 +55,7 @@ export interface OptionsQuery<T, P extends string = never> {
   /**
    * Load strategy (e.g for mikro orm it accept select-in or joined)
    */
-  strategy?: 'select-in' | 'joined' | string & {}
+  strategy?: "select-in" | "joined" | (string & {})
 }
 
 /**
@@ -66,12 +67,13 @@ export type FindOptions<T = any> = {
   /**
    * The filters to apply on the items.
    */
-  where: FilterQuery<T> & BaseFilterable<FilterQuery<T>>
+  where: FilterQuery<InferEntityType<T>> &
+    BaseFilterable<FilterQuery<InferEntityType<T>>>
 
   /**
    * The options to apply when retrieving the items.
    */
-  options?: OptionsQuery<T, any>
+  options?: OptionsQuery<InferEntityType<T>>
 }
 
 /**

packages/core/types/src/dal/repository-service.ts

@@ -1,16 +1,23 @@
 import { RepositoryTransformOptions } from "../common"
 import { Context } from "../shared-context"
 import {
-  BaseFilterable,
-  FilterQuery,
   FilterQuery as InternalFilterQuery,
   FindOptions,
   UpsertWithReplaceConfig,
 } from "./index"
+import { EntityClass } from "@mikro-orm/core"
+import { IDmlEntity, InferTypeOf } from "../dml"
 
 type EntityClassName = string
 type EntityValues = { id: string }[]
 
+/**
+ * Either infer the properties from a DML object or from a Mikro orm class prototype.
+ */
+export type InferRepositoryReturnType<T> = T extends IDmlEntity<any, any>
+  ? InferTypeOf<T>
+  : EntityClass<T>["prototype"]
+
 export type PerformedActions = {
   created: Record<EntityClassName, EntityValues>
   updated: Record<EntityClassName, EntityValues>
@@ -22,7 +29,7 @@ export type PerformedActions = {
  * This layer helps to separate the business logic (service layer) from accessing the
  * ORM directly and allows to switch to another ORM without changing the business logic.
  */
-interface BaseRepositoryService<T = any> {
+interface BaseRepositoryService {
   transaction<TManager = unknown>(
     task: (transactionManager: TManager) => Promise<any>,
     context?: {
@@ -42,22 +49,28 @@ interface BaseRepositoryService<T = any> {
   ): Promise<TOutput>
 }
 
-export interface RepositoryService<T = any> extends BaseRepositoryService<T> {
-  find(options?: FindOptions<T>, context?: Context): Promise<T[]>
+export interface RepositoryService<T = any> extends BaseRepositoryService {
+  find(
+    options?: FindOptions<T>,
+    context?: Context
+  ): Promise<InferRepositoryReturnType<T>[]>
 
   findAndCount(
     options?: FindOptions<T>,
     context?: Context
-  ): Promise<[T[], number]>
-
-  create(data: any[], context?: Context): Promise<T[]>
+  ): Promise<[InferRepositoryReturnType<T>[], number]>
 
-  update(data: { entity; update }[], context?: Context): Promise<T[]>
+  create(
+    data: any[],
+    context?: Context
+  ): Promise<InferRepositoryReturnType<T>[]>
 
-  delete(
-    idsOrPKs: FilterQuery<T> & BaseFilterable<FilterQuery<T>>,
+  update(
+    data: { entity; update }[],
     context?: Context
-  ): Promise<void>
+  ): Promise<InferRepositoryReturnType<T>[]>
+
+  delete(idsOrPKs: FindOptions<T>["where"], context?: Context): Promise<void>
 
   /**
    * Soft delete entities and cascade to related entities if configured.
@@ -74,37 +87,45 @@ export interface RepositoryService<T = any> extends BaseRepositoryService<T> {
       | InternalFilterQuery
       | InternalFilterQuery[],
     context?: Context
-  ): Promise<[T[], Record<string, unknown[]>]>
+  ): Promise<[InferRepositoryReturnType<T>[], Record<string, unknown[]>]>
 
   restore(
     idsOrFilter: string[] | InternalFilterQuery,
     context?: Context
-  ): Promise<[T[], Record<string, unknown[]>]>
+  ): Promise<[InferRepositoryReturnType<T>[], Record<string, unknown[]>]>
 
-  upsert(data: any[], context?: Context): Promise<T[]>
+  upsert(
+    data: any[],
+    context?: Context
+  ): Promise<InferRepositoryReturnType<T>[]>
 
   upsertWithReplace(
     data: any[],
-    config?: UpsertWithReplaceConfig<T>,
+    config?: UpsertWithReplaceConfig<InferRepositoryReturnType<T>>,
     context?: Context
-  ): Promise<{ entities: T[]; performedActions: PerformedActions }>
+  ): Promise<{
+    entities: InferRepositoryReturnType<T>[]
+    performedActions: PerformedActions
+  }>
 }
 
-export interface TreeRepositoryService<T = any>
-  extends BaseRepositoryService<T> {
+export interface TreeRepositoryService<T = any> extends BaseRepositoryService {
   find(
     options?: FindOptions<T>,
     transformOptions?: RepositoryTransformOptions,
     context?: Context
-  ): Promise<T[]>
+  ): Promise<InferRepositoryReturnType<T>[]>
 
   findAndCount(
     options?: FindOptions<T>,
     transformOptions?: RepositoryTransformOptions,
     context?: Context
-  ): Promise<[T[], number]>
+  ): Promise<[InferRepositoryReturnType<T>[], number]>
 
-  create(data: unknown[], context?: Context): Promise<T[]>
+  create(
+    data: unknown[],
+    context?: Context
+  ): Promise<InferRepositoryReturnType<T>[]>
 
   delete(ids: string[], context?: Context): Promise<void>
 }

packages/core/types/src/dal/utils.ts

@@ -1,3 +1,5 @@
+import { Constructor } from "../modules-sdk"
+
 type ExpandProperty<T> = T extends (infer U)[] ? NonNullable<U> : NonNullable<T>
 
 export type Dictionary<T = any> = {
@@ -84,25 +86,29 @@ type FilterValue<T> =
 
 type PrevLimit = [never, 0, 1, 2]
 
+export type FilterQueryProperties<T, Prev extends number = 3> = {
+  [Key in keyof T]?: T[Key] extends
+    | boolean
+    | number
+    | string
+    | bigint
+    | symbol
+    | Date
+    ? T[Key] | OperatorMap<T[Key]>
+    : T[Key] extends infer U
+    ? U extends { [x: number]: infer V }
+      ? V extends object
+        ? FilterQuery<Partial<V>, PrevLimit[Prev]>
+        : never
+      : never
+    : never
+}
+
 export type FilterQuery<T = any, Prev extends number = 3> = Prev extends never
   ? never
-  : {
-      [Key in keyof T]?: T[Key] extends
-        | boolean
-        | number
-        | string
-        | bigint
-        | symbol
-        | Date
-        ? T[Key] | OperatorMap<T[Key]>
-        : T[Key] extends infer U
-        ? U extends { [x: number]: infer V }
-          ? V extends object
-            ? FilterQuery<Partial<V>, PrevLimit[Prev]>
-            : never
-          : never
-        : never
-    }
+  : T extends Constructor<infer Prototype>
+  ? FilterQueryProperties<Prototype, Prev>
+  : FilterQueryProperties<T, Prev>
 
 declare type QueryOrder = "ASC" | "DESC" | "asc" | "desc"
 

packages/core/types/src/dml/index.ts

@@ -55,6 +55,13 @@ export type RelationshipTypes =
   | "belongsTo"
   | "manyToMany"
 
+/**
+ * Return true if the relationship is nullable
+ */
+export type IsNullableRelation<T> = T extends () => IDmlEntity<any, any> | null
+  ? true
+  : false
+
 /**
  * The meta-data returned by the property parse method
  */
@@ -135,14 +142,12 @@ export interface EntityConstructor<Props> extends Function {
  * "belongsTo" relation meaning "hasOne" and "ManyToOne"
  */
 export type InferForeignKeys<Schema extends DMLSchema> = {
-  [K in keyof Schema as Schema[K] extends { type: infer Type }
-    ? Type extends RelationshipTypes
-      ? `${K & string}_id`
-      : never
-    : never]: Schema[K] extends { type: infer Type }
-    ? Type extends RelationshipTypes
-      ? string
-      : never
+  [K in keyof Schema as Schema[K] extends { type: "belongsTo" }
+    ? `${K & string}_id`
+    : never]: Schema[K] extends { type: "belongsTo" }
+    ? null extends Schema[K]["$dataType"]
+      ? string | null
+      : string
     : never
 }
 
@@ -182,19 +187,21 @@ export type InferManyToManyFields<Relation> = InferHasManyFields<Relation>
  * Inferring the types of the schema fields from the DML
  * entity
  */
-export type InferSchemaFields<Schema extends DMLSchema> = Prettify<{
-  [K in keyof Schema]: Schema[K] extends RelationshipType<any>
-    ? Schema[K]["type"] extends "belongsTo"
-      ? InferBelongsToFields<Schema[K]["$dataType"]>
-      : Schema[K]["type"] extends "hasOne"
-      ? InferHasOneFields<Schema[K]["$dataType"]>
-      : Schema[K]["type"] extends "hasMany"
-      ? InferHasManyFields<Schema[K]["$dataType"]>
-      : Schema[K]["type"] extends "manyToMany"
-      ? InferManyToManyFields<Schema[K]["$dataType"]>
-      : never
-    : Schema[K]["$dataType"]
-}>
+export type InferSchemaFields<Schema extends DMLSchema> = Prettify<
+  {
+    [K in keyof Schema]: Schema[K] extends RelationshipType<any>
+      ? Schema[K]["type"] extends "belongsTo"
+        ? InferBelongsToFields<Schema[K]["$dataType"]>
+        : Schema[K]["type"] extends "hasOne"
+        ? InferHasOneFields<Schema[K]["$dataType"]>
+        : Schema[K]["type"] extends "hasMany"
+        ? InferHasManyFields<Schema[K]["$dataType"]>
+        : Schema[K]["type"] extends "manyToMany"
+        ? InferManyToManyFields<Schema[K]["$dataType"]>
+        : never
+      : Schema[K]["$dataType"]
+  } & InferForeignKeys<Schema>
+>
 
 /**
  * Helper to infer the schema type of a DmlEntity

packages/core/utils/package.json

@@ -69,7 +69,7 @@
   "scripts": {
     "build": "rimraf dist && tsc --build",
     "watch": "tsc --build --watch",
-    "test": "jest --silent=false --bail --maxWorkers=50% --forceExit --testPathIgnorePatterns='/integration-tests/' -- src/**/__tests__/**/*.ts",
+    "test": "jest --silent --bail --maxWorkers=50% --forceExit --testPathIgnorePatterns='/integration-tests/' -- src/**/__tests__/**/*.ts",
     "test:integration": "jest --silent --bail --runInBand --forceExit -- src/**/integration-tests/__tests__/**/*.ts"
   }
 }

packages/core/utils/src/dal/mikro-orm/integration-tests/__tests__/mikro-orm-repository.spec.ts

@@ -120,9 +120,9 @@ class Entity3 {
   }
 }
 
-const Entity1Repository = mikroOrmBaseRepositoryFactory<Entity1>(Entity1)
-const Entity2Repository = mikroOrmBaseRepositoryFactory<Entity2>(Entity2)
-const Entity3Repository = mikroOrmBaseRepositoryFactory<Entity3>(Entity3)
+const Entity1Repository = mikroOrmBaseRepositoryFactory(Entity1)
+const Entity2Repository = mikroOrmBaseRepositoryFactory(Entity2)
+const Entity3Repository = mikroOrmBaseRepositoryFactory(Entity3)
 
 describe("mikroOrmRepository", () => {
   let orm!: MikroORM