From b5935782b77e35ad802e778985caf3143387507d Mon Sep 17 00:00:00 2001 From: "John.R" Date: Wed, 15 May 2024 15:01:20 +0200 Subject: [PATCH 1/3] fix: is full sync done checl --- ps_eventbus.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ps_eventbus.php b/ps_eventbus.php index 89fec34c..48f41000 100644 --- a/ps_eventbus.php +++ b/ps_eventbus.php @@ -1552,7 +1552,7 @@ public function hookActionObjectSpecificPriceDeleteAfter($parameters) */ private function sendLiveSync(string $shopContent, int $shopContentId, string $action) { - if ($this->isFullSyncDone($shopContent)) { + if (!$this->isFullSyncDone($shopContent)) { return; } } @@ -1609,7 +1609,7 @@ private function insertIncrementalSyncObject($objectId, $type, $date, $shopId, $ $languagesIsoCodes = $languageRepository->getLanguagesIsoCodes(); foreach ($languagesIsoCodes as $languagesIsoCode) { - if ($this->isFullSyncDone($type, $languagesIsoCode)) { + if (!$this->isFullSyncDone($type, $languagesIsoCode)) { return; } @@ -1618,7 +1618,7 @@ private function insertIncrementalSyncObject($objectId, $type, $date, $shopId, $ } else { $languagesIsoCode = $languageRepository->getDefaultLanguageIsoCode(); - if ($this->isFullSyncDone($type, $languagesIsoCode)) { + if (!$this->isFullSyncDone($type, $languagesIsoCode)) { return; } From 1128f11a3f686012ddbfff01260862798d00379d Mon Sep 17 00:00:00 2001 From: "John.R" Date: Wed, 15 May 2024 15:03:34 +0200 Subject: [PATCH 2/3] fix: another version of check --- ps_eventbus.php | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/ps_eventbus.php b/ps_eventbus.php index 48f41000..8422556c 100644 --- a/ps_eventbus.php +++ b/ps_eventbus.php @@ -1609,20 +1609,16 @@ private function insertIncrementalSyncObject($objectId, $type, $date, $shopId, $ $languagesIsoCodes = $languageRepository->getLanguagesIsoCodes(); foreach ($languagesIsoCodes as $languagesIsoCode) { - if (!$this->isFullSyncDone($type, $languagesIsoCode)) { - return; + if ($this->isFullSyncDone($type, $languagesIsoCode)) { + $incrementalSyncRepository->insertIncrementalObject($objectId, $type, $date, $shopId, $languagesIsoCode); } - - $incrementalSyncRepository->insertIncrementalObject($objectId, $type, $date, $shopId, $languagesIsoCode); } } else { $languagesIsoCode = $languageRepository->getDefaultLanguageIsoCode(); - if (!$this->isFullSyncDone($type, $languagesIsoCode)) { - return; + if ($this->isFullSyncDone($type, $languagesIsoCode)) { + $incrementalSyncRepository->insertIncrementalObject($objectId, $type, $date, $shopId, $languagesIsoCode); } - - $incrementalSyncRepository->insertIncrementalObject($objectId, $type, $date, $shopId, $languagesIsoCode); } } From b8c9d199c8b679ddce29208fd5c21b336c2d57c8 Mon Sep 17 00:00:00 2001 From: "John.R" Date: Wed, 15 May 2024 15:04:26 +0200 Subject: [PATCH 3/3] fix: livesync --- ps_eventbus.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ps_eventbus.php b/ps_eventbus.php index 8422556c..c72a423d 100644 --- a/ps_eventbus.php +++ b/ps_eventbus.php @@ -1552,8 +1552,8 @@ public function hookActionObjectSpecificPriceDeleteAfter($parameters) */ private function sendLiveSync(string $shopContent, int $shopContentId, string $action) { - if (!$this->isFullSyncDone($shopContent)) { - return; + if ($this->isFullSyncDone($shopContent)) { + // SEND live sync only when fullsync is done } }