asyavee/medusa-store
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

chore: remove container registration name (#9137)

Browse Source
This commit is contained in:
Carlos R. L. Rodrigues
2024-09-16 06:22:24 -03:00
committed by GitHub
parent ab4a422fc8
commit 950cf9af79
421 changed files with 1528 additions and 2496 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/core/workflows-sdk/src/helper/workflow-export.ts
+3 -3
View File
@@ -9,9 +9,9 @@ import {
import { Context, LoadedModule, MedusaContainer } from "@medusajs/types"
import {
ContainerRegistrationKeys,
isPresent,
MedusaContextType,
ModuleRegistrationName,
Modules,
isPresent,
} from "@medusajs/utils"
import { EOL } from "os"
import { ulid } from "ulid"
@@ -535,7 +535,7 @@ function attachOnFinishReleaseEvents(
await onFinish?.(args)
const eventBusService = (flow.container as MedusaContainer).resolve(
ModuleRegistrationName.EVENT_BUS,
Modules.EVENT_BUS,
{ allowUnregistered: true }
)
packages/core/workflows-sdk/src/utils/composer/__tests__/compose.ts
+7 -11
View File
@@ -5,7 +5,7 @@ import {
WorkflowScheduler,
} from "@medusajs/orchestration"
import {
ModuleRegistrationName,
Modules,
composeMessage,
createMedusaContainer,
promiseAll,
@@ -2105,7 +2105,7 @@ describe("Workflow composer", function () {
it("should emit grouped events once the workflow is executed and finished", async () => {
const container = createMedusaContainer()
container.register({
[ModuleRegistrationName.EVENT_BUS]: asValue({
[Modules.EVENT_BUS]: asValue({
releaseGroupedEvents: jest
.fn()
.mockImplementation(() => Promise.resolve()),
@@ -2117,9 +2117,7 @@ describe("Workflow composer", function () {
.fn()
.mockImplementation(
async (input, { context: stepContext, container }) => {
const eventBusService = container.resolve(
ModuleRegistrationName.EVENT_BUS
)
const eventBusService = container.resolve(Modules.EVENT_BUS)
await eventBusService.emit(
"event1",
@@ -2149,7 +2147,7 @@ describe("Workflow composer", function () {
expect(mockStep1Fn).toHaveBeenCalledTimes(1)
expect(mockStep1Fn.mock.calls[0]).toHaveLength(2)
const eventBusMock = container.resolve(ModuleRegistrationName.EVENT_BUS)
const eventBusMock = container.resolve(Modules.EVENT_BUS)
expect(eventBusMock.emit).toHaveBeenCalledTimes(1)
expect(eventBusMock.emit.mock.calls[0][0]).toEqual("event1")
@@ -2162,7 +2160,7 @@ describe("Workflow composer", function () {
it("should clear grouped events on fail state", async () => {
const container = createMedusaContainer()
container.register({
[ModuleRegistrationName.EVENT_BUS]: asValue({
[Modules.EVENT_BUS]: asValue({
releaseGroupedEvents: jest
.fn()
.mockImplementation(() => Promise.resolve()),
@@ -2177,9 +2175,7 @@ describe("Workflow composer", function () {
.fn()
.mockImplementation(
async (input, { context: stepContext, container }) => {
const eventBusService = container.resolve(
ModuleRegistrationName.EVENT_BUS
)
const eventBusService = container.resolve(Modules.EVENT_BUS)
await eventBusService.emit(
"event1",
@@ -2213,7 +2209,7 @@ describe("Workflow composer", function () {
throwOnError: false,
})
const eventBusMock = container.resolve(ModuleRegistrationName.EVENT_BUS)
const eventBusMock = container.resolve(Modules.EVENT_BUS)
expect(eventBusMock.emit).toHaveBeenCalledTimes(1)
expect(eventBusMock.releaseGroupedEvents).toHaveBeenCalledTimes(0)