82a176e30e
**What** - Better error handling and error message - update deps management and dynamic import/require - Pass a new flag to the modules loaders for the module loaders to be able to act depending on it. In that case, the module can determine what should be run or not. e.g in the workflow engine redis, when we are only partially loading the module, we do not want to set the Distributed transaction storage
81 lines
2.0 KiB
TypeScript
81 lines
2.0 KiB
TypeScript
import {
|
|
ExternalModuleDeclaration,
|
|
InternalModuleDeclaration,
|
|
ModuleJoinerConfig,
|
|
} from "@medusajs/types"
|
|
import {
|
|
ContainerRegistrationKeys,
|
|
ModulesSdkUtils,
|
|
promiseAll,
|
|
} from "@medusajs/utils"
|
|
|
|
export interface InitModulesOptions {
|
|
injectedDependencies?: Record<string, unknown>
|
|
databaseConfig: {
|
|
clientUrl: string
|
|
schema?: string
|
|
}
|
|
modulesConfig: {
|
|
[key: string]:
|
|
| string
|
|
| boolean
|
|
| Partial<InternalModuleDeclaration | ExternalModuleDeclaration>
|
|
}
|
|
joinerConfig?: ModuleJoinerConfig[]
|
|
preventConnectionDestroyWarning?: boolean
|
|
}
|
|
|
|
export async function initModules({
|
|
injectedDependencies,
|
|
databaseConfig,
|
|
modulesConfig,
|
|
joinerConfig,
|
|
preventConnectionDestroyWarning = false,
|
|
}: InitModulesOptions) {
|
|
const moduleSdkImports = require("@medusajs/modules-sdk")
|
|
|
|
injectedDependencies ??= {}
|
|
|
|
let sharedPgConnection =
|
|
injectedDependencies?.[ContainerRegistrationKeys.PG_CONNECTION]
|
|
|
|
let shouldDestroyConnectionAutomatically = !sharedPgConnection
|
|
if (!sharedPgConnection) {
|
|
sharedPgConnection = ModulesSdkUtils.createPgConnection({
|
|
clientUrl: databaseConfig.clientUrl,
|
|
schema: databaseConfig.schema,
|
|
})
|
|
|
|
injectedDependencies[ContainerRegistrationKeys.PG_CONNECTION] =
|
|
sharedPgConnection
|
|
}
|
|
|
|
const medusaApp = await moduleSdkImports.MedusaApp({
|
|
modulesConfig,
|
|
servicesConfig: joinerConfig,
|
|
injectedDependencies,
|
|
})
|
|
|
|
async function shutdown() {
|
|
if (shouldDestroyConnectionAutomatically) {
|
|
await promiseAll([
|
|
(sharedPgConnection as any).context?.destroy(),
|
|
(sharedPgConnection as any).destroy(),
|
|
medusaApp.onApplicationShutdown(),
|
|
])
|
|
} else {
|
|
if (!preventConnectionDestroyWarning) {
|
|
console.info(
|
|
`You are using a custom shared connection. The connection won't be destroyed automatically.`
|
|
)
|
|
}
|
|
}
|
|
moduleSdkImports.MedusaModule.clearInstances()
|
|
}
|
|
|
|
return {
|
|
medusaApp,
|
|
shutdown,
|
|
}
|
|
}
|