chore: update mikro-orm to 6.6.12 (#15018)

* chore: update mikro-orm to 6.6.10

* fix refund test

* fix

* fix alias bug

* fix error related to autoJoinRefsForFilters

* update to latest

Author: shahednasser

.changeset/rare-snakes-itch.md

@@ -0,0 +1,6 @@
+---
+"@medusajs/utils": patch
+"@medusajs/deps": patch
+---
+
+chore: update mikro-orm to 6.6.10

packages/core/utils/src/dal/mikro-orm/mikro-orm-create-connection.ts

@@ -113,6 +113,13 @@ export async function mikroOrmCreateConnection(
     useBatchUpdates: true,
     implicitTransactions: false,
     ignoreUndefinedInQuery: true,
+    // Introduced in MikroORM 6.5.0: when enabled, MikroORM auto-joins referenced entities
+    // (e.g. INNER JOINs PaymentSession when querying Payment) to apply their global filters
+    // (e.g. softDeletable). For non-nullable FKs this uses INNER JOIN, silently excluding
+    // owning entities (e.g. Payment) when the referenced entity (e.g. PaymentSession) is
+    // soft-deleted. Medusa was designed around MikroORM 6.4.x where this didn't exist, so
+    // we disable it to preserve the expected behavior.
+    autoJoinRefsForFilters: false,
     batchSize: 100,
     metadataCache: {
       enabled: true,

packages/core/utils/src/modules-sdk/medusa-internal-service.ts

@@ -55,12 +55,9 @@ export function registerInternalServiceEventSubscriber(
     context.manager) as EntityManager
   if (manager && subscriber) {
     const subscriberInstance = new subscriber(context)
-    // There is no public API to unregister subscribers or check if a subscriber is already
-    // registered. This means that we need to manually check if the subscriber is already
-    // registered, otherwise we will register the same subscriber twice.
-    const hasListeners = (manager.getEventManager() as any).subscribers.some(
-      (s) => s.constructor.name === subscriberInstance.constructor.name
-    )
+    const hasListeners = Array.from(
+      manager.getEventManager().getSubscribers()
+    ).some((s) => s.constructor.name === subscriberInstance.constructor.name)
     if (!hasListeners) {
       manager.getEventManager().registerSubscriber(subscriberInstance)
     }

packages/deps/package.json

@@ -39,11 +39,11 @@
     "build": "yarn run -T rimraf dist && yarn run -T tsc --build"
   },
   "dependencies": {
-    "@mikro-orm/cli": "6.4.16",
-    "@mikro-orm/core": "6.4.16",
-    "@mikro-orm/knex": "6.4.16",
-    "@mikro-orm/migrations": "6.4.16",
-    "@mikro-orm/postgresql": "6.4.16",
+    "@mikro-orm/cli": "6.6.12",
+    "@mikro-orm/core": "6.6.12",
+    "@mikro-orm/knex": "6.6.12",
+    "@mikro-orm/migrations": "6.6.12",
+    "@mikro-orm/postgresql": "6.6.12",
     "@opentelemetry/api": "^1.9.0",
     "@opentelemetry/instrumentation-pg": "^0.52.0",
     "@opentelemetry/resources": "^2.0.0",

packages/modules/order/src/utils/base-repository-find.ts

@@ -1,6 +1,6 @@
 import { Constructor, Context, DAL } from "@medusajs/framework/types"
 import { MikroOrmBaseRepository, toMikroORMEntity } from "@medusajs/framework/utils"
-import { LoadStrategy } from "@medusajs/framework/mikro-orm/core"
+import { LoadStrategy, raw } from "@medusajs/framework/mikro-orm/core"
 import { Order, OrderClaim, OrderLineItemAdjustment } from "@models"
 
 import { mapRepositoryToOrderModel } from "."
@@ -116,7 +116,13 @@ export function setFindMethods<T>(klass: Constructor<T>, entity: any) {
     const version = config.where?.version ?? defaultVersion
     delete config.where?.version
 
-    configurePopulateWhere(config, isRelatedEntity, version)
+    configurePopulateWhere(
+      config,
+      isRelatedEntity,
+      version,
+      strategy === LoadStrategy.SELECT_IN,
+      manager
+    )
 
     let loadAdjustments = false
     if (config.options.populate.includes("items.item.adjustments")) {
@@ -253,11 +259,16 @@ export function setFindMethods<T>(klass: Constructor<T>, entity: any) {
       })
     }
 
-    const [result, count] = await manager.findAndCount(
-      this.entity,
-      config.where,
-      config.options
-    )
+    // The count query uses JOINED strategy internally (MikroORM 6.6+), but
+    // populateWhere version subqueries reference SELECT_IN aliases (e.g. "o0")
+    // that don't exist in the JOINED count context. Since version filters only
+    // control which items to load (not which root entities to count), we run
+    // find and count separately with different populateWhere options.
+    const countOptions = { ...config.options, populateWhere: undefined }
+    const [result, count] = await Promise.all([
+      manager.find(this.entity, config.where, config.options),
+      manager.count(this.entity, config.where, countOptions),
+    ])
 
     if (loadAdjustments) {
       const orders = !isRelatedEntity
@@ -339,36 +350,65 @@ function configurePopulateWhere(
   config.options.populateWhere ??= {}
   const popWhere = config.options.populateWhere
 
-  // isSelectIn && isRelatedEntity - Order is always the FROM clause (field o0.id)
   if (isRelatedEntity) {
     popWhere.order ??= {}
 
     const popWhereOrder = popWhere.order
 
-    popWhereOrder.version = isSelectIn
-      ? getVersionSubQuery(manager, "o0", "id")
-      : version
+    if (!isSelectIn) {
+      // For JOINED strategy, version is a reference to the order alias (e.g. "o1"."version")
+      // This is trivially true since Order has one row per id, but kept for consistency
+      popWhereOrder.version = version
+    }
+    // For SELECT_IN strategy, the order.version condition is always trivially true
+    // (Order has one row per id) so we skip it entirely
 
     // related entity shipping method
     if (hasRelation("shipping_methods")) {
       popWhere.shipping_methods ??= {}
-      popWhere.shipping_methods.version = isSelectIn
-        ? getVersionSubQuery(manager, "s0")
-        : version
+      if (isSelectIn) {
+        // For MikroORM 6.6.x+, populateWhere conditions for force-joined relations are
+        // embedded as inline JOIN conditions. Use alias callback so [::alias::] gets
+        // replaced with the actual shipping_method alias at query-build time.
+        const fragment = raw(
+          (alias) =>
+            `"${alias}"."version" = (select "_sub0"."version" from "order" as "_sub0" where "_sub0"."id" = "${alias}"."order_id")`
+        )
+        ;(popWhere.shipping_methods as any)[fragment.toString()] = []
+      } else {
+        popWhere.shipping_methods.version = version
+      }
     }
 
     if (hasRelation("items") || hasRelation("order.items")) {
       popWhereOrder.items ??= {}
-      popWhereOrder.items.version = isSelectIn
-        ? getVersionSubQuery(manager, "o0", "id")
-        : version
+      if (isSelectIn) {
+        // In MikroORM 6.6.x+, the global alias counter changed (no longer per-entity-type),
+        // so "o0" no longer exists in the query context for related entity queries.
+        // Instead, use a self-referential raw fragment: the [::alias::] placeholder is
+        // replaced with the order_item's own JOIN alias, and order_item.order_id is used
+        // to look up the order's current version.
+        const fragment = raw(
+          (alias) =>
+            `"${alias}"."version" = (select "_sub0"."version" from "order" as "_sub0" where "_sub0"."id" = "${alias}"."order_id")`
+        )
+        ;(popWhereOrder.items as any)[fragment.toString()] = []
+      } else {
+        popWhereOrder.items.version = version
+      }
     }
 
     if (hasRelation("shipping_methods")) {
       popWhereOrder.shipping_methods ??= {}
-      popWhereOrder.shipping_methods.version = isSelectIn
-        ? getVersionSubQuery(manager, "o0", "id")
-        : version
+      if (isSelectIn) {
+        const fragment = raw(
+          (alias) =>
+            `"${alias}"."version" = (select "_sub0"."version" from "order" as "_sub0" where "_sub0"."id" = "${alias}"."order_id")`
+        )
+        ;(popWhereOrder.shipping_methods as any)[fragment.toString()] = []
+      } else {
+        popWhereOrder.shipping_methods.version = version
+      }
     }
 
     return

packages/modules/pricing/src/repositories/pricing.ts

@@ -51,7 +51,7 @@ export class PricingRepository
     `
     )
     this.#availableAttributes.clear()
-    rows.forEach(({ attribute }) => {
+    rows.forEach(({ attribute }: { attribute: string }) => {
       this.#availableAttributes.add(attribute)
     })
   }
@@ -72,11 +72,11 @@ export class PricingRepository
     const context = { ...(pricingContext.context || {}) }
 
     // Extract quantity and currency from context
-    const quantity = context.quantity
+    const quantity = context.quantity as number | undefined
     delete context.quantity
 
     // Currency code is required
-    const currencyCode = context.currency_code
+    const currencyCode = context.currency_code as string | undefined
     delete context.currency_code
 
     if (!currencyCode) {