From 22bea2724d48f7635f96b7c229c3084dee70b37a Mon Sep 17 00:00:00 2001
From: Kasper Fabricius Kristensen
 <45367945+kasperkristensen@users.noreply.github.com>
Date: Thu, 23 Nov 2023 17:33:51 +0000
Subject: [PATCH] fix(medusa): Normalize subscriber paths (#5703)

---
 .changeset/beige-zebras-explain.md     | 5 +++++
 packages/medusa/src/loaders/plugins.ts | 7 +++----
 2 files changed, 8 insertions(+), 4 deletions(-)
 create mode 100644 .changeset/beige-zebras-explain.md

diff --git a/.changeset/beige-zebras-explain.md b/.changeset/beige-zebras-explain.md
new file mode 100644
index 0000000000..8c1647787c
--- /dev/null
+++ b/.changeset/beige-zebras-explain.md
@@ -0,0 +1,5 @@
+---
+"@medusajs/medusa": patch
+---
+
+fix(medusa): Exclude subscribers correctly on Windows
diff --git a/packages/medusa/src/loaders/plugins.ts b/packages/medusa/src/loaders/plugins.ts
index a5db6bc287..47fbeb172f 100644
--- a/packages/medusa/src/loaders/plugins.ts
+++ b/packages/medusa/src/loaders/plugins.ts
@@ -579,8 +579,6 @@ async function registerSubscribers(
   container: MedusaContainer,
   activityId: string
 ): Promise<void> {
-  const exclude: string[] = []
-
   const loadedFiles = await new SubscriberLoader(
     path.join(pluginDetails.resolve, "subscribers"),
     container,
@@ -591,11 +589,12 @@ async function registerSubscribers(
   /**
    * Exclude any files that have already been loaded by the subscriber loader
    */
-  exclude.push(...(loadedFiles ?? []))
+  const normalizedLoadedFiles =
+    loadedFiles?.map((file) => file.replace(/\\/g, "/")) ?? []
 
   const files = glob.sync(`${pluginDetails.resolve}/subscribers/*.js`, {})
   files
-    .filter((file) => !exclude.includes(file))
+    .filter((file) => !normalizedLoadedFiles.includes(file))
     .forEach((fn) => {
       const loaded = require(fn).default