Merge pull request ntidev#5 from ealcantara22/fail-items-inclution

Fail items inclution
ealcantara22 · Mar 13, 2018 · 46d2b63 · 46d2b63
2 parents f19cba1 + 659e34e
commit 46d2b63
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/Service/SyncService.php b/Service/SyncService.php
@@ -62,6 +62,10 @@ public function getFromMappings($mappings) {
 
             $deletes = $this->em->getRepository(SyncDeleteState::class)->findFromTimestamp($mappingName, $timestamp);
             $newItems = $this->em->getRepository(SyncNewItemState::class)->findFromTimestampAndMapping($mappingName, $timestamp);
+	    /**
+             * Failed Items Synchronization
+             */
+            $failedItems = $this->em->getRepository('NTISyncBundle:SyncFailedItemState')->findFromTimestampAndMapping($mappingName, $timestamp);
 
             /** @var SyncRepositoryInterface $repository */
             $repository = $this->em->getRepository($syncMapping->getClass());
@@ -76,6 +80,7 @@ public function getFromMappings($mappings) {
                 'changes' => $result["data"],
                 'deletes' => json_decode($this->container->get('jms_serializer')->serialize($deletes, 'json'), true),
                 'newItems' => json_decode($this->container->get('jms_serializer')->serialize($newItems, 'json'), true),
+		'failedItems' => json_decode($this->container->get('jms_serializer')->serialize($failedItems, 'json'), true),
                 SyncState::REAL_LAST_TIMESTAMP => $result[SyncState::REAL_LAST_TIMESTAMP],
             );
         }
@@ -136,4 +141,4 @@ public function addToDeleteSyncState($class, $id) {
             error_log($ex->getMessage());
         }
     }
-}
+}