Files
medusa-store/packages/core/modules-sdk/src/definitions.ts
Adrien de Peretti a33aebd895 feat(index): full sync operations (#11178)
Closes: FRMW-2892, FRMW-2893

**What**
Wired up the building block that we merged previously in order to manage data synchronization. The flow is as follow
- On application start
  - Build schema object representation from configuration
  - Check configuration changes
    - if new entities configured
      - Data synchronizer initialize orchestrator and start sync
        - for each entity
          - acquire lock
          - mark existing data as staled
          - sync all data by batch
          - marked them not staled anymore
          - acknowledge each processed batch and renew lock
          - update metadata with last synced cursor for entity X
          - release lock
      - remove all remaining staled data
    - if any entities removed from last configuration
      - remove the index data and relations

Co-authored-by: Carlos R. L. Rodrigues <37986729+carlos-r-l-rodrigues@users.noreply.github.com>
2025-02-05 16:49:18 +00:00

300 lines
8.1 KiB
TypeScript

import { ModuleDefinition } from "@medusajs/types"
import {
ContainerRegistrationKeys,
MODULE_PACKAGE_NAMES,
Modules,
upperCaseFirst,
} from "@medusajs/utils"
import { MODULE_SCOPE } from "./types"
export const ModulesDefinition: {
[key: string]: ModuleDefinition
} = {
[Modules.EVENT_BUS]: {
key: Modules.EVENT_BUS,
defaultPackage: MODULE_PACKAGE_NAMES[Modules.EVENT_BUS],
label: upperCaseFirst(Modules.EVENT_BUS),
isRequired: true,
isQueryable: false,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.STOCK_LOCATION]: {
key: Modules.STOCK_LOCATION,
defaultPackage: false,
label: upperCaseFirst(Modules.STOCK_LOCATION),
isRequired: false,
isQueryable: true,
dependencies: [Modules.EVENT_BUS],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.INVENTORY]: {
key: Modules.INVENTORY,
defaultPackage: false,
label: upperCaseFirst(Modules.INVENTORY),
isRequired: false,
isQueryable: true,
dependencies: [Modules.EVENT_BUS],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.CACHE]: {
key: Modules.CACHE,
defaultPackage: MODULE_PACKAGE_NAMES[Modules.CACHE],
label: upperCaseFirst(Modules.CACHE),
isRequired: true,
isQueryable: false,
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.PRODUCT]: {
key: Modules.PRODUCT,
defaultPackage: false,
label: upperCaseFirst(Modules.PRODUCT),
isRequired: false,
isQueryable: true,
dependencies: [Modules.EVENT_BUS, ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.PRICING]: {
key: Modules.PRICING,
defaultPackage: false,
label: upperCaseFirst(Modules.PRICING),
isRequired: false,
isQueryable: true,
dependencies: [Modules.EVENT_BUS, ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.PROMOTION]: {
key: Modules.PROMOTION,
defaultPackage: false,
label: upperCaseFirst(Modules.PROMOTION),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.AUTH]: {
key: Modules.AUTH,
defaultPackage: false,
label: upperCaseFirst(Modules.AUTH),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER, Modules.CACHE],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.WORKFLOW_ENGINE]: {
key: Modules.WORKFLOW_ENGINE,
defaultPackage: false,
label: upperCaseFirst(Modules.WORKFLOW_ENGINE),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
__passSharedContainer: true,
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.SALES_CHANNEL]: {
key: Modules.SALES_CHANNEL,
defaultPackage: false,
label: upperCaseFirst(Modules.SALES_CHANNEL),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.FULFILLMENT]: {
key: Modules.FULFILLMENT,
defaultPackage: false,
label: upperCaseFirst(Modules.FULFILLMENT),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER, Modules.EVENT_BUS],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.CART]: {
key: Modules.CART,
defaultPackage: false,
label: upperCaseFirst(Modules.CART),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.CUSTOMER]: {
key: Modules.CUSTOMER,
defaultPackage: false,
label: upperCaseFirst(Modules.CUSTOMER),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.PAYMENT]: {
key: Modules.PAYMENT,
defaultPackage: false,
label: upperCaseFirst(Modules.PAYMENT),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.USER]: {
key: Modules.USER,
defaultPackage: false,
label: upperCaseFirst(Modules.USER),
isRequired: false,
isQueryable: true,
dependencies: [Modules.EVENT_BUS, ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.REGION]: {
key: Modules.REGION,
defaultPackage: false,
label: upperCaseFirst(Modules.REGION),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.ORDER]: {
key: Modules.ORDER,
defaultPackage: false,
label: upperCaseFirst(Modules.ORDER),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER, Modules.EVENT_BUS],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.TAX]: {
key: Modules.TAX,
defaultPackage: false,
label: upperCaseFirst(Modules.TAX),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER, Modules.EVENT_BUS],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.API_KEY]: {
key: Modules.API_KEY,
defaultPackage: false,
label: upperCaseFirst(Modules.API_KEY),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.STORE]: {
key: Modules.STORE,
defaultPackage: false,
label: upperCaseFirst(Modules.STORE),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.CURRENCY]: {
key: Modules.CURRENCY,
defaultPackage: false,
label: upperCaseFirst(Modules.CURRENCY),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.FILE]: {
key: Modules.FILE,
defaultPackage: false,
label: upperCaseFirst(Modules.FILE),
isRequired: false,
isQueryable: true,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.NOTIFICATION]: {
key: Modules.NOTIFICATION,
defaultPackage: false,
label: upperCaseFirst(Modules.NOTIFICATION),
isRequired: false,
isQueryable: true,
dependencies: [Modules.EVENT_BUS, ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.INDEX]: {
key: Modules.INDEX,
defaultPackage: false,
label: upperCaseFirst(Modules.INDEX),
isRequired: false,
isQueryable: false,
dependencies: [
Modules.EVENT_BUS,
Modules.LOCKING,
ContainerRegistrationKeys.LOGGER,
ContainerRegistrationKeys.REMOTE_QUERY,
ContainerRegistrationKeys.QUERY,
],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
[Modules.LOCKING]: {
key: Modules.LOCKING,
defaultPackage: false,
label: upperCaseFirst(Modules.LOCKING),
isRequired: false,
isQueryable: false,
dependencies: [ContainerRegistrationKeys.LOGGER],
defaultModuleDeclaration: {
scope: MODULE_SCOPE.INTERNAL,
},
},
}
export const MODULE_DEFINITIONS: ModuleDefinition[] =
Object.values(ModulesDefinition)
export default MODULE_DEFINITIONS