82 lines
1.7 KiB
JavaScript
82 lines
1.7 KiB
JavaScript
const path = require("path")
|
|
const express = require("express")
|
|
const getPort = require("get-port")
|
|
const { isObject } = require("@medusajs/framework/utils")
|
|
const { setContainer } = require("./use-container")
|
|
const { setPort, setExpressServer } = require("./use-api")
|
|
|
|
async function bootstrapApp({ cwd, env = {} } = {}) {
|
|
const app = express()
|
|
|
|
if (isObject(env)) {
|
|
Object.entries(env).forEach(([k, v]) => (process.env[k] = v))
|
|
}
|
|
|
|
const loaders = require("@medusajs/medusa/dist/loaders").default
|
|
|
|
const { container, shutdown } = await loaders({
|
|
directory: path.resolve(cwd || process.cwd()),
|
|
expressApp: app,
|
|
isTest: false,
|
|
})
|
|
|
|
const PORT = await getPort()
|
|
|
|
return {
|
|
shutdown,
|
|
container,
|
|
app,
|
|
port: PORT,
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
bootstrapApp,
|
|
startBootstrapApp: async ({
|
|
cwd,
|
|
env = {},
|
|
skipExpressListen = false,
|
|
} = {}) => {
|
|
const {
|
|
app,
|
|
port,
|
|
container,
|
|
shutdown: medusaShutdown,
|
|
} = await bootstrapApp({
|
|
cwd,
|
|
env,
|
|
})
|
|
let expressServer
|
|
|
|
setContainer(container)
|
|
|
|
if (skipExpressListen) {
|
|
return
|
|
}
|
|
|
|
const shutdown = async () => {
|
|
await Promise.all([expressServer.close(), medusaShutdown()])
|
|
|
|
if (typeof global !== "undefined" && global?.gc) {
|
|
global.gc()
|
|
}
|
|
}
|
|
|
|
return await new Promise((resolve, reject) => {
|
|
expressServer = app
|
|
.listen(port)
|
|
.on("error", async (err) => {
|
|
await shutdown()
|
|
return reject(err)
|
|
})
|
|
.on("listening", () => {
|
|
setPort(port)
|
|
process.send(port)
|
|
resolve(shutdown)
|
|
})
|
|
|
|
setExpressServer(expressServer)
|
|
})
|
|
},
|
|
}
|