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

feat(index): Only run the synchronisation in worker/shared mode (#12530)

Browse Source 
* feat(index): Only run the synchronisation in worker/shared mode

* Create dirty-trees-smoke.md
This commit is contained in:
Adrien de Peretti
2025-05-19 14:20:51 +02:00
committed by GitHub
parent ac49eb9a6c
commit dd66720404
2 changed files with 30 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
packages/modules/index/src/services/index-module-service.ts
View File

@@ -40,6 +40,8 @@ export default class IndexModuleService
extends ModulesSdkUtils.MedusaService({})
implements IndexTypes.IIndexService
{
#isWorkerMode: boolean = false
private readonly container_: InjectedDependencies
private readonly moduleOptions_: IndexTypes.IndexModuleOptions
@@ -83,6 +85,8 @@ export default class IndexModuleService
this.moduleOptions_ = (moduleDeclaration.options ??
moduleDeclaration) as unknown as IndexTypes.IndexModuleOptions
this.#isWorkerMode = moduleDeclaration.worker_mode !== "server"
const {
[Modules.EVENT_BUS]: eventBusModuleService,
storageProviderCtr,
@@ -126,22 +130,29 @@ export default class IndexModuleService
await gqlSchemaToTypes(executableSchema!)
this.dataSynchronizer_.onApplicationStart({
schemaObjectRepresentation: this.schemaObjectRepresentation_,
storageProvider: this.storageProvider_,
})
/**
* Only run the data synchronization in worker mode
*/
const configurationChecker = new Configuration({
logger: this.logger_,
schemaObjectRepresentation: this.schemaObjectRepresentation_,
indexMetadataService: this.indexMetadataService_,
indexSyncService: this.indexSyncService_,
dataSynchronizer: this.dataSynchronizer_,
})
const entitiesMetadataChanged = await configurationChecker.checkChanges()
if (this.#isWorkerMode) {
this.dataSynchronizer_.onApplicationStart({
schemaObjectRepresentation: this.schemaObjectRepresentation_,
storageProvider: this.storageProvider_,
})
if (entitiesMetadataChanged.length) {
await this.dataSynchronizer_.syncEntities(entitiesMetadataChanged)
const configurationChecker = new Configuration({
logger: this.logger_,
schemaObjectRepresentation: this.schemaObjectRepresentation_,
indexMetadataService: this.indexMetadataService_,
indexSyncService: this.indexSyncService_,
dataSynchronizer: this.dataSynchronizer_,
})
const entitiesMetadataChanged =
await configurationChecker.checkChanges()
if (entitiesMetadataChanged.length) {
await this.dataSynchronizer_.syncEntities(entitiesMetadataChanged)
}
}
} catch (e) {
this.logger_.error(e)