feat: sales channel module

.changeset/flat-bees-laugh.md

@@ -0,0 +1,8 @@
+---
+"@medusajs/core-flows": patch
+"@medusajs/modules-sdk": patch
+"@medusajs/medusa": patch
+"@medusajs/types": patch
+---
+
+feat: Sales Channel module

integration-tests/plugins/medusa-config.js

@@ -66,5 +66,10 @@ module.exports = {
       resources: "shared",
       resolve: "@medusajs/pricing",
     },
+    [Modules.SALES_CHANNEL]: {
+      scope: "internal",
+      resources: "shared",
+      resolve: "@medusajs/sales-channel",
+    },
   },
 }

packages/core-flows/src/handlers/cart/attach-cart-to-sales-channel.ts

@@ -1,5 +1,6 @@
 import { MedusaV2Flag } from "@medusajs/utils"
 import { WorkflowArguments } from "@medusajs/workflows-sdk"
+import { Modules } from "@medusajs/modules-sdk"
 
 type HandlerInputData = {
   cart: {
@@ -30,10 +31,10 @@ export async function attachCartToSalesChannel({
   const salesChannel = data[Aliases.SalesChannel]
 
   await remoteLink.create({
-    cartService: {
+    [Modules.CART]: {
       cart_id: cart.id,
     },
-    salesChannelService: {
+    [Modules.SALES_CHANNEL]: {
       sales_channel_id: salesChannel.sales_channel_id,
     },
   })

packages/core-flows/src/handlers/cart/detach-cart-from-sales-channel.ts

@@ -1,5 +1,6 @@
 import { MedusaV2Flag } from "@medusajs/utils"
 import { WorkflowArguments } from "@medusajs/workflows-sdk"
+import { Modules } from "@medusajs/modules-sdk"
 
 type HandlerInputData = {
   cart: {
@@ -30,10 +31,10 @@ export async function detachCartFromSalesChannel({
   const salesChannel = data[Aliases.SalesChannel]
 
   await remoteLink.dismiss({
-    cartService: {
+    [Modules.CART]: {
       cart_id: cart.id,
     },
-    salesChannelService: {
+    [Modules.SALES_CHANNEL]: {
       sales_channel_id: salesChannel.sales_channel_id,
     },
   })

packages/core-flows/src/handlers/product/attach-sales-channel-to-products.ts

@@ -51,7 +51,7 @@ export async function attachSalesChannelToProducts({
           [Modules.PRODUCT]: {
             product_id: id,
           },
-          salesChannelService: {
+          [Modules.SALES_CHANNEL]: {
             sales_channel_id: salesChannelId,
           },
         })

packages/core-flows/src/handlers/product/detach-sales-channel-from-products.ts

@@ -49,7 +49,7 @@ export async function detachSalesChannelFromProducts({
             [Modules.PRODUCT]: {
               product_id: id,
             },
-            salesChannelService: {
+            [Modules.SALES_CHANNEL]: {
               sales_channel_id: salesChannelId,
             },
           })

packages/link-modules/src/definitions/cart-sales-channel.ts

@@ -1,5 +1,6 @@
 import { ModuleJoinerConfig } from "@medusajs/types"
 import { LINKS } from "../links"
+import { Modules } from "@medusajs/modules-sdk"
 
 export const CartSalesChannel: ModuleJoinerConfig = {
   serviceName: LINKS.CartSalesChannel,
@@ -19,14 +20,14 @@ export const CartSalesChannel: ModuleJoinerConfig = {
   primaryKeys: ["id", "cart_id", "sales_channel_id"],
   relationships: [
     {
-      serviceName: "cartService",
+      serviceName: Modules.CART,
       isInternalService: true,
       primaryKey: "id",
       foreignKey: "cart_id",
       alias: "cart",
     },
     {
-      serviceName: "salesChannelService",
+      serviceName: Modules.SALES_CHANNEL,
       isInternalService: true,
       primaryKey: "id",
       foreignKey: "sales_channel_id",
@@ -35,7 +36,7 @@ export const CartSalesChannel: ModuleJoinerConfig = {
   ],
   extends: [
     {
-      serviceName: "cartService",
+      serviceName: Modules.CART,
       fieldAlias: {
         sales_channel: "sales_channel_link.sales_channel",
       },
@@ -48,7 +49,7 @@ export const CartSalesChannel: ModuleJoinerConfig = {
       },
     },
     {
-      serviceName: "salesChannelService",
+      serviceName: Modules.SALES_CHANNEL,
       fieldAlias: {
         carts: "cart_link.cart",
       },

packages/link-modules/src/definitions/product-sales-channel.ts

@@ -26,7 +26,7 @@ export const ProductSalesChannel: ModuleJoinerConfig = {
       alias: "product",
     },
     {
-      serviceName: "salesChannelService",
+      serviceName: Modules.SALES_CHANNEL,
       isInternalService: true,
       primaryKey: "id",
       foreignKey: "sales_channel_id",
@@ -48,7 +48,7 @@ export const ProductSalesChannel: ModuleJoinerConfig = {
       },
     },
     {
-      serviceName: "salesChannelService",
+      serviceName: Modules.SALES_CHANNEL,
       relationship: {
         serviceName: LINKS.ProductSalesChannel,
         isInternalService: true,

packages/link-modules/src/links.ts

@@ -25,25 +25,25 @@ export const LINKS = {
   ProductSalesChannel: composeLinkName(
     Modules.PRODUCT,
     "product_id",
-    "salesChannelService",
+    Modules.SALES_CHANNEL,
     "sales_channel_id"
   ),
   CartSalesChannel: composeLinkName(
-    "cartService",
+    Modules.CART,
     "cart_id",
-    "salesChannelService",
+    Modules.SALES_CHANNEL,
     "sales_channel_id"
   ),
   OrderSalesChannel: composeLinkName(
     "orderService",
     "order_id",
-    "salesChannelService",
+    Modules.SALES_CHANNEL,
     "sales_channel_id"
   ),
   PublishableApiKeySalesChannel: composeLinkName(
     "publishableApiKeyService",
     "publishable_key_id",
-    "salesChannelService",
+    Modules.SALES_CHANNEL,
     "sales_channel_id"
   ),
 }

packages/medusa/src/joiner-configs/cart-service.ts

@@ -4,7 +4,7 @@ import { ModuleJoinerConfig } from "@medusajs/types"
 import { Cart } from "../models"
 
 export default {
-  serviceName: "cartService",
+  serviceName: Modules.CART,
   primaryKeys: ["id"],
   linkableKeys: { cart_id: "Cart" },
   alias: {

packages/medusa/src/joiner-configs/index.ts

@@ -1,6 +1,5 @@
 export * as cart from "./cart-service"
 export * as customer from "./customer-service"
 export * as region from "./region-service"
-export * as salesChannel from "./sales-channel-service"
 export * as shippingProfile from "./shipping-profile-service"
 export * as publishableApiKey from "./publishable-api-key-service"

packages/medusa/src/services/cart.ts

@@ -69,7 +69,7 @@ import { ShippingMethodRepository } from "../repositories/shipping-method"
 import { PaymentSessionInput } from "../types/payment"
 import { validateEmail } from "../utils/is-email"
 import { RemoteQueryFunction } from "@medusajs/types"
-import { RemoteLink } from "@medusajs/modules-sdk"
+import { Modules, RemoteLink } from "@medusajs/modules-sdk"
 
 type InjectedDependencies = {
   manager: EntityManager
@@ -501,10 +501,10 @@ class CartService extends TransactionBaseService {
           )
 
           await this.remoteLink_.create({
-            cartService: {
+            [Modules.CART]: {
               cart_id: cart.id,
             },
-            salesChannelService: {
+            [Modules.SALES_CHANNEL]: {
               sales_channel_id: salesChannel.id,
             },
           })
@@ -1294,20 +1294,20 @@ class CartService extends TransactionBaseService {
           if (this.featureFlagRouter_.isFeatureEnabled(MedusaV2Flag.key)) {
             if (cart.sales_channel_id) {
               await this.remoteLink_.dismiss({
-                cartService: {
+                [Modules.CART]: {
                   cart_id: cart.id,
                 },
-                salesChannelService: {
+                [Modules.SALES_CHANNEL]: {
                   sales_channel_id: cart.sales_channel_id,
                 },
               })
             }
 
             await this.remoteLink_.create({
-              cartService: {
+              [Modules.CART]: {
                 cart_id: cart.id,
               },
-              salesChannelService: {
+              [Modules.SALES_CHANNEL]: {
                 sales_channel_id: salesChannel.id,
               },
             })

packages/modules-sdk/src/definitions.ts

@@ -15,6 +15,7 @@ export enum Modules {
   PRICING = "pricingService",
   PROMOTION = "promotion",
   AUTHENTICATION = "authentication",
+  SALES_CHANNEL = "salesChannel",
   CART = "cart",
   PAYMENT = "payment",
 }
@@ -28,6 +29,7 @@ export enum ModuleRegistrationName {
   PRICING = "pricingModuleService",
   PROMOTION = "promotionModuleService",
   AUTHENTICATION = "authenticationModuleService",
+  SALES_CHANNEL = "salesChannelModuleService",
   CART = "cartModuleService",
   PAYMENT = "paymentModuleService",
 }
@@ -41,6 +43,7 @@ export const MODULE_PACKAGE_NAMES = {
   [Modules.PRICING]: "@medusajs/pricing",
   [Modules.PROMOTION]: "@medusajs/promotion",
   [Modules.AUTHENTICATION]: "@medusajs/authentication",
+  [Modules.SALES_CHANNEL]: "@medusajs/sales-channel",
   [Modules.CART]: "@medusajs/cart",
   [Modules.PAYMENT]: "@medusajs/payment",
 }
@@ -160,6 +163,20 @@ export const ModulesDefinition: { [key: string | Modules]: ModuleDefinition } =
         resources: MODULE_RESOURCE_TYPE.SHARED,
       },
     },
+    [Modules.SALES_CHANNEL]: {
+      key: Modules.SALES_CHANNEL,
+      registrationName: ModuleRegistrationName.SALES_CHANNEL,
+      defaultPackage: false,
+      label: upperCaseFirst(ModuleRegistrationName.SALES_CHANNEL),
+      isRequired: false,
+      canOverride: true,
+      isQueryable: true,
+      dependencies: ["logger"],
+      defaultModuleDeclaration: {
+        scope: MODULE_SCOPE.INTERNAL,
+        resources: MODULE_RESOURCE_TYPE.SHARED,
+      },
+    },
     [Modules.CART]: {
       key: Modules.CART,
       registrationName: ModuleRegistrationName.CART,

packages/sales-channel/.gitignore

@@ -0,0 +1,6 @@
+/dist
+node_modules
+.DS_store
+.env*
+.env
+*.sql

packages/sales-channel/README.md

@@ -0,0 +1,3 @@
+# Sales Channel Module
+
+Sales Channel module enables management of sales channels that are used for grouping Products/Carts/Orders etc.

packages/sales-channel/integration-tests/__fixtures__/index.ts

@@ -0,0 +1,40 @@
+import { SqlEntityManager } from "@mikro-orm/postgresql"
+import { SalesChannel } from "@models"
+
+const salesChannelData = [
+  {
+    id: "channel-1",
+    name: "Channel 1",
+    description: "Channel description 1",
+    is_disabled: false,
+  },
+  {
+    id: "channel-2",
+    name: "Channel 2",
+    description: "Channel description 2",
+    is_disabled: false,
+  },
+  {
+    id: "channel-3",
+    name: "Channel 3",
+    description: "Channel description 3",
+    is_disabled: true,
+  },
+]
+
+export async function createSalesChannels(
+  manager: SqlEntityManager,
+  channelData: any[] = salesChannelData
+): Promise<SalesChannel[]> {
+  const channels: SalesChannel[] = []
+
+  for (let data of channelData) {
+    const sc = manager.create(SalesChannel, data)
+
+    channels.push(sc)
+  }
+
+  await manager.persistAndFlush(channels)
+
+  return channels
+}